OLD | NEW |
1 from mod_pywebsocket import common | 1 from mod_pywebsocket import common |
2 from mod_pywebsocket import msgutil | 2 from mod_pywebsocket import msgutil |
3 | 3 |
4 | 4 |
5 def _retrieve_frame(stream): | 5 def _retrieve_frame(stream): |
6 # FIXME: Use better API. | 6 # FIXME: Use better API. |
7 frame = stream._receive_frame_as_frame_object() | 7 frame = stream._receive_frame_as_frame_object() |
8 for frame_filter in stream._options.incoming_frame_filters: | 8 for frame_filter in stream._options.incoming_frame_filters: |
9 frame_filter.filter(frame) | 9 frame_filter.filter(frame) |
10 return frame | 10 return frame |
(...skipping 11 matching lines...) Expand all Loading... |
22 for test_number, expected_message in enumerate(expected_messages): | 22 for test_number, expected_message in enumerate(expected_messages): |
23 frame = _retrieve_frame(request.ws_stream) | 23 frame = _retrieve_frame(request.ws_stream) |
24 if frame.opcode == common.OPCODE_BINARY and frame.payload == expected_me
ssage and frame.fin: | 24 if frame.opcode == common.OPCODE_BINARY and frame.payload == expected_me
ssage and frame.fin: |
25 msgutil.send_message(request, 'PASS: Message #%d.' % test_number) | 25 msgutil.send_message(request, 'PASS: Message #%d.' % test_number) |
26 else: | 26 else: |
27 msgutil.send_message(request, 'FAIL: Message #%d: Received unexpecte
d frame: opcode = %r, payload = %r, final = %r' % (test_number, frame.opcode, fr
ame.payload, frame.fin)) | 27 msgutil.send_message(request, 'FAIL: Message #%d: Received unexpecte
d frame: opcode = %r, payload = %r, final = %r' % (test_number, frame.opcode, fr
ame.payload, frame.fin)) |
28 | 28 |
29 | 29 |
30 def all_distinct_bytes(): | 30 def all_distinct_bytes(): |
31 return ''.join([chr(i) for i in xrange(256)]) | 31 return ''.join([chr(i) for i in xrange(256)]) |
OLD | NEW |