|
@@ -10,28 +10,28 @@
|
|
|
#define TEST_READ(Type, type, value) \
|
|
|
{ \
|
|
|
type u; \
|
|
|
- CORE_TEST_FALSE(coreReadInPacket##Type(&in, &u)); \
|
|
|
- CORE_TEST_TRUE(u == value); \
|
|
|
+ TEST_FALSE(readInPacket##Type(&in, &u)); \
|
|
|
+ TEST_TRUE(u == value); \
|
|
|
}
|
|
|
|
|
|
static void testWriteRead(void) {
|
|
|
- CoreOutPacket out;
|
|
|
- coreInitOutPacket(&out);
|
|
|
- coreWriteOutPacketU8(&out, 200);
|
|
|
- coreWriteOutPacketU16(&out, 6656);
|
|
|
- coreWriteOutPacketU32(&out, 348923689);
|
|
|
- coreWriteOutPacketI8(&out, 90);
|
|
|
- coreWriteOutPacketI8(&out, -35);
|
|
|
- coreWriteOutPacketI16(&out, 843);
|
|
|
- coreWriteOutPacketI16(&out, -8961);
|
|
|
- coreWriteOutPacketI32(&out, 100430199);
|
|
|
- coreWriteOutPacketI32(&out, -534534);
|
|
|
- coreWriteOutPacketFloat(&out, 64564.5346f);
|
|
|
+ OutPacket out;
|
|
|
+ initOutPacket(&out);
|
|
|
+ writeOutPacketU8(&out, 200);
|
|
|
+ writeOutPacketU16(&out, 6656);
|
|
|
+ writeOutPacketU32(&out, 348923689);
|
|
|
+ writeOutPacketI8(&out, 90);
|
|
|
+ writeOutPacketI8(&out, -35);
|
|
|
+ writeOutPacketI16(&out, 843);
|
|
|
+ writeOutPacketI16(&out, -8961);
|
|
|
+ writeOutPacketI32(&out, 100430199);
|
|
|
+ writeOutPacketI32(&out, -534534);
|
|
|
+ writeOutPacketFloat(&out, 64564.5346f);
|
|
|
const char s[] = "This is Great";
|
|
|
- coreWriteOutPacketString(&out, s);
|
|
|
+ writeOutPacketString(&out, s);
|
|
|
|
|
|
- CoreInPacket in;
|
|
|
- coreInitInPacket(&in, out.data.buffer, out.data.size);
|
|
|
+ InPacket in;
|
|
|
+ initInPacket(&in, out.data.buffer, out.data.size);
|
|
|
TEST_READ(U8, u8, 200)
|
|
|
TEST_READ(U16, u16, 6656)
|
|
|
TEST_READ(U32, u32, 348923689)
|
|
@@ -42,44 +42,44 @@ static void testWriteRead(void) {
|
|
|
TEST_READ(I32, i32, 100430199)
|
|
|
TEST_READ(I32, i32, -534534)
|
|
|
float f;
|
|
|
- CORE_TEST_FALSE(coreReadInPacketFloat(&in, &f));
|
|
|
- CORE_TEST_FLOAT(64564.5346f, f, 0.00001f);
|
|
|
+ TEST_FALSE(readInPacketFloat(&in, &f));
|
|
|
+ TEST_FLOAT(64564.5346f, f, 0.00001f);
|
|
|
char buffer[256];
|
|
|
- size_t n = coreReadInPacketString(&in, buffer, sizeof(buffer));
|
|
|
- CORE_TEST_SIZE(14, n);
|
|
|
- CORE_TEST_STRING(s, buffer);
|
|
|
-
|
|
|
- CORE_TEST_TRUE(coreReadInPacketU8(&in, &(u8){0}));
|
|
|
- CORE_TEST_TRUE(coreReadInPacketU16(&in, &(u16){0}));
|
|
|
- CORE_TEST_TRUE(coreReadInPacketU32(&in, &(u32){0}));
|
|
|
- CORE_TEST_TRUE(coreReadInPacketI8(&in, &(i8){0}));
|
|
|
- CORE_TEST_TRUE(coreReadInPacketI16(&in, &(i16){0}));
|
|
|
- CORE_TEST_TRUE(coreReadInPacketI32(&in, &(i32){0}));
|
|
|
- CORE_TEST_TRUE(coreReadInPacketFloat(&in, &(float){0}));
|
|
|
- CORE_TEST_SIZE(0, coreReadInPacketString(&in, nullptr, 0));
|
|
|
- CORE_TEST_SIZE(0, coreReadInPacketString(&in, buffer, sizeof(buffer)));
|
|
|
-
|
|
|
- coreDestroyOutPacket(&out);
|
|
|
+ size_t n = readInPacketString(&in, buffer, sizeof(buffer));
|
|
|
+ TEST_SIZE(14, n);
|
|
|
+ TEST_STRING(s, buffer);
|
|
|
+
|
|
|
+ TEST_TRUE(readInPacketU8(&in, &(u8){0}));
|
|
|
+ TEST_TRUE(readInPacketU16(&in, &(u16){0}));
|
|
|
+ TEST_TRUE(readInPacketU32(&in, &(u32){0}));
|
|
|
+ TEST_TRUE(readInPacketI8(&in, &(i8){0}));
|
|
|
+ TEST_TRUE(readInPacketI16(&in, &(i16){0}));
|
|
|
+ TEST_TRUE(readInPacketI32(&in, &(i32){0}));
|
|
|
+ TEST_TRUE(readInPacketFloat(&in, &(float){0}));
|
|
|
+ TEST_SIZE(0, readInPacketString(&in, nullptr, 0));
|
|
|
+ TEST_SIZE(0, readInPacketString(&in, buffer, sizeof(buffer)));
|
|
|
+
|
|
|
+ destroyOutPacket(&out);
|
|
|
}
|
|
|
|
|
|
static void testTooShortBuffer(void) {
|
|
|
- CoreOutPacket out;
|
|
|
- coreInitOutPacket(&out);
|
|
|
- coreWriteOutPacketString(&out, "This is Great");
|
|
|
- coreWriteOutPacketString(&out, "Well hoho");
|
|
|
+ OutPacket out;
|
|
|
+ initOutPacket(&out);
|
|
|
+ writeOutPacketString(&out, "This is Great");
|
|
|
+ writeOutPacketString(&out, "Well hoho");
|
|
|
|
|
|
- CoreInPacket in;
|
|
|
- coreInitInPacket(&in, out.data.buffer, out.data.size);
|
|
|
+ InPacket in;
|
|
|
+ initInPacket(&in, out.data.buffer, out.data.size);
|
|
|
char buffer[8];
|
|
|
- size_t n = coreReadInPacketString(&in, buffer, sizeof(buffer));
|
|
|
- CORE_TEST_SIZE(14, n);
|
|
|
- CORE_TEST_STRING("This is", buffer);
|
|
|
+ size_t n = readInPacketString(&in, buffer, sizeof(buffer));
|
|
|
+ TEST_SIZE(14, n);
|
|
|
+ TEST_STRING("This is", buffer);
|
|
|
char buffer2[6];
|
|
|
- size_t n2 = coreReadInPacketString(&in, buffer2, sizeof(buffer2));
|
|
|
- CORE_TEST_SIZE(10, n2);
|
|
|
- CORE_TEST_STRING("Well ", buffer2);
|
|
|
+ size_t n2 = readInPacketString(&in, buffer2, sizeof(buffer2));
|
|
|
+ TEST_SIZE(10, n2);
|
|
|
+ TEST_STRING("Well ", buffer2);
|
|
|
|
|
|
- coreDestroyOutPacket(&out);
|
|
|
+ destroyOutPacket(&out);
|
|
|
}
|
|
|
|
|
|
typedef struct {
|
|
@@ -88,48 +88,48 @@ typedef struct {
|
|
|
} PacketTest;
|
|
|
|
|
|
static void testBinaryData(void) {
|
|
|
- CoreOutPacket out;
|
|
|
- coreInitOutPacket(&out);
|
|
|
+ OutPacket out;
|
|
|
+ initOutPacket(&out);
|
|
|
PacketTest data = {56, 3};
|
|
|
- coreWriteOutPacket(&out, &data, sizeof(data));
|
|
|
+ writeOutPacket(&out, &data, sizeof(data));
|
|
|
|
|
|
- CoreInPacket in;
|
|
|
- coreInitInPacket(&in, out.data.buffer, out.data.size);
|
|
|
+ InPacket in;
|
|
|
+ initInPacket(&in, out.data.buffer, out.data.size);
|
|
|
|
|
|
PacketTest inData;
|
|
|
- CORE_TEST_FALSE(coreReadInPacket(&in, &inData, sizeof(inData)));
|
|
|
- CORE_TEST_TRUE(memcmp(&inData, &data, sizeof(inData)) == 0);
|
|
|
+ TEST_FALSE(readInPacket(&in, &inData, sizeof(inData)));
|
|
|
+ TEST_TRUE(memcmp(&inData, &data, sizeof(inData)) == 0);
|
|
|
|
|
|
- coreDestroyOutPacket(&out);
|
|
|
+ destroyOutPacket(&out);
|
|
|
}
|
|
|
|
|
|
static void testShortString(void) {
|
|
|
- CoreOutPacket out;
|
|
|
- coreInitOutPacket(&out);
|
|
|
- coreWriteOutPacketU16(&out, 200);
|
|
|
- coreWriteOutPacketU16(&out, 65535);
|
|
|
+ OutPacket out;
|
|
|
+ initOutPacket(&out);
|
|
|
+ writeOutPacketU16(&out, 200);
|
|
|
+ writeOutPacketU16(&out, 65535);
|
|
|
|
|
|
- CoreInPacket in;
|
|
|
- coreInitInPacket(&in, out.data.buffer, out.data.size);
|
|
|
+ InPacket in;
|
|
|
+ initInPacket(&in, out.data.buffer, out.data.size);
|
|
|
|
|
|
char buffer[256];
|
|
|
- size_t n = coreReadInPacketString(&in, buffer, sizeof(buffer));
|
|
|
- CORE_TEST_SIZE(200, n);
|
|
|
- CORE_TEST_STRING("", buffer);
|
|
|
+ size_t n = readInPacketString(&in, buffer, sizeof(buffer));
|
|
|
+ TEST_SIZE(200, n);
|
|
|
+ TEST_STRING("", buffer);
|
|
|
|
|
|
- coreDestroyOutPacket(&out);
|
|
|
+ destroyOutPacket(&out);
|
|
|
}
|
|
|
|
|
|
-static void tickClient(int ticks) {
|
|
|
+static void tickClientN(int ticks) {
|
|
|
for(int i = 0; i < ticks; i++) {
|
|
|
- coreTickClient();
|
|
|
+ tickClient();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
static void tick(int ticks) {
|
|
|
for(int i = 0; i < ticks; i++) {
|
|
|
- coreTickClient();
|
|
|
- coreTickServer();
|
|
|
+ tickClient();
|
|
|
+ tickServer();
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -151,37 +151,37 @@ static i32 data9 = 0;
|
|
|
static char data10[20];
|
|
|
static float data11 = 0.0f;
|
|
|
|
|
|
-static void onServerConnect(CoreClient) {
|
|
|
+static void onServerConnect(Client) {
|
|
|
serverConnected = true;
|
|
|
}
|
|
|
|
|
|
-static void onServerDisconnect(CoreClient) {
|
|
|
+static void onServerDisconnect(Client) {
|
|
|
serverDisconnect = true;
|
|
|
}
|
|
|
|
|
|
-static void onServerPacket(CoreClient client, CoreInPacket* in) {
|
|
|
- CORE_TEST_FALSE(coreReadInPacketU8(in, &data1));
|
|
|
- CORE_TEST_FALSE(coreReadInPacketU16(in, &data2));
|
|
|
- CORE_TEST_FALSE(coreReadInPacketU32(in, &data3));
|
|
|
- CORE_TEST_FALSE(coreReadInPacketI8(in, &data4));
|
|
|
- CORE_TEST_FALSE(coreReadInPacketI16(in, &data5));
|
|
|
- CORE_TEST_FALSE(coreReadInPacketI32(in, &data6));
|
|
|
- CORE_TEST_FALSE(coreReadInPacketI8(in, &data7));
|
|
|
- CORE_TEST_FALSE(coreReadInPacketI16(in, &data8));
|
|
|
- CORE_TEST_FALSE(coreReadInPacketI32(in, &data9));
|
|
|
- CORE_TEST_SIZE(9, coreReadInPacketString(in, data10, sizeof(data10)));
|
|
|
- CORE_TEST_FALSE(coreReadInPacketFloat(in, &data11));
|
|
|
-
|
|
|
- CoreOutPacket out;
|
|
|
- coreInitOutPacket(&out);
|
|
|
+static void onServerPacket(Client client, InPacket* in) {
|
|
|
+ TEST_FALSE(readInPacketU8(in, &data1));
|
|
|
+ TEST_FALSE(readInPacketU16(in, &data2));
|
|
|
+ TEST_FALSE(readInPacketU32(in, &data3));
|
|
|
+ TEST_FALSE(readInPacketI8(in, &data4));
|
|
|
+ TEST_FALSE(readInPacketI16(in, &data5));
|
|
|
+ TEST_FALSE(readInPacketI32(in, &data6));
|
|
|
+ TEST_FALSE(readInPacketI8(in, &data7));
|
|
|
+ TEST_FALSE(readInPacketI16(in, &data8));
|
|
|
+ TEST_FALSE(readInPacketI32(in, &data9));
|
|
|
+ TEST_SIZE(9, readInPacketString(in, data10, sizeof(data10)));
|
|
|
+ TEST_FALSE(readInPacketFloat(in, &data11));
|
|
|
+
|
|
|
+ OutPacket out;
|
|
|
+ initOutPacket(&out);
|
|
|
if(packageCounter == 0) {
|
|
|
- coreSendServerPacket(client, &out, CORE_RELIABLE);
|
|
|
+ sendServerPacket(client, &out, PACKET_RELIABLE);
|
|
|
} else if(packageCounter == 1) {
|
|
|
- coreSendServerPacket(client, &out, CORE_SEQUENCED);
|
|
|
+ sendServerPacket(client, &out, PACKET_SEQUENCED);
|
|
|
} else if(packageCounter == 2) {
|
|
|
- coreSendServerPacket(client, &out, CORE_UNSEQUENCED);
|
|
|
+ sendServerPacket(client, &out, PACKET_UNSEQUENCED);
|
|
|
}
|
|
|
- coreDestroyOutPacket(&out);
|
|
|
+ destroyOutPacket(&out);
|
|
|
packageCounter++;
|
|
|
}
|
|
|
|
|
@@ -193,11 +193,11 @@ static void onClientDisconnect() {
|
|
|
clientDisconnected = true;
|
|
|
}
|
|
|
|
|
|
-static void onClientPacket(CoreInPacket*) {
|
|
|
+static void onClientPacket(InPacket*) {
|
|
|
clientPackage = true;
|
|
|
}
|
|
|
|
|
|
-static void testConnect(CorePacketSendMode mode) {
|
|
|
+static void testConnect(PacketSendMode mode) {
|
|
|
clientConnected = false;
|
|
|
clientDisconnected = false;
|
|
|
clientPackage = false;
|
|
@@ -215,73 +215,73 @@ static void testConnect(CorePacketSendMode mode) {
|
|
|
*data10 = '\0';
|
|
|
data11 = 0.0f;
|
|
|
|
|
|
- coreResetServerHandler();
|
|
|
- coreSetServerConnectHandler(onServerConnect);
|
|
|
- coreSetServerDisconnectHandler(onServerDisconnect);
|
|
|
- coreSetServerPacketHandler(onServerPacket);
|
|
|
+ resetServerHandler();
|
|
|
+ setServerConnectHandler(onServerConnect);
|
|
|
+ setServerDisconnectHandler(onServerDisconnect);
|
|
|
+ setServerPacketHandler(onServerPacket);
|
|
|
|
|
|
- coreResetClientHandler();
|
|
|
- coreSetClientConnectHandler(onClientConnect);
|
|
|
- coreSetClientDisconnectHandler(onClientDisconnect);
|
|
|
- coreSetClientPacketHandler(onClientPacket);
|
|
|
+ resetClientHandler();
|
|
|
+ setClientConnectHandler(onClientConnect);
|
|
|
+ setClientDisconnectHandler(onClientDisconnect);
|
|
|
+ setClientPacketHandler(onClientPacket);
|
|
|
|
|
|
- if(!CORE_TEST_FALSE(coreStartServer(54321, 5))) {
|
|
|
+ if(!TEST_FALSE(startServer(54321, 5))) {
|
|
|
return;
|
|
|
- } else if(!CORE_TEST_FALSE(coreStartClient())) {
|
|
|
+ } else if(!TEST_FALSE(startClient())) {
|
|
|
return;
|
|
|
- } else if(!CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 90))) {
|
|
|
+ } else if(!TEST_FALSE(connectClient("127.0.0.1", 54321, 90))) {
|
|
|
return;
|
|
|
}
|
|
|
- CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
- CORE_TEST_TRUE(coreIsClientConnecting());
|
|
|
+ TEST_FALSE(isClientConnected());
|
|
|
+ TEST_TRUE(isClientConnecting());
|
|
|
tick(100);
|
|
|
- CORE_TEST_TRUE(clientConnected);
|
|
|
- CORE_TEST_TRUE(coreIsClientConnected());
|
|
|
- CORE_TEST_FALSE(coreIsClientConnecting());
|
|
|
-
|
|
|
- CoreOutPacket out;
|
|
|
- coreInitOutPacket(&out);
|
|
|
- coreWriteOutPacketU8(&out, 0xF1);
|
|
|
- coreWriteOutPacketU16(&out, 0xF123);
|
|
|
- coreWriteOutPacketU32(&out, 0xF1234567);
|
|
|
- coreWriteOutPacketI8(&out, -0x71);
|
|
|
- coreWriteOutPacketI16(&out, -0x7123);
|
|
|
- coreWriteOutPacketI32(&out, -0x71234567);
|
|
|
- coreWriteOutPacketI8(&out, 0x71);
|
|
|
- coreWriteOutPacketI16(&out, 0x7123);
|
|
|
- coreWriteOutPacketI32(&out, 0x71234567);
|
|
|
+ TEST_TRUE(clientConnected);
|
|
|
+ TEST_TRUE(isClientConnected());
|
|
|
+ TEST_FALSE(isClientConnecting());
|
|
|
+
|
|
|
+ OutPacket out;
|
|
|
+ initOutPacket(&out);
|
|
|
+ writeOutPacketU8(&out, 0xF1);
|
|
|
+ writeOutPacketU16(&out, 0xF123);
|
|
|
+ writeOutPacketU32(&out, 0xF1234567);
|
|
|
+ writeOutPacketI8(&out, -0x71);
|
|
|
+ writeOutPacketI16(&out, -0x7123);
|
|
|
+ writeOutPacketI32(&out, -0x71234567);
|
|
|
+ writeOutPacketI8(&out, 0x71);
|
|
|
+ writeOutPacketI16(&out, 0x7123);
|
|
|
+ writeOutPacketI32(&out, 0x71234567);
|
|
|
const char s[] = "Hi there";
|
|
|
- coreWriteOutPacketString(&out, s);
|
|
|
- coreWriteOutPacketFloat(&out, 252345.983f);
|
|
|
- coreSendClientPacket(&out, mode);
|
|
|
- coreDestroyOutPacket(&out);
|
|
|
+ writeOutPacketString(&out, s);
|
|
|
+ writeOutPacketFloat(&out, 252345.983f);
|
|
|
+ sendClientPacket(&out, mode);
|
|
|
+ destroyOutPacket(&out);
|
|
|
|
|
|
tick(100);
|
|
|
|
|
|
- CORE_TEST_TRUE(clientPackage);
|
|
|
- CORE_TEST_TRUE(serverConnected);
|
|
|
-
|
|
|
- CORE_TEST_U64(0xF1, data1);
|
|
|
- CORE_TEST_U64(0xF123, data2);
|
|
|
- CORE_TEST_U64(0xF1234567, data3);
|
|
|
- CORE_TEST_I64(-0x71, data4);
|
|
|
- CORE_TEST_I64(-0x7123, data5);
|
|
|
- CORE_TEST_I64(-0x71234567, data6);
|
|
|
- CORE_TEST_I64(0x71, data7);
|
|
|
- CORE_TEST_I64(0x7123, data8);
|
|
|
- CORE_TEST_I64(0x71234567, data9);
|
|
|
- CORE_TEST_STRING(s, data10);
|
|
|
- CORE_TEST_FLOAT(252345.983f, data11, 0.01f);
|
|
|
-
|
|
|
- coreDisconnectClient(90);
|
|
|
- CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
- CORE_TEST_FALSE(coreIsClientConnecting());
|
|
|
+ TEST_TRUE(clientPackage);
|
|
|
+ TEST_TRUE(serverConnected);
|
|
|
+
|
|
|
+ TEST_U64(0xF1, data1);
|
|
|
+ TEST_U64(0xF123, data2);
|
|
|
+ TEST_U64(0xF1234567, data3);
|
|
|
+ TEST_I64(-0x71, data4);
|
|
|
+ TEST_I64(-0x7123, data5);
|
|
|
+ TEST_I64(-0x71234567, data6);
|
|
|
+ TEST_I64(0x71, data7);
|
|
|
+ TEST_I64(0x7123, data8);
|
|
|
+ TEST_I64(0x71234567, data9);
|
|
|
+ TEST_STRING(s, data10);
|
|
|
+ TEST_FLOAT(252345.983f, data11, 0.01f);
|
|
|
+
|
|
|
+ disconnectClient(90);
|
|
|
+ TEST_FALSE(isClientConnected());
|
|
|
+ TEST_FALSE(isClientConnecting());
|
|
|
tick(100);
|
|
|
- CORE_TEST_TRUE(clientDisconnected);
|
|
|
- CORE_TEST_TRUE(serverDisconnect);
|
|
|
+ TEST_TRUE(clientDisconnected);
|
|
|
+ TEST_TRUE(serverDisconnect);
|
|
|
|
|
|
- coreStopClient();
|
|
|
- coreStopServer();
|
|
|
+ stopClient();
|
|
|
+ stopServer();
|
|
|
}
|
|
|
|
|
|
static bool disconnected = false;
|
|
@@ -292,204 +292,204 @@ static void testStopDisconnect(void) {
|
|
|
|
|
|
static void testDisconnect(void) {
|
|
|
disconnected = false;
|
|
|
- coreResetClientHandler();
|
|
|
- coreSetClientDisconnectHandler(testStopDisconnect);
|
|
|
- if(!CORE_TEST_FALSE(coreStartClient())) {
|
|
|
+ resetClientHandler();
|
|
|
+ setClientDisconnectHandler(testStopDisconnect);
|
|
|
+ if(!TEST_FALSE(startClient())) {
|
|
|
return;
|
|
|
- } else if(!CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 90))) {
|
|
|
+ } else if(!TEST_FALSE(connectClient("127.0.0.1", 54321, 90))) {
|
|
|
return;
|
|
|
}
|
|
|
- CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
- CORE_TEST_TRUE(coreIsClientConnecting());
|
|
|
- coreDisconnectClient(50);
|
|
|
- tickClient(100);
|
|
|
- CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
- CORE_TEST_FALSE(coreIsClientConnecting());
|
|
|
- CORE_TEST_TRUE(disconnected);
|
|
|
- coreStopClient();
|
|
|
+ TEST_FALSE(isClientConnected());
|
|
|
+ TEST_TRUE(isClientConnecting());
|
|
|
+ disconnectClient(50);
|
|
|
+ tickClientN(100);
|
|
|
+ TEST_FALSE(isClientConnected());
|
|
|
+ TEST_FALSE(isClientConnecting());
|
|
|
+ TEST_TRUE(disconnected);
|
|
|
+ stopClient();
|
|
|
}
|
|
|
|
|
|
static void testStop(void) {
|
|
|
disconnected = false;
|
|
|
- coreResetClientHandler();
|
|
|
- coreSetClientDisconnectHandler(testStopDisconnect);
|
|
|
- if(!CORE_TEST_FALSE(coreStartClient())) {
|
|
|
+ resetClientHandler();
|
|
|
+ setClientDisconnectHandler(testStopDisconnect);
|
|
|
+ if(!TEST_FALSE(startClient())) {
|
|
|
return;
|
|
|
- } else if(!CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 90))) {
|
|
|
+ } else if(!TEST_FALSE(connectClient("127.0.0.1", 54321, 90))) {
|
|
|
return;
|
|
|
}
|
|
|
- CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
- CORE_TEST_TRUE(coreIsClientConnecting());
|
|
|
- coreStopClient();
|
|
|
- CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
- CORE_TEST_FALSE(coreIsClientConnecting());
|
|
|
- CORE_TEST_TRUE(disconnected);
|
|
|
+ TEST_FALSE(isClientConnected());
|
|
|
+ TEST_TRUE(isClientConnecting());
|
|
|
+ stopClient();
|
|
|
+ TEST_FALSE(isClientConnected());
|
|
|
+ TEST_FALSE(isClientConnecting());
|
|
|
+ TEST_TRUE(disconnected);
|
|
|
}
|
|
|
|
|
|
static void testClientStartFails(void) {
|
|
|
- CORE_TEST_FALSE(coreStartClient());
|
|
|
+ TEST_FALSE(startClient());
|
|
|
logLevel = LOG_NONE;
|
|
|
- CORE_TEST_TRUE(coreStartClient());
|
|
|
- coreStopClient();
|
|
|
+ TEST_TRUE(startClient());
|
|
|
+ stopClient();
|
|
|
#ifdef ERROR_SIMULATOR
|
|
|
- coreFailCounter = 0;
|
|
|
- CORE_TEST_TRUE(coreStartClient());
|
|
|
- coreFailCounter = 1;
|
|
|
- CORE_TEST_TRUE(coreStartClient());
|
|
|
- coreFailCounter = -1;
|
|
|
+ failCounter = 0;
|
|
|
+ TEST_TRUE(startClient());
|
|
|
+ failCounter = 1;
|
|
|
+ TEST_TRUE(startClient());
|
|
|
+ failCounter = -1;
|
|
|
#endif
|
|
|
logLevel = LOG_DEBUG;
|
|
|
}
|
|
|
|
|
|
static void testClientConnectionFails(void) {
|
|
|
- coreResetClientHandler();
|
|
|
+ resetClientHandler();
|
|
|
logLevel = LOG_NONE;
|
|
|
- CORE_TEST_TRUE(coreConnectClient("", 54321, 100));
|
|
|
- CORE_TEST_FALSE(coreStartClient());
|
|
|
+ TEST_TRUE(connectClient("", 54321, 100));
|
|
|
+ TEST_FALSE(startClient());
|
|
|
#ifdef ERROR_SIMULATOR
|
|
|
- coreFailCounter = 0;
|
|
|
- CORE_TEST_TRUE(coreConnectClient("", 54321, 100));
|
|
|
- coreFailCounter = -1;
|
|
|
+ failCounter = 0;
|
|
|
+ TEST_TRUE(connectClient("", 54321, 100));
|
|
|
+ failCounter = -1;
|
|
|
#endif
|
|
|
- CORE_TEST_FALSE(coreConnectClient("", 54321, 100));
|
|
|
- CORE_TEST_TRUE(coreConnectClient("", 54321, 100));
|
|
|
+ TEST_FALSE(connectClient("", 54321, 100));
|
|
|
+ TEST_TRUE(connectClient("", 54321, 100));
|
|
|
logLevel = LOG_DEBUG;
|
|
|
- tickClient(100);
|
|
|
- coreStopClient();
|
|
|
+ tickClientN(100);
|
|
|
+ stopClient();
|
|
|
}
|
|
|
|
|
|
static void testInvalidClientAccess(void) {
|
|
|
- coreDisconnectClient(0);
|
|
|
- coreSendClientPacket(nullptr, 0);
|
|
|
- coreTickClient();
|
|
|
+ disconnectClient(0);
|
|
|
+ sendClientPacket(nullptr, 0);
|
|
|
+ tickClient();
|
|
|
}
|
|
|
|
|
|
static void testServerStartFails(void) {
|
|
|
logLevel = LOG_NONE;
|
|
|
- CORE_TEST_TRUE(coreStartServer(54321, 0));
|
|
|
+ TEST_TRUE(startServer(54321, 0));
|
|
|
#ifdef ERROR_SIMULATOR
|
|
|
- coreFailCounter = 0;
|
|
|
- CORE_TEST_TRUE(coreStartServer(54321, 5));
|
|
|
- coreFailCounter = 1;
|
|
|
- CORE_TEST_TRUE(coreStartServer(54321, 5));
|
|
|
- coreFailCounter = -1;
|
|
|
+ failCounter = 0;
|
|
|
+ TEST_TRUE(startServer(54321, 5));
|
|
|
+ failCounter = 1;
|
|
|
+ TEST_TRUE(startServer(54321, 5));
|
|
|
+ failCounter = -1;
|
|
|
#endif
|
|
|
- CORE_TEST_FALSE(coreStartServer(54321, 5));
|
|
|
- CORE_TEST_TRUE(coreStartServer(54321, 5));
|
|
|
+ TEST_FALSE(startServer(54321, 5));
|
|
|
+ TEST_TRUE(startServer(54321, 5));
|
|
|
logLevel = LOG_DEBUG;
|
|
|
- coreStopServer();
|
|
|
+ stopServer();
|
|
|
}
|
|
|
|
|
|
static void testServerClosesOnConnected(void) {
|
|
|
clientDisconnected = false;
|
|
|
- CORE_TEST_FALSE(coreStartServer(54321, 5));
|
|
|
- CORE_TEST_FALSE(coreStartClient());
|
|
|
- coreSetClientDisconnectHandler(onClientDisconnect);
|
|
|
- CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 50));
|
|
|
+ TEST_FALSE(startServer(54321, 5));
|
|
|
+ TEST_FALSE(startClient());
|
|
|
+ setClientDisconnectHandler(onClientDisconnect);
|
|
|
+ TEST_FALSE(connectClient("127.0.0.1", 54321, 50));
|
|
|
tick(100);
|
|
|
- CORE_TEST_TRUE(coreIsClientConnected());
|
|
|
- coreStopServer();
|
|
|
+ TEST_TRUE(isClientConnected());
|
|
|
+ stopServer();
|
|
|
|
|
|
- coreSetClientTimeout(500, 500, 500);
|
|
|
- for(int i = 0; i < 500 && coreIsClientConnected(); i++) {
|
|
|
- coreTickClient();
|
|
|
- coreSleepNanos(10000000);
|
|
|
+ setClientTimeout(500, 500, 500);
|
|
|
+ for(int i = 0; i < 500 && isClientConnected(); i++) {
|
|
|
+ tickClient();
|
|
|
+ sleepNanos(10000000);
|
|
|
}
|
|
|
- CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
- CORE_TEST_TRUE(clientDisconnected);
|
|
|
- coreStopClient();
|
|
|
+ TEST_FALSE(isClientConnected());
|
|
|
+ TEST_TRUE(clientDisconnected);
|
|
|
+ stopClient();
|
|
|
}
|
|
|
|
|
|
-static CoreClient clientId = 0;
|
|
|
+static Client clientId = 0;
|
|
|
|
|
|
-static void onConnectSetClient(CoreClient client) {
|
|
|
+static void onConnectSetClient(Client client) {
|
|
|
clientId = client;
|
|
|
}
|
|
|
|
|
|
static void testServerDisconnectsClient(void) {
|
|
|
clientDisconnected = false;
|
|
|
- CORE_TEST_FALSE(coreStartServer(54321, 5));
|
|
|
- CORE_TEST_FALSE(coreStartClient());
|
|
|
- coreSetClientDisconnectHandler(onClientDisconnect);
|
|
|
- coreSetServerConnectHandler(onConnectSetClient);
|
|
|
- CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 50));
|
|
|
+ TEST_FALSE(startServer(54321, 5));
|
|
|
+ TEST_FALSE(startClient());
|
|
|
+ setClientDisconnectHandler(onClientDisconnect);
|
|
|
+ setServerConnectHandler(onConnectSetClient);
|
|
|
+ TEST_FALSE(connectClient("127.0.0.1", 54321, 50));
|
|
|
tick(100);
|
|
|
- CORE_TEST_TRUE(coreIsClientConnected());
|
|
|
+ TEST_TRUE(isClientConnected());
|
|
|
|
|
|
- coreDisconnectServerClient(clientId);
|
|
|
+ disconnectServerClient(clientId);
|
|
|
|
|
|
- for(int i = 0; i < 500 && coreIsClientConnected(); i++) {
|
|
|
- coreTickClient();
|
|
|
- coreTickServer();
|
|
|
- coreSleepNanos(10000000);
|
|
|
+ for(int i = 0; i < 500 && isClientConnected(); i++) {
|
|
|
+ tickClient();
|
|
|
+ tickServer();
|
|
|
+ sleepNanos(10000000);
|
|
|
}
|
|
|
- CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
- CORE_TEST_TRUE(clientDisconnected);
|
|
|
- coreStopClient();
|
|
|
- coreStopServer();
|
|
|
+ TEST_FALSE(isClientConnected());
|
|
|
+ TEST_TRUE(clientDisconnected);
|
|
|
+ stopClient();
|
|
|
+ stopServer();
|
|
|
}
|
|
|
|
|
|
-static void onConnectSetTimeout(CoreClient client) {
|
|
|
- coreServerTimeout(client, 500, 500, 500);
|
|
|
+static void onConnectSetTimeout(Client client) {
|
|
|
+ setServerTimeout(client, 500, 500, 500);
|
|
|
}
|
|
|
|
|
|
static void testClientClosesOnConnected(void) {
|
|
|
serverDisconnect = false;
|
|
|
- CORE_TEST_FALSE(coreStartServer(54321, 5));
|
|
|
- CORE_TEST_FALSE(coreStartClient());
|
|
|
- coreSetServerDisconnectHandler(onServerDisconnect);
|
|
|
- coreSetServerConnectHandler(onConnectSetTimeout);
|
|
|
- CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 50));
|
|
|
+ TEST_FALSE(startServer(54321, 5));
|
|
|
+ TEST_FALSE(startClient());
|
|
|
+ setServerDisconnectHandler(onServerDisconnect);
|
|
|
+ setServerConnectHandler(onConnectSetTimeout);
|
|
|
+ TEST_FALSE(connectClient("127.0.0.1", 54321, 50));
|
|
|
tick(100);
|
|
|
- CORE_TEST_TRUE(coreIsClientConnected());
|
|
|
+ TEST_TRUE(isClientConnected());
|
|
|
#ifdef ERROR_SIMULATOR
|
|
|
- coreFailCounter = 0;
|
|
|
+ failCounter = 0;
|
|
|
#endif
|
|
|
- coreStopClient();
|
|
|
+ stopClient();
|
|
|
#ifdef ERROR_SIMULATOR
|
|
|
- coreFailCounter = -1;
|
|
|
+ failCounter = -1;
|
|
|
#endif
|
|
|
for(int i = 0; i < 500 && !serverDisconnect; i++) {
|
|
|
- coreTickServer();
|
|
|
- coreSleepNanos(10000000);
|
|
|
+ tickServer();
|
|
|
+ sleepNanos(10000000);
|
|
|
}
|
|
|
- CORE_TEST_TRUE(serverDisconnect);
|
|
|
- coreStopServer();
|
|
|
+ TEST_TRUE(serverDisconnect);
|
|
|
+ stopServer();
|
|
|
}
|
|
|
|
|
|
static void testInvalidServerAccess(void) {
|
|
|
- coreTickServer();
|
|
|
- coreSendServerPacket(0, nullptr, 0);
|
|
|
- coreServerTimeout(0, 500, 500, 500);
|
|
|
- coreDisconnectServerClient(0);
|
|
|
+ tickServer();
|
|
|
+ sendServerPacket(0, nullptr, 0);
|
|
|
+ setServerTimeout(0, 500, 500, 500);
|
|
|
+ disconnectServerClient(0);
|
|
|
}
|
|
|
|
|
|
static void testDummyCallbacks(void) {
|
|
|
- coreResetClientHandler();
|
|
|
- coreResetServerHandler();
|
|
|
- CORE_TEST_FALSE(coreStartServer(54321, 5));
|
|
|
- CORE_TEST_FALSE(coreStartClient());
|
|
|
- CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 50));
|
|
|
+ resetClientHandler();
|
|
|
+ resetServerHandler();
|
|
|
+ TEST_FALSE(startServer(54321, 5));
|
|
|
+ TEST_FALSE(startClient());
|
|
|
+ TEST_FALSE(connectClient("127.0.0.1", 54321, 50));
|
|
|
tick(100);
|
|
|
- CORE_TEST_TRUE(coreIsClientConnected());
|
|
|
- CoreOutPacket out;
|
|
|
- coreInitOutPacket(&out);
|
|
|
- coreSendServerPacketBroadcast(&out, CORE_RELIABLE);
|
|
|
- coreSendClientPacket(&out, CORE_RELIABLE);
|
|
|
+ TEST_TRUE(isClientConnected());
|
|
|
+ OutPacket out;
|
|
|
+ initOutPacket(&out);
|
|
|
+ sendServerPacketBroadcast(&out, PACKET_RELIABLE);
|
|
|
+ sendClientPacket(&out, PACKET_RELIABLE);
|
|
|
tick(100);
|
|
|
- coreDestroyOutPacket(&out);
|
|
|
- coreStopClient();
|
|
|
- coreStopServer();
|
|
|
+ destroyOutPacket(&out);
|
|
|
+ stopClient();
|
|
|
+ stopServer();
|
|
|
}
|
|
|
|
|
|
-void coreTestNetwork(void) {
|
|
|
+void testNetwork(void) {
|
|
|
testWriteRead();
|
|
|
testTooShortBuffer();
|
|
|
testBinaryData();
|
|
|
testShortString();
|
|
|
- testConnect(CORE_UNSEQUENCED);
|
|
|
- testConnect(CORE_SEQUENCED);
|
|
|
- testConnect(CORE_RELIABLE);
|
|
|
+ testConnect(PACKET_UNSEQUENCED);
|
|
|
+ testConnect(PACKET_SEQUENCED);
|
|
|
+ testConnect(PACKET_RELIABLE);
|
|
|
testDisconnect();
|
|
|
testStop();
|
|
|
testClientStartFails();
|