core: asyncio prototype

pyroute2/iproute/linux.py

@@ -1,4 +1,5 @@
 # -*- coding: utf-8 -*-
+import json
 import logging
 import os
 import time
@@ -25,6 +26,7 @@
  NetlinkError,
  SkipInode,
 )
+from pyroute2.netlink.nlsocket import IPCSocket
 from pyroute2.netlink.rtnl import (
  RTM_DELADDR,
  RTM_DELLINK,
@@ -83,6 +85,7 @@
  IPBatchSocket,
  IPRSocket,
 )
+from pyroute2.netlink.rtnl.marshal import MarshalRtnl
 from pyroute2.netlink.rtnl.ndtmsg import ndtmsg
 from pyroute2.netlink.rtnl.nsidmsg import nsidmsg
 from pyroute2.netlink.rtnl.nsinfmsg import nsinfmsg
@@ -91,6 +94,9 @@
 from pyroute2.netlink.rtnl.rtmsg import rtmsg
 from pyroute2.netlink.rtnl.tcmsg import plugins as tc_plugins
 from pyroute2.netlink.rtnl.tcmsg import tcmsg
+from pyroute2.netns import setns
+from pyroute2.plan9 import Tcall
+from pyroute2.plan9.server import Plan9Server
 from pyroute2.requests.address import AddressFieldFilter, AddressIPRouteFilter
 from pyroute2.requests.bridge import (
  BridgeFieldFilter,
@@ -2597,6 +2603,38 @@ class IPRoute(LAB_API, RTNL_API, IPRSocket):
  pass
 
 
+def ipr_call(session, inode, req, response):
+ arg = json.loads(req['text'])
+ data = req['data']
+ if data:
+ arg['kwarg']['data'] = data
+ response['err'] = 0
+ ret = getattr(session.ipr, arg['call'])(*arg['argv'], **arg['kwarg'])
+ if isinstance(ret, bytes):
+ response['data'] = ret
+ response['text'] = ''
+ else:
+ response['data'] = b''
+ response['text'] = json.dumps(ret)
+ return response
+
+
+class NetNS(RTNL_API, IPCSocket):
+
+ def __init__(self, netns):
+ super().__init__(target=netns)
+ self.marshal = MarshalRtnl()
+
+ def ipc_server(self):
+ setns(self.status['target'])
+ p9 = Plan9Server(use_socket=self.socket.server)
+ p9.filesystem.create('call').add_callback(Tcall, ipr_call)
+ p9.filesystem.create('log')
+ connection = p9.accept()
+ connection.session.ipr = IPRoute()
+ connection.serve()
+
+
 class RawIPRoute(RTNL_API, RawIPRSocket):
  '''
  The same as `IPRoute`, but does not use the netlink proxy.

pyroute2/netlink/__init__.py

@@ -1754,7 +1754,7 @@ def ft_encode(self, offset):
  else:
  zs = 0
  for name, fmt in self.fields:
- default = self.defaults.get(name)
+ default = self.defaults.get(name, 0)
  value = self[name] if name in self else default
  if value is None:
  continue