Home
last modified time | relevance | path

Searched refs:remote_addr (Results 1 - 25 of 53) sorted by relevance

123

/third_party/nghttp2/src/
H A Dshrpx_quic_connection_handler.cc62 const Address &remote_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()
201 send_connection_close(faddr, hd.version, hd.dcid, hd.scid, remote_addr, in handle_packet()
210 vc.scidlen, remote_addr, local_addr, datalen * 3); in handle_packet()
230 hd.dcid, &remote_addr.su.sa, remote_addr 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.h57 int handle_packet(const UpstreamAddr *faddr, const Address &remote_addr,
84 int handle_packet(const UpstreamAddr *faddr, const Address &remote_addr,
94 const Address &remote_addr, const Address &local_addr,
104 const Address &remote_addr,
107 size_t dcidlen, const Address &remote_addr,
116 const Address &remote_addr,
120 handle_new_connection(const UpstreamAddr *faddr, const Address &remote_addr,
H A Dshrpx_quic_listener.cc115 Address remote_addr; in on_read() local
116 remote_addr.su = su; in on_read()
117 remote_addr.len = msg.msg_namelen; in on_read()
119 quic_conn_handler->handle_packet(faddr_, remote_addr, local_addr, pi, in on_read()
H A Dshrpx_http3_upstream.h90 int init(const UpstreamAddr *faddr, const Address &remote_addr,
95 int on_read(const UpstreamAddr *faddr, const Address &remote_addr,
150 const ngtcp2_addr &remote_addr,
158 int send_new_token(const ngtcp2_addr *remote_addr);
182 Address remote_addr; member
H A Dshrpx_worker.h266 QUICPacket(size_t upstream_addr_index, const Address &remote_addr, in QUICPacket()
270 remote_addr{remote_addr},
274 QUICPacket() : upstream_addr_index{}, remote_addr{}, local_addr{}, pi{} {} in QUICPacket()
276 Address remote_addr; member
H A Dh2load_quic.cc326 const sockaddr *remote_addr, socklen_t remote_addrlen) { in quic_init()
436 const_cast<sockaddr *>(remote_addr), in quic_init()
801 void Client::on_send_blocked(const ngtcp2_addr &remote_addr, in on_send_blocked() argument
811 memcpy(&p.remote_addr.su, remote_addr.addr, remote_addr.addrlen); in on_send_blocked()
813 p.remote_addr.len = remote_addr.addrlen; in on_send_blocked()
828 rv = write_udp(&p.remote_addr.su.sa, p.remote_addr in send_blocked_packet()
325 quic_init(const sockaddr *local_addr, socklen_t local_addrlen, const sockaddr *remote_addr, socklen_t remote_addrlen) quic_init() argument
[all...]
H A Dshrpx_connection_handler.cc1021 const UpstreamAddr *faddr, const Address &remote_addr, in forward_quic_packet()
1034 wev.quic_pkt = std::make_unique<QUICPacket>(faddr->index, remote_addr, in forward_quic_packet()
1105 QUICLingeringWorkerProcess *quic_lwp, const Address &remote_addr, in forward_quic_packet_to_lingering_worker_process()
1111 assert(remote_addr.len > 0); in forward_quic_packet_to_lingering_worker_process()
1117 *p++ = static_cast<uint8_t>(remote_addr.len - 1); in forward_quic_packet_to_lingering_worker_process()
1118 p = std::copy_n(reinterpret_cast<const uint8_t *>(&remote_addr.su), in forward_quic_packet_to_lingering_worker_process()
1119 remote_addr.len, p); in forward_quic_packet_to_lingering_worker_process()
1221 pkt->remote_addr.len = remote_addrlen; in quic_ipc_read()
1222 memcpy(&pkt->remote_addr.su, p, remote_addrlen); in quic_ipc_read()
1280 quic_conn_handler->handle_packet(faddr, pkt->remote_addr, pk 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_http3_upstream.cc523 int Http3Upstream::send_new_token(const ngtcp2_addr *remote_addr) { in send_new_token() argument
532 if (generate_token(token.data(), tokenlen, remote_addr->addr, in send_new_token()
533 remote_addr->addrlen, qkm.secret.data(), in send_new_token()
568 int Http3Upstream::init(const UpstreamAddr *faddr, const Address &remote_addr, in init() argument
736 const_cast<sockaddr *>(&remote_addr.su.sa), in init()
737 static_cast<socklen_t>(remote_addr.len), in init()
754 if (generate_quic_hashed_connection_id(hashed_scid_, remote_addr, local_addr, in init()
1784 const Address &remote_addr, in on_read()
1795 const_cast<sockaddr *>(&remote_addr.su.sa), in on_read()
1796 static_cast<socklen_t>(remote_addr in on_read()
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 Dh2load.h354 Address remote_addr; member
478 const sockaddr *remote_addr, socklen_t remote_addrlen);
484 void on_send_blocked(const ngtcp2_addr &remote_addr, const uint8_t *data,
/third_party/libcoap/src/
H A Dcoap_tcp.c48 coap_address_t *remote_addr) {
151 if (getpeername(sock->fd, &remote_addr->addr.sa, &remote_addr->size) == COAP_SOCKET_ERROR) {
167 coap_address_t *remote_addr) {
195 if (getpeername(sock->fd, &remote_addr->addr.sa, &remote_addr->size) == COAP_SOCKET_ERROR) {
302 coap_address_t *remote_addr) {
313 new_client->fd = accept(server->fd, &remote_addr->addr.sa,
314 &remote_addr->size);
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
H A Dcoap_io_lwip.c381 coap_address_t *remote_addr) { in coap_socket_connect_udp()
388 (void)remote_addr; in coap_socket_connect_udp()
440 coap_address_t *remote_addr) { in coap_socket_connect_tcp1()
446 (void)remote_addr; in coap_socket_connect_tcp1()
453 coap_address_t *remote_addr) { in coap_socket_connect_tcp2()
456 (void)remote_addr; in coap_socket_connect_tcp2()
474 coap_address_t *remote_addr) { in coap_socket_accept_tcp()
478 (void)remote_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.c112 coap_address_t *remote_addr) { in coap_socket_connect_udp()
132 uip_ipaddr_copy(&remote_addr->addr, &server->addr); in coap_socket_connect_udp()
133 remote_addr->port = sock->udp_conn->rport; 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
H A Dcoap_tinydtls.c296 coap_address_t remote_addr; in dtls_send_to_peer() local
299 get_session_addr(dtls_session, &remote_addr); in dtls_send_to_peer()
300 coap_session = coap_session_get_by_peer(coap_context, &remote_addr, dtls_session->ifindex); in dtls_send_to_peer()
316 coap_address_t remote_addr; in dtls_application_data() local
319 get_session_addr(dtls_session, &remote_addr); in dtls_application_data()
320 coap_session = coap_session_get_by_peer(coap_context, &remote_addr, dtls_session->ifindex); in dtls_application_data()
381 coap_address_t remote_addr; in get_psk_info() local
394 get_session_addr(dtls_session, &remote_addr); in get_psk_info()
395 coap_session = coap_session_get_by_peer(coap_context, &remote_addr, dtls_session->ifindex); in get_psk_info()
588 coap_address_t remote_addr; in verify_ecdsa_key() local
[all...]
/third_party/libcoap/include/coap3/
H A Dcoap_tcp_internal.h43 * @param remote_addr Filled in after connection initiation with
53 coap_address_t *remote_addr);
62 * @param remote_addr Filled in with the final remote address
68 coap_address_t *remote_addr);
95 * @param remote_addr Filled in with the remote address
102 coap_address_t *remote_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,
87 void* lwiperf_start_tcp_client(const ip_addr_t* remote_addr, u16_t remote_port,
90 void* lwiperf_start_tcp_client_default(const ip_addr_t* remote_addr,
/third_party/curl/lib/vquic/
H A Dvquic.c343 struct sockaddr_storage remote_addr[MMSG_NUM]; in recvmmsg_packets() local
360 mmsg[i].msg_hdr.msg_name = &remote_addr[i]; in recvmmsg_packets()
361 mmsg[i].msg_hdr.msg_namelen = sizeof(remote_addr[i]); in recvmmsg_packets()
418 struct sockaddr_storage remote_addr; in recvmsg_packets() local
433 msg.msg_name = &remote_addr; in recvmsg_packets()
434 msg.msg_namelen = sizeof(remote_addr); in recvmsg_packets()
483 struct sockaddr_storage remote_addr; in recvfrom_packets() local
484 socklen_t remote_addrlen = sizeof(remote_addr); in recvfrom_packets()
493 (struct sockaddr *)&remote_addr, in recvfrom_packets()
521 result = recv_cb(buf, (size_t)nread, &remote_addr, remote_addrle in recvfrom_packets()
[all...]
/third_party/lwip/src/apps/lwiperf/
H A Dlwiperf.c129 ip_addr_t remote_addr; member
393 ip_addr_t remote_addr; in lwiperf_tx_start_impl() local
426 ip_addr_copy(remote_addr, *remote_ip); in lwiperf_tx_start_impl()
428 err = tcp_connect(newpcb, &remote_addr, remote_port, lwiperf_tcp_client_connected); in lwiperf_tx_start_impl()
605 if (!ip_addr_cmp(&newpcb->remote_ip, &s->remote_addr)) { in lwiperf_tcp_accept()
744 void* lwiperf_start_tcp_client_default(const ip_addr_t* remote_addr, in lwiperf_start_tcp_client_default() argument
747 return lwiperf_start_tcp_client(remote_addr, LWIPERF_TCP_PORT_DEFAULT, LWIPERF_CLIENT, in lwiperf_start_tcp_client_default()
758 void* lwiperf_start_tcp_client(const ip_addr_t* remote_addr, u16_t remote_port, in lwiperf_start_tcp_client() argument
788 ret = lwiperf_tx_start_impl(remote_addr, remote_port, &settings, report_fn, report_arg, NULL, &state); in lwiperf_start_tcp_client()
803 server->remote_addr in lwiperf_start_tcp_client()
[all...]
/third_party/curl/lib/
H A Dtftp.c135 struct Curl_sockaddr_storage remote_addr; member
531 &data->conn->remote_addr->sa_addr, in tftp_send_first()
532 data->conn->remote_addr->addrlen); in tftp_send_first()
616 (struct sockaddr *)&state->remote_addr, in tftp_rx()
641 (struct sockaddr *)&state->remote_addr, in tftp_rx()
667 (struct sockaddr *)&state->remote_addr, in tftp_rx()
681 (struct sockaddr *)&state->remote_addr, in tftp_rx()
741 (struct sockaddr *)&state->remote_addr, in tftp_tx()
785 (struct sockaddr *)&state->remote_addr, in tftp_tx()
811 (struct sockaddr *)&state->remote_addr, in tftp_tx()
[all...]
/third_party/ltp/testcases/kernel/syscalls/bind/
H A Dbind05.c122 struct sockaddr_storage listen_addr, remote_addr; in test_bind() local
151 (struct sockaddr *)&remote_addr, &remote_len); in test_bind()
160 (struct sockaddr *)&remote_addr, remote_len); in test_bind()
H A Dbind04.c108 struct sockaddr_storage listen_addr, remote_addr; in test_bind() local
138 sock = SAFE_ACCEPT(listen_sock, (struct sockaddr *)&remote_addr, in test_bind()
/third_party/node/deps/ngtcp2/ngtcp2/lib/
H A Dngtcp2_path.c51 const ngtcp2_sockaddr *remote_addr, in ngtcp2_path_storage_init()
59 ngtcp2_addr_copy_byte(&ps->path.remote, remote_addr, remote_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/node/deps/ngtcp2/ngtcp2/crypto/includes/ngtcp2/
H A Dngtcp2_crypto.h648 * encrypt the token. |version| is QUIC version. |remote_addr| of
659 const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen,
669 * packet that contains this token. |remote_addr| of length
683 const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen,
696 * encrypt the token. |remote_addr| of length |remote_addrlen| is an
705 const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen,
714 * generate keys to decrypt the token. |remote_addr| of length
722 size_t secretlen, const ngtcp2_sockaddr *remote_addr,
/third_party/lwip/src/apps/http/
H A Dhttp_client.c136 ip_addr_t remote_addr; member
422 if (&req->remote_addr != ipaddr) { in httpc_get_internal_addr()
424 req->remote_addr = *ipaddr; in httpc_get_internal_addr()
427 err = altcp_connect(req->pcb, &req->remote_addr, req->remote_port, httpc_tcp_connected); in httpc_get_internal_addr()
472 err = dns_gethostbyname(server_name, &req->remote_addr, httpc_dns_found, req); in httpc_get_internal_dns()
474 err = ipaddr_aton(server_name, &req->remote_addr) ? ERR_OK : ERR_ARG; in httpc_get_internal_dns()
479 err = httpc_get_internal_addr(req, &req->remote_addr); in httpc_get_internal_dns()
/third_party/node/deps/ngtcp2/ngtcp2/crypto/
H A Dshared.c898 const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen, in ngtcp2_crypto_generate_retry_token()
947 aadlen = crypto_generate_retry_token_aad(aad, version, remote_addr, in ngtcp2_crypto_generate_retry_token()
976 const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen, in ngtcp2_crypto_verify_retry_token()
1019 aadlen = crypto_generate_retry_token_aad(aad, version, remote_addr, in ngtcp2_crypto_verify_retry_token()
1081 const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen, in ngtcp2_crypto_generate_regular_token()
1125 aadlen = crypto_generate_regular_token_aad(aad, remote_addr); in ngtcp2_crypto_generate_regular_token()
1152 const ngtcp2_sockaddr *remote_addr, in ngtcp2_crypto_verify_regular_token()
1195 aadlen = crypto_generate_regular_token_aad(aad, remote_addr); in ngtcp2_crypto_verify_regular_token()
896 ngtcp2_crypto_generate_retry_token( uint8_t *token, const uint8_t *secret, size_t secretlen, uint32_t version, const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen, const ngtcp2_cid *retry_scid, const ngtcp2_cid *odcid, ngtcp2_tstamp ts) ngtcp2_crypto_generate_retry_token() argument
973 ngtcp2_crypto_verify_retry_token( ngtcp2_cid *odcid, const uint8_t *token, size_t tokenlen, const uint8_t *secret, size_t secretlen, uint32_t version, const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen, const ngtcp2_cid *dcid, ngtcp2_duration timeout, ngtcp2_tstamp ts) ngtcp2_crypto_verify_retry_token() argument
1079 ngtcp2_crypto_generate_regular_token( uint8_t *token, const uint8_t *secret, size_t secretlen, const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen, ngtcp2_tstamp ts) ngtcp2_crypto_generate_regular_token() argument
1150 ngtcp2_crypto_verify_regular_token(const uint8_t *token, size_t tokenlen, const uint8_t *secret, size_t secretlen, const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen, ngtcp2_duration timeout, ngtcp2_tstamp ts) ngtcp2_crypto_verify_regular_token() argument
/third_party/python/Lib/asyncio/
H A Dbase_events.py1277 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):
1323 (local_addr, remote_addr)), )
1327 for idx, addr in ((0, local_addr), (1, remote_addr)):
1348 (remote_addr and addr_pair[1] is None))]
1371 if remote_addr
[all...]

Completed in 29 milliseconds

123