Lines Matching defs:paddr
1199 doq_pkt_addr_init(struct doq_pkt_addr* paddr)
1201 paddr->addrlen = (socklen_t)sizeof(paddr->addr);
1202 paddr->localaddrlen = (socklen_t)sizeof(paddr->localaddr);
1203 paddr->ifindex = 0;
1323 doq_store_blocked_pkt(struct comm_point* c, struct doq_pkt_addr* paddr,
1335 memcpy(c->doq_socket->blocked_paddr, paddr,
1345 doq_send_pkt(struct comm_point* c, struct doq_pkt_addr* paddr, uint32_t ecn)
1357 msg.msg_name = (void*)&paddr->addr;
1358 msg.msg_namelen = paddr->addrlen;
1367 doq_set_localaddr_cmsg(&msg, sizeof(control.buf), &paddr->localaddr,
1368 paddr->localaddrlen, paddr->ifindex);
1369 doq_set_ecn(c->fd, paddr->addr.sockaddr.in.sin_family, ecn);
1391 doq_store_blocked_pkt(c, paddr, ecn);
1394 if(!udp_send_errno_needs_log((void*)&paddr->addr,
1395 paddr->addrlen))
1399 if(doq_print_addr_port(&paddr->addr, paddr->addrlen,
1412 if(doq_print_addr_port(&paddr->addr, paddr->addrlen, host,
1443 doq_get_localaddr_cmsg(struct comm_point* c, struct doq_pkt_addr* paddr,
1450 memset(&paddr->localaddr, 0, sizeof(paddr->localaddr));
1459 &paddr->localaddr;
1461 &paddr->addr;
1470 paddr->ifindex = v6info->ipi6_ifindex;
1473 paddr->localaddrlen = sizeof(struct sockaddr_in6);
1481 &paddr->localaddr;
1483 &paddr->addr;
1492 paddr->ifindex = v4info->ipi_ifindex;
1495 paddr->localaddrlen = sizeof(struct sockaddr_in);
1501 &paddr->localaddr;
1503 &paddr->addr;
1512 paddr->ifindex = 0;
1515 paddr->localaddrlen = sizeof(struct sockaddr_in);
1560 doq_recv(struct comm_point* c, struct doq_pkt_addr* paddr, int* pkt_continue,
1571 msg.msg_name = &paddr->addr;
1572 msg.msg_namelen = (socklen_t)sizeof(paddr->addr);
1593 paddr->addrlen = msg.msg_namelen;
1596 if(!doq_get_localaddr_cmsg(c, paddr, pkt_continue, &msg))
1598 pi->ecn = msghdr_get_ecn(&msg, paddr->addr.sockaddr.in.sin_family);
1605 doq_send_version_negotiation(struct comm_point* c, struct doq_pkt_addr* paddr,
1630 doq_send_pkt(c, paddr, 0);
1644 memmove(&key.key.paddr.addr, addr, addrlen);
1645 key.key.paddr.addrlen = addrlen;
1646 memmove(&key.key.paddr.localaddr, localaddr, localaddrlen);
1647 key.key.paddr.localaddrlen = localaddrlen;
1648 key.key.paddr.ifindex = ifindex;
1677 conn = doq_conn_find(table, &key.paddr.addr,
1678 key.paddr.addrlen, &key.paddr.localaddr,
1679 key.paddr.localaddrlen, key.paddr.ifindex, key.dcid,
1704 struct doq_pkt_addr* paddr, const uint8_t* dcid, size_t dcidlen)
1708 conn = doq_conn_find(table, &paddr->addr, paddr->addrlen,
1709 &paddr->localaddr, paddr->localaddrlen, paddr->ifindex,
1732 struct doq_pkt_addr* paddr, struct doq_conn** conn)
1756 doq_send_version_negotiation(c, paddr,
1794 *conn = doq_conn_find_by_addr_or_cid(c->doq_socket->table, paddr,
1819 doq_send_retry(struct comm_point* c, struct doq_pkt_addr* paddr,
1828 if(!doq_print_addr_port(&paddr->addr, paddr->addrlen, host,
1843 hd->version, (void*)&paddr->addr, paddr->addrlen, &scid,
1862 doq_send_pkt(c, paddr, 0);
1868 struct doq_pkt_addr* paddr, struct ngtcp2_pkt_hd* hd,
1884 doq_send_pkt(c, paddr, 0);
1889 doq_verify_retry_token(struct comm_point* c, struct doq_pkt_addr* paddr,
1894 if(!doq_print_addr_port(&paddr->addr, paddr->addrlen, host,
1910 (void*)&paddr->addr, paddr->addrlen, &hd->dcid,
1922 doq_verify_token(struct comm_point* c, struct doq_pkt_addr* paddr,
1927 if(!doq_print_addr_port(&paddr->addr, paddr->addrlen, host,
1941 (void*)&paddr->addr, paddr->addrlen, 3600*NGTCP2_SECONDS,
2002 doq_setup_new_conn(struct comm_point* c, struct doq_pkt_addr* paddr,
2012 doq_send_stateless_connection_close(c, paddr, hd,
2016 conn = doq_conn_create(c, paddr, hd->dcid.data, hd->dcid.datalen,
2057 doq_address_validation(struct comm_point* c, struct doq_pkt_addr* paddr,
2071 doq_send_retry(c, paddr, hd);
2076 doq_send_stateless_connection_close(c, paddr, hd,
2081 if(!doq_verify_retry_token(c, paddr, ocid, hd)) {
2082 doq_send_stateless_connection_close(c, paddr, hd,
2088 if(!doq_verify_token(c, paddr, hd)) {
2089 doq_send_retry(c, paddr, hd);
2104 doq_send_retry(c, paddr, hd);
2120 doq_accept(struct comm_point* c, struct doq_pkt_addr* paddr,
2132 doq_send_retry(c, paddr, &hd);
2146 if(!doq_address_validation(c, paddr, &hd, &ocid, &pocid))
2149 *conn = doq_setup_new_conn(c, paddr, &hd, pocid);
2153 if(!doq_conn_recv(c, paddr, *conn, pi, &err_retry, NULL)) {
2155 doq_send_retry(c, paddr, &hd);
2407 struct doq_pkt_addr paddr;
2420 memcpy(&paddr, c->doq_socket->blocked_paddr, sizeof(paddr));
2421 doq_send_pkt(c, &paddr, c->doq_socket->blocked_pkt_pi.ecn);
2494 addr_to_str((void*)&conn->key.paddr.addr,
2495 conn->key.paddr.addrlen, remotestr,
2518 struct doq_pkt_addr paddr;
2577 addr_to_str((void*)&conn->key.paddr.addr,
2578 conn->key.paddr.addrlen, remotestr,
2582 &conn->key.paddr.addr));
2615 doq_pkt_addr_init(&paddr);
2618 if(!doq_recv(c, &paddr, &pkt_continue, &pi)) {
2627 addr_to_str((void*)&paddr.addr, paddr.addrlen,
2629 addr_to_str((void*)&paddr.localaddr,
2630 paddr.localaddrlen, localstr,
2634 remotestr, doq_sockaddr_get_port(&paddr.addr),
2636 doq_sockaddr_get_port(&paddr.localaddr),
2637 paddr.ifindex);
2647 if(!doq_decode_pkt_header_negotiate(c, &paddr, &conn))
2650 if(!doq_accept(c, &paddr, &conn, &pi))
2683 if(!doq_conn_recv(c, &paddr, conn, &pi, NULL, &err_drop)) {
2804 conn = doq_conn_find(table, &key.paddr.addr,
2805 key.paddr.addrlen, &key.paddr.localaddr,
2806 key.paddr.localaddrlen, key.paddr.ifindex, key.dcid,