diff --git a/cs/src/core/Async/RMWAsync.cs b/cs/src/core/Async/RMWAsync.cs index 0c1b0fd53..3a0f57d82 100644 --- a/cs/src/core/Async/RMWAsync.cs +++ b/cs/src/core/Async/RMWAsync.cs @@ -62,7 +62,10 @@ public bool CompletePendingIO(IFasterSession /// public void DecrementPending(FasterExecutionContext currentCtx, ref PendingContext pendingContext) { - currentCtx.ioPendingRequests.Remove(pendingContext.id); + if (!this.diskRequest.IsDefault()) + { + currentCtx.ioPendingRequests.Remove(pendingContext.id); + } currentCtx.asyncPendingCount--; currentCtx.pendingReads.Remove(); }