1/* 2 * Copyright (C) 2010 Google Inc. All rights reserved. 3 * Copyright (C) 2013 Apple Inc. All rights reserved. 4 * 5 * Redistribution and use in source and binary forms, with or without 6 * modification, are permitted provided that the following conditions 7 * are met: 8 * 9 * 1. Redistributions of source code must retain the above copyright 10 * notice, this list of conditions and the following disclaimer. 11 * 2. Redistributions in binary form must reproduce the above copyright 12 * notice, this list of conditions and the following disclaimer in the 13 * documentation and/or other materials provided with the distribution. 14 * 15 * THIS SOFTWARE IS PROVIDED BY APPLE AND ITS CONTRIBUTORS "AS IS" AND ANY 16 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED 17 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 18 * DISCLAIMED. IN NO EVENT SHALL APPLE OR ITS CONTRIBUTORS BE LIABLE FOR ANY 19 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES 20 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; 21 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND 22 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 23 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF 24 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 25 */ 26 27#include "config.h" 28#include "IDBCursorBackendOperations.h" 29 30#include "IDBServerConnection.h" 31 32#if ENABLE(INDEXED_DATABASE) 33 34#include "Logging.h" 35 36namespace WebCore { 37 38void CursorAdvanceOperation::perform(std::function<void()> completionCallback) 39{ 40 LOG(StorageAPI, "CursorAdvanceOperation"); 41 42 RefPtr<CursorAdvanceOperation> operation(this); 43 auto callback = [this, operation, completionCallback](PassRefPtr<IDBKey> key, PassRefPtr<IDBKey> primaryKey, PassRefPtr<SharedBuffer> valueBuffer, PassRefPtr<IDBDatabaseError> error) { 44 if (error) { 45 m_cursor->clear(); 46 m_callbacks->onError(error); 47 } else if (!key) { 48 // If there's no error but also no key, then the cursor reached the end. 49 m_cursor->clear(); 50 m_callbacks->onSuccess(static_cast<SharedBuffer*>(0)); 51 } else { 52 m_cursor->updateCursorData(key.get(), primaryKey.get(), valueBuffer.get()); 53 m_callbacks->onSuccess(key, primaryKey, valueBuffer); 54 } 55 56 // FIXME: Cursor operations should be able to pass along an error instead of success 57 completionCallback(); 58 }; 59 60 m_cursor->transaction().database().serverConnection().cursorAdvance(*m_cursor, *this, callback); 61} 62 63void CursorIterationOperation::perform(std::function<void()> completionCallback) 64{ 65 LOG(StorageAPI, "CursorIterationOperation"); 66 67 RefPtr<CursorIterationOperation> operation(this); 68 auto callback = [this, operation, completionCallback](PassRefPtr<IDBKey> key, PassRefPtr<IDBKey> primaryKey, PassRefPtr<SharedBuffer> valueBuffer, PassRefPtr<IDBDatabaseError> error) { 69 if (error) { 70 m_cursor->clear(); 71 m_callbacks->onError(error); 72 } else if (!key) { 73 // If there's no error but also no key, then the cursor reached the end. 74 m_cursor->clear(); 75 m_callbacks->onSuccess(static_cast<SharedBuffer*>(0)); 76 } else { 77 m_cursor->updateCursorData(key.get(), primaryKey.get(), valueBuffer.get()); 78 m_callbacks->onSuccess(key, primaryKey, valueBuffer); 79 } 80 81 // FIXME: Cursor operations should be able to pass along an error instead of success 82 completionCallback(); 83 }; 84 85 m_cursor->transaction().database().serverConnection().cursorIterate(*m_cursor, *this, callback); 86} 87 88} // namespace WebCore 89 90#endif // ENABLED(INDEXED_DATABASE) 91