Open lwaly opened 3 years ago
I'm getting the following "moved" error when i send write command。i change uvMapRequest function to repair it # see diff: src/dep/rmr/rmr.c | 6 ++++++ 1 file changed, 6 insertions(+)
diff --git a/src/dep/rmr/rmr.c b/src/dep/rmr/rmr.c index 8fff8f9..76ea653 100644 --- a/src/dep/rmr/rmr.c +++ b/src/dep/rmr/rmr.c @@ -291,11 +291,17 @@ static void uvMapRequest(struct MRRequestCtx *mc) { }
for (int i = 0; i < mc->numCmds; i++) {
}
if (MRCluster_SendCommand(cluster_g, mrctx->strategy, &mc->cmds[i], fanoutCallback, mrctx) == REDIS_OK) { mrctx->numExpected++; }
mrctx->strategy = MRCluster_FlatCoordination; }
if (mrctx->numExpected == 0) {
I'm getting the following "moved" error when i send write command。i change uvMapRequest function to repair it #
see diff: src/dep/rmr/rmr.c | 6 ++++++ 1 file changed, 6 insertions(+)
diff --git a/src/dep/rmr/rmr.c b/src/dep/rmr/rmr.c index 8fff8f9..76ea653 100644 --- a/src/dep/rmr/rmr.c +++ b/src/dep/rmr/rmr.c @@ -291,11 +291,17 @@ static void uvMapRequest(struct MRRequestCtx *mc) { }
for (int i = 0; i < mc->numCmds; i++) {
}
if (MRCluster_SendCommand(cluster_g, mrctx->strategy, &mc->cmds[i], fanoutCallback, mrctx) == REDIS_OK) { mrctx->numExpected++; }
mrctx->strategy = MRCluster_FlatCoordination; }
if (mrctx->numExpected == 0) {