MCPcopy Create free account
hub / github.com/Snapchat/KeyDB / postFunction

Method postFunction

src/server.cpp:5131–5138  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

5129}
5130
5131bool client::postFunction(std::function<void(client *)> fn, bool fLock) {
5132 this->casyncOpsPending++;
5133 return aePostFunction(g_pserver->rgthreadvar[this->iel].el, [this, fn]{
5134 std::lock_guard<decltype(this->lock)> lock(this->lock);
5135 fn(this);
5136 --casyncOpsPending;
5137 }, fLock) == AE_OK;
5138}
5139
5140std::vector<robj_sharedptr> clientArgs(client *c) {
5141 std::vector<robj_sharedptr> args;

Callers 4

rdbPipeReadHandlerFunction · 0.80
replicationCronFunction · 0.80

Calls 1

aePostFunctionFunction · 0.85

Tested by

no test coverage detected