CodingPirates/godot-demo-projects
1
0
Fork 0
mirror of https://github.com/godotengine/godot-demo-projects.git synced 2026-01-04 23:10:08 +01:00
Code Issues Packages Projects Releases Wiki Activity

make websocket pool every time

Browse Source
This commit is contained in:
Satoshi Disciple
2023-10-16 22:53:00 -03:00
parent fc7ff91882
commit db8ac0422d
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
networking/webrtc_signaling/client/ws_webrtc_client.gd
View File

@@ -9,6 +9,7 @@ enum Message {JOIN, ID, PEER_CONNECT, PEER_DISCONNECT, OFFER, ANSWER, CANDIDATE,
var ws: WebSocketPeer = WebSocketPeer.new() var ws: WebSocketPeer = WebSocketPeer.new()
var code = 1000 var code = 1000
var reason = "Unknown" var reason = "Unknown"
var old_state = WebSocketPeer.STATE_CLOSED
signal lobby_joined(lobby) signal lobby_joined(lobby)
signal connected(id, use_mesh) signal connected(id, use_mesh)
@@ -33,9 +34,6 @@ func close():
func _process(delta): func _process(delta):
var old_state: int = ws.get_ready_state()
if old_state == WebSocketPeer.STATE_CLOSED:
return
ws.poll() ws.poll()
var state = ws.get_ready_state() var state = ws.get_ready_state()
if state != old_state and state == WebSocketPeer.STATE_OPEN and autojoin: if state != old_state and state == WebSocketPeer.STATE_OPEN and autojoin:
@@ -43,10 +41,11 @@ func _process(delta):
while state == WebSocketPeer.STATE_OPEN and ws.get_available_packet_count(): while state == WebSocketPeer.STATE_OPEN and ws.get_available_packet_count():
if not _parse_msg(): if not _parse_msg():
print("Error parsing message from server.") print("Error parsing message from server.")
if state == WebSocketPeer.STATE_CLOSED: if state != old_state and state == WebSocketPeer.STATE_CLOSED:
code = ws.get_close_code() code = ws.get_close_code()
reason = ws.get_close_reason() reason = ws.get_close_reason()
disconnected.emit() disconnected.emit()
old_state = state
func _parse_msg(): func _parse_msg():