Home
last modified time | relevance | path

Searched refs:endpoint_state (Results 1 – 25 of 30) sorted by relevance

12

/dports/net/openmpi3/openmpi-3.1.6/opal/mca/btl/tcp/
H A Dbtl_tcp_endpoint.c84 endpoint->endpoint_state = MCA_BTL_TCP_CLOSED; in mca_btl_tcp_endpoint_construct()
193 switch(btl_endpoint->endpoint_state) { in mca_btl_tcp_endpoint_dump()
333 switch(btl_endpoint->endpoint_state) { in mca_btl_tcp_endpoint_send()
339 if(btl_endpoint->endpoint_state == MCA_BTL_TCP_CLOSED) in mca_btl_tcp_endpoint_send()
550 btl_endpoint->endpoint_state = MCA_BTL_TCP_CLOSED; in mca_btl_tcp_endpoint_close()
563 btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECTED; in mca_btl_tcp_endpoint_connected()
765 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_endpoint_start_connect()
836 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_endpoint_complete_connect()
876 switch(btl_endpoint->endpoint_state) { in mca_btl_tcp_endpoint_recv_handler()
973 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_endpoint_recv_handler()
[all …]
H A Dbtl_tcp_frag.c131 frag->endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_send()
138 frag->endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_send()
215 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_recv()
228 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_recv()
237 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_recv()
245 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_recv()
H A Dbtl_tcp_endpoint.h63 mca_btl_tcp_state_t endpoint_state; /**< current state of the connection */ member
/dports/net/openmpi/openmpi-4.1.1/opal/mca/btl/tcp/
H A Dbtl_tcp_endpoint.c84 endpoint->endpoint_state = MCA_BTL_TCP_CLOSED; in mca_btl_tcp_endpoint_construct()
193 switch(btl_endpoint->endpoint_state) { in mca_btl_tcp_endpoint_dump()
333 switch(btl_endpoint->endpoint_state) { in mca_btl_tcp_endpoint_send()
339 if(btl_endpoint->endpoint_state == MCA_BTL_TCP_CLOSED) in mca_btl_tcp_endpoint_send()
550 btl_endpoint->endpoint_state = MCA_BTL_TCP_CLOSED; in mca_btl_tcp_endpoint_close()
563 btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECTED; in mca_btl_tcp_endpoint_connected()
798 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_endpoint_start_connect()
869 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_endpoint_complete_connect()
909 switch(btl_endpoint->endpoint_state) { in mca_btl_tcp_endpoint_recv_handler()
1006 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_endpoint_recv_handler()
[all …]
H A Dbtl_tcp_frag.c131 frag->endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_send()
138 frag->endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_send()
215 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_recv()
228 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_recv()
237 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_recv()
245 btl_endpoint->endpoint_state = MCA_BTL_TCP_FAILED; in mca_btl_tcp_frag_recv()
H A Dbtl_tcp_endpoint.h63 mca_btl_tcp_state_t endpoint_state; /**< current state of the connection */ member
H A Dbtl_tcp_proc.c855 } else if (btl_endpoint->endpoint_state != MCA_BTL_TCP_CLOSED) { in mca_btl_tcp_proc_accept()
876 } else if (btl_endpoint->endpoint_state != MCA_BTL_TCP_CLOSED) { in mca_btl_tcp_proc_accept()
888 btl_endpoint->endpoint_state = MCA_BTL_TCP_CONNECTING; in mca_btl_tcp_proc_accept()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/nearby/src/cpp/core/internal/
H A Dendpoint_manager.cc323 EndpointState& endpoint_state = item->second; in EnsureWorkersTerminated() local
326 endpoint_state.barrier.Await(); in EnsureWorkersTerminated()
358 EndpointState& endpoint_state = in RegisterEndpoint() local
360 endpoint_state.client = client; in RegisterEndpoint()
371 [this, client, endpoint_id, barrier = &endpoint_state.barrier]() { in RegisterEndpoint()
392 barrier = &endpoint_state.barrier]() { in RegisterEndpoint()
/dports/devel/grpc134/grpc-1.34.1/src/core/ext/xds/
H A Dxds_client.cc1065 EndpointState& endpoint_state = in AcceptCdsUpdate() local
1067 endpoint_state.update.reset(); in AcceptCdsUpdate()
1093 EndpointState& endpoint_state = in AcceptEdsUpdate() local
1096 if (endpoint_state.update.has_value() && in AcceptEdsUpdate()
1097 *endpoint_state.update == eds_update) { in AcceptEdsUpdate()
1106 endpoint_state.update = std::move(eds_update); in AcceptEdsUpdate()
1937 endpoint_state.watchers[w] = std::move(watcher); in WatchEndpointData()
1940 if (endpoint_state.update.has_value()) { in WatchEndpointData()
1958 if (it != endpoint_state.watchers.end()) { in CancelEndpointDataWatch()
1959 endpoint_state.watchers.erase(it); in CancelEndpointDataWatch()
[all …]
/dports/net-im/telepathy-glib/telepathy-glib-0.24.1/telepathy-glib/
H A Dcall-stream-endpoint.c119 GHashTable *endpoint_state; member
140 self->priv->endpoint_state = g_hash_table_new (NULL, NULL); in tp_call_stream_endpoint_init()
180 tp_clear_pointer (&self->priv->endpoint_state, g_hash_table_unref); in tp_call_stream_endpoint_finalize()
219 g_value_set_boxed (value, self->priv->endpoint_state); in tp_call_stream_endpoint_get_property()
554 return GPOINTER_TO_UINT (g_hash_table_lookup (self->priv->endpoint_state, in tp_call_stream_endpoint_get_state()
850 g_hash_table_insert (self->priv->endpoint_state, in call_stream_endpoint_set_endpoint_state()
/dports/devel/grpc130/grpc-1.30.2/src/core/ext/filters/client_channel/xds/
H A Dxds_client.cc1059 EndpointState& endpoint_state = in AcceptCdsUpdate() local
1061 endpoint_state.update.reset(); in AcceptCdsUpdate()
1124 EndpointState& endpoint_state = in AcceptEdsUpdate() local
1127 if (endpoint_state.update.has_value()) { in AcceptEdsUpdate()
1144 endpoint_state.update = std::move(eds_update); in AcceptEdsUpdate()
1887 endpoint_state.watchers[w] = std::move(watcher); in WatchEndpointData()
1890 if (endpoint_state.update.has_value()) { in WatchEndpointData()
1906 auto it = endpoint_state.watchers.find(watcher); in CancelEndpointDataWatch()
1907 if (it != endpoint_state.watchers.end()) { in CancelEndpointDataWatch()
1908 endpoint_state.watchers.erase(it); in CancelEndpointDataWatch()
[all …]
/dports/devel/grpc/grpc-1.42.0/src/core/ext/xds/
H A Dxds_client.cc1229 endpoint_state.update.reset(); in AcceptCdsUpdateLocked()
1261 EndpointState& endpoint_state = in AcceptEdsUpdateLocked() local
1266 if (endpoint_state.update.has_value() && in AcceptEdsUpdateLocked()
1267 *endpoint_state.update == eds_update) { in AcceptEdsUpdateLocked()
1276 endpoint_state.update = std::move(eds_update); in AcceptEdsUpdateLocked()
2280 endpoint_state.watchers[w] = std::move(watcher); in WatchEndpointData()
2283 if (endpoint_state.update.has_value()) { in WatchEndpointData()
2308 auto it = endpoint_state.watchers.find(watcher); in CancelEndpointDataWatch()
2309 if (it == endpoint_state.watchers.end()) { in CancelEndpointDataWatch()
2313 endpoint_state.watchers.erase(it); in CancelEndpointDataWatch()
[all …]
/dports/devel/pecl-grpc/grpc-1.42.0/src/core/ext/xds/
H A Dxds_client.cc1229 endpoint_state.update.reset(); in AcceptCdsUpdateLocked()
1261 EndpointState& endpoint_state = in AcceptEdsUpdateLocked() local
1266 if (endpoint_state.update.has_value() && in AcceptEdsUpdateLocked()
1267 *endpoint_state.update == eds_update) { in AcceptEdsUpdateLocked()
1276 endpoint_state.update = std::move(eds_update); in AcceptEdsUpdateLocked()
2280 endpoint_state.watchers[w] = std::move(watcher); in WatchEndpointData()
2283 if (endpoint_state.update.has_value()) { in WatchEndpointData()
2308 auto it = endpoint_state.watchers.find(watcher); in CancelEndpointDataWatch()
2309 if (it == endpoint_state.watchers.end()) { in CancelEndpointDataWatch()
2313 endpoint_state.watchers.erase(it); in CancelEndpointDataWatch()
[all …]
/dports/devel/py-grpcio/grpcio-1.43.0/src/core/ext/xds/
H A Dxds_client.cc1263 EndpointState& endpoint_state = xds_client() in AcceptEdsUpdateLocked() local
1267 if (endpoint_state.update.has_value() && in AcceptEdsUpdateLocked()
1268 *endpoint_state.update == eds_update) { in AcceptEdsUpdateLocked()
1277 endpoint_state.update = std::move(eds_update); in AcceptEdsUpdateLocked()
1281 auto& watchers_list = endpoint_state.watchers; in AcceptEdsUpdateLocked()
1282 auto& value = endpoint_state.update.value(); in AcceptEdsUpdateLocked()
2352 endpoint_state.watchers[w] = watcher; in WatchEndpointData()
2355 if (endpoint_state.update.has_value()) { in WatchEndpointData()
2390 if (it == endpoint_state.watchers.end()) { in CancelEndpointDataWatch()
2394 endpoint_state.watchers.erase(it); in CancelEndpointDataWatch()
[all …]
/dports/net/openmpi/openmpi-4.1.1/opal/mca/btl/openib/connect/
H A Dbtl_openib_connect_rdmacm.c798 b = stringify(message->ipaddr), message->tcp_port, endpoint->endpoint_state));
804 message->ipaddr, message->tcp_port, endpoint->endpoint_state));
806 if (MCA_BTL_IB_CONNECTED == endpoint->endpoint_state ||
807 MCA_BTL_IB_CONNECTING == endpoint->endpoint_state ||
808 MCA_BTL_IB_CONNECT_ACK == endpoint->endpoint_state) {
815 endpoint->endpoint_state = MCA_BTL_IB_CONNECTING;
992 endpoint->endpoint_state, contents->ipaddr, message->ipaddr,
1024 endpoint->endpoint_state = MCA_BTL_IB_CONNECTING;
1319 endpoint->endpoint_state));
H A Dbtl_openib_connect_udcm.c818 if (MCA_BTL_IB_CLOSED != lcl_ep->endpoint_state) { in udcm_module_start_connect()
821 (void *) lcl_ep, lcl_ep->endpoint_state)); in udcm_module_start_connect()
828 lcl_ep->endpoint_state = MCA_BTL_IB_CONNECTING; in udcm_module_start_connect()
1876 if (MCA_BTL_IB_CLOSED == lcl_ep->endpoint_state) { in udcm_handle_connect()
1877 lcl_ep->endpoint_state = MCA_BTL_IB_CONNECTING; in udcm_handle_connect()
2306 MCA_BTL_IB_CONNECTED == lcl_ep->endpoint_state || in udcm_send_timeout()
2391 lcl_ep->endpoint_state = MCA_BTL_IB_CONNECTING; in udcm_xrc_start_connect()
/dports/net/openmpi3/openmpi-3.1.6/opal/mca/btl/openib/connect/
H A Dbtl_openib_connect_rdmacm.c798 b = stringify(message->ipaddr), message->tcp_port, endpoint->endpoint_state));
804 message->ipaddr, message->tcp_port, endpoint->endpoint_state));
806 if (MCA_BTL_IB_CONNECTED == endpoint->endpoint_state ||
807 MCA_BTL_IB_CONNECTING == endpoint->endpoint_state ||
808 MCA_BTL_IB_CONNECT_ACK == endpoint->endpoint_state) {
815 endpoint->endpoint_state = MCA_BTL_IB_CONNECTING;
992 endpoint->endpoint_state, contents->ipaddr, message->ipaddr,
1024 endpoint->endpoint_state = MCA_BTL_IB_CONNECTING;
1311 endpoint->endpoint_state));
/dports/net/openmpi/openmpi-4.1.1/opal/mca/btl/openib/
H A Dbtl_openib_get.c95 if (ep->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_get()
H A Dbtl_openib_atomic.c78 if (endpoint->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_atomic_internal()
H A Dbtl_openib_put.c103 if (ep->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_put()
H A Dbtl_openib_endpoint.h200 mca_btl_openib_endpoint_state_t endpoint_state; member
500 switch(ep->endpoint_state) { in check_endpoint_state()
/dports/net/openmpi3/openmpi-3.1.6/opal/mca/btl/openib/
H A Dbtl_openib_get.c95 if (ep->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_get()
H A Dbtl_openib_atomic.c78 if (endpoint->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_atomic_internal()
H A Dbtl_openib_put.c103 if (ep->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_put()
H A Dbtl_openib_endpoint.h200 mca_btl_openib_endpoint_state_t endpoint_state; member
498 switch(ep->endpoint_state) { in check_endpoint_state()

12