Lines Matching refs:MSG
37 MSG = 'Michael Gilfix was here\u1234\r\n'.encode('utf-8') ## test unicode string and carriage return variable
445 self.assertEqual(msg, MSG)
448 self.cli.send(MSG)
2116 self.assertEqual(msg, MSG)
2119 self.serv_conn.send(MSG)
2123 seg1 = self.cli_conn.recv(len(MSG) - 3)
2126 self.assertEqual(msg, MSG)
2129 self.serv_conn.send(MSG)
2134 self.assertEqual(msg, MSG)
2137 self.serv_conn.send(MSG)
2141 seg1, addr = self.cli_conn.recvfrom(len(MSG)-3)
2144 self.assertEqual(msg, MSG)
2147 self.serv_conn.send(MSG)
2170 self.assertEqual(msg, MSG)
2173 self.serv_conn.send(MSG)
2180 self.assertEqual(msg, MSG)
2183 self.serv_conn.send(MSG)
2188 self.assertEqual(msg, MSG)
2195 self.serv_conn.send(MSG)
2203 self.serv_conn.send(MSG)
2225 self.assertEqual(msg, MSG)
2228 self.serv_conn.send(MSG)
2238 msg = self.serv.recv(len(MSG))
2239 self.assertEqual(msg, MSG)
2242 self.cli.sendto(MSG, 0, (HOST, self.port))
2246 msg, addr = self.serv.recvfrom(len(MSG))
2247 self.assertEqual(msg, MSG)
2250 self.cli.sendto(MSG, 0, (HOST, self.port))
2257 self.cli.sendto(MSG, 0, (HOST, self.port))
2488 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2491 self.assertEqual(self.sendmsgToServer([MSG]), len(MSG))
2495 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2498 self.assertEqual(self.sendmsgToServer((o for o in [MSG])),
2499 len(MSG))
2503 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2506 self.assertEqual(self.sendmsgToServer([MSG], (o for o in [])),
2507 len(MSG))
2511 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2514 self.assertEqual(self.sendmsgToServer([array.array("B", MSG)]),
2515 len(MSG))
2519 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2522 self.assertEqual(self.sendmsgToServer([MSG[:3], MSG[3:]]), len(MSG))
2537 [MSG, object()])
2539 [MSG], object())
2541 [MSG], [], object())
2543 [MSG], [], 0, object())
2552 [MSG], [object()])
2554 [MSG], [(object(), 0, b"data")])
2556 [MSG], [(0, object(), b"data")])
2558 [MSG], [(0, 0, object())])
2560 [MSG], [(0, 0)])
2562 [MSG], [(0, 0, b"data", 42)])
2574 [MSG], [0, 0, b""])
2576 [MSG], [(0, 0, b""), object()])
2588 self.sendmsgToServer([MSG], [(0, 0, b""), (0, 0, b"")])
2598 self.assertRaises(OSError, self.sendmsgToServer, [MSG])
2607 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2610 self.assertEqual(self.sendmsgToServer([MSG], [], 0, None), len(MSG))
2674 [MSG])
2676 [MSG], [], 0, None)
2685 msg, ancdata, flags, addr = self.doRecvmsg(self.serv_sock, len(MSG))
2686 self.assertEqual(msg, MSG)
2692 self.sendToServer(MSG)
2697 len(MSG), 0, 0)
2698 self.assertEqual(msg, MSG)
2704 self.sendToServer(MSG)
2709 len(MSG) + 42)
2710 self.assertEqual(msg, MSG)
2716 self.sendToServer(MSG)
2721 len(MSG) - 3)
2722 self.assertEqual(msg, MSG[:-3])
2728 self.sendToServer(MSG)
2733 len(MSG), 1)
2734 self.assertEqual(msg, MSG)
2740 self.sendToServer(MSG)
2745 len(MSG), 10240)
2746 self.assertEqual(msg, MSG)
2752 self.sendToServer(MSG)
2767 self.doRecvmsg, self.serv_sock, len(MSG))
2781 len(MSG) - 3, 0,
2783 self.assertEqual(msg, MSG[:-3])
2795 len(MSG), 0,
2797 self.assertEqual(msg, MSG)
2803 msg, ancdata, flags, addr = self.doRecvmsg(self.serv_sock, len(MSG))
2804 self.assertEqual(msg, MSG)
2811 self.sendToServer(MSG)
2818 msg, ancdata, flags, addr = self.doRecvmsg(self.serv_sock, len(MSG))
2819 self.assertEqual(msg, MSG)
2826 self.assertEqual(self.sendmsgToServer([MSG[:3], MSG[3:]]), len(MSG))
2847 len(MSG) - 3)
2858 self.assertEqual(msg, MSG)
2861 self.sendToServer(MSG)
2873 len(MSG), -1, 0)
2879 len(MSG), object(), 0)
2881 len(MSG), 0, object())
2883 msg, ancdata, flags, addr = self.serv_sock.recvmsg(len(MSG), 0, 0)
2884 self.assertEqual(msg, MSG)
2890 self.sendToServer(MSG)
2898 buf = bytearray(len(MSG))
2901 len(MSG), 0, 0)
2918 self.assertEqual(nbytes, len(MSG))
2919 self.assertEqual(buf, bytearray(MSG))
2925 self.sendToServer(MSG)
2929 buf = bytearray(len(MSG))
2932 self.assertEqual(nbytes, len(MSG))
2933 self.assertEqual(buf, bytearray(MSG))
2939 self.sendToServer(MSG)
2943 buf = array.array("B", [0] * len(MSG))
2945 self.assertEqual(nbytes, len(MSG))
2946 self.assertEqual(buf.tobytes(), MSG)
2952 self.sendToServer(MSG)
3078 self.sendmsgToServer([MSG],
3082 len(MSG))
3091 self.assertEqual(msg, MSG)
3114 len(MSG), 10240))
3119 [MSG],
3123 len(MSG))
3128 len(MSG), 10240))
3137 4, self.doRecvmsg(self.serv_sock, len(MSG),
3147 self.doRecvmsg(self.serv_sock, len(MSG),
3164 self.doRecvmsg(self.serv_sock, len(MSG), 10240),
3173 self.sendmsgToServer([MSG], [(socket.SOL_SOCKET,
3179 len(MSG))
3189 self.doRecvmsg(self.serv_sock, len(MSG),
3200 self.sendmsgToServer([MSG], [(socket.SOL_SOCKET,
3206 len(MSG))
3224 len(MSG), 10240),
3228 self.sendAncillaryIfPossible(MSG, [(socket.SOL_SOCKET,
3235 len(MSG), 10240)
3236 self.assertEqual(msg, MSG)
3247 MSG,
3256 len(MSG), 10240)
3257 self.assertEqual(msg, MSG)
3275 MSG,
3287 self.assertEqual(msg, MSG)
3296 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG)),
3307 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG), 0),
3317 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG), 1))
3326 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG),
3333 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG),
3348 len(MSG), ancbuf)
3349 self.assertEqual(msg, MSG)
3429 len(MSG), ancbufsize)
3431 self.assertEqual(msg, MSG)
3459 self.sendToServer(MSG)
3469 self.sendToServer(MSG)
3487 self.sendmsgToServer([MSG],
3490 len(MSG))
3505 len(MSG), ancbufsize)
3507 self.assertEqual(msg, MSG)
3537 self.sendToServer(MSG)
3550 self.sendToServer(MSG)
3565 self.sendmsgToServer([MSG],
3570 len(MSG))
3587 [MSG],
3595 [MSG],
3600 self.assertEqual(nbytes, len(MSG))
3616 len(MSG), *args)
3618 self.assertEqual(msg, MSG)
3638 self.sendToServer(MSG)
3650 self.sendToServer(MSG)
3662 self.sendToServer(MSG)
3671 self.sendToServer(MSG)
3680 self.sendToServer(MSG)
3691 self.serv_sock, len(MSG), socket.CMSG_LEN(SIZEOF_INT) - 1)
3693 self.assertEqual(msg, MSG)
3707 self.sendToServer(MSG)
3722 len(MSG), ancbufsize)
3724 self.assertEqual(msg, MSG)
3750 self.sendToServer(MSG)
3760 self.sendToServer(MSG)
3771 self.sendToServer(MSG)
3782 self.sendToServer(MSG)
3795 self.serv_sock, len(MSG),
3798 self.assertEqual(msg, MSG)
3824 self.sendToServer(MSG)
4162 self.assertEqual(msg, MSG)
4165 self.cli.send(MSG)
4168 self.serv.send(MSG)
4172 self.assertEqual(msg, MSG)
4277 message = conn.recv(len(MSG))
4286 self.cli.send(MSG)
4331 msg = conn.recv(len(MSG))
4340 msg = conn.recv(len(MSG))
4341 self.assertEqual(msg, MSG)
4351 self.cli.sendall(MSG)
4372 read_msg = MSG
4374 write_msg = MSG
4484 msg = self.cli_conn.recv(len(MSG))
4639 read_msg = MSG.decode('utf-8')
4641 write_msg = MSG
4649 read_msg = MSG
4651 write_msg = MSG.decode('utf-8')
4659 read_msg = MSG.decode('utf-8')
4661 write_msg = MSG.decode('utf-8')
5062 buf = array.array("B", [0] * len(MSG))
5064 self.assertEqual(nbytes, len(MSG))
5066 msg = buf[:len(MSG)]
5067 self.assertEqual(msg, MSG)
5070 buf = bytes(MSG)
5076 self.assertEqual(nbytes, len(MSG))
5077 msg = buf[:len(MSG)]
5078 self.assertEqual(msg, MSG)
5085 self.assertEqual(nbytes, len(MSG))
5086 msg = buf[:len(MSG)]
5087 self.assertEqual(msg, MSG)
5092 buf = array.array("B", [0] * len(MSG))
5094 self.assertEqual(nbytes, len(MSG))
5096 msg = buf[:len(MSG)]
5097 self.assertEqual(msg, MSG)
5100 buf = bytes(MSG)
5106 self.assertEqual(nbytes, len(MSG))
5107 msg = buf[:len(MSG)]
5108 self.assertEqual(msg, MSG)
5115 self.assertEqual(nbytes, len(MSG))
5116 msg = buf[:len(MSG)]
5117 self.assertEqual(msg, MSG)
5127 self.serv_conn.send(MSG)
5177 cli.sendto(MSG, sendaddr)
5182 self.assertEqual(msg, MSG)
5218 self.assertEqual(msg, MSG)
5222 self.cli.send(MSG)