server.c

   1 #include <assert.h>
   2 #include <SDL2/SDL_net.h>
   3
   4 #include "game.h"
   5 #include "server.h"
   6 #include "network.h"
   7 #include "protocol.h"
   8
   9 #define MAX_NAMESIZE 32
  10
  11 typedef struct Client {
  12         bool      connected;
  13         IPaddress address;
  14         char      name[MAX_NAMESIZE];
  15 } Client;
  16
  17 static Uint32 lastTime;
  18 static Uint32 currTime;
  19
  20 static UDPsocket sock;
  21 static Client    client[MAX_PLAYERS];
  22 static char      name[MAX_NAMESIZE] = "netwar! server";
  23 static int       clientlimit        = 0;
  24
  25 static inline float randf() {
  26         return (float) rand() / (float) RAND_MAX;
  27 }
  28
  29 static inline float randfm() {
  30         return (rand() % 2) ? (-randf()) : (+randf());
  31 }
  32
  33 static inline bool cmpaddr(IPaddress a, IPaddress b) {
  34         return (a.host == b.host) && (a.port == b.port);
  35 }
  36
  37 static int sv_find_client(IPaddress address) {
  38         for(int i = 0; i < clientlimit; i++)
  39                 if(client[i].connected && cmpaddr(client[i].address, address))
  40                         return i;
  41         return -1;
  42 }
  43
  44 static void sv_sync_client(int id, bool full) {
  45         assert(id >= 0);
  46         assert(client[id].connected);
  47
  48         for(int i = 0; i < clientlimit; i++)
  49                 if(full || g_player[i].updated)
  50                         SendMessage(sock, client[id].address, sv_splr(i, g_player[i].live, g_player[i].x, g_player[i].y, g_player[i].r, g_player[i].vx, g_player[i].vy, g_player[i].vr));
  51 }
  52
  53 static void sv_kill_player(int id, bool send, const char * msg) {
  54         assert(id >= 0);
  55         assert(client[id].connected);
  56
  57         if(send)
  58                 SendMessage(sock, client[id].address, sv_kill(msg));
  59
  60         client[id].connected = false;
  61         g_player_set(id, false, 0, 0, 0, 0, 0, 0);
  62         SDL_Log("Player %s (%i) disconnected: %s", client[id].name, id, msg);
  63 }
  64
  65 static void sv_move_player(int id, ProtocolMessage m) {
  66         assert(id >= 0);
  67         assert(client[id].connected);
  68
  69         g_player_does(id, m.cl.does.code);
  70 }
  71
  72 static void sv_register_player(IPaddress address, ProtocolMessage m) {
  73         if(m.cl.info.version != PROTOCOL_VERSION)
  74                 SendMessage(sock, address, sv_kill("Uncompatible version"));
  75
  76         int i = 0;
  77         while((i < clientlimit) && (client[i].connected))
  78                 ++i;
  79
  80         int namesize = sizeof(m.cl.info.name);
  81         if(i >= clientlimit) {
  82                 SDL_Log("Too may clints, player %.*s disconnected", namesize, m.cl.info.name);
  83                 SendMessage(sock, address, sv_kill("Too many clients"));
  84                 return;
  85         }
  86
  87         client[i].connected = true;
  88         client[i].address   = address;
  89         strncpy(client[i].name, (char*) m.cl.info.name, MAX_NAMESIZE);
  90         client[i].name[MAX_NAMESIZE - 1] = 0;
  91
  92         SDL_Log("Player %s (%i) connected", client[i].name, i);
  93         SendMessage(sock, address, sv_info(name, i, clientlimit));
  94
  95         g_player_set(i, true, randfm(), randfm(), randfm(), 0, 0, 0);
  96         sv_sync_client(i, true);
  97 }
  98
  99 static void sv_recv() {
 100         IPaddress address;
 101         ProtocolMessage m;
 102         if(!RecvMessage(sock, &address, &m))
 103                 return;
 104
 105         switch(m.type) {
 106         case CL_INFO: sv_register_player(address, m); break;
 107         case CL_KILL: sv_kill_player(sv_find_client(address), false, ""); break;
 108         case CL_DOES: sv_move_player(sv_find_client(address), m); break;
 109         default:      SDL_Log("invalid message %i", m.type);
 110         }
 111 }
 112
 113 static void sv_send() {
 114         for(int i = 0; i < clientlimit; i++)
 115                 if(client[i].connected)
 116                         sv_sync_client(i, false);
 117
 118         for(int i = 0; i < clientlimit; i++)
 119                 g_player[i].updated = false;
 120 }
 121
 122 void sv_start(uint16_t port) {
 123         sock = OpenPort(port);
 124         lastTime = SDL_GetTicks();
 125         currTime = SDL_GetTicks();
 126 }
 127
 128 void sv_stop() {
 129         for(int i = 0; i < clientlimit; i++)
 130                 if(client[i].connected)
 131                         sv_kill_player(i, true, "Server shutdown");
 132         ClosePort(sock);
 133 }
 134
 135 void sv_setclientlimit(unsigned int maxclients) {
 136         // TODO disconnect clients
 137         clientlimit = (maxclients > MAX_PLAYERS) ? (MAX_PLAYERS) : (maxclients);
 138 }
 139
 140 void sv_handle() {
 141         if(currTime - lastTime >= TICK_DELAY) {
 142                 sv_recv();
 143                 g_update();
 144                 sv_send();
 145                 lastTime = SDL_GetTicks();
 146         }
 147         currTime = SDL_GetTicks();
 148 }