-
-static void on_inet_scoreboard( SteamNetworkingMessage_t *msg )
-{
- netmsg_scoreboard *sb = msg->m_pData;
-
- u32 base_size = sizeof(netmsg_scoreboard)-
- sizeof(struct netmsg_board)*vg_list_size(track_infos),
- expected = base_size+sizeof(struct netmsg_board)*sb->board_count;
-
- if( msg->m_cbSize != expected )
- {
- vg_error( "Server scoreboard was corrupted. Size: %u != %u\n",
- msg->m_cbSize, expected );
- }
- 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 )
- vg_warn( "Client out of date, server sent more boards than we have\n");
- 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++)
- {
- scoreboard_client_data.boards[i] = sb->boards[i];
- highscores_board_printf( stdout, sb->boards[i].data, 10 );
- }
- }
-
- /* We dont need to stay on the server currently */
- SteamAPI_ISteamNetworkingSockets_CloseConnection(
- hSteamNetworkingSockets, cremote, 0, NULL, 1 );
-
- network_scores_updated = 1;
-}
-
-static void poll_connection(void)
-{
- SteamNetworkingMessage_t *messages[32];
- int len;
-
- while(1)
- {
- len = SteamAPI_ISteamNetworkingSockets_ReceiveMessagesOnConnection(
- hSteamNetworkingSockets, cremote, messages, vg_list_size(messages));
-
- if( len <= 0 )
- return;
-
- for( int i=0; i<len; i++ )
- {
- SteamNetworkingMessage_t *msg = messages[i];
-
- if( msg->m_cbSize < sizeof(netmsg_blank) )
- {
- vg_warn( "Discarding message (too small: %d)\n", msg->m_cbSize );
- continue;
- }
-
- netmsg_blank *tmp = msg->m_pData;
-
- if( tmp->inetmsg_id == k_inetmsg_scoreboard )
- on_inet_scoreboard( msg );
-
- SteamAPI_SteamNetworkingMessage_t_Release( msg );
- }
- }
-}
-
-/*
- * Subroutine to be connected to main game loop, runs all routines on timers
- */
-static void network_update(void)
-{
- if( steam_ready )
- {
- static double last_update = 0.0;
- poll_connection();
-
- if( vg_time > (last_update + 60.0) )
- {
- last_update = vg_time;
-
- if( steam_app_ticket_length )
- {
- network_connect_gc();
- }
- else
- {
- vg_low( "Not making remote connection; app ticket not gotten\n" );
- }
- }
-
- if( vg_time > (last_update + 10.0) &&
- (cremote_state == k_ESteamNetworkingConnectionState_Connected ))
- {
- vg_warn( "Connected to server but no return... disconnecting\n" );
- SteamAPI_ISteamNetworkingSockets_CloseConnection(
- hSteamNetworkingSockets, cremote, 0, NULL, 1 );
- }
- }
-}
-
-static void network_init(void)
-{
- if( steam_ready )
- {
- steam_register_callback( k_iSteamNetConnectionStatusChangedCallBack,
- on_server_connect_status );
- request_auth_ticket();
- }
-}
-
-static void network_end(void*_)
-{
- /* TODO: Fire off any buffered highscores that need to be setn */
- if( cremote_state == k_ESteamNetworkingConnectionState_Connected ||
- cremote_state == k_ESteamNetworkingConnectionState_Connecting )
- {
- SteamAPI_ISteamNetworkingSockets_CloseConnection(
- hSteamNetworkingSockets, cremote, 0, NULL, 1 );
- }
-}
-
-#else /* SR_NETWORKED */
-
-static void network_init(void){}
-static void network_update(void){}
-static void network_end(void*_){}
-
-#endif /* SR_NETWORKED */
-#endif /* NETWORK_H */