##// 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
library.py
208 lines | 5.9 KiB | text/x-python | PythonLexer
/ trunk / absroot / source / abspy / bin / library.py
History | Source | Raw |Copy content |Copy permalink
imanay
Fedora 10 no deja instalar modulo tftp
 r41 #import tftpy
murco
-Se organizó la estructura de directorios....
 r19 import socket
imanay
Actualizacion del directorio
 r25
murco
-Se organizó la estructura de directorios....
 r19 class UDPComm:
__HEADER = "ABS"
imanay
Modificaciones a scripts python de cliente y servidor UDP
r27 def __init__(self, ipSource, ipDestino, portDestino, asServer=False):
murco
-Se organizó la estructura de directorios....
 r19
self.ipSource = ipSource
self.ipDestino = ipDestino
self.portDestino = portDestino
imanay
Modificaciones a scripts python de cliente y servidor UDP
r27 self.addr = (ipDestino,portDestino)
imanay
r60 self.answer = "none" #test
imanay
r54 self.mode = "none"
imanay
r92
murco
-Se organizó la estructura de directorios....
 r19
self.openSocket(asServer)
def openSocket(self, asServer):
imanay
Modificaciones a scripts python de cliente y servidor UDP
r27 #self.socket_c = socket.socket(AF_INET,SOCK_DGRAM)
self.socket_c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM,0)
# self.socket_c.connect((self.ipDestino, self.portDestino))
murco
-Se organizó la estructura de directorios....
 r19
if asServer:
self.configAsServer()
imanay
r54 self.mode = "server"
murco
-Se organizó la estructura de directorios....
 r19 else:
self.configAsClient()
imanay
r54 self.mode = "client"
murco
-Se organizó la estructura de directorios....
 r19
def configAsClient(self):
imanay
Modificaciones a scripts python de cliente y servidor UDP
r27 #Configurar broadcast
self.socket_c.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
murco
-Se organizó la estructura de directorios....
 r19
def configAsServer(self):
imanay
Modificaciones a scripts python de cliente y servidor UDP
r27 self.socket_c.bind(self.addr)
print "\nServer initialized"
murco
-Se organizó la estructura de directorios....
 r19
imanay
r46 def waitData(self, nbytes = 16384):
murco
-Se organizó la estructura de directorios....
 r19
imanay
r46 print "\nWaiting some data"
trama_rx, self.answer = self.socket_c.recvfrom(nbytes)
imanay
r55 print "\nThis socket has received some data from:"
imanay
r54 print self.answer
murco
-Se organizó la estructura de directorios....
 r19 ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx)
return ipSource, ipDestino, cmd, data
imanay
Modificaciones a scripts python de cliente y servidor UDP
r27
imanay
r46 def sendData(self, cmd, data):
imanay
Modificaciones a scripts python de cliente y servidor UDP
r27
imanay
r54 if self.portDestino == 7000:
trama_tx = self.__HEADER + ":" + str(self.ipSource) + ":" + str(self.ipDestino) + ":" + str(cmd) + ":" + str(data) + ":"
else:
trama_tx = data
imanay
Modificaciones a scripts python de cliente y servidor UDP
r27
imanay
r54 if self.mode == "client":
destiny = self.addr
else:
destiny = self.answer
imanay
r46 # Send messages
imanay
r54 if(self.socket_c.sendto(trama_tx, destiny)):
imanay
r55 print "Sending message:[" + trama_tx + "] to " + str(destiny)
murco
-Se organizó la estructura de directorios....
 r19
def __getTrama(self, trama):
imanay
Modificaciones a scripts python de cliente y servidor UDP
r27 FrameList = trama.split(':')
header = FrameList[0]
ipSource = FrameList[1]
ipDestino = FrameList[2]
cmd = FrameList[3]
data = FrameList[4]
trash = FrameList[5]
murco
-Se organizó la estructura de directorios....
 r19
