diff options
author | antirez <antirez@gmail.com> | 2018-02-27 10:40:40 +0100 |
---|---|---|
committer | antirez <antirez@gmail.com> | 2018-02-27 10:40:40 +0100 |
commit | ec6484d7309e658fb5490c23aac55e00f235e63b (patch) | |
tree | fc384489f58df26a4683c7d83306c4bd4ffe84cb | |
parent | 2b974404c0c9c92963c69be06cdd3411445931c6 (diff) | |
download | redis-ec6484d7309e658fb5490c23aac55e00f235e63b.tar.gz |
AOF: fix a bug that may prevent proper fsyncing when fsync=always.
In case the write handler is already installed, it could happen that we
serve the reply of a query in the same event loop cycle we received it,
preventing beforeSleep() from guaranteeing that we do the AOF fsync
before sending the reply to the client.
The AE_BARRIER mechanism, introduced in a previous commit, prevents this
problem. This commit makes actual use of this new feature to fix the
bug.
-rw-r--r-- | src/networking.c | 24 |
1 files changed, 18 insertions, 6 deletions
diff --git a/src/networking.c b/src/networking.c index faa6d664b..ed70e7786 100644 --- a/src/networking.c +++ b/src/networking.c @@ -1044,13 +1044,25 @@ int handleClientsWithPendingWrites(void) { /* Try to write buffers to the client socket. */ if (writeToClient(c->fd,c,0) == C_ERR) continue; - /* If there is nothing left, do nothing. Otherwise install - * the write handler. */ - if (clientHasPendingReplies(c) && - aeCreateFileEvent(server.el, c->fd, AE_WRITABLE, + /* If after the synchronous writes above we still have data to + * output to the client, we need to install the writable handler. */ + if (clientHasPendingReplies(c)) { + int ae_flags = AE_WRITABLE; + /* For the fsync=always policy, we want that a given FD is never + * served for reading and writing in the same event loop iteration, + * so that in the middle of receiving the query, and serving it + * to the client, we'll call beforeSleep() that will do the + * actual fsync of AOF to disk. AE_BARRIER ensures that. */ + if (server.aof_state == AOF_ON && + server.aof_fsync == AOF_FSYNC_ALWAYS) + { + ae_flags |= AE_BARRIER; + } + if (aeCreateFileEvent(server.el, c->fd, AE_WRITABLE, sendReplyToClient, c) == AE_ERR) - { - freeClientAsync(c); + { + freeClientAsync(c); + } } } return processed; |