Moved networking code into high cohesion functions
This commit is contained in:
+2
-2
@@ -1,7 +1,7 @@
|
|||||||
#configuration of the programs
|
#configuration of the programs
|
||||||
server.host = 127.0.0.1
|
server.host = 255.255.255.255
|
||||||
server.port = 21795
|
server.port = 21795
|
||||||
server.name = foobar
|
server.name = local
|
||||||
|
|
||||||
server.dbname = database.db
|
server.dbname = database.db
|
||||||
|
|
||||||
|
|||||||
@@ -124,58 +124,19 @@ void ServerApplication::Quit() {
|
|||||||
void ServerApplication::HandlePacket(NetworkPacket packet) {
|
void ServerApplication::HandlePacket(NetworkPacket packet) {
|
||||||
switch(packet.meta.type) {
|
switch(packet.meta.type) {
|
||||||
case NetworkPacket::Type::BROADCAST_REQUEST:
|
case NetworkPacket::Type::BROADCAST_REQUEST:
|
||||||
//send back the server's name
|
HandleBroadcastRequest(packet);
|
||||||
packet.meta.type = NetworkPacket::Type::BROADCAST_RESPONSE;
|
|
||||||
snprintf(packet.serverInfo.name, PACKET_STRING_SIZE, "%s", config["server.name"].c_str());
|
|
||||||
network.Send(&packet.meta.srcAddress, &packet, sizeof(NetworkPacket));
|
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case NetworkPacket::Type::JOIN_REQUEST: {
|
case NetworkPacket::Type::JOIN_REQUEST:
|
||||||
//TODO: prevent duplicate logins from the same address?
|
HandleJoinRequest(packet);
|
||||||
|
|
||||||
//create the new client, filling it with the correct info
|
|
||||||
Client newClient;
|
|
||||||
newClient.address = packet.meta.srcAddress;
|
|
||||||
|
|
||||||
//push the new client
|
|
||||||
clientMap[Client::counter] = newClient;
|
|
||||||
|
|
||||||
//send the client their info
|
|
||||||
packet.meta.type = NetworkPacket::Type::JOIN_RESPONSE;
|
|
||||||
packet.clientInfo.index = Client::counter;
|
|
||||||
network.Send(&newClient.address, &packet, sizeof(NetworkPacket));
|
|
||||||
|
|
||||||
//finished this routine
|
|
||||||
Client::counter++;
|
|
||||||
cout << "connect, total: " << clientMap.size() << endl;
|
|
||||||
}
|
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case NetworkPacket::Type::DISCONNECT:
|
case NetworkPacket::Type::DISCONNECT:
|
||||||
//disconnect the specified client
|
HandleDisconnect(packet);
|
||||||
network.Send(&clientMap[packet.clientInfo.index].address, &packet, sizeof(NetworkPacket));
|
|
||||||
clientMap.erase(packet.clientInfo.index);
|
|
||||||
|
|
||||||
//remove players?
|
|
||||||
|
|
||||||
cout << "disconnect, total: " << clientMap.size() << endl;
|
|
||||||
break;
|
|
||||||
|
|
||||||
case NetworkPacket::Type::SYNCHRONIZE:
|
|
||||||
//TODO
|
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case NetworkPacket::Type::SHUTDOWN:
|
case NetworkPacket::Type::SHUTDOWN:
|
||||||
//end the server
|
HandleShutdown(packet);
|
||||||
running = false;
|
|
||||||
|
|
||||||
//disconnect all clients
|
|
||||||
packet.meta.type = NetworkPacket::Type::DISCONNECT;
|
|
||||||
for (auto& it : clientMap) {
|
|
||||||
network.Send(&it.second.address, &packet, sizeof(NetworkPacket));
|
|
||||||
}
|
|
||||||
|
|
||||||
cout << "shutting down" << endl;
|
|
||||||
break;
|
break;
|
||||||
|
|
||||||
//handle errors
|
//handle errors
|
||||||
@@ -184,3 +145,53 @@ void ServerApplication::HandlePacket(NetworkPacket packet) {
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void ServerApplication::HandleBroadcastRequest(NetworkPacket packet) {
|
||||||
|
//send back the server's name
|
||||||
|
packet.meta.type = NetworkPacket::Type::BROADCAST_RESPONSE;
|
||||||
|
snprintf(packet.serverInfo.name, PACKET_STRING_SIZE, "%s", config["server.name"].c_str());
|
||||||
|
network.Send(&packet.meta.srcAddress, &packet, sizeof(NetworkPacket));
|
||||||
|
}
|
||||||
|
|
||||||
|
void ServerApplication::HandleJoinRequest(NetworkPacket packet) {
|
||||||
|
//TODO: prevent duplicate logins from the same address?
|
||||||
|
|
||||||
|
//create the new client, filling it with the correct info
|
||||||
|
Client newClient;
|
||||||
|
newClient.address = packet.meta.srcAddress;
|
||||||
|
|
||||||
|
//push the new client
|
||||||
|
clientMap[Client::counter] = newClient;
|
||||||
|
|
||||||
|
//send the client their info
|
||||||
|
packet.meta.type = NetworkPacket::Type::JOIN_RESPONSE;
|
||||||
|
packet.clientInfo.index = Client::counter;
|
||||||
|
network.Send(&newClient.address, &packet, sizeof(NetworkPacket));
|
||||||
|
|
||||||
|
//finished this routine
|
||||||
|
Client::counter++;
|
||||||
|
cout << "connect, total: " << clientMap.size() << endl;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ServerApplication::HandleDisconnect(NetworkPacket packet) {
|
||||||
|
//disconnect the specified client
|
||||||
|
network.Send(&clientMap[packet.clientInfo.index].address, &packet, sizeof(NetworkPacket));
|
||||||
|
clientMap.erase(packet.clientInfo.index);
|
||||||
|
|
||||||
|
//TODO: remove players?
|
||||||
|
|
||||||
|
cout << "disconnect, total: " << clientMap.size() << endl;
|
||||||
|
}
|
||||||
|
|
||||||
|
void ServerApplication::HandleShutdown(NetworkPacket packet) {
|
||||||
|
//end the server
|
||||||
|
running = false;
|
||||||
|
|
||||||
|
//disconnect all clients
|
||||||
|
packet.meta.type = NetworkPacket::Type::DISCONNECT;
|
||||||
|
for (auto& it : clientMap) {
|
||||||
|
network.Send(&it.second.address, &packet, sizeof(NetworkPacket));
|
||||||
|
}
|
||||||
|
|
||||||
|
cout << "shutting down" << endl;
|
||||||
|
}
|
||||||
|
|||||||
@@ -56,6 +56,12 @@ public:
|
|||||||
private:
|
private:
|
||||||
void HandlePacket(NetworkPacket);
|
void HandlePacket(NetworkPacket);
|
||||||
|
|
||||||
|
//high cohesion utility functions
|
||||||
|
void HandleBroadcastRequest(NetworkPacket);
|
||||||
|
void HandleJoinRequest(NetworkPacket);
|
||||||
|
void HandleDisconnect(NetworkPacket);
|
||||||
|
void HandleShutdown(NetworkPacket);
|
||||||
|
|
||||||
//networking
|
//networking
|
||||||
UDPNetworkUtility network;
|
UDPNetworkUtility network;
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user