Index: content/common/indexed_db/indexed_db_message_filter.cc |
diff --git a/content/common/indexed_db/indexed_db_message_filter.cc b/content/common/indexed_db/indexed_db_message_filter.cc |
index 1574243f579775965d1487f076bd7cbc9f064c0b..189f568a022c2e580e72baf2853648745d323e82 100644 |
--- a/content/common/indexed_db/indexed_db_message_filter.cc |
+++ b/content/common/indexed_db/indexed_db_message_filter.cc |
@@ -7,6 +7,7 @@ |
#include "base/bind.h" |
#include "base/location.h" |
#include "base/message_loop_proxy.h" |
+#include "base/pickle.h" |
#include "content/common/indexed_db/indexed_db_dispatcher.h" |
#include "content/common/indexed_db/indexed_db_messages.h" |
#include "webkit/glue/worker_task_runner.h" |
@@ -22,7 +23,9 @@ IndexedDBMessageFilter::IndexedDBMessageFilter() : |
bool IndexedDBMessageFilter::OnMessageReceived(const IPC::Message& msg) { |
if (IPC_MESSAGE_CLASS(msg) != IndexedDBMsgStart) |
return false; |
- int ipc_thread_id = IPC::MessageIterator(msg).NextInt(); |
+ int ipc_thread_id = -1; |
+ bool result = PickleIterator(msg).ReadInt(&ipc_thread_id); |
+ DCHECK(result); |
base::Closure closure = base::Bind( |
&IndexedDBMessageFilter::DispatchMessage, this, msg); |
if (ipc_thread_id) |