| /third_party/nghttp2/src/ |
| D | shrpx_quic_connection_handler.cc | 62 const Address &remote_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()
200 send_connection_close(faddr, hd.version, hd.dcid, hd.scid, remote_addr, in handle_packet()
209 vc.scidlen, remote_addr, local_addr, datalen * 3); in handle_packet()
229 hd.dcid, &remote_addr.su.sa, remote_addr.len, in handle_packet()
233 << util::to_numeric_addr(&remote_addr); in handle_packet()
[all …]
|
| D | shrpx_quic_connection_handler.h | 57 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 const Address &remote_addr,
|
| D | shrpx_quic_listener.cc | 116 Address remote_addr; in on_read() local
117 remote_addr.su = su; in on_read()
118 remote_addr.len = msg.msg_namelen; in on_read()
120 quic_conn_handler->handle_packet(faddr_, remote_addr, local_addr, pi, in on_read()
|
| D | shrpx_http3_upstream.h | 90 int init(const UpstreamAddr *faddr, const Address &remote_addr,
94 int on_read(const UpstreamAddr *faddr, const Address &remote_addr,
148 const ngtcp2_addr &remote_addr,
156 int send_new_token(const ngtcp2_addr *remote_addr);
180 Address remote_addr; member
|
| D | h2load_quic.cc | 326 const sockaddr *remote_addr, socklen_t remote_addrlen) { in quic_init() argument
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.len, p.data, p.datalen, in send_blocked_packet()
|
| D | shrpx_worker.h | 266 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
|
| D | shrpx_connection_handler.cc | 1021 const UpstreamAddr *faddr, const Address &remote_addr, in forward_quic_packet() argument
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() argument
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, pkt->local_addr, in quic_ipc_read()
|
| D | shrpx_http3_upstream.cc | 505 int Http3Upstream::send_new_token(const ngtcp2_addr *remote_addr) { in send_new_token() argument
514 if (generate_token(token.data(), tokenlen, remote_addr->addr, in send_new_token()
515 remote_addr->addrlen, qkm.secret.data(), in send_new_token()
550 int Http3Upstream::init(const UpstreamAddr *faddr, const Address &remote_addr, in init() argument
717 const_cast<sockaddr *>(&remote_addr.su.sa), in init()
718 static_cast<socklen_t>(remote_addr.len), in init()
735 if (generate_quic_hashed_connection_id(hashed_scid_, remote_addr, local_addr, in init()
1767 const Address &remote_addr, in on_read() argument
1778 const_cast<sockaddr *>(&remote_addr.su.sa), in on_read()
1779 static_cast<socklen_t>(remote_addr.len), in on_read()
[all …]
|
| D | h2load.h | 354 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/ |
| D | coap_tcp.c | 48 coap_address_t *remote_addr) { argument
151 if (getpeername(sock->fd, &remote_addr->addr.sa, &remote_addr->size) == COAP_SOCKET_ERROR) {
167 coap_address_t *remote_addr) { argument
195 if (getpeername(sock->fd, &remote_addr->addr.sa, &remote_addr->size) == COAP_SOCKET_ERROR) {
302 coap_address_t *remote_addr) { argument
313 new_client->fd = accept(server->fd, &remote_addr->addr.sa,
314 &remote_addr->size);
|
| D | coap_io_lwip.c | 381 coap_address_t *remote_addr) { in coap_socket_connect_udp() argument
388 (void)remote_addr; in coap_socket_connect_udp()
440 coap_address_t *remote_addr) { in coap_socket_connect_tcp1() argument
446 (void)remote_addr; in coap_socket_connect_tcp1()
453 coap_address_t *remote_addr) { in coap_socket_connect_tcp2() argument
456 (void)remote_addr; in coap_socket_connect_tcp2()
474 coap_address_t *remote_addr) { in coap_socket_accept_tcp() argument
478 (void)remote_addr; in coap_socket_accept_tcp()
|
| D | coap_io_contiki.c | 112 coap_address_t *remote_addr) { in coap_socket_connect_udp() argument
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()
|
| D | coap_tinydtls.c | 296 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/ |
| D | coap_tcp_internal.h | 53 coap_address_t *remote_addr);
68 coap_address_t *remote_addr);
102 coap_address_t *remote_addr);
|
| /third_party/lwip/src/include/lwip/apps/ |
| D | lwiperf.h | 81 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/ |
| D | vquic.c | 329 struct sockaddr_storage remote_addr[MMSG_NUM]; in recvmmsg_packets() local
346 mmsg[i].msg_hdr.msg_name = &remote_addr[i]; in recvmmsg_packets()
347 mmsg[i].msg_hdr.msg_namelen = sizeof(remote_addr[i]); in recvmmsg_packets()
404 struct sockaddr_storage remote_addr; in recvmsg_packets() local
419 msg.msg_name = &remote_addr; in recvmsg_packets()
420 msg.msg_namelen = sizeof(remote_addr); in recvmsg_packets()
469 struct sockaddr_storage remote_addr; in recvfrom_packets() local
470 socklen_t remote_addrlen = sizeof(remote_addr); in recvfrom_packets()
479 (struct sockaddr *)&remote_addr, in recvfrom_packets()
507 result = recv_cb(buf, (size_t)nread, &remote_addr, remote_addrlen, in recvfrom_packets()
|
| /third_party/lwip/src/apps/lwiperf/ |
| D | lwiperf.c | 129 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, &sta… in lwiperf_start_tcp_client()
803 server->remote_addr = state->conn_pcb->remote_ip; in lwiperf_start_tcp_client()
|
| /third_party/curl/lib/ |
| D | tftp.c | 137 struct Curl_sockaddr_storage remote_addr; member
533 &data->conn->remote_addr->sa_addr, in tftp_send_first()
534 data->conn->remote_addr->addrlen); in tftp_send_first()
618 (struct sockaddr *)&state->remote_addr, in tftp_rx()
643 (struct sockaddr *)&state->remote_addr, in tftp_rx()
669 (struct sockaddr *)&state->remote_addr, in tftp_rx()
683 (struct sockaddr *)&state->remote_addr, in tftp_rx()
743 (struct sockaddr *)&state->remote_addr, in tftp_tx()
787 (struct sockaddr *)&state->remote_addr, in tftp_tx()
813 (struct sockaddr *)&state->remote_addr, in tftp_tx()
[all …]
|
| /third_party/ltp/testcases/kernel/syscalls/bind/ |
| D | bind05.c | 122 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()
|
| D | bind04.c | 108 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/ |
| D | ngtcp2_path.c | 51 const ngtcp2_sockaddr *remote_addr, in ngtcp2_path_storage_init() argument
59 ngtcp2_addr_copy_byte(&ps->path.remote, remote_addr, remote_addrlen); in ngtcp2_path_storage_init()
|
| /third_party/node/deps/ngtcp2/ngtcp2/crypto/includes/ngtcp2/ |
| D | ngtcp2_crypto.h | 659 const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen,
683 const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen,
705 const ngtcp2_sockaddr *remote_addr, ngtcp2_socklen remote_addrlen,
722 size_t secretlen, const ngtcp2_sockaddr *remote_addr,
|
| /third_party/lwip/src/apps/http/ |
| D | http_client.c | 136 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/gstreamer/gstplugins_bad/ext/sctp/ |
| D | sctpassociation.c | 472 struct sockaddr_conn remote_addr; in gst_sctp_association_send_data() local
489 remote_addr = get_sctp_socket_address (self, self->remote_port); in gst_sctp_association_send_data()
517 (struct sockaddr *) &remote_addr, 1, (void *) &spa, in gst_sctp_association_send_data()
711 struct sockaddr_conn local_addr, remote_addr; in client_role_connect() local
718 remote_addr = get_sctp_socket_address (self, self->remote_port); in client_role_connect()
731 usrsctp_connect (self->sctp_ass_sock, (struct sockaddr *) &remote_addr, in client_role_connect()
740 memcpy (&paddrparams.spp_address, &remote_addr, in client_role_connect()
|
| /third_party/python/Lib/asyncio/ |
| D | base_events.py | 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):
1286 (local_addr, remote_addr)), )
1290 for idx, addr in ((0, local_addr), (1, remote_addr)):
1311 (remote_addr and addr_pair[1] is None))]
1347 if remote_addr:
1372 local_addr, remote_addr, transport, protocol)
[all …]
|