Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(73)

Unified Diff: ipc/ipc_sync_channel.cc

Issue 6142009: Upating the app, ceee, chrome, ipc, media, and net directories to use the correct lock.h file. (Closed) Base URL: http://git.chromium.org/git/chromium.git@trunk
Patch Set: Unified patch updating all references to the new base/synchronization/lock.h Created 9 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « ipc/ipc_sync_channel.h ('k') | ipc/ipc_sync_message_filter.h » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: ipc/ipc_sync_channel.cc
diff --git a/ipc/ipc_sync_channel.cc b/ipc/ipc_sync_channel.cc
index fbad0f617a83f298c01549dd197680f11fa5bbd1..1c7edfa6d59521c55685327854c510835b145712 100644
--- a/ipc/ipc_sync_channel.cc
+++ b/ipc/ipc_sync_channel.cc
@@ -55,7 +55,7 @@ class SyncChannel::ReceivedSyncMsgQueue :
void QueueMessage(const Message& msg, SyncChannel::SyncContext* context) {
bool was_task_pending;
{
- AutoLock auto_lock(message_lock_);
+ base::AutoLock auto_lock(message_lock_);
was_task_pending = task_pending_;
task_pending_ = true;
@@ -80,7 +80,7 @@ class SyncChannel::ReceivedSyncMsgQueue :
// messages.
void DispatchMessagesTask() {
{
- AutoLock auto_lock(message_lock_);
+ base::AutoLock auto_lock(message_lock_);
task_pending_ = false;
}
DispatchMessages();
@@ -91,7 +91,7 @@ class SyncChannel::ReceivedSyncMsgQueue :
Message* message;
scoped_refptr<SyncChannel::SyncContext> context;
{
- AutoLock auto_lock(message_lock_);
+ base::AutoLock auto_lock(message_lock_);
if (message_queue_.empty())
break;
@@ -107,7 +107,7 @@ class SyncChannel::ReceivedSyncMsgQueue :
// SyncChannel calls this in its destructor.
void RemoveContext(SyncContext* context) {
- AutoLock auto_lock(message_lock_);
+ base::AutoLock auto_lock(message_lock_);
SyncMessageQueue::iterator iter = message_queue_.begin();
while (iter != message_queue_.end()) {
@@ -185,7 +185,7 @@ class SyncChannel::ReceivedSyncMsgQueue :
// message.
WaitableEvent dispatch_event_;
MessageLoop* listener_message_loop_;
- Lock message_lock_;
+ base::Lock message_lock_;
bool task_pending_;
int listener_count_;
@@ -223,14 +223,14 @@ void SyncChannel::SyncContext::Push(SyncMessage* sync_msg) {
PendingSyncMsg pending(SyncMessage::GetMessageId(*sync_msg),
sync_msg->GetReplyDeserializer(),
new WaitableEvent(true, false));
- AutoLock auto_lock(deserializers_lock_);
+ base::AutoLock auto_lock(deserializers_lock_);
deserializers_.push_back(pending);
}
bool SyncChannel::SyncContext::Pop() {
bool result;
{
- AutoLock auto_lock(deserializers_lock_);
+ base::AutoLock auto_lock(deserializers_lock_);
PendingSyncMsg msg = deserializers_.back();
delete msg.deserializer;
delete msg.done_event;
@@ -251,7 +251,7 @@ bool SyncChannel::SyncContext::Pop() {
}
WaitableEvent* SyncChannel::SyncContext::GetSendDoneEvent() {
- AutoLock auto_lock(deserializers_lock_);
+ base::AutoLock auto_lock(deserializers_lock_);
return deserializers_.back().done_event;
}
@@ -264,7 +264,7 @@ void SyncChannel::SyncContext::DispatchMessages() {
}
bool SyncChannel::SyncContext::TryToUnblockListener(const Message* msg) {
- AutoLock auto_lock(deserializers_lock_);
+ base::AutoLock auto_lock(deserializers_lock_);
if (deserializers_.empty() ||
!SyncMessage::IsMessageReplyTo(*msg, deserializers_.back().id)) {
return false;
@@ -324,7 +324,7 @@ void SyncChannel::SyncContext::OnChannelClosed() {
}
void SyncChannel::SyncContext::OnSendTimeout(int message_id) {
- AutoLock auto_lock(deserializers_lock_);
+ base::AutoLock auto_lock(deserializers_lock_);
PendingSyncMessageQueue::iterator iter;
for (iter = deserializers_.begin(); iter != deserializers_.end(); iter++) {
if (iter->id == message_id) {
@@ -335,7 +335,7 @@ void SyncChannel::SyncContext::OnSendTimeout(int message_id) {
}
void SyncChannel::SyncContext::CancelPendingSends() {
- AutoLock auto_lock(deserializers_lock_);
+ base::AutoLock auto_lock(deserializers_lock_);
PendingSyncMessageQueue::iterator iter;
for (iter = deserializers_.begin(); iter != deserializers_.end(); iter++)
iter->done_event->Signal();
« no previous file with comments | « ipc/ipc_sync_channel.h ('k') | ipc/ipc_sync_message_filter.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698