File tree Expand file tree Collapse file tree 1 file changed +2
-10
lines changed
vm/devices/net/netvsp/src Expand file tree Collapse file tree 1 file changed +2
-10
lines changed Original file line number Diff line number Diff line change @@ -1208,7 +1208,6 @@ impl VmbusDevice for Nic {
1208
1208
. unwrap ( )
1209
1209
. channel
1210
1210
. packet_filter ;
1211
- self . coordinator . state_mut ( ) . unwrap ( ) . workers [ 0 ] . start ( ) ;
1212
1211
(
1213
1212
WorkerState :: Ready ( ReadyState {
1214
1213
state : ActiveState :: new ( None , buffers. recv_buffer . count ) ,
@@ -3970,7 +3969,6 @@ impl Coordinator {
3970
3969
}
3971
3970
} ) ;
3972
3971
}
3973
- self . restart = true ; // Restart the workers
3974
3972
}
3975
3973
3976
3974
if update_type. guest_vf_state {
@@ -4418,13 +4416,7 @@ impl Coordinator {
4418
4416
self . num_queues = num_queues;
4419
4417
}
4420
4418
4421
- let primary_packet_filter = primary_worker
4422
- . get ( )
4423
- . 1
4424
- . as_ref ( )
4425
- . unwrap ( )
4426
- . channel
4427
- . packet_filter ;
4419
+ let primary_packet_filter = state. state . primary . as_ref ( ) . unwrap ( ) . packet_filter ;
4428
4420
4429
4421
// Provide the queue and receive buffer ranges for each worker.
4430
4422
for ( ( worker, queue) , rx_buffer) in self . workers . iter_mut ( ) . zip ( queues) . zip ( rx_buffers) {
@@ -4434,7 +4426,7 @@ impl Coordinator {
4434
4426
rx_buffer_range : rx_buffer,
4435
4427
} ) ;
4436
4428
// Update the receive packet filter for the subchannel worker.
4437
- if let Some ( worker) = worker. get_mut ( ) . 1 . as_mut ( ) {
4429
+ if let Some ( worker) = worker. state_mut ( ) {
4438
4430
worker. channel . packet_filter = primary_packet_filter;
4439
4431
}
4440
4432
}
You can’t perform that action at this time.
0 commit comments