Skip to content

S
StackExchange.Redis
Commit d9a5ee7f authored by Hans Kuder's avatar Hans Kuder Committed by Marc Gravell
Browse files
Options

Update lastReadTickCount in ReadFromPipe (#1030)

parent 15b8dac8
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 0 deletions
src/StackExchange.Redis/PhysicalConnection.cs
View file @ d9a5ee7f
...@@ -1325,6 +1325,7 @@ private void OnDebugAbort() ...@@ -1325,6 +1325,7 @@ private void OnDebugAbort()
partial void OnWrapForLogging(ref IDuplexPipe pipe, string name, SocketManager mgr); partial void OnWrapForLogging(ref IDuplexPipe pipe, string name, SocketManager mgr);
internal void UpdateLastReadTime() => Interlocked.Exchange(ref lastReadTickCount, Environment.TickCount);
private async Task ReadFromPipe() private async Task ReadFromPipe()
{ {
bool allowSyncRead = true, isReading = false; bool allowSyncRead = true, isReading = false;
...@@ -1343,6 +1344,7 @@ private async Task ReadFromPipe() ...@@ -1343,6 +1344,7 @@ private async Task ReadFromPipe()
readResult = await input.ReadAsync().ForAwait(); readResult = await input.ReadAsync().ForAwait();
} }
isReading = false; isReading = false;
UpdateLastReadTime();
var buffer = readResult.Buffer; var buffer = readResult.Buffer;
int handled = 0; int handled = 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