-
-
Notifications
You must be signed in to change notification settings - Fork 244
performance
Peter V. Saveliev edited this page Jun 15, 2016
·
5 revisions
- IPDB
- (+) init subsystems on demand
- interfaces
- routes
- rules
- (+) init subsystems on demand
- parser
- (-) add a setting to drop the msg_seq locking — for threadless applications
- RX path
- avoid buffer copying
- (+)
socket.recv_into() - (+)
struct.unpack_from()
- (+)
- (+) NLA fast tracks: zstring, string, packed (+nla), generic (+nla)
- (+) cache lookups instead of
unpack()for NLA headers
- avoid buffer copying
- TX path
- (!) bottleneck:
socket.sendto():
- (!) bottleneck:
Line # Hits Time Per Hit % Time Line Contents
==============================================================
76 @profile
77 def _gate(self, msg, addr):
78 230 1549 6.7 0.2 msg.reset()
79 230 60965 265.1 6.5 msg.encode()
80 230 11351 49.4 1.2 ret = self._sproxy.handle(msg)
81 230 524 2.3 0.1 if ret is not None:
82 100 222 2.2 0.0 if ret['verdict'] == 'forward':
83 100 406408 4064.1 43.6 return self._sendto(ret['data'], addr)
84 elif ret['verdict'] in ('return', 'error'):
85 if self._s_channel is not None:
86 return self._s_channel.send(ret['data'])
87 else:
88 msgs = self.marshal.parse(ret['data'])
89 for msg in msgs:
90 seq = msg['header']['sequence_number']
91 if seq in self.backlog:
92 self.backlog[seq].append(msg)
93 else:
94 self.backlog[seq] = [msg]
95 return len(ret['data'])
96 else:
97 ValueError('Incorrect verdict')
98
99 130 450966 3469.0 48.4 return self._sendto(msg.data, addr)