mirror of
https://github.com/mozilla/gecko-dev.git
synced 2024-11-01 06:35:42 +00:00
433 lines
12 KiB
C++
433 lines
12 KiB
C++
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this file,
|
|
* You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
#ifndef mozilla_dom_indexeddb_ipc_indexeddbchild_h__
|
|
#define mozilla_dom_indexeddb_ipc_indexeddbchild_h__
|
|
|
|
#include "mozilla/Attributes.h"
|
|
#include "mozilla/DebugOnly.h"
|
|
|
|
#include "mozilla/dom/indexedDB/IndexedDatabase.h"
|
|
|
|
#include "mozilla/dom/indexedDB/PIndexedDBChild.h"
|
|
#include "mozilla/dom/indexedDB/PIndexedDBCursorChild.h"
|
|
#include "mozilla/dom/indexedDB/PIndexedDBDatabaseChild.h"
|
|
#include "mozilla/dom/indexedDB/PIndexedDBDeleteDatabaseRequestChild.h"
|
|
#include "mozilla/dom/indexedDB/PIndexedDBIndexChild.h"
|
|
#include "mozilla/dom/indexedDB/PIndexedDBObjectStoreChild.h"
|
|
#include "mozilla/dom/indexedDB/PIndexedDBRequestChild.h"
|
|
#include "mozilla/dom/indexedDB/PIndexedDBTransactionChild.h"
|
|
|
|
class nsIAtom;
|
|
|
|
BEGIN_INDEXEDDB_NAMESPACE
|
|
|
|
class AsyncConnectionHelper;
|
|
class IDBCursor;
|
|
class IDBFactory;
|
|
class IDBIndex;
|
|
class IDBOpenDBRequest;
|
|
class IDBRequest;
|
|
class IDBTransactionListener;
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBChild
|
|
******************************************************************************/
|
|
|
|
class IndexedDBChild : public PIndexedDBChild
|
|
{
|
|
IDBFactory* mFactory;
|
|
nsCString mASCIIOrigin;
|
|
|
|
#ifdef DEBUG
|
|
bool mDisconnected;
|
|
#endif
|
|
|
|
public:
|
|
IndexedDBChild(const nsCString& aASCIIOrigin);
|
|
virtual ~IndexedDBChild();
|
|
|
|
const nsCString&
|
|
ASCIIOrigin() const
|
|
{
|
|
return mASCIIOrigin;
|
|
}
|
|
|
|
void
|
|
SetFactory(IDBFactory* aFactory);
|
|
|
|
void
|
|
Disconnect();
|
|
|
|
protected:
|
|
virtual void
|
|
ActorDestroy(ActorDestroyReason aWhy) MOZ_OVERRIDE;
|
|
|
|
virtual PIndexedDBDatabaseChild*
|
|
AllocPIndexedDBDatabase(const nsString& aName, const uint64_t& aVersion)
|
|
MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
DeallocPIndexedDBDatabase(PIndexedDBDatabaseChild* aActor) MOZ_OVERRIDE;
|
|
|
|
virtual PIndexedDBDeleteDatabaseRequestChild*
|
|
AllocPIndexedDBDeleteDatabaseRequest(const nsString& aName) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
DeallocPIndexedDBDeleteDatabaseRequest(
|
|
PIndexedDBDeleteDatabaseRequestChild* aActor)
|
|
MOZ_OVERRIDE;
|
|
};
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBDatabaseChild
|
|
******************************************************************************/
|
|
|
|
class IndexedDBDatabaseChild : public PIndexedDBDatabaseChild
|
|
{
|
|
IDBDatabase* mDatabase;
|
|
nsString mName;
|
|
uint64_t mVersion;
|
|
|
|
nsRefPtr<IDBOpenDBRequest> mRequest;
|
|
nsRefPtr<AsyncConnectionHelper> mOpenHelper;
|
|
|
|
// Only used during version change transactions and blocked events.
|
|
nsRefPtr<IDBDatabase> mStrongDatabase;
|
|
|
|
public:
|
|
IndexedDBDatabaseChild(const nsString& aName, uint64_t aVersion);
|
|
virtual ~IndexedDBDatabaseChild();
|
|
|
|
void
|
|
SetRequest(IDBOpenDBRequest* aRequest);
|
|
|
|
void
|
|
Disconnect();
|
|
|
|
protected:
|
|
bool
|
|
EnsureDatabase(IDBOpenDBRequest* aRequest,
|
|
const DatabaseInfoGuts& aDBInfo,
|
|
const InfallibleTArray<ObjectStoreInfoGuts>& aOSInfo);
|
|
|
|
virtual void
|
|
ActorDestroy(ActorDestroyReason aWhy) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
RecvSuccess(const DatabaseInfoGuts& aDBInfo,
|
|
const InfallibleTArray<ObjectStoreInfoGuts>& aOSInfo)
|
|
MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
RecvError(const nsresult& aRv) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
RecvBlocked(const uint64_t& aOldVersion) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
RecvVersionChange(const uint64_t& aOldVersion, const uint64_t& aNewVersion)
|
|
MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
RecvInvalidate() MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
RecvPIndexedDBTransactionConstructor(PIndexedDBTransactionChild* aActor,
|
|
const TransactionParams& aParams)
|
|
MOZ_OVERRIDE;
|
|
|
|
virtual PIndexedDBTransactionChild*
|
|
AllocPIndexedDBTransaction(const TransactionParams& aParams) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
DeallocPIndexedDBTransaction(PIndexedDBTransactionChild* aActor) MOZ_OVERRIDE;
|
|
};
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBTransactionChild
|
|
******************************************************************************/
|
|
|
|
class IndexedDBTransactionChild : public PIndexedDBTransactionChild
|
|
{
|
|
IDBTransaction* mTransaction;
|
|
|
|
nsRefPtr<IDBTransaction> mStrongTransaction;
|
|
nsRefPtr<IDBTransactionListener> mTransactionListener;
|
|
|
|
public:
|
|
IndexedDBTransactionChild();
|
|
virtual ~IndexedDBTransactionChild();
|
|
|
|
void
|
|
SetTransaction(IDBTransaction* aTransaction);
|
|
|
|
IDBTransaction*
|
|
GetTransaction() const
|
|
{
|
|
return mTransaction;
|
|
}
|
|
|
|
void
|
|
Disconnect();
|
|
|
|
protected:
|
|
void
|
|
FireCompleteEvent(nsresult aRv);
|
|
|
|
virtual void
|
|
ActorDestroy(ActorDestroyReason aWhy) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
RecvComplete(const CompleteParams& aParams) MOZ_OVERRIDE;
|
|
|
|
virtual PIndexedDBObjectStoreChild*
|
|
AllocPIndexedDBObjectStore(const ObjectStoreConstructorParams& aParams)
|
|
MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
DeallocPIndexedDBObjectStore(PIndexedDBObjectStoreChild* aActor) MOZ_OVERRIDE;
|
|
};
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBObjectStoreChild
|
|
******************************************************************************/
|
|
|
|
class IndexedDBObjectStoreChild : public PIndexedDBObjectStoreChild
|
|
{
|
|
IDBObjectStore* mObjectStore;
|
|
|
|
public:
|
|
IndexedDBObjectStoreChild(IDBObjectStore* aObjectStore);
|
|
virtual ~IndexedDBObjectStoreChild();
|
|
|
|
void
|
|
Disconnect();
|
|
|
|
protected:
|
|
virtual void
|
|
ActorDestroy(ActorDestroyReason aWhy) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
RecvPIndexedDBCursorConstructor(
|
|
PIndexedDBCursorChild* aActor,
|
|
const ObjectStoreCursorConstructorParams& aParams)
|
|
MOZ_OVERRIDE;
|
|
|
|
virtual PIndexedDBRequestChild*
|
|
AllocPIndexedDBRequest(const ObjectStoreRequestParams& aParams) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
DeallocPIndexedDBRequest(PIndexedDBRequestChild* aActor) MOZ_OVERRIDE;
|
|
|
|
virtual PIndexedDBIndexChild*
|
|
AllocPIndexedDBIndex(const IndexConstructorParams& aParams) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
DeallocPIndexedDBIndex(PIndexedDBIndexChild* aActor) MOZ_OVERRIDE;
|
|
|
|
virtual PIndexedDBCursorChild*
|
|
AllocPIndexedDBCursor(const ObjectStoreCursorConstructorParams& aParams)
|
|
MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
DeallocPIndexedDBCursor(PIndexedDBCursorChild* aActor) MOZ_OVERRIDE;
|
|
};
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBIndexChild
|
|
******************************************************************************/
|
|
|
|
class IndexedDBIndexChild : public PIndexedDBIndexChild
|
|
{
|
|
IDBIndex* mIndex;
|
|
|
|
public:
|
|
IndexedDBIndexChild(IDBIndex* aIndex);
|
|
virtual ~IndexedDBIndexChild();
|
|
|
|
void
|
|
Disconnect();
|
|
|
|
protected:
|
|
virtual void
|
|
ActorDestroy(ActorDestroyReason aWhy) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
RecvPIndexedDBCursorConstructor(PIndexedDBCursorChild* aActor,
|
|
const IndexCursorConstructorParams& aParams)
|
|
MOZ_OVERRIDE;
|
|
|
|
virtual PIndexedDBRequestChild*
|
|
AllocPIndexedDBRequest(const IndexRequestParams& aParams) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
DeallocPIndexedDBRequest(PIndexedDBRequestChild* aActor) MOZ_OVERRIDE;
|
|
|
|
virtual PIndexedDBCursorChild*
|
|
AllocPIndexedDBCursor(const IndexCursorConstructorParams& aParams)
|
|
MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
DeallocPIndexedDBCursor(PIndexedDBCursorChild* aActor) MOZ_OVERRIDE;
|
|
};
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBCursorChild
|
|
******************************************************************************/
|
|
|
|
class IndexedDBCursorChild : public PIndexedDBCursorChild
|
|
{
|
|
IDBCursor* mCursor;
|
|
|
|
nsRefPtr<IDBCursor> mStrongCursor;
|
|
|
|
public:
|
|
IndexedDBCursorChild();
|
|
virtual ~IndexedDBCursorChild();
|
|
|
|
void
|
|
SetCursor(IDBCursor* aCursor);
|
|
|
|
already_AddRefed<IDBCursor>
|
|
ForgetStrongCursor()
|
|
{
|
|
return mStrongCursor.forget();
|
|
}
|
|
|
|
void
|
|
Disconnect();
|
|
|
|
protected:
|
|
virtual void
|
|
ActorDestroy(ActorDestroyReason aWhy) MOZ_OVERRIDE;
|
|
|
|
virtual PIndexedDBRequestChild*
|
|
AllocPIndexedDBRequest(const CursorRequestParams& aParams) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
DeallocPIndexedDBRequest(PIndexedDBRequestChild* aActor) MOZ_OVERRIDE;
|
|
};
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBRequestChildBase
|
|
******************************************************************************/
|
|
|
|
class IndexedDBRequestChildBase : public PIndexedDBRequestChild
|
|
{
|
|
protected:
|
|
nsRefPtr<AsyncConnectionHelper> mHelper;
|
|
|
|
public:
|
|
IDBRequest*
|
|
GetRequest() const;
|
|
|
|
void
|
|
Disconnect();
|
|
|
|
protected:
|
|
IndexedDBRequestChildBase(AsyncConnectionHelper* aHelper);
|
|
virtual ~IndexedDBRequestChildBase();
|
|
|
|
virtual bool
|
|
Recv__delete__(const ResponseValue& aResponse) MOZ_OVERRIDE;
|
|
};
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBObjectStoreRequestChild
|
|
******************************************************************************/
|
|
|
|
class IndexedDBObjectStoreRequestChild : public IndexedDBRequestChildBase
|
|
{
|
|
nsRefPtr<IDBObjectStore> mObjectStore;
|
|
|
|
typedef ipc::ObjectStoreRequestParams ParamsUnionType;
|
|
typedef ParamsUnionType::Type RequestType;
|
|
DebugOnly<RequestType> mRequestType;
|
|
|
|
public:
|
|
IndexedDBObjectStoreRequestChild(AsyncConnectionHelper* aHelper,
|
|
IDBObjectStore* aObjectStore,
|
|
RequestType aRequestType);
|
|
virtual ~IndexedDBObjectStoreRequestChild();
|
|
|
|
protected:
|
|
virtual bool
|
|
Recv__delete__(const ResponseValue& aResponse) MOZ_OVERRIDE;
|
|
};
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBIndexRequestChild
|
|
******************************************************************************/
|
|
|
|
class IndexedDBIndexRequestChild : public IndexedDBRequestChildBase
|
|
{
|
|
nsRefPtr<IDBIndex> mIndex;
|
|
|
|
typedef ipc::IndexRequestParams ParamsUnionType;
|
|
typedef ParamsUnionType::Type RequestType;
|
|
DebugOnly<RequestType> mRequestType;
|
|
|
|
public:
|
|
IndexedDBIndexRequestChild(AsyncConnectionHelper* aHelper, IDBIndex* aIndex,
|
|
RequestType aRequestType);
|
|
virtual ~IndexedDBIndexRequestChild();
|
|
|
|
protected:
|
|
virtual bool
|
|
Recv__delete__(const ResponseValue& aResponse) MOZ_OVERRIDE;
|
|
};
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBCursorRequestChild
|
|
******************************************************************************/
|
|
|
|
class IndexedDBCursorRequestChild : public IndexedDBRequestChildBase
|
|
{
|
|
nsRefPtr<IDBCursor> mCursor;
|
|
|
|
typedef ipc::CursorRequestParams ParamsUnionType;
|
|
typedef ParamsUnionType::Type RequestType;
|
|
DebugOnly<RequestType> mRequestType;
|
|
|
|
public:
|
|
IndexedDBCursorRequestChild(AsyncConnectionHelper* aHelper,
|
|
IDBCursor* aCursor,
|
|
RequestType aRequestType);
|
|
virtual ~IndexedDBCursorRequestChild();
|
|
|
|
protected:
|
|
virtual bool
|
|
Recv__delete__(const ResponseValue& aResponse) MOZ_OVERRIDE;
|
|
};
|
|
|
|
/*******************************************************************************
|
|
* IndexedDBDeleteDatabaseRequestChild
|
|
******************************************************************************/
|
|
|
|
class IndexedDBDeleteDatabaseRequestChild :
|
|
public PIndexedDBDeleteDatabaseRequestChild
|
|
{
|
|
nsRefPtr<IDBFactory> mFactory;
|
|
nsRefPtr<IDBOpenDBRequest> mOpenRequest;
|
|
nsCOMPtr<nsIAtom> mDatabaseId;
|
|
|
|
public:
|
|
IndexedDBDeleteDatabaseRequestChild(IDBFactory* aFactory,
|
|
IDBOpenDBRequest* aOpenRequest,
|
|
nsIAtom* aDatabaseId);
|
|
virtual ~IndexedDBDeleteDatabaseRequestChild();
|
|
|
|
protected:
|
|
virtual bool
|
|
Recv__delete__(const nsresult& aRv) MOZ_OVERRIDE;
|
|
|
|
virtual bool
|
|
RecvBlocked(const uint64_t& aCurrentVersion) MOZ_OVERRIDE;
|
|
};
|
|
|
|
END_INDEXEDDB_NAMESPACE
|
|
|
|
#endif // mozilla_dom_indexeddb_ipc_indexeddbchild_h__
|