Lines Matching refs:MSG
42 MSG = 'Michael Gilfix was here\u1234\r\n'.encode('utf-8') variable
516 self.assertEqual(msg, MSG)
519 self.cli.send(MSG)
2429 self.assertEqual(msg, MSG)
2432 self.serv_conn.send(MSG)
2436 seg1 = self.cli_conn.recv(len(MSG) - 3)
2439 self.assertEqual(msg, MSG)
2442 self.serv_conn.send(MSG)
2447 self.assertEqual(msg, MSG)
2450 self.serv_conn.send(MSG)
2454 seg1, addr = self.cli_conn.recvfrom(len(MSG)-3)
2457 self.assertEqual(msg, MSG)
2460 self.serv_conn.send(MSG)
2483 self.assertEqual(msg, MSG)
2486 self.serv_conn.send(MSG)
2493 self.assertEqual(msg, MSG)
2496 self.serv_conn.send(MSG)
2501 self.assertEqual(msg, MSG)
2508 self.serv_conn.send(MSG)
2516 self.serv_conn.send(MSG)
2538 self.assertEqual(msg, MSG)
2541 self.serv_conn.send(MSG)
2551 msg = self.serv.recv(len(MSG))
2552 self.assertEqual(msg, MSG)
2555 self.cli.sendto(MSG, 0, (HOST, self.port))
2559 msg, addr = self.serv.recvfrom(len(MSG))
2560 self.assertEqual(msg, MSG)
2563 self.cli.sendto(MSG, 0, (HOST, self.port))
2570 self.cli.sendto(MSG, 0, (HOST, self.port))
2582 msg = self.serv.recv(len(MSG))
2583 self.assertEqual(msg, MSG)
2586 self.cli.sendto(MSG, 0, (HOST, self.port))
2590 msg, addr = self.serv.recvfrom(len(MSG))
2591 self.assertEqual(msg, MSG)
2594 self.cli.sendto(MSG, 0, (HOST, self.port))
2601 self.cli.sendto(MSG, 0, (HOST, self.port))
2832 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2835 self.assertEqual(self.sendmsgToServer([MSG]), len(MSG))
2839 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2842 self.assertEqual(self.sendmsgToServer((o for o in [MSG])),
2843 len(MSG))
2847 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2850 self.assertEqual(self.sendmsgToServer([MSG], (o for o in [])),
2851 len(MSG))
2855 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2858 self.assertEqual(self.sendmsgToServer([array.array("B", MSG)]),
2859 len(MSG))
2863 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2866 self.assertEqual(self.sendmsgToServer([MSG[:3], MSG[3:]]), len(MSG))
2881 [MSG, object()])
2883 [MSG], object())
2885 [MSG], [], object())
2887 [MSG], [], 0, object())
2896 [MSG], [object()])
2898 [MSG], [(object(), 0, b"data")])
2900 [MSG], [(0, object(), b"data")])
2902 [MSG], [(0, 0, object())])
2904 [MSG], [(0, 0)])
2906 [MSG], [(0, 0, b"data", 42)])
2918 [MSG], [0, 0, b""])
2920 [MSG], [(0, 0, b""), object()])
2932 self.sendmsgToServer([MSG], [(0, 0, b""), (0, 0, b"")])
2942 self.assertRaises(OSError, self.sendmsgToServer, [MSG])
2951 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2954 self.assertEqual(self.sendmsgToServer([MSG], [], 0, None), len(MSG))
3018 [MSG])
3020 [MSG], [], 0, None)
3029 msg, ancdata, flags, addr = self.doRecvmsg(self.serv_sock, len(MSG))
3030 self.assertEqual(msg, MSG)
3036 self.sendToServer(MSG)
3041 len(MSG), 0, 0)
3042 self.assertEqual(msg, MSG)
3048 self.sendToServer(MSG)
3053 len(MSG) + 42)
3054 self.assertEqual(msg, MSG)
3060 self.sendToServer(MSG)
3065 len(MSG) - 3)
3066 self.assertEqual(msg, MSG[:-3])
3072 self.sendToServer(MSG)
3077 len(MSG), 1)
3078 self.assertEqual(msg, MSG)
3084 self.sendToServer(MSG)
3089 len(MSG), 10240)
3090 self.assertEqual(msg, MSG)
3096 self.sendToServer(MSG)
3111 self.doRecvmsg, self.serv_sock, len(MSG))
3125 len(MSG) - 3, 0,
3127 self.assertEqual(msg, MSG[:-3])
3139 len(MSG), 0,
3141 self.assertEqual(msg, MSG)
3147 msg, ancdata, flags, addr = self.doRecvmsg(self.serv_sock, len(MSG))
3148 self.assertEqual(msg, MSG)
3155 self.sendToServer(MSG)
3162 msg, ancdata, flags, addr = self.doRecvmsg(self.serv_sock, len(MSG))
3163 self.assertEqual(msg, MSG)
3170 self.assertEqual(self.sendmsgToServer([MSG[:3], MSG[3:]]), len(MSG))
3191 len(MSG) - 3)
3202 self.assertEqual(msg, MSG)
3205 self.sendToServer(MSG)
3217 len(MSG), -1, 0)
3223 len(MSG), object(), 0)
3225 len(MSG), 0, object())
3227 msg, ancdata, flags, addr = self.serv_sock.recvmsg(len(MSG), 0, 0)
3228 self.assertEqual(msg, MSG)
3234 self.sendToServer(MSG)
3242 buf = bytearray(len(MSG))
3245 len(MSG), 0, 0)
3262 self.assertEqual(nbytes, len(MSG))
3263 self.assertEqual(buf, bytearray(MSG))
3269 self.sendToServer(MSG)
3273 buf = bytearray(len(MSG))
3276 self.assertEqual(nbytes, len(MSG))
3277 self.assertEqual(buf, bytearray(MSG))
3283 self.sendToServer(MSG)
3287 buf = array.array("B", [0] * len(MSG))
3289 self.assertEqual(nbytes, len(MSG))
3290 self.assertEqual(buf.tobytes(), MSG)
3296 self.sendToServer(MSG)
3422 self.sendmsgToServer([MSG],
3426 len(MSG))
3435 self.assertEqual(msg, MSG)
3458 len(MSG), 10240))
3463 [MSG],
3467 len(MSG))
3472 len(MSG), 10240))
3481 4, self.doRecvmsg(self.serv_sock, len(MSG),
3491 self.doRecvmsg(self.serv_sock, len(MSG),
3508 self.doRecvmsg(self.serv_sock, len(MSG), 10240),
3517 self.sendmsgToServer([MSG], [(socket.SOL_SOCKET,
3523 len(MSG))
3533 self.doRecvmsg(self.serv_sock, len(MSG),
3544 self.sendmsgToServer([MSG], [(socket.SOL_SOCKET,
3550 len(MSG))
3568 len(MSG), 10240),
3572 self.sendAncillaryIfPossible(MSG, [(socket.SOL_SOCKET,
3579 len(MSG), 10240)
3580 self.assertEqual(msg, MSG)
3591 MSG,
3600 len(MSG), 10240)
3601 self.assertEqual(msg, MSG)
3619 MSG,
3631 self.assertEqual(msg, MSG)
3640 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG)),
3651 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG), 0),
3661 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG), 1))
3670 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG),
3677 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG),
3692 len(MSG), ancbuf)
3693 self.assertEqual(msg, MSG)
3773 len(MSG), ancbufsize)
3775 self.assertEqual(msg, MSG)
3803 self.sendToServer(MSG)
3813 self.sendToServer(MSG)
3831 self.sendmsgToServer([MSG],
3834 len(MSG))
3849 len(MSG), ancbufsize)
3851 self.assertEqual(msg, MSG)
3881 self.sendToServer(MSG)
3894 self.sendToServer(MSG)
3909 self.sendmsgToServer([MSG],
3914 len(MSG))
3931 [MSG],
3939 [MSG],
3944 self.assertEqual(nbytes, len(MSG))
3960 len(MSG), *args)
3962 self.assertEqual(msg, MSG)
3982 self.sendToServer(MSG)
3994 self.sendToServer(MSG)
4006 self.sendToServer(MSG)
4015 self.sendToServer(MSG)
4024 self.sendToServer(MSG)
4035 self.serv_sock, len(MSG), socket.CMSG_LEN(SIZEOF_INT) - 1)
4037 self.assertEqual(msg, MSG)
4051 self.sendToServer(MSG)
4066 len(MSG), ancbufsize)
4068 self.assertEqual(msg, MSG)
4094 self.sendToServer(MSG)
4104 self.sendToServer(MSG)
4115 self.sendToServer(MSG)
4126 self.sendToServer(MSG)
4139 self.serv_sock, len(MSG),
4142 self.assertEqual(msg, MSG)
4168 self.sendToServer(MSG)
4592 self.assertEqual(msg, MSG)
4595 self.cli.send(MSG)
4598 self.serv.send(MSG)
4602 self.assertEqual(msg, MSG)
4742 msg = conn.recv(len(MSG))
4751 msg = conn.recv(len(MSG))
4752 self.assertEqual(msg, MSG)
4762 self.cli.sendall(MSG)
4783 read_msg = MSG
4785 write_msg = MSG
4895 msg = self.cli_conn.recv(len(MSG))
5050 read_msg = MSG.decode('utf-8')
5052 write_msg = MSG
5060 read_msg = MSG
5062 write_msg = MSG.decode('utf-8')
5070 read_msg = MSG.decode('utf-8')
5072 write_msg = MSG.decode('utf-8')
5502 buf = array.array("B", [0] * len(MSG))
5504 self.assertEqual(nbytes, len(MSG))
5506 msg = buf[:len(MSG)]
5507 self.assertEqual(msg, MSG)
5510 buf = bytes(MSG)
5516 self.assertEqual(nbytes, len(MSG))
5517 msg = buf[:len(MSG)]
5518 self.assertEqual(msg, MSG)
5525 self.assertEqual(nbytes, len(MSG))
5526 msg = buf[:len(MSG)]
5527 self.assertEqual(msg, MSG)
5532 buf = array.array("B", [0] * len(MSG))
5534 self.assertEqual(nbytes, len(MSG))
5536 msg = buf[:len(MSG)]
5537 self.assertEqual(msg, MSG)
5540 buf = bytes(MSG)
5546 self.assertEqual(nbytes, len(MSG))
5547 msg = buf[:len(MSG)]
5548 self.assertEqual(msg, MSG)
5555 self.assertEqual(nbytes, len(MSG))
5556 msg = buf[:len(MSG)]
5557 self.assertEqual(msg, MSG)
5567 self.serv_conn.send(MSG)
5617 cli.sendto(MSG, sendaddr)
5622 self.assertEqual(msg, MSG)
5658 self.assertEqual(msg, MSG)
5662 self.cli.send(MSG)
6578 socket.send_fds(sock1, [MSG], fds)
6580 msg, fds2, flags, addr = socket.recv_fds(sock2, len(MSG) * 2, len(fds) * 2)
6583 self.assertEqual(msg, MSG)