Redis 7.0 Multi Part AOF的设计和实现

Posted 2022-02-12 阿里技术

25 2022 09* 681725 2022 09* 25 2022 09* 25 2022 09* 213525 2022 09* *s, len) * not one already. */ (!server.aof_stop_sending_diff && aeGetFileEvents(server.el,server.aof_pipe_write_data_to_child) == aeCreateFileEvent(server.el, server.aof_pipe_write_data_to_child, AE_WRITABLE, aofChildWriteDiffData, *filename) * We can\'t read forever (the server may receive data from clients * faster than it is able to send data to the child), so we try to read * some more data in a loop as soon as there is a good chance more data * will come. If it looks like we are wasting time, we abort (this * happens after 20 ms without new data). */ nodata = start = mstime(); && nodata < (aeWait(server.aof_pipe_read_data_from_parent, AE_READABLE, nodata++; nodata = timeouts. */ aofReadDiffFromParent(); exitcode, bysignal) (aofRewriteBufferWrite(newfd) == serverLog(LL_WARNING, close(newfd); cleanup; aof_pipe_write_data_to_child;aof_pipe_read_data_from_parent;aof_pipe_write_ack_to_parent;aof_pipe_read_ack_from_child;aof_pipe_write_ack_to_child;aof_pipe_read_ack_from_parent;

sds file_name; file_seq; aof_file_type file_type; aofInfo *base_aof_info; *incr_aof_list; *history_aof_list; `base_aof_info` and `incr_aof_list` will be moved to this list. We will delete these AOF files when AOFRW finish. */ curr_base_file_seq; curr_incr_file_seq; dirty; disk, we need to persist it immediately. */ aofManifest *aof_manifest; 1 1 2 1 1 2 BASE_FILE_SUFFIX INCR_FILE_SUFFIX RDB_FORMAT_SUFFIX AOF_FORMAT_SUFFIX MANIFEST_NAME_SUFFIX * from an old redis version. We will use enter upgrade mode in three situations. * * 1. If the \'server.aof_dirname\' directory not exist * 2. If the \'server.aof_dirname\' directory exists but the manifest file is missing * 3. If the \'server.aof_dirname\' directory exists and the manifest file it contains * has only one base AOF record, and the file name of this base AOF is \'server.aof_filename\', * and the \'server.aof_filename\' file not exist in \'server.aof_dirname\' directory * */ (fileExist(server.aof_filename)) (!dirExists(server.aof_dirname) || (am->base_aof_info == && listLength(am->incr_aof_list) == (am->base_aof_info != && listLength(am->incr_aof_list) == && !strcmp(am->base_aof_info->file_name, server.aof_filename) && !aofFileExist(server.aof_filename))) aofUpgradePrepare(am);