| 3977 | } |
| 3978 | |
| 3979 | inline 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 | |
| 3987 | void flushReplBacklogToClients(); |
no test coverage detected