| Index: blimp/net/blimp_message_thread_pipe.h
|
| diff --git a/blimp/net/blimp_message_thread_pipe.h b/blimp/net/blimp_message_thread_pipe.h
|
| deleted file mode 100644
|
| index 648e4a4800cad1e78bc8bf7563ca7b1ab08170ec..0000000000000000000000000000000000000000
|
| --- a/blimp/net/blimp_message_thread_pipe.h
|
| +++ /dev/null
|
| @@ -1,67 +0,0 @@
|
| -// Copyright 2015 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.
|
| -
|
| -#ifndef BLIMP_NET_BLIMP_MESSAGE_THREAD_PIPE_H_
|
| -#define BLIMP_NET_BLIMP_MESSAGE_THREAD_PIPE_H_
|
| -
|
| -#include <memory>
|
| -
|
| -#include "base/memory/ref_counted.h"
|
| -#include "base/memory/weak_ptr.h"
|
| -#include "blimp/net/blimp_net_export.h"
|
| -
|
| -namespace base {
|
| -class SequencedTaskRunner;
|
| -}
|
| -
|
| -namespace blimp {
|
| -
|
| -class BlimpMessageProcessor;
|
| -
|
| -// Uni-directional MessageProcessor "pipe" that accepts messages on
|
| -// one thread and dispatches them to a MessageProcessor on a different
|
| -// thread.
|
| -//
|
| -// Typical usage involves:
|
| -// 1. Create the pipe on the "main" thread, specifying the target thread's
|
| -// task runner.
|
| -// 2. Take one or more MessageProcessor proxies from it.
|
| -// 3. Post a task to the target thread to set the target MessageProcessor.
|
| -// 4. Start using the MessageProcessor proxy(/ies) on the main thread.
|
| -// 5. When the target MessageProcessor is about to be destroyed on the
|
| -// target thread, destroy the pipe instance immediately beforehand.
|
| -// Any messages that are subsequently passed to a proxy, or are already
|
| -// in-flight to the pipe, will be silently dropped.
|
| -class BLIMP_NET_EXPORT BlimpMessageThreadPipe {
|
| - public:
|
| - explicit BlimpMessageThreadPipe(
|
| - const scoped_refptr<base::SequencedTaskRunner>& task_runner);
|
| - ~BlimpMessageThreadPipe();
|
| -
|
| - // Creates a proxy MessageProcessor that routes messages to
|
| - // the outgoing MessageProcessor on |task_runner|.
|
| - // Proxies are safe to create before the outgoing MessageProcessor
|
| - // has been set, but cannot be used until it has after been set -
|
| - // see the class-level comment on usage.
|
| - // Proxies must be deleted on the thread on which they are used.
|
| - std::unique_ptr<BlimpMessageProcessor> CreateProxy();
|
| -
|
| - // Sets/gets the target MessageProcessor on the target thread.
|
| - void set_target_processor(BlimpMessageProcessor* processor);
|
| - BlimpMessageProcessor* target_processor() const;
|
| -
|
| - private:
|
| - // Target MessageProcessor & TaskRunner to process messages with.
|
| - BlimpMessageProcessor* target_processor_ = nullptr;
|
| - scoped_refptr<base::SequencedTaskRunner> target_task_runner_;
|
| -
|
| - // Allows |this| to be safely detached from existing proxies on deletion.
|
| - base::WeakPtrFactory<BlimpMessageThreadPipe> weak_factory_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(BlimpMessageThreadPipe);
|
| -};
|
| -
|
| -} // namespace blimp
|
| -
|
| -#endif // BLIMP_NET_BLIMP_MESSAGE_THREAD_PIPE_H_
|
|
|