diff options
| author | Oran Agra <oran@redislabs.com> | 2019-07-16 11:00:34 +0300 |
|---|---|---|
| committer | antirez <antirez@gmail.com> | 2019-07-17 16:46:22 +0200 |
| commit | c56b4ddc6f216ff751f9e8e94d345eee30d9997c (patch) | |
| tree | b6e00dace3430e7caa3b8fcb31b831bfa5aca4b9 /src/stream.h | |
| parent | 241d18d954289fcccd98a1183cd0d161dbf7acb1 (diff) | |
| download | redis-c56b4ddc6f216ff751f9e8e94d345eee30d9997c.tar.gz | |
prevent diskless replica from terminating on short read
now that replica can read rdb directly from the socket, it should avoid exiting
on short read and instead try to re-sync.
this commit tries to have minimal effects on non-diskless rdb reading.
and includes a test that tries to trigger this scenario on various read cases.
Diffstat (limited to 'src/stream.h')
| -rw-r--r-- | src/stream.h | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/stream.h b/src/stream.h index ef08753b5..8ae90ce77 100644 --- a/src/stream.h +++ b/src/stream.h @@ -109,5 +109,6 @@ streamCG *streamCreateCG(stream *s, char *name, size_t namelen, streamID *id); streamNACK *streamCreateNACK(streamConsumer *consumer); void streamDecodeID(void *buf, streamID *id); int streamCompareID(streamID *a, streamID *b); +void streamFreeNACK(streamNACK *na); #endif |