OLD | NEW |
| (Empty) |
1 // Copyright 2015 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 #include "mojo/public/cpp/bindings/lib/control_message_proxy.h" | |
6 | |
7 #include "mojo/public/cpp/bindings/lib/message_builder.h" | |
8 #include "mojo/public/cpp/bindings/message.h" | |
9 #include "mojo/public/cpp/system/macros.h" | |
10 #include "mojo/public/interfaces/bindings/interface_control_messages.mojom.h" | |
11 | |
12 namespace mojo { | |
13 namespace internal { | |
14 | |
15 namespace { | |
16 | |
17 using RunCallback = Callback<void(QueryVersionResultPtr)>; | |
18 | |
19 class RunResponseForwardToCallback : public MessageReceiver { | |
20 public: | |
21 RunResponseForwardToCallback(const RunCallback& callback) | |
22 : callback_(callback) {} | |
23 bool Accept(Message* message) override; | |
24 | |
25 private: | |
26 RunCallback callback_; | |
27 MOJO_DISALLOW_COPY_AND_ASSIGN(RunResponseForwardToCallback); | |
28 }; | |
29 | |
30 bool RunResponseForwardToCallback::Accept(Message* message) { | |
31 RunResponseMessageParams_Data* params = | |
32 reinterpret_cast<RunResponseMessageParams_Data*>( | |
33 message->mutable_payload()); | |
34 params->DecodePointersAndHandles(message->mutable_handles()); | |
35 | |
36 RunResponseMessageParamsPtr params_ptr(RunResponseMessageParams::New()); | |
37 Deserialize_(params, params_ptr.get()); | |
38 | |
39 callback_.Run(params_ptr->query_version_result.Pass()); | |
40 return true; | |
41 } | |
42 | |
43 void SendRunMessage(MessageReceiverWithResponder* receiver, | |
44 QueryVersionPtr query_version, | |
45 const RunCallback& callback) { | |
46 RunMessageParamsPtr params_ptr(RunMessageParams::New()); | |
47 params_ptr->reserved0 = 16u; | |
48 params_ptr->reserved1 = 0u; | |
49 params_ptr->query_version = query_version.Pass(); | |
50 | |
51 size_t size = GetSerializedSize_(*params_ptr); | |
52 RequestMessageBuilder builder(kRunMessageId, size); | |
53 | |
54 RunMessageParams_Data* params = nullptr; | |
55 auto result = Serialize_(params_ptr.get(), builder.buffer(), ¶ms); | |
56 MOJO_DCHECK(result == ValidationError::NONE); | |
57 | |
58 params->EncodePointersAndHandles(builder.message()->mutable_handles()); | |
59 MessageReceiver* responder = new RunResponseForwardToCallback(callback); | |
60 if (!receiver->AcceptWithResponder(builder.message(), responder)) | |
61 delete responder; | |
62 } | |
63 | |
64 void SendRunOrClosePipeMessage(MessageReceiverWithResponder* receiver, | |
65 RequireVersionPtr require_version) { | |
66 RunOrClosePipeMessageParamsPtr params_ptr(RunOrClosePipeMessageParams::New()); | |
67 params_ptr->reserved0 = 16u; | |
68 params_ptr->reserved1 = 0u; | |
69 params_ptr->require_version = require_version.Pass(); | |
70 | |
71 size_t size = GetSerializedSize_(*params_ptr); | |
72 MessageBuilder builder(kRunOrClosePipeMessageId, size); | |
73 | |
74 RunOrClosePipeMessageParams_Data* params = nullptr; | |
75 auto result = Serialize_(params_ptr.get(), builder.buffer(), ¶ms); | |
76 MOJO_DCHECK(result == ValidationError::NONE); | |
77 | |
78 params->EncodePointersAndHandles(builder.message()->mutable_handles()); | |
79 bool ok = receiver->Accept(builder.message()); | |
80 MOJO_ALLOW_UNUSED_LOCAL(ok); | |
81 } | |
82 | |
83 } // namespace | |
84 | |
85 ControlMessageProxy::ControlMessageProxy(MessageReceiverWithResponder* receiver) | |
86 : receiver_(receiver) { | |
87 } | |
88 | |
89 void ControlMessageProxy::QueryVersion( | |
90 const Callback<void(uint32_t)>& callback) { | |
91 auto run_callback = [callback](QueryVersionResultPtr query_version_result) { | |
92 callback.Run(query_version_result->version); | |
93 }; | |
94 SendRunMessage(receiver_, QueryVersion::New(), run_callback); | |
95 } | |
96 | |
97 void ControlMessageProxy::RequireVersion(uint32_t version) { | |
98 RequireVersionPtr require_version(RequireVersion::New()); | |
99 require_version->version = version; | |
100 SendRunOrClosePipeMessage(receiver_, require_version.Pass()); | |
101 } | |
102 | |
103 } // namespace internal | |
104 } // namespace mojo | |
OLD | NEW |