MCPcopy Create free account
hub / github.com/apache/kvrocks / ScriptFlush

Method ScriptFlush

src/server/server.cc:1944–1951  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1942}
1943
1944Status Server::ScriptFlush() {
1945 auto cf = storage->GetCFHandle(ColumnFamilyID::Propagate);
1946 engine::Context ctx(storage);
1947 auto s = storage->FlushScripts(ctx, storage->DefaultWriteOptions(), cf);
1948 if (!s.ok()) return {Status::NotOK, s.ToString()};
1949 ScriptReset();
1950 return Status::OK();
1951}
1952
1953// Generally, we store data into RocksDB and just replicate WAL instead of propagating
1954// commands. But sometimes, we need to update inner states or do special operations

Callers 3

ExecuteMethod · 0.80
TestScriptingFunction · 0.80
TestScriptingMasterSlaveFunction · 0.80

Calls 3

GetCFHandleMethod · 0.80
FlushScriptsMethod · 0.80
ToStringMethod · 0.45

Tested by 2

TestScriptingFunction · 0.64
TestScriptingMasterSlaveFunction · 0.64