Lines Matching refs:recv
515 msg = self.conn.recv(1024)
2497 msg = self.cli_conn.recv(1024)
2505 seg1 = self.cli_conn.recv(len(MSG) - 3)
2506 seg2 = self.cli_conn.recv(1024)
2535 read = self.cli_conn.recv(1024)
2551 msg = sock.recv(1024)
2561 msg = sock.recv(1024)
2569 msg = self.cli_conn.recv(1024)
2600 self.assertRaises(OSError, self.cli_conn.recv, 1024)
2606 msg = sock.recv(1024)
2620 msg = self.serv.recv(len(MSG))
2651 msg = self.serv.recv(len(MSG))
2901 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2908 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2916 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2924 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2932 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2939 self.assertEqual(self.serv_sock.recv(1000), b"done")
2961 self.assertEqual(self.serv_sock.recv(1000), b"done")
2982 self.assertEqual(self.serv_sock.recv(1000), b"done")
2995 self.assertEqual(self.serv_sock.recv(1000), b"done")
3020 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
3027 self.assertEqual(self.serv_sock.recv(512), b"a"*512)
3058 self.assertEqual(self.serv_sock.recv(512), b"a"*512)
4521 # Test interrupting the recv*() methods with signals when a
4539 self.checkInterruptedRecv(self.serv.recv, 1024)
4628 self.assertEqual(sd.recv(1), b'')
4660 msg = self.serv.recv(1024)
4670 msg = self.cli.recv(1024)
4689 # sock.recv(), and other socket operations use a select() call and
4804 # Testing non-blocking recv
4809 # the server didn't send data yet: non-blocking recv() fails
4811 msg = conn.recv(len(MSG))
4819 # the server sent data yet: non-blocking recv() doesn't block
4820 msg = conn.recv(len(MSG))
4827 # that non-blocking recv() raises BlockingIOError
4830 # send data: recv() will no longer block
4964 msg = self.cli_conn.recv(len(MSG))
5025 msg = self.cli_conn.recv(1024)
5029 self.assertRaises(OSError, self.cli_conn.recv, 1024)
5073 # otherwise system recv() will return 0 instead of EWOULDBLOCK.
5333 data = sock.recv(5)
5338 self.assertRaises(TimeoutError, lambda: sock.recv(5))
5403 self.serv.recv(1024)
5411 foo = self.serv.recv(1024)
5419 self.fail("recv() returned success when we did not expect it")
5428 self.serv.recv(1024)
5436 foo = self.serv.recv(1024)
5444 self.fail("recv() returned success when we did not expect it")
5602 Test the buffer versions of socket.recv() and socket.send().
5763 msg = self.conn.recv(1024)
5791 data = conn.recv(1024)
5799 self.assertEqual(sock.recv(1024), b'foo')
5805 data = conn.recv(1024)
5898 # object, "blocking" means that operations like 'sock.recv()'
5901 # *non-blocking* mode, and 'sock.recv()' uses 'select()'
5990 data = s.recv(100)
6091 chunk = conn.recv(self.BUFSIZE)
6247 if conn.recv(8192):
6280 conn.recv(88192)
6347 self.assertEqual(op.recv(512), expected)
6355 self.assertEqual(op.recv(512), expected)
6364 self.assertEqual(op.recv(512), expected)
6382 self.assertEqual(op.recv(msglen), ciphertext)
6388 self.assertEqual(op.recv(msglen), msg)
6397 enc = op.recv(msglen * multiplier)
6405 dec = op.recv(msglen * multiplier)
6433 res = op.recv(assoclen + len(plain) + taglen)
6443 res = op.recv(assoclen + len(plain) + taglen)
6459 res = op.recv(len(msg) + taglen)
6469 res = op.recv(len(msg) - taglen)
6480 rn = op.recv(32)
6608 msg = conn.recv(1024)
6625 self.assertEqual(sock.recv(1024), b'foo')