修复一个发送的数据大于50KB时可能会阻塞的严重BUG

aaasoft · aaasoft · commit 10b880f92ba2 · 2025-10-25T14:45:04.000+08:00
diff --git a/Quick.Protocol/QpChannel_Send.cs b/Quick.Protocol/QpChannel_Send.cs
@@ -127,7 +127,7 @@ private async Task writePackageBuffer(PipeReader currentReader, QpPackageType pa
                     packageBodyBuffer.CopyTo(bodyMemory.Span);
                     writer.Advance(packageBodyLength);
                 }
-                await writer.FlushAsync();
+                _ = writer.FlushAsync();
 
                 //发送
                 var reader = sendRawPipe.Reader;
@@ -244,7 +244,7 @@ await UseSendPipe(QpPackageType.Notice, async pipe =>
                         bodyLength += byteCount;
                     }
                 }
-                await writer.FlushAsync();
+                _ = writer.FlushAsync();
                 if (LogUtils.LogNotice)
                     LogUtils.Log("{0}: [Send-NoticePackage]Type:{1},Content:{2}", DateTime.Now, typeName, LogUtils.LogContent ? content : LogUtils.NOT_SHOW_CONTENT_MESSAGE);
                 return bodyLength;
@@ -290,8 +290,7 @@ await UseSendPipe(QpPackageType.CommandRequest, async pipe =>
                     writer.Advance(contentLength);
                     bodyLength += contentLength;
                 }
-                await writer.FlushAsync();
-
+                _ = writer.FlushAsync();
                 if (LogUtils.LogCommand)
                     LogUtils.Log("{0}: [Send-CommandRequestPackage]CommandId:{1},Type:{2},Content:{3}", DateTime.Now, commandId, typeName, LogUtils.LogContent ? content : LogUtils.NOT_SHOW_CONTENT_MESSAGE);
 
diff --git a/Test/Pipeline/PipelineClient/PipelineClient.csproj b/Test/Pipeline/PipelineClient/PipelineClient.csproj
@@ -3,6 +3,7 @@
   <PropertyGroup>
     <OutputType>Exe</OutputType>
     <TargetFramework>net8.0</TargetFramework>
+    <RollForward>Major</RollForward>
     <IsPackable>false</IsPackable>
   </PropertyGroup>
 
diff --git a/Test/Pipeline/PipelineServer/PipelineServer.csproj b/Test/Pipeline/PipelineServer/PipelineServer.csproj
@@ -3,6 +3,7 @@
   <PropertyGroup>
     <OutputType>Exe</OutputType>
     <TargetFramework>net8.0</TargetFramework>
+    <RollForward>Major</RollForward>
     <IsPackable>false</IsPackable>
   </PropertyGroup>
 

Original file line number	Diff line number	Diff line change
`@@ -127,7 +127,7 @@ private async Task writePackageBuffer(PipeReader currentReader, QpPackageType pa`
`127`	`127`	`packageBodyBuffer.CopyTo(bodyMemory.Span);`
`128`	`128`	`writer.Advance(packageBodyLength);`
`129`	`129`	`}`
`130`		`- await writer.FlushAsync();`
	`130`	`+ _ = writer.FlushAsync();`
`131`	`131`
`132`	`132`	`//发送`
`133`	`133`	`var reader = sendRawPipe.Reader;`
`@@ -244,7 +244,7 @@ await UseSendPipe(QpPackageType.Notice, async pipe =>`
`244`	`244`	`bodyLength += byteCount;`
`245`	`245`	`}`
`246`	`246`	`}`
`247`		`- await writer.FlushAsync();`
	`247`	`+ _ = writer.FlushAsync();`
`248`	`248`	`if (LogUtils.LogNotice)`
`249`	`249`	`LogUtils.Log("{0}: [Send-NoticePackage]Type:{1},Content:{2}", DateTime.Now, typeName, LogUtils.LogContent ? content : LogUtils.NOT_SHOW_CONTENT_MESSAGE);`
`250`	`250`	`return bodyLength;`
`@@ -290,8 +290,7 @@ await UseSendPipe(QpPackageType.CommandRequest, async pipe =>`
`290`	`290`	`writer.Advance(contentLength);`
`291`	`291`	`bodyLength += contentLength;`
`292`	`292`	`}`
`293`		`- await writer.FlushAsync();`
`294`		`-`
	`293`	`+ _ = writer.FlushAsync();`
`295`	`294`	`if (LogUtils.LogCommand)`
`296`	`295`	`LogUtils.Log("{0}: [Send-CommandRequestPackage]CommandId:{1},Type:{2},Content:{3}", DateTime.Now, commandId, typeName, LogUtils.LogContent ? content : LogUtils.NOT_SHOW_CONTENT_MESSAGE);`
`297`	`296`