diff --git a/src/runtime/endpoints.rs b/src/runtime/endpoints.rs index 36c8a1de749887f8f1c2dbd51eecece32f65b9bf..ce5dfa05290a337d006c69856dad3f5b27c9834f 100644 --- a/src/runtime/endpoints.rs +++ b/src/runtime/endpoints.rs @@ -237,7 +237,7 @@ impl EndpointManager { self.udp_endpoint_store.polled_undrained.insert(index); if !ee.received_this_round { let payload = Payload::from(&recv_buffer[..bytes_written]); - let port_spec_var = rctx.current_state.spec_var_for(ee.getter_for_incoming); + let port_spec_var = rctx.ips.spec_var_for(ee.getter_for_incoming); let predicate = Predicate::singleton(port_spec_var, SpecVal::FIRING); rctx.getter_push( ee.getter_for_incoming,