Index: content/browser/indexed_db/indexed_db_dispatcher_host.cc |
diff --git a/content/browser/indexed_db/indexed_db_dispatcher_host.cc b/content/browser/indexed_db/indexed_db_dispatcher_host.cc |
index 996e6a50ea73ac96d873744eb2d512cdca3a375b..f08901370386e0e2c8419e5f0defd3ebadec2198 100644 |
--- a/content/browser/indexed_db/indexed_db_dispatcher_host.cc |
+++ b/content/browser/indexed_db/indexed_db_dispatcher_host.cc |
@@ -4,6 +4,8 @@ |
#include "content/browser/indexed_db/indexed_db_dispatcher_host.h" |
+#include <stddef.h> |
+ |
#include "base/bind.h" |
#include "base/command_line.h" |
#include "base/files/file_path.h" |
@@ -76,7 +78,7 @@ IndexedDBDispatcherHost::~IndexedDBDispatcherHost() { |
delete iter.second.first; |
} |
-void IndexedDBDispatcherHost::OnChannelConnected(int32 peer_pid) { |
+void IndexedDBDispatcherHost::OnChannelConnected(int32_t peer_pid) { |
BrowserMessageFilter::OnChannelConnected(peer_pid); |
if (request_context_getter_.get()) { |
@@ -160,63 +162,63 @@ bool IndexedDBDispatcherHost::OnMessageReceived(const IPC::Message& message) { |
return handled; |
} |
-int32 IndexedDBDispatcherHost::Add(IndexedDBCursor* cursor) { |
+int32_t IndexedDBDispatcherHost::Add(IndexedDBCursor* cursor) { |
if (!cursor_dispatcher_host_) { |
return 0; |
} |
return cursor_dispatcher_host_->map_.Add(cursor); |
} |
-int32 IndexedDBDispatcherHost::Add(IndexedDBConnection* connection, |
- int32 ipc_thread_id, |
- const GURL& origin_url) { |
+int32_t IndexedDBDispatcherHost::Add(IndexedDBConnection* connection, |
+ int32_t ipc_thread_id, |
+ const GURL& origin_url) { |
if (!database_dispatcher_host_) { |
connection->Close(); |
delete connection; |
return -1; |
} |
- int32 ipc_database_id = database_dispatcher_host_->map_.Add(connection); |
+ int32_t ipc_database_id = database_dispatcher_host_->map_.Add(connection); |
Context()->ConnectionOpened(origin_url, connection); |
database_dispatcher_host_->database_url_map_[ipc_database_id] = origin_url; |
return ipc_database_id; |
} |
-void IndexedDBDispatcherHost::RegisterTransactionId(int64 host_transaction_id, |
+void IndexedDBDispatcherHost::RegisterTransactionId(int64_t host_transaction_id, |
const GURL& url) { |
if (!database_dispatcher_host_) |
return; |
database_dispatcher_host_->transaction_url_map_[host_transaction_id] = url; |
} |
-int64 IndexedDBDispatcherHost::HostTransactionId(int64 transaction_id) { |
+int64_t IndexedDBDispatcherHost::HostTransactionId(int64_t transaction_id) { |
// Inject the renderer process id into the transaction id, to |
// uniquely identify this transaction, and effectively bind it to |
// the renderer that initiated it. The lower 32 bits of |
// transaction_id are guaranteed to be unique within that renderer. |
base::ProcessId pid = peer_pid(); |
DCHECK(!(transaction_id >> 32)) << "Transaction ids can only be 32 bits"; |
- static_assert(sizeof(base::ProcessId) <= sizeof(int32), |
+ static_assert(sizeof(base::ProcessId) <= sizeof(int32_t), |
"Process ID must fit in 32 bits"); |
- return transaction_id | (static_cast<uint64>(pid) << 32); |
+ return transaction_id | (static_cast<uint64_t>(pid) << 32); |
} |
-int64 IndexedDBDispatcherHost::RendererTransactionId( |
- int64 host_transaction_id) { |
+int64_t IndexedDBDispatcherHost::RendererTransactionId( |
+ int64_t host_transaction_id) { |
DCHECK(host_transaction_id >> 32 == peer_pid()) |
<< "Invalid renderer target for transaction id"; |
return host_transaction_id & 0xffffffff; |
} |
// static |
-uint32 IndexedDBDispatcherHost::TransactionIdToRendererTransactionId( |
- int64 host_transaction_id) { |
+uint32_t IndexedDBDispatcherHost::TransactionIdToRendererTransactionId( |
+ int64_t host_transaction_id) { |
return host_transaction_id & 0xffffffff; |
} |
// static |
-uint32 IndexedDBDispatcherHost::TransactionIdToProcessId( |
- int64 host_transaction_id) { |
+uint32_t IndexedDBDispatcherHost::TransactionIdToProcessId( |
+ int64_t host_transaction_id) { |
return (host_transaction_id >> 32) & 0xffffffff; |
} |
@@ -263,7 +265,8 @@ void IndexedDBDispatcherHost::DropBlobData(const std::string& uuid) { |
} |
} |
-IndexedDBCursor* IndexedDBDispatcherHost::GetCursorFromId(int32 ipc_cursor_id) { |
+IndexedDBCursor* IndexedDBDispatcherHost::GetCursorFromId( |
+ int32_t ipc_cursor_id) { |
DCHECK(indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
return cursor_dispatcher_host_->map_.Lookup(ipc_cursor_id); |
} |
@@ -328,7 +331,7 @@ void IndexedDBDispatcherHost::OnIDBFactoryOpen( |
GURL origin_url = |
storage::GetOriginFromIdentifier(params.database_identifier); |
- int64 host_transaction_id = HostTransactionId(params.transaction_id); |
+ int64_t host_transaction_id = HostTransactionId(params.transaction_id); |
// TODO(dgrogan): Don't let a non-existing database be opened (and therefore |
// created) if this origin is already over quota. |
@@ -384,7 +387,7 @@ void IndexedDBDispatcherHost::OnAckReceivedBlobs( |
DropBlobData(uuid); |
} |
-void IndexedDBDispatcherHost::FinishTransaction(int64 host_transaction_id, |
+void IndexedDBDispatcherHost::FinishTransaction(int64_t host_transaction_id, |
bool committed) { |
DCHECK(indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
if (!database_dispatcher_host_) |
@@ -409,7 +412,7 @@ void IndexedDBDispatcherHost::FinishTransaction(int64 host_transaction_id, |
template <typename ObjectType> |
ObjectType* IndexedDBDispatcherHost::GetOrTerminateProcess( |
IDMap<ObjectType, IDMapOwnPointer>* map, |
- int32 ipc_return_object_id) { |
+ int32_t ipc_return_object_id) { |
DCHECK(indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
ObjectType* return_object = map->Lookup(ipc_return_object_id); |
if (!return_object) { |
@@ -423,7 +426,7 @@ ObjectType* IndexedDBDispatcherHost::GetOrTerminateProcess( |
template <typename ObjectType> |
ObjectType* IndexedDBDispatcherHost::GetOrTerminateProcess( |
RefIDMap<ObjectType>* map, |
- int32 ipc_return_object_id) { |
+ int32_t ipc_return_object_id) { |
DCHECK(indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
ObjectType* return_object = map->Lookup(ipc_return_object_id); |
if (!return_object) { |
@@ -435,7 +438,8 @@ ObjectType* IndexedDBDispatcherHost::GetOrTerminateProcess( |
} |
template <typename MapType> |
-void IndexedDBDispatcherHost::DestroyObject(MapType* map, int32 ipc_object_id) { |
+void IndexedDBDispatcherHost::DestroyObject(MapType* map, |
+ int32_t ipc_object_id) { |
GetOrTerminateProcess(map, ipc_object_id); |
map->Remove(ipc_object_id); |
} |
@@ -465,8 +469,8 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::CloseAll() { |
for (TransactionIDToDatabaseIDMap::iterator iter = |
transaction_database_map_.begin(); |
iter != transaction_database_map_.end();) { |
- int64 transaction_id = iter->first; |
- int32 ipc_database_id = iter->second; |
+ int64_t transaction_id = iter->first; |
+ int32_t ipc_database_id = iter->second; |
++iter; |
IndexedDBConnection* connection = map_.Lookup(ipc_database_id); |
if (connection && connection->IsConnected()) { |
@@ -535,7 +539,8 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnCreateObjectStore( |
if (!connection || !connection->IsConnected()) |
return; |
- int64 host_transaction_id = parent_->HostTransactionId(params.transaction_id); |
+ int64_t host_transaction_id = |
+ parent_->HostTransactionId(params.transaction_id); |
connection->database()->CreateObjectStore(host_transaction_id, |
params.object_store_id, |
params.name, |
@@ -550,9 +555,9 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnCreateObjectStore( |
} |
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnDeleteObjectStore( |
- int32 ipc_database_id, |
- int64 transaction_id, |
- int64 object_store_id) { |
+ int32_t ipc_database_id, |
+ int64_t transaction_id, |
+ int64_t object_store_id) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
IndexedDBConnection* connection = |
@@ -573,7 +578,8 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnCreateTransaction( |
if (!connection || !connection->IsConnected()) |
return; |
- int64 host_transaction_id = parent_->HostTransactionId(params.transaction_id); |
+ int64_t host_transaction_id = |
+ parent_->HostTransactionId(params.transaction_id); |
if (transaction_database_map_.find(host_transaction_id) != |
transaction_database_map_.end()) { |
@@ -589,7 +595,7 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnCreateTransaction( |
} |
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnClose( |
- int32 ipc_database_id) { |
+ int32_t ipc_database_id) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
IndexedDBConnection* connection = |
@@ -600,7 +606,7 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnClose( |
} |
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnVersionChangeIgnored( |
- int32 ipc_database_id) { |
+ int32_t ipc_database_id) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
IndexedDBConnection* connection = |
@@ -611,7 +617,7 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnVersionChangeIgnored( |
} |
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnDestroyed( |
- int32 ipc_object_id) { |
+ int32_t ipc_object_id) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
IndexedDBConnection* connection = |
@@ -694,7 +700,8 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnPut( |
scoped_refptr<IndexedDBCallbacks> callbacks(new IndexedDBCallbacks( |
parent_, params.ipc_thread_id, params.ipc_callbacks_id)); |
- int64 host_transaction_id = parent_->HostTransactionId(params.transaction_id); |
+ int64_t host_transaction_id = |
+ parent_->HostTransactionId(params.transaction_id); |
std::vector<IndexedDBBlobInfo> blob_info( |
params.value.blob_or_file_info.size()); |
@@ -754,7 +761,8 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnSetIndexKeys( |
if (!connection || !connection->IsConnected()) |
return; |
- int64 host_transaction_id = parent_->HostTransactionId(params.transaction_id); |
+ int64_t host_transaction_id = |
+ parent_->HostTransactionId(params.transaction_id); |
connection->database()->SetIndexKeys( |
host_transaction_id, |
params.object_store_id, |
@@ -763,10 +771,10 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnSetIndexKeys( |
} |
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnSetIndexesReady( |
- int32 ipc_database_id, |
- int64 transaction_id, |
- int64 object_store_id, |
- const std::vector<int64>& index_ids) { |
+ int32_t ipc_database_id, |
+ int64_t transaction_id, |
+ int64_t object_store_id, |
+ const std::vector<int64_t>& index_ids) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
IndexedDBConnection* connection = |
@@ -838,11 +846,11 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnDeleteRange( |
} |
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnClear( |
- int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- int32 ipc_database_id, |
- int64 transaction_id, |
- int64 object_store_id) { |
+ int32_t ipc_thread_id, |
+ int32_t ipc_callbacks_id, |
+ int32_t ipc_database_id, |
+ int64_t transaction_id, |
+ int64_t object_store_id) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
IndexedDBConnection* connection = |
@@ -858,8 +866,8 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnClear( |
} |
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnAbort( |
- int32 ipc_database_id, |
- int64 transaction_id) { |
+ int32_t ipc_database_id, |
+ int64_t transaction_id) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
IndexedDBConnection* connection = |
@@ -871,8 +879,8 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnAbort( |
} |
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnCommit( |
- int32 ipc_database_id, |
- int64 transaction_id) { |
+ int32_t ipc_database_id, |
+ int64_t transaction_id) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
IndexedDBConnection* connection = |
@@ -880,8 +888,8 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnCommit( |
if (!connection || !connection->IsConnected()) |
return; |
- int64 host_transaction_id = parent_->HostTransactionId(transaction_id); |
- int64 transaction_size = transaction_size_map_[host_transaction_id]; |
+ int64_t host_transaction_id = parent_->HostTransactionId(transaction_id); |
+ int64_t transaction_size = transaction_size_map_[host_transaction_id]; |
if (transaction_size && |
parent_->Context()->WouldBeOverQuota( |
transaction_url_map_[host_transaction_id], transaction_size)) { |
@@ -903,7 +911,8 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnCreateIndex( |
if (!connection || !connection->IsConnected()) |
return; |
- int64 host_transaction_id = parent_->HostTransactionId(params.transaction_id); |
+ int64_t host_transaction_id = |
+ parent_->HostTransactionId(params.transaction_id); |
connection->database()->CreateIndex(host_transaction_id, |
params.object_store_id, |
params.index_id, |
@@ -920,10 +929,10 @@ void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnCreateIndex( |
} |
void IndexedDBDispatcherHost::DatabaseDispatcherHost::OnDeleteIndex( |
- int32 ipc_database_id, |
- int64 transaction_id, |
- int64 object_store_id, |
- int64 index_id) { |
+ int32_t ipc_database_id, |
+ int64_t transaction_id, |
+ int64_t object_store_id, |
+ int64_t index_id) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
IndexedDBConnection* connection = |
@@ -968,10 +977,10 @@ bool IndexedDBDispatcherHost::CursorDispatcherHost::OnMessageReceived( |
} |
void IndexedDBDispatcherHost::CursorDispatcherHost::OnAdvance( |
- int32 ipc_cursor_id, |
- int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
- uint32 count) { |
+ int32_t ipc_cursor_id, |
+ int32_t ipc_thread_id, |
+ int32_t ipc_callbacks_id, |
+ uint32_t count) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
IndexedDBCursor* idb_cursor = |
@@ -986,9 +995,9 @@ void IndexedDBDispatcherHost::CursorDispatcherHost::OnAdvance( |
} |
void IndexedDBDispatcherHost::CursorDispatcherHost::OnContinue( |
- int32 ipc_cursor_id, |
- int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
+ int32_t ipc_cursor_id, |
+ int32_t ipc_thread_id, |
+ int32_t ipc_callbacks_id, |
const IndexedDBKey& key, |
const IndexedDBKey& primary_key) { |
DCHECK( |
@@ -1008,9 +1017,9 @@ void IndexedDBDispatcherHost::CursorDispatcherHost::OnContinue( |
} |
void IndexedDBDispatcherHost::CursorDispatcherHost::OnPrefetch( |
- int32 ipc_cursor_id, |
- int32 ipc_thread_id, |
- int32 ipc_callbacks_id, |
+ int32_t ipc_cursor_id, |
+ int32_t ipc_thread_id, |
+ int32_t ipc_callbacks_id, |
int n) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
@@ -1026,7 +1035,7 @@ void IndexedDBDispatcherHost::CursorDispatcherHost::OnPrefetch( |
} |
void IndexedDBDispatcherHost::CursorDispatcherHost::OnPrefetchReset( |
- int32 ipc_cursor_id, |
+ int32_t ipc_cursor_id, |
int used_prefetches, |
int unused_prefetches) { |
DCHECK( |
@@ -1044,7 +1053,7 @@ void IndexedDBDispatcherHost::CursorDispatcherHost::OnPrefetchReset( |
} |
void IndexedDBDispatcherHost::CursorDispatcherHost::OnDestroyed( |
- int32 ipc_object_id) { |
+ int32_t ipc_object_id) { |
DCHECK( |
parent_->indexed_db_context_->TaskRunner()->RunsTasksOnCurrentThread()); |
parent_->DestroyObject(&map_, ipc_object_id); |