Struct IndexedDBManager 

struct IndexedDBManager {
    port: GenericReceiver<IndexedDBThreadMsg>,
    idb_base_dir: PathBuf,
    databases: HashMap<IndexedDBDescription, IndexedDBEnvironment<SqliteEngine>>,
    thread_pool: Arc<ThreadPool>,
    serial_number_counter: u64,
    connection_queues: HashMap<IndexedDBDescription, VecDeque<OpenRequest>>,
    connections: HashMap<IndexedDBDescription, HashSet<Connection>>,
}

Fields

port: GenericReceiver<IndexedDBThreadMsg>

idb_base_dir: PathBuf

databases: HashMap<IndexedDBDescription, IndexedDBEnvironment<SqliteEngine>>

thread_pool: Arc<ThreadPool>

serial_number_counter: u64

A global counter to produce unique transaction ids. TODO: remove once db connections lifecyle is managed. A global counter is only necessary because of how deleting a db currently does not wait for connection to close and transactions to finish.

connection_queues: HashMap<IndexedDBDescription, VecDeque<OpenRequest>>

https://w3c.github.io/IndexedDB/#connection-queue

connections: HashMap<IndexedDBDescription, HashSet<Connection>>

https://w3c.github.io/IndexedDB/#connection

Implementations

impl IndexedDBManager

fn new( port: GenericReceiver<IndexedDBThreadMsg>, idb_base_dir: PathBuf, ) -> IndexedDBManager

impl IndexedDBManager

fn start(&mut self)

fn handle_open_transaction_inactive( &mut self, name: String, origin: ImmutableOrigin, )

Handle when an open transaction becomes inactive.

fn advance_connection_queue(&mut self, key: IndexedDBDescription)

Run the next open request in the queue.

fn maybe_remove_front_from_queue(&mut self, key: &IndexedDBDescription) -> bool

Remove the record at the front if it is not pending.

fn abort_pending_upgrade( &mut self, name: String, id: Uuid, origin: ImmutableOrigin, )

Aborting the current upgrade for an origin. Note: this only reverts the version at this point.

fn abort_pending_upgrades( &mut self, pending_upgrades: HashMap<String, HashSet<Uuid>>, origin: ImmutableOrigin, )

Aborting all upgrades for an origin Note: this only reverts the version at this point.

fn open_a_database_connection( &mut self, sender: GenericCallback<BackendResult<OpenDatabaseResult>>, origin: ImmutableOrigin, db_name: String, version: Option<u64>, id: Uuid, )

https://w3c.github.io/IndexedDB/#open-a-database-connection

fn get_database( &self, origin: ImmutableOrigin, db_name: String, ) -> Option<&IndexedDBEnvironment<SqliteEngine>>

fn get_database_mut( &mut self, origin: ImmutableOrigin, db_name: String, ) -> Option<&mut IndexedDBEnvironment<SqliteEngine>>

fn upgrade_database( &mut self, idb_description: IndexedDBDescription, key: IndexedDBDescription, new_version: u64, )

https://w3c.github.io/IndexedDB/#upgrade-a-database To upgrade a database with connection (a connection), a new version, and a request, run these steps: TODO: connection and request.

fn open_database(&mut self, key: IndexedDBDescription)

https://w3c.github.io/IndexedDB/#open-a-database-connection The part where the open request is ready for processing.

fn start_delete_database( &mut self, key: IndexedDBDescription, id: Uuid, sender: GenericCallback<BackendResult<u64>>, )

https://www.w3.org/TR/IndexedDB/#delete-a-database The part adding the request to the connection queue.

fn delete_database(&mut self, key: IndexedDBDescription)

https://www.w3.org/TR/IndexedDB/#delete-a-database

fn handle_sync_operation(&mut self, operation: SyncOperation)