| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | tcp_server_posix.cc | 242 acceptor->port_index = sp->port_index; in on_read()
268 unsigned port_index, in add_wildcard_addrs_to_server() argument
282 return grpc_tcp_server_add_all_local_addrs(s, port_index, requested_port, in add_wildcard_addrs_to_server()
288 if ((v6_err = grpc_tcp_server_add_addr(s, &wild6, port_index, fd_index, in add_wildcard_addrs_to_server()
298 if ((v4_err = grpc_tcp_server_add_addr(s, &wild4, port_index, fd_index, in add_wildcard_addrs_to_server()
368 sp->port_index = listener->port_index; in clone_port()
388 unsigned port_index = 0; in tcp_server_add_port() local
393 port_index = s->tail->port_index + 1; in tcp_server_add_port()
419 return add_wildcard_addrs_to_server(s, port_index, requested_port, in tcp_server_add_port()
425 if ((err = grpc_tcp_server_add_addr(s, addr, port_index, 0, &dsmode, &sp)) == in tcp_server_add_port()
[all …]
|
| D | tcp_server.h | 38 unsigned port_index; member
57 unsigned (*port_fd_count)(grpc_tcp_server* s, unsigned port_index);
58 int (*port_fd)(grpc_tcp_server* s, unsigned port_index, unsigned fd_index);
93 unsigned grpc_tcp_server_port_fd_count(grpc_tcp_server* s, unsigned port_index);
99 int grpc_tcp_server_port_fd(grpc_tcp_server* s, unsigned port_index,
|
| D | tcp_server_custom.cc | 44 unsigned port_index; member
234 acceptor->port_index = sp->port_index; in finish_accept()
273 unsigned port_index, in add_socket_to_server() argument
314 sp->port_index = port_index; in add_socket_to_server()
332 unsigned port_index = 0; in tcp_server_add_port() local
339 port_index = s->tail->port_index + 1; in tcp_server_add_port()
396 error = add_socket_to_server(s, socket, addr, port_index, &sp); in tcp_server_add_port()
441 unsigned port_index) { in tcp_server_port_fd_count() argument
445 static int tcp_server_port_fd(grpc_tcp_server* s, unsigned port_index, in tcp_server_port_fd() argument
|
| D | tcp_server.cc | 45 unsigned port_index) { in grpc_tcp_server_port_fd_count() argument
46 return grpc_tcp_server_impl->port_fd_count(s, port_index); in grpc_tcp_server_port_fd_count()
49 int grpc_tcp_server_port_fd(grpc_tcp_server* s, unsigned port_index, in grpc_tcp_server_port_fd() argument
51 return grpc_tcp_server_impl->port_fd(s, port_index, fd_index); in grpc_tcp_server_port_fd()
|
| D | tcp_server_windows.cc | 60 unsigned port_index; member
373 acceptor->port_index = sp->port_index; in on_accept()
390 unsigned port_index, in add_socket_to_server() argument
437 sp->port_index = port_index; in add_socket_to_server()
455 unsigned port_index = 0; in tcp_server_add_port() local
459 port_index = s->tail->port_index + 1; in tcp_server_add_port()
502 error = add_socket_to_server(s, sock, addr, port_index, &sp); in tcp_server_add_port()
539 unsigned port_index) { in tcp_server_port_fd_count() argument
543 static int tcp_server_port_fd(grpc_tcp_server* s, unsigned port_index, in tcp_server_port_fd() argument
|
| D | tcp_server_utils_posix.h | 36 unsigned port_index; member
101 unsigned port_index, unsigned fd_index,
111 unsigned port_index,
|
| D | tcp_server_utils_posix_common.cc | 82 unsigned port_index, unsigned fd_index, in add_socket_to_server() argument
111 sp->port_index = port_index; in add_socket_to_server()
129 unsigned port_index, unsigned fd_index, in grpc_tcp_server_add_addr() argument
143 return add_socket_to_server(s, fd, addr, port_index, fd_index, listener); in grpc_tcp_server_add_addr()
|
| D | tcp_server_utils_posix_ifaddrs.cc | 90 unsigned port_index, in grpc_tcp_server_add_all_local_addrs() argument
148 if ((err = grpc_tcp_server_add_addr(s, &addr, port_index, fd_index, &dsmode, in grpc_tcp_server_add_all_local_addrs()
|
| D | tcp_server_utils_posix_noifaddrs.cc | 28 unsigned port_index, in grpc_tcp_server_add_all_local_addrs() argument
|
| D | udp_server.h | 84 int grpc_udp_server_get_fd(grpc_udp_server* s, unsigned port_index);
|
| D | udp_server.cc | 694 int grpc_udp_server_get_fd(grpc_udp_server* s, unsigned port_index) { in grpc_udp_server_get_fd() argument
695 if (port_index >= s->listeners.size()) { in grpc_udp_server_get_fd()
699 return s->listeners[port_index].fd(); in grpc_udp_server_get_fd()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | tcp_server_uv_test.cc | 51 unsigned port_index; member
66 result->port_index = 0; in on_connect_result_init()
73 result->port_index = acceptor->port_index; in on_connect_result_set()
257 GPR_ASSERT(result.port_index == 0); in test_connect()
267 GPR_ASSERT(result.port_index == 1); in test_connect()
|
| D | tcp_server_posix_test.cc | 57 unsigned port_index; member
99 result->port_index = 0; in on_connect_result_init()
107 result->port_index = acceptor->port_index; in on_connect_result_set()
110 result->server, acceptor->port_index, acceptor->fd_index); in on_connect_result_set()
273 gpr_log(GPR_INFO, "Result (%d, %d) fd %d", result->port_index, in tcp_connect()
403 GPR_ASSERT(result.port_index == port_num); in test_connect()
407 grpc_tcp_server_port_fd(s, result.port_index, result.fd_index) == in test_connect()
|
| /external/iproute2/devlink/ |
| D | devlink.c | 128 uint32_t port_index; member
134 uint32_t port_index, in ifname_map_alloc() argument
144 ifname_map->port_index = port_index; in ifname_map_alloc()
186 uint32_t port_index; member
218 uint32_t port_index; member
427 *p_port_index = ifname_map->port_index; in ifname_map_lookup()
435 const char *dev_name, uint32_t port_index, in ifname_map_rev_lookup() argument
443 port_index == ifname_map->port_index) { in ifname_map_rev_lookup()
794 &opts->port_index, &handle_bit); in dl_argv_parse()
805 &opts->port_index); in dl_argv_parse()
[all …]
|
| /external/libchrome/mojo/core/ |
| D | user_message_impl.cc | 210 size_t port_index = original_num_ports; in CreateOrExtendSerializedEventMessage() local
229 event->ports() + port_index, in CreateOrExtendSerializedEventMessage()
236 port_index += info.num_ports; in CreateOrExtendSerializedEventMessage()
585 size_t port_index = 0; in ExtractSerializedHandles() local
605 base::CheckedNumeric<size_t> next_port_index = port_index; in ExtractSerializedHandles()
625 message_event_->ports() + port_index, dh.num_ports, out_handles, in ExtractSerializedHandles()
634 port_index = next_port_index.ValueOrDie(); in ExtractSerializedHandles()
|
| /external/tensorflow/tensorflow/contrib/verbs/ |
| D | rdma.cc | 97 int rc, port_index, active_ports = 0; in get_dev_active_port_count() local
104 for (port_index = 1; port_index <= device_att.phys_port_cnt; port_index++) { in get_dev_active_port_count()
105 rc = ibv_query_port(context, port_index, &port_attr); in get_dev_active_port_count()
106 CHECK(!rc) << "Failed to query the port" << port_index; in get_dev_active_port_count()
177 int rc, port_index; in set_port() local
196 for (port_index = 1; port_index <= device_att.phys_port_cnt; port_index++) { in set_port()
197 rc = ibv_query_port(context, port_index, &port_attr); in set_port()
198 CHECK(!rc) << "Failed to query the port" << port_index; in set_port()
200 port_num = port_index; in set_port()
|
| /external/tensorflow/tensorflow/core/grappler/costs/ |
| D | graph_properties.cc | 930 ShapeHandle OutputAsUnion(const NodeDef* node, int port_index, in OutputAsUnion() argument
939 relaxed = GetUnknownOutputShape(node, port_index); in OutputAsUnion()
946 DimensionHandle new_dim = GetUnknownOutputDim(node, port_index, d); in OutputAsUnion()
|