| Index: mojo/public/cpp/bindings/lib/router.cc
|
| diff --git a/mojo/public/cpp/bindings/lib/router.cc b/mojo/public/cpp/bindings/lib/router.cc
|
| index 2db2eed3e3d4a42847cd5cb881cc237730c42d79..8c1b77d56476c6151eb9b37533f91cff5833fa59 100644
|
| --- a/mojo/public/cpp/bindings/lib/router.cc
|
| +++ b/mojo/public/cpp/bindings/lib/router.cc
|
| @@ -60,7 +60,7 @@ class ResponderThunk : public MessageReceiverWithStatus {
|
| bool Accept(Message* message) override {
|
| DCHECK(task_runner_->RunsTasksOnCurrentThread());
|
| accept_was_invoked_ = true;
|
| - DCHECK(message->has_flag(kMessageIsResponse));
|
| + DCHECK(message->has_flag(Message::kFlagIsResponse));
|
|
|
| bool result = false;
|
|
|
| @@ -142,20 +142,20 @@ Router::~Router() {}
|
|
|
| bool Router::Accept(Message* message) {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| - DCHECK(!message->has_flag(kMessageExpectsResponse));
|
| + DCHECK(!message->has_flag(Message::kFlagExpectsResponse));
|
| return connector_.Accept(message);
|
| }
|
|
|
| bool Router::AcceptWithResponder(Message* message, MessageReceiver* responder) {
|
| DCHECK(thread_checker_.CalledOnValidThread());
|
| - DCHECK(message->has_flag(kMessageExpectsResponse));
|
| + DCHECK(message->has_flag(Message::kFlagExpectsResponse));
|
|
|
| // Reserve 0 in case we want it to convey special meaning in the future.
|
| uint64_t request_id = next_request_id_++;
|
| if (request_id == 0)
|
| request_id = next_request_id_++;
|
|
|
| - bool is_sync = message->has_flag(kMessageIsSync);
|
| + bool is_sync = message->has_flag(Message::kFlagIsSync);
|
| message->set_request_id(request_id);
|
| if (!connector_.Accept(message))
|
| return false;
|
| @@ -202,7 +202,7 @@ bool Router::HandleIncomingMessage(Message* message) {
|
|
|
| const bool during_sync_call =
|
| connector_.during_sync_handle_watcher_callback();
|
| - if (!message->has_flag(kMessageIsSync) &&
|
| + if (!message->has_flag(Message::kFlagIsSync) &&
|
| (during_sync_call || !pending_messages_.empty())) {
|
| std::unique_ptr<Message> pending_message(new Message);
|
| message->MoveTo(pending_message.get());
|
| @@ -250,7 +250,7 @@ void Router::HandleQueuedMessages() {
|
| }
|
|
|
| bool Router::HandleMessageInternal(Message* message) {
|
| - if (message->has_flag(kMessageExpectsResponse)) {
|
| + if (message->has_flag(Message::kFlagExpectsResponse)) {
|
| if (!incoming_receiver_)
|
| return false;
|
|
|
| @@ -261,10 +261,10 @@ bool Router::HandleMessageInternal(Message* message) {
|
| delete responder;
|
| return ok;
|
|
|
| - } else if (message->has_flag(kMessageIsResponse)) {
|
| + } else if (message->has_flag(Message::kFlagIsResponse)) {
|
| uint64_t request_id = message->request_id();
|
|
|
| - if (message->has_flag(kMessageIsSync)) {
|
| + if (message->has_flag(Message::kFlagIsSync)) {
|
| auto it = sync_responses_.find(request_id);
|
| if (it == sync_responses_.end()) {
|
| DCHECK(testing_mode_);
|
|
|