OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2010 Google Inc. All rights reserved. | 2 * Copyright (C) 2010 Google Inc. All rights reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions | 5 * modification, are permitted provided that the following conditions |
6 * are met: | 6 * are met: |
7 * | 7 * |
8 * 1. Redistributions of source code must retain the above copyright | 8 * 1. Redistributions of source code must retain the above copyright |
9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
10 * 2. Redistributions in binary form must reproduce the above copyright | 10 * 2. Redistributions in binary form must reproduce the above copyright |
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
93 } | 93 } |
94 | 94 |
95 int64_t IDBDatabase::nextTransactionId() | 95 int64_t IDBDatabase::nextTransactionId() |
96 { | 96 { |
97 // Only keep a 32-bit counter to allow ports to use the other 32 | 97 // Only keep a 32-bit counter to allow ports to use the other 32 |
98 // bits of the id. | 98 // bits of the id. |
99 AtomicallyInitializedStatic(int, currentTransactionId = 0); | 99 AtomicallyInitializedStatic(int, currentTransactionId = 0); |
100 return atomicIncrement(¤tTransactionId); | 100 return atomicIncrement(¤tTransactionId); |
101 } | 101 } |
102 | 102 |
| 103 void IDBDatabase::ackReceivedBlobs(const Vector<blink::WebBlobInfo>* blobInfo) |
| 104 { |
| 105 ASSERT(blobInfo); |
| 106 if (!blobInfo->size() || !m_backend) |
| 107 return; |
| 108 Vector<blink::WebBlobInfo>::const_iterator iter; |
| 109 Vector<String> uuids; |
| 110 uuids.reserveCapacity(blobInfo->size()); |
| 111 for (iter = blobInfo->begin(); iter != blobInfo->end(); ++iter) |
| 112 uuids.append(iter->uuid()); |
| 113 m_backend->ackReceivedBlobs(uuids); |
| 114 } |
| 115 |
103 void IDBDatabase::indexCreated(int64_t objectStoreId, const IDBIndexMetadata& me
tadata) | 116 void IDBDatabase::indexCreated(int64_t objectStoreId, const IDBIndexMetadata& me
tadata) |
104 { | 117 { |
105 IDBDatabaseMetadata::ObjectStoreMap::iterator it = m_metadata.objectStores.f
ind(objectStoreId); | 118 IDBDatabaseMetadata::ObjectStoreMap::iterator it = m_metadata.objectStores.f
ind(objectStoreId); |
106 ASSERT_WITH_SECURITY_IMPLICATION(it != m_metadata.objectStores.end()); | 119 ASSERT_WITH_SECURITY_IMPLICATION(it != m_metadata.objectStores.end()); |
107 it->value.indexes.set(metadata.id, metadata); | 120 it->value.indexes.set(metadata.id, metadata); |
108 } | 121 } |
109 | 122 |
110 void IDBDatabase::indexDeleted(int64_t objectStoreId, int64_t indexId) | 123 void IDBDatabase::indexDeleted(int64_t objectStoreId, int64_t indexId) |
111 { | 124 { |
112 IDBDatabaseMetadata::ObjectStoreMap::iterator it = m_metadata.objectStores.f
ind(objectStoreId); | 125 IDBDatabaseMetadata::ObjectStoreMap::iterator it = m_metadata.objectStores.f
ind(objectStoreId); |
(...skipping 326 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
439 { | 452 { |
440 return EventTargetNames::IDBDatabase; | 453 return EventTargetNames::IDBDatabase; |
441 } | 454 } |
442 | 455 |
443 ExecutionContext* IDBDatabase::executionContext() const | 456 ExecutionContext* IDBDatabase::executionContext() const |
444 { | 457 { |
445 return ActiveDOMObject::executionContext(); | 458 return ActiveDOMObject::executionContext(); |
446 } | 459 } |
447 | 460 |
448 } // namespace WebCore | 461 } // namespace WebCore |
OLD | NEW |