| 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 |