xref: /aosp_15_r20/external/cronet/net/quic/quic_http_utils.cc (revision 6777b5387eb2ff775bb5750e3f5d96f37fb7352b)

// Copyright 2013 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "net/quic/quic_http_utils.h"

#include <utility>

#include "base/metrics/histogram_macros.h"
#include "net/spdy/spdy_log_util.h"

namespace net {

spdy::SpdyPriority ConvertRequestPriorityToQuicPriority(
    const RequestPriority priority) {
  DCHECK_GE(priority, MINIMUM_PRIORITY);
  DCHECK_LE(priority, MAXIMUM_PRIORITY);
  return static_cast<spdy::SpdyPriority>(HIGHEST - priority);
}

RequestPriority ConvertQuicPriorityToRequestPriority(
    spdy::SpdyPriority priority) {
  // Handle invalid values gracefully.
  return (priority >= 5) ? IDLE
                         : static_cast<RequestPriority>(HIGHEST - priority);
}

base::Value::Dict QuicRequestNetLogParams(quic::QuicStreamId stream_id,
                                          const spdy::Http2HeaderBlock* headers,
                                          quic::QuicStreamPriority priority,
                                          NetLogCaptureMode capture_mode) {
  base::Value::Dict dict = Http2HeaderBlockNetLogParams(headers, capture_mode);
  switch (priority.type()) {
    case quic::QuicPriorityType::kHttp: {
      auto http_priority = priority.http();
      dict.Set("quic_priority_type", "http");
      dict.Set("quic_priority_urgency", http_priority.urgency);
      dict.Set("quic_priority_incremental", http_priority.incremental);
      break;
    }
    case quic::QuicPriorityType::kWebTransport: {
      auto web_transport_priority = priority.web_transport();
      dict.Set("quic_priority_type", "web_transport");
      const char* stream_type = "invalid";
      switch (web_transport_priority.stream_type) {
        case quic::WebTransportStreamPriority::StreamType::kData:
          stream_type = "data";
          break;
        case quic::WebTransportStreamPriority::StreamType::kHttp:
          stream_type = "http";
          break;
        case quic::WebTransportStreamPriority::StreamType::kStatic:
          stream_type = "static";
          break;
      }
      dict.Set("web_transport_stream_type", stream_type);
      // send_order is an int64_t, but base::Value doesn't support that type.
      // Case to a double instead. As this is just for diagnostics, some loss of
      // precision is acceptable.
      dict.Set("web_transport_send_order",
               static_cast<double>(web_transport_priority.send_order));
      break;
    }
  }
  dict.Set("quic_stream_id", static_cast<int>(stream_id));
  return dict;
}

base::Value::Dict QuicResponseNetLogParams(
    quic::QuicStreamId stream_id,
    bool fin_received,
    const spdy::Http2HeaderBlock* headers,
    NetLogCaptureMode capture_mode) {
  base::Value::Dict dict = Http2HeaderBlockNetLogParams(headers, capture_mode);
  dict.Set("quic_stream_id", static_cast<int>(stream_id));
  dict.Set("fin", fin_received);
  return dict;
}

}  // namespace net