arachne::coordination::operational_ledger::implementation Struct Reference

Public Member Functions
	implementation (const std::filesystem::path &path)
	implementation (const std::filesystem::path &path)

Public Attributes
sqlite_handle	database

Detailed Description

Definition at line 394 of file coordinator.cpp.

Constructor & Destructor Documentation

implementation() [1/2]

arachne::coordination::operational_ledger::implementation::implementation ( const std::filesystem::path & path )

inlineexplicit

Definition at line 395 of file coordinator.cpp.

        : database(nullptr, sqlite3_close) {
        sqlite3* raw = nullptr;
        if (sqlite3_open_v2(
                path.string().c_str(), &raw,
                SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE
                    | SQLITE_OPEN_FULLMUTEX,
                nullptr
            )
            != SQLITE_OK) {
            const std::string message = raw != nullptr
                ? sqlite3_errmsg(raw)
                : "cannot open operational ledger";
            if (raw != nullptr) {
                sqlite3_close(raw);
            }
            throw std::runtime_error(message);
        }
        database.reset(raw);
        if (sqlite3_busy_timeout(database.get(), 5000) != SQLITE_OK) {
            throw_sqlite(
                database.get(), "configure operational-ledger timeout"
            );
        }
        execute(database.get(), "PRAGMA foreign_keys = ON;");
        execute(database.get(), "PRAGMA journal_mode = WAL;");
        execute(database.get(), "PRAGMA synchronous = NORMAL;");
        execute(database.get(), R"SQL(
CREATE TABLE IF NOT EXISTS envelopes (

References implementation().

Referenced by implementation().

Here is the call graph for this function:

Here is the caller graph for this function:

implementation() [2/2]

arachne::coordination::operational_ledger::implementation::implementation ( const std::filesystem::path & path )

inlineexplicit

Definition at line 395 of file coordinator.cpp.

        : database(nullptr, sqlite3_close) {
        sqlite3* raw = nullptr;
        if (sqlite3_open_v2(
                path.string().c_str(), &raw,
                SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE
                    | SQLITE_OPEN_FULLMUTEX,
                nullptr
            )
            != SQLITE_OK) {
            const std::string message = raw != nullptr
                ? sqlite3_errmsg(raw)
                : "cannot open operational ledger";
            if (raw != nullptr) {
                sqlite3_close(raw);
            }
            throw std::runtime_error(message);
        }
        database.reset(raw);
        if (sqlite3_busy_timeout(database.get(), 5000) != SQLITE_OK) {
            throw_sqlite(
                database.get(), "configure operational-ledger timeout"
            );
        }
        execute(database.get(), "PRAGMA foreign_keys = ON;");
        execute(database.get(), "PRAGMA journal_mode = WAL;");
        execute(database.get(), "PRAGMA synchronous = NORMAL;");
        execute(database.get(), R"SQL(
CREATE TABLE IF NOT EXISTS envelopes (

Member Data Documentation

database

sqlite_handle arachne::coordination::operational_ledger::implementation::database

Definition at line 425 of file coordinator.cpp.

---

The documentation for this struct was generated from the following file:

• coordinator.cpp