connection test removed

tests/CMakeLists.txt

@@ -10,7 +10,6 @@ add_executable(allocators allocators.cpp)
 add_executable(containers containers.cpp)
 add_executable(messages messages.cpp)
 add_executable(compressors compressors.cpp)
-add_executable(connections connections.cpp)
 add_executable(strings strings.cpp)
 add_executable(paths paths.cpp)
 add_executable(script script.cpp)
@@ -19,7 +18,6 @@ target_link_libraries(allocators crown)
 target_link_libraries(containers crown)
 target_link_libraries(messages crown)
 target_link_libraries(compressors crown)
-target_link_libraries(connections crown)
 target_link_libraries(strings crown)
 target_link_libraries(paths crown)
 
@@ -31,7 +29,6 @@ add_test(allocators-test ${EXECUTABLE_OUTPUT_PATH}/allocators)
 add_test(containers-test containers)
 add_test(messages-test messages)
 add_test(compressors-test compressors)
-add_test(connections-test connections)
 add_test(strings-test strings)
 add_test(paths-test paths)
 

tests/connections.cpp

@@ -1,161 +0,0 @@
-#include <cstdio>
-#include <cstring>
-
-#include "OS.h"
-#include "MallocAllocator.h"
-#include "BitMessage.h"
-#include "AsyncConnection.h"
-#include "PacketQueue.h"
-
-using namespace crown;
-
-const unsigned int server_port = 30000;
-const unsigned int client_port = 30001;
-const uint32_t protocol_id = 0x00;
-const float delta_time = 1.0f / 45.0f;
-const real send_rate = 1.0f / 45.0f;
-
-const float time_out = 10.0f;
-
-enum Mode
-{
-    SERVER,
-    CLIENT
-};
-
-int main(int argc, char** argv)
-{
-	if (argc != 2)
-	{
-		os::printf("Usage: ./connections server/client.\n");
-		return -1;
-	}
-	
-	bool connected = false;
-	real send_acc = 0.0f;
-	Mode mode = SERVER;
-	os::NetAddress addr(127, 0, 0, 1, server_port);
-	
-	// creates connection
-	MallocAllocator alloc;
-	network::AsyncConnection connection(alloc);
-	
-	if (strcmp(argv[1], "server") == 0)
-	{
-		mode = SERVER;
-	}
-	else if (strcmp(argv[1], "client") == 0)
-	{
-		mode = CLIENT;
-	}
-	else
-	{
-		os::printf("Usage: ./connections server/client.\n");
-		return -1;
-	}
-	
-	uint16_t port = mode == SERVER ? server_port : client_port;
-
-	// connection init
-	connection.init(protocol_id, 10.0f);
-	//connection start
-	if (!connection.start(port))
-	{
-        os::printf("Couldn't start connection on port %d\n", port);
-		return -1;
-	}
-	
-	if (mode == CLIENT)
-	{
-		connection.connect(addr);
-	}
-	else if (mode == SERVER)
-	{
-		connection.listen();
-	}	
-	
-	// main loop
-	while (true)
-	{
-       
-        if (!connected && connection.is_connected())
-        {
-            os::printf("Client connected to server\n");
-            connected = true;
-        }
-        
-        if (!connected && connection.is_connect_fail())
-        {
-            os::printf("Connection failed\n");
-            break;
-        }
-                
-        send_acc += delta_time;
-		
-		if (mode == SERVER)
-		{
-			while (true)
-			{
-				network::BitMessage received(alloc);
-				
-				received.init(6);
-				
-				int32_t bytes = connection.receive_message(received, delta_time);
-				if (bytes > 0)
-				{
-					uint8_t* header = received.get_header();
-					uint32_t protocol_id = header[0] << 24 | header[1] << 16 | header[2] << 8 | header[3];
-					uint16_t sequence = header[4] << 8 | header[5];
-					uint16_t ack = header[6] << 8 | header[7];
-					uint32_t ack_bits = header[8] << 24 | header[9] << 16 | header[10] << 8 | header[11];  
-					char string[6];
-					received.read_string(string, 6);
-					os::printf("------------------\n");
-					os::printf("protocol_id: %d\n", protocol_id);
-					os::printf("sequence: %d\n", sequence);
-					os::printf("ack: %d\n", ack);
-					os::printf("ack_bits: %d\n", ack_bits);
- 					os::printf("data: %s\n", string);
-					os::printf("------------------\n");
-
-				} 
-				
-				if (bytes <= 0)
-				{
-					break;
-				}
-			}
-		}
-		
-		if (mode == CLIENT)
-		{
-			while (send_acc > 1 / send_rate)
-			{
-				network::BitMessage message(alloc);
-			
-				message.init(6);
-				message.begin_writing();
-				message.write_string("prova", 6);
-				
-				connection.send_message(message, delta_time);
-
-				uint8_t* header = message.get_header();
-				uint32_t protocol_id = header[0] << 24 | header[1] << 16 | header[2] << 8 | header[3];
-				uint16_t sequence = header[4] << 8 | header[5];
-				uint16_t ack = header[6] << 8 | header[7];
-				uint32_t ack_bits = header[8] << 24 | header[9] << 16 | header[10] << 8 | header[11];
-				os::printf("------------------\n");
-				os::printf("protocol_id: %d\n", protocol_id);
-				os::printf("sequence: %d\n", sequence);
-				os::printf("ack: %d\n", ack);
-				os::printf("ack_bits: %d\n", ack_bits);
-				os::printf("------------------\n");
-
-				send_acc -= 1.0f / send_rate;
-			}
-		}
-	}
-	
-	connection.stop();
-  
-}