| Server IP : 91.108.119.25 / Your IP : 216.73.217.1 Web Server : LiteSpeed System : Linux id-dci-web1986.main-hosting.eu 5.14.0-611.26.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Jan 29 05:24:47 EST 2026 x86_64 User : u686484674 ( 686484674) PHP Version : 8.0.30 Disable Function : system, exec, shell_exec, passthru, mysql_list_dbs, ini_alter, dl, symlink, link, chgrp, leak, popen, apache_child_terminate, virtual, mb_send_mail MySQL : OFF | cURL : ON | WGET : ON | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /proc/self/root/opt/alt/python311/lib/python3.11/site-packages/pyroute2/netlink/generic/ |
Upload File : |
from socket import AF_INET, AF_INET6
from pyroute2.netlink import NLM_F_ACK, NLM_F_DUMP, NLM_F_REQUEST, genlmsg, nla
from pyroute2.netlink.generic import GenericNetlinkSocket
MPTCP_GENL_NAME = 'mptcp_pm'
MPTCP_PM_CMD_UNSPEC = 0
MPTCP_PM_CMD_ADD_ADDR = 1
MPTCP_PM_CMD_DEL_ADDR = 2
MPTCP_PM_CMD_GET_ADDR = 3
MPTCP_PM_CMD_FLUSH_ADDRS = 4
MPTCP_PM_CMD_SET_LIMITS = 5
MPTCP_PM_CMD_GET_LIMITS = 6
MPTCP_PM_CMD_SET_FLAGS = 7
class mptcp_msg(genlmsg):
prefix = 'MPTCP_PM_ATTR_'
nla_map = (
('MPTCP_PM_ATTR_UNSPEC', 'none'),
('MPTCP_PM_ATTR_ADDR', 'pm_addr'),
('MPTCP_PM_ATTR_RCV_ADD_ADDRS', 'uint32'),
('MPTCP_PM_ATTR_SUBFLOWS', 'uint32'),
)
class pm_addr(nla):
prefix = 'MPTCP_PM_ADDR_ATTR_'
nla_map = (
('MPTCP_PM_ADDR_ATTR_UNSPEC', 'none'),
('MPTCP_PM_ADDR_ATTR_FAMILY', 'uint16'),
('MPTCP_PM_ADDR_ATTR_ID', 'uint8'),
('MPTCP_PM_ADDR_ATTR_ADDR4', 'ipaddr'),
('MPTCP_PM_ADDR_ATTR_ADDR6', 'ipaddr'),
('MPTCP_PM_ADDR_ATTR_PORT', 'uint16'),
('MPTCP_PM_ADDR_ATTR_FLAGS', 'uint32'),
('MPTCP_PM_ADDR_ATTR_IF_IDX', 'hex'),
)
class MPTCP(GenericNetlinkSocket):
def __init__(self, ext_ack=True):
super(MPTCP, self).__init__(ext_ack=ext_ack)
try:
self.bind(MPTCP_GENL_NAME, mptcp_msg)
except Exception as e:
self.close()
raise e
def endpoint(self, cmd, **kwarg):
'''
Usage::
mptcp.endpoint('show')
mptcp.endpoint('add', addr='172.17.20.2')
mptcp.endpoint('del', id=4)
mptcp.endpoint('flush')
Argument `addr` is equal to `addr4` and implies `family=AF_INET`,
while `addr6` implies `family=AF_INET6`
'''
flags_dump = NLM_F_REQUEST | NLM_F_DUMP
flags_base = NLM_F_REQUEST | NLM_F_ACK
commands = {
'show': (MPTCP_PM_CMD_GET_ADDR, flags_dump),
'add': (MPTCP_PM_CMD_ADD_ADDR, flags_base),
'del': (MPTCP_PM_CMD_DEL_ADDR, flags_base),
'flush': (MPTCP_PM_CMD_FLUSH_ADDRS, flags_base),
}
(command, flags) = commands.get(cmd, cmd)
msg = mptcp_msg()
msg['cmd'] = command
msg['version'] = 1
if cmd in ('add', 'del'):
addr_info = {'attrs': []}
if 'addr' in kwarg:
kwarg['addr4'] = kwarg.pop('addr')
if 'addr4' in kwarg:
kwarg['family'] = AF_INET
elif 'addr6' in kwarg:
kwarg['family'] = AF_INET6
for key, value in kwarg.items():
addr_info['attrs'].append(
(mptcp_msg.pm_addr.name2nla(key), value)
)
msg['attrs'] = [('MPTCP_PM_ATTR_ADDR', addr_info, 0x8000)]
return self.nlm_request(msg, msg_type=self.prid, msg_flags=flags)
def limits(self, cmd, **kwarg):
'''
Usage::
mptcp.limits('show')
mptcp.limits('set', subflows=10)
'''
flags_dump = NLM_F_REQUEST
flags_base = NLM_F_REQUEST | NLM_F_ACK
commands = {
'show': (MPTCP_PM_CMD_GET_LIMITS, flags_dump),
'set': (MPTCP_PM_CMD_SET_LIMITS, flags_base),
}
(command, flags) = commands.get(cmd, cmd)
msg = mptcp_msg()
msg['cmd'] = command
msg['version'] = 1
if cmd == 'set':
if not set(kwarg) < set(
('subflows', 'rcv_add_addrs', 'add_addr_accepted')
):
raise TypeError('invalid parameter')
for key, value in kwarg.items():
if key == 'add_addr_accepted':
key = 'rcv_add_addrs'
msg['attrs'].append((mptcp_msg.name2nla(key), value))
return self.nlm_request(msg, msg_type=self.prid, msg_flags=flags)