File tree Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Expand file tree Collapse file tree 1 file changed +6
-1
lines changed Original file line number Diff line number Diff line change @@ -11,7 +11,7 @@ use crate::chunk::{
11
11
chunk_reconfig:: ChunkReconfig , chunk_selective_ack:: ChunkSelectiveAck ,
12
12
chunk_shutdown:: ChunkShutdown , chunk_shutdown_ack:: ChunkShutdownAck ,
13
13
chunk_shutdown_complete:: ChunkShutdownComplete , chunk_type:: CT_FORWARD_TSN , Chunk ,
14
- ErrorCauseUnrecognizedChunkType ,
14
+ ErrorCauseUnrecognizedChunkType , USER_INITIATED_ABORT ,
15
15
} ;
16
16
use crate :: config:: { ServerConfig , TransportConfig , COMMON_HEADER_SIZE , DATA_CHUNK_HEADER_SIZE } ;
17
17
use crate :: error:: { Error , Result } ;
@@ -829,6 +829,11 @@ impl Association {
829
829
} else if let Some ( c) = chunk_any. downcast_ref :: < ChunkAbort > ( ) {
830
830
let mut err_str = String :: new ( ) ;
831
831
for e in & c. error_causes {
832
+ if matches ! ( e. code, USER_INITIATED_ABORT ) {
833
+ debug ! ( "User initiated abort received" ) ;
834
+ let _ = self . close ( ) ;
835
+ return Ok ( ( ) ) ;
836
+ }
832
837
err_str += & format ! ( "({})" , e) ;
833
838
}
834
839
return Err ( Error :: ErrAbortChunk ( err_str) ) ;
You can’t perform that action at this time.
0 commit comments