chromium/remoting/base/protobuf_http_stream_request.cc

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

#include "remoting/base/protobuf_http_stream_request.h"

#include "base/functional/bind.h"
#include "base/logging.h"
#include "base/time/time.h"
#include "remoting/base/protobuf_http_client.h"
#include "remoting/base/protobuf_http_request_config.h"
#include "remoting/base/protobuf_http_status.h"
#include "remoting/base/protobuf_http_stream_parser.h"
#include "services/network/public/cpp/simple_url_loader.h"
#include "third_party/protobuf/src/google/protobuf/message_lite.h"

namespace remoting {

// static
constexpr base::TimeDelta
    ProtobufHttpStreamRequest::kStreamReadyTimeoutDuration;

ProtobufHttpStreamRequest::ProtobufHttpStreamRequest(
    std::unique_ptr<ProtobufHttpRequestConfig> config)
    : … { … }

ProtobufHttpStreamRequest::~ProtobufHttpStreamRequest() = default;

void ProtobufHttpStreamRequest::SetStreamReadyCallback(
    base::OnceClosure callback) { … }

void ProtobufHttpStreamRequest::SetStreamClosedCallback(
    StreamClosedCallback callback) { … }

void ProtobufHttpStreamRequest::OnMessage(const std::string& message) { … }

void ProtobufHttpStreamRequest::OnStreamClosed(
    const ProtobufHttpStatus& status) { … }

void ProtobufHttpStreamRequest::OnAuthFailed(const ProtobufHttpStatus& status) { … }

void ProtobufHttpStreamRequest::StartRequestInternal(
    network::mojom::URLLoaderFactory* loader_factory) { … }

base::TimeDelta ProtobufHttpStreamRequest::GetRequestTimeoutDuration() const { … }

void ProtobufHttpStreamRequest::OnDataReceived(std::string_view string_view,
                                               base::OnceClosure resume) { … }

void ProtobufHttpStreamRequest::OnComplete(bool success) { … }

void ProtobufHttpStreamRequest::OnRetry(base::OnceClosure start_retry) { … }

void ProtobufHttpStreamRequest::OnStreamReadyTimeout() { … }

}  // namespace remoting