FM / tcmsg

/opt/imh-python/lib/python3.9/site-packages/pyroute2/netlink/rtnl/tcmsg/

/opt/imh-python/lib/python3.9/site-packages/pyroute2/netlink/rtnl/tcmsg

Name	Size	Mode	Actions
__pycache__/	-	0755	rm
act_bpf.py	979	0644	edit dl rm
act_connmark.py	1234	0644	edit dl rm
act_gact.py	709	0644	edit dl rm
act_mirred.py	1725	0644	edit dl rm
act_police.py	1866	0644	edit dl rm
act_skbedit.py	3337	0644	edit dl rm
act_vlan.py	1465	0644	edit dl rm
cls_basic.py	8478	0644	edit dl rm
cls_flow.py	4613	0644	edit dl rm
cls_fw.py	1427	0644	edit dl rm
cls_matchall.py	986	0644	edit dl rm
cls_u32.py	8034	0644	edit dl rm
common.py	10728	0644	edit dl rm
common_act.py	2063	0644	edit dl rm
common_ematch.py	3148	0644	edit dl rm
em_cmp.py	2776	0644	edit dl rm
em_ipset.py	1741	0644	edit dl rm
em_meta.py	5933	0644	edit dl rm
sched_bpf.py	2571	0644	edit dl rm
sched_cake.py	12833	0644	edit dl rm
sched_choke.py	3432	0644	edit dl rm
sched_clsact.py	1011	0644	edit dl rm
sched_codel.py	1607	0644	edit dl rm
sched_drr.py	755	0644	edit dl rm
sched_fq_codel.py	2658	0644	edit dl rm
sched_hfsc.py	2353	0644	edit dl rm
sched_htb.py	5739	0644	edit dl rm
sched_ingress.py	214	0644	edit dl rm
sched_netem.py	5142	0644	edit dl rm
sched_pfifo.py	196	0644	edit dl rm
sched_pfifo_fast.py	215	0644	edit dl rm
sched_plug.py	446	0644	edit dl rm
sched_sfq.py	2717	0644	edit dl rm
sched_tbf.py	1087	0644	edit dl rm
sched_template.py	1250	0644	edit dl rm
__init__.py	2743	0644	edit dl rm

Edit: /opt/imh-python/lib/python3.9/site-packages/pyroute2/netlink/rtnl/tcmsg/sched_sfq.py (2717B)

from pyroute2.netlink import nla
from pyroute2.netlink.rtnl import TC_H_ROOT
from pyroute2.netlink.rtnl.tcmsg.common import (
    get_size,
    red_eval_ewma,
    red_eval_P,
)

parent = TC_H_ROOT

TC_RED_ECN = 1
TC_RED_HARDDROP = 2
TC_RED_ADAPTATIVE = 4

def get_parameters(kwarg):
    kwarg['quantum'] = get_size(kwarg.get('quantum', 0))
    kwarg['perturb_period'] = kwarg.get('perturb', 0) or kwarg.get(
        'perturb_period', 0
    )
    limit = kwarg['limit'] = kwarg.get('limit', 0) or kwarg.get(
        'redflowlimit', 0
    )
    qth_min = kwarg.get('min', 0)
    qth_max = kwarg.get('max', 0)
    avpkt = kwarg.get('avpkt', 1000)
    probability = kwarg.get('probability', 0.02)
    ecn = kwarg.get('ecn', False)
    harddrop = kwarg.get('harddrop', False)
    kwarg['flags'] = kwarg.get('flags', 0)
    if ecn:
        kwarg['flags'] |= TC_RED_ECN
    if harddrop:
        kwarg['flags'] |= TC_RED_HARDDROP
    if kwarg.get('redflowlimit'):
        qth_max = qth_max or limit / 4
        qth_min = qth_min or qth_max / 3
        kwarg['burst'] = kwarg['burst'] or (2 * qth_min + qth_max) / (
            3 * avpkt
        )
        if limit <= qth_max:
            raise ValueError('limit must be > qth_max')
        if qth_max <= qth_min:
            raise ValueError('qth_max must be > qth_min')
        kwarg['qth_min'] = qth_min
        kwarg['qth_max'] = qth_max
        kwarg['Wlog'] = red_eval_ewma(qth_min, kwarg['burst'], avpkt)
        kwarg['Plog'] = red_eval_P(qth_min, qth_max, probability)
        if kwarg['Wlog'] < 0:
            raise ValueError('Wlog must be > 0')
        if kwarg['Plog'] < 0:
            raise ValueError('Plog must be > 0')
        kwarg['max_P'] = int(probability * pow(2, 23))

