@@ -407,13 +407,19 @@ def receive_frame(self, frame):
407
407
# code registry otherwise use the frame's additional data.
408
408
if frame .error_code != 0 :
409
409
try :
410
- name , number , description = errors .get_data (frame .error_code )
410
+ name , number , description = errors .get_data (
411
+ frame .error_code
412
+ )
411
413
except ValueError :
412
- error_string = ("Encountered error code %d, extra data %s" %
413
- (frame .error_code , frame .additional_data ))
414
+ error_string = (
415
+ "Encountered error code %d, extra data %s" %
416
+ (frame .error_code , frame .additional_data )
417
+ )
414
418
else :
415
- error_string = ("Encountered error %s %s: %s" %
416
- (name , number , description ))
419
+ error_string = (
420
+ "Encountered error %s %s: %s" %
421
+ (name , number , description )
422
+ )
417
423
418
424
raise ConnectionError (error_string )
419
425
@@ -458,15 +464,20 @@ def _update_settings(self, frame):
458
464
if SettingsFrame .SETTINGS_MAX_FRAME_SIZE in frame .settings :
459
465
new_size = frame .settings [SettingsFrame .SETTINGS_MAX_FRAME_SIZE ]
460
466
if FRAME_MAX_LEN <= new_size <= FRAME_MAX_ALLOWED_LEN :
461
- self ._settings [SettingsFrame .SETTINGS_MAX_FRAME_SIZE ] = new_size
467
+ self ._settings [SettingsFrame .SETTINGS_MAX_FRAME_SIZE ] = (
468
+ new_size
469
+ )
462
470
else :
463
471
log .warning (
464
472
"Frame size %d is outside of allowed range" ,
465
- new_size )
473
+ new_size
474
+ )
475
+
466
476
# Tear the connection down with error code PROTOCOL_ERROR
467
477
self .close (1 )
468
- error_string = ("Advertised frame size %d is outside of range" %
469
- (new_size ))
478
+ error_string = (
479
+ "Advertised frame size %d is outside of range" % (new_size )
480
+ )
470
481
raise ConnectionError (error_string )
471
482
472
483
def _new_stream (self , stream_id = None , local_closed = False ):
@@ -510,11 +521,12 @@ def _send_cb(self, frame, tolerate_peer_gone=False):
510
521
511
522
data = frame .serialize ()
512
523
513
- if frame .body_len > self ._settings [SettingsFrame .SETTINGS_MAX_FRAME_SIZE ]:
524
+ max_frame_size = self ._settings [SettingsFrame .SETTINGS_MAX_FRAME_SIZE ]
525
+ if frame .body_len > max_frame_size :
514
526
raise ValueError (
515
527
"Frame size %d exceeds maximum frame size setting %d" %
516
528
(frame .body_len ,
517
- self ._settings [SettingsFrame .SETTINGS_MAX_FRAME_SIZE ])
529
+ self ._settings [SettingsFrame .SETTINGS_MAX_FRAME_SIZE ])
518
530
)
519
531
520
532
log .info (
@@ -526,7 +538,8 @@ def _send_cb(self, frame, tolerate_peer_gone=False):
526
538
try :
527
539
self ._sock .send (data )
528
540
except socket .error as e :
529
- if not tolerate_peer_gone or e .errno not in (errno .EPIPE , errno .ECONNRESET ):
541
+ if (not tolerate_peer_gone or
542
+ e .errno not in (errno .EPIPE , errno .ECONNRESET )):
530
543
raise
531
544
532
545
def _adjust_receive_window (self , frame_len ):
0 commit comments