Home
last modified time | relevance | path

Searched refs:local_addr (Results 1 - 25 of 51) sorted by relevance

123

/third_party/rust/crates/rustix/tests/net/
H A Dconnect_bind_send.rs17 let local_addr = rustix::net::getsockname(&listener)?; in net_v4_connect_any()
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()
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()
89 let local_addr = match local_addr { in net_v4_connect()
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()
128 let local_addr in net_v6_connect()
[all...]
/third_party/nghttp2/src/
H A Dshrpx_quic_connection_handler.cc63 const Address &local_addr, in handle_packet()
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, datale in handle_packet()
61 handle_packet(const UpstreamAddr *faddr, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *data, size_t datalen) handle_packet() argument
367 handle_new_connection( const UpstreamAddr *faddr, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_hd &hd, const ngtcp2_cid *odcid, const uint8_t *token, size_t tokenlen, ngtcp2_token_type token_type) handle_new_connection() argument
458 send_retry( const UpstreamAddr *faddr, uint32_t version, const uint8_t *ini_dcid, size_t ini_dcidlen, const uint8_t *ini_scid, size_t ini_scidlen, const Address &remote_addr, const Address &local_addr, size_t max_pktlen) send_retry() argument
537 send_version_negotiation( const UpstreamAddr *faddr, uint32_t version, const uint8_t *ini_dcid, size_t ini_dcidlen, const uint8_t *ini_scid, size_t ini_scidlen, const Address &remote_addr, const Address &local_addr) send_version_negotiation() argument
565 send_stateless_reset(const UpstreamAddr *faddr, const uint8_t *dcid, size_t dcidlen, const Address &remote_addr, const Address &local_addr) send_stateless_reset() argument
628 send_connection_close( const UpstreamAddr *faddr, uint32_t version, const ngtcp2_cid &ini_dcid, const ngtcp2_cid &ini_scid, const Address &remote_addr, const Address &local_addr, uint64_t error_code, size_t max_pktlen) send_connection_close() argument
731 handle_packet(const UpstreamAddr *faddr, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *data, size_t datalen) handle_packet() argument
[all...]
H A 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,
H A Dshrpx_quic_listener.cc77 Address local_addr{}; in on_read()
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()
H A 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
392 // Returns a pointer to UpstreamAddr which matches |local_addr|.
393 const UpstreamAddr *find_quic_upstream_addr(const Address &local_addr);
H A 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
H A Dshrpx_connection_handler.cc1022 const Address &local_addr, const ngtcp2_pkt_info &pi, in forward_quic_packet()
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()
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()
1020 forward_quic_packet( const UpstreamAddr *faddr, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *cid_prefix, const uint8_t *data, size_t datalen) forward_quic_packet() argument
1104 forward_quic_packet_to_lingering_worker_process( QUICLingeringWorkerProcess *quic_lwp, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *data, size_t datalen) forward_quic_packet_to_lingering_worker_process() argument
[all...]
H A 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()
H A Dshrpx_http3_upstream.cc569 const Address &local_addr, in init()
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()
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()
1896 memcpy(&p.local_addr in on_send_blocked()
568 init(const UpstreamAddr *faddr, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_hd &initial_hd, const ngtcp2_cid *odcid, const uint8_t *token, size_t tokenlen, ngtcp2_token_type token_type) init() argument
1783 on_read(const UpstreamAddr *faddr, const Address &remote_addr, const Address &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *data, size_t datalen) on_read() argument
1883 on_send_blocked(const UpstreamAddr *faddr, const ngtcp2_addr &remote_addr, const ngtcp2_addr &local_addr, const ngtcp2_pkt_info &pi, const uint8_t *data, size_t datalen, size_t gso_size) on_send_blocked() argument
[all...]
H A 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,
H A Dshrpx_quic.cc260 const Address &local_addr, in generate_quic_hashed_connection_id()
270 !EVP_DigestUpdate(ctx, &local_addr.su.sa, local_addr.len) || in generate_quic_hashed_connection_id()
258 generate_quic_hashed_connection_id(ngtcp2_cid &dest, const Address &remote_addr, const Address &local_addr, const ngtcp2_cid &cid) generate_quic_hashed_connection_id() argument
/third_party/libcoap/src/
H A Dcoap_tcp.c47 coap_address_t *local_addr,
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,
190 if (getsockname(sock->fd, &local_addr->addr.sa, &local_addr->size) == COAP_SOCKET_ERROR) {
301 coap_address_t *local_addr,
321 if (getsockname(new_client->fd, &local_addr
43 coap_socket_connect_tcp1(coap_socket_t *sock, const coap_address_t *local_if, const coap_address_t *server, int default_port, coap_address_t *local_addr, coap_address_t *remote_addr) global() argument
165 coap_socket_connect_tcp2(coap_socket_t *sock, coap_address_t *local_addr, coap_address_t *remote_addr) global() argument
299 coap_socket_accept_tcp(coap_socket_t *server, coap_socket_t *new_client, coap_address_t *local_addr, coap_address_t *remote_addr) global() argument
[all...]
H A Dcoap_io_lwip.c380 coap_address_t *local_addr, in coap_socket_connect_udp()
387 (void)local_addr; in coap_socket_connect_udp()
439 coap_address_t *local_addr, in coap_socket_connect_tcp1()
445 (void)local_addr; in coap_socket_connect_tcp1()
452 coap_address_t *local_addr, in coap_socket_connect_tcp2()
455 (void)local_addr; in coap_socket_connect_tcp2()
473 coap_address_t *local_addr, in coap_socket_accept_tcp()
477 (void)local_addr; in coap_socket_accept_tcp()
376 coap_socket_connect_udp(coap_socket_t *sock, const coap_address_t *local_if, const coap_address_t *server, int default_port, coap_address_t *local_addr, coap_address_t *remote_addr) coap_socket_connect_udp() argument
435 coap_socket_connect_tcp1(coap_socket_t *sock, const coap_address_t *local_if, const coap_address_t *server, int default_port, coap_address_t *local_addr, coap_address_t *remote_addr) coap_socket_connect_tcp1() argument
451 coap_socket_connect_tcp2(coap_socket_t *sock, coap_address_t *local_addr, coap_address_t *remote_addr) coap_socket_connect_tcp2() argument
471 coap_socket_accept_tcp(coap_socket_t *server, coap_socket_t *new_client, coap_address_t *local_addr, coap_address_t *remote_addr) coap_socket_accept_tcp() argument
H A Dcoap_io_contiki.c111 coap_address_t *local_addr, in coap_socket_connect_udp()
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()
107 coap_socket_connect_udp(coap_socket_t *sock, const coap_address_t *local_if, const coap_address_t *server, int default_port, coap_address_t *local_addr, coap_address_t *remote_addr) coap_socket_connect_udp() argument
/third_party/libcoap/include/coap3/
H A Dcoap_tcp_internal.h41 * @param local_addr Filled in after connection initiation with
52 coap_address_t *local_addr,
61 * @param local_addr Filled in with the final local address
67 coap_address_t *local_addr,
94 * @param local_addr Filled in with the local address
101 coap_address_t *local_addr,
/third_party/lwip/src/include/lwip/apps/
H A 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/netif/
H A 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, int is_public_addr) 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/netif/
H A Dlowpan6_ble.h58 err_t rfc7668_set_local_addr_eui64(struct netif *netif, const u8_t *local_addr, size_t local_addr_len);
59 err_t rfc7668_set_local_addr_mac48(struct netif *netif, const u8_t *local_addr, size_t local_addr_len, int is_public_addr);
/third_party/python/Lib/asyncio/
H A Dbase_events.py991 local_addr=None, server_hostname=None,
1051 if local_addr is not None:
1053 local_addr, family=family,
1277 local_addr=None, remote_addr=None, *,
1286 if (local_addr or remote_addr or
1290 opts = dict(local_addr=local_addr, remote_addr=remote_addr,
1301 if not (local_addr or remote_addr):
1306 for addr in (local_addr, remote_addr):
1310 if local_addr an
[all...]
/third_party/node/deps/ngtcp2/ngtcp2/lib/
H A Dngtcp2_path.c49 const ngtcp2_sockaddr *local_addr, in ngtcp2_path_storage_init()
58 ngtcp2_addr_copy_byte(&ps->path.local, local_addr, local_addrlen); in ngtcp2_path_storage_init()
48 ngtcp2_path_storage_init(ngtcp2_path_storage *ps, const ngtcp2_sockaddr *local_addr, ngtcp2_socklen local_addrlen, const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen, void *user_data) ngtcp2_path_storage_init() argument
/third_party/lwip/src/apps/lwiperf/
H A 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/
H A Dudp.c203 struct sockaddr *local_addr, void *logctx) in udp_join_multicast_group()
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()
225 //TODO: Interface index should be looked up from local_addr in udp_join_multicast_group()
237 struct sockaddr *local_addr, void *logctx) in udp_leave_multicast_group()
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()
259 //TODO: Interface index should be looked up from local_addr in udp_leave_multicast_group()
272 int addr_len, struct sockaddr_storage *local_addr, in udp_set_multicast_sources()
287 //TODO: Interface index should be looked up from local_addr in udp_set_multicast_sources()
202 udp_join_multicast_group(int sockfd, struct sockaddr *addr, struct sockaddr *local_addr, void *logctx) udp_join_multicast_group() argument
236 udp_leave_multicast_group(int sockfd, struct sockaddr *addr, struct sockaddr *local_addr, void *logctx) udp_leave_multicast_group() argument
270 udp_set_multicast_sources(URLContext *h, int sockfd, struct sockaddr *addr, int addr_len, struct sockaddr_storage *local_addr, struct sockaddr_storage *sources, int nb_sources, int include) udp_set_multicast_sources() argument
[all...]
/third_party/mbedtls/library/
H A Dnet_sockets.c407 struct sockaddr_storage local_addr; local
419 (struct sockaddr *) &local_addr, &n) != 0 ||
420 (bind_ctx->fd = (int) socket(local_addr.ss_family,
427 if (bind(bind_ctx->fd, (struct sockaddr *) &local_addr, n) != 0) {
/third_party/python/Lib/test/test_asyncio/
H A Dtest_base_events.py1272 local_addr=(None, 8080))
1394 local_addr=(None, 8080))
1598 MyDatagramProto, local_addr=('localhost', 0))
1604 MyDatagramProto, local_addr='localhost')
1608 MyDatagramProto, local_addr=('localhost', 1, 2, 3))
1649 asyncio.DatagramProtocol, local_addr=('127.0.0.1', 0))
1657 remote_addr=('127.0.0.1', 0), local_addr=('::1', 0))
1688 local_addr=('127.0.0.1', 0), family=socket.AF_INET) variable in BaseEventLoopWithSelectorTests.test_create_datagram_endpoint_cant_bind.Err
1733 MyDatagramProto, local_addr=('127.0.0.1', 0), sock=FakeSock())
1768 local_addr
[all...]
/third_party/curl/lib/vquic/
H A Dvquic_int.h39 struct sockaddr_storage local_addr; /* address socket is bound to */ member

Completed in 21 milliseconds

123