OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "mojo/public/cpp/bindings/lib/connector.h" | 5 #include "mojo/public/cpp/bindings/lib/connector.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 | 8 |
9 #include "mojo/public/cpp/bindings/error_handler.h" | 9 #include "mojo/public/cpp/bindings/error_handler.h" |
10 #include "mojo/public/cpp/environment/logging.h" | 10 #include "mojo/public/cpp/environment/logging.h" |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
56 MOJO_DEADLINE_INDEFINITE); | 56 MOJO_DEADLINE_INDEFINITE); |
57 if (rv != MOJO_RESULT_OK) { | 57 if (rv != MOJO_RESULT_OK) { |
58 NotifyError(); | 58 NotifyError(); |
59 return false; | 59 return false; |
60 } | 60 } |
61 mojo_ignore_result(ReadSingleMessage(&rv)); | 61 mojo_ignore_result(ReadSingleMessage(&rv)); |
62 return (rv == MOJO_RESULT_OK); | 62 return (rv == MOJO_RESULT_OK); |
63 } | 63 } |
64 | 64 |
65 bool Connector::Accept(Message* message) { | 65 bool Connector::Accept(Message* message) { |
66 MOJO_DCHECK(message_pipe_.is_valid()); | 66 MOJO_CHECK(message_pipe_.is_valid()); |
67 | 67 |
68 if (error_) | 68 if (error_) |
69 return false; | 69 return false; |
70 | 70 |
71 if (drop_writes_) | 71 if (drop_writes_) |
72 return true; | 72 return true; |
73 | 73 |
74 MojoResult rv = WriteMessageRaw( | 74 MojoResult rv = WriteMessageRaw( |
75 message_pipe_.get(), | 75 message_pipe_.get(), |
76 message->data(), | 76 message->data(), |
(...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
115 return true; | 115 return true; |
116 } | 116 } |
117 | 117 |
118 // static | 118 // static |
119 void Connector::CallOnHandleReady(void* closure, MojoResult result) { | 119 void Connector::CallOnHandleReady(void* closure, MojoResult result) { |
120 Connector* self = static_cast<Connector*>(closure); | 120 Connector* self = static_cast<Connector*>(closure); |
121 self->OnHandleReady(result); | 121 self->OnHandleReady(result); |
122 } | 122 } |
123 | 123 |
124 void Connector::OnHandleReady(MojoResult result) { | 124 void Connector::OnHandleReady(MojoResult result) { |
125 MOJO_DCHECK(async_wait_id_ != 0); | 125 MOJO_CHECK(async_wait_id_ != 0); |
126 async_wait_id_ = 0; | 126 async_wait_id_ = 0; |
127 if (result != MOJO_RESULT_OK) { | 127 if (result != MOJO_RESULT_OK) { |
128 NotifyError(); | 128 NotifyError(); |
129 return; | 129 return; |
130 } | 130 } |
131 ReadAllAvailableMessages(); | 131 ReadAllAvailableMessages(); |
132 // At this point, this object might have been deleted. Return. | 132 // At this point, this object might have been deleted. Return. |
133 } | 133 } |
134 | 134 |
135 void Connector::WaitToReadMore() { | 135 void Connector::WaitToReadMore() { |
136 MOJO_DCHECK(!async_wait_id_); | 136 MOJO_CHECK(!async_wait_id_); |
137 async_wait_id_ = waiter_->AsyncWait(message_pipe_.get().value(), | 137 async_wait_id_ = waiter_->AsyncWait(message_pipe_.get().value(), |
138 MOJO_HANDLE_SIGNAL_READABLE, | 138 MOJO_HANDLE_SIGNAL_READABLE, |
139 MOJO_DEADLINE_INDEFINITE, | 139 MOJO_DEADLINE_INDEFINITE, |
140 &Connector::CallOnHandleReady, | 140 &Connector::CallOnHandleReady, |
141 this); | 141 this); |
142 } | 142 } |
143 | 143 |
144 bool Connector::ReadSingleMessage(MojoResult* read_result) { | 144 bool Connector::ReadSingleMessage(MojoResult* read_result) { |
145 bool receiver_result = false; | 145 bool receiver_result = false; |
146 | 146 |
(...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
202 // should end early. | 202 // should end early. |
203 if (destroyed_flag_) { | 203 if (destroyed_flag_) { |
204 *destroyed_flag_ = true; // Propagate flag. | 204 *destroyed_flag_ = true; // Propagate flag. |
205 } | 205 } |
206 if (error_handler_) | 206 if (error_handler_) |
207 error_handler_->OnConnectionError(); | 207 error_handler_->OnConnectionError(); |
208 } | 208 } |
209 | 209 |
210 } // namespace internal | 210 } // namespace internal |
211 } // namespace mojo | 211 } // namespace mojo |
OLD | NEW |