Bennett/Arcaea-server
1
0
Fork 0
mirror of https://github.com/Lost-MSth/Arcaea-server.git synced 2026-02-12 11:07:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

Try to fix a bug in Unix

Browse Source 
multiprocess bug of python in Unix operating system:
The subprocess will not start when using 'fork' mode. This will make the UDP server down.
This commit is contained in:
Lost-MSth
2022-04-05 22:12:23 +08:00
parent 4b8c5a520e
commit 35c34f25d5
2 changed files with 17 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
latest version/main.py
View File

@@ -20,7 +20,7 @@ import server.arclinkplay
from udpserver.udp_main import link_play from udpserver.udp_main import link_play
import os import os
import sys import sys
from multiprocessing import Process, Pipe from multiprocessing import Process, Pipe, set_start_method
from urllib.parse import parse_qs, urlparse from urllib.parse import parse_qs, urlparse
@@ -899,6 +899,7 @@ def main():
if __name__ == '__main__': if __name__ == '__main__':
set_start_method("spawn")
main() main()

18
latest version/server/arclinkplay.py
View File

@@ -46,7 +46,11 @@ def create_room(conn, user_id, client_song_map):
song_unlock = get_song_unlock(client_song_map) song_unlock = get_song_unlock(client_song_map)
conn.send((1, name, song_unlock)) conn.send((1, name, song_unlock))
data = conn.recv() if conn.poll(10):
data = conn.recv()
else:
data = (-1,)
if data[0] == 0: if data[0] == 0:
error_code = 0 error_code = 0
return error_code, {'roomCode': data[1], return error_code, {'roomCode': data[1],
@@ -74,7 +78,11 @@ def join_room(conn, user_id, client_song_map, room_code):
song_unlock = get_song_unlock(client_song_map) song_unlock = get_song_unlock(client_song_map)
conn.send((2, name, song_unlock, room_code)) conn.send((2, name, song_unlock, room_code))
data = conn.recv() if conn.poll(10):
data = conn.recv()
else:
data = (-1,)
if data[0] == 0: if data[0] == 0:
error_code = 0 error_code = 0
return error_code, {'roomCode': data[1], return error_code, {'roomCode': data[1],
@@ -96,7 +104,11 @@ def update_room(conn, user_id, token):
error_code = 108 error_code = 108
conn.send((3, int(token))) conn.send((3, int(token)))
data = conn.recv() if conn.poll(10):
data = conn.recv()
else:
data = (-1,)
if data[0] == 0: if data[0] == 0:
error_code = 0 error_code = 0
return error_code, {'roomCode': data[1], return error_code, {'roomCode': data[1],