logging + ack check

1 files changed, 11 insertions, 0 deletions

@@ -43,6 +43,7 @@ func _ready():
 
         var race_manager = global.get_node("RaceManager")
         for packet in race_manager.held_messages:
+                global._print("(MP) Handling held packet")
                 _handle_packet(packet)
         race_manager.held_messages.clear()
 
@@ -178,8 +179,10 @@ func _update_lobby_members():
                         active_lobby_members[member_id].steam_name = steam_name
                         if Steam.getLobbyMemberData(active_lobby_id, member_id, "loaded") != "true":
                                 everyone_ready = false
+                                global._print("%d is not ready" % member_id)
                         if Steam.getLobbyMemberData(active_lobby_id, member_id, "timeout") != "true":
                                 everyone_activated = false
+                                global._print("%d is not activated" % member_id)
         for member in prior_lobby_members.values():
                 if not member.steam_id in active_lobby_members:
                         member.queue_free()
@@ -209,6 +212,7 @@ func _handle_packet(packet):
         var remote_id = packet["steam_id_remote"]
         var serialized: PoolByteArray = packet["data"]
         var data: Dictionary = bytes2var(serialized, false)
+        global._print("(MP) RECEIVED Packet %s" % JSON.print(data))
         if "global_transform" in data:
                 _receive_member_location(remote_id, data["global_transform"])
         if "message_id" in data:
@@ -228,6 +232,7 @@ func _handle_packet(packet):
                 _someone_victory(Steam.getFriendPersonaName(remote_id))
         if "ack" in data:
                 messages_needing_ack.erase(data["ack"])
+                _update_lobby_members()
 
 
 func _receive_member_location(member_id: int, global_transform) -> void:
@@ -239,6 +244,7 @@ func _receive_member_location(member_id: int, global_transform) -> void:
 
 func _send_p2p_packet(data: Dictionary, recipient_id: int, mode: int, needs_ack: bool) -> void:
         if recipient_id == RECIPIENT_BROADCAST_ALL:
+                global._print("(MP) SENDING packet %s" % JSON.print(data))
                 for member_id in active_lobby_members.keys():
                         _send_p2p_packet(data.duplicate(), member_id, mode, needs_ack)
                 return
@@ -263,6 +269,7 @@ func _send_p2p_packet(data: Dictionary, recipient_id: int, mode: int, needs_ack:
 
 
 func player_loaded():
+        global._print("(MP) Player has loaded")
         is_loaded = true
         if active_lobby_id != 0:
                 Steam.setLobbyMemberData(active_lobby_id, "loaded", "true")
@@ -271,6 +278,7 @@ func player_loaded():
 
 
 func send_timeout():
+        global._print("(MP) Player is activating")
         is_activating = true
         Steam.setLobbyMemberData(active_lobby_id, "timeout", "true")
         _send_p2p_packet({"timeout": "true"}, RECIPIENT_BROADCAST_ALL, Steam.P2P_SEND_RELIABLE, true)
@@ -278,6 +286,7 @@ func send_timeout():
 
 
 func time_to_start():
+        global._print("(MP) Time To Start")
         var player = get_tree().get_root().get_node("Spatial/player")
         player.playable = true
         get_node("/root/Spatial/label").text = (
@@ -288,6 +297,7 @@ func time_to_start():
 
 func player_victory():
         if !is_victory:
+                global._print("(MP) Victory!")
                 is_victory = true
                 _send_p2p_packet(
                         {"victory": "true"}, RECIPIENT_BROADCAST_ALL, Steam.P2P_SEND_RELIABLE, true
@@ -297,6 +307,7 @@ func player_victory():
 
 func _someone_victory(name):
         if !victorious_players.has(name):
+                global._print("(MP) Someone's victory")
                 victorious_players.append(name)
 
                 var label = get_node("/root/Spatial/label")