fix unstable test case

smdn · smdn · commit 95cd021b7b0d · 2024-07-04T23:52:56.000+09:00
diff --git a/tests/Smdn.Net.SkStackIP/Smdn.Net.SkStackIP/SkStackDuplexPipe.cs b/tests/Smdn.Net.SkStackIP/Smdn.Net.SkStackIP/SkStackDuplexPipe.cs
@@ -102,11 +102,14 @@ private async Task SendAsync(CancellationToken stopToken)
         if (buffer.IsEmpty && read.IsCompleted)
           break;
 
+        // ignore cancellation request until the read content is written to the sentDataBuffer
+        var cancellationTokenForWritingSentData = CancellationToken.None;
+
         foreach (var segment in buffer) {
-          await sentDataBuffer.WriteAsync(segment, stopToken).ConfigureAwait(false);
+          await sentDataBuffer.WriteAsync(segment, cancellationTokenForWritingSentData).ConfigureAwait(false);
         }
 
-        await sentDataBuffer.FlushAsync(stopToken).ConfigureAwait(false);
+        await sentDataBuffer.FlushAsync(cancellationTokenForWritingSentData).ConfigureAwait(false);
 
         sendPipe.Reader.AdvanceTo(buffer.End);
       }

Original file line number	Diff line number	Diff line change
`@@ -102,11 +102,14 @@ private async Task SendAsync(CancellationToken stopToken)`
`102`	`102`	`if (buffer.IsEmpty && read.IsCompleted)`
`103`	`103`	`break;`
`104`	`104`
	`105`	`+ // ignore cancellation request until the read content is written to the sentDataBuffer`
	`106`	`+ var cancellationTokenForWritingSentData = CancellationToken.None;`
	`107`	`+`
`105`	`108`	`foreach (var segment in buffer) {`
`106`		`- await sentDataBuffer.WriteAsync(segment, stopToken).ConfigureAwait(false);`
	`109`	`+ await sentDataBuffer.WriteAsync(segment, cancellationTokenForWritingSentData).ConfigureAwait(false);`
`107`	`110`	`}`
`108`	`111`
`109`		`- await sentDataBuffer.FlushAsync(stopToken).ConfigureAwait(false);`
	`112`	`+ await sentDataBuffer.FlushAsync(cancellationTokenForWritingSentData).ConfigureAwait(false);`
`110`	`113`
`111`	`114`	`sendPipe.Reader.AdvanceTo(buffer.End);`
`112`	`115`	`}`