diff options
| author | Oran Agra <oran@redislabs.com> | 2019-08-19 12:18:25 +0300 |
|---|---|---|
| committer | Yossi Gottlieb <yossigo@gmail.com> | 2019-10-07 21:06:30 +0300 |
| commit | 6b6294807c0bca50041da117c1abb35f5114e972 (patch) | |
| tree | e13c13d22cab5b36d1ad70c73d4398d30dd6eb15 /src/cluster.c | |
| parent | 5a477946065bcf05b335ededd6b794e82882ab73 (diff) | |
| download | redis-6b6294807c0bca50041da117c1abb35f5114e972.tar.gz | |
TLS: Implement support for write barrier.
Diffstat (limited to 'src/cluster.c')
| -rw-r--r-- | src/cluster.c | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/cluster.c b/src/cluster.c index 639ab1ea7..1d922e87a 100644 --- a/src/cluster.c +++ b/src/cluster.c @@ -2277,7 +2277,7 @@ void clusterReadHandler(connection *conn) { * from event handlers that will do stuff with the same link later. */ void clusterSendMessage(clusterLink *link, unsigned char *msg, size_t msglen) { if (sdslen(link->sndbuf) == 0 && msglen != 0) - connSetWriteHandler(link->conn, clusterWriteHandler); /* TODO: Handle AE_BARRIER in conns */ + connSetWriteHandlerWithBarrier(link->conn, clusterWriteHandler, 1); link->sndbuf = sdscatlen(link->sndbuf, msg, msglen); |