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 == {
367 frame = ws.message_read(sock)
368 check_frame(frame, True, opcode, payload)
394 frame = ws.message_read(sock)
395 check_frame(frame, True, opcode, payload)
419 frame = ws.frame_read(sock)
421 check_frame(frame, True, op_pong, payload, decode=decode)
461 frame = ws.frame_read(sock)
462 check_frame(frame, True, ws.OP_PONG, payload)
478 frame = ws.frame_read(sock)
479 check_frame(frame, True, ws.OP_PONG, f'payload-{i}')
488 frame = ws.frame_read(sock)
489 check_frame(frame, True, ws.OP_PONG, f'payload-{i}')
515 frame = ws.frame_read(sock)
516 check_frame(frame, True, ws.OP_TEXT, payload)
529 frame = ws.frame_read(sock)
530 check_frame(frame, True, ws.OP_TEXT, payload)
547 frame = ws.frame_read(sock)
548 check_frame(frame, True, ws.OP_TEXT, payload)
611 frame = ws.frame_read(sock)
612 check_frame(frame, True, ws.OP_TEXT, payload)
625 frame = ws.frame_read(sock)
626 check_frame(frame, True, ws.OP_TEXT, payload)
639 frame = ws.frame_read(sock)
640 check_frame(frame, True, ws.OP_TEXT, payload)
667 frame = ws.frame_read(sock)
668 check_frame(frame, True, ws.OP_TEXT, payload)
681 frame = ws.frame_read(sock)
682 check_frame(frame, True, ws.OP_TEXT, payload)
695 frame = ws.frame_read(sock)
696 check_frame(frame, True, ws.OP_TEXT, payload)
730 frame = ws.frame_read(sock)
731 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
739 frame = ws.frame_read(sock)
740 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
747 frame = ws.frame_read(sock)
748 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
758 frame = ws.frame_read(sock)
759 check_frame(frame, True, ws.OP_PONG, ping_payload)
761 frame = ws.frame_read(sock)
762 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
773 frame = ws.frame_read(sock)
774 check_frame(frame, True, ws.OP_PONG, ping_payload)
778 frame = ws.frame_read(sock)
779 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
789 frame = ws.frame_read(sock)
790 check_frame(frame, True, ws.OP_PONG, ping_payload)
792 frame = ws.frame_read(sock)
793 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
862 frame = ws.frame_read(sock)
864 if frame['opcode'] == ws.OP_TEXT:
865 check_frame(frame, True, ws.OP_TEXT, 'fragment1fragment2')
866 frame = None
868 check_close(sock, 1002, frame=frame)
913 frame = ws.frame_read(sock)
914 check_frame(frame, True, ws.OP_PONG, 'pongme 1!')
916 frame = ws.frame_read(sock)
917 check_frame(frame, True, ws.OP_PONG, 'pongme 2!')
932 frame = ws.frame_read(sock)
933 check_frame(frame, True, ws.OP_PONG, 'pongme 1!')
941 frame = ws.frame_read(sock)
942 check_frame(frame, True, ws.OP_PONG, 'pongme 2!')
965 frame = ws.frame_read(sock, read_timeout=3)
966 check_frame(frame, True, ws.OP_TEXT, '')
974 frame = ws.frame_read(sock, read_timeout=3)
975 check_frame(frame, True, ws.OP_TEXT, '')
985 frame = ws.frame_read(sock)
986 check_frame(frame, True, ws.OP_TEXT, payload)
994 frame = ws.frame_read(sock)
995 check_frame(frame, True, ws.OP_TEXT, payload)
1002 frame = ws.frame_read(sock)
1003 check_frame(frame, True, ws.OP_TEXT, payload)
1009 frame = ws.frame_read(sock)
1010 check_frame(frame, True, ws.OP_TEXT, payload)
1018 frame = ws.frame_read(sock)
1019 check_frame(frame, True, ws.OP_TEXT, payload)
1058 frame = ws.frame_read(sock)
1059 check_frame(frame, True, ws.OP_TEXT, payload)
1274 frame = ws.frame_read(sock)
1275 check_frame(frame, True, opcode, payload)
1284 frame = ws.frame_read(sock, read_timeout=5)
1285 check_frame(frame, True, opcode, payload)
1348 frame = ws.message_read(sock)
1349 check_frame(frame, True, ws.OP_TEXT, payload)
1371 frame = ws.frame_read(sock)
1372 check_frame(frame, True, opcode, payload)
1389 frame = ws.frame_to_send(ws.OP_TEXT, 'blah')
1390 sock.sendall(frame[:2])
1406 frame = ws.frame_to_send(ws.OP_TEXT, 'blah')
1407 sock.sendall(frame[:2])
1411 frame = ws.frame_read(sock)
1412 check_frame(frame, True, ws.OP_PING, '') # PING frame