OLD | NEW |
---|---|
(Empty) | |
1 // Copyright 2017 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 HEADLESS_LIB_BROWSER_HEADLESS_TAB_SOCKET_IMPL_H_ | |
6 #define HEADLESS_LIB_BROWSER_HEADLESS_TAB_SOCKET_IMPL_H_ | |
7 | |
8 #include <list> | |
9 | |
10 #include "base/synchronization/lock.h" | |
11 #include "headless/lib/tab_socket.mojom.h" | |
12 #include "headless/public/headless_tab_socket.h" | |
13 #include "mojo/public/cpp/bindings/binding_set.h" | |
14 | |
15 namespace headless { | |
16 | |
17 class HeadlessTabSocketImpl : public HeadlessTabSocket, public TabSocket { | |
18 public: | |
19 HeadlessTabSocketImpl(); | |
20 ~HeadlessTabSocketImpl() override; | |
21 | |
22 // HeadlessTabSocket implementation: | |
23 void SendMessageToTab(const std::string& message) override; | |
24 void SetListener(Listener* listener) override; | |
25 | |
26 // TabSocket implementation: | |
27 void SendMessageToEmbedder(const std::string& message) override; | |
28 void AwaitNextMessageFromEmbedder( | |
29 const AwaitNextMessageFromEmbedderCallback& callback) override; | |
30 | |
31 void CreateMojoService(mojo::InterfaceRequest<TabSocket> request); | |
32 | |
33 private: | |
34 mojo::BindingSet<TabSocket> mojo_bindings_; | |
35 | |
36 base::Lock lock_; // Protects everything below. | |
37 AwaitNextMessageFromEmbedderCallback waiting_for_message_cb_; | |
38 std::list<std::string> out_going_message_queue_; | |
Sami
2017/04/12 14:18:45
nit: outgoing_message_queue_
alex clarke (OOO till 29th)
2017/04/12 15:47:46
Done.
| |
39 std::list<std::string> incomming_message_queue_; | |
Sami
2017/04/12 14:18:45
typo: incoming
alex clarke (OOO till 29th)
2017/04/12 15:47:46
Done.
| |
40 Listener* listener_; // NOT OWNED | |
41 | |
42 DISALLOW_COPY_AND_ASSIGN(HeadlessTabSocketImpl); | |
43 }; | |
44 | |
45 } // namespace headless | |
46 | |
47 #endif // HEADLESS_LIB_BROWSER_HEADLESS_TAB_SOCKET_IMPL_H_ | |
OLD | NEW |