|
@@ -10,25 +10,25 @@
|
|
|
#define TEST_READ(Type, type, value) \
|
|
|
{ \
|
|
|
type u; \
|
|
|
- CORE_TEST_FALSE(coreInPacketRead##Type(&in, &u)); \
|
|
|
+ CORE_TEST_FALSE(coreReadInPacket##Type(&in, &u)); \
|
|
|
CORE_TEST_TRUE(u == value); \
|
|
|
}
|
|
|
|
|
|
static void testWriteRead(void) {
|
|
|
CoreOutPacket out;
|
|
|
coreInitOutPacket(&out);
|
|
|
- coreOutPacketWriteU8(&out, 200);
|
|
|
- coreOutPacketWriteU16(&out, 6656);
|
|
|
- coreOutPacketWriteU32(&out, 348923689);
|
|
|
- coreOutPacketWriteI8(&out, 90);
|
|
|
- coreOutPacketWriteI8(&out, -35);
|
|
|
- coreOutPacketWriteI16(&out, 843);
|
|
|
- coreOutPacketWriteI16(&out, -8961);
|
|
|
- coreOutPacketWriteI32(&out, 100430199);
|
|
|
- coreOutPacketWriteI32(&out, -534534);
|
|
|
- coreOutPacketWriteFloat(&out, 64564.5346f);
|
|
|
+ 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);
|
|
|
const char s[] = "This is Great";
|
|
|
- coreOutPacketWriteString(&out, s);
|
|
|
+ coreWriteOutPacketString(&out, s);
|
|
|
|
|
|
CoreInPacket in;
|
|
|
coreInitInPacket(&in, out.data.buffer, out.data.size);
|
|
@@ -42,22 +42,22 @@ static void testWriteRead(void) {
|
|
|
TEST_READ(I32, i32, 100430199)
|
|
|
TEST_READ(I32, i32, -534534)
|
|
|
float f;
|
|
|
- CORE_TEST_FALSE(coreInPacketReadFloat(&in, &f));
|
|
|
+ CORE_TEST_FALSE(coreReadInPacketFloat(&in, &f));
|
|
|
CORE_TEST_FLOAT(64564.5346f, f, 0.00001f);
|
|
|
char buffer[256];
|
|
|
- size_t n = coreInPacketReadString(&in, buffer, sizeof(buffer));
|
|
|
+ size_t n = coreReadInPacketString(&in, buffer, sizeof(buffer));
|
|
|
CORE_TEST_SIZE(14, n);
|
|
|
CORE_TEST_STRING(s, buffer);
|
|
|
|
|
|
- CORE_TEST_TRUE(coreInPacketReadU8(&in, &(u8){0}));
|
|
|
- CORE_TEST_TRUE(coreInPacketReadU16(&in, &(u16){0}));
|
|
|
- CORE_TEST_TRUE(coreInPacketReadU32(&in, &(u32){0}));
|
|
|
- CORE_TEST_TRUE(coreInPacketReadI8(&in, &(i8){0}));
|
|
|
- CORE_TEST_TRUE(coreInPacketReadI16(&in, &(i16){0}));
|
|
|
- CORE_TEST_TRUE(coreInPacketReadI32(&in, &(i32){0}));
|
|
|
- CORE_TEST_TRUE(coreInPacketReadFloat(&in, &(float){0}));
|
|
|
- CORE_TEST_SIZE(0, coreInPacketReadString(&in, nullptr, 0));
|
|
|
- CORE_TEST_SIZE(0, coreInPacketReadString(&in, buffer, sizeof(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);
|
|
|
}
|
|
@@ -65,17 +65,17 @@ static void testWriteRead(void) {
|
|
|
static void testTooShortBuffer(void) {
|
|
|
CoreOutPacket out;
|
|
|
coreInitOutPacket(&out);
|
|
|
- coreOutPacketWriteString(&out, "This is Great");
|
|
|
- coreOutPacketWriteString(&out, "Well hoho");
|
|
|
+ coreWriteOutPacketString(&out, "This is Great");
|
|
|
+ coreWriteOutPacketString(&out, "Well hoho");
|
|
|
|
|
|
CoreInPacket in;
|
|
|
coreInitInPacket(&in, out.data.buffer, out.data.size);
|
|
|
char buffer[8];
|
|
|
- size_t n = coreInPacketReadString(&in, buffer, sizeof(buffer));
|
|
|
+ size_t n = coreReadInPacketString(&in, buffer, sizeof(buffer));
|
|
|
CORE_TEST_SIZE(14, n);
|
|
|
CORE_TEST_STRING("This is", buffer);
|
|
|
char buffer2[6];
|
|
|
- size_t n2 = coreInPacketReadString(&in, buffer2, sizeof(buffer2));
|
|
|
+ size_t n2 = coreReadInPacketString(&in, buffer2, sizeof(buffer2));
|
|
|
CORE_TEST_SIZE(10, n2);
|
|
|
CORE_TEST_STRING("Well ", buffer2);
|
|
|
|
|
@@ -91,13 +91,13 @@ static void testBinaryData(void) {
|
|
|
CoreOutPacket out;
|
|
|
coreInitOutPacket(&out);
|
|
|
PacketTest data = {56, 3};
|
|
|
- coreOutPacketWrite(&out, &data, sizeof(data));
|
|
|
+ coreWriteOutPacket(&out, &data, sizeof(data));
|
|
|
|
|
|
CoreInPacket in;
|
|
|
coreInitInPacket(&in, out.data.buffer, out.data.size);
|
|
|
|
|
|
PacketTest inData;
|
|
|
- CORE_TEST_FALSE(coreInPacketRead(&in, &inData, sizeof(inData)));
|
|
|
+ CORE_TEST_FALSE(coreReadInPacket(&in, &inData, sizeof(inData)));
|
|
|
CORE_TEST_TRUE(memcmp(&inData, &data, sizeof(inData)) == 0);
|
|
|
|
|
|
coreDestroyOutPacket(&out);
|
|
@@ -106,14 +106,14 @@ static void testBinaryData(void) {
|
|
|
static void testShortString(void) {
|
|
|
CoreOutPacket out;
|
|
|
coreInitOutPacket(&out);
|
|
|
- coreOutPacketWriteU16(&out, 200);
|
|
|
- coreOutPacketWriteU16(&out, 65535);
|
|
|
+ coreWriteOutPacketU16(&out, 200);
|
|
|
+ coreWriteOutPacketU16(&out, 65535);
|
|
|
|
|
|
CoreInPacket in;
|
|
|
coreInitInPacket(&in, out.data.buffer, out.data.size);
|
|
|
|
|
|
char buffer[256];
|
|
|
- size_t n = coreInPacketReadString(&in, buffer, sizeof(buffer));
|
|
|
+ size_t n = coreReadInPacketString(&in, buffer, sizeof(buffer));
|
|
|
CORE_TEST_SIZE(200, n);
|
|
|
CORE_TEST_STRING("", buffer);
|
|
|
|
|
@@ -122,14 +122,14 @@ static void testShortString(void) {
|
|
|
|
|
|
static void tickClient(int ticks) {
|
|
|
for(int i = 0; i < ticks; i++) {
|
|
|
- coreClientTick();
|
|
|
+ coreTickClient();
|
|
|
}
|
|
|
}
|
|
|
|
|
|
static void tick(int ticks) {
|
|
|
for(int i = 0; i < ticks; i++) {
|
|
|
- coreClientTick();
|
|
|
- coreServerTick();
|
|
|
+ coreTickClient();
|
|
|
+ coreTickServer();
|
|
|
}
|
|
|
}
|
|
|
|
|
@@ -160,26 +160,26 @@ static void onServerDisconnect(CoreClient) {
|
|
|
}
|
|
|
|
|
|
static void onServerPacket(CoreClient client, CoreInPacket* in) {
|
|
|
- CORE_TEST_FALSE(coreInPacketReadU8(in, &data1));
|
|
|
- CORE_TEST_FALSE(coreInPacketReadU16(in, &data2));
|
|
|
- CORE_TEST_FALSE(coreInPacketReadU32(in, &data3));
|
|
|
- CORE_TEST_FALSE(coreInPacketReadI8(in, &data4));
|
|
|
- CORE_TEST_FALSE(coreInPacketReadI16(in, &data5));
|
|
|
- CORE_TEST_FALSE(coreInPacketReadI32(in, &data6));
|
|
|
- CORE_TEST_FALSE(coreInPacketReadI8(in, &data7));
|
|
|
- CORE_TEST_FALSE(coreInPacketReadI16(in, &data8));
|
|
|
- CORE_TEST_FALSE(coreInPacketReadI32(in, &data9));
|
|
|
- CORE_TEST_SIZE(9, coreInPacketReadString(in, data10, sizeof(data10)));
|
|
|
- CORE_TEST_FALSE(coreInPacketReadFloat(in, &data11));
|
|
|
+ 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);
|
|
|
if(packageCounter == 0) {
|
|
|
- coreServerSend(client, &out, CORE_RELIABLE);
|
|
|
+ coreSendServerPacket(client, &out, CORE_RELIABLE);
|
|
|
} else if(packageCounter == 1) {
|
|
|
- coreServerSend(client, &out, CORE_SEQUENCED);
|
|
|
+ coreSendServerPacket(client, &out, CORE_SEQUENCED);
|
|
|
} else if(packageCounter == 2) {
|
|
|
- coreServerSend(client, &out, CORE_UNSEQUENCED);
|
|
|
+ coreSendServerPacket(client, &out, CORE_UNSEQUENCED);
|
|
|
}
|
|
|
coreDestroyOutPacket(&out);
|
|
|
packageCounter++;
|
|
@@ -215,45 +215,45 @@ static void testConnect(CorePacketSendMode mode) {
|
|
|
*data10 = '\0';
|
|
|
data11 = 0.0f;
|
|
|
|
|
|
- coreServerResetHandler();
|
|
|
- coreServerSetConnectHandler(onServerConnect);
|
|
|
- coreServerSetDisconnectHandler(onServerDisconnect);
|
|
|
- coreServerSetPacketHandler(onServerPacket);
|
|
|
+ coreResetServerHandler();
|
|
|
+ coreSetServerConnectHandler(onServerConnect);
|
|
|
+ coreSetServerDisconnectHandler(onServerDisconnect);
|
|
|
+ coreSetServerPacketHandler(onServerPacket);
|
|
|
|
|
|
- coreClientResetHandler();
|
|
|
- coreClientSetConnectHandler(onClientConnect);
|
|
|
- coreClientSetDisconnectHandler(onClientDisconnect);
|
|
|
- coreClientSetPacketHandler(onClientPacket);
|
|
|
+ coreResetClientHandler();
|
|
|
+ coreSetClientConnectHandler(onClientConnect);
|
|
|
+ coreSetClientDisconnectHandler(onClientDisconnect);
|
|
|
+ coreSetClientPacketHandler(onClientPacket);
|
|
|
|
|
|
- if(!CORE_TEST_FALSE(coreServerStart(54321, 5))) {
|
|
|
+ if(!CORE_TEST_FALSE(coreStartServer(54321, 5))) {
|
|
|
return;
|
|
|
- } else if(!CORE_TEST_FALSE(coreClientStart())) {
|
|
|
+ } else if(!CORE_TEST_FALSE(coreStartClient())) {
|
|
|
return;
|
|
|
- } else if(!CORE_TEST_FALSE(coreClientConnect("127.0.0.1", 54321, 90))) {
|
|
|
+ } else if(!CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 90))) {
|
|
|
return;
|
|
|
}
|
|
|
- CORE_TEST_FALSE(coreClientIsConnected());
|
|
|
- CORE_TEST_TRUE(coreClientIsConnecting());
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
+ CORE_TEST_TRUE(coreIsClientConnecting());
|
|
|
tick(100);
|
|
|
CORE_TEST_TRUE(clientConnected);
|
|
|
- CORE_TEST_TRUE(coreClientIsConnected());
|
|
|
- CORE_TEST_FALSE(coreClientIsConnecting());
|
|
|
+ CORE_TEST_TRUE(coreIsClientConnected());
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnecting());
|
|
|
|
|
|
CoreOutPacket out;
|
|
|
coreInitOutPacket(&out);
|
|
|
- coreOutPacketWriteU8(&out, 0xF1);
|
|
|
- coreOutPacketWriteU16(&out, 0xF123);
|
|
|
- coreOutPacketWriteU32(&out, 0xF1234567);
|
|
|
- coreOutPacketWriteI8(&out, -0x71);
|
|
|
- coreOutPacketWriteI16(&out, -0x7123);
|
|
|
- coreOutPacketWriteI32(&out, -0x71234567);
|
|
|
- coreOutPacketWriteI8(&out, 0x71);
|
|
|
- coreOutPacketWriteI16(&out, 0x7123);
|
|
|
- coreOutPacketWriteI32(&out, 0x71234567);
|
|
|
+ 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);
|
|
|
const char s[] = "Hi there";
|
|
|
- coreOutPacketWriteString(&out, s);
|
|
|
- coreOutPacketWriteFloat(&out, 252345.983f);
|
|
|
- coreClientSend(&out, mode);
|
|
|
+ coreWriteOutPacketString(&out, s);
|
|
|
+ coreWriteOutPacketFloat(&out, 252345.983f);
|
|
|
+ coreSendClientPacket(&out, mode);
|
|
|
coreDestroyOutPacket(&out);
|
|
|
|
|
|
tick(100);
|
|
@@ -273,15 +273,15 @@ static void testConnect(CorePacketSendMode mode) {
|
|
|
CORE_TEST_STRING(s, data10);
|
|
|
CORE_TEST_FLOAT(252345.983f, data11, 0.01f);
|
|
|
|
|
|
- coreClientDisconnect(90);
|
|
|
- CORE_TEST_FALSE(coreClientIsConnected());
|
|
|
- CORE_TEST_FALSE(coreClientIsConnecting());
|
|
|
+ coreDisconnectClient(90);
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnecting());
|
|
|
tick(100);
|
|
|
CORE_TEST_TRUE(clientDisconnected);
|
|
|
CORE_TEST_TRUE(serverDisconnect);
|
|
|
|
|
|
- coreClientStop();
|
|
|
- coreServerStop();
|
|
|
+ coreStopClient();
|
|
|
+ coreStopServer();
|
|
|
}
|
|
|
|
|
|
static bool disconnected = false;
|
|
@@ -292,112 +292,112 @@ static void testStopDisconnect(void) {
|
|
|
|
|
|
static void testDisconnect(void) {
|
|
|
disconnected = false;
|
|
|
- coreClientResetHandler();
|
|
|
- coreClientSetDisconnectHandler(testStopDisconnect);
|
|
|
- if(!CORE_TEST_FALSE(coreClientStart())) {
|
|
|
+ coreResetClientHandler();
|
|
|
+ coreSetClientDisconnectHandler(testStopDisconnect);
|
|
|
+ if(!CORE_TEST_FALSE(coreStartClient())) {
|
|
|
return;
|
|
|
- } else if(!CORE_TEST_FALSE(coreClientConnect("127.0.0.1", 54321, 90))) {
|
|
|
+ } else if(!CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 90))) {
|
|
|
return;
|
|
|
}
|
|
|
- CORE_TEST_FALSE(coreClientIsConnected());
|
|
|
- CORE_TEST_TRUE(coreClientIsConnecting());
|
|
|
- coreClientDisconnect(50);
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
+ CORE_TEST_TRUE(coreIsClientConnecting());
|
|
|
+ coreDisconnectClient(50);
|
|
|
tickClient(100);
|
|
|
- CORE_TEST_FALSE(coreClientIsConnected());
|
|
|
- CORE_TEST_FALSE(coreClientIsConnecting());
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnecting());
|
|
|
CORE_TEST_TRUE(disconnected);
|
|
|
- coreClientStop();
|
|
|
+ coreStopClient();
|
|
|
}
|
|
|
|
|
|
static void testStop(void) {
|
|
|
disconnected = false;
|
|
|
- coreClientResetHandler();
|
|
|
- coreClientSetDisconnectHandler(testStopDisconnect);
|
|
|
- if(!CORE_TEST_FALSE(coreClientStart())) {
|
|
|
+ coreResetClientHandler();
|
|
|
+ coreSetClientDisconnectHandler(testStopDisconnect);
|
|
|
+ if(!CORE_TEST_FALSE(coreStartClient())) {
|
|
|
return;
|
|
|
- } else if(!CORE_TEST_FALSE(coreClientConnect("127.0.0.1", 54321, 90))) {
|
|
|
+ } else if(!CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 90))) {
|
|
|
return;
|
|
|
}
|
|
|
- CORE_TEST_FALSE(coreClientIsConnected());
|
|
|
- CORE_TEST_TRUE(coreClientIsConnecting());
|
|
|
- coreClientStop();
|
|
|
- CORE_TEST_FALSE(coreClientIsConnected());
|
|
|
- CORE_TEST_FALSE(coreClientIsConnecting());
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
+ CORE_TEST_TRUE(coreIsClientConnecting());
|
|
|
+ coreStopClient();
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnecting());
|
|
|
CORE_TEST_TRUE(disconnected);
|
|
|
}
|
|
|
|
|
|
static void testClientStartFails(void) {
|
|
|
- CORE_TEST_FALSE(coreClientStart());
|
|
|
+ CORE_TEST_FALSE(coreStartClient());
|
|
|
logLevel = LOG_NONE;
|
|
|
- CORE_TEST_TRUE(coreClientStart());
|
|
|
- coreClientStop();
|
|
|
+ CORE_TEST_TRUE(coreStartClient());
|
|
|
+ coreStopClient();
|
|
|
#ifdef ERROR_SIMULATOR
|
|
|
coreFailCounter = 0;
|
|
|
- CORE_TEST_TRUE(coreClientStart());
|
|
|
+ CORE_TEST_TRUE(coreStartClient());
|
|
|
coreFailCounter = 1;
|
|
|
- CORE_TEST_TRUE(coreClientStart());
|
|
|
+ CORE_TEST_TRUE(coreStartClient());
|
|
|
coreFailCounter = -1;
|
|
|
#endif
|
|
|
logLevel = LOG_DEBUG;
|
|
|
}
|
|
|
|
|
|
static void testClientConnectionFails(void) {
|
|
|
- coreClientResetHandler();
|
|
|
+ coreResetClientHandler();
|
|
|
logLevel = LOG_NONE;
|
|
|
- CORE_TEST_TRUE(coreClientConnect("", 54321, 100));
|
|
|
- CORE_TEST_FALSE(coreClientStart());
|
|
|
+ CORE_TEST_TRUE(coreConnectClient("", 54321, 100));
|
|
|
+ CORE_TEST_FALSE(coreStartClient());
|
|
|
#ifdef ERROR_SIMULATOR
|
|
|
coreFailCounter = 0;
|
|
|
- CORE_TEST_TRUE(coreClientConnect("", 54321, 100));
|
|
|
+ CORE_TEST_TRUE(coreConnectClient("", 54321, 100));
|
|
|
coreFailCounter = -1;
|
|
|
#endif
|
|
|
- CORE_TEST_FALSE(coreClientConnect("", 54321, 100));
|
|
|
- CORE_TEST_TRUE(coreClientConnect("", 54321, 100));
|
|
|
+ CORE_TEST_FALSE(coreConnectClient("", 54321, 100));
|
|
|
+ CORE_TEST_TRUE(coreConnectClient("", 54321, 100));
|
|
|
logLevel = LOG_DEBUG;
|
|
|
tickClient(100);
|
|
|
- coreClientStop();
|
|
|
+ coreStopClient();
|
|
|
}
|
|
|
|
|
|
static void testInvalidClientAccess(void) {
|
|
|
- coreClientDisconnect(0);
|
|
|
- coreClientSend(nullptr, 0);
|
|
|
- coreClientTick();
|
|
|
+ coreDisconnectClient(0);
|
|
|
+ coreSendClientPacket(nullptr, 0);
|
|
|
+ coreTickClient();
|
|
|
}
|
|
|
|
|
|
static void testServerStartFails(void) {
|
|
|
logLevel = LOG_NONE;
|
|
|
- CORE_TEST_TRUE(coreServerStart(54321, 0));
|
|
|
+ CORE_TEST_TRUE(coreStartServer(54321, 0));
|
|
|
#ifdef ERROR_SIMULATOR
|
|
|
coreFailCounter = 0;
|
|
|
- CORE_TEST_TRUE(coreServerStart(54321, 5));
|
|
|
+ CORE_TEST_TRUE(coreStartServer(54321, 5));
|
|
|
coreFailCounter = 1;
|
|
|
- CORE_TEST_TRUE(coreServerStart(54321, 5));
|
|
|
+ CORE_TEST_TRUE(coreStartServer(54321, 5));
|
|
|
coreFailCounter = -1;
|
|
|
#endif
|
|
|
- CORE_TEST_FALSE(coreServerStart(54321, 5));
|
|
|
- CORE_TEST_TRUE(coreServerStart(54321, 5));
|
|
|
+ CORE_TEST_FALSE(coreStartServer(54321, 5));
|
|
|
+ CORE_TEST_TRUE(coreStartServer(54321, 5));
|
|
|
logLevel = LOG_DEBUG;
|
|
|
- coreServerStop();
|
|
|
+ coreStopServer();
|
|
|
}
|
|
|
|
|
|
static void testServerClosesOnConnected(void) {
|
|
|
clientDisconnected = false;
|
|
|
- CORE_TEST_FALSE(coreServerStart(54321, 5));
|
|
|
- CORE_TEST_FALSE(coreClientStart());
|
|
|
- coreClientSetDisconnectHandler(onClientDisconnect);
|
|
|
- CORE_TEST_FALSE(coreClientConnect("127.0.0.1", 54321, 50));
|
|
|
+ CORE_TEST_FALSE(coreStartServer(54321, 5));
|
|
|
+ CORE_TEST_FALSE(coreStartClient());
|
|
|
+ coreSetClientDisconnectHandler(onClientDisconnect);
|
|
|
+ CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 50));
|
|
|
tick(100);
|
|
|
- CORE_TEST_TRUE(coreClientIsConnected());
|
|
|
- coreServerStop();
|
|
|
+ CORE_TEST_TRUE(coreIsClientConnected());
|
|
|
+ coreStopServer();
|
|
|
|
|
|
- coreClientTimeout(500, 500, 500);
|
|
|
- for(int i = 0; i < 500 && coreClientIsConnected(); i++) {
|
|
|
- coreClientTick();
|
|
|
+ coreSetClientTimeout(500, 500, 500);
|
|
|
+ for(int i = 0; i < 500 && coreIsClientConnected(); i++) {
|
|
|
+ coreTickClient();
|
|
|
coreSleepNanos(10000000);
|
|
|
}
|
|
|
- CORE_TEST_FALSE(coreClientIsConnected());
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
CORE_TEST_TRUE(clientDisconnected);
|
|
|
- coreClientStop();
|
|
|
+ coreStopClient();
|
|
|
}
|
|
|
|
|
|
static CoreClient clientId = 0;
|
|
@@ -408,25 +408,25 @@ static void onConnectSetClient(CoreClient client) {
|
|
|
|
|
|
static void testServerDisconnectsClient(void) {
|
|
|
clientDisconnected = false;
|
|
|
- CORE_TEST_FALSE(coreServerStart(54321, 5));
|
|
|
- CORE_TEST_FALSE(coreClientStart());
|
|
|
- coreClientSetDisconnectHandler(onClientDisconnect);
|
|
|
- coreServerSetConnectHandler(onConnectSetClient);
|
|
|
- CORE_TEST_FALSE(coreClientConnect("127.0.0.1", 54321, 50));
|
|
|
+ CORE_TEST_FALSE(coreStartServer(54321, 5));
|
|
|
+ CORE_TEST_FALSE(coreStartClient());
|
|
|
+ coreSetClientDisconnectHandler(onClientDisconnect);
|
|
|
+ coreSetServerConnectHandler(onConnectSetClient);
|
|
|
+ CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 50));
|
|
|
tick(100);
|
|
|
- CORE_TEST_TRUE(coreClientIsConnected());
|
|
|
+ CORE_TEST_TRUE(coreIsClientConnected());
|
|
|
|
|
|
- coreServerDisconnect(clientId);
|
|
|
+ coreDisconnectServerClient(clientId);
|
|
|
|
|
|
- for(int i = 0; i < 500 && coreClientIsConnected(); i++) {
|
|
|
- coreClientTick();
|
|
|
- coreServerTick();
|
|
|
+ for(int i = 0; i < 500 && coreIsClientConnected(); i++) {
|
|
|
+ coreTickClient();
|
|
|
+ coreTickServer();
|
|
|
coreSleepNanos(10000000);
|
|
|
}
|
|
|
- CORE_TEST_FALSE(coreClientIsConnected());
|
|
|
+ CORE_TEST_FALSE(coreIsClientConnected());
|
|
|
CORE_TEST_TRUE(clientDisconnected);
|
|
|
- coreClientStop();
|
|
|
- coreServerStop();
|
|
|
+ coreStopClient();
|
|
|
+ coreStopServer();
|
|
|
}
|
|
|
|
|
|
static void onConnectSetTimeout(CoreClient client) {
|
|
@@ -435,51 +435,51 @@ static void onConnectSetTimeout(CoreClient client) {
|
|
|
|
|
|
static void testClientClosesOnConnected(void) {
|
|
|
serverDisconnect = false;
|
|
|
- CORE_TEST_FALSE(coreServerStart(54321, 5));
|
|
|
- CORE_TEST_FALSE(coreClientStart());
|
|
|
- coreServerSetDisconnectHandler(onServerDisconnect);
|
|
|
- coreServerSetConnectHandler(onConnectSetTimeout);
|
|
|
- CORE_TEST_FALSE(coreClientConnect("127.0.0.1", 54321, 50));
|
|
|
+ CORE_TEST_FALSE(coreStartServer(54321, 5));
|
|
|
+ CORE_TEST_FALSE(coreStartClient());
|
|
|
+ coreSetServerDisconnectHandler(onServerDisconnect);
|
|
|
+ coreSetServerConnectHandler(onConnectSetTimeout);
|
|
|
+ CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 50));
|
|
|
tick(100);
|
|
|
- CORE_TEST_TRUE(coreClientIsConnected());
|
|
|
+ CORE_TEST_TRUE(coreIsClientConnected());
|
|
|
#ifdef ERROR_SIMULATOR
|
|
|
coreFailCounter = 0;
|
|
|
#endif
|
|
|
- coreClientStop();
|
|
|
+ coreStopClient();
|
|
|
#ifdef ERROR_SIMULATOR
|
|
|
coreFailCounter = -1;
|
|
|
#endif
|
|
|
for(int i = 0; i < 500 && !serverDisconnect; i++) {
|
|
|
- coreServerTick();
|
|
|
+ coreTickServer();
|
|
|
coreSleepNanos(10000000);
|
|
|
}
|
|
|
CORE_TEST_TRUE(serverDisconnect);
|
|
|
- coreServerStop();
|
|
|
+ coreStopServer();
|
|
|
}
|
|
|
|
|
|
static void testInvalidServerAccess(void) {
|
|
|
- coreServerTick();
|
|
|
- coreServerSend(0, nullptr, 0);
|
|
|
+ coreTickServer();
|
|
|
+ coreSendServerPacket(0, nullptr, 0);
|
|
|
coreServerTimeout(0, 500, 500, 500);
|
|
|
- coreServerDisconnect(0);
|
|
|
+ coreDisconnectServerClient(0);
|
|
|
}
|
|
|
|
|
|
static void testDummyCallbacks(void) {
|
|
|
- coreClientResetHandler();
|
|
|
- coreServerResetHandler();
|
|
|
- CORE_TEST_FALSE(coreServerStart(54321, 5));
|
|
|
- CORE_TEST_FALSE(coreClientStart());
|
|
|
- CORE_TEST_FALSE(coreClientConnect("127.0.0.1", 54321, 50));
|
|
|
+ coreResetClientHandler();
|
|
|
+ coreResetServerHandler();
|
|
|
+ CORE_TEST_FALSE(coreStartServer(54321, 5));
|
|
|
+ CORE_TEST_FALSE(coreStartClient());
|
|
|
+ CORE_TEST_FALSE(coreConnectClient("127.0.0.1", 54321, 50));
|
|
|
tick(100);
|
|
|
- CORE_TEST_TRUE(coreClientIsConnected());
|
|
|
+ CORE_TEST_TRUE(coreIsClientConnected());
|
|
|
CoreOutPacket out;
|
|
|
coreInitOutPacket(&out);
|
|
|
- coreServerSendAll(&out, CORE_RELIABLE);
|
|
|
- coreClientSend(&out, CORE_RELIABLE);
|
|
|
+ coreSendServerPacketBroadcast(&out, CORE_RELIABLE);
|
|
|
+ coreSendClientPacket(&out, CORE_RELIABLE);
|
|
|
tick(100);
|
|
|
coreDestroyOutPacket(&out);
|
|
|
- coreClientStop();
|
|
|
- coreServerStop();
|
|
|
+ coreStopClient();
|
|
|
+ coreStopServer();
|
|
|
}
|
|
|
|
|
|
void coreTestNetwork(void) {
|