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

Function FCorrectThread

src/server.h:3979–3984  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

3977}
3978
3979inline int FCorrectThread(client *c)
3980{
3981 return (c->conn == nullptr)
3982 || (c->iel == IDX_EVENT_LOOP_MAIN && moduleGILAcquiredByModule())
3983 || (serverTL != NULL && (g_pserver->rgthreadvar[c->iel].el == serverTL->el));
3984}
3985#define AssertCorrectThread(c) serverAssert(FCorrectThread(c))
3986
3987void flushReplBacklogToClients();

Callers 15

pubsubPublishMessageFunction · 0.85
replicationFeedMonitorsFunction · 0.85
sendBulkToSlaveFunction · 0.85
disconnectMasterFunction · 0.85
asyncCommandMethod · 0.85
prepareClientToWriteFunction · 0.85
_addReplyToBufferFunction · 0.85
addReplyDeferredLenFunction · 0.85
setDeferredAggregateLenFunction · 0.85
writeToClientFunction · 0.85

Calls 1

Tested by

no test coverage detected