##// END OF EJS Templates
ABS » abscontrol
RSS
imanay -
r54:55
parent child
Show More
Show file before | Show file after | Hide comments
@@ -39,10 +39,17
39 self.commObj.sendData(cmd="CHGB", data=newBeam)
39 self.commObj.sendData(cmd="CHGB", data=newBeam)
40 self.commObj.waitData()
40 self.commObj.waitData()
41
41
42 def __writeFile(self, filename, data):
43
44 fobj = open(filename,"w")
45 fobj.writelines(data)
46 fobj.close()
47
42 def getStatus(self, data):
48 def getStatus(self, data):
43
49
44 self.commObj.sendData(cmd="ANST", data = data)
50 self.commObj.sendData(cmd="ANST", data = data)
45 self.commObj.waitData2()
51 ipSource, ipDestino, cmd, data = self.commObj.waitData()
52 self.__writeFile("report.txt", data)
46
53
47 ##########
54 ##########
48
55
Show file before | Show file after | Hide comments
@@ -12,6 +12,7
12 self.portDestino = portDestino
12 self.portDestino = portDestino
13 self.addr = (ipDestino,portDestino)
13 self.addr = (ipDestino,portDestino)
14 self.answer = ipDestino #test
14 self.answer = ipDestino #test
15 self.mode = "none"
15
16
16 self.openSocket(asServer)
17 self.openSocket(asServer)
17
18
@@ -23,8 +24,10
23
24
24 if asServer:
25 if asServer:
25 self.configAsServer()
26 self.configAsServer()
27 self.mode = "server"
26 else:
28 else:
27 self.configAsClient()
29 self.configAsClient()
30 self.mode = "client"
28
31
29 def configAsClient(self):
32 def configAsClient(self):
30 #Configurar broadcast
33 #Configurar broadcast
@@ -40,42 +43,25
40 print "\nWaiting some data"
43 print "\nWaiting some data"
41 trama_rx, self.answer = self.socket_c.recvfrom(nbytes)
44 trama_rx, self.answer = self.socket_c.recvfrom(nbytes)
42 print "\nThis socket has received some data"
45 print "\nThis socket has received some data"
46 print self.answer
43 ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx)
47 ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx)
44
45 return ipSource, ipDestino, cmd, data
46
47 def waitData2(self, nbytes = 16384):
48
49 print "\nWaiting some data"
50 trama_rx, self.answer = self.socket_c.recvfrom(nbytes)
51 print "\nThis socket has received some data"
52 ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx)
53 filename = "report.txt"
54 fobj = open(filename,"w")
55 fobj.writelines(data)
56 fobj.close()
57
48
58 return ipSource, ipDestino, cmd, data
49 return ipSource, ipDestino, cmd, data
59
50
60 def sendData(self, cmd, data):
51 def sendData(self, cmd, data):
61
52
62 trama_tx = self.__HEADER + ":" + str(self.ipSource) + ":" + str(self.ipDestino) + ":" + str(cmd) + ":" + str(data) + ":"
53 if self.portDestino == 7000:
54 trama_tx = self.__HEADER + ":" + str(self.ipSource) + ":" + str(self.ipDestino) + ":" + str(cmd) + ":" + str(data) + ":"
55 else:
56 trama_tx = data
57
58 if self.mode == "client":
59 destiny = self.addr
60 else:
61 destiny = self.answer
63 # Send messages
62 # Send messages
64 if(self.socket_c.sendto(trama_tx, self.addr)):
63 if(self.socket_c.sendto(trama_tx, destiny)):
65 print "Sending message:[" + trama_tx + "]"
64 print "Sending message:[" + trama_tx + "]"
66
67 def sendData2(self, cmd, data):
68
69 trama_tx = self.__HEADER + ":" + str(self.ipSource) + ":" + str(self.ipDestino) + ":" + str(cmd) + ":" + str(data) + ":"
70 # Send messages
71 if(self.socket_c.sendto(trama_tx, self.answer)):
72 print "Sending message:[" + trama_tx + "]"
73
74 def sendData2ControlModules(self, trama_tx):
75
76 # Send messages
77 if(self.socket_c.sendto(trama_tx, self.addr)):
78 print "Sending message:[" + trama_tx + "]"
79
65
80 def __getTrama(self, trama):
66 def __getTrama(self, trama):
81
67
Show file before | Show file after | Hide comments
@@ -25,52 +25,6
25 self.commServerObj = library.UDPComm(self.ipSource, self.ipDestino, self.portDestino, asServer)
25 self.commServerObj = library.UDPComm(self.ipSource, self.ipDestino, self.portDestino, asServer)
26 self.commClientObj = library.UDPComm(self.ipSource, self.ipDestino2, self.portDestino2)
26 self.commClientObj = library.UDPComm(self.ipSource, self.ipDestino2, self.portDestino2)
27 #self.ftpCommObj = library.FTPComm(self.ipSource, self.ipDestino, self.ftpPortDestino)
27 #self.ftpCommObj = library.FTPComm(self.ipSource, self.ipDestino, self.ftpPortDestino)
28
29 def sendFile(self, base):
30
31 #Needed for the loop
32 rx_frame_list = self.datarx.split('\n',2)
33
34 experiment_name = rx_frame_list[0]
35 experiment_number = rx_frame_list[1]
36 str_control_modules = rx_frame_list[2]
37
38 lst_control_modules = str_control_modules.split("------\n")
39 #Setting variables of the loop
40 i =3
41 module = 1
42 number_of_modules = 16
43 number_of_beams = int (experiment_number)
44 module_list = self.connection_status(10)
45 #Loop for creating and sending the control module files
46 while module <= number_of_modules:
47 #Generating the control modules files
48 fobj = open(experiment_name,"w")
49 fobj.write(experiment_name + "\n")
50 fobj.write("------\n")
51 # tmp_list = rx_frame_list[i:i + number_of_beams + 1]
52 fobj.write(lst_control_modules[module-1])
53 fobj.write("------\n")
54 fobj.close()
55 if module_list[module -1] == "1":
56 #Preparing and doing the tftp command
57 cmd = "tftp -m binary 192.168.1."+ str(base + module) +" 69 -c put " + experiment_name
58 print cmd
59 os.system(cmd)
60 #Updating variables of the loop
61 i = i + number_of_beams + 2
62 module += 1
63 #Working with the UDP socket
64 # self.commClientObj.sendData2ControlModules("CARGA:" + experiment_name + ":")
65 # self.commClientObj.sendData2ControlModules("CAMBIA:0:")
66 #Another tftp way
67 # self.ftpCommObj.sendFile(filename)
68 # rpta = self.commClientObj.sendTxRxCommand(cmd# filename2 = "report.txt"
69 #fobj2 = open(filename2,"w")
70 #fobj2.write("Verification_file\n")
71 #fobj2.write("-----------------\n")
72 #fobj2.close()='CARGA', data=filename)
73 self.experiment_name = experiment_name
74
28
75
29
76 def waitRequest(self):
30 def waitRequest(self):
@@ -86,11 +40,20
86 self.changeBeam()
40 self.changeBeam()
87
41
88 if cmd == "ANST":
42 if cmd == "ANST":
89 self.getStatus(10, mode=2)
43 self.getStatus(mode=3)
90 datarpta = self.tx_buffer
44 datarpta = self.tx_buffer
91
45
92 self.commServerObj.sendData2(cmd=cmd, data=datarpta)
46 self.commServerObj.sendData(cmd=cmd, data=datarpta)
93
47
48 def checkModule(self, address):
49
50 cmd = "ping -c 1 -w 1 192.168.1."+ str(address) + " >> /dev/null"
51 status = os.system(cmd)
52
53 if status == 256:
54 return False
55
56 return True
94
57
95 def __writeReport(self, enaModules):
58 def __writeReport(self, enaModules):
96
59
@@ -107,16 +70,6
107 f = open("module_status.txt","w")
70 f = open("module_status.txt","w")
108 f.writelines(status_array)
71 f.writelines(status_array)
109 f.close()
72 f.close()
110
111 def checkModule(self, address):
112
113 cmd = "ping -c 1 -w 1 192.168.1."+ str(address) + " >> /dev/null"
114 status = os.system(cmd)
115
116 if status == 256:
117 return False
118
119 return True
120
73
121 def checkAntenna(self):
74 def checkAntenna(self):
122
75
@@ -138,12 +91,34
138
91
139 self.__writeReport(enaModules)
92 self.__writeReport(enaModules)
140 return enaModules
93 return enaModules
141
94
142 def __loadFile(self):
95 def sendFile2Modules(self):
143
96
144 #Working with the UDP socket
97 #Needed for the loop
145 self.commClientObj.sendData2ControlModules("CARGA:" + self.experiment_name + ":")
98 rx_frame_list = self.datarx.split('\n',2)
146 self.commClientObj.sendData2ControlModules("CAMBIA:0:")
99
100 experiment_name = rx_frame_list[0]
101 experiment_number = rx_frame_list[1]
102 str_control_modules = rx_frame_list[2]
103
104 lst_control_modules = str_control_modules.split("------\n")
105
106 enaModules = self.checkAntenna()
107
108 for address in range(1,65):
109
110 if address not in enaModules:
111 continue
112
113 self.__writeModuleFile(experiment_name, lst_control_modules[address-1])
114
115 cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c put " + experiment_name
116 print cmd
117 os.system(cmd)
118
119 self.experiment_name = experiment_name
120
121 self.__loadFile()
147
122
148 def __writeModuleFile(self, filename, str):
123 def __writeModuleFile(self, filename, str):
149
124
@@ -153,43 +128,40
153 fobj.write(str)
128 fobj.write(str)
154 fobj.write("------\n")
129 fobj.write("------\n")
155 fobj.close()
130 fobj.close()
156
131
157 def sendFile2Modules(self):
132 def __readModuleFile(self, filename):
158
133
159 #Needed for the loop
134 fobj1 = open(filename,"r")
160 rx_frame_list = self.datarx.split('\n',2)
135 file_list_1 = fobj1.readlines()
161
136 fobj1.close()
162 experiment_name = rx_frame_list[0]
137 content_str = ''.join(file_list_1[2:-1])
163 experiment_number = rx_frame_list[1]
138
164 str_control_modules = rx_frame_list[2]
139 return content_str
165
140
166 lst_control_modules = str_control_modules.split("------\n")
141 def __loadFile(self):
167
142
168 enaModules = self.checkAntenna()
143 #Working with the UDP socket
169
144 self.commClientObj.sendData("none", "CARGA:" + self.experiment_name + ":")
170 for address in range(1,65):
145 self.commClientObj.sendData("none", "CAMBIA:0:")
171
172 if address not in enaModules:
173 continue
174
175 self.__writeModuleFile(experiment_name, lst_control_modules[address-1])
176
177 cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c put " + experiment_name
178 print cmd
179 os.system(cmd)
180
181 self.experiment_name = experiment_name
182
183 self.__loadFile()
184
146
185 def changeBeam(self):
147 def changeBeam(self):
186
148
187 #rpta = self.commClientObj.sendTxRxCommand(cmd='CAMBIA', data="0")
149 #rpta = self.commClientObj.sendTxRxCommand(cmd='CAMBIA', data="0")
188 self.commClientObj.sendData2ControlModules("CAMBIA:" + self.datarx + ":")
150 self.commClientObj.sendData("CAMBIA:" + self.datarx + ":")
151
152 def getStatus(self,mode):
153
154 if mode == 1:
155 self.__getStsMode1()
156 elif mode == 2:
157 self.__getStsMode2()
158 else:
159 self.__getStsMode3()
160
189
161
190 def __getStsMode1(self):
162 def __getStsMode1(self):
191 #rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
163 #rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
192 self.commClientObj.sendData2ControlModules("CHEQUEO:" + self.datarx + ":")
164 self.commClientObj.sendData("CHEQUEO:" + self.datarx + ":")
193 seconds = int (self.datarx)
165 seconds = int (self.datarx)
194 # Give 5 seconds to the control modules
166 # Give 5 seconds to the control modules
195 time.sleep(seconds)
167 time.sleep(seconds)
@@ -229,15 +201,13
229 def __getStsMode2(self):
201 def __getStsMode2(self):
230
202
231 #rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
203 #rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
232 self.commClientObj.sendData2ControlModules("CHEQUEO:" + self.datarx + ":")
204 self.commClientObj.sendData("CHEQUEO:" + self.datarx + ":")
233 seconds = int (self.datarx)
205 seconds = int (self.datarx)
234 # Give 5 seconds to the control modules
206 # Give 5 seconds to the control modules
235 time.sleep(seconds)
207 time.sleep(seconds)
236 # Checking the module connection
208 # Checking the module connection
237 enaModules = self.checkAntenna()
209 enaModules = self.checkAntenna()
238 #Generating the complete report
210 #Generating the complete report
239 module = 1
240 number_of_modules = 16
241 filename1 = "Verificacion"
211 filename1 = "Verificacion"
242 line1 = "Verification_file\n"
212 line1 = "Verification_file\n"
243 line2 = "-----------------\n"
213 line2 = "-----------------\n"
@@ -262,54 +232,46
262 #Ending
232 #Ending
263 report_list.append("------\n")
233 report_list.append("------\n")
264 #print "\nFinalizado"
234 #print "\nFinalizado"
265 self.tx_buffer = ''.join(report_list)
235 self.tx_buffer = ''.join(report_list)
266
236
237 def __AddingHeader(self,content_list, title):
238
239 line1 = title + "\n"
240 line2 = "-----------------\n"
241 header_list = [line1, line2]
242 verification_list = header_list + content_list
243 # Arming the frame
244 self.tx_buffer = ''.join(verification_list)
245
246 def __getModuleFile(self, filename):
247
248 enaModules = self.checkAntenna()
249 content_list = []
250 for address in range(1,65):
251
252 if address not in enaModules:
253 continue
254 #Preparing and doing the tftp command
255 cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c get " + filename
256 print cmd
257 os.system(cmd)
258 #Sub_header
259 content_list.append("ABS_" + str(address) + "\n")
260 # From module file to list
261 content_str = self.__readModuleFile(filename)
262 content_list.append(content_str)
263 content_list.append("------\n")
264
265 self.__AddingHeader(content_list, title = "Verification_file")
266
267 def __getStsMode3(self):
267 def __getStsMode3(self):
268
268
269 #rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
269 self.commClientObj.sendData("CHEQUEO:" + self.datarx + ":")
270 self.commClientObj.sendData2ControlModules("CHEQUEO:" + self.datarx + ":")
271 seconds = int (self.datarx)
270 seconds = int (self.datarx)
272 # Give 5 seconds to the control modules
271 # Give 5 seconds to the control modules
273 time.sleep(seconds)
272 time.sleep(seconds)
274 # Checking the module connection
273
275 module_list = self.connection_status(10)
274 self.__getModuleFile(filename = "Verificacion")
276 #Generating the complete report
277 module = 1
278 number_of_modules = 16
279 filename1 = "Verificacion"
280 line1 = "Verification_file\n"
281 line2 = "-----------------\n"
282 report_list = [line1, line2]
283 while module <= number_of_modules:
284 if module_list[module -1] == "1":
285 #Preparing and doing the tftp command
286 cmd = "tftp -m binary 192.168.1."+ str(base + module) +" 69 -c get " + filename1
287 print cmd
288 os.system(cmd)
289 #Sub_header
290 if base == 10:
291 report_list.append("S" + str(module) + "\n")
292 else:
293 report_list.append("N" + str(module) + "\n")
294 # Content
295 fobj1 = open(filename1,"r")
296 file_list_1 = fobj1.readlines()
297 fobj1.close()
298 content = ''.join(file_list_1[2:-1])
299 # content = "010101\n"
300 report_list.append(content)
301 #Ending
302 report_list.append("------\n")
303 module = module + 1
304 #print "\nFinalizado"
305 self.tx_buffer = ''.join(report_list)
306
307 def getStatus(self, base, mode):
308
309 if mode == 1:
310 self.__getStsMode1()
311 else:
312 self.__getStsMode2()
313
275
314
276
315 if __name__ == '__main__':
277 if __name__ == '__main__':
General Comments 0
You need to be logged in to leave comments. Login now