diff options
| author | Max Romanov <max.romanov@nginx.com> | 2021-03-24 11:43:41 +0300 |
|---|---|---|
| committer | Max Romanov <max.romanov@nginx.com> | 2021-03-24 11:43:41 +0300 |
| commit | 178f232b3ad36a763b3b5c2e0ef6f26cc1885229 (patch) | |
| tree | 6b5b968c84ee8779c47d3649d04eb74978ef6108 /test/test_asgi_websockets.py | |
| parent | f267dd0a8da280d2a803b61c9a309fe51d60d95a (diff) | |
| download | unit-178f232b3ad36a763b3b5c2e0ef6f26cc1885229.tar.gz unit-178f232b3ad36a763b3b5c2e0ef6f26cc1885229.tar.bz2 | |
Tests: fixed racing condition in websocket test 5_15.
Test case: "send a text message split into two fragments, then a continuation
frame with FIN = false where there is nothing to continue, then an unfragmented
text message, all sent in one chop".
The test case investigates immediate connection closing since there is no
message to continue.
The mirror server may send a response for the first frame before the test
сontinuation frame is received by the router. In this case, the test will
receive a text frame before the close frame.
Diffstat (limited to 'test/test_asgi_websockets.py')
| -rw-r--r-- | test/test_asgi_websockets.py | 14 |
1 files changed, 11 insertions, 3 deletions
diff --git a/test/test_asgi_websockets.py b/test/test_asgi_websockets.py index 6121fcc5..7218d526 100644 --- a/test/test_asgi_websockets.py +++ b/test/test_asgi_websockets.py @@ -30,8 +30,9 @@ class TestASGIWebsockets(TestApplicationPython): self.check_close(sock) - def check_close(self, sock, code=1000, no_close=False): - frame = self.ws.frame_read(sock) + def check_close(self, sock, code=1000, no_close=False, frame=None): + if frame == None: + frame = self.ws.frame_read(sock) assert frame['fin'] == True, 'close fin' assert frame['opcode'] == self.ws.OP_CLOSE, 'close opcode' @@ -930,7 +931,14 @@ class TestASGIWebsockets(TestApplicationPython): self.ws.frame_write(sock, self.ws.OP_CONT, 'fragment2', fin=True) self.ws.frame_write(sock, self.ws.OP_CONT, 'fragment3', fin=False) self.ws.frame_write(sock, self.ws.OP_TEXT, 'fragment4', fin=True) - self.check_close(sock, 1002) + + frame = self.ws.frame_read(sock) + + if frame['opcode'] == self.ws.OP_TEXT: + self.check_frame(frame, True, self.ws.OP_TEXT, 'fragment1fragment2') + frame = None + + self.check_close(sock, 1002, frame=frame) # 5_16 |