server changes
authorhgn <hgodden00@gmail.com>
Wed, 31 May 2023 16:58:34 +0000 (17:58 +0100)
committerhgn <hgodden00@gmail.com>
Wed, 31 May 2023 16:58:34 +0000 (17:58 +0100)
highscores.h
network.h
network_msg.h
server.c
skaterift.c
world_routes.c

index 817a503870ef602ed543f81338873e2e5fc6238d..b096714cb9e8c16af1e93e0cf47322846ae9b134 100644 (file)
@@ -164,8 +164,7 @@ VG_STATIC int highscores_read(void)
    struct highscore_system *sys = &highscore_system;
 
    FILE *fp = fopen( ".aadb", "rb" );
-   if( fp )
-   {
+   if( fp ){
       vg_info( "Loading existing database\n" );
       
       u64 count = fread( &sys->dbheader, sizeof(highscore_database), 1, fp );
index 3a49d63795473646e9609329cad58e87abdc16eb..38fc9039eb3a39e97e129fd5c012d66b78bc967b 100644 (file)
--- a/network.h
+++ b/network.h
@@ -243,13 +243,11 @@ VG_STATIC void on_inet_scoreboard( SteamNetworkingMessage_t *msg )
       sizeof(struct netmsg_board)*vg_list_size(track_infos),
        expected = base_size+sizeof(struct netmsg_board)*sb->board_count;
 
-   if( msg->m_cbSize != expected )
-   {
+   if( msg->m_cbSize != expected ){
       vg_error( "Server scoreboard was corrupted. Size: %u != %u\n",
             msg->m_cbSize, expected );
    }
-   else
-   {
+   else{
       if( vg_list_size(track_infos) > sb->board_count )
          vg_warn( "Server is out of date, not enough boards recieved\n");
       else if( vg_list_size(track_infos) < sb->board_count )
@@ -257,8 +255,7 @@ VG_STATIC void on_inet_scoreboard( SteamNetworkingMessage_t *msg )
       else
          vg_success( "Recieved new scoreboards from server\n" );
 
-      for( int i=0; i < vg_min(sb->board_count,vg_list_size(track_infos)); i++)
-      {
+      for( int i=0; i < vg_min(sb->board_count,vg_list_size(track_infos)); i++){
          scoreboard_client_data.boards[i] = sb->boards[i];
          highscores_board_printf( stdout, sb->boards[i].data, 10 );
       }
@@ -276,20 +273,17 @@ VG_STATIC void poll_connection(void)
    SteamNetworkingMessage_t *messages[32];
    int len;
 
-   while(1)
-   {
+   while(1){
       len = SteamAPI_ISteamNetworkingSockets_ReceiveMessagesOnConnection(
             hSteamNetworkingSockets, cremote, messages, vg_list_size(messages));
 
       if( len <= 0 )
          return;
 
-      for( int i=0; i<len; i++ )
-      {
+      for( int i=0; i<len; i++ ){
          SteamNetworkingMessage_t *msg = messages[i];
 
-         if( msg->m_cbSize < sizeof(netmsg_blank) )
-         {
+         if( msg->m_cbSize < sizeof(netmsg_blank) ){
             vg_warn( "Discarding message (too small: %d)\n", msg->m_cbSize );
             continue;
          }
@@ -309,21 +303,17 @@ VG_STATIC void poll_connection(void)
  */
 VG_STATIC void network_update(void)
 {
-   if( steam_ready )
-   {
+   if( steam_ready ){
       static double last_update = 0.0;
       poll_connection();
       
-      if( vg.time > (last_update + 60.0) )
-      {
+      if( vg.time > (last_update + 60.0) ){
          last_update = vg.time;
 
-         if( steam_app_ticket_length )
-         {
+         if( steam_app_ticket_length ){
             network_connect_gc();
          }
-         else
-         {
+         else{
             vg_low( "Not making remote connection; app ticket not gotten\n" );
          }
       }
@@ -340,8 +330,7 @@ VG_STATIC void network_update(void)
 
 VG_STATIC void network_init(void)
 {
-   if( steam_ready )
-   {
+   if( steam_ready ){
       steam_register_callback( k_iSteamNetConnectionStatusChangedCallBack,
                                on_server_connect_status );
       request_auth_ticket();
index 5f1bc416a67e96b82d72813d1a063a62344097cb..1df9434a8ca1cb03d91ef7a586192cfbb73fddea 100644 (file)
@@ -49,7 +49,9 @@ struct netmsg_set_score
    }
    records[];
 };
-enum{ k_inetmsg_set_score = 3 };
+enum{ k_inetmsg_set_score = 6 };
+/* 31.05.23: k_inetmsg_set_score id changed from ID 3 to ID 6,
+ *                               3 is now INVALID */
 
 typedef struct netmsg_set_nickname netmsg_set_nickname;
 struct netmsg_set_nickname
index be3f2a9e0d10d6b52efd8cf3f252a82827c03d82..5e133558e8718fd3ce1f607fbd87db4082b24a84 100644 (file)
--- a/server.c
+++ b/server.c
@@ -275,8 +275,7 @@ static void poll_connections(void)
    SteamNetworkingMessage_t *messages[32];
    int len;
 
-   while(1)
-   {
+   while(1){
       len = SteamAPI_ISteamNetworkingSockets_ReceiveMessagesOnPollGroup(
             hSteamNetworkingSockets,
             client_pollgroup, messages, vg_list_size(messages) );
@@ -284,12 +283,10 @@ static void poll_connections(void)
       if( len <= 0 )
          return;
 
-      for( int i=0; i<len; i++ )
-      {
+      for( int i=0; i<len; i++ ){
          SteamNetworkingMessage_t *msg = messages[i];
 
-         if( msg->m_cbSize < sizeof(netmsg_blank) )
-         {
+         if( msg->m_cbSize < sizeof(netmsg_blank) ){
             vg_warn( "Discarding message (too small: %d)\n", 
                   msg->m_cbSize );
             continue;
@@ -305,6 +302,10 @@ static void poll_connections(void)
             on_inet_set_nickname( msg );
          else if( tmp->inetmsg_id == k_inetmsg_set_score )
             on_inet_set_score( msg );
+         else {
+            vg_warn( "Unknown inetmsg_id recieved from client. (%u)\n",
+                     temp->inetmsg_id );
+         }
 
          SteamAPI_SteamNetworkingMessage_t_Release( msg );
       }
index 50e780f898811a3be394cf2338b5e55648f60630..74e360b4d5e9ddbda702482f1a3faf76412f3b08 100644 (file)
@@ -57,10 +57,12 @@ int main( int argc, char *argv[] )
    return 0;
 }
 
+#if 0
 VG_STATIC void highscores_save_at_exit(void)
 {
    highscores_serialize_all();
 }
+#endif
 
 VG_STATIC void vg_launch_opt(void)
 {
@@ -78,11 +80,13 @@ vg_info("            |   \\/   | |        /     |      |    \\ | /   | \n" );
 vg_info("            '        ' '--' [] '----- '----- '     ' '---'  " 
         "SOFTWARE\n" );
 
+   /* 31.05.23 (hgn): this is only a server feature now */
+#if 0
    highscores_init( 2000, 50 );
    if( !highscores_read() )
       highscores_create_db();
-
    vg_loader_step( NULL, highscores_save_at_exit );
+#endif
 
    steam_init();
    vg_loader_step( NULL, steam_end );
index efde3644dd07d3203988a0d1ddb577ad42d9cafe..d366a123e09ee0f3f5e079504dacf1e66bdbb440 100644 (file)
@@ -22,7 +22,7 @@
 
 VG_STATIC 
 void world_routes_local_set_record( world_instance *world, ent_route *route,
-                                    double lap_time )
+                                    f64 lap_time )
 {
    vg_success( "  NEW LAP TIME: %f\n", lap_time );
 
@@ -37,7 +37,6 @@ void world_routes_local_set_record( world_instance *world, ent_route *route,
       temp.playerid = 0;
       temp.points   = 0;
       temp.time     = time_centiseconds;
-
 #if 0
       highscores_push_record( &temp );
 #endif