|
36 | 36 | # Cover our bases because NPN doesn't yet work on all our test platforms.
|
37 | 37 | hyper.http20.connection.H2_NPN_PROTOCOLS += ['', None]
|
38 | 38 |
|
| 39 | + |
39 | 40 | def decode_frame(frame_data):
|
40 | 41 | f, length = Frame.parse_frame_header(frame_data[:9])
|
41 | 42 | f.parse_body(memoryview(frame_data[9:9 + length]))
|
@@ -249,7 +250,7 @@ def socket_handler(listener):
|
249 | 250 | send_event.set()
|
250 | 251 |
|
251 | 252 | # Check that we closed the connection.
|
252 |
| - assert conn._sock == None |
| 253 | + assert conn._sock is None |
253 | 254 |
|
254 | 255 | self.tear_down()
|
255 | 256 |
|
@@ -302,8 +303,10 @@ def socket_handler(listener):
|
302 | 303 | receive_preamble(sock)
|
303 | 304 | sock.recv(65535)
|
304 | 305 |
|
305 |
| - # Now, send the headers for the response. This response has no body. |
306 |
| - f = build_headers_frame([(':status', '204'), ('content-length', '0')]) |
| 306 | + # Now, send the headers for the response. This response has no body |
| 307 | + f = build_headers_frame( |
| 308 | + [(':status', '204'), ('content-length', '0')] |
| 309 | + ) |
307 | 310 | f.flags.add('END_STREAM')
|
308 | 311 | f.stream_id = 1
|
309 | 312 | sock.send(f.serialize())
|
@@ -338,7 +341,6 @@ def socket_handler(listener):
|
338 | 341 | sock = listener.accept()[0]
|
339 | 342 |
|
340 | 343 | e = Encoder()
|
341 |
| - e.huffman_coder = HuffmanEncoder(REQUEST_CODES, REQUEST_CODES_LENGTH) |
342 | 344 |
|
343 | 345 | # We get two messages for the connection open and then a HEADERS
|
344 | 346 | # frame.
|
@@ -402,7 +404,6 @@ def socket_handler(listener):
|
402 | 404 | sock = listener.accept()[0]
|
403 | 405 |
|
404 | 406 | e = Encoder()
|
405 |
| - e.huffman_coder = HuffmanEncoder(REQUEST_CODES, REQUEST_CODES_LENGTH) |
406 | 407 |
|
407 | 408 | # We get two messages for the connection open and then a HEADERS
|
408 | 409 | # frame.
|
@@ -549,10 +550,11 @@ def socket_handler(listener):
|
549 | 550 |
|
550 | 551 | h = HeadersFrame(1)
|
551 | 552 | h.data = self.get_encoder().encode(
|
552 |
| - [(':status', 200), |
553 |
| - ('content-type', 'not/real'), |
554 |
| - ('content-length', 14), |
555 |
| - ('server', 'socket-level-server') |
| 553 | + [ |
| 554 | + (':status', 200), |
| 555 | + ('content-type', 'not/real'), |
| 556 | + ('content-length', 14), |
| 557 | + ('server', 'socket-level-server') |
556 | 558 | ]
|
557 | 559 | )
|
558 | 560 | h.flags.add('END_HEADERS')
|
@@ -597,10 +599,11 @@ def socket_handler(listener):
|
597 | 599 |
|
598 | 600 | h = HeadersFrame(1)
|
599 | 601 | h.data = self.get_encoder().encode(
|
600 |
| - [(':status', 200), |
601 |
| - ('content-type', 'not/real'), |
602 |
| - ('content-length', 12), |
603 |
| - ('server', 'socket-level-server') |
| 602 | + [ |
| 603 | + (':status', 200), |
| 604 | + ('content-type', 'not/real'), |
| 605 | + ('content-length', 12), |
| 606 | + ('server', 'socket-level-server') |
604 | 607 | ]
|
605 | 608 | )
|
606 | 609 | h.flags.add('END_HEADERS')
|
@@ -884,9 +887,10 @@ def socket_handler(listener):
|
884 | 887 | # Respond!
|
885 | 888 | h = HeadersFrame(1)
|
886 | 889 | h.data = self.get_encoder().encode(
|
887 |
| - [(':status', 200), |
888 |
| - ('content-type', 'not/real'), |
889 |
| - ('content-length', 20), |
| 890 | + [ |
| 891 | + (':status', 200), |
| 892 | + ('content-type', 'not/real'), |
| 893 | + ('content-length', 20), |
890 | 894 | ]
|
891 | 895 | )
|
892 | 896 | h.flags.add('END_HEADERS')
|
@@ -942,9 +946,10 @@ def socket_handler(listener):
|
942 | 946 | # Respond!
|
943 | 947 | h = HeadersFrame(1)
|
944 | 948 | h.data = self.get_encoder().encode(
|
945 |
| - [(':status', 200), |
946 |
| - ('content-type', 'not/real'), |
947 |
| - ('content-length', 20), |
| 949 | + [ |
| 950 | + (':status', 200), |
| 951 | + ('content-type', 'not/real'), |
| 952 | + ('content-length', 20), |
948 | 953 | ]
|
949 | 954 | )
|
950 | 955 | h.flags.add('END_HEADERS')
|
|
0 commit comments