File tree 1 file changed +12
-11
lines changed
1 file changed +12
-11
lines changed Original file line number Diff line number Diff line change @@ -76,21 +76,22 @@ where
76
76
77
77
#[ cfg( all( feature = "server" , feature = "runtime" ) ) ]
78
78
if !* ctx. h1_header_read_timeout_running {
79
- if let Some ( h1_header_read_timeout) = ctx. h1_header_read_timeout {
80
- let deadline = Instant :: now ( ) + h1_header_read_timeout;
79
+ if let Some ( h1_header_read_timeout) = ctx. h1_header_read_timeout {
80
+ let deadline = Instant :: now ( ) + h1_header_read_timeout;
81
81
82
- match ctx. h1_header_read_timeout_fut {
83
- Some ( h1_header_read_timeout_fut) => {
84
- debug ! ( "resetting h1 header read timeout timer" ) ;
85
- h1_header_read_timeout_fut. as_mut ( ) . reset ( deadline) ;
86
- } ,
87
- None => {
88
- debug ! ( "setting h1 header read timeout timer" ) ;
89
- * ctx. h1_header_read_timeout_fut = Some ( Box :: pin ( tokio:: time:: sleep_until ( deadline) ) ) ;
82
+ match ctx. h1_header_read_timeout_fut {
83
+ Some ( h1_header_read_timeout_fut) => {
84
+ debug ! ( "resetting h1 header read timeout timer" ) ;
85
+ h1_header_read_timeout_fut. as_mut ( ) . reset ( deadline) ;
86
+ }
87
+ None => {
88
+ debug ! ( "setting h1 header read timeout timer" ) ;
89
+ * ctx. h1_header_read_timeout_fut =
90
+ Some ( Box :: pin ( tokio:: time:: sleep_until ( deadline) ) ) ;
91
+ }
90
92
}
91
93
}
92
94
}
93
- }
94
95
95
96
T :: parse ( bytes, ctx)
96
97
}
You can’t perform that action at this time.
0 commit comments