|
@@ -1,27 +1,30 @@
|
|
|
-#include <core/Clock.hpp>
|
|
|
|
|
-#include <core/Logger.hpp>
|
|
|
|
|
-#include <core/Utility.hpp>
|
|
|
|
|
#include <cstring>
|
|
#include <cstring>
|
|
|
|
|
|
|
|
#include "../Tests.hpp"
|
|
#include "../Tests.hpp"
|
|
|
#include "../src/ErrorSimulator.hpp"
|
|
#include "../src/ErrorSimulator.hpp"
|
|
|
#include "core/Network.hpp"
|
|
#include "core/Network.hpp"
|
|
|
|
|
|
|
|
|
|
+import Core.Clock;
|
|
|
|
|
+import Core.Logger;
|
|
|
|
|
+import Core.Utility;
|
|
|
|
|
+import Core.Test;
|
|
|
|
|
+import Core.Types;
|
|
|
|
|
+
|
|
|
using Core::Client;
|
|
using Core::Client;
|
|
|
using Core::InPacket;
|
|
using Core::InPacket;
|
|
|
using Core::OutPacket;
|
|
using Core::OutPacket;
|
|
|
using Core::Server;
|
|
using Core::Server;
|
|
|
|
|
|
|
|
-#define TEST_READ(Type, type, value) \
|
|
|
|
|
- { \
|
|
|
|
|
- type u; \
|
|
|
|
|
- TEST_FALSE(in.read##Type(u)); \
|
|
|
|
|
- TEST_TRUE(u == value); \
|
|
|
|
|
|
|
+#define TEST_READ(Type, type, value) \
|
|
|
|
|
+ { \
|
|
|
|
|
+ type u; \
|
|
|
|
|
+ Core::testFalse(in.read##Type(u)); \
|
|
|
|
|
+ Core::testTrue(u == value); \
|
|
|
}
|
|
}
|
|
|
-#define TEST_READ_FAIL(Type, type) \
|
|
|
|
|
- { \
|
|
|
|
|
- type u; \
|
|
|
|
|
- TEST_TRUE(in.read##Type(u)); \
|
|
|
|
|
|
|
+#define TEST_READ_FAIL(Type, type) \
|
|
|
|
|
+ { \
|
|
|
|
|
+ type u; \
|
|
|
|
|
+ Core::testTrue(in.read##Type(u)); \
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
static void testWriteRead() {
|
|
static void testWriteRead() {
|
|
@@ -50,12 +53,12 @@ static void testWriteRead() {
|
|
|
TEST_READ(I32, i32, 100'430'199)
|
|
TEST_READ(I32, i32, 100'430'199)
|
|
|
TEST_READ(I32, i32, -534'534)
|
|
TEST_READ(I32, i32, -534'534)
|
|
|
float f;
|
|
float f;
|
|
|
- TEST_FALSE(in.readFloat(f));
|
|
|
|
|
- TEST_FLOAT(64564.5346f, f, 0.00001f);
|
|
|
|
|
|
|
+ Core::testFalse(in.readFloat(f));
|
|
|
|
|
+ Core::testFloat(64564.5346f, f, 0.00001f);
|
|
|
char buffer[256];
|
|
char buffer[256];
|
|
|
size_t n = in.readString(buffer, sizeof(buffer));
|
|
size_t n = in.readString(buffer, sizeof(buffer));
|
|
|
- TEST(14, n);
|
|
|
|
|
- TEST_STRING(s, buffer);
|
|
|
|
|
|
|
+ Core::test(14, n);
|
|
|
|
|
+ Core::testString(s, buffer);
|
|
|
|
|
|
|
|
TEST_READ_FAIL(U8, u8)
|
|
TEST_READ_FAIL(U8, u8)
|
|
|
TEST_READ_FAIL(U16, u16)
|
|
TEST_READ_FAIL(U16, u16)
|
|
@@ -64,8 +67,8 @@ static void testWriteRead() {
|
|
|
TEST_READ_FAIL(I16, i16)
|
|
TEST_READ_FAIL(I16, i16)
|
|
|
TEST_READ_FAIL(I32, i32)
|
|
TEST_READ_FAIL(I32, i32)
|
|
|
TEST_READ_FAIL(Float, float)
|
|
TEST_READ_FAIL(Float, float)
|
|
|
- TEST(0, in.readString(nullptr, 0));
|
|
|
|
|
- TEST(0, in.readString(buffer, sizeof(buffer)));
|
|
|
|
|
|
|
+ Core::test(0, in.readString(nullptr, 0));
|
|
|
|
|
+ Core::test(0, in.readString(buffer, sizeof(buffer)));
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
static void testTooShortBuffer() {
|
|
static void testTooShortBuffer() {
|
|
@@ -76,12 +79,12 @@ static void testTooShortBuffer() {
|
|
|
InPacket in(out.data.getData(), out.data.getLength());
|
|
InPacket in(out.data.getData(), out.data.getLength());
|
|
|
char buffer[8];
|
|
char buffer[8];
|
|
|
size_t n = in.readString(buffer, sizeof(buffer));
|
|
size_t n = in.readString(buffer, sizeof(buffer));
|
|
|
- TEST(14, n);
|
|
|
|
|
- TEST_STRING("This is", buffer);
|
|
|
|
|
|
|
+ Core::test(14, n);
|
|
|
|
|
+ Core::testString("This is", buffer);
|
|
|
char buffer2[6];
|
|
char buffer2[6];
|
|
|
size_t n2 = in.readString(buffer2, sizeof(buffer2));
|
|
size_t n2 = in.readString(buffer2, sizeof(buffer2));
|
|
|
- TEST(10, n2);
|
|
|
|
|
- TEST_STRING("Well ", buffer2);
|
|
|
|
|
|
|
+ Core::test(10, n2);
|
|
|
|
|
+ Core::testString("Well ", buffer2);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
struct PacketTest {
|
|
struct PacketTest {
|
|
@@ -97,8 +100,8 @@ static void testBinaryData() {
|
|
|
InPacket in(out.data.getData(), out.data.getLength());
|
|
InPacket in(out.data.getData(), out.data.getLength());
|
|
|
|
|
|
|
|
PacketTest inData;
|
|
PacketTest inData;
|
|
|
- TEST_FALSE(in.read(&inData, sizeof(inData)));
|
|
|
|
|
- TEST_TRUE(memcmp(&inData, &data, sizeof(inData)) == 0);
|
|
|
|
|
|
|
+ Core::testFalse(in.read(&inData, sizeof(inData)));
|
|
|
|
|
+ Core::testTrue(memcmp(&inData, &data, sizeof(inData)) == 0);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
static void testShortString() {
|
|
static void testShortString() {
|
|
@@ -110,8 +113,8 @@ static void testShortString() {
|
|
|
|
|
|
|
|
char buffer[256];
|
|
char buffer[256];
|
|
|
size_t n = in.readString(buffer, sizeof(buffer));
|
|
size_t n = in.readString(buffer, sizeof(buffer));
|
|
|
- TEST(200, n);
|
|
|
|
|
- TEST_STRING("", buffer);
|
|
|
|
|
|
|
+ Core::test(200, n);
|
|
|
|
|
+ Core::testString("", buffer);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
using BoolFunction = bool (*)(void*);
|
|
using BoolFunction = bool (*)(void*);
|
|
@@ -156,17 +159,17 @@ static void onServerDisconnect(Server&, Core::ClientHandle) {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
static void onServerPacket(Server& s, Core::ClientHandle client, InPacket& in) {
|
|
static void onServerPacket(Server& s, Core::ClientHandle client, InPacket& in) {
|
|
|
- TEST_FALSE(in.readU8(data1));
|
|
|
|
|
- TEST_FALSE(in.readU16(data2));
|
|
|
|
|
- TEST_FALSE(in.readU32(data3));
|
|
|
|
|
- TEST_FALSE(in.readI8(data4));
|
|
|
|
|
- TEST_FALSE(in.readI16(data5));
|
|
|
|
|
- TEST_FALSE(in.readI32(data6));
|
|
|
|
|
- TEST_FALSE(in.readI8(data7));
|
|
|
|
|
- TEST_FALSE(in.readI16(data8));
|
|
|
|
|
- TEST_FALSE(in.readI32(data9));
|
|
|
|
|
- TEST(9, in.readString(data10, sizeof(data10)));
|
|
|
|
|
- TEST_FALSE(in.readFloat(data11));
|
|
|
|
|
|
|
+ Core::testFalse(in.readU8(data1));
|
|
|
|
|
+ Core::testFalse(in.readU16(data2));
|
|
|
|
|
+ Core::testFalse(in.readU32(data3));
|
|
|
|
|
+ Core::testFalse(in.readI8(data4));
|
|
|
|
|
+ Core::testFalse(in.readI16(data5));
|
|
|
|
|
+ Core::testFalse(in.readI32(data6));
|
|
|
|
|
+ Core::testFalse(in.readI8(data7));
|
|
|
|
|
+ Core::testFalse(in.readI16(data8));
|
|
|
|
|
+ Core::testFalse(in.readI32(data9));
|
|
|
|
|
+ Core::test(9, in.readString(data10, sizeof(data10)));
|
|
|
|
|
+ Core::testFalse(in.readFloat(data11));
|
|
|
|
|
|
|
|
OutPacket out;
|
|
OutPacket out;
|
|
|
if(packageCounter == 0) {
|
|
if(packageCounter == 0) {
|
|
@@ -221,19 +224,19 @@ static void testConnect(Core::PacketSendMode mode) {
|
|
|
c.setDisconnectHandler(onClientDisconnect);
|
|
c.setDisconnectHandler(onClientDisconnect);
|
|
|
c.setPacketHandler(onClientPacket);
|
|
c.setPacketHandler(onClientPacket);
|
|
|
|
|
|
|
|
- if(!TEST_FALSE(s.start(54'321, 5))) {
|
|
|
|
|
|
|
+ if(!Core::testFalse(s.start(54'321, 5))) {
|
|
|
return;
|
|
return;
|
|
|
- } else if(!TEST_FALSE(c.start())) {
|
|
|
|
|
|
|
+ } else if(!Core::testFalse(c.start())) {
|
|
|
return;
|
|
return;
|
|
|
- } else if(!TEST_FALSE(c.connect("127.0.0.1", 54'321, 90))) {
|
|
|
|
|
|
|
+ } else if(!Core::testFalse(c.connect("127.0.0.1", 54'321, 90))) {
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|
|
|
- TEST_FALSE(c.isConnected());
|
|
|
|
|
- TEST_TRUE(c.isConnecting());
|
|
|
|
|
|
|
+ Core::testFalse(c.isConnected());
|
|
|
|
|
+ Core::testTrue(c.isConnecting());
|
|
|
tickUntilConnected(s, c);
|
|
tickUntilConnected(s, c);
|
|
|
- TEST_TRUE(clientConnected);
|
|
|
|
|
- TEST_TRUE(c.isConnected());
|
|
|
|
|
- TEST_FALSE(c.isConnecting());
|
|
|
|
|
|
|
+ Core::testTrue(clientConnected);
|
|
|
|
|
+ Core::testTrue(c.isConnected());
|
|
|
|
|
+ Core::testFalse(c.isConnecting());
|
|
|
|
|
|
|
|
OutPacket out;
|
|
OutPacket out;
|
|
|
out.writeU8(0xF1);
|
|
out.writeU8(0xF1);
|
|
@@ -251,29 +254,29 @@ static void testConnect(Core::PacketSendMode mode) {
|
|
|
c.sendPacket(out, mode);
|
|
c.sendPacket(out, mode);
|
|
|
|
|
|
|
|
tick(s, c, [](void*) { return !clientPackage || !serverConnected; }, &c);
|
|
tick(s, c, [](void*) { return !clientPackage || !serverConnected; }, &c);
|
|
|
- TEST_TRUE(clientPackage);
|
|
|
|
|
- TEST_TRUE(serverConnected);
|
|
|
|
|
-
|
|
|
|
|
- TEST(0xF1, data1);
|
|
|
|
|
- TEST(0xF123, data2);
|
|
|
|
|
- TEST(0xF123'4567, data3);
|
|
|
|
|
- TEST(-0x71, data4);
|
|
|
|
|
- TEST(-0x7123, data5);
|
|
|
|
|
- TEST(-0x7123'4567, data6);
|
|
|
|
|
- TEST(0x71, data7);
|
|
|
|
|
- TEST(0x7123, data8);
|
|
|
|
|
- TEST(0x7123'4567, data9);
|
|
|
|
|
- TEST_STRING(st, data10);
|
|
|
|
|
- TEST_FLOAT(252345.983f, data11, 0.01f);
|
|
|
|
|
|
|
+ Core::testTrue(clientPackage);
|
|
|
|
|
+ Core::testTrue(serverConnected);
|
|
|
|
|
+
|
|
|
|
|
+ Core::test(0xF1, data1);
|
|
|
|
|
+ Core::test(0xF123, data2);
|
|
|
|
|
+ Core::test(0xF123'4567, data3);
|
|
|
|
|
+ Core::test(-0x71, data4);
|
|
|
|
|
+ Core::test(-0x7123, data5);
|
|
|
|
|
+ Core::test(-0x7123'4567, data6);
|
|
|
|
|
+ Core::test(0x71, data7);
|
|
|
|
|
+ Core::test(0x7123, data8);
|
|
|
|
|
+ Core::test(0x7123'4567, data9);
|
|
|
|
|
+ Core::testString(st, data10);
|
|
|
|
|
+ Core::testFloat(252345.983f, data11, 0.01f);
|
|
|
|
|
|
|
|
c.disconnect(90);
|
|
c.disconnect(90);
|
|
|
- TEST_FALSE(c.isConnected());
|
|
|
|
|
- TEST_FALSE(c.isConnecting());
|
|
|
|
|
|
|
+ Core::testFalse(c.isConnected());
|
|
|
|
|
+ Core::testFalse(c.isConnecting());
|
|
|
tick(
|
|
tick(
|
|
|
s, c, [](void*) { return !clientDisconnected || !serverDisconnect; },
|
|
s, c, [](void*) { return !clientDisconnected || !serverDisconnect; },
|
|
|
&c);
|
|
&c);
|
|
|
- TEST_TRUE(clientDisconnected);
|
|
|
|
|
- TEST_TRUE(serverDisconnect);
|
|
|
|
|
|
|
+ Core::testTrue(clientDisconnected);
|
|
|
|
|
+ Core::testTrue(serverDisconnect);
|
|
|
|
|
|
|
|
c.stop();
|
|
c.stop();
|
|
|
s.stop();
|
|
s.stop();
|
|
@@ -290,19 +293,19 @@ static void testDisconnect() {
|
|
|
Client c;
|
|
Client c;
|
|
|
c.resetHandler();
|
|
c.resetHandler();
|
|
|
c.setDisconnectHandler(testStopDisconnect);
|
|
c.setDisconnectHandler(testStopDisconnect);
|
|
|
- if(!TEST_FALSE(c.start())) {
|
|
|
|
|
|
|
+ if(!Core::testFalse(c.start())) {
|
|
|
return;
|
|
return;
|
|
|
- } else if(!TEST_FALSE(c.connect("127.0.0.1", 54'321, 90))) {
|
|
|
|
|
|
|
+ } else if(!Core::testFalse(c.connect("127.0.0.1", 54'321, 90))) {
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|
|
|
- TEST_FALSE(c.isConnected());
|
|
|
|
|
- TEST_TRUE(c.isConnecting());
|
|
|
|
|
|
|
+ Core::testFalse(c.isConnected());
|
|
|
|
|
+ Core::testTrue(c.isConnecting());
|
|
|
c.disconnect(50);
|
|
c.disconnect(50);
|
|
|
Server s;
|
|
Server s;
|
|
|
tick(s, c, [](void*) { return !disconnected; }, &c);
|
|
tick(s, c, [](void*) { return !disconnected; }, &c);
|
|
|
- TEST_FALSE(c.isConnected());
|
|
|
|
|
- TEST_FALSE(c.isConnecting());
|
|
|
|
|
- TEST_TRUE(disconnected);
|
|
|
|
|
|
|
+ Core::testFalse(c.isConnected());
|
|
|
|
|
+ Core::testFalse(c.isConnecting());
|
|
|
|
|
+ Core::testTrue(disconnected);
|
|
|
c.stop();
|
|
c.stop();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -311,30 +314,30 @@ static void testStop() {
|
|
|
Client c;
|
|
Client c;
|
|
|
c.resetHandler();
|
|
c.resetHandler();
|
|
|
c.setDisconnectHandler(testStopDisconnect);
|
|
c.setDisconnectHandler(testStopDisconnect);
|
|
|
- if(!TEST_FALSE(c.start())) {
|
|
|
|
|
|
|
+ if(!Core::testFalse(c.start())) {
|
|
|
return;
|
|
return;
|
|
|
- } else if(!TEST_FALSE(c.connect("127.0.0.1", 54'321, 90))) {
|
|
|
|
|
|
|
+ } else if(!Core::testFalse(c.connect("127.0.0.1", 54'321, 90))) {
|
|
|
return;
|
|
return;
|
|
|
}
|
|
}
|
|
|
- TEST_FALSE(c.isConnected());
|
|
|
|
|
- TEST_TRUE(c.isConnecting());
|
|
|
|
|
|
|
+ Core::testFalse(c.isConnected());
|
|
|
|
|
+ Core::testTrue(c.isConnecting());
|
|
|
c.stop();
|
|
c.stop();
|
|
|
- TEST_FALSE(c.isConnected());
|
|
|
|
|
- TEST_FALSE(c.isConnecting());
|
|
|
|
|
- TEST_TRUE(disconnected);
|
|
|
|
|
|
|
+ Core::testFalse(c.isConnected());
|
|
|
|
|
+ Core::testFalse(c.isConnecting());
|
|
|
|
|
+ Core::testTrue(disconnected);
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
static void testClientStartFails() {
|
|
static void testClientStartFails() {
|
|
|
Client c;
|
|
Client c;
|
|
|
- TEST_FALSE(c.start());
|
|
|
|
|
|
|
+ Core::testFalse(c.start());
|
|
|
useReport = false;
|
|
useReport = false;
|
|
|
- TEST_TRUE(c.start());
|
|
|
|
|
|
|
+ Core::testTrue(c.start());
|
|
|
c.stop();
|
|
c.stop();
|
|
|
#ifdef ERROR_SIMULATOR
|
|
#ifdef ERROR_SIMULATOR
|
|
|
failCounter = 0;
|
|
failCounter = 0;
|
|
|
- TEST_TRUE(c.start());
|
|
|
|
|
|
|
+ Core::testTrue(c.start());
|
|
|
failCounter = 1;
|
|
failCounter = 1;
|
|
|
- TEST_TRUE(c.start());
|
|
|
|
|
|
|
+ Core::testTrue(c.start());
|
|
|
failCounter = -1;
|
|
failCounter = -1;
|
|
|
#endif
|
|
#endif
|
|
|
useReport = true;
|
|
useReport = true;
|
|
@@ -344,15 +347,15 @@ static void testClientConnectionFails() {
|
|
|
Client c;
|
|
Client c;
|
|
|
c.resetHandler();
|
|
c.resetHandler();
|
|
|
useReport = false;
|
|
useReport = false;
|
|
|
- TEST_TRUE(c.connect("", 54'321, 100));
|
|
|
|
|
- TEST_FALSE(c.start());
|
|
|
|
|
|
|
+ Core::testTrue(c.connect("", 54'321, 100));
|
|
|
|
|
+ Core::testFalse(c.start());
|
|
|
#ifdef ERROR_SIMULATOR
|
|
#ifdef ERROR_SIMULATOR
|
|
|
failCounter = 0;
|
|
failCounter = 0;
|
|
|
- TEST_TRUE(c.connect("", 54'321, 100));
|
|
|
|
|
|
|
+ Core::testTrue(c.connect("", 54'321, 100));
|
|
|
failCounter = -1;
|
|
failCounter = -1;
|
|
|
#endif
|
|
#endif
|
|
|
- TEST_FALSE(c.connect("", 54'321, 100));
|
|
|
|
|
- TEST_TRUE(c.connect("", 54'321, 100));
|
|
|
|
|
|
|
+ Core::testFalse(c.connect("", 54'321, 100));
|
|
|
|
|
+ Core::testTrue(c.connect("", 54'321, 100));
|
|
|
useReport = true;
|
|
useReport = true;
|
|
|
for(int i = 0; i < 100; i++) {
|
|
for(int i = 0; i < 100; i++) {
|
|
|
c.tick();
|
|
c.tick();
|
|
@@ -371,16 +374,16 @@ static void testInvalidClientAccess() {
|
|
|
static void testServerStartFails() {
|
|
static void testServerStartFails() {
|
|
|
useReport = false;
|
|
useReport = false;
|
|
|
Server s;
|
|
Server s;
|
|
|
- TEST_TRUE(s.start(54'321, 0));
|
|
|
|
|
|
|
+ Core::testTrue(s.start(54'321, 0));
|
|
|
#ifdef ERROR_SIMULATOR
|
|
#ifdef ERROR_SIMULATOR
|
|
|
failCounter = 0;
|
|
failCounter = 0;
|
|
|
- TEST_TRUE(s.start(54'321, 5));
|
|
|
|
|
|
|
+ Core::testTrue(s.start(54'321, 5));
|
|
|
failCounter = 1;
|
|
failCounter = 1;
|
|
|
- TEST_TRUE(s.start(54'321, 5));
|
|
|
|
|
|
|
+ Core::testTrue(s.start(54'321, 5));
|
|
|
failCounter = -1;
|
|
failCounter = -1;
|
|
|
#endif
|
|
#endif
|
|
|
- TEST_FALSE(s.start(54'321, 5));
|
|
|
|
|
- TEST_TRUE(s.start(54'321, 5));
|
|
|
|
|
|
|
+ Core::testFalse(s.start(54'321, 5));
|
|
|
|
|
+ Core::testTrue(s.start(54'321, 5));
|
|
|
useReport = true;
|
|
useReport = true;
|
|
|
s.stop();
|
|
s.stop();
|
|
|
}
|
|
}
|
|
@@ -389,12 +392,12 @@ static void testServerClosesOnConnected() {
|
|
|
Server s;
|
|
Server s;
|
|
|
Client c;
|
|
Client c;
|
|
|
clientDisconnected = false;
|
|
clientDisconnected = false;
|
|
|
- TEST_FALSE(s.start(54'321, 5));
|
|
|
|
|
- TEST_FALSE(c.start());
|
|
|
|
|
|
|
+ Core::testFalse(s.start(54'321, 5));
|
|
|
|
|
+ Core::testFalse(c.start());
|
|
|
c.setDisconnectHandler(onClientDisconnect);
|
|
c.setDisconnectHandler(onClientDisconnect);
|
|
|
- TEST_FALSE(c.connect("127.0.0.1", 54'321, 50));
|
|
|
|
|
|
|
+ Core::testFalse(c.connect("127.0.0.1", 54'321, 50));
|
|
|
tickUntilConnected(s, c);
|
|
tickUntilConnected(s, c);
|
|
|
- TEST_TRUE(c.isConnected());
|
|
|
|
|
|
|
+ Core::testTrue(c.isConnected());
|
|
|
s.stop();
|
|
s.stop();
|
|
|
|
|
|
|
|
c.setTimeout(500, 500, 500);
|
|
c.setTimeout(500, 500, 500);
|
|
@@ -402,8 +405,8 @@ static void testServerClosesOnConnected() {
|
|
|
c.tick();
|
|
c.tick();
|
|
|
Core::Clock::sleepMillis(10);
|
|
Core::Clock::sleepMillis(10);
|
|
|
}
|
|
}
|
|
|
- TEST_FALSE(c.isConnected());
|
|
|
|
|
- TEST_TRUE(clientDisconnected);
|
|
|
|
|
|
|
+ Core::testFalse(c.isConnected());
|
|
|
|
|
+ Core::testTrue(clientDisconnected);
|
|
|
c.stop();
|
|
c.stop();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -417,13 +420,13 @@ static void testServerDisconnectsClient() {
|
|
|
clientDisconnected = false;
|
|
clientDisconnected = false;
|
|
|
Server s;
|
|
Server s;
|
|
|
Client c;
|
|
Client c;
|
|
|
- TEST_FALSE(s.start(54'321, 5));
|
|
|
|
|
- TEST_FALSE(c.start());
|
|
|
|
|
|
|
+ Core::testFalse(s.start(54'321, 5));
|
|
|
|
|
+ Core::testFalse(c.start());
|
|
|
c.setDisconnectHandler(onClientDisconnect);
|
|
c.setDisconnectHandler(onClientDisconnect);
|
|
|
s.setConnectHandler(onConnectSetClient);
|
|
s.setConnectHandler(onConnectSetClient);
|
|
|
- TEST_FALSE(c.connect("127.0.0.1", 54'321, 50));
|
|
|
|
|
|
|
+ Core::testFalse(c.connect("127.0.0.1", 54'321, 50));
|
|
|
tickUntilConnected(s, c);
|
|
tickUntilConnected(s, c);
|
|
|
- TEST_TRUE(c.isConnected());
|
|
|
|
|
|
|
+ Core::testTrue(c.isConnected());
|
|
|
|
|
|
|
|
s.disconnectClient(clientId);
|
|
s.disconnectClient(clientId);
|
|
|
|
|
|
|
@@ -432,8 +435,8 @@ static void testServerDisconnectsClient() {
|
|
|
s.tick();
|
|
s.tick();
|
|
|
Core::Clock::sleepMillis(10);
|
|
Core::Clock::sleepMillis(10);
|
|
|
}
|
|
}
|
|
|
- TEST_FALSE(c.isConnected());
|
|
|
|
|
- TEST_TRUE(clientDisconnected);
|
|
|
|
|
|
|
+ Core::testFalse(c.isConnected());
|
|
|
|
|
+ Core::testTrue(clientDisconnected);
|
|
|
c.stop();
|
|
c.stop();
|
|
|
s.stop();
|
|
s.stop();
|
|
|
}
|
|
}
|
|
@@ -446,13 +449,13 @@ static void testClientClosesOnConnected() {
|
|
|
serverDisconnect = false;
|
|
serverDisconnect = false;
|
|
|
Server s;
|
|
Server s;
|
|
|
Client c;
|
|
Client c;
|
|
|
- TEST_FALSE(s.start(54'321, 5));
|
|
|
|
|
- TEST_FALSE(c.start());
|
|
|
|
|
|
|
+ Core::testFalse(s.start(54'321, 5));
|
|
|
|
|
+ Core::testFalse(c.start());
|
|
|
s.setDisconnectHandler(onServerDisconnect);
|
|
s.setDisconnectHandler(onServerDisconnect);
|
|
|
s.setConnectHandler(onConnectSetTimeout);
|
|
s.setConnectHandler(onConnectSetTimeout);
|
|
|
- TEST_FALSE(c.connect("127.0.0.1", 54'321, 50));
|
|
|
|
|
|
|
+ Core::testFalse(c.connect("127.0.0.1", 54'321, 50));
|
|
|
tickUntilConnected(s, c);
|
|
tickUntilConnected(s, c);
|
|
|
- TEST_TRUE(c.isConnected());
|
|
|
|
|
|
|
+ Core::testTrue(c.isConnected());
|
|
|
#ifdef ERROR_SIMULATOR
|
|
#ifdef ERROR_SIMULATOR
|
|
|
failCounter = 0;
|
|
failCounter = 0;
|
|
|
#endif
|
|
#endif
|
|
@@ -464,7 +467,7 @@ static void testClientClosesOnConnected() {
|
|
|
s.tick();
|
|
s.tick();
|
|
|
Core::Clock::sleepMillis(10);
|
|
Core::Clock::sleepMillis(10);
|
|
|
}
|
|
}
|
|
|
- TEST_TRUE(serverDisconnect);
|
|
|
|
|
|
|
+ Core::testTrue(serverDisconnect);
|
|
|
s.stop();
|
|
s.stop();
|
|
|
}
|
|
}
|
|
|
|
|
|
|
@@ -482,11 +485,11 @@ static void testDummyCallbacks() {
|
|
|
Client c;
|
|
Client c;
|
|
|
c.resetHandler();
|
|
c.resetHandler();
|
|
|
s.resetHandler();
|
|
s.resetHandler();
|
|
|
- TEST_FALSE(s.start(54'321, 5));
|
|
|
|
|
- TEST_FALSE(c.start());
|
|
|
|
|
- TEST_FALSE(c.connect("127.0.0.1", 54'321, 50));
|
|
|
|
|
|
|
+ Core::testFalse(s.start(54'321, 5));
|
|
|
|
|
+ Core::testFalse(c.start());
|
|
|
|
|
+ Core::testFalse(c.connect("127.0.0.1", 54'321, 50));
|
|
|
tickUntilConnected(s, c);
|
|
tickUntilConnected(s, c);
|
|
|
- TEST_TRUE(c.isConnected());
|
|
|
|
|
|
|
+ Core::testTrue(c.isConnected());
|
|
|
OutPacket out;
|
|
OutPacket out;
|
|
|
s.sendPacketBroadcast(out, Core::PacketSendMode::RELIABLE);
|
|
s.sendPacketBroadcast(out, Core::PacketSendMode::RELIABLE);
|
|
|
c.sendPacket(out, Core::PacketSendMode::RELIABLE);
|
|
c.sendPacket(out, Core::PacketSendMode::RELIABLE);
|