File tree Expand file tree Collapse file tree 2 files changed +8
-1
lines changed Expand file tree Collapse file tree 2 files changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -3,6 +3,7 @@ mod association_internal_test;
3
3
4
4
use super :: * ;
5
5
6
+ use crate :: param:: param_forward_tsn_supported:: ParamForwardTsnSupported ;
6
7
use crate :: param:: param_type:: ParamType ;
7
8
use crate :: param:: param_unrecognized:: ParamUnrecognized ;
8
9
use async_trait:: async_trait;
@@ -769,6 +770,12 @@ impl AssociationInternal {
769
770
self . use_forward_tsn = true ;
770
771
}
771
772
}
773
+ } else if param
774
+ . as_any ( )
775
+ . downcast_ref :: < ParamForwardTsnSupported > ( )
776
+ . is_some ( )
777
+ {
778
+ self . use_forward_tsn = true ;
772
779
}
773
780
}
774
781
if !self . use_forward_tsn {
Original file line number Diff line number Diff line change @@ -169,7 +169,7 @@ impl Chunk for ChunkInit {
169
169
let mut params = vec ! [ ] ;
170
170
let mut offset = CHUNK_HEADER_SIZE + INIT_CHUNK_MIN_LENGTH ;
171
171
let mut remaining = raw. len ( ) as isize - offset as isize ;
172
- while remaining > INIT_OPTIONAL_VAR_HEADER_LENGTH as isize {
172
+ while remaining >= INIT_OPTIONAL_VAR_HEADER_LENGTH as isize {
173
173
let p = build_param ( & raw . slice ( offset..CHUNK_HEADER_SIZE + header. value_length ( ) ) ) ?;
174
174
let p_len = PARAM_HEADER_LENGTH + p. value_length ( ) ;
175
175
let len_plus_padding = p_len + get_padding_size ( p_len) ;
You can’t perform that action at this time.
0 commit comments