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_hfsc.py (2353B)

'''
hfsc
++++

Simple HFSC example::

eth0 = ip.get_links(ifname="eth0")[0]
    ip.tc("add", "hfsc", eth0,
          handle="1:",
          default="1:1")
    ip.tc("add-class", "hfsc", eth0,
          handle="1:1",
          parent="1:0"
          rsc={"m2": "5mbit"})

HFSC curve nla types:

* `rsc`: real-time curve
* `fsc`: link-share curve
* `usc`: upper-limit curve
'''

from pyroute2.netlink import nla
from pyroute2.netlink.rtnl import RTM_DELQDISC, RTM_NEWQDISC, TC_H_ROOT
from pyroute2.netlink.rtnl.tcmsg.common import get_rate, get_time
from pyroute2.netlink.rtnl.tcmsg.common import stats2 as c_stats2

parent = TC_H_ROOT

def get_parameters(kwarg):
    defcls = kwarg.get('default', kwarg.get('defcls', 0x10))
    defcls &= 0xFFFF
    return {'defcls': defcls}

def get_class_parameters(kwarg):
    ret = {'attrs': []}
    for key in ('rsc', 'fsc', 'usc'):
        if key in kwarg:
            ret['attrs'].append(
                [
                    'TCA_HFSC_%s' % key.upper(),
                    {
                        'm1': get_rate(kwarg[key].get('m1', 0)),
                        'd': get_time(kwarg[key].get('d', 0)),
                        'm2': get_rate(kwarg[key].get('m2', 0)),
                    },
                ]
            )
    return ret

class options_hfsc(nla):
    fields = (('defcls', 'H'),)  # default class

class options_hfsc_class(nla):
    nla_map = (
        ('TCA_HFSC_UNSPEC', 'none'),
        ('TCA_HFSC_RSC', 'hfsc_curve'),  # real-time curve
        ('TCA_HFSC_FSC', 'hfsc_curve'),  # link-share curve
        ('TCA_HFSC_USC', 'hfsc_curve'),
    )  # upper-limit curve

class hfsc_curve(nla):
        fields = (
            ('m1', 'I'),  # slope of the first segment in bps
            ('d', 'I'),  # x-projection of the first segment in us
            ('m2', 'I'),
        )  # slope of the second segment in bps

def options(msg, *argv, **kwarg):
    if msg['header']['type'] in (RTM_NEWQDISC, RTM_DELQDISC):
        return options_hfsc
    else:
        return options_hfsc_class

class stats2(c_stats2):
    class stats_app(nla):
        fields = (
            ('work', 'Q'),  # total work done
            ('rtwork', 'Q'),  # total work done by real-time criteria
            ('period', 'I'),  # current period
            ('level', 'I'),
        )  # class level in hierarchy

cmd: