Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(152)

Side by Side Diff: mojo/edk/system/remote_message_pipe_bootstrap.h

Issue 2596363002: [mojo] Delete RemoteMessagePipeBootstrap (Closed)
Patch Set: rebased Created 3 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
(Empty)
1 // Copyright 2016 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 #ifndef MOJO_EDK_SYSTEM_REMOTE_MESSAGE_PIPE_BOOTSTRAP_H_
6 #define MOJO_EDK_SYSTEM_REMOTE_MESSAGE_PIPE_BOOTSTRAP_H_
7
8 #include <string>
9
10 #include "base/macros.h"
11 #include "base/memory/ref_counted.h"
12 #include "base/message_loop/message_loop.h"
13 #include "base/task_runner.h"
14 #include "mojo/edk/embedder/scoped_platform_handle.h"
15 #include "mojo/edk/system/channel.h"
16 #include "mojo/edk/system/ports/name.h"
17 #include "mojo/edk/system/ports/port_ref.h"
18
19 namespace mojo {
20 namespace edk {
21
22 class NodeController;
23
24 // This is used by Core to negotiate a new cross-process message pipe given
25 // an arbitrary platform channel. Both ends of the channel must be passed to
26 // RemoteMessagePipeBootstrap::Create() in their respective processes.
27 //
28 // The bootstrapping procedure the same on either end:
29 //
30 // 1. Select a local port P to be merged with a remote port.
31 // 2. Write the local node name and P's name to the bootstrap pipe.
32 // 3. When a message is read from the pipe:
33 // - If it's the first message read, extract the remote node+port name and
34 // and send an empty ACK message on the pipe.
35 // - If it's the second message read, close the channel, and delete |this|.
36 // 4. When an error occus on the pipe, delete |this|.
37 //
38 // Excluding irrecoverable error conditions such as either process dying,
39 // armageddon, etc., this ensures neither end closes the channel until both ends
40 // are aware of each other's port-to-merge.
41 //
42 // At step 3, one side of the channel is chosen to issue a message at the Ports
43 // layer which eventually merges the two ports.
44 class RemoteMessagePipeBootstrap
45 : public Channel::Delegate,
46 public base::MessageLoop::DestructionObserver {
47 public:
48 ~RemoteMessagePipeBootstrap() override;
49
50 // |port| must be a reference to an uninitialized local port.
51 static void Create(NodeController* node_controller,
52 ScopedPlatformHandle platform_handle,
53 const ports::PortRef& port);
54
55 protected:
56 explicit RemoteMessagePipeBootstrap(NodeController* node_controller,
57 ScopedPlatformHandle platform_handle,
58 const ports::PortRef& port);
59
60 void ShutDown();
61
62 bool shutting_down_ = false;
63 NodeController* node_controller_;
64 const ports::PortRef local_port_;
65
66 scoped_refptr<base::TaskRunner> io_task_runner_;
67 scoped_refptr<Channel> channel_;
68
69 bool peer_info_received_ = false;
70
71 private:
72 // base::MessageLoop::DestructionObserver:
73 void WillDestroyCurrentMessageLoop() override;
74
75 // Channel::Delegate:
76 void OnChannelMessage(const void* payload,
77 size_t payload_size,
78 ScopedPlatformHandleVectorPtr handles) override;
79 void OnChannelError() override;
80
81 void ShutDownNow();
82
83 DISALLOW_COPY_AND_ASSIGN(RemoteMessagePipeBootstrap);
84 };
85
86 } // namespace edk
87 } // namespace mojo
88
89 #endif // MOJO_EDK_SYSTEM_REMOTE_MESSAGE_PIPE_BOOTSTRAP_H_
OLDNEW
« no previous file with comments | « mojo/edk/system/multiprocess_message_pipe_unittest.cc ('k') | mojo/edk/system/remote_message_pipe_bootstrap.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698