Searched refs:state_change (Results 1 – 6 of 6) sorted by relevance
42 state_change = debug_service_pb2.EventReply.DebugOpStateChange()43 state_change.state = new_state44 state_change.node_name = node_name45 state_change.output_slot = output_slot46 state_change.debug_op = debug_op47 return state_change200 state_change = self._debug_ops_state_change_queue.get()201 debug_node_key = (state_change.node_name, state_change.output_slot,202 state_change.debug_op)203 if (state_change.state ==[all …]
636 ConnectivityStateChange state_change) { in PushConnectivityStateChange() argument638 connectivity_state_queue_.push_back(std::move(state_change)); in PushConnectivityStateChange()645 ConnectivityStateChange state_change = connectivity_state_queue_.front(); in PopConnectivityStateChange() local647 return state_change; in PopConnectivityStateChange()
201 void PushConnectivityStateChange(ConnectivityStateChange state_change);
1476 ConnectivityStateChange state_change = PopConnectivityStateChange(); in ApplyUpdateInControlPlaneWorkSerializer() local1478 state_change.status.GetPayload(kKeepaliveThrottlingKey); in ApplyUpdateInControlPlaneWorkSerializer()1506 last_seen_state_ = state_change.state; in ApplyUpdateInControlPlaneWorkSerializer()1508 std::move(state_change.connected_subchannel)); in ApplyUpdateInControlPlaneWorkSerializer()1509 watcher_->OnConnectivityStateChange(state_change.state); in ApplyUpdateInControlPlaneWorkSerializer()
438 for (const auto& state_change : events.instance_state_changes()) { in OnObservableEvents() local439 DataSourceHandle handle{state_change.producer_name(), in OnObservableEvents()440 state_change.data_source_name()}; in OnObservableEvents()442 state_change.state() == in OnObservableEvents()
466 struct cec_event_state_change state_change; member