|
|
@@ -1,17 +1,17 @@
|
|
|
using System.Diagnostics;
|
|
|
-using System.Threading;
|
|
|
-using ENet;
|
|
|
+using System.Threading;
|
|
|
+using ENet;
|
|
|
using Helper;
|
|
|
using Log;
|
|
|
-using Microsoft.VisualStudio.TestTools.UnitTesting;
|
|
|
-
|
|
|
-namespace ENetCSTest
|
|
|
-{
|
|
|
- [TestClass]
|
|
|
- public class ENetClientServerTest
|
|
|
- {
|
|
|
- private const int pingPangCount = 1000;
|
|
|
- private static async void ClientEvent(EService service, string hostName, ushort port)
|
|
|
+using Microsoft.VisualStudio.TestTools.UnitTesting;
|
|
|
+
|
|
|
+namespace ENetCSTest
|
|
|
+{
|
|
|
+ [TestClass]
|
|
|
+ public class ENetClientServerTest
|
|
|
+ {
|
|
|
+ private const int pingPangCount = 1000;
|
|
|
+ private static async void ClientEvent(EService service, string hostName, ushort port)
|
|
|
{
|
|
|
var eSocket = new ESocket(service);
|
|
|
await eSocket.ConnectAsync(hostName, port);
|
|
|
@@ -27,12 +27,12 @@ namespace ENetCSTest
|
|
|
}
|
|
|
stopWatch.Stop();
|
|
|
Logger.Debug("time: {0}", stopWatch.ElapsedMilliseconds);
|
|
|
- await eSocket.DisconnectAsync();
|
|
|
- service.Stop();
|
|
|
- }
|
|
|
-
|
|
|
- private static async void ServerEvent(EService service, Barrier barrier)
|
|
|
- {
|
|
|
+ await eSocket.DisconnectAsync();
|
|
|
+ service.Stop();
|
|
|
+ }
|
|
|
+
|
|
|
+ private static async void ServerEvent(EService service, Barrier barrier)
|
|
|
+ {
|
|
|
barrier.SignalAndWait();
|
|
|
var eSocket = new ESocket(service);
|
|
|
await eSocket.AcceptAsync();
|
|
|
@@ -47,34 +47,34 @@ namespace ENetCSTest
|
|
|
|
|
|
eSocket.WriteAsync("9876543210".ToByteArray());
|
|
|
}
|
|
|
- }
|
|
|
-
|
|
|
- [TestMethod]
|
|
|
- public void ClientSendToServer()
|
|
|
- {
|
|
|
- const string hostName = "127.0.0.1";
|
|
|
- const ushort port = 8888;
|
|
|
- var clientHost = new EService();
|
|
|
- var serverHost = new EService(hostName, port);
|
|
|
-
|
|
|
- var serverThread = new Thread(() => serverHost.Start(10));
|
|
|
- var clientThread = new Thread(() => clientHost.Start(10));
|
|
|
-
|
|
|
- serverThread.Start();
|
|
|
- clientThread.Start();
|
|
|
-
|
|
|
- var barrier = new Barrier(2);
|
|
|
-
|
|
|
- // 往server host线程增加事件,accept
|
|
|
- serverHost.Events += () => ServerEvent(serverHost, barrier);
|
|
|
-
|
|
|
- barrier.SignalAndWait();
|
|
|
-
|
|
|
- // 往client host线程增加事件,client线程连接server
|
|
|
- clientHost.Events += () => ClientEvent(clientHost, hostName, port);
|
|
|
-
|
|
|
- serverThread.Join();
|
|
|
- clientThread.Join();
|
|
|
- }
|
|
|
- }
|
|
|
+ }
|
|
|
+
|
|
|
+ [TestMethod]
|
|
|
+ public void ClientSendToServer()
|
|
|
+ {
|
|
|
+ const string hostName = "127.0.0.1";
|
|
|
+ const ushort port = 8888;
|
|
|
+ var clientHost = new EService();
|
|
|
+ var serverHost = new EService(hostName, port);
|
|
|
+
|
|
|
+ var serverThread = new Thread(() => serverHost.Start(10));
|
|
|
+ var clientThread = new Thread(() => clientHost.Start(10));
|
|
|
+
|
|
|
+ serverThread.Start();
|
|
|
+ clientThread.Start();
|
|
|
+
|
|
|
+ var barrier = new Barrier(2);
|
|
|
+
|
|
|
+ // 往server host线程增加事件,accept
|
|
|
+ serverHost.Events += () => ServerEvent(serverHost, barrier);
|
|
|
+
|
|
|
+ barrier.SignalAndWait();
|
|
|
+
|
|
|
+ // 往client host线程增加事件,client线程连接server
|
|
|
+ clientHost.Events += () => ClientEvent(clientHost, hostName, port);
|
|
|
+
|
|
|
+ serverThread.Join();
|
|
|
+ clientThread.Join();
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|