Skip to content
This repository was archived by the owner on Jan 13, 2021. It is now read-only.

Commit 3018e6f

Browse files
committed
Fixup some events in H2 integration tests.
1 parent c72f4da commit 3018e6f

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

test/test_integration.py

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -84,13 +84,13 @@ def socket_handler(listener):
8484
f = SettingsFrame(0)
8585
sock.send(f.serialize())
8686

87-
send_event.set()
87+
send_event.wait()
8888
sock.close()
8989

9090
self._start_server(socket_handler)
9191
conn = self.get_connection()
9292
conn.connect()
93-
send_event.wait()
93+
send_event.set()
9494

9595
assert data[0] == b'PRI * HTTP/2.0\r\n\r\nSM\r\n\r\n'
9696

@@ -118,13 +118,13 @@ def socket_handler(listener):
118118
f = SettingsFrame(0)
119119
sock.send(f.serialize())
120120

121-
send_event.set()
121+
send_event.wait()
122122
sock.close()
123123

124124
self._start_server(socket_handler)
125125
conn = self.get_connection()
126126
conn.connect()
127-
send_event.wait()
127+
send_event.set()
128128

129129
# Get the second chunk of data and decode it into a frame.
130130
data = data[1]
@@ -229,13 +229,13 @@ def socket_handler(listener):
229229
f = SettingsFrame(0)
230230
sock.send(f.serialize())
231231

232-
send_event.set()
232+
send_event.wait()
233233
sock.close()
234234

235235
self._start_server(socket_handler)
236236
with self.get_connection() as conn:
237237
conn.connect()
238-
send_event.wait()
238+
send_event.set()
239239

240240
# Check that we closed the connection.
241241
assert conn._sock == None

0 commit comments

Comments
 (0)