|
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