chromium/services/network/websocket_throttler.cc

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

#include "services/network/websocket_throttler.h"

#include <algorithm>

#include "base/rand_util.h"
#include "services/network/public/mojom/network_context.mojom-forward.h"

namespace network {

constexpr int WebSocketPerProcessThrottler::kMaxPendingWebSocketConnections;

WebSocketPerProcessThrottler::PendingConnection::PendingConnection(
    base::WeakPtr<WebSocketPerProcessThrottler> throttler)
    : … { … }
WebSocketPerProcessThrottler::PendingConnection::PendingConnection(
    PendingConnection&& other)
    : … { … }
WebSocketPerProcessThrottler::PendingConnection::~PendingConnection() { … }

void WebSocketPerProcessThrottler::PendingConnection::OnCompleteHandshake() { … }

WebSocketPerProcessThrottler::WebSocketPerProcessThrottler() { … }
WebSocketPerProcessThrottler::~WebSocketPerProcessThrottler() { … }

base::TimeDelta WebSocketPerProcessThrottler::CalculateDelay() const { … }

WebSocketPerProcessThrottler::PendingConnection
WebSocketPerProcessThrottler::IssuePendingConnectionTracker() { … }

bool WebSocketPerProcessThrottler::IsClean() const { … }

void WebSocketPerProcessThrottler::Roll() { … }

WebSocketThrottler::WebSocketThrottler() { … }
WebSocketThrottler::~WebSocketThrottler() { … }

bool WebSocketThrottler::HasTooManyPendingConnections(int process_id) const { … }

base::TimeDelta WebSocketThrottler::CalculateDelay(int process_id) const { … }

std::optional<WebSocketThrottler::PendingConnection>
WebSocketThrottler::IssuePendingConnectionTracker(int process_id) { … }

void WebSocketThrottler::OnTimer() { … }

}  // namespace network