| Index: remoting/protocol/named_message_pipe_handler.cc
|
| diff --git a/remoting/protocol/named_message_pipe_handler.cc b/remoting/protocol/named_message_pipe_handler.cc
|
| deleted file mode 100644
|
| index 4741d57a02244ae5ff56db52e532010102b32cb1..0000000000000000000000000000000000000000
|
| --- a/remoting/protocol/named_message_pipe_handler.cc
|
| +++ /dev/null
|
| @@ -1,69 +0,0 @@
|
| -// Copyright 2017 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#include "remoting/protocol/named_message_pipe_handler.h"
|
| -
|
| -#include <utility>
|
| -
|
| -#include "base/location.h"
|
| -#include "base/logging.h"
|
| -#include "base/threading/thread_task_runner_handle.h"
|
| -#include "remoting/base/compound_buffer.h"
|
| -
|
| -namespace remoting {
|
| -namespace protocol {
|
| -
|
| -NamedMessagePipeHandler::NamedMessagePipeHandler(
|
| - const std::string& name,
|
| - std::unique_ptr<MessagePipe> pipe)
|
| - : name_(name),
|
| - pipe_(std::move(pipe)) {
|
| - DCHECK(pipe_);
|
| - pipe_->Start(this);
|
| -}
|
| -
|
| -NamedMessagePipeHandler::~NamedMessagePipeHandler() = default;
|
| -
|
| -void NamedMessagePipeHandler::Close() {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - if (connected()) {
|
| - OnDisconnecting();
|
| - is_connected_ = false;
|
| - }
|
| - delete this;
|
| -}
|
| -
|
| -void NamedMessagePipeHandler::Send(google::protobuf::MessageLite* message,
|
| - const base::Closure& done) {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - DCHECK(connected());
|
| - pipe_->Send(message, done);
|
| -}
|
| -
|
| -void NamedMessagePipeHandler::OnIncomingMessage(
|
| - std::unique_ptr<CompoundBuffer> message) {}
|
| -
|
| -void NamedMessagePipeHandler::OnConnected() {}
|
| -
|
| -void NamedMessagePipeHandler::OnDisconnecting() {}
|
| -
|
| -void NamedMessagePipeHandler::OnMessagePipeOpen() {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - DCHECK(!is_connected_);
|
| - is_connected_ = true;
|
| - OnConnected();
|
| -}
|
| -
|
| -void NamedMessagePipeHandler::OnMessageReceived(
|
| - std::unique_ptr<CompoundBuffer> message) {
|
| - DCHECK(thread_checker_.CalledOnValidThread());
|
| - OnIncomingMessage(std::move(message));
|
| -}
|
| -
|
| -void NamedMessagePipeHandler::OnMessagePipeClosed() {
|
| - Close();
|
| -}
|
| -
|
| -} // namespace protocol
|
| -} // namespace remoting
|
|
|