##// END OF EJS Templates
ABS » abscontrol
RSS
First beam is loaded by default after sending the beam file to the control modules.
First beam is loaded by default after sending the beam file to the control modules.
jsalyrosas - - Load All Authors

File last commit:

r165:166
r231:232
Show More
server2.py
368 lines | 11.6 KiB | text/x-python | PythonLexer
/ trunk / absroot / source / abspy / bin / server2.py
History | Source | Raw |Copy content |Copy permalink
imanay
r62 import os
imanay
r92 import library2
imanay
r62 import time
class ABSServer:
imanay
r92 def __init__(self,ipSource="localhost", ipDestino="192.168.1.117", portDestino=7000, ipDestino2="192.168.1.11", portDestino2=5500):
imanay
r62
self.ipSource = ipSource
self.ipDestino = ipDestino
self.portDestino = portDestino
self.ipDestino2 = ipDestino2
self.portDestino2 = portDestino2
self.tx_buffer = "default"
imanay
r92 self.rx_buffer = "default"
imanay
r62
self.createObjects()
def createObjects(self):
asServer = True
imanay
r92 self.commServerObj = library2.TCPComm("Central_Control", self.ipDestino, self.portDestino, asServer)
self.commClientObj = library2.TCPComm("Central_Control", self.ipDestino2, self.portDestino2)
imanay
r62
def waitRequest(self):
imanay
r92 # Using rx buffer
ipSource, ipDestino, cmd, self.rx_buffer = self.commServerObj.waitServer()
imanay
r62
if cmd == "SNDF":
imanay
r92 datarpta = self.sendFile2Modules(mode=2, cmd = cmd)
imanay
r62
if cmd == "CHGB":
imanay
r92 datarpta = self.changeBeam(cmd = cmd)
imanay
r62
if cmd == "ANST":
imanay
r92 self.getStatus(mode=4, cmd = cmd)
# Using tx buffer
imanay
r62 datarpta = self.tx_buffer
imanay
r92 self.commServerObj.sendData2(cmd=cmd, data=datarpta, ipDestino = ipSource)
imanay
r62
def checkModule(self, address):
cmd = "ping -c 1 -w 1 192.168.1."+ str(address) + " >> /dev/null"
status = os.system(cmd)
if status == 256:
return False
return True
def __writeReport(self, enaModules):
status_array = ["Status of modules\n"]
status_array.append("----------------\n")
for address in range(1,65):
if address in enaModules:
status_array.append("192.168.1." + str(address) + " [1 1]\n")
else:
status_array.append("192.168.1." + str(address) + " [0 0]\n")
f = open("module_status.txt","w")
f.writelines(status_array)
f.close()
def checkAntenna(self):
"""
Direccion de los modulos de las antenas:
Norte : 01-16
Este : 17-32
Oeste: : 33-48
Sur : 49-64
"""
enaModules = []
for address in range(1,65):
if self.checkModule(address):
enaModules.append(address)
self.__writeReport(enaModules)
return enaModules
imanay
r92 def sendFile2Modules(self, mode, cmd):
if mode == 1:
self.__sendFile2Modules1()
else:
self.__sendFile2Modules2(cmd)
def __sendFile2Modules1(self):
imanay
r62
#Needed for the loop
imanay
r92 rx_frame_list = self.rx_buffer.split('\n',2)
imanay
r62
self.experiment_name = rx_frame_list[0]
experiment_number = rx_frame_list[1]
str_control_modules = rx_frame_list[2]
lst_control_modules = str_control_modules.split("------\n")
imanay
r92 # enaModules = self.checkAntenna()
enaModules = [11,12,13,14]
imanay
r62
for address in range(1,65):
if address not in enaModules:
continue
self.__writeModuleFile(self.experiment_name, lst_control_modules[address-1])
cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c put " + self.experiment_name
print cmd
os.system(cmd)
self.__loadFile()
imanay
r92 def __sendFile2Modules2(self,cmd):
#Needed for the loop
rx_frame_list = self.rx_buffer.split('\n',2)
correct = 0
failure = 0
header = rx_frame_list[0] + "\n"
str_control_modules = rx_frame_list[2]
lst_control_modules = str_control_modules.split("------\n")
# enaModules = self.checkAntenna()
enaModules = [11,12,13,14]
for id in range(1,65):
if id not in enaModules:
continue
#tcp client needed
self.commClientObj.open_socket()
ip = "192.168.1." + str(id)
self.commClientObj.sendData2(cmd, header + lst_control_modules[id-1], ip)
ipSource, ipDestino, cmd, tmp = self.commClientObj.waitClient()
self.commClientObj.close_socket()
if tmp == "OK":
correct = correct + 1
else:
failure = failure + 1
if correct == len(enaModules):
rpta = "OK"
else:
rpta = "Failure"
return rpta
imanay
r62 def __writeModuleFile(self, filename, str):
fobj = open(filename,"w")
fobj.write(filename + "\n")
fobj.write("------\n")
fobj.write(str)
fobj.write("------\n")
fobj.close()
def __readModuleFile(self, filename):
fobj1 = open(filename,"r")
file_list_1 = fobj1.readlines()
fobj1.close()
content_str = ''.join(file_list_1[2:-1])
return content_str
def __loadFile(self):
#Working with the UDP socket
self.commClientObj.sendData("none", "CARGA:" + self.experiment_name + ":")
self.commClientObj.sendData("none", "CAMBIA:0:")
imanay
r92 def changeBeam(self, cmd):
imanay
r62
imanay
r92 correct = 0
failure = 0
# enaModules = self.checkAntenna()
enaModules = [11,12,13,14]
imanay
r62
imanay
r92 for id in range(1,65):
if id not in enaModules:
continue
self.commClientObj.open_socket()
ip = "192.168.1." + str(id)
self.commClientObj.sendData2(cmd, self.rx_buffer, ip)
# ipSource, ipDestino, cmd, tmp = self.commClientObj.waitData()
ipSource, ipDestino, cmd, tmp = self.commClientObj.waitClient()
self.commClientObj.close_socket()
if tmp == "OK":
correct = correct + 1
else:
failure = failure + 1
if correct == len(enaModules):
rpta = "OK"
else:
rpta = "Failure"
return rpta
def getStatus(self, mode, cmd):
imanay
r62 if mode == 1:
self.__getStsMode1()
elif mode == 2:
self.__getStsMode2()
imanay
r92 elif mode == 3:
self.__getStsMode3()
imanay
r62 else:
imanay
r92 self.__getStsMode4(cmd)
imanay
r62
def __getStsMode1(self):
#rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
imanay
r92 self.commClientObj.sendData("CHEQUEO:" + self.rx_buffer + ":")
seconds = int (self.rx_buffer)
imanay
r62 # Give 5 seconds to the control modules
time.sleep(seconds)
# Checking the module connection
module_list = self.connection_status(10)
#Generating the complete report
module = 1
number_of_modules = 16
filename1 = "Verificacion"
filename2 = "report.txt"
fobj2 = open(filename2,"w")
fobj2.write("Verification_file\n")
fobj2.write("-----------------\n")
fobj2.close()
while module <= number_of_modules:
if module_list[module -1] == "1":
#Preparing and doing the tftp command
cmd = "tftp -m binary 192.168.1."+ str(base + module) +" 69 -c get " + filename1
print cmd
os.system(cmd)
# Getting data from the control module file
fobj1 = open(filename1,"r")
file_list_1 = fobj1.readlines()
fobj1.close()
content = file_list_1[2:-1]
#
fobj2 = open(filename2,"a")
if base == 10:
fobj2.write("S" + str(module) + "\n")
else:
fobj2.write("N" + str(module) + "\n")
fobj2.writelines(content)
fobj2.write("------\n")
fobj2.close()
module = module + 1
def __getStsMode2(self):
#rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
imanay
r92 self.commClientObj.sendData("CHEQUEO:" + self.rx_buffer + ":")
seconds = int (self.rx_buffer)
imanay
r62 # Give 5 seconds to the control modules
time.sleep(seconds)
# Checking the module connection
enaModules = self.checkAntenna()
#Generating the complete report
filename1 = "Verificacion"
line1 = "Verification_file\n"
line2 = "-----------------\n"
report_list = [line1, line2]
for address in range(1,65):
if address not in enaModules:
continue
#Preparing and doing the tftp command
cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c get " + filename1
print cmd
os.system(cmd)
#Sub_header
report_list.append("ABS_" + str(address) + "\n")
# Content
fobj1 = open(filename1,"r")
file_list_1 = fobj1.readlines()
fobj1.close()
content = ''.join(file_list_1[2:-1])
report_list.append(content)
#Ending
report_list.append("------\n")
#print "\nFinalizado"
self.tx_buffer = ''.join(report_list)
def __AddingHeader(self,content_list, title):
line1 = title + "\n"
line2 = "-----------------\n"
header_list = [line1, line2]
verification_list = header_list + content_list
# Arming the frame
self.tx_buffer = ''.join(verification_list)
def __getModuleFile(self, filename):
enaModules = self.checkAntenna()
content_list = []
for address in range(1,65):
if address not in enaModules:
continue
#Preparing and doing the tftp command
cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c get " + filename
print cmd
os.system(cmd)
#Sub_header
content_list.append("ABS_" + str(address) + "\n")
# From module file to list
content_str = self.__readModuleFile(filename)
content_list.append(content_str)
content_list.append("------\n")
self.__AddingHeader(content_list, title = "Verification_file")
def __getStsMode3(self):
imanay
r92 self.commClientObj.sendData("none", "CHEQUEO:" + self.rx_buffer + ":")
seconds = int (self.rx_buffer)
imanay
r62 # Give 5 seconds to the control modules
time.sleep(seconds)
self.__getModuleFile(filename = "Verificacion")
imanay
r92
def __getStsMode4(self, cmd):
imanay
r62
imanay
r92 content_str = ""
# enaModules = self.checkAntenna()
enaModules = [11,12,13,14]
for id in range(1,65):
if id not in enaModules:
continue
self.commClientObj.open_socket()
ip = "192.168.1." + str(id)
self.commClientObj.sendData2(cmd, self.rx_buffer, ip)
ipSource, ipDestino, cmd, tmp = self.commClientObj.waitClient()
self.commClientObj.close_socket()
content_str = content_str + tmp
# self.__AddingHeader(content_list, title = "Verification_file")
#Using tx buffer
self.tx_buffer = content_str
imanay
r62 if __name__ == '__main__':
absObj = ABSServer()
while 1:
absObj.waitRequest()