Index: mojo/common/message_pump_mojo.cc |
diff --git a/mojo/common/message_pump_mojo.cc b/mojo/common/message_pump_mojo.cc |
index 9eee1a0f605addf67f96449b6be41093c0074903..751d5c01b0c0a59e10bdfb2a9a2a4ce38717d1d9 100644 |
--- a/mojo/common/message_pump_mojo.cc |
+++ b/mojo/common/message_pump_mojo.cc |
@@ -20,7 +20,7 @@ namespace common { |
// corresponds to that of the control pipe. |
struct MessagePumpMojo::WaitState { |
std::vector<Handle> handles; |
- std::vector<MojoWaitFlags> wait_flags; |
+ std::vector<MojoHandleSignals> wait_signals; |
}; |
struct MessagePumpMojo::RunState { |
@@ -50,7 +50,7 @@ scoped_ptr<base::MessagePump> MessagePumpMojo::Create() { |
void MessagePumpMojo::AddHandler(MessagePumpMojoHandler* handler, |
const Handle& handle, |
- MojoWaitFlags wait_flags, |
+ MojoHandleSignals wait_signals, |
base::TimeTicks deadline) { |
DCHECK(handler); |
DCHECK(handle.is_valid()); |
@@ -58,7 +58,7 @@ void MessagePumpMojo::AddHandler(MessagePumpMojoHandler* handler, |
DCHECK_EQ(0u, handlers_.count(handle)); |
Handler handler_data; |
handler_data.handler = handler; |
- handler_data.wait_flags = wait_flags; |
+ handler_data.wait_signals = wait_signals; |
handler_data.deadline = deadline; |
handler_data.id = next_handler_id_++; |
handlers_[handle] = handler_data; |
@@ -142,7 +142,7 @@ void MessagePumpMojo::DoInternalWork(const RunState& run_state, bool block) { |
const MojoDeadline deadline = block ? GetDeadlineForWait(run_state) : 0; |
const WaitState wait_state = GetWaitState(run_state); |
const MojoResult result = |
- WaitMany(wait_state.handles, wait_state.wait_flags, deadline); |
+ WaitMany(wait_state.handles, wait_state.wait_signals, deadline); |
if (result == 0) { |
// Control pipe was written to. |
uint32_t num_bytes = 0; |
@@ -189,7 +189,7 @@ void MessagePumpMojo::RemoveFirstInvalidHandle(const WaitState& wait_state) { |
// TODO(sky): deal with control pipe going bad. |
for (size_t i = 1; i < wait_state.handles.size(); ++i) { |
const MojoResult result = |
- Wait(wait_state.handles[i], wait_state.wait_flags[i], 0); |
+ Wait(wait_state.handles[i], wait_state.wait_signals[i], 0); |
if (result == MOJO_RESULT_INVALID_ARGUMENT || |
result == MOJO_RESULT_FAILED_PRECONDITION || |
result == MOJO_RESULT_CANCELLED) { |
@@ -215,12 +215,12 @@ MessagePumpMojo::WaitState MessagePumpMojo::GetWaitState( |
const RunState& run_state) const { |
WaitState wait_state; |
wait_state.handles.push_back(run_state.read_handle.get()); |
- wait_state.wait_flags.push_back(MOJO_WAIT_FLAG_READABLE); |
+ wait_state.wait_signals.push_back(MOJO_WAIT_FLAG_READABLE); |
for (HandleToHandler::const_iterator i = handlers_.begin(); |
i != handlers_.end(); ++i) { |
wait_state.handles.push_back(i->first); |
- wait_state.wait_flags.push_back(i->second.wait_flags); |
+ wait_state.wait_signals.push_back(i->second.wait_signals); |
} |
return wait_state; |
} |