| Index: mojo/public/cpp/bindings/lib/connector.h
|
| diff --git a/mojo/public/cpp/bindings/lib/connector.h b/mojo/public/cpp/bindings/lib/connector.h
|
| index 8e664a196cd7811ebb1ea10bd9d931e89652dc89..3978171101ce0d8f7368954b37ee29171a4e3b67 100644
|
| --- a/mojo/public/cpp/bindings/lib/connector.h
|
| +++ b/mojo/public/cpp/bindings/lib/connector.h
|
| @@ -6,7 +6,6 @@
|
| #define MOJO_PUBLIC_CPP_BINDINGS_LIB_CONNECTOR_H_
|
|
|
| #include "base/memory/scoped_ptr.h"
|
| -#include "base/memory/weak_ptr.h"
|
| #include "base/threading/thread_checker.h"
|
| #include "mojo/public/c/environment/async_waiter.h"
|
| #include "mojo/public/cpp/bindings/callback.h"
|
| @@ -122,31 +121,9 @@
|
| return message_pipe_.get();
|
| }
|
|
|
| - // Requests to register |message_pipe_| with SyncHandleWatcher whenever this
|
| - // instance is expecting incoming messages.
|
| - //
|
| - // Please note that UnregisterSyncHandleWatch() needs to be called as many
|
| - // times as successful RegisterSyncHandleWatch() calls in order to cancel the
|
| - // effect.
|
| - bool RegisterSyncHandleWatch();
|
| - void UnregisterSyncHandleWatch();
|
| -
|
| - // Watches all handles registered with SyncHandleWatcher on the same thread.
|
| - // The method returns true when |*should_stop| is set to true; returns false
|
| - // when any failure occurs during the watch, including |message_pipe_| is
|
| - // closed.
|
| - bool RunSyncHandleWatch(const bool* should_stop);
|
| -
|
| - // Whether currently the control flow is inside the sync handle watcher
|
| - // callback.
|
| - bool during_sync_handle_watcher_callback() const {
|
| - return sync_handle_watcher_callback_count_ > 0;
|
| - }
|
| -
|
| private:
|
| static void CallOnHandleReady(void* closure, MojoResult result);
|
| - void OnSyncHandleWatcherHandleReady(MojoResult result);
|
| - void OnHandleReadyInternal(MojoResult result);
|
| + void OnHandleReady(MojoResult result);
|
|
|
| void WaitToReadMore();
|
|
|
| @@ -178,21 +155,16 @@
|
|
|
| bool paused_;
|
|
|
| + // If non-null, this will be set to true when the Connector is destroyed. We
|
| + // use this flag to allow for the Connector to be destroyed as a side-effect
|
| + // of dispatching an incoming message.
|
| + bool* destroyed_flag_;
|
| +
|
| // If sending messages is allowed from multiple threads, |lock_| is used to
|
| // protect modifications to |message_pipe_| and |drop_writes_|.
|
| scoped_ptr<base::Lock> lock_;
|
|
|
| - // If non-zero, |message_pipe_| should be registered with SyncHandleWatcher.
|
| - size_t register_sync_handle_watch_count_;
|
| - // Whether |message_pipe_| has been registered with SyncHandleWatcher.
|
| - bool registered_with_sync_handle_watcher_;
|
| - // If non-zero, currently the control flow is inside the sync handle watcher
|
| - // callback.
|
| - size_t sync_handle_watcher_callback_count_;
|
| -
|
| base::ThreadChecker thread_checker_;
|
| -
|
| - base::WeakPtrFactory<Connector> weak_factory_;
|
|
|
| MOJO_DISALLOW_COPY_AND_ASSIGN(Connector);
|
| };
|
|
|