| Index: mojo/edk/system/channel_manager.h
|
| diff --git a/mojo/edk/system/channel_manager.h b/mojo/edk/system/channel_manager.h
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..244f8add8e80638cf1bb0bb8957c718a7a97ec52
|
| --- /dev/null
|
| +++ b/mojo/edk/system/channel_manager.h
|
| @@ -0,0 +1,74 @@
|
| +// Copyright 2014 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 MOJO_EDK_SYSTEM_CHANNEL_MANAGER_H_
|
| +#define MOJO_EDK_SYSTEM_CHANNEL_MANAGER_H_
|
| +
|
| +#include <stdint.h>
|
| +
|
| +#include "base/containers/hash_tables.h"
|
| +#include "base/macros.h"
|
| +#include "base/memory/ref_counted.h"
|
| +#include "base/synchronization/lock.h"
|
| +#include "base/task_runner.h"
|
| +#include "mojo/edk/system/channel.h"
|
| +#include "mojo/edk/system/channel_info.h"
|
| +
|
| +namespace mojo {
|
| +namespace system {
|
| +
|
| +// IDs for |Channel|s managed by a |ChannelManager|. (IDs should be thought of
|
| +// as specific to a given |ChannelManager|.) 0 is never a valid ID.
|
| +//
|
| +// Note: We currently just use the pointer of the |Channel| casted to a
|
| +// |uintptr_t|, but we reserve the right to change this.
|
| +typedef uintptr_t ChannelId;
|
| +
|
| +// This class manages and "owns" |Channel|s (which typically connect to other
|
| +// processes) for a given process. This class is thread-safe.
|
| +class MOJO_SYSTEM_IMPL_EXPORT ChannelManager {
|
| + public:
|
| + ChannelManager();
|
| + ~ChannelManager();
|
| +
|
| + // Gets the ID for a given channel.
|
| + //
|
| + // Note: This is currently a static method and thus may be called under
|
| + // |lock_|. If this is ever made non-static (i.e., made specific to a given
|
| + // |ChannelManager|), those call sites may have to changed.
|
| + static ChannelId GetChannelId(const Channel* channel) {
|
| + return reinterpret_cast<ChannelId>(channel);
|
| + }
|
| +
|
| + // Adds |channel| to the set of |Channel|s managed by this |ChannelManager|;
|
| + // |channel_thread_task_runner| should be the task runner for |channel|'s
|
| + // creation (a.k.a. I/O) thread.
|
| + //
|
| + // |channel| should either already be initialized or at least already have a
|
| + // task posted to |channel_thread_task_runner| to initialize it. It should not
|
| + // be managed by any |ChannelManager| yet.
|
| + //
|
| + // Returns the ID for the added channel.
|
| + ChannelId AddChannel(
|
| + scoped_refptr<Channel> channel,
|
| + scoped_refptr<base::TaskRunner> channel_thread_task_runner);
|
| +
|
| + // Shuts down the channel specified by the given ID. It is up to the caller to
|
| + // guarantee that this is only called once per channel (that was added using
|
| + // |AddChannel()|).
|
| + void ShutdownChannel(ChannelId channel_id);
|
| +
|
| + private:
|
| + // Note: |Channel| methods should not be called under |lock_|.
|
| + base::Lock lock_; // Protects the members below.
|
| +
|
| + base::hash_map<ChannelId, ChannelInfo> channel_infos_;
|
| +
|
| + DISALLOW_COPY_AND_ASSIGN(ChannelManager);
|
| +};
|
| +
|
| +} // namespace system
|
| +} // namespace mojo
|
| +
|
| +#endif // MOJO_EDK_SYSTEM_CHANNEL_MANAGER_H_
|
|
|