Commit 78d04c28 authored by Marc Gravell's avatar Marc Gravell

lib update; better connection status tracking

parent 3643bb3a
...@@ -264,7 +264,7 @@ internal void KeepAlive() ...@@ -264,7 +264,7 @@ internal void KeepAlive()
{ {
msg.SetInternalCall(); msg.SetInternalCall();
Multiplexer.Trace("Enqueue: " + msg); Multiplexer.Trace("Enqueue: " + msg);
Multiplexer.OnInfoMessage($"heartbeat ({physical?.LastWriteSecondsAgo}s >= {ServerEndPoint?.WriteEverySeconds}s) '{msg.CommandAndKey}' on '{PhysicalName}' (v{features.Version})"); Multiplexer.OnInfoMessage($"heartbeat ({physical?.LastWriteSecondsAgo}s >= {ServerEndPoint?.WriteEverySeconds}s, {physical?.GetSentAwaitingResponseCount()} waiting) '{msg.CommandAndKey}' on '{PhysicalName}' (v{features.Version})");
physical?.UpdateLastWriteTime(); // pre-emptively physical?.UpdateLastWriteTime(); // pre-emptively
var result = TryWrite(msg, ServerEndPoint.IsSlave); var result = TryWrite(msg, ServerEndPoint.IsSlave);
......
...@@ -335,7 +335,7 @@ public Task FlushAsync() ...@@ -335,7 +335,7 @@ public Task FlushAsync()
} }
if (sc.BytesRead == 0) exMessage.Append(", 0-read"); if (sc.BytesRead == 0) exMessage.Append(", 0-read");
if (sc.BytesSent == 0) exMessage.Append(", 0-sent"); if (sc.BytesSent == 0) exMessage.Append(", 0-sent");
exMessage.Append(")"); exMessage.Append(", last-recv: ").Append(sc.LastReceived).Append(")");
} }
var data = new List<Tuple<string, string>>(); var data = new List<Tuple<string, string>>();
...@@ -414,7 +414,6 @@ void add(string lk, string sk, string v) ...@@ -414,7 +414,6 @@ void add(string lk, string sk, string v)
Shutdown(); Shutdown();
} }
internal bool IsIdle() => _writeStatus == WriteStatus.Idle; internal bool IsIdle() => _writeStatus == WriteStatus.Idle;
internal void SetIdle() => _writeStatus = WriteStatus.Idle; internal void SetIdle() => _writeStatus = WriteStatus.Idle;
internal void SetWriting() => _writeStatus = WriteStatus.Writing; internal void SetWriting() => _writeStatus = WriteStatus.Writing;
......
...@@ -19,7 +19,7 @@ ...@@ -19,7 +19,7 @@
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>
<PackageReference Include="Pipelines.Sockets.Unofficial" Version="0.2.1-alpha.77" /> <PackageReference Include="Pipelines.Sockets.Unofficial" Version="0.2.1-alpha.80" />
<PackageReference Include="System.Diagnostics.PerformanceCounter" Version="4.5.0" /> <PackageReference Include="System.Diagnostics.PerformanceCounter" Version="4.5.0" />
<PackageReference Include="System.IO.Pipelines" Version="4.5.0" /> <PackageReference Include="System.IO.Pipelines" Version="4.5.0" />
<PackageReference Include="System.Threading.Channels" Version="4.5.0" /> <PackageReference Include="System.Threading.Channels" Version="4.5.0" />
......
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