|
|
@@ -1,7 +1,6 @@
|
|
|
using System.Threading;
|
|
|
using ENet;
|
|
|
-using Helper;
|
|
|
-using Log;
|
|
|
+using Helper;
|
|
|
using Microsoft.VisualStudio.TestTools.UnitTesting;
|
|
|
|
|
|
namespace ENetCSTest
|
|
|
@@ -9,31 +8,31 @@ namespace ENetCSTest
|
|
|
[TestClass]
|
|
|
public class ENetClientServerTest
|
|
|
{
|
|
|
- private static async void ClientEvent(IOService service, string hostName, ushort port)
|
|
|
- {
|
|
|
- var eSocket = new ESocket(service);
|
|
|
- await eSocket.ConnectAsync(hostName, port);
|
|
|
- eSocket.WriteAsync("0123456789".ToByteArray());
|
|
|
-
|
|
|
- var bytes = await eSocket.ReadAsync();
|
|
|
- CollectionAssert.AreEqual("9876543210".ToByteArray(), bytes);
|
|
|
-
|
|
|
+ private static async void ClientEvent(IOService service, string hostName, ushort port)
|
|
|
+ {
|
|
|
+ var eSocket = new ESocket(service);
|
|
|
+ await eSocket.ConnectAsync(hostName, port);
|
|
|
+ eSocket.WriteAsync("0123456789".ToByteArray());
|
|
|
+
|
|
|
+ var bytes = await eSocket.ReadAsync();
|
|
|
+ CollectionAssert.AreEqual("9876543210".ToByteArray(), bytes);
|
|
|
+
|
|
|
await eSocket.DisconnectAsync();
|
|
|
|
|
|
service.Stop();
|
|
|
- }
|
|
|
-
|
|
|
+ }
|
|
|
+
|
|
|
private static async void ServerEvent(IOService service, Barrier barrier)
|
|
|
{
|
|
|
- barrier.SignalAndWait();
|
|
|
+ barrier.SignalAndWait();
|
|
|
var eSocket = new ESocket(service);
|
|
|
await eSocket.AcceptAsync();
|
|
|
- // Client断开,Server端收到Disconnect事件,结束Server线程
|
|
|
- eSocket.ESocketEvent.Disconnect += ev => service.Stop();
|
|
|
-
|
|
|
- var bytes = await eSocket.ReadAsync();
|
|
|
+ // Client断开,Server端收到Disconnect事件,结束Server线程
|
|
|
+ eSocket.ESocketEvent.Disconnect += ev => service.Stop();
|
|
|
+
|
|
|
+ var bytes = await eSocket.ReadAsync();
|
|
|
CollectionAssert.AreEqual("0123456789".ToByteArray(), bytes);
|
|
|
-
|
|
|
+
|
|
|
eSocket.WriteAsync("9876543210".ToByteArray(), 0, PacketFlags.Reliable);
|
|
|
}
|
|
|
|
|
|
@@ -41,7 +40,7 @@ namespace ENetCSTest
|
|
|
public void ClientSendToServer()
|
|
|
{
|
|
|
const string hostName = "127.0.0.1";
|
|
|
- const ushort port = 8888;
|
|
|
+ const ushort port = 8888;
|
|
|
var clientHost = new IOService();
|
|
|
var serverHost = new IOService(hostName, port);
|
|
|
|