File tree Expand file tree Collapse file tree 4 files changed +6
-6
lines changed
replicated_state/src/canister_state Expand file tree Collapse file tree 4 files changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -1124,7 +1124,7 @@ impl CanisterQueues {
1124
1124
& mut self ,
1125
1125
request : Request ,
1126
1126
reject_context : RejectContext ,
1127
- subnet_ids : & [ PrincipalId ] ,
1127
+ subnet_ids : & BTreeSet < PrincipalId > ,
1128
1128
) -> Result < ( ) , StateError > {
1129
1129
assert ! (
1130
1130
request. receiver == IC_00 || subnet_ids. contains( & request. receiver. get( ) ) ,
Original file line number Diff line number Diff line change @@ -2689,7 +2689,7 @@ fn test_reject_subnet_output_request() {
2689
2689
2690
2690
// Reject an output request without having enqueued it first.
2691
2691
queues
2692
- . reject_subnet_output_request ( request, reject_context. clone ( ) , & [ ] )
2692
+ . reject_subnet_output_request ( request, reject_context. clone ( ) , & BTreeSet :: new ( ) )
2693
2693
. unwrap ( ) ;
2694
2694
2695
2695
// There is now a reject response.
Original file line number Diff line number Diff line change @@ -1152,7 +1152,7 @@ impl SystemState {
1152
1152
& mut self ,
1153
1153
request : Request ,
1154
1154
reject_context : RejectContext ,
1155
- subnet_ids : & [ PrincipalId ] ,
1155
+ subnet_ids : & BTreeSet < PrincipalId > ,
1156
1156
) -> Result < ( ) , StateError > {
1157
1157
assert_eq ! (
1158
1158
request. sender, self . canister_id,
Original file line number Diff line number Diff line change @@ -151,7 +151,7 @@ impl SystemStateModifications {
151
151
152
152
fn reject_subnet_message_routing (
153
153
system_state : & mut SystemState ,
154
- subnet_ids : & [ PrincipalId ] ,
154
+ subnet_ids : & BTreeSet < PrincipalId > ,
155
155
msg : Request ,
156
156
err : ResolveDestinationError ,
157
157
logger : & ReplicaLogger ,
@@ -178,7 +178,7 @@ impl SystemStateModifications {
178
178
179
179
fn reject_subnet_message_user_error (
180
180
system_state : & mut SystemState ,
181
- subnet_ids : & [ PrincipalId ] ,
181
+ subnet_ids : & BTreeSet < PrincipalId > ,
182
182
msg : Request ,
183
183
err : UserError ,
184
184
logger : & ReplicaLogger ,
@@ -367,7 +367,7 @@ impl SystemStateModifications {
367
367
// Push outgoing messages.
368
368
let mut callback_changes = BTreeMap :: new ( ) ;
369
369
let nns_subnet_id = network_topology. nns_subnet_id ;
370
- let subnet_ids: Vec < PrincipalId > =
370
+ let subnet_ids: BTreeSet < PrincipalId > =
371
371
network_topology. subnets . keys ( ) . map ( |s| s. get ( ) ) . collect ( ) ;
372
372
for mut msg in self . requests {
373
373
if msg. receiver == IC_00 {
You can’t perform that action at this time.
0 commit comments