chromium/chrome/test/chromedriver/net/sync_websocket_impl.cc

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

#include "chrome/test/chromedriver/net/sync_websocket_impl.h"

#include <memory>

#include "base/functional/bind.h"
#include "base/functional/callback.h"
#include "base/json/json_reader.h"
#include "base/json/json_writer.h"
#include "base/location.h"
#include "base/synchronization/waitable_event.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/single_thread_task_runner.h"
#include "chrome/test/chromedriver/net/command_id.h"
#include "chrome/test/chromedriver/net/timeout.h"
#include "net/base/net_errors.h"
#include "net/url_request/url_request_context_getter.h"
#include "url/gurl.h"

SyncWebSocketImpl::SyncWebSocketImpl(
    net::URLRequestContextGetter* context_getter)
    : … { … }

SyncWebSocketImpl::~SyncWebSocketImpl() = default;

bool SyncWebSocketImpl::IsConnected() { … }

bool SyncWebSocketImpl::Connect(const GURL& url) { … }

bool SyncWebSocketImpl::Send(const std::string& message) { … }

SyncWebSocket::StatusCode SyncWebSocketImpl::ReceiveNextMessage(
    std::string* message, const Timeout& timeout) { … }

bool SyncWebSocketImpl::HasNextMessage() { … }

void SyncWebSocketImpl::SetNotificationCallback(
    base::RepeatingClosure callback) { … }

void SyncWebSocketImpl::SendNotification() { … }

SyncWebSocketImpl::Core::Core(net::URLRequestContextGetter* context_getter)
    : … { … }

bool SyncWebSocketImpl::Core::IsConnected() { … }

bool SyncWebSocketImpl::Core::Connect(const GURL& url) { … }

bool SyncWebSocketImpl::Core::Send(const std::string& message) { … }

SyncWebSocket::StatusCode SyncWebSocketImpl::Core::ReceiveNextMessage(
    std::string* message,
    const Timeout& timeout) { … }

bool SyncWebSocketImpl::Core::HasNextMessage() { … }

// TODO(johnchen) : Send messages with negative command ids to client.
// https://crrev.com/c/1745493 is a pending CL that does this
void SyncWebSocketImpl::Core::OnMessageReceived(const std::string& message) { … }

void SyncWebSocketImpl::Core::DetermineRecipient(const std::string& message,
                                                 bool* send_to_chromedriver) { … }

void SyncWebSocketImpl::Core::OnClose() { … }

void SyncWebSocketImpl::Core::SetNotificationCallback(
    base::RepeatingClosure callback) { … }

SyncWebSocketImpl::Core::~Core() = default;

void SyncWebSocketImpl::Core::ConnectOnIO(
    const GURL& url,
    bool* success,
    base::WaitableEvent* event) { … }

void SyncWebSocketImpl::Core::OnConnectCompletedOnIO(
    bool* success,
    base::WaitableEvent* event,
    int error) { … }

void SyncWebSocketImpl::Core::SendOnIO(
    const std::string& message,
    bool* success,
    base::WaitableEvent* event) { … }

void SyncWebSocketImpl::Core::OnDestruct() const { … }

void SyncWebSocketImpl::Core::CloseOnIO(base::WaitableEvent* event) { … }