@@ -16,17 +16,16 @@ Options:
16
16
from docopt import docopt
17
17
from mpi4py import MPI
18
18
19
- if __name__ == ' __main__' :
19
+ if __name__ == " __main__" :
20
20
opt = docopt (__doc__ )
21
21
22
- import time
22
+ import os
23
23
import sys
24
+ import time
24
25
25
26
import nest
26
27
import nest .server
27
28
28
- import os
29
-
30
29
HOST = os .getenv ("NEST_SERVER_HOST" , "127.0.0.1" )
31
30
PORT = os .getenv ("NEST_SERVER_PORT" , "52425" )
32
31
@@ -35,34 +34,33 @@ rank = comm.Get_rank()
35
34
36
35
37
36
def log (call_name , msg ):
38
- msg = f' ==> WORKER { rank } /{ time .time ():.7f} ({ call_name } ): { msg } '
37
+ msg = f" ==> WORKER { rank } /{ time .time ():.7f} ({ call_name } ): { msg } "
39
38
print (msg , flush = True )
40
39
41
40
42
41
if rank == 0 :
43
42
print ("==> Starting NEST Server Master on rank 0" , flush = True )
44
43
nest .server .set_mpi_comm (comm )
45
- nest .server .run_mpi_app (host = opt .get (' --host' , HOST ), port = opt .get (' --port' , PORT ))
44
+ nest .server .run_mpi_app (host = opt .get (" --host" , HOST ), port = opt .get (" --port" , PORT ))
46
45
47
46
else :
48
47
print (f"==> Starting NEST Server Worker on rank { rank } " , flush = True )
49
48
nest .server .set_mpi_comm (comm )
50
49
while True :
51
-
52
- log ('spinwait' , 'waiting for call bcast' )
50
+ log ("spinwait" , "waiting for call bcast" )
53
51
call_name = comm .bcast (None , root = 0 )
54
52
55
- log (call_name , ' received call bcast, waiting for data bcast' )
53
+ log (call_name , " received call bcast, waiting for data bcast" )
56
54
data = comm .bcast (None , root = 0 )
57
55
58
- log (call_name , f' received data bcast, data={ data } ' )
56
+ log (call_name , f" received data bcast, data={ data } " )
59
57
args , kwargs = data
60
58
61
- if call_name == ' exec' :
59
+ if call_name == " exec" :
62
60
response = nest .server .do_exec (args , kwargs )
63
61
else :
64
62
call , args , kwargs = nest .server .nestify (call_name , args , kwargs )
65
- log (call_name , f' local call, args={ args } , kwargs={ kwargs } ' )
63
+ log (call_name , f" local call, args={ args } , kwargs={ kwargs } " )
66
64
67
65
# The following exception handler is useful if an error
68
66
# occurs simulataneously on all processes. If only a
74
72
except Exception :
75
73
continue
76
74
77
- log (call_name , f' sending reponse gather, data={ response } ' )
75
+ log (call_name , f" sending reponse gather, data={ response } " )
78
76
comm .gather (nest .serializable (response ), root = 0 )
0 commit comments