diff options
author | Salvatore Sanfilippo <antirez@gmail.com> | 2020-02-06 10:30:39 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-02-06 10:30:39 +0100 |
commit | 5558c0e4cf85a1745c7d574fd6c7adadddb1adac (patch) | |
tree | f06cc21bbe83dfca4239f4a5485ec238c5921a4b | |
parent | 7cf53252eedd0251aeb66be8513a3a7f1fd4b30d (diff) | |
parent | 485d5d4a18441feff626e61e31e480c3054fe877 (diff) | |
download | redis-5558c0e4cf85a1745c7d574fd6c7adadddb1adac.tar.gz |
Merge pull request #6848 from oranagra/opt_use_diskless_load_calls
reduce repeated calls to use_diskless_load
-rw-r--r-- | src/replication.c | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/replication.c b/src/replication.c index 5499ebc57..a006d0ad1 100644 --- a/src/replication.c +++ b/src/replication.c @@ -1354,7 +1354,7 @@ void disklessLoadRestoreBackups(redisDb *backup, int restore, int empty_db_flags void readSyncBulkPayload(connection *conn) { char buf[4096]; ssize_t nread, readlen, nwritten; - int use_diskless_load; + int use_diskless_load = useDisklessLoad(); redisDb *diskless_load_backup = NULL; int empty_db_flags = server.repl_slave_lazy_flush ? EMPTYDB_ASYNC : EMPTYDB_NO_FLAGS; @@ -1411,19 +1411,18 @@ void readSyncBulkPayload(connection *conn) { server.repl_transfer_size = 0; serverLog(LL_NOTICE, "MASTER <-> REPLICA sync: receiving streamed RDB from master with EOF %s", - useDisklessLoad()? "to parser":"to disk"); + use_diskless_load? "to parser":"to disk"); } else { usemark = 0; server.repl_transfer_size = strtol(buf+1,NULL,10); serverLog(LL_NOTICE, "MASTER <-> REPLICA sync: receiving %lld bytes from master %s", (long long) server.repl_transfer_size, - useDisklessLoad()? "to parser":"to disk"); + use_diskless_load? "to parser":"to disk"); } return; } - use_diskless_load = useDisklessLoad(); if (!use_diskless_load) { /* Read the data from the socket, store it to a file and search * for the EOF. */ |