Commit 7d74d187 authored by Hrishikesh Pathak's avatar Hrishikesh Pathak

Merge branch 'SERedis' into SEClusterConfigBugFix

parents ccb16f5c 15898d28
...@@ -141,6 +141,7 @@ public virtual bool SetResult(PhysicalConnection connection, Message message, Ra ...@@ -141,6 +141,7 @@ public virtual bool SetResult(PhysicalConnection connection, Message message, Ra
var server = bridge.ServerEndPoint; var server = bridge.ServerEndPoint;
bool log = !message.IsInternalCall; bool log = !message.IsInternalCall;
bool isMoved = result.AssertStarts(MOVED); bool isMoved = result.AssertStarts(MOVED);
string err = string.Empty;
if (isMoved || result.AssertStarts(ASK)) if (isMoved || result.AssertStarts(ASK))
{ {
message.SetResponseReceived(); message.SetResponseReceived();
...@@ -161,11 +162,19 @@ public virtual bool SetResult(PhysicalConnection connection, Message message, Ra ...@@ -161,11 +162,19 @@ public virtual bool SetResult(PhysicalConnection connection, Message message, Ra
connection.Multiplexer.Trace(message.Command + " re-issued to " + endpoint, isMoved ? "MOVED" : "ASK"); connection.Multiplexer.Trace(message.Command + " re-issued to " + endpoint, isMoved ? "MOVED" : "ASK");
return false; return false;
} }
else
{
err = string.Format("Endpoint {0} serving hashslot {1} is not reachable at this point of time. Please check connectTimeout value. If it is low, try increasing it to give the ConnectionMultiplexer a chance to recover from the network disconnect.", endpoint, hashSlot);
}
} }
} }
} }
string err = result.GetString(); if (string.IsNullOrWhiteSpace(err))
{
err = result.GetString();
}
if (log) if (log)
{ {
bridge.Multiplexer.OnErrorMessage(server.EndPoint, err); bridge.Multiplexer.OnErrorMessage(server.EndPoint, err);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment