Mojo C++ bindings: MultiplexRouter more aggressively dispatch queued messages.

mojo/public/cpp/bindings/lib/multiplex_router.h

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #ifndef MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_
 #define MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_
 
 #include <stdint.h>
 
 #include <deque>
@@ skipping 156 matching lines @@
   // If |force_async| is true, it guarantees not to call any
   // InterfaceEndpointClient methods directly.
   //
   // Note: Because calling into InterfaceEndpointClient may lead to destruction
   // of this object, if |force_async| is set to false, the caller needs to hold
   // on to a ref outside of |lock_| before calling this method.
   void ProcessTasks(bool force_async);
 
   // Returns true to indicate that |task| has been processed. Otherwise the task
   // will be added back to the front of the queue.
-  // |*force_async| may be set to true to force subsequent tasks being processed
-  // in an asynchronous manner.
-  bool ProcessNotifyErrorTask(Task* task, bool* force_async);
-  bool ProcessIncomingMessageTask(Task* task, bool* force_async);
+  bool ProcessNotifyErrorTask(Task* task, bool force_async);
+  bool ProcessIncomingMessageTask(Task* task, bool force_async);
 
   void LockAndCallProcessTasks();
 
   // Updates the state of |endpoint|. If both the endpoint and its peer have
   // been closed, removes it from |endpoints_|.
   // NOTE: The method may invalidate |endpoint|.
   enum EndpointStateUpdateType { ENDPOINT_CLOSED, PEER_ENDPOINT_CLOSED };
   void UpdateEndpointStateMayRemove(InterfaceEndpoint* endpoint,
                                     EndpointStateUpdateType type);
 
@@ skipping 21 matching lines @@
 
   bool testing_mode_;
 
   DISALLOW_COPY_AND_ASSIGN(MultiplexRouter);
 };
 
 }  // namespace internal
 }  // namespace mojo
 
 #endif  // MOJO_PUBLIC_CPP_BINDINGS_LIB_MULTIPLEX_ROUTER_H_