basic_python_client-server/server.py at main · Morgane55440/basic_python_client-server · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
# Server
frompymathfunimportfibo_c
importquery_struct

importsocket
importasyncio
importpickle


HOST="127.0.0.1"
PORT=55557
MAX_DATA_SIZE=1024
CLIENT_NB=1


asyncdefasync_exec(query : query_struct.Query) ->None:
"""
 executes a computable query
 """
if (query.type==query_struct.Query_type.COMPUTE_FIBO):
res=fibo_c(query.value) # Where there is potentially a long exectution time
query.result=res
query.status=query_struct.Query_Status.DONE


asyncdefget_next_query(client_socket, result_list):
"""
 accepts a query, schedules or executes it immediatly depending on type, the calls itself recursively
 """
try:
query=pickle.loads(client_socket.recv(MAX_DATA_SIZE))
except:
print("client disconnected")
return
print('new query : {0}'.format(query.type))
ifquery.type==query_struct.Query_type.COMPUTE_FIBO:
query.status=query_struct.Query_Status.SCHEDULED
result_list.append(query)
returnawaitasyncio.gather(get_next_query(client_socket, result_list), async_exec(query))
ifquery.type==query_struct.Query_type.LIST:
client_socket.send(pickle.dumps(result_list))
returnawaitget_next_query(client_socket, result_list)

defserver_start(client_socket):
"""
 starting point for the server
 """
result_list= []
asyncio.run(get_next_query(client_socket, result_list))


defmain():
server_socket=socket.socket()
server_socket.bind((HOST, PORT))
whileTrue:
server_socket.listen(CLIENT_NB)
client, _=server_socket.accept()
print("client connected")
server_start(client)

if__name__=="__main__":
main()