Lines Matching refs:MSG
44 MSG = 'Michael Gilfix was here\u1234\r\n'.encode('utf-8')
516 self.assertEqual(msg, MSG)
519 self.cli.send(MSG)
2498 self.assertEqual(msg, MSG)
2501 self.serv_conn.send(MSG)
2505 seg1 = self.cli_conn.recv(len(MSG) - 3)
2508 self.assertEqual(msg, MSG)
2511 self.serv_conn.send(MSG)
2516 self.assertEqual(msg, MSG)
2519 self.serv_conn.send(MSG)
2523 seg1, addr = self.cli_conn.recvfrom(len(MSG)-3)
2526 self.assertEqual(msg, MSG)
2529 self.serv_conn.send(MSG)
2552 self.assertEqual(msg, MSG)
2555 self.serv_conn.send(MSG)
2562 self.assertEqual(msg, MSG)
2565 self.serv_conn.send(MSG)
2570 self.assertEqual(msg, MSG)
2577 self.serv_conn.send(MSG)
2585 self.serv_conn.send(MSG)
2607 self.assertEqual(msg, MSG)
2610 self.serv_conn.send(MSG)
2620 msg = self.serv.recv(len(MSG))
2621 self.assertEqual(msg, MSG)
2624 self.cli.sendto(MSG, 0, (HOST, self.port))
2628 msg, addr = self.serv.recvfrom(len(MSG))
2629 self.assertEqual(msg, MSG)
2632 self.cli.sendto(MSG, 0, (HOST, self.port))
2639 self.cli.sendto(MSG, 0, (HOST, self.port))
2651 msg = self.serv.recv(len(MSG))
2652 self.assertEqual(msg, MSG)
2655 self.cli.sendto(MSG, 0, (HOST, self.port))
2659 msg, addr = self.serv.recvfrom(len(MSG))
2660 self.assertEqual(msg, MSG)
2663 self.cli.sendto(MSG, 0, (HOST, self.port))
2670 self.cli.sendto(MSG, 0, (HOST, self.port))
2901 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2904 self.assertEqual(self.sendmsgToServer([MSG]), len(MSG))
2908 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2911 self.assertEqual(self.sendmsgToServer((o for o in [MSG])),
2912 len(MSG))
2916 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2919 self.assertEqual(self.sendmsgToServer([MSG], (o for o in [])),
2920 len(MSG))
2924 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2927 self.assertEqual(self.sendmsgToServer([array.array("B", MSG)]),
2928 len(MSG))
2932 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
2935 self.assertEqual(self.sendmsgToServer([MSG[:3], MSG[3:]]), len(MSG))
2950 [MSG, object()])
2952 [MSG], object())
2954 [MSG], [], object())
2956 [MSG], [], 0, object())
2965 [MSG], [object()])
2967 [MSG], [(object(), 0, b"data")])
2969 [MSG], [(0, object(), b"data")])
2971 [MSG], [(0, 0, object())])
2973 [MSG], [(0, 0)])
2975 [MSG], [(0, 0, b"data", 42)])
2987 [MSG], [0, 0, b""])
2989 [MSG], [(0, 0, b""), object()])
3001 self.sendmsgToServer([MSG], [(0, 0, b""), (0, 0, b"")])
3011 self.assertRaises(OSError, self.sendmsgToServer, [MSG])
3020 self.assertEqual(self.serv_sock.recv(len(MSG)), MSG)
3023 self.assertEqual(self.sendmsgToServer([MSG], [], 0, None), len(MSG))
3087 [MSG])
3089 [MSG], [], 0, None)
3098 msg, ancdata, flags, addr = self.doRecvmsg(self.serv_sock, len(MSG))
3099 self.assertEqual(msg, MSG)
3105 self.sendToServer(MSG)
3110 len(MSG), 0, 0)
3111 self.assertEqual(msg, MSG)
3117 self.sendToServer(MSG)
3122 len(MSG) + 42)
3123 self.assertEqual(msg, MSG)
3129 self.sendToServer(MSG)
3134 len(MSG) - 3)
3135 self.assertEqual(msg, MSG[:-3])
3141 self.sendToServer(MSG)
3146 len(MSG), 1)
3147 self.assertEqual(msg, MSG)
3153 self.sendToServer(MSG)
3158 len(MSG), 10240)
3159 self.assertEqual(msg, MSG)
3165 self.sendToServer(MSG)
3180 self.doRecvmsg, self.serv_sock, len(MSG))
3194 len(MSG) - 3, 0,
3196 self.assertEqual(msg, MSG[:-3])
3208 len(MSG), 0,
3210 self.assertEqual(msg, MSG)
3216 msg, ancdata, flags, addr = self.doRecvmsg(self.serv_sock, len(MSG))
3217 self.assertEqual(msg, MSG)
3224 self.sendToServer(MSG)
3231 msg, ancdata, flags, addr = self.doRecvmsg(self.serv_sock, len(MSG))
3232 self.assertEqual(msg, MSG)
3239 self.assertEqual(self.sendmsgToServer([MSG[:3], MSG[3:]]), len(MSG))
3260 len(MSG) - 3)
3271 self.assertEqual(msg, MSG)
3274 self.sendToServer(MSG)
3286 len(MSG), -1, 0)
3292 len(MSG), object(), 0)
3294 len(MSG), 0, object())
3296 msg, ancdata, flags, addr = self.serv_sock.recvmsg(len(MSG), 0, 0)
3297 self.assertEqual(msg, MSG)
3303 self.sendToServer(MSG)
3311 buf = bytearray(len(MSG))
3314 len(MSG), 0, 0)
3331 self.assertEqual(nbytes, len(MSG))
3332 self.assertEqual(buf, bytearray(MSG))
3338 self.sendToServer(MSG)
3342 buf = bytearray(len(MSG))
3345 self.assertEqual(nbytes, len(MSG))
3346 self.assertEqual(buf, bytearray(MSG))
3352 self.sendToServer(MSG)
3356 buf = array.array("B", [0] * len(MSG))
3358 self.assertEqual(nbytes, len(MSG))
3359 self.assertEqual(buf.tobytes(), MSG)
3365 self.sendToServer(MSG)
3489 # server, with the constant MSG as the non-ancillary data.
3491 self.sendmsgToServer([MSG],
3495 len(MSG))
3498 # Check that constant MSG was received with numfds file
3504 self.assertEqual(msg, MSG)
3527 len(MSG), 10240))
3532 [MSG],
3536 len(MSG))
3541 len(MSG), 10240))
3550 4, self.doRecvmsg(self.serv_sock, len(MSG),
3560 self.doRecvmsg(self.serv_sock, len(MSG),
3577 self.doRecvmsg(self.serv_sock, len(MSG), 10240),
3586 self.sendmsgToServer([MSG], [(socket.SOL_SOCKET,
3592 len(MSG))
3602 self.doRecvmsg(self.serv_sock, len(MSG),
3613 self.sendmsgToServer([MSG], [(socket.SOL_SOCKET,
3619 len(MSG))
3637 len(MSG), 10240),
3641 self.sendAncillaryIfPossible(MSG, [(socket.SOL_SOCKET,
3648 len(MSG), 10240)
3649 self.assertEqual(msg, MSG)
3660 MSG,
3669 len(MSG), 10240)
3670 self.assertEqual(msg, MSG)
3688 MSG,
3700 self.assertEqual(msg, MSG)
3709 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG)),
3720 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG), 0),
3730 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG), 1))
3739 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG),
3746 self.checkTruncatedHeader(self.doRecvmsg(self.serv_sock, len(MSG),
3761 len(MSG), ancbuf)
3762 self.assertEqual(msg, MSG)
3835 # space. Check that data is MSG, ancillary data is not
3842 len(MSG), ancbufsize)
3844 self.assertEqual(msg, MSG)
3872 self.sendToServer(MSG)
3882 self.sendToServer(MSG)
3900 self.sendmsgToServer([MSG],
3903 len(MSG))
3908 # ancillary data space. Check that data is MSG, ancillary
3918 len(MSG), ancbufsize)
3920 self.assertEqual(msg, MSG)
3950 self.sendToServer(MSG)
3963 self.sendToServer(MSG)
3978 self.sendmsgToServer([MSG],
3983 len(MSG))
4000 [MSG],
4008 [MSG],
4013 self.assertEqual(nbytes, len(MSG))
4021 # to recvmsg()). Check that data is MSG, MSG_CTRUNC is set
4029 len(MSG), *args)
4031 self.assertEqual(msg, MSG)
4051 self.sendToServer(MSG)
4063 self.sendToServer(MSG)
4075 self.sendToServer(MSG)
4084 self.sendToServer(MSG)
4093 self.sendToServer(MSG)
4104 self.serv_sock, len(MSG), socket.CMSG_LEN(SIZEOF_INT) - 1)
4106 self.assertEqual(msg, MSG)
4120 self.sendToServer(MSG)
4126 # of the second. Check that data is MSG, MSG_CTRUNC is set
4135 len(MSG), ancbufsize)
4137 self.assertEqual(msg, MSG)
4163 self.sendToServer(MSG)
4173 self.sendToServer(MSG)
4184 self.sendToServer(MSG)
4195 self.sendToServer(MSG)
4208 self.serv_sock, len(MSG),
4211 self.assertEqual(msg, MSG)
4237 self.sendToServer(MSG)
4661 self.assertEqual(msg, MSG)
4664 self.cli.send(MSG)
4667 self.serv.send(MSG)
4671 self.assertEqual(msg, MSG)
4811 msg = conn.recv(len(MSG))
4820 msg = conn.recv(len(MSG))
4821 self.assertEqual(msg, MSG)
4831 self.cli.sendall(MSG)
4852 read_msg = MSG
4854 write_msg = MSG
4964 msg = self.cli_conn.recv(len(MSG))
5119 read_msg = MSG.decode('utf-8')
5121 write_msg = MSG
5129 read_msg = MSG
5131 write_msg = MSG.decode('utf-8')
5139 read_msg = MSG.decode('utf-8')
5141 write_msg = MSG.decode('utf-8')
5608 buf = array.array("B", [0] * len(MSG))
5610 self.assertEqual(nbytes, len(MSG))
5612 msg = buf[:len(MSG)]
5613 self.assertEqual(msg, MSG)
5616 buf = bytes(MSG)
5622 self.assertEqual(nbytes, len(MSG))
5623 msg = buf[:len(MSG)]
5624 self.assertEqual(msg, MSG)
5631 self.assertEqual(nbytes, len(MSG))
5632 msg = buf[:len(MSG)]
5633 self.assertEqual(msg, MSG)
5638 buf = array.array("B", [0] * len(MSG))
5640 self.assertEqual(nbytes, len(MSG))
5642 msg = buf[:len(MSG)]
5643 self.assertEqual(msg, MSG)
5646 buf = bytes(MSG)
5652 self.assertEqual(nbytes, len(MSG))
5653 msg = buf[:len(MSG)]
5654 self.assertEqual(msg, MSG)
5661 self.assertEqual(nbytes, len(MSG))
5662 msg = buf[:len(MSG)]
5663 self.assertEqual(msg, MSG)
5673 self.serv_conn.send(MSG)
5723 cli.sendto(MSG, sendaddr)
5728 self.assertEqual(msg, MSG)
5764 self.assertEqual(msg, MSG)
5768 self.cli.send(MSG)
6685 socket.send_fds(sock1, [MSG], fds)
6687 msg, fds2, flags, addr = socket.recv_fds(sock2, len(MSG) * 2, len(fds) * 2)
6690 self.assertEqual(msg, MSG)