g82tt/ThingsGateway
1
0
Fork 0
mirror of https://gitee.com/ThingsGateway/ThingsGateway.git synced 2025-10-21 11:08:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

ByteBlock实际长度

Browse Source
This commit is contained in:
2248356998 qq.com
2023-03-18 16:45:39 +08:00
parent 8d2a811184
commit e9aa475398
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/ThingsGateway.Foundation/Serial/Serial/SerialClient.cs
View File

@@ -542,6 +542,7 @@ namespace ThingsGateway.Foundation.Serial
MainSerialPort.DataReceived += this.EventArgs_DataReceived;
SerialReceivedEventArgs eventArgs = new();
ByteBlock byteBlock = BytePool.Default.GetByteBlock(this.BufferLength);
byteBlock.SetLength(0);
eventArgs.UserToken = byteBlock;
if (this.MainSerialPort.BytesToRead > 0)
{
@@ -563,6 +564,7 @@ namespace ThingsGateway.Foundation.Serial
{
SerialReceivedEventArgs eventArgs = new();
ByteBlock byteBlock = BytePool.Default.GetByteBlock(this.BufferLength);
byteBlock.SetLength(0);
eventArgs.UserToken = byteBlock;
if (this.MainSerialPort.BytesToRead > 0)
{
@@ -825,11 +827,13 @@ namespace ThingsGateway.Foundation.Serial
int offset = 0;
int num = MainSerialPort.Read(buffer, offset, MainSerialPort.BytesToRead);
ByteBlock byteBlock = e.UserToken;
byteBlock.Write(buffer);
byteBlock.Write(buffer, byteBlock.Len, num);
this.HandleBuffer(byteBlock);
try
{
ByteBlock newByteBlock = BytePool.Default.GetByteBlock(this.BufferLength);
newByteBlock.SetLength(num);
e.UserToken = newByteBlock;
if (MainSerialPort.BytesToRead > 0)