Lines Matching refs:frame
31 def check_close(sock, code=1000, no_close=False, frame=None): argument
32 if frame is None:
33 frame = ws.frame_read(sock)
35 assert frame['fin'], 'close fin'
36 assert frame['opcode'] == ws.OP_CLOSE, 'close opcode'
37 assert frame['code'] == code, 'close code'
43 def check_frame(frame, fin, opcode, payload, decode=True): argument
45 data = frame['data']
47 data = frame['data'].decode('utf-8')
49 assert frame['fin'] == fin, 'fin'
50 assert frame['opcode'] == opcode, 'opcode'
74 frame = ws.frame_read(sock)
76 assert message == frame['data'].decode('utf-8'), 'mirror'
79 frame = ws.frame_read(sock)
81 assert message == frame['data'].decode('utf-8'), 'mirror 2'
95 frame = ws.frame_read(sock)
97 assert frame['opcode'] == ws.OP_CLOSE, 'no mask opcode'
98 assert frame['code'] == 1002, 'no mask close code'
114 frame = ws.frame_read(sock)
116 assert f'{message} {message}' == frame['data'].decode(
132 frame = ws.frame_read(sock)
134 frame.pop('data')
135 assert frame == {
158 frame = ws.frame_read(sock)
159 data = frame['data'].decode('utf-8')
161 frame = ws.frame_read(sock)
162 data += frame['data'].decode('utf-8')
387 frame = ws.frame_read(sock)
388 check_frame(frame, True, opcode, payload)
413 frame = ws.frame_read(sock)
415 check_frame(frame, True, opcode, payload)
439 frame = ws.frame_read(sock)
441 check_frame(frame, True, op_pong, payload, decode=decode)
481 frame = ws.frame_read(sock)
482 check_frame(frame, True, ws.OP_PONG, payload)
498 frame = ws.frame_read(sock)
499 check_frame(frame, True, ws.OP_PONG, f'payload-{i}')
508 frame = ws.frame_read(sock)
509 check_frame(frame, True, ws.OP_PONG, f'payload-{i}')
535 frame = ws.frame_read(sock)
536 check_frame(frame, True, ws.OP_TEXT, payload)
549 frame = ws.frame_read(sock)
550 check_frame(frame, True, ws.OP_TEXT, payload)
567 frame = ws.frame_read(sock)
568 check_frame(frame, True, ws.OP_TEXT, payload)
631 frame = ws.frame_read(sock)
632 check_frame(frame, True, ws.OP_TEXT, payload)
645 frame = ws.frame_read(sock)
646 check_frame(frame, True, ws.OP_TEXT, payload)
659 frame = ws.frame_read(sock)
660 check_frame(frame, True, ws.OP_TEXT, payload)
687 frame = ws.frame_read(sock)
688 check_frame(frame, True, ws.OP_TEXT, payload)
701 frame = ws.frame_read(sock)
702 check_frame(frame, True, ws.OP_TEXT, payload)
715 frame = ws.frame_read(sock)
716 check_frame(frame, True, ws.OP_TEXT, payload)
750 frame = ws.frame_read(sock)
751 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
759 frame = ws.frame_read(sock)
760 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
767 frame = ws.frame_read(sock)
768 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
778 frame = ws.frame_read(sock)
779 check_frame(frame, True, ws.OP_PONG, ping_payload)
781 frame = ws.frame_read(sock)
782 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
793 frame = ws.frame_read(sock)
794 check_frame(frame, True, ws.OP_PONG, ping_payload)
798 frame = ws.frame_read(sock)
799 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
809 frame = ws.frame_read(sock)
810 check_frame(frame, True, ws.OP_PONG, ping_payload)
812 frame = ws.frame_read(sock)
813 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
882 frame = ws.frame_read(sock)
884 if frame['opcode'] == ws.OP_TEXT:
885 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
886 frame = None
888 check_close(sock, 1002, frame=frame)
933 frame = ws.frame_read(sock)
934 check_frame(frame, True, ws.OP_PONG, 'pongme 1!')
936 frame = ws.frame_read(sock)
937 check_frame(frame, True, ws.OP_PONG, 'pongme 2!')
952 frame = ws.frame_read(sock)
953 check_frame(frame, True, ws.OP_PONG, 'pongme 1!')
961 frame = ws.frame_read(sock)
962 check_frame(frame, True, ws.OP_PONG, 'pongme 2!')
985 frame = ws.frame_read(sock)
986 check_frame(frame, True, ws.OP_TEXT, '')
994 frame = ws.frame_read(sock)
995 check_frame(frame, True, ws.OP_TEXT, '')
1005 frame = ws.frame_read(sock)
1006 check_frame(frame, True, ws.OP_TEXT, payload)
1014 frame = ws.frame_read(sock)
1015 check_frame(frame, True, ws.OP_TEXT, payload)
1022 frame = ws.frame_read(sock)
1023 check_frame(frame, True, ws.OP_TEXT, payload)
1029 frame = ws.frame_read(sock)
1030 check_frame(frame, True, ws.OP_TEXT, payload)
1038 frame = ws.frame_read(sock)
1039 check_frame(frame, True, ws.OP_TEXT, payload)
1078 frame = ws.frame_read(sock)
1079 check_frame(frame, True, ws.OP_TEXT, payload)
1294 frame = ws.frame_read(sock, read_timeout=5)
1295 check_frame(frame, True, opcode, payload)
1304 frame = ws.frame_read(sock, read_timeout=5)
1305 check_frame(frame, True, opcode, payload)
1368 frame = ws.frame_read(sock)
1369 check_frame(frame, True, ws.OP_TEXT, payload)
1391 frame = ws.frame_read(sock)
1392 check_frame(frame, True, opcode, payload)
1409 frame = ws.frame_to_send(ws.OP_TEXT, 'blah')
1410 sock.sendall(frame[:2])
1426 frame = ws.frame_to_send(ws.OP_TEXT, 'blah')
1427 sock.sendall(frame[:2])
1431 frame = ws.frame_read(sock)
1432 check_frame(frame, True, ws.OP_PING, '') # PING frame