IDBCursorBackend.cpp [plain text]
#include "config.h"
#include "IDBCursorBackend.h"
#if ENABLE(INDEXED_DATABASE)
#include "IDBCallbacks.h"
#include "IDBCursorBackendOperations.h"
#include "IDBDatabaseBackend.h"
#include "IDBDatabaseCallbacks.h"
#include "IDBDatabaseError.h"
#include "IDBDatabaseException.h"
#include "IDBKeyRange.h"
#include "IDBOperation.h"
#include "IDBServerConnection.h"
#include "Logging.h"
#include "SharedBuffer.h"
namespace WebCore {
IDBCursorBackend::IDBCursorBackend(int64_t cursorID, IndexedDB::CursorType cursorType, IDBDatabaseBackend::TaskType taskType, IDBTransactionBackend& transaction, int64_t objectStoreID)
: m_taskType(taskType)
, m_cursorType(cursorType)
, m_transaction(&transaction)
, m_objectStoreID(objectStoreID)
, m_cursorID(cursorID)
, m_savedCursorID(0)
, m_closed(false)
{
m_transaction->registerOpenCursor(this);
}
IDBCursorBackend::~IDBCursorBackend()
{
m_transaction->unregisterOpenCursor(this);
}
void IDBCursorBackend::continueFunction(PassRefPtr<IDBKey> key, PassRefPtr<IDBCallbacks> prpCallbacks, ExceptionCode&)
{
LOG(StorageAPI, "IDBCursorBackend::continue");
RefPtr<IDBCallbacks> callbacks = prpCallbacks;
m_transaction->scheduleTask(m_taskType, CursorIterationOperation::create(this, key, callbacks));
}
void IDBCursorBackend::advance(unsigned long count, PassRefPtr<IDBCallbacks> prpCallbacks, ExceptionCode&)
{
LOG(StorageAPI, "IDBCursorBackend::advance");
RefPtr<IDBCallbacks> callbacks = prpCallbacks;
m_transaction->scheduleTask(CursorAdvanceOperation::create(this, count, callbacks));
}
void IDBCursorBackend::deleteFunction(PassRefPtr<IDBCallbacks> prpCallbacks, ExceptionCode&)
{
LOG(StorageAPI, "IDBCursorBackend::delete");
ASSERT(m_transaction->mode() != IndexedDB::TransactionMode::ReadOnly);
RefPtr<IDBKeyRange> keyRange = IDBKeyRange::create(primaryKey());
m_transaction->database().deleteRange(m_transaction->id(), m_objectStoreID, keyRange.release(), prpCallbacks);
}
void IDBCursorBackend::close()
{
LOG(StorageAPI, "IDBCursorBackend::close");
clear();
m_closed = true;
m_savedCursorID = 0;
}
void IDBCursorBackend::updateCursorData(IDBKey* key, IDBKey* primaryKey, SharedBuffer* valueBuffer)
{
m_currentKey = key;
m_currentPrimaryKey = primaryKey;
m_currentValueBuffer = valueBuffer;
}
void IDBCursorBackend::clear()
{
m_cursorID = 0;
m_currentKey = nullptr;
m_currentPrimaryKey = nullptr;
m_currentValueBuffer = nullptr;
}
}
#endif // ENABLE(INDEXED_DATABASE)