Lines Matching defs:self

88     def __init__(self, family, port=1234):
89 self._libc = ctypes.CDLL("libc.so.7", use_errno=True)
91 self._listen_fd = self._libc.socket(family, socket.SOCK_STREAM, socket.IPPROTO_SCTP)
92 if self._listen_fd == -1:
108 ret = self._libc.bind(self._listen_fd, ctypes.pointer(srvaddr),
113 ret = self._libc.listen(self._listen_fd, 2)
117 def _to_string(self, buf):
120 def accept(self, vnet):
121 fd = self._libc.accept(self._listen_fd, 0, 0)
132 ret = self._libc.sctp_recvmsg(fd, ctypes.cast(buf, ctypes.c_void_p), 128,
142 rcvd['data'] = self._to_string(buf)
148 def __init__(self, ip, port=1234, fromaddr=None):
149 self._libc = ctypes.CDLL("libc.so.7", use_errno=True)
156 self._fd = self._libc.socket(family, socket.SOCK_STREAM,
158 if self._fd == -1:
164 ret = self._libc.bind(self._fd, ctypes.pointer(addr), ctypes.sizeof(addr))
170 ret = self._libc.connect(self._fd, ctypes.pointer(addr), ctypes.sizeof(addr))
177 ret = self._libc.setsockopt(self._fd, socket.IPPROTO_SCTP,
180 def newpeer(self, addr):
191 ret = self._libc.setsockopt(self._fd, socket.IPPROTO_SCTP,
197 def newprimary(self, addr):
210 ret = self._libc.setsockopt(self._fd, socket.IPPROTO_SCTP,
216 def bindx(self, addr, add):
225 ret = self._libc.sctp_bindx(self._fd, ctypes.pointer(addr), 1, flag)
230 def send(self, buf, ppid, ordered=False):
237 ret = self._libc.sctp_sendmsg(self._fd, ctypes.c_char_p(buf), len(buf),
242 def close(self):
243 self._libc.close(self._fd)
244 self._fd = -1
254 def vnet2_handler(self, vnet):
265 def test_multihome(self):
266 srv_vnet = self.vnet_map["vnet2"]
277 rcvd = self.wait_object(srv_vnet.pipe)
285 rcvd = self.wait_object(srv_vnet.pipe)
300 def test_multihome_asconf(self):
301 srv_vnet = self.vnet_map["vnet2"]
305 % self.vnet.iface_alias_map["if1"].name)
315 rcvd = self.wait_object(srv_vnet.pipe)
325 rcvd = self.wait_object(srv_vnet.pipe)
334 rcvd = self.wait_object(srv_vnet.pipe, 5)
353 rcvd = self.wait_object(srv_vnet.pipe, 5)
367 def test_permutation_if_bound(self):
370 srv_vnet = self.vnet_map["vnet2"]
372 ifname = self.vnet_map["vnet1"].iface_alias_map["if1"].name
385 rcvd = self.wait_object(srv_vnet.pipe)
399 def test_permutation_floating(self):
402 srv_vnet = self.vnet_map["vnet2"]
404 ifname = self.vnet_map["vnet1"].iface_alias_map["if1"].name
416 rcvd = self.wait_object(srv_vnet.pipe)
430 def test_disallow_related(self):
431 srv_vnet = self.vnet_map["vnet2"]
442 rcvd = self.wait_object(srv_vnet.pipe)
452 rcvd = self.wait_object(srv_vnet.pipe)
467 def test_allow_related(self):
468 srv_vnet = self.vnet_map["vnet2"]
480 rcvd = self.wait_object(srv_vnet.pipe)
489 rcvd = self.wait_object(srv_vnet.pipe)
513 def vnet2_handler(self, vnet):
524 def test_multihome(self):
525 srv_vnet = self.vnet_map["vnet2"]
536 rcvd = self.wait_object(srv_vnet.pipe)
545 rcvd = self.wait_object(srv_vnet.pipe)
559 def test_multihome_asconf(self):
560 srv_vnet = self.vnet_map["vnet2"]
564 % self.vnet.iface_alias_map["if1"].name)
574 rcvd = self.wait_object(srv_vnet.pipe)
584 rcvd = self.wait_object(srv_vnet.pipe)
593 rcvd = self.wait_object(srv_vnet.pipe, 5)
612 rcvd = self.wait_object(srv_vnet.pipe, 5)
625 def test_permutation(self):
628 srv_vnet = self.vnet_map["vnet2"]
630 ifname = self.vnet_map["vnet1"].iface_alias_map["if1"].name
643 rcvd = self.wait_object(srv_vnet.pipe)
657 def test_permutation_floating(self):
660 srv_vnet = self.vnet_map["vnet2"]
662 ifname = self.vnet_map["vnet1"].iface_alias_map["if1"].name
674 rcvd = self.wait_object(srv_vnet.pipe)