Lines Matching refs:sock

24 def close_connection(sock):  argument
25 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty soc'
27 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
29 check_close(sock)
32 def check_close(sock, code=1000, no_close=False, frame=None): argument
34 frame = ws.frame_read(sock)
41 sock.close()
58 resp, sock, key = ws.upgrade()
59 sock.close()
72 _, sock, _ = ws.upgrade()
74 ws.frame_write(sock, ws.OP_TEXT, message)
75 frame = ws.frame_read(sock)
79 ws.frame_write(sock, ws.OP_TEXT, message)
80 frame = ws.frame_read(sock)
84 sock.close()
92 _, sock, _ = ws.upgrade()
94 ws.frame_write(sock, ws.OP_TEXT, message, mask=False)
96 frame = ws.frame_read(sock)
101 sock.close()
109 _, sock, _ = ws.upgrade()
111 ws.frame_write(sock, ws.OP_TEXT, message, fin=False)
112 ws.frame_write(sock, ws.OP_CONT, ' ', fin=False)
113 ws.frame_write(sock, ws.OP_CONT, message)
115 frame = ws.frame_read(sock)
121 sock.close()
129 _, sock, _ = ws.upgrade()
131 ws.frame_write(sock, ws.OP_PING, message, fin=False)
133 frame = ws.frame_read(sock)
147 sock.close()
193 resp, sock, _ = ws.upgrade(
203 sock.close()
332 resp, sock, _ = ws.upgrade(
341 sock.close()
361 _, sock, _ = ws.upgrade()
366 ws.frame_write(sock, opcode, payload, chopsize=chopsize)
368 frame = ws.message_read(sock)
380 close_connection(sock)
388 _, sock, _ = ws.upgrade()
393 ws.frame_write(sock, opcode, payload, chopsize=chopsize)
395 frame = ws.message_read(sock)
407 close_connection(sock)
416 _, sock, _ = ws.upgrade()
419 ws.frame_write(sock, op_ping, payload, chopsize=chopsize)
420 frame = ws.frame_read(sock)
430 close_connection(sock)
434 _, sock, _ = ws.upgrade()
436 ws.frame_write(sock, ws.OP_PING, b'\xfe' * 126)
437 check_close(sock, 1002)
445 _, sock, _ = ws.upgrade()
447 ws.frame_write(sock, ws.OP_PONG, '')
448 assert client.recvall(sock, read_timeout=0.1) == b'', '2_7'
452 ws.frame_write(sock, ws.OP_PONG, 'unsolicited pong payload')
453 assert client.recvall(sock, read_timeout=0.1) == b'', '2_8'
459 ws.frame_write(sock, ws.OP_PONG, 'unsolicited pong payload')
460 ws.frame_write(sock, ws.OP_PING, payload)
462 frame = ws.frame_read(sock)
465 close_connection(sock)
473 _, sock, _ = ws.upgrade()
476 ws.frame_write(sock, ws.OP_PING, f'payload-{i}')
479 frame = ws.frame_read(sock)
486 ws.frame_write(sock, opcode, f'payload-{i}', chopsize=1)
489 frame = ws.frame_read(sock)
492 close_connection(sock)
503 _, sock, _ = ws.upgrade()
505 ws.frame_write(sock, ws.OP_TEXT, payload, rsv1=True)
506 check_close(sock, 1002)
510 _, sock, _ = ws.upgrade()
512 ws.frame_write(sock, ws.OP_TEXT, payload)
513 ws.frame_write(sock, ws.OP_TEXT, payload, rsv2=True)
514 ws.frame_write(sock, ws.OP_PING, '')
516 frame = ws.frame_read(sock)
519 check_close(sock, 1002, no_close=True)
521 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty 3_2'
522 sock.close()
526 _, sock, _ = ws.upgrade()
528 ws.frame_write(sock, ws.OP_TEXT, payload)
530 frame = ws.frame_read(sock)
533 ws.frame_write(sock, ws.OP_TEXT, payload, rsv1=True, rsv2=True)
535 check_close(sock, 1002, no_close=True)
537 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty 3_3'
538 sock.close()
542 _, sock, _ = ws.upgrade()
544 ws.frame_write(sock, ws.OP_TEXT, payload, chopsize=1)
545 ws.frame_write(sock, ws.OP_TEXT, payload, rsv3=True, chopsize=1)
546 ws.frame_write(sock, ws.OP_PING, '')
548 frame = ws.frame_read(sock)
551 check_close(sock, 1002, no_close=True)
553 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty 3_4'
554 sock.close()
558 _, sock, _ = ws.upgrade()
561 sock,
568 check_close(sock, 1002)
572 _, sock, _ = ws.upgrade()
574 ws.frame_write(sock, ws.OP_PING, payload, rsv2=True, rsv3=True)
576 check_close(sock, 1002)
580 _, sock, _ = ws.upgrade()
582 ws.frame_write(sock, ws.OP_CLOSE, payload, rsv1=True, rsv2=True, rsv3=True)
584 check_close(sock, 1002)
594 _, sock, _ = ws.upgrade()
596 ws.frame_write(sock, 0x03, '')
597 check_close(sock, 1002)
601 _, sock, _ = ws.upgrade()
603 ws.frame_write(sock, 0x04, 'reserved opcode payload')
604 check_close(sock, 1002)
608 _, sock, _ = ws.upgrade()
610 ws.frame_write(sock, ws.OP_TEXT, payload)
612 frame = ws.frame_read(sock)
615 ws.frame_write(sock, 0x05, '')
616 ws.frame_write(sock, ws.OP_PING, '')
618 check_close(sock, 1002)
622 _, sock, _ = ws.upgrade()
624 ws.frame_write(sock, ws.OP_TEXT, payload)
626 frame = ws.frame_read(sock)
629 ws.frame_write(sock, 0x06, payload)
630 ws.frame_write(sock, ws.OP_PING, '')
632 check_close(sock, 1002)
636 _, sock, _ = ws.upgrade()
638 ws.frame_write(sock, ws.OP_TEXT, payload, chopsize=1)
640 frame = ws.frame_read(sock)
643 ws.frame_write(sock, 0x07, payload, chopsize=1)
644 ws.frame_write(sock, ws.OP_PING, '')
646 check_close(sock, 1002)
650 _, sock, _ = ws.upgrade()
652 ws.frame_write(sock, 0x0B, '')
653 check_close(sock, 1002)
657 _, sock, _ = ws.upgrade()
659 ws.frame_write(sock, 0x0C, 'reserved opcode payload')
660 check_close(sock, 1002)
664 _, sock, _ = ws.upgrade()
666 ws.frame_write(sock, ws.OP_TEXT, payload)
668 frame = ws.frame_read(sock)
671 ws.frame_write(sock, 0x0D, '')
672 ws.frame_write(sock, ws.OP_PING, '')
674 check_close(sock, 1002)
678 _, sock, _ = ws.upgrade()
680 ws.frame_write(sock, ws.OP_TEXT, payload)
682 frame = ws.frame_read(sock)
685 ws.frame_write(sock, 0x0E, payload)
686 ws.frame_write(sock, ws.OP_PING, '')
688 check_close(sock, 1002)
692 _, sock, _ = ws.upgrade()
694 ws.frame_write(sock, ws.OP_TEXT, payload, chopsize=1)
696 frame = ws.frame_read(sock)
699 ws.frame_write(sock, 0x0F, payload, chopsize=1)
700 ws.frame_write(sock, ws.OP_PING, '')
702 check_close(sock, 1002)
710 _, sock, _ = ws.upgrade()
712 ws.frame_write(sock, ws.OP_PING, 'fragment1', fin=False)
713 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
714 check_close(sock, 1002)
718 _, sock, _ = ws.upgrade()
720 ws.frame_write(sock, ws.OP_PONG, 'fragment1', fin=False)
721 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
722 check_close(sock, 1002)
726 _, sock, _ = ws.upgrade()
728 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
729 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
731 frame = ws.frame_read(sock)
736 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
737 assert client.recvall(sock, read_timeout=0.1) == b'', '5_4'
738 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
740 frame = ws.frame_read(sock)
745 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False, chopsize=1)
746 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True, chopsize=1)
748 frame = ws.frame_read(sock)
755 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
756 ws.frame_write(sock, ws.OP_PING, ping_payload)
757 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
759 frame = ws.frame_read(sock)
762 frame = ws.frame_read(sock)
769 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
770 assert client.recvall(sock, read_timeout=0.1) == b'', '5_7'
772 ws.frame_write(sock, ws.OP_PING, ping_payload)
774 frame = ws.frame_read(sock)
777 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
779 frame = ws.frame_read(sock)
786 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False, chopsize=1)
787 ws.frame_write(sock, ws.OP_PING, ping_payload, chopsize=1)
788 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True, chopsize=1)
790 frame = ws.frame_read(sock)
793 frame = ws.frame_read(sock)
798 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=True)
799 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
800 check_close(sock, 1002)
804 _, sock, _ = ws.upgrade()
806 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=True)
807 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
808 check_close(sock, 1002)
812 _, sock, _ = ws.upgrade()
815 sock,
821 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True, chopsize=1)
822 check_close(sock, 1002)
826 _, sock, _ = ws.upgrade()
828 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=False)
829 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
830 check_close(sock, 1002)
834 _, sock, _ = ws.upgrade()
836 ws.frame_write(sock, ws.OP_CONT, 'non-continuation payload', fin=False)
837 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True)
838 check_close(sock, 1002)
842 _, sock, _ = ws.upgrade()
845 sock,
851 ws.frame_write(sock, ws.OP_TEXT, 'Hello, world!', fin=True, chopsize=1)
852 check_close(sock, 1002)
856 _, sock, _ = ws.upgrade()
858 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
859 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=True)
860 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=False)
861 ws.frame_write(sock, ws.OP_TEXT, 'fragment4', fin=True)
863 frame = ws.frame_read(sock)
869 check_close(sock, 1002, frame=frame)
873 _, sock, _ = ws.upgrade()
876 ws.frame_write(sock, ws.OP_CONT, 'fragment1', fin=False)
877 ws.frame_write(sock, ws.OP_TEXT, 'fragment2', fin=False)
878 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=True)
879 check_close(sock, 1002)
883 _, sock, _ = ws.upgrade()
886 ws.frame_write(sock, ws.OP_CONT, 'fragment1', fin=True)
887 ws.frame_write(sock, ws.OP_TEXT, 'fragment2', fin=False)
888 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=True)
889 check_close(sock, 1002)
893 _, sock, _ = ws.upgrade()
895 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
896 ws.frame_write(sock, ws.OP_TEXT, 'fragment2')
897 check_close(sock, 1002)
901 _, sock, _ = ws.upgrade()
903 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
904 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=False)
905 ws.frame_write(sock, ws.OP_PING, 'pongme 1!')
909 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=False)
910 ws.frame_write(sock, ws.OP_CONT, 'fragment4', fin=False)
911 ws.frame_write(sock, ws.OP_PING, 'pongme 2!')
912 ws.frame_write(sock, ws.OP_CONT, 'fragment5')
914 frame = ws.frame_read(sock)
917 frame = ws.frame_read(sock)
921 ws.frame_read(sock),
929 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
930 ws.frame_write(sock, ws.OP_CONT, 'fragment2', fin=False)
931 ws.frame_write(sock, ws.OP_PING, 'pongme 1!')
933 frame = ws.frame_read(sock)
938 ws.frame_write(sock, ws.OP_CONT, 'fragment3', fin=False)
939 ws.frame_write(sock, ws.OP_CONT, 'fragment4', fin=False)
940 ws.frame_write(sock, ws.OP_PING, 'pongme 2!')
942 frame = ws.frame_read(sock)
945 assert client.recvall(sock, read_timeout=0.1) == b'', '5_20'
946 ws.frame_write(sock, ws.OP_CONT, 'fragment5')
949 ws.frame_read(sock),
955 close_connection(sock)
963 _, sock, _ = ws.upgrade()
965 ws.frame_write(sock, ws.OP_TEXT, '')
966 frame = ws.frame_read(sock, read_timeout=3)
971 ws.frame_write(sock, ws.OP_TEXT, '', fin=False)
972 ws.frame_write(sock, ws.OP_CONT, '', fin=False)
973 ws.frame_write(sock, ws.OP_CONT, '')
975 frame = ws.frame_read(sock, read_timeout=3)
982 ws.frame_write(sock, ws.OP_TEXT, '', fin=False)
983 ws.frame_write(sock, ws.OP_CONT, payload, fin=False)
984 ws.frame_write(sock, ws.OP_CONT, '')
986 frame = ws.frame_read(sock)
993 ws.frame_write(sock, ws.OP_TEXT, payload)
995 frame = ws.frame_read(sock)
1000 ws.frame_write(sock, ws.OP_TEXT, payload[:12], fin=False)
1001 ws.frame_write(sock, ws.OP_CONT, payload[12:])
1003 frame = ws.frame_read(sock)
1008 ws.message(sock, ws.OP_TEXT, payload, fragmention_size=1)
1010 frame = ws.frame_read(sock)
1017 ws.message(sock, ws.OP_TEXT, payload, fragmention_size=1)
1019 frame = ws.frame_read(sock)
1022 close_connection(sock)
1053 _, sock, _ = ws.upgrade()
1057 ws.frame_write(sock, ws.OP_TEXT, payload)
1059 frame = ws.frame_read(sock)
1062 close_connection(sock)
1066 _, sock, _ = ws.upgrade()
1068 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1069 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1071 check_close(sock)
1075 _, sock, _ = ws.upgrade()
1077 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1078 check_close(sock, no_close=True)
1080 ws.frame_write(sock, ws.OP_PING, '')
1081 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty soc'
1083 sock.close()
1087 _, sock, _ = ws.upgrade()
1089 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1090 check_close(sock, no_close=True)
1092 ws.frame_write(sock, ws.OP_TEXT, payload)
1093 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty soc'
1095 sock.close()
1099 _, sock, _ = ws.upgrade()
1101 ws.frame_write(sock, ws.OP_TEXT, 'fragment1', fin=False)
1102 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1103 check_close(sock, no_close=True)
1105 ws.frame_write(sock, ws.OP_CONT, 'fragment2')
1106 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty soc'
1108 sock.close()
1112 _, sock, _ = ws.upgrade()
1114 ws.frame_write(sock, ws.OP_TEXT, 'BAsd7&jh23' * 26 * 2**10)
1115 ws.frame_write(sock, ws.OP_TEXT, payload)
1116 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1118 client.recvall(sock, read_timeout=1)
1120 ws.frame_write(sock, ws.OP_PING, '')
1121 assert client.recvall(sock, read_timeout=0.1) == b'', 'empty soc'
1123 sock.close()
1127 _, sock, _ = ws.upgrade()
1129 ws.frame_write(sock, ws.OP_CLOSE, '')
1130 check_close(sock)
1134 _, sock, _ = ws.upgrade()
1136 ws.frame_write(sock, ws.OP_CLOSE, 'a')
1137 check_close(sock, 1002)
1141 _, sock, _ = ws.upgrade()
1143 ws.frame_write(sock, ws.OP_CLOSE, ws.serialize_close())
1144 check_close(sock)
1148 _, sock, _ = ws.upgrade()
1152 ws.frame_write(sock, ws.OP_CLOSE, payload)
1153 check_close(sock)
1157 _, sock, _ = ws.upgrade()
1161 ws.frame_write(sock, ws.OP_CLOSE, payload)
1162 check_close(sock)
1166 _, sock, _ = ws.upgrade()
1170 ws.frame_write(sock, ws.OP_CLOSE, payload)
1171 check_close(sock, 1002)
1207 _, sock, _ = ws.upgrade()
1211 ws.frame_write(sock, ws.OP_CLOSE, payload)
1212 check_close(sock, code=code)
1215 _, sock, _ = ws.upgrade()
1219 ws.frame_write(sock, ws.OP_CLOSE, payload)
1220 check_close(sock, 1002)
1228 _, sock, _ = ws.upgrade()
1232 ws.frame_write(sock, ws.OP_CLOSE, payload)
1233 check_close(sock, 1002)
1237 _, sock, _ = ws.upgrade()
1241 ws.frame_write(sock, ws.OP_CLOSE, payload)
1242 check_close(sock, 1002)
1263 _, sock, _ = ws.upgrade()
1274 ws.frame_write(sock, opcode, payload, chopsize=chopsize)
1275 frame = ws.frame_read(sock)
1284 ws.message(sock, opcode, payload, fragmention_size=f_size)
1285 frame = ws.frame_read(sock, read_timeout=5)
1337 close_connection(sock)
1343 _, sock, _ = ws.upgrade()
1347 ws.message(sock, ws.OP_TEXT, payload, fragmention_size=1300)
1349 frame = ws.message_read(sock)
1352 close_connection(sock)
1365 _, sock, _ = ws.upgrade()
1370 ws.frame_write(sock, opcode, payload) # frame length is 100
1372 frame = ws.frame_read(sock)
1377 ws.frame_write(sock, opcode, payload) # frame length is 101
1378 check_close(sock, 1009) # 1009 - CLOSE_TOO_LARGE
1388 _, sock, _ = ws.upgrade()
1391 sock.sendall(frame[:2])
1395 check_close(sock, 1001) # 1001 - CLOSE_GOING_AWAY
1405 _, sock, _ = ws.upgrade()
1408 sock.sendall(frame[:2])
1412 frame = ws.frame_read(sock)
1415 sock.close()