Lines Matching refs:request
195 // Someone else has already shutdown this database, so we can't request a delete.
233 // If this is the first unanswered metadata request, then later we need to
237 // Then remember this metadata request to be answered later.
238 RefPtr<AsyncRequest> request = AsyncRequestImpl<>::create([completionCallback, this]() {
247 m_pendingMetadataRequests.append(request.release());
280 RefPtr<AsyncRequest> request = m_pendingMetadataRequests.takeFirst();
281 request->completeRequest();
327 RefPtr<AsyncRequest> request = AsyncRequestImpl<bool>::create([successCallback](bool success) {
333 m_pendingTransactionRequests.add(transactionIdentifier, request.release());
340 RefPtr<AsyncRequest> request = m_pendingTransactionRequests.take(transactionIdentifier);
342 if (request)
343 request->completeRequest(success);
361 RefPtr<AsyncRequest> request = AsyncRequestImpl<bool>::create([this, oldVersion, successCallback](bool success) {
370 uint64_t requestID = request->requestID();
371 m_pendingDatabaseTasks.add(requestID, request.release());
408 RefPtr<AsyncRequest> request = m_pendingDatabaseTasks.take(requestID);
409 ASSERT(request);
411 request->completeRequest(success);
427 RefPtr<AsyncRequest> request = AsyncRequestImpl<bool>::create([this, addedObjectStoreID, successCallback](bool success) {
436 uint64_t requestID = request->requestID();
437 m_pendingDatabaseTasks.add(requestID, request.release());
454 RefPtr<AsyncRequest> request = AsyncRequestImpl<bool>::create([this, metadata, successCallback](bool success) {
463 uint64_t requestID = request->requestID();
464 m_pendingDatabaseTasks.add(requestID, request.release());
480 RefPtr<AsyncRequest> request = AsyncRequestImpl<bool>::create([this, successCallback](bool success) {
486 uint64_t requestID = request->requestID();
487 m_pendingDatabaseTasks.add(requestID, request.release());
506 RefPtr<AsyncRequest> request = AsyncRequestImpl<bool>::create([this, objectStoreID, addedIndexID, successCallback](bool success) {
520 uint64_t requestID = request->requestID();
521 m_pendingDatabaseTasks.add(requestID, request.release());
540 RefPtr<AsyncRequest> request = AsyncRequestImpl<bool>::create([this, objectStoreID, metadata, successCallback](bool success) {
554 uint64_t requestID = request->requestID();
555 m_pendingDatabaseTasks.add(requestID, request.release());
571 RefPtr<AsyncRequest> request = AsyncRequestImpl<const IDBKeyData&, uint32_t, const String&>::create([this, callback](const IDBKeyData& keyData, uint32_t errorCode, const String& errorMessage) {
577 uint64_t requestID = request->requestID();
578 m_pendingDatabaseTasks.add(requestID, request.release());
594 RefPtr<AsyncRequest> request = AsyncRequestImpl<const IDBGetResult&, uint32_t, const String&>::create([this, callback](const IDBGetResult& result, uint32_t errorCode, const String& errorMessage) {
600 uint64_t requestID = request->requestID();
601 m_pendingDatabaseTasks.add(requestID, request.release());
617 RefPtr<AsyncRequest> request = AsyncRequestImpl<int64_t, const IDBKeyData&, const IDBKeyData&, PassRefPtr<SharedBuffer>, uint32_t, const String&>::create([this, callback](int64_t cursorID, const IDBKeyData& key, const IDBKeyData& primaryKey, PassRefPtr<SharedBuffer> value, uint32_t errorCode, const String& errorMessage) {
623 uint64_t requestID = request->requestID();
624 m_pendingDatabaseTasks.add(requestID, request.release());
638 RefPtr<AsyncRequest> request = AsyncRequestImpl<const IDBKeyData&, const IDBKeyData&, PassRefPtr<SharedBuffer>, uint32_t, const String&>::create([this, callback](const IDBKeyData& key, const IDBKeyData& primaryKey, PassRefPtr<SharedBuffer> value, uint32_t errorCode, const String& errorMessage) {
644 uint64_t requestID = request->requestID();
645 m_pendingDatabaseTasks.add(requestID, request.release());
659 RefPtr<AsyncRequest> request = AsyncRequestImpl<const IDBKeyData&, const IDBKeyData&, PassRefPtr<SharedBuffer>, uint32_t, const String&>::create([this, callback](const IDBKeyData& key, const IDBKeyData& primaryKey, PassRefPtr<SharedBuffer> value, uint32_t errorCode, const String& errorMessage) {
665 uint64_t requestID = request->requestID();
666 m_pendingDatabaseTasks.add(requestID, request.release());
680 RefPtr<AsyncRequest> request = AsyncRequestImpl<int64_t, uint32_t, const String&>::create([this, callback](int64_t count, uint32_t errorCode, const String& errorMessage) {
686 uint64_t requestID = request->requestID();
687 m_pendingDatabaseTasks.add(requestID, request.release());
701 RefPtr<AsyncRequest> request = AsyncRequestImpl<uint32_t, const String&>::create([callback](uint32_t errorCode, const String& errorMessage) {
707 uint64_t requestID = request->requestID();
708 m_pendingDatabaseTasks.add(requestID, request.release());
892 RefPtr<AsyncRequest> request = m_pendingDatabaseTasks.take(requestID);
893 ASSERT(request);
895 request->completeRequest(keyData, errorCode, errorMessage);
953 RefPtr<AsyncRequest> request = m_pendingDatabaseTasks.take(requestID);
954 ASSERT(request);
956 request->completeRequest(result, errorCode, errorMessage);
982 RefPtr<AsyncRequest> request = m_pendingDatabaseTasks.take(requestID);
983 ASSERT(request);
985 request->completeRequest(cursorID, key, primaryKey, SharedBuffer::create(valueBuffer.data(), valueBuffer.size()), errorCode, errorMessage);
1007 RefPtr<AsyncRequest> request = m_pendingDatabaseTasks.take(requestID);
1008 ASSERT(request);
1010 request->completeRequest(key, primaryKey, SharedBuffer::create(valueBuffer.data(), valueBuffer.size()), errorCode, errorMessage);
1032 RefPtr<AsyncRequest> request = m_pendingDatabaseTasks.take(requestID);
1033 ASSERT(request);
1035 request->completeRequest(key, primaryKey, SharedBuffer::create(valueBuffer.data(), valueBuffer.size()), errorCode, errorMessage);
1052 RefPtr<AsyncRequest> request = m_pendingDatabaseTasks.take(requestID);
1053 ASSERT(request);
1055 request->completeRequest(count, errorCode, errorMessage);
1072 RefPtr<AsyncRequest> request = m_pendingDatabaseTasks.take(requestID);
1073 ASSERT(request);
1075 request->completeRequest(errorCode, errorMessage);