From b544d5cccd76735e034c8055918a50927b437474 Mon Sep 17 00:00:00 2001
From: wenxiangchao <wenxiangchao@ihengxin.com.cn>
Date: 星期二, 10 十一月 2026 08:29:04 +0800
Subject: [PATCH] fix: 维护模式重复进入失败与按钮灰死 + Broker 并发验证用例
---
Plugin.TestResult/Model/TcpServer.cs | 30 ++++++++++++++++++++++++------
1 files changed, 24 insertions(+), 6 deletions(-)
diff --git a/Plugin.TestResult/Model/TcpServer.cs b/Plugin.TestResult/Model/TcpServer.cs
index c1c0911..2f1fc8c 100644
--- a/Plugin.TestResult/Model/TcpServer.cs
+++ b/Plugin.TestResult/Model/TcpServer.cs
@@ -1,7 +1,7 @@
-锘縰sing ScottPlot.Colormaps;
-using SuperSocket.SocketBase;
+锘縰sing SuperSocket.SocketBase;
using SuperSocket.SocketBase.Protocol;
using System;
+using System.Collections.Generic;
using System.Text;
namespace Plugin.TestResult_WPF.Model
@@ -11,8 +11,8 @@
public override StringRequestInfo Filter(byte[] readBuffer, int offset, int length, bool toBeCopied, out int rest)
{
rest = 0;
- StringBuilder sb = new StringBuilder();
int i = offset;
+ List<byte> bytes = new List<byte>();
while (i < readBuffer.Length)
{
byte b = readBuffer[i++];
@@ -20,15 +20,33 @@
{
break;
}
- sb.Append((char)b);
+ bytes.Add(b);
}
- return new StringRequestInfo(DateTime.Now + "", sb.ToString(), null);
+ byte[] arr = bytes.ToArray();
+ return new StringRequestInfo(DateTime.Now.ToString("yyyyMMddHHmmssfff"), Encoding.UTF8.GetString(arr), null);//sb.ToString()
}
}
+ public class StringParser : IRequestInfoParser<StringRequestInfo>
+ {
+
+ public StringRequestInfo ParseRequestInfo(string source)
+ {
+ return new StringRequestInfo(DateTime.Now.ToString("yyyyMMddHHmmssfff"), source, null);
+ }
+ }
+
+ //public class TcpServer : AppServer<TcpSession>
+ //{
+ // public TcpServer() : base(new DefaultReceiveFilterFactory<DTReceiveFilter, StringRequestInfo>())
+ // {
+
+ // }
+ //}
+
public class TcpServer : AppServer<TcpSession>
{
- public TcpServer() : base(new DefaultReceiveFilterFactory<DTReceiveFilter, StringRequestInfo>())
+ public TcpServer() : base(new TerminatorReceiveFilterFactory("\n", Encoding.UTF8, new StringParser()))
{
}
--
Gitblit v1.9.1