return ipSource, ipDestino, cmd, data
imanay
r61 class TCPComm:
imanay
r92 __HEADER = "JRO"
__TYPE = "ABS"
imanay
r61
def __init__(self, ipSource, ipDestino, portDestino, asServer=False):
self.ipSource = ipSource
self.ipDestino = ipDestino
self.portDestino = portDestino
self.addr = (ipDestino,portDestino)
imanay
r63
self.sc = "none"
imanay
r61 self.answer = "none" #test
self.mode = "none"
imanay
r92 self.len = 0
self.crc = 0
imanay
r61
self.openSocket(asServer)
def openSocket(self, asServer):
#self.socket_c = socket.socket(AF_INET,SOCK_DGRAM)
imanay
r92 # self.socket_c = socket.socket()
imanay
r61 # self.socket_c.connect((self.ipDestino, self.portDestino))
if asServer:
imanay
r92 self.socket_c = socket.socket()
# self.configAsServer()
self.socket_c.bind(self.addr)
imanay
r61 self.mode = "server"
else:
imanay
r92 # self.configAsClient()
self.mode = "client" #Socket is opened at the sendData function
imanay
r61
imanay
r92 # def configAsClient(self):
imanay
r61 #Buscar broadcast TCP
# self.socket_c.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
imanay
r92 # self.socket_c.connect(self.addr)
# pass
imanay
r61
imanay
r92 # def configAsServer(self):
#
# self.socket_c.bind(self.addr)
imanay
r61
imanay
r70 def waitData(self, nbytes = 1024):
imanay
r61
imanay
r70 print "\nWaiting some client."
imanay
r61 if self.mode == "client":
imanay
r70 # Short data through ethernet
imanay
r63 trama_rx = self.socket_c.recv(nbytes)
imanay
r61 else:
imanay
r70 self.socket_c.listen(1)
sc, addr = self.socket_c.accept()
self.sc = sc
self.answer = addr
# Big data through ethernet
trama_rx = ""
while True:
tmp = self.sc.recv(nbytes)
trama_rx = trama_rx + tmp
if trama_rx[-4:] == "quit":
break
imanay
r61
imanay
r92 print "\nThis socket has received some data."
imanay
r61
ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx)
return ipSource, ipDestino, cmd, data
imanay
r92 def sendData(self, cmd, data, id):
imanay
r61
imanay
r92 trama_tx = self.__HEADER + ":" + self.__TYPE + ":" + str(self.ipSource) + ":" + str(self.ipDestino) + ":" + str(self.len) + ":" + str(cmd) + ":" + str(data) + ":" + str(self.crc)
imanay
r61 if self.portDestino == 7000:
imanay
r92 trama_tx = trama_tx + ":" + "quit"
imanay
r61 # Send messages
if self.mode == "client":
imanay
r92 host = "192.168.1." + str(id)
self.socket_c.connect((host, self.portDestino))
imanay
r61 self.socket_c.send(trama_tx)
else:
imanay
r70 self.sc.send(trama_tx)
imanay
r61 print "Sending message:[" + trama_tx + "]"
def __getTrama(self, trama):
FrameList = trama.split(':')
header = FrameList[0]
imanay
r92 TypeOfInstrument = FrameList[1]
ipSource = FrameList[2]
ipDestino = FrameList[3]
len = FrameList[4]
cmd = FrameList[5]
data = FrameList[6]
crc = FrameList[7]
trash = FrameList[8]
imanay
r61
return ipSource, ipDestino, cmd, data
imanay
r70 def close_socket(self):
imanay
r63 self.socket_c.close()
imanay
r92 def open_socket(self):
self.socket_c = socket.socket()
imanay
Fedora 10 no deja instalar modulo tftp
 r41 #class FTPComm:
#
# ftp_servidor = 'ftp.servidor.com'
# ftp_usuario = 'miusuario'
# ftp_clave = 'miclave'
# ftp_raiz = '/public_html'
#
# def __init__(self):
#
# self.client = tftpy.TftpClient(self.ftp_servidor, '69')
#
#
# def sendFile(self, filename):
#
# self.client.upload(filename)
#
#if __name__ == '__main__':
#
# obj = FTPComm()
murco
-Se organizó la estructura de directorios....
 r19
imanay
Actualizacion del directorio
 r25
murco
-Se organizó la estructura de directorios....
 r19