Commit 2063eaae authored by Matt Falkenhagen's avatar Matt Falkenhagen Committed by Commit Bot

Convert ipc to Once/Repeating variants of Bind/Callback. (pt 3)

Bug: 1007797
Change-Id: Ic18cf3733c107d3f24f9089095bc27276395ee60
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/1928387
Auto-Submit: Matt Falkenhagen <falken@chromium.org>
Commit-Queue: Ken Rockot <rockot@google.com>
Reviewed-by: default avatarKen Rockot <rockot@google.com>
Cr-Commit-Position: refs/heads/master@{#718250}
parent 409db58c
...@@ -288,8 +288,8 @@ class SyncChannel::ReceivedSyncMsgQueue : ...@@ -288,8 +288,8 @@ class SyncChannel::ReceivedSyncMsgQueue :
listener_task_runner_(base::ThreadTaskRunnerHandle::Get()), listener_task_runner_(base::ThreadTaskRunnerHandle::Get()),
sync_dispatch_watcher_(std::make_unique<mojo::SyncEventWatcher>( sync_dispatch_watcher_(std::make_unique<mojo::SyncEventWatcher>(
&dispatch_event_, &dispatch_event_,
base::Bind(&ReceivedSyncMsgQueue::OnDispatchEventReady, base::BindRepeating(&ReceivedSyncMsgQueue::OnDispatchEventReady,
base::Unretained(this)))) { base::Unretained(this)))) {
sync_dispatch_watcher_->AllowWokenUpBySyncWatchOnSameThread(); sync_dispatch_watcher_->AllowWokenUpBySyncWatchOnSameThread();
} }
...@@ -662,13 +662,14 @@ void SyncChannel::WaitForReply(mojo::SyncHandleRegistry* registry, ...@@ -662,13 +662,14 @@ void SyncChannel::WaitForReply(mojo::SyncHandleRegistry* registry,
bool dispatch = false; bool dispatch = false;
bool send_done = false; bool send_done = false;
bool should_pump_messages = false; bool should_pump_messages = false;
base::Closure on_send_done_callback = base::Bind(&OnEventReady, &send_done); base::RepeatingClosure on_send_done_callback =
base::BindRepeating(&OnEventReady, &send_done);
registry->RegisterEvent(context->GetSendDoneEvent(), on_send_done_callback); registry->RegisterEvent(context->GetSendDoneEvent(), on_send_done_callback);
base::Closure on_pump_messages_callback; base::RepeatingClosure on_pump_messages_callback;
if (pump_messages_event) { if (pump_messages_event) {
on_pump_messages_callback = on_pump_messages_callback =
base::Bind(&OnEventReady, &should_pump_messages); base::BindRepeating(&OnEventReady, &should_pump_messages);
registry->RegisterEvent(pump_messages_event, on_pump_messages_callback); registry->RegisterEvent(pump_messages_event, on_pump_messages_callback);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment