| 1846 | } |
| 1847 | |
| 1848 | void aofClosePipes(void) { |
| 1849 | int fdAofAckPipe = g_pserver->aof_pipe_read_ack_from_child; |
| 1850 | int res = aePostFunction(g_pserver->el_alf_pip_read_ack_from_child, [fdAofAckPipe]{ |
| 1851 | aeDeleteFileEventAsync(serverTL->el,fdAofAckPipe,AE_READABLE); |
| 1852 | close (fdAofAckPipe); |
| 1853 | }); |
| 1854 | serverAssert(res == AE_OK); |
| 1855 | |
| 1856 | int fdAofWritePipe = g_pserver->aof_pipe_write_data_to_child; |
| 1857 | res = aePostFunction(g_pserver->rgthreadvar[IDX_EVENT_LOOP_MAIN].el, [fdAofWritePipe]{ |
| 1858 | aeDeleteFileEventAsync(serverTL->el,fdAofWritePipe,AE_WRITABLE); |
| 1859 | close(fdAofWritePipe); |
| 1860 | }); |
| 1861 | serverAssert(res == AE_OK); |
| 1862 | g_pserver->aof_pipe_write_data_to_child = -1; |
| 1863 | |
| 1864 | close(g_pserver->aof_pipe_read_data_from_parent); |
| 1865 | close(g_pserver->aof_pipe_write_ack_to_parent); |
| 1866 | close(g_pserver->aof_pipe_write_ack_to_child); |
| 1867 | close(g_pserver->aof_pipe_read_ack_from_parent); |
| 1868 | } |
| 1869 | |
| 1870 | /* ---------------------------------------------------------------------------- |
| 1871 | * AOF background rewrite |
no test coverage detected