MCPcopy Create free account
hub / github.com/Restream/reindexer / OpenDatabase

Method OpenDatabase

cpp_src/server/rpcserver.cc:130–140  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

128}
129
130Error RPCServer::OpenDatabase(cproto::Context& ctx, p_string db, std::optional<bool> createDBIfMissing) {
131 auto* clientData = getClientDataSafe(ctx);
132 if (clientData->auth.HaveDB()) {
133 return Error(errParams, "Database already opened");
134 }
135 auto status = dbMgr_.OpenDatabase(db.toString(), clientData->auth, createDBIfMissing && *createDBIfMissing);
136 if (!status.ok()) {
137 clientData->auth.ResetDB();
138 }
139 return status;
140}
141
142Error RPCServer::CloseDatabase(cproto::Context& ctx) {
143 auto clientData = getClientDataSafe(ctx);

Callers 8

PostDatabaseMethod · 0.45
getDBMethod · 0.45
removeExpiredTxMethod · 0.45
getDBMethod · 0.45
CreateDatabaseMethod · 0.45
removeExpiredTxCbMethod · 0.45
get_reindexer_instanceFunction · 0.45
collectStatsMethod · 0.45

Calls 6

getClientDataSafeFunction · 0.85
HaveDBMethod · 0.80
okMethod · 0.80
ResetDBMethod · 0.80
ErrorClass · 0.50
toStringMethod · 0.45

Tested by

no test coverage detected