Function proxy_protocol_v2_parse

src/iocore/net/ProxyProtocol.cc:225–315

PROXY Protocol v2 Parser @return read length */

   @return read length
 */
size_t
proxy_protocol_v2_parse(ProxyProtocol *pp_info, const swoc::TextView &msg)
{
  ink_release_assert(msg.size() >= PPv2_CONNECTION_HEADER_LEN);

  const PPv2Hdr *hdr_v2 = reinterpret_cast<const PPv2Hdr *>(msg.data());

  // Assuming PREFACE check is done

  // length check
  const uint16_t len       = ntohs(hdr_v2->len);
  const size_t   total_len = PPv2_CONNECTION_HEADER_LEN + len;
  uint16_t       tlv_len   = 0;

  if (msg.size() < total_len) {
    Dbg(dbg_ctl_proxyprotocol_v2, "The amount of available data is smaller than the expected size");
    return 0;
  }

  // protocol version and command
  switch (hdr_v2->ver_cmd) {
  case PPv2_CMD_LOCAL: {
    // protocol byte should be UNSPEC (\x00) with LOCAL command
    if (hdr_v2->fam != PPv2_PROTO_UNSPEC) {
      Dbg(dbg_ctl_proxyprotocol_v2, "UNSPEC is unexpected");
      return 0;
    }

    pp_info->version   = ProxyProtocolVersion::V2;
    pp_info->ip_family = AF_UNSPEC;

    return total_len;
  }
  case PPv2_CMD_PROXY: {
    switch (hdr_v2->fam) {
    case PPv2_PROTO_TCP4:
    case PPv2_PROTO_UDP4:
      if (len < PPv2_ADDR_LEN_INET) {
        Dbg(dbg_ctl_proxyprotocol_v2, "There is not enough data left for IPv4 info");
        return 0;
      }
      tlv_len = len - PPv2_ADDR_LEN_INET;

      pp_info->set_ipv4_addrs(reinterpret_cast<in_addr_t>(hdr_v2->addr.ip4.src_addr), hdr_v2->addr.ip4.src_port,
                              reinterpret_cast<in_addr_t>(hdr_v2->addr.ip4.dst_addr), hdr_v2->addr.ip4.dst_port);
      pp_info->type    = hdr_v2->fam == PPv2_PROTO_TCP4 ? SOCK_STREAM : SOCK_DGRAM;
      pp_info->version = ProxyProtocolVersion::V2;

      break;
    case PPv2_PROTO_TCP6:
    case PPv2_PROTO_UDP6:
      if (len < PPv2_ADDR_LEN_INET6) {
        Dbg(dbg_ctl_proxyprotocol_v2, "There is not enough data left for IPv6 info");
        return 0;
      }
      tlv_len = len - PPv2_ADDR_LEN_INET6;

      pp_info->set_ipv6_addrs(reinterpret_cast<in6_addr const &>(hdr_v2->addr.ip6.src_addr), hdr_v2->addr.ip6.src_port,