Index: components/nacl/loader/nacl_ipc_adapter.cc |
diff --git a/components/nacl/loader/nacl_ipc_adapter.cc b/components/nacl/loader/nacl_ipc_adapter.cc |
index 076594eff91f9a59a54047ff6ac88af5c10bc588..879fa2cd57872e0c44121c0487b26ec5fc9f79bb 100644 |
--- a/components/nacl/loader/nacl_ipc_adapter.cc |
+++ b/components/nacl/loader/nacl_ipc_adapter.cc |
@@ -437,8 +437,8 @@ int NaClIPCAdapter::BlockingReceive(NaClImcTypedMsgHdr* msg) { |
retval = LockedReceive(msg); |
DCHECK(retval > 0); |
} |
+ cond_var_.Signal(); |
} |
- cond_var_.Signal(); |
return retval; |
} |
@@ -446,8 +446,8 @@ void NaClIPCAdapter::CloseChannel() { |
{ |
base::AutoLock lock(lock_); |
locked_data_.channel_closed_ = true; |
+ cond_var_.Signal(); |
} |
- cond_var_.Signal(); |
task_runner_->PostTask(FROM_HERE, |
base::Bind(&NaClIPCAdapter::CloseChannelOnIOThread, this)); |
@@ -551,8 +551,8 @@ bool NaClIPCAdapter::OnMessageReceived(const IPC::Message& msg) { |
SaveMessage(*new_msg, rewritten_msg.get()); |
else |
SaveMessage(msg, rewritten_msg.get()); |
+ cond_var_.Signal(); |
} |
- cond_var_.Signal(); |
return true; |
} |