| 125 | } |
| 126 | |
| 127 | void installAofRewriteEvent() |
| 128 | { |
| 129 | serverTL->fRetrySetAofEvent = false; |
| 130 | if (!g_pserver->aof_rewrite_pending) { |
| 131 | g_pserver->aof_rewrite_pending = true; |
| 132 | int res = aePostFunction(g_pserver->rgthreadvar[IDX_EVENT_LOOP_MAIN].el, [] { |
| 133 | g_pserver->aof_rewrite_pending = false; |
| 134 | if (!g_pserver->aof_stop_sending_diff && g_pserver->aof_pipe_write_data_to_child >= 0) |
| 135 | aeCreateFileEvent(g_pserver->rgthreadvar[IDX_EVENT_LOOP_MAIN].el, g_pserver->aof_pipe_write_data_to_child, AE_WRITABLE, aofChildWriteDiffData, NULL); |
| 136 | }); |
| 137 | if (res != AE_OK) |
| 138 | serverTL->fRetrySetAofEvent = true; |
| 139 | } |
| 140 | } |
| 141 | |
| 142 | /* Append data to the AOF rewrite buffer, allocating new blocks if needed. */ |
| 143 | void aofRewriteBufferAppend(unsigned char *s, unsigned long len) { |
no test coverage detected