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
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
|
print "Accept"
from mpi4py.MPI import *
from Xdmf import *
if __name__ == "__main__":
if get_vendor()[0] == 'Open MPI':
print "Interprogram DSM does not work properly with OpenMPI"
else:
#//initMPI begin
dsmSize = 64
comm = COMM_WORLD
id = comm.Get_rank()
size = comm.Get_size()
newPath = "dsm";
numServersCores = size - 1;
numConnections = 2
exampleWriter = XdmfHDF5WriterDSM.New(newPath, comm, dsmSize/numServersCores, 1, 1, "Accept");
if id == 0:
#//initMPI end
#//GetDsmFileName begin
connectionFileName = exampleWriter.getServerBuffer().GetComm().GetDsmFileName()
#//GetDsmFileName end
#//SetDsmFileName begin
exampleWriter.getServerBuffer().GetComm().SetDsmFileName(connectionFileName)
#//SetDsmFileName end
#//OpenPort begin
exampleWriter.getServerBuffer().GetComm().OpenPort()
#//OpenPort end
#//SendAccept begin
exampleWriter.getServerBuffer().SendAccept(numConnections)
#//SendAccept end
'''
#//manualAccept begin
# Notify the server cores to accept connections
for i in range(exampleWriter.getServerBuffer().StartServerId, exampleWriter.getServerBuffer().EndServerId+1):
if i != exampleWriter.getServerBuffer().Comm.GetId():
exampleWriter.getServerBuffer().SendCommandHeader(XDMF_DSM_ACCEPT, i, 0, 0, XDMF_DSM_INTER_COMM)
exampleWriter.getServerBuffer().SendAcknowledgment(i, numConnections, XDMF_DSM_EXCHANGE_TAG, XDMF_DSM_INTER_COMM)
# Accept connections
exampleWriter.getServerBuffer().Comm.Accept(numConnections)
# Distribute current DSM status
exampleWriter.getServerBuffer().SendInfo()
#//manualAccept end
'''
#//finishwork begin
exampleWriter.getServerBuffer().GetComm().GetIntraComm().Barrier()
exampleWriter.getServerBuffer().GetComm().GetInterComm().Barrier()
#//finishwork end
#//ClosePort begin
if id == 0:
exampleWriter.getServerBuffer().GetComm().ClosePort()
#//ClosePort end
|
