|
8
|
1 import re
|
|
|
2 import sys
|
|
|
3 import string
|
|
|
4 import time
|
|
|
5
|
|
|
6 sys.path.append('../modules')
|
|
|
7
|
|
|
8 import FederatedLinda
|
|
|
9
|
|
|
10 ROUTING_HEADER_FORMAT = "!I"
|
|
|
11 TUPLE_ID_LINKCONFIG = 1
|
|
|
12 TUPLE_ID_ROUTING = 2
|
|
|
13
|
|
|
14 ROUTING_COMMAND_CONNECT = 1
|
|
|
15 ROUTING_COMMAND_DISCONNECT = 2
|
|
|
16 ROUTING_COMMAND_TRANSFER = 3
|
|
|
17 ROUTING_COMMAND_UPDATE_TABLE = 4
|
|
|
18
|
|
|
19 testxml = \
|
|
|
20 """
|
|
|
21 <graph name = "Graf">
|
|
|
22 <node label = "Node008" tsid = "ant014.cs.ie.u-ryukyu.ac.jp:10008">
|
|
|
23 <destination label = "Node005"/>
|
|
|
24 <destination label = "Node006"/>
|
|
|
25 <destination label = "Node009"/>
|
|
|
26 </node>
|
|
|
27 <node label = "Node007" tsid = "ant013.cs.ie.u-ryukyu.ac.jp:10007">
|
|
|
28 <destination label = "Node003"/>
|
|
|
29 <destination label = "Node004"/>
|
|
|
30 <destination label = "Node009"/>
|
|
|
31 </node>
|
|
|
32 <node label = "Node006" tsid = "ant012.cs.ie.u-ryukyu.ac.jp:10006">
|
|
|
33 <destination label = "Node001"/>
|
|
|
34 <destination label = "Node002"/>
|
|
|
35 <destination label = "Node008"/>
|
|
|
36 </node>
|
|
|
37 <node label = "Node005" tsid = "ant011.cs.ie.u-ryukyu.ac.jp:10005">
|
|
|
38 <destination label = "Node000"/>
|
|
|
39 <destination label = "Node008"/>
|
|
|
40 </node>
|
|
|
41 <node label = "Node004" tsid = "ant005.cs.ie.u-ryukyu.ac.jp:10004">
|
|
|
42 <destination label = "Node007"/>
|
|
|
43 </node>
|
|
|
44 <node label = "Node003" tsid = "ant004.cs.ie.u-ryukyu.ac.jp:10003">
|
|
|
45 <destination label = "Node007"/>
|
|
|
46 </node>
|
|
|
47 <node label = "Node002" tsid = "ant003.cs.ie.u-ryukyu.ac.jp:10002">
|
|
|
48 <destination label = "Node006"/>
|
|
|
49 </node>
|
|
|
50 <node label = "Node001" tsid = "ant002.cs.ie.u-ryukyu.ac.jp:10001">
|
|
|
51 <destination label = "Node006"/>
|
|
|
52 </node>
|
|
|
53 <node label = "Node000" tsid = "ant001.cs.ie.u-ryukyu.ac.jp:10000">
|
|
|
54 <destination label = "Node005"/>
|
|
|
55 </node>
|
|
|
56 <node label = "Node009" tsid = "ant015.cs.ie.u-ryukyu.ac.jp:10009">
|
|
|
57 <destination label = "Node007"/>
|
|
|
58 <destination label = "Node008"/>
|
|
|
59 </node>
|
|
|
60 </graph>
|
|
|
61 """
|
|
|
62 def getFirstTsid(xmltext):
|
|
|
63 p = re.compile('(?<=tsid = \").*(?=\")')
|
|
|
64 m = p.findall(xmltext)
|
|
|
65 return m[0]
|
|
|
66
|
|
|
67
|
|
|
68
|
|
|
69 if __name__ == "__main__":
|
|
|
70
|
|
|
71 if (len(sys.argv) == 2):
|
|
|
72 print " : %s <xmlfilename>" % sys.argv[0]
|
|
|
73 xmltext = open(sys.argv[1]).read()
|
|
|
74 if xmltext is None:
|
|
|
75 sys.exit(1)
|
|
|
76 else:
|
|
|
77 xmltext = testxml
|
|
|
78
|
|
|
79 start = time.time()
|
|
|
80 print "start time ",start
|
|
|
81
|
|
|
82 firsttsid = getFirstTsid(xmltext)
|
|
|
83
|
|
|
84 flinda = FederatedLinda.FederatedLinda()
|
|
|
85
|
|
|
86 host, portnum = string.split(firsttsid,':')
|
|
|
87
|
|
|
88 linda1 = flinda.open(host, int(portnum))
|
|
|
89 linda1.Out(TUPLE_ID_LINKCONFIG, testxml)
|
|
|
90 flinda.sync()
|
|
|
91
|
|
|
92
|
|
|
93
|
