Index: chrome_frame/sync_msg_reply_dispatcher.cc |
diff --git a/chrome_frame/sync_msg_reply_dispatcher.cc b/chrome_frame/sync_msg_reply_dispatcher.cc |
deleted file mode 100644 |
index e2f197472d401707d3a1eefb9cc5ff9e0e39da6d..0000000000000000000000000000000000000000 |
--- a/chrome_frame/sync_msg_reply_dispatcher.cc |
+++ /dev/null |
@@ -1,68 +0,0 @@ |
-// Copyright (c) 2009 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "chrome_frame/sync_msg_reply_dispatcher.h" |
- |
-#include "ipc/ipc_sync_message.h" |
- |
-void SyncMessageReplyDispatcher::Push(IPC::SyncMessage* msg, |
- SyncMessageCallContext* context, |
- void* key) { |
- if (context) { |
- context->message_type_ = msg->type(); |
- context->id_ = IPC::SyncMessage::GetMessageId(*msg); |
- context->key_ = key; |
- |
- base::AutoLock lock(message_queue_lock_); |
- message_queue_.push_back(context); |
- } |
-} |
- |
-bool SyncMessageReplyDispatcher::HandleMessageType( |
- const IPC::Message& msg, SyncMessageCallContext* context) { |
- return false; |
-} |
- |
-bool SyncMessageReplyDispatcher::OnMessageReceived(const IPC::Message& msg) { |
- SyncMessageCallContext* context = GetContext(msg); |
- // No context e.g. no return values and/or don't care |
- if (!context) { |
- return false; |
- } |
- |
- return HandleMessageType(msg, context); |
-} |
- |
-void SyncMessageReplyDispatcher::Cancel(void* key) { |
- DCHECK(key != NULL); |
- base::AutoLock lock(message_queue_lock_); |
- PendingSyncMessageQueue::iterator it = message_queue_.begin(); |
- while (it != message_queue_.end()) { |
- SyncMessageCallContext* context = *it; |
- if (context->key_ == key) { |
- it = message_queue_.erase(it); |
- delete context; |
- } else { |
- ++it; |
- } |
- } |
-} |
- |
-SyncMessageReplyDispatcher::SyncMessageCallContext* |
- SyncMessageReplyDispatcher::GetContext(const IPC::Message& msg) { |
- if (!msg.is_reply()) |
- return NULL; |
- |
- int id = IPC::SyncMessage::GetMessageId(msg); |
- base::AutoLock lock(message_queue_lock_); |
- PendingSyncMessageQueue::iterator it; |
- for (it = message_queue_.begin(); it != message_queue_.end(); ++it) { |
- SyncMessageCallContext* context = *it; |
- if (context->id_ == id) { |
- message_queue_.erase(it); |
- return context; |
- } |
- } |
- return NULL; |
-} |