Home
last modified time | relevance | path

Searched refs:local_addr (Results 1 – 25 of 55) sorted by relevance

123

/third_party/rust/crates/rustix/tests/net/
Dconnect_bind_send.rs17 let local_addr = rustix::net::getsockname(&listener)?; in net_v4_connect_any() localVariable
19 rustix::net::connect_any(&sender, &local_addr).expect("connect"); in net_v4_connect_any()
52 let local_addr = rustix::net::getsockname(&listener)?; in net_v6_connect_any() localVariable
58 rustix::net::connect_any(&sender, &local_addr).expect("connect"); in net_v6_connect_any()
88 let local_addr = rustix::net::getsockname(&listener)?; in net_v4_connect() localVariable
89 let local_addr = match local_addr { in net_v4_connect() localVariable
94 rustix::net::connect(&sender, &local_addr).expect("connect"); in net_v4_connect()
127 let local_addr = rustix::net::getsockname(&listener)?; in net_v6_connect() localVariable
128 let local_addr = match local_addr { in net_v6_connect() localVariable
137 rustix::net::connect(&sender, &local_addr).expect("connect"); in net_v6_connect()
[all …]
/third_party/nghttp2/src/
Dshrpx_quic_connection_handler.cc63 const Address &local_addr, in handle_packet() argument
75 vc.scidlen, remote_addr, local_addr); in handle_packet()
99 cw->handle_packet(faddr, remote_addr, local_addr, pi, data, datalen); in handle_packet()
105 if (generate_quic_hashed_connection_id(dcid_key, remote_addr, local_addr, in handle_packet()
116 cw->handle_packet(faddr, remote_addr, local_addr, pi, data, datalen); in handle_packet()
149 quic_lwp, remote_addr, local_addr, pi, data, datalen) == 0) { in handle_packet()
202 local_addr, NGTCP2_CONNECTION_REFUSED, in handle_packet()
210 vc.scidlen, remote_addr, local_addr, datalen * 3); in handle_packet()
240 remote_addr, local_addr, NGTCP2_INVALID_TOKEN, in handle_packet()
272 vc.scidlen, remote_addr, local_addr, datalen * 3); in handle_packet()
[all …]
Dshrpx_quic_connection_handler.h58 const Address &local_addr, const ngtcp2_pkt_info &pi,
85 const Address &local_addr, const ngtcp2_pkt_info &pi,
94 const Address &remote_addr, const Address &local_addr,
105 const Address &local_addr);
108 const Address &local_addr);
117 const Address &local_addr, uint64_t error_code,
121 const Address &local_addr, const ngtcp2_pkt_hd &hd,
Dshrpx_quic_listener.cc77 Address local_addr{}; in on_read() local
78 if (util::msghdr_get_local_addr(local_addr, &msg, su.storage.ss_family) != in on_read()
85 util::set_port(local_addr, faddr_->port); in on_read()
105 << util::to_numeric_addr(&local_addr) << " remote=" in on_read()
119 quic_conn_handler->handle_packet(faddr_, remote_addr, local_addr, pi, in on_read()
Dshrpx_worker.h267 const Address &local_addr, const ngtcp2_pkt_info &pi, in QUICPacket()
271 local_addr{local_addr},
274 QUICPacket() : upstream_addr_index{}, remote_addr{}, local_addr{}, pi{} {} in QUICPacket()
277 Address local_addr; member
393 const UpstreamAddr *find_quic_upstream_addr(const Address &local_addr);
Dshrpx_http3_upstream.h91 const Address &local_addr, const ngtcp2_pkt_hd &initial_hd,
96 const Address &local_addr, const ngtcp2_pkt_info &pi,
151 const ngtcp2_addr &local_addr, const ngtcp2_pkt_info &pi,
181 Address local_addr; member
Dshrpx_connection_handler.cc1022 const Address &local_addr, const ngtcp2_pkt_info &pi, in forward_quic_packet() argument
1035 local_addr, pi, data, datalen); in forward_quic_packet()
1106 const Address &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *data, in forward_quic_packet_to_lingering_worker_process() argument
1112 assert(local_addr.len > 0); in forward_quic_packet_to_lingering_worker_process()
1120 *p++ = static_cast<uint8_t>(local_addr.len - 1); in forward_quic_packet_to_lingering_worker_process()
1121 p = std::copy_n(reinterpret_cast<const uint8_t *>(&local_addr.su), in forward_quic_packet_to_lingering_worker_process()
1122 local_addr.len, p); in forward_quic_packet_to_lingering_worker_process()
1241 pkt->local_addr.len = local_addrlen; in quic_ipc_read()
1242 memcpy(&pkt->local_addr.su, p, local_addrlen); in quic_ipc_read()
1270 auto faddr = single_worker_->find_quic_upstream_addr(pkt->local_addr); in quic_ipc_read()
[all …]
Dshrpx_http3_upstream.cc569 const Address &local_addr, in init() argument
732 const_cast<sockaddr *>(&local_addr.su.sa), in init()
733 static_cast<socklen_t>(local_addr.len), in init()
754 if (generate_quic_hashed_connection_id(hashed_scid_, remote_addr, local_addr, in init()
1785 const Address &local_addr, const ngtcp2_pkt_info &pi, in on_read() argument
1791 const_cast<sockaddr *>(&local_addr.su.sa), in on_read()
1792 static_cast<socklen_t>(local_addr.len), in on_read()
1829 remote_addr, local_addr, datalen * 3); in on_read()
1885 const ngtcp2_addr &local_addr, in on_send_blocked() argument
1896 memcpy(&p.local_addr.su, local_addr.addr, local_addr.addrlen); in on_send_blocked()
[all …]
Dshrpx_worker.cc546 faddr = find_quic_upstream_addr(wev.quic_pkt->local_addr); in process_events()
562 faddr, wev.quic_pkt->remote_addr, wev.quic_pkt->local_addr, in process_events()
1082 const UpstreamAddr *Worker::find_quic_upstream_addr(const Address &local_addr) { in find_quic_upstream_addr() argument
1085 auto rv = getnameinfo(&local_addr.su.sa, local_addr.len, host.data(), in find_quic_upstream_addr()
1095 switch (local_addr.su.sa.sa_family) { in find_quic_upstream_addr()
1097 port = htons(local_addr.su.in.sin_port); in find_quic_upstream_addr()
1101 port = htons(local_addr.su.in6.sin6_port); in find_quic_upstream_addr()
1120 if (faddr.port != port || faddr.family != local_addr.su.sa.sa_family) { in find_quic_upstream_addr()
Dshrpx_quic.cc260 const Address &local_addr, in generate_quic_hashed_connection_id() argument
270 !EVP_DigestUpdate(ctx, &local_addr.su.sa, local_addr.len) || in generate_quic_hashed_connection_id()
Dshrpx_connection_handler.h199 const Address &local_addr, const ngtcp2_pkt_info &pi,
222 const Address &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *data,
/third_party/libcoap/src/
Dcoap_tcp.c47 coap_address_t *local_addr, argument
109 coap_address_copy(local_addr, local_if);
124 local_addr->addr.sa.sa_family = server->addr.sa.sa_family;
146 if (getsockname(sock->fd, &local_addr->addr.sa, &local_addr->size) == COAP_SOCKET_ERROR) {
166 coap_address_t *local_addr, argument
190 if (getsockname(sock->fd, &local_addr->addr.sa, &local_addr->size) == COAP_SOCKET_ERROR) {
301 coap_address_t *local_addr, argument
321 if (getsockname(new_client->fd, &local_addr->addr.sa, &local_addr->size) < 0)
Dcoap_io_lwip.c380 coap_address_t *local_addr, in coap_socket_connect_udp() argument
387 (void)local_addr; in coap_socket_connect_udp()
439 coap_address_t *local_addr, in coap_socket_connect_tcp1() argument
445 (void)local_addr; in coap_socket_connect_tcp1()
452 coap_address_t *local_addr, in coap_socket_connect_tcp2() argument
455 (void)local_addr; in coap_socket_connect_tcp2()
473 coap_address_t *local_addr, in coap_socket_accept_tcp() argument
477 (void)local_addr; in coap_socket_accept_tcp()
Dcoap_io_contiki.c111 coap_address_t *local_addr, in coap_socket_connect_udp() argument
130 uip_ipaddr_copy(&local_addr->addr, &addr->ipaddr); in coap_socket_connect_udp()
131 local_addr->port = sock->udp_conn->lport; in coap_socket_connect_udp()
/third_party/libcoap/include/coap3/
Dcoap_tcp_internal.h52 coap_address_t *local_addr,
67 coap_address_t *local_addr,
101 coap_address_t *local_addr,
/third_party/python/Lib/asyncio/
Dbase_events.py970 local_addr=None, server_hostname=None, argument
1022 if local_addr is not None:
1024 local_addr, family=family,
1240 local_addr=None, remote_addr=None, *, argument
1249 if (local_addr or remote_addr or
1253 opts = dict(local_addr=local_addr, remote_addr=remote_addr,
1264 if not (local_addr or remote_addr):
1269 for addr in (local_addr, remote_addr):
1273 if local_addr and local_addr[0] not in (0, '\x00'):
1275 if stat.S_ISSOCK(os.stat(local_addr).st_mode):
[all …]
/third_party/lwip/src/netif/
Dlowpan6_ble.c176 rfc7668_set_local_addr_eui64(struct netif *netif, const u8_t *local_addr, size_t local_addr_len) in rfc7668_set_local_addr_eui64() argument
180 return rfc7668_set_addr(&rfc7668_local_addr, local_addr, local_addr_len, 0, 0); in rfc7668_set_local_addr_eui64()
187 rfc7668_set_local_addr_mac48(struct netif *netif, const u8_t *local_addr, size_t local_addr_len, in… in rfc7668_set_local_addr_mac48() argument
191 return rfc7668_set_addr(&rfc7668_local_addr, local_addr, local_addr_len, 1, is_public_addr); in rfc7668_set_local_addr_mac48()
/third_party/lwip/src/include/lwip/apps/
Dlwiperf.h81 const ip_addr_t* local_addr, u16_t local_port, const ip_addr_t* remote_addr, u16_t remote_port,
84 void* lwiperf_start_tcp_server(const ip_addr_t* local_addr, u16_t local_port,
/third_party/lwip/src/include/netif/
Dlowpan6_ble.h58 err_t rfc7668_set_local_addr_eui64(struct netif *netif, const u8_t *local_addr, size_t local_addr_l…
59 err_t rfc7668_set_local_addr_mac48(struct netif *netif, const u8_t *local_addr, size_t local_addr_l…
/third_party/node/deps/ngtcp2/ngtcp2/lib/
Dngtcp2_path.c49 const ngtcp2_sockaddr *local_addr, in ngtcp2_path_storage_init() argument
58 ngtcp2_addr_copy_byte(&ps->path.local, local_addr, local_addrlen); in ngtcp2_path_storage_init()
/third_party/lwip/src/apps/lwiperf/
Dlwiperf.c180 static err_t lwiperf_start_tcp_server_impl(const ip_addr_t *local_addr, u16_t local_port,
670 lwiperf_start_tcp_server(const ip_addr_t *local_addr, u16_t local_port, in lwiperf_start_tcp_server() argument
676 err = lwiperf_start_tcp_server_impl(local_addr, local_port, report_fn, report_arg, in lwiperf_start_tcp_server()
684 static err_t lwiperf_start_tcp_server_impl(const ip_addr_t *local_addr, u16_t local_port, in lwiperf_start_tcp_server_impl() argument
696 if (local_addr == NULL) { in lwiperf_start_tcp_server_impl()
715 err = tcp_bind(pcb, local_addr, local_port); in lwiperf_start_tcp_server_impl()
/third_party/ffmpeg/libavformat/
Dudp.c203 struct sockaddr *local_addr, void *logctx) in udp_join_multicast_group() argument
210 if (local_addr) in udp_join_multicast_group()
211 mreq.imr_interface= ((struct sockaddr_in *)local_addr)->sin_addr; in udp_join_multicast_group()
237 struct sockaddr *local_addr, void *logctx) in udp_leave_multicast_group() argument
244 if (local_addr) in udp_leave_multicast_group()
245 mreq.imr_interface = ((struct sockaddr_in *)local_addr)->sin_addr; in udp_leave_multicast_group()
272 int addr_len, struct sockaddr_storage *local_addr, in udp_set_multicast_sources() argument
318 if (local_addr) in udp_set_multicast_sources()
319 mreqs.imr_interface = ((struct sockaddr_in *)local_addr)->sin_addr; in udp_set_multicast_sources()
/third_party/mbedtls/library/
Dnet_sockets.c423 struct sockaddr_storage local_addr; local
435 (struct sockaddr *) &local_addr, &n) != 0 ||
436 (bind_ctx->fd = (int) socket(local_addr.ss_family,
443 if (bind(bind_ctx->fd, (struct sockaddr *) &local_addr, n) != 0) {
/third_party/libcoap/examples/
Dcoap-client.c1494 const char *local_addr, in get_session() argument
1506 if (local_addr || coap_is_af_unix(dst)) { in get_session()
1510 if (local_addr) { in get_session()
1512 (const uint8_t *)local_addr, in get_session()
1513 strlen(local_addr))) { in get_session()
1515 local_addr); in get_session()
1541 local.s = (const uint8_t *)local_addr; in get_session()
1542 local.length = strlen(local_addr); in get_session()
1549 fprintf(stderr, "coap_resolve_address_info: %s: failed\n", local_addr); in get_session()
/third_party/python/Lib/test/test_asyncio/
Dtest_base_events.py1267 local_addr=(None, 8080))
1395 local_addr=(None, 8080))
1594 MyDatagramProto, local_addr=('localhost', 0))
1600 MyDatagramProto, local_addr='localhost')
1604 MyDatagramProto, local_addr=('localhost', 1, 2, 3))
1645 asyncio.DatagramProtocol, local_addr=('127.0.0.1', 0))
1653 remote_addr=('127.0.0.1', 0), local_addr=('::1', 0))
1684 local_addr=('127.0.0.1', 0), family=socket.AF_INET)
1729 MyDatagramProto, local_addr=('127.0.0.1', 0), sock=FakeSock())
1764 local_addr=('127.0.0.1', 0))
[all …]

123