/dports/net/openmpi3/openmpi-3.1.6/opal/mca/btl/tcp/ |
H A D | btl_tcp_endpoint.c | 84 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 D | btl_tcp_frag.c | 131 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 D | btl_tcp_endpoint.h | 63 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 D | btl_tcp_endpoint.c | 84 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 D | btl_tcp_frag.c | 131 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 D | btl_tcp_endpoint.h | 63 mca_btl_tcp_state_t endpoint_state; /**< current state of the connection */ member
|
H A D | btl_tcp_proc.c | 855 } 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 D | endpoint_manager.cc | 323 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 D | xds_client.cc | 1065 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 D | call-stream-endpoint.c | 119 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 D | xds_client.cc | 1059 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 D | xds_client.cc | 1229 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 D | xds_client.cc | 1229 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 D | xds_client.cc | 1263 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 D | btl_openib_connect_rdmacm.c | 798 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 D | btl_openib_connect_udcm.c | 818 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 D | btl_openib_connect_rdmacm.c | 798 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 D | btl_openib_get.c | 95 if (ep->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_get()
|
H A D | btl_openib_atomic.c | 78 if (endpoint->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_atomic_internal()
|
H A D | btl_openib_put.c | 103 if (ep->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_put()
|
H A D | btl_openib_endpoint.h | 200 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 D | btl_openib_get.c | 95 if (ep->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_get()
|
H A D | btl_openib_atomic.c | 78 if (endpoint->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_atomic_internal()
|
H A D | btl_openib_put.c | 103 if (ep->endpoint_state != MCA_BTL_IB_CONNECTED) { in mca_btl_openib_put()
|
H A D | btl_openib_endpoint.h | 200 mca_btl_openib_endpoint_state_t endpoint_state; member 498 switch(ep->endpoint_state) { in check_endpoint_state()
|