return kwarg

class options_sfq_v0(nla):
    fields = (
        ('quantum', 'I'),
        ('perturb_period', 'i'),
        ('limit', 'I'),
        ('divisor', 'I'),
        ('flows', 'I'),
    )

class options_sfq_v1(nla):
    fields = (
        ('quantum', 'I'),
        ('perturb_period', 'i'),
        ('limit_v0', 'I'),
        ('divisor', 'I'),
        ('flows', 'I'),
        ('depth', 'I'),
        ('headdrop', 'I'),
        ('limit_v1', 'I'),
        ('qth_min', 'I'),
        ('qth_max', 'I'),
        ('Wlog', 'B'),
        ('Plog', 'B'),
        ('Scell_log', 'B'),
        ('flags', 'B'),
        ('max_P', 'I'),
        ('prob_drop', 'I'),
        ('forced_drop', 'I'),
        ('prob_mark', 'I'),
        ('forced_mark', 'I'),
        ('prob_mark_head', 'I'),
        ('forced_mark_head', 'I'),
    )

def options(*argv, **kwarg):
    if kwarg.get('length', 0) >= options_sfq_v1.get_size():
        return options_sfq_v1
    else:
        return options_sfq_v0

from pyroute2.netlink import nla from pyroute2.netlink.rtnl import TC_H_ROOT from pyroute2.netlink.rtnl.tcmsg.common import ( get_size, red_eval_ewma, red_eval_P, ) parent = TC_H_ROOT TC_RED_ECN = 1 TC_RED_HARDDROP = 2 TC_RED_ADAPTATIVE = 4 def get_parameters(kwarg): kwarg['quantum'] = get_size(kwarg.get('quantum', 0)) kwarg['perturb_period'] = kwarg.get('perturb', 0) or kwarg.get( 'perturb_period', 0 ) limit = kwarg['limit'] = kwarg.get('limit', 0) or kwarg.get( 'redflowlimit', 0 ) qth_min = kwarg.get('min', 0) qth_max = kwarg.get('max', 0) avpkt = kwarg.get('avpkt', 1000) probability = kwarg.get('probability', 0.02) ecn = kwarg.get('ecn', False) harddrop = kwarg.get('harddrop', False) kwarg['flags'] = kwarg.get('flags', 0) if ecn: kwarg['flags'] |= TC_RED_ECN if harddrop: kwarg['flags'] |= TC_RED_HARDDROP if kwarg.get('redflowlimit'): qth_max = qth_max or limit / 4 qth_min = qth_min or qth_max / 3 kwarg['burst'] = kwarg['burst'] or (2 * qth_min + qth_max) / ( 3 * avpkt ) if limit <= qth_max: raise ValueError('limit must be > qth_max') if qth_max <= qth_min: raise ValueError('qth_max must be > qth_min') kwarg['qth_min'] = qth_min kwarg['qth_max'] = qth_max kwarg['Wlog'] = red_eval_ewma(qth_min, kwarg['burst'], avpkt) kwarg['Plog'] = red_eval_P(qth_min, qth_max, probability) if kwarg['Wlog'] < 0: raise ValueError('Wlog must be > 0') if kwarg['Plog'] < 0: raise ValueError('Plog must be > 0') kwarg['max_P'] = int(probability * pow(2, 23)) return kwarg class options_sfq_v0(nla): fields = ( ('quantum', 'I'), ('perturb_period', 'i'), ('limit', 'I'), ('divisor', 'I'), ('flows', 'I'), ) class options_sfq_v1(nla): fields = ( ('quantum', 'I'), ('perturb_period', 'i'), ('limit_v0', 'I'), ('divisor', 'I'), ('flows', 'I'), ('depth', 'I'), ('headdrop', 'I'), ('limit_v1', 'I'), ('qth_min', 'I'), ('qth_max', 'I'), ('Wlog', 'B'), ('Plog', 'B'), ('Scell_log', 'B'), ('flags', 'B'), ('max_P', 'I'), ('prob_drop', 'I'), ('forced_drop', 'I'), ('prob_mark', 'I'), ('forced_mark', 'I'), ('prob_mark_head', 'I'), ('forced_mark_head', 'I'), ) def options(*argv, **kwarg): if kwarg.get('length', 0) >= options_sfq_v1.get_size(): return options_sfq_v1 else: return options_sfq_v0