ABS/abscontrol Commit - r165:166 · Jicamarca Repository

- Eliminando error por duplicidad con el nombre del paquete: abscontrol y la aplicacion web con django. El nuevo nombre aplicado es bin.

jsalyrosas -

r165:166

parent child

Context file:

r165:166

Collapse all files

trunk/absroot/source/abspy/bin/__init__.py created 10644 0 0

NO CONTENT: new file 10644

trunk/absroot/source/abspy/bin/client.py created 10644 +488 0

@@ -0,0 +1,488
	1	# imports needed for the file convertion
	2	import os
	3	import sys
	4	import time
	5	import numpy as np
	6
	7	import library
	8
	9	class ABSClient:
	10
	11	def __init__(self,ipSource="localhost", ipDestino="192.168.1.117", portDestino=7000):
	12
	13	self.ipSource = ipSource
	14	self.ipDestino = ipDestino
	15	self.portDestino = portDestino
	16
	17	self.createObjects()
	18
	19	def createObjects(self):
	20
	21	self.commObj = library.UDPComm(self.ipSource, self.ipDestino, self.portDestino)
	22
	23	def sendFile(self, filename):
	24
	25	#From matriz to control module format
	26	self.FuncionMaestra_GeneraFormatoControlCentral(filename)
	27	FileName = "FormatoControlCentral.txt"
	28	F_Obj = open(FileName,"r")
	29	FileList = F_Obj.readlines()
	30	F_Obj.close()
	31	FileStr = "".join(FileList)
	32	data = FileStr
	33
	34	self.commObj.sendData(cmd="SNDF", data=data)
	35	self.commObj.waitData()
	36
	37	def changeBeam(self, newBeam):
	38
	39	self.commObj.sendData(cmd="CHGB", data=newBeam)
	40	self.commObj.waitData()
	41
	42	def __writeFile(self, filename, data):
	43
	44	fobj = open(filename,"w")
	45	fobj.writelines(data)
	46	fobj.close()
	47
	48	def getStatus(self, data):
	49
	50	self.commObj.sendData(cmd="ANST", data = data)
	51	ipSource, ipDestino, cmd, data = self.commObj.waitData()
	52	self.__writeFile("report.txt", data)
	53
	54	##########
	55
	56	def FuncionMaestra_GeneraFormatoControlCentral(self,archivo):
	57	""" Funcion que genera un archivo para el control central"""
	58
	59	# CarpetaDeTrabajo='/home/redes/ABS_Control_2012_09_24/Control_Module_v1_Client_09_24/'
	60	CarpetaDeTrabajo = os.getcwd() + '/'
	61	#print CarpetaDeTrabajo
	62	#CarpetaDeTrabajo='/home/redes/workspace/ABS_Client_v2/Debug/'
	63
	64	def lst2string(lst):
	65	string=''
	66	for i in lst:
	67	string=string+i
	68	return string
	69
	70	def string2lst(string):
	71	lst = []
	72	for i in string:
	73	lst.append(i)
	74	return lst
	75
	76
	77	def file1(string, type):
	78	lst = string2lst(archivo)
	79	fin = -1
	80	t = len(lst)
	81	for i in np.arange(-1,-t,-1):
	82	if lst[i]=='/':
	83	fin=i
	84	break
	85	if type == '1':
	86	nombre2 = lst[fin+1:]
	87	nombre2[-1]='s'
	88	nombre2 = lst2string(nombre2)
	89	return nombre2
	90	if type == '2':
	91	nombre2 = lst[fin+1:]
	92	nombre2[-1]='1'
	93	nombre2 = lst2string(nombre2)
	94	return nombre2
	95
	96
	97	def EliminaSaltoDeLinea(cadena):
	98	i = 0
	99	for elemento in cadena:
	100	if elemento =='\n' or elemento =='\r':
	101	pass
	102	else:
	103	i=i+1
	104	return cadena [:i]
	105
	106	def NumeroDeExperimentos(path):
	107	fichero1=open(path,'r')
	108	cont=0
	109	for cadena in fichero1:
	110	cont=cont+1
	111	if cont==3:
	112	nexp=''
	113	pos=0
	114	for elemento in cadena:
	115	pos=pos+1
	116	if elemento=='=':
	117	nexp=int(cadena[pos:])
	118	return nexp
	119	fichero1.close()
	120
	121	def Paridad(numero):
	122	if numero%2==0: return 'par'
	123	elif numero%2==1: return 'impar'
	124
	125	def EvaluaCadena(cadena):
	126	if len(cadena)>35:
	127	if cadena[-1]=='$':
	128	return cadena[-35:-2]
	129	elif cadena[-1]==']':
	130	return cadena[-34:-1]
	131	else:
	132	return None
	133
	134	def GuardaEnLista(path):
	135	fichero=open(path,'r')
	136	lista=[]
	137	for cadena in fichero:
	138	cadena = EliminaSaltoDeLinea(cadena)
	139	cadena = EvaluaCadena(cadena)
	140	if cadena != None:
	141	lista.append(cadena)
	142	fichero.close()
	143	return lista
	144
	145	def CreaFicherosPrevios():
	146	vector = GuardaEnLista(archivo)
	147	for i in range(1,NumeroDeExperimentos(archivo)+1):
	148	fichero =open(CarpetaDeTrabajo+str(i)+'.txt','w')
	149	for j in range(0,16):
	150	fichero.write(vector[j+16*(i-1)]+'\n')
	151	fichero.close()
	152
	153	def CapturaValoresEnArchivo(path,polarizacion='up'):
	154	fichero =open(path,'r')
	155	cnt=0
	156	lstup=[]
	157	lstdw=[]
	158	for cadena in fichero:
	159	cnt=cnt+1
	160	if cnt==5:
	161	su01=cadena[17:20]
	162	su02=cadena[21:24]
	163	su03=cadena[25:28]
	164	su04=cadena[29:32]
	165	if cnt==6:
	166	su05=cadena[17:20]
	167	su06=cadena[21:24]
	168	su07=cadena[25:28]
	169	su08=cadena[29:32]
	170	if cnt==7:
	171	su09=cadena[17:20]
	172	su10=cadena[21:24]
	173	su11=cadena[25:28]
	174	su12=cadena[29:32]
	175	if cnt==8:
	176	su13=cadena[17:20]
	177	su14=cadena[21:24]
	178	su15=cadena[25:28]
	179	su16=cadena[29:32]
	180	if cnt==13:
	181	sd01=cadena[17:20]
	182	sd02=cadena[21:24]
	183	sd03=cadena[25:28]
	184	sd04=cadena[29:32]
	185	if cnt==14:
	186	sd05=cadena[17:20]
	187	sd06=cadena[21:24]
	188	sd07=cadena[25:28]
	189	sd08=cadena[29:32]
	190	if cnt==15:
	191	sd09=cadena[17:20]
	192	sd10=cadena[21:24]
	193	sd11=cadena[25:28]
	194	sd12=cadena[29:32]
	195	if cnt==16:
	196	sd13=cadena[17:20]
	197	sd14=cadena[21:24]
	198	sd15=cadena[25:28]
	199	sd16=cadena[29:32]
	200	lstup=[su01,su02,su03,su04,su05,su06,su07,su08,su09,su10,su11,su12,su13,su14,su15,su16]
	201	lstdw=[sd01,sd02,sd03,sd04,sd05,sd06,sd07,sd08,sd09,sd10,sd11,sd12,sd13,sd14,sd15,sd16]
	202	if polarizacion=='up':
	203	return lstup
	204	elif polarizacion=='dw':
	205	return lstdw
	206	fichero.close()
	207
	208	def CapturaValoresEnArchivo2(path,polarizacion='up'):
	209	fichero =open(path,'r')
	210	cnt=0
	211	lstup=[]
	212	lstdw=[]
	213	for cadena in fichero:
	214	cnt=cnt+1
	215	if cnt==1:
	216	nu01=cadena[1:4]
	217	nu02=cadena[5:8]
	218	nu03=cadena[9:12]
	219	nu04=cadena[13:16]
	220	eu01=cadena[17:20]
	221	eu02=cadena[21:24]
	222	eu03=cadena[25:28]
	223	eu04=cadena[29:32]
	224	if cnt==2:
	225	nu05=cadena[1:4]
	226	nu06=cadena[5:8]
	227	nu07=cadena[9:12]
	228	nu08=cadena[13:16]
	229	eu05=cadena[17:20]
	230	eu06=cadena[21:24]
	231	eu07=cadena[25:28]
	232	eu08=cadena[29:32]
	233	if cnt==3:
	234	nu09=cadena[1:4]
	235	nu10=cadena[5:8]
	236	nu11=cadena[9:12]
	237	nu12=cadena[13:16]
	238	eu09=cadena[17:20]
	239	eu10=cadena[21:24]
	240	eu11=cadena[25:28]
	241	eu12=cadena[29:32]
	242	if cnt==4:
	243	nu13=cadena[1:4]
	244	nu14=cadena[5:8]
	245	nu15=cadena[9:12]
	246	nu16=cadena[13:16]
	247	eu13=cadena[17:20]
	248	eu14=cadena[21:24]
	249	eu15=cadena[25:28]
	250	eu16=cadena[29:32]
	251	if cnt==5:
	252	wu01=cadena[1:4]
	253	wu02=cadena[5:8]
	254	wu03=cadena[9:12]
	255	wu04=cadena[13:16]
	256	su01=cadena[17:20]
	257	su02=cadena[21:24]
	258	su03=cadena[25:28]
	259	su04=cadena[29:32]
	260	if cnt==6:
	261	wu05=cadena[1:4]
	262	wu06=cadena[5:8]
	263	wu07=cadena[9:12]
	264	wu08=cadena[13:16]
	265	su05=cadena[17:20]
	266	su06=cadena[21:24]
	267	su07=cadena[25:28]
	268	su08=cadena[29:32]
	269	if cnt==7:
	270	wu09=cadena[1:4]
	271	wu10=cadena[5:8]
	272	wu11=cadena[9:12]
	273	wu12=cadena[13:16]
	274	su09=cadena[17:20]
	275	su10=cadena[21:24]
	276	su11=cadena[25:28]
	277	su12=cadena[29:32]
	278	if cnt==8:
	279	wu13=cadena[1:4]
	280	wu14=cadena[5:8]
	281	wu15=cadena[9:12]
	282	wu16=cadena[13:16]
	283	su13=cadena[17:20]
	284	su14=cadena[21:24]
	285	su15=cadena[25:28]
	286	su16=cadena[29:32]
	287	if cnt==9:
	288	nd01=cadena[1:4]
	289	nd02=cadena[5:8]
	290	nd03=cadena[9:12]
	291	nd04=cadena[13:16]
	292	ed01=cadena[17:20]
	293	ed02=cadena[21:24]
	294	ed03=cadena[25:28]
	295	ed04=cadena[29:32]
	296	if cnt==10:
	297	nd05=cadena[1:4]
	298	nd06=cadena[5:8]
	299	nd07=cadena[9:12]
	300	nd08=cadena[13:16]
	301	ed05=cadena[17:20]
	302	ed06=cadena[21:24]
	303	ed07=cadena[25:28]
	304	ed08=cadena[29:32]
	305	if cnt==11:
	306	nd09=cadena[1:4]
	307	nd10=cadena[5:8]
	308	nd11=cadena[9:12]
	309	nd12=cadena[13:16]
	310	ed09=cadena[17:20]
	311	ed10=cadena[21:24]
	312	ed11=cadena[25:28]
	313	ed12=cadena[29:32]
	314	if cnt==12:
	315	nd13=cadena[1:4]
	316	nd14=cadena[5:8]
	317	nd15=cadena[9:12]
	318	nd16=cadena[13:16]
	319	ed13=cadena[17:20]
	320	ed14=cadena[21:24]
	321	ed15=cadena[25:28]
	322	ed16=cadena[29:32]
	323	if cnt==13:
	324	wd01=cadena[1:4]
	325	wd02=cadena[5:8]
	326	wd03=cadena[9:12]
	327	wd04=cadena[13:16]
	328	sd01=cadena[17:20]
	329	sd02=cadena[21:24]
	330	sd03=cadena[25:28]
	331	sd04=cadena[29:32]
	332	if cnt==14:
	333	wd05=cadena[1:4]
	334	wd06=cadena[5:8]
	335	wd07=cadena[9:12]
	336	wd08=cadena[13:16]
	337	sd05=cadena[17:20]
	338	sd06=cadena[21:24]
	339	sd07=cadena[25:28]
	340	sd08=cadena[29:32]
	341	if cnt==15:
	342	wd09=cadena[1:4]
	343	wd10=cadena[5:8]
	344	wd11=cadena[9:12]
	345	wd12=cadena[13:16]
	346	sd09=cadena[17:20]
	347	sd10=cadena[21:24]
	348	sd11=cadena[25:28]
	349	sd12=cadena[29:32]
	350	if cnt==16:
	351	wd13=cadena[1:4]
	352	wd14=cadena[5:8]
	353	wd15=cadena[9:12]
	354	wd16=cadena[13:16]
	355	sd13=cadena[17:20]
	356	sd14=cadena[21:24]
	357	sd15=cadena[25:28]
	358	sd16=cadena[29:32]
	359	lst_n_up=[nu01,nu02,nu03,nu04,nu05,nu06,nu07,nu08,nu09,nu10,nu11,nu12,nu13,nu14,nu15,nu16]
	360	lst_n_dw=[nd01,nd02,nd03,nd04,nd05,nd06,nd07,nd08,nd09,nd10,nd11,nd12,nd13,nd14,nd15,nd16]
	361	lst_s_up=[su01,su02,su03,su04,su05,su06,su07,su08,su09,su10,su11,su12,su13,su14,su15,su16]
	362	lst_s_dw=[sd01,sd02,sd03,sd04,sd05,sd06,sd07,sd08,sd09,sd10,sd11,sd12,sd13,sd14,sd15,sd16]
	363	lst_w_up=[wu01,wu02,wu03,wu04,wu05,wu06,wu07,wu08,wu09,wu10,wu11,wu12,wu13,wu14,wu15,wu16]
	364	lst_w_dw=[wd01,wd02,wd03,wd04,wd05,wd06,wd07,wd08,wd09,wd10,wd11,wd12,wd13,wd14,wd15,wd16]
	365	lst_e_up=[eu01,eu02,eu03,eu04,eu05,eu06,eu07,eu08,eu09,eu10,eu11,eu12,eu13,eu14,eu15,eu16]
	366	lst_e_dw=[ed01,ed02,ed03,ed04,ed05,ed06,ed07,ed08,ed09,ed10,ed11,ed12,ed13,ed14,ed15,ed16]
	367
	368	lstup = lst_s_up + lst_w_up + lst_n_up + lst_e_up
	369	lstdw = lst_s_dw + lst_w_dw + lst_n_up + lst_e_up
	370
	371	if polarizacion=='up':
	372	return lstup
	373	elif polarizacion=='dw':
	374	return lstdw
	375	fichero.close()
	376
	377
	378	def CreaFormatoFinal():
	379	ne=NumeroDeExperimentos(archivo)
	380
	381	#nombre01 = file1(archivo,'1')
	382	nombre02 = file1(archivo,'2')
	383	fichero=open(CarpetaDeTrabajo+'FormatoControlCentral.txt','w')
	384	fichero.write(nombre02+'\n')
	385	fichero.write(str(ne)+'\n')
	386	for i in range(1,17):
	387
	388	if i<10:
	389	nmod = '0'+str(i)
	390	else: nmod = str(i)
	391
	392
	393	fichero.write('S'+nmod+'\n')
	394	for j in range(1,ne+1):
	395	ruta=CarpetaDeTrabajo+str(j)+'.txt'
	396	lu=CapturaValoresEnArchivo(ruta,polarizacion='up')
	397	ld=CapturaValoresEnArchivo(ruta,polarizacion='dw')
	398	part1=''
	399	part2=''
	400	if lu[i-1]=='1.0': part1='000'
	401	if lu[i-1]=='2.0': part1='001'
	402	if lu[i-1]=='3.0': part1='010'
	403	if lu[i-1]=='0.0': part1='011'
	404	if lu[i-1]=='0.5': part1='100'
	405	if lu[i-1]=='1.5': part1='101'
	406	if lu[i-1]=='2.5': part1='110'
	407	if lu[i-1]=='3.5': part1='111'
	408	if ld[i-1]=='1.0': part2='000'
	409	if ld[i-1]=='2.0': part2='001'
	410	if ld[i-1]=='3.0': part2='010'
	411	if ld[i-1]=='0.0': part2='011'
	412	if ld[i-1]=='0.5': part2='100'
	413	if ld[i-1]=='1.5': part2='101'
	414	if ld[i-1]=='2.5': part2='110'
	415	if ld[i-1]=='3.5': part2='111'
	416	fichero.write(part1+part2+'\n')
	417	fichero.write('------'+'\n')
	418	fichero.close()
	419
	420	def CreaFormatoFinal2():
	421	ne=NumeroDeExperimentos(archivo)
	422
	423	#nombre01 = file1(archivo,'1')
	424	nombre02 = file1(archivo,'2')
	425	fichero=open(CarpetaDeTrabajo+'FormatoControlCentral.txt','w')
	426	fichero.write(nombre02+'\n')
	427	fichero.write(str(ne)+'\n')
	428
	429	for i in range(1,65):
	430
	431	if i<10:
	432	nmod = '0'+str(i)
	433	else: nmod = str(i)
	434
	435	fichero.write("ABS_" + nmod+'\n')
	436
	437	for j in range(1,ne+1):
	438	ruta=CarpetaDeTrabajo+str(j)+'.txt'
	439	lu=CapturaValoresEnArchivo2(ruta,polarizacion='up')
	440	ld=CapturaValoresEnArchivo2(ruta,polarizacion='dw')
	441	part1=''
	442	part2=''
	443	if lu[i-1]=='1.0': part1='000'
	444	if lu[i-1]=='2.0': part1='001'
	445	if lu[i-1]=='3.0': part1='010'
	446	if lu[i-1]=='0.0': part1='011'
	447	if lu[i-1]=='0.5': part1='100'
	448	if lu[i-1]=='1.5': part1='101'
	449	if lu[i-1]=='2.5': part1='110'
	450	if lu[i-1]=='3.5': part1='111'
	451	if ld[i-1]=='1.0': part2='000'
	452	if ld[i-1]=='2.0': part2='001'
	453	if ld[i-1]=='3.0': part2='010'
	454	if ld[i-1]=='0.0': part2='011'
	455	if ld[i-1]=='0.5': part2='100'
	456	if ld[i-1]=='1.5': part2='101'
	457	if ld[i-1]=='2.5': part2='110'
	458	if ld[i-1]=='3.5': part2='111'
	459	fichero.write(part1+part2+'\n')
	460	fichero.write('------'+'\n')
	461	fichero.close()
	462
	463	def EliminaArchivosEnLaCarpeta():
	464	ne=NumeroDeExperimentos(archivo)
	465	for i in range(1,ne+1):
	466	os.remove(CarpetaDeTrabajo+str(i)+'.txt')
	467
	468	CreaFicherosPrevios()
	469	CreaFormatoFinal2()
	470	EliminaArchivosEnLaCarpeta()
	471
	472	##########
	473
	474	if __name__ == '__main__':
	475
	476	filename = "experimento1.abs"
	477
	478	absObj = ABSClient()
	479	absObj.sendFile(filename)
	480	# absObj.changeBeam("0")
	481	# absObj.changeBeam("1")
	482	# absObj.changeBeam("2")
	483	# absObj.changeBeam("3")
	484	# absObj.changeBeam("4")
	485	# absObj.changeBeam("5")
	486	# absObj.changeBeam("6")
	487	# absObj.changeBeam("7")
	488	# absObj.getStatus(5) No newline at end of file

trunk/absroot/source/abspy/bin/client2.py created 10644 +500 0

@@ -0,0 +1,500
	1	# imports needed for the file convertion
	2	import os
	3	import sys
	4	import time
	5	import numpy as np
	6
	7	import library2
	8
	9	class ABSClient:
	10
	11	def __init__(self,ipSource="localhost", ipDestino="192.168.1.117", portDestino=7000):
	12
	13	self.ipSource = ipSource
	14	self.ipDestino = ipDestino
	15	self.portDestino = portDestino
	16
	17	self.createObjects()
	18
	19	def createObjects(self):
	20
	21	self.commObj = library2.TCPComm(self.ipSource, self.ipDestino, self.portDestino)
	22
	23	def sendFile(self, filename):
	24
	25	#From matriz to control module format
	26	self.FuncionMaestra_GeneraFormatoControlCentral(filename)
	27	FileName = "FormatoControlCentral.txt"
	28	F_Obj = open(FileName,"r")
	29	FileList = F_Obj.readlines()
	30	F_Obj.close()
	31	FileStr = "".join(FileList)
	32	data = FileStr
	33
	34	self.commObj.open_socket()
	35	# self.commObj.sendData(cmd="SNDF", data=data, id = 117)
	36	self.commObj.sendData2(cmd="SNDF", data=data, ipDestino = self.ipDestino)
	37	# self.commObj.waitData()
	38	self.commObj.waitClient()
	39	self.commObj.close_socket()
	40
	41	def changeBeam(self, newBeam):
	42
	43	self.commObj.open_socket()
	44	# self.commObj.sendData(cmd="CHGB", data=newBeam, id = 117)
	45	self.commObj.sendData2(cmd="CHGB", data=newBeam, ipDestino = self.ipDestino)
	46	# self.commObj.waitData()
	47	self.commObj.waitClient()
	48	self.commObj.close_socket()
	49
	50	def __writeFile(self, filename, data):
	51
	52	fobj = open(filename,"w")
	53	fobj.writelines(data)
	54	fobj.close()
	55
	56	def getStatus(self, data):
	57
	58	self.commObj.open_socket()
	59	# self.commObj.sendData(cmd="ANST", data = data, id = 117)
	60	self.commObj.sendData2(cmd="ANST", data = data, ipDestino = self.ipDestino)
	61	# ipSource, ipDestino, cmd, data = self.commObj.waitData()
	62	ipSource, ipDestino, cmd, data = self.commObj.waitClient()
	63	self.commObj.close_socket()
	64	self.__writeFile("report.txt", data)
	65
	66	##########
	67
	68	def FuncionMaestra_GeneraFormatoControlCentral(self,archivo):
	69	""" Funcion que genera un archivo para el control central"""
	70
	71	# CarpetaDeTrabajo='/home/redes/ABS_Control_2012_09_24/Control_Module_v1_Client_09_24/'
	72	CarpetaDeTrabajo = os.getcwd() + '/'
	73	#print CarpetaDeTrabajo
	74	#CarpetaDeTrabajo='/home/redes/workspace/ABS_Client_v2/Debug/'
	75
	76	def lst2string(lst):
	77	string=''
	78	for i in lst:
	79	string=string+i
	80	return string
	81
	82	def string2lst(string):
	83	lst = []
	84	for i in string:
	85	lst.append(i)
	86	return lst
	87
	88
	89	def file1(string, type):
	90	lst = string2lst(archivo)
	91	fin = -1
	92	t = len(lst)
	93	for i in np.arange(-1,-t,-1):
	94	if lst[i]=='/':
	95	fin=i
	96	break
	97	if type == '1':
	98	nombre2 = lst[fin+1:]
	99	nombre2[-1]='s'
	100	nombre2 = lst2string(nombre2)
	101	return nombre2
	102	if type == '2':
	103	nombre2 = lst[fin+1:]
	104	nombre2[-1]='1'
	105	nombre2 = lst2string(nombre2)
	106	return nombre2
	107
	108
	109	def EliminaSaltoDeLinea(cadena):
	110	i = 0
	111	for elemento in cadena:
	112	if elemento =='\n' or elemento =='\r':
	113	pass
	114	else:
	115	i=i+1
	116	return cadena [:i]
	117
	118	def NumeroDeExperimentos(path):
	119	fichero1=open(path,'r')
	120	cont=0
	121	for cadena in fichero1:
	122	cont=cont+1
	123	if cont==3:
	124	nexp=''
	125	pos=0
	126	for elemento in cadena:
	127	pos=pos+1
	128	if elemento=='=':
	129	nexp=int(cadena[pos:])
	130	return nexp
	131	fichero1.close()
	132
	133	def Paridad(numero):
	134	if numero%2==0: return 'par'
	135	elif numero%2==1: return 'impar'
	136
	137	def EvaluaCadena(cadena):
	138	if len(cadena)>35:
	139	if cadena[-1]=='$':
	140	return cadena[-35:-2]
	141	elif cadena[-1]==']':
	142	return cadena[-34:-1]
	143	else:
	144	return None
	145
	146	def GuardaEnLista(path):
	147	fichero=open(path,'r')
	148	lista=[]
	149	for cadena in fichero:
	150	cadena = EliminaSaltoDeLinea(cadena)
	151	cadena = EvaluaCadena(cadena)
	152	if cadena != None:
	153	lista.append(cadena)
	154	fichero.close()
	155	return lista
	156
	157	def CreaFicherosPrevios():
	158	vector = GuardaEnLista(archivo)
	159	for i in range(1,NumeroDeExperimentos(archivo)+1):
	160	fichero =open(CarpetaDeTrabajo+str(i)+'.txt','w')
	161	for j in range(0,16):
	162	fichero.write(vector[j+16*(i-1)]+'\n')
	163	fichero.close()
	164
	165	def CapturaValoresEnArchivo(path,polarizacion='up'):
	166	fichero =open(path,'r')
	167	cnt=0
	168	lstup=[]
	169	lstdw=[]
	170	for cadena in fichero:
	171	cnt=cnt+1
	172	if cnt==5:
	173	su01=cadena[17:20]
	174	su02=cadena[21:24]
	175	su03=cadena[25:28]
	176	su04=cadena[29:32]
	177	if cnt==6:
	178	su05=cadena[17:20]
	179	su06=cadena[21:24]
	180	su07=cadena[25:28]
	181	su08=cadena[29:32]
	182	if cnt==7:
	183	su09=cadena[17:20]
	184	su10=cadena[21:24]
	185	su11=cadena[25:28]
	186	su12=cadena[29:32]
	187	if cnt==8:
	188	su13=cadena[17:20]
	189	su14=cadena[21:24]
	190	su15=cadena[25:28]
	191	su16=cadena[29:32]
	192	if cnt==13:
	193	sd01=cadena[17:20]
	194	sd02=cadena[21:24]
	195	sd03=cadena[25:28]
	196	sd04=cadena[29:32]
	197	if cnt==14:
	198	sd05=cadena[17:20]
	199	sd06=cadena[21:24]
	200	sd07=cadena[25:28]
	201	sd08=cadena[29:32]
	202	if cnt==15:
	203	sd09=cadena[17:20]
	204	sd10=cadena[21:24]
	205	sd11=cadena[25:28]
	206	sd12=cadena[29:32]
	207	if cnt==16:
	208	sd13=cadena[17:20]
	209	sd14=cadena[21:24]
	210	sd15=cadena[25:28]
	211	sd16=cadena[29:32]
	212	lstup=[su01,su02,su03,su04,su05,su06,su07,su08,su09,su10,su11,su12,su13,su14,su15,su16]
	213	lstdw=[sd01,sd02,sd03,sd04,sd05,sd06,sd07,sd08,sd09,sd10,sd11,sd12,sd13,sd14,sd15,sd16]
	214	if polarizacion=='up':
	215	return lstup
	216	elif polarizacion=='dw':
	217	return lstdw
	218	fichero.close()
	219
	220	def CapturaValoresEnArchivo2(path,polarizacion='up'):
	221	fichero =open(path,'r')
	222	cnt=0
	223	lstup=[]
	224	lstdw=[]
	225	for cadena in fichero:
	226	cnt=cnt+1
	227	if cnt==1:
	228	nu01=cadena[1:4]
	229	nu02=cadena[5:8]
	230	nu03=cadena[9:12]
	231	nu04=cadena[13:16]
	232	eu01=cadena[17:20]
	233	eu02=cadena[21:24]
	234	eu03=cadena[25:28]
	235	eu04=cadena[29:32]
	236	if cnt==2:
	237	nu05=cadena[1:4]
	238	nu06=cadena[5:8]
	239	nu07=cadena[9:12]
	240	nu08=cadena[13:16]
	241	eu05=cadena[17:20]
	242	eu06=cadena[21:24]
	243	eu07=cadena[25:28]
	244	eu08=cadena[29:32]
	245	if cnt==3:
	246	nu09=cadena[1:4]
	247	nu10=cadena[5:8]
	248	nu11=cadena[9:12]
	249	nu12=cadena[13:16]
	250	eu09=cadena[17:20]
	251	eu10=cadena[21:24]
	252	eu11=cadena[25:28]
	253	eu12=cadena[29:32]
	254	if cnt==4:
	255	nu13=cadena[1:4]
	256	nu14=cadena[5:8]
	257	nu15=cadena[9:12]
	258	nu16=cadena[13:16]
	259	eu13=cadena[17:20]
	260	eu14=cadena[21:24]
	261	eu15=cadena[25:28]
	262	eu16=cadena[29:32]
	263	if cnt==5:
	264	wu01=cadena[1:4]
	265	wu02=cadena[5:8]
	266	wu03=cadena[9:12]
	267	wu04=cadena[13:16]
	268	su01=cadena[17:20]
	269	su02=cadena[21:24]
	270	su03=cadena[25:28]
	271	su04=cadena[29:32]
	272	if cnt==6:
	273	wu05=cadena[1:4]
	274	wu06=cadena[5:8]
	275	wu07=cadena[9:12]
	276	wu08=cadena[13:16]
	277	su05=cadena[17:20]
	278	su06=cadena[21:24]
	279	su07=cadena[25:28]
	280	su08=cadena[29:32]
	281	if cnt==7:
	282	wu09=cadena[1:4]
	283	wu10=cadena[5:8]
	284	wu11=cadena[9:12]
	285	wu12=cadena[13:16]
	286	su09=cadena[17:20]
	287	su10=cadena[21:24]
	288	su11=cadena[25:28]
	289	su12=cadena[29:32]
	290	if cnt==8:
	291	wu13=cadena[1:4]
	292	wu14=cadena[5:8]
	293	wu15=cadena[9:12]
	294	wu16=cadena[13:16]
	295	su13=cadena[17:20]
	296	su14=cadena[21:24]
	297	su15=cadena[25:28]
	298	su16=cadena[29:32]
	299	if cnt==9:
	300	nd01=cadena[1:4]
	301	nd02=cadena[5:8]
	302	nd03=cadena[9:12]
	303	nd04=cadena[13:16]
	304	ed01=cadena[17:20]
	305	ed02=cadena[21:24]
	306	ed03=cadena[25:28]
	307	ed04=cadena[29:32]
	308	if cnt==10:
	309	nd05=cadena[1:4]
	310	nd06=cadena[5:8]
	311	nd07=cadena[9:12]
	312	nd08=cadena[13:16]
	313	ed05=cadena[17:20]
	314	ed06=cadena[21:24]
	315	ed07=cadena[25:28]
	316	ed08=cadena[29:32]
	317	if cnt==11:
	318	nd09=cadena[1:4]
	319	nd10=cadena[5:8]
	320	nd11=cadena[9:12]
	321	nd12=cadena[13:16]
	322	ed09=cadena[17:20]
	323	ed10=cadena[21:24]
	324	ed11=cadena[25:28]
	325	ed12=cadena[29:32]
	326	if cnt==12:
	327	nd13=cadena[1:4]
	328	nd14=cadena[5:8]
	329	nd15=cadena[9:12]
	330	nd16=cadena[13:16]
	331	ed13=cadena[17:20]
	332	ed14=cadena[21:24]
	333	ed15=cadena[25:28]
	334	ed16=cadena[29:32]
	335	if cnt==13:
	336	wd01=cadena[1:4]
	337	wd02=cadena[5:8]
	338	wd03=cadena[9:12]
	339	wd04=cadena[13:16]
	340	sd01=cadena[17:20]
	341	sd02=cadena[21:24]
	342	sd03=cadena[25:28]
	343	sd04=cadena[29:32]
	344	if cnt==14:
	345	wd05=cadena[1:4]
	346	wd06=cadena[5:8]
	347	wd07=cadena[9:12]
	348	wd08=cadena[13:16]
	349	sd05=cadena[17:20]
	350	sd06=cadena[21:24]
	351	sd07=cadena[25:28]
	352	sd08=cadena[29:32]
	353	if cnt==15:
	354	wd09=cadena[1:4]
	355	wd10=cadena[5:8]
	356	wd11=cadena[9:12]
	357	wd12=cadena[13:16]
	358	sd09=cadena[17:20]
	359	sd10=cadena[21:24]
	360	sd11=cadena[25:28]
	361	sd12=cadena[29:32]
	362	if cnt==16:
	363	wd13=cadena[1:4]
	364	wd14=cadena[5:8]
	365	wd15=cadena[9:12]
	366	wd16=cadena[13:16]
	367	sd13=cadena[17:20]
	368	sd14=cadena[21:24]
	369	sd15=cadena[25:28]
	370	sd16=cadena[29:32]
	371	lst_n_up=[nu01,nu02,nu03,nu04,nu05,nu06,nu07,nu08,nu09,nu10,nu11,nu12,nu13,nu14,nu15,nu16]
	372	lst_n_dw=[nd01,nd02,nd03,nd04,nd05,nd06,nd07,nd08,nd09,nd10,nd11,nd12,nd13,nd14,nd15,nd16]
	373	lst_s_up=[su01,su02,su03,su04,su05,su06,su07,su08,su09,su10,su11,su12,su13,su14,su15,su16]
	374	lst_s_dw=[sd01,sd02,sd03,sd04,sd05,sd06,sd07,sd08,sd09,sd10,sd11,sd12,sd13,sd14,sd15,sd16]
	375	lst_w_up=[wu01,wu02,wu03,wu04,wu05,wu06,wu07,wu08,wu09,wu10,wu11,wu12,wu13,wu14,wu15,wu16]
	376	lst_w_dw=[wd01,wd02,wd03,wd04,wd05,wd06,wd07,wd08,wd09,wd10,wd11,wd12,wd13,wd14,wd15,wd16]
	377	lst_e_up=[eu01,eu02,eu03,eu04,eu05,eu06,eu07,eu08,eu09,eu10,eu11,eu12,eu13,eu14,eu15,eu16]
	378	lst_e_dw=[ed01,ed02,ed03,ed04,ed05,ed06,ed07,ed08,ed09,ed10,ed11,ed12,ed13,ed14,ed15,ed16]
	379
	380	lstup = lst_s_up + lst_w_up + lst_n_up + lst_e_up
	381	lstdw = lst_s_dw + lst_w_dw + lst_n_up + lst_e_up
	382
	383	if polarizacion=='up':
	384	return lstup
	385	elif polarizacion=='dw':
	386	return lstdw
	387	fichero.close()
	388
	389
	390	def CreaFormatoFinal():
	391	ne=NumeroDeExperimentos(archivo)
	392
	393	#nombre01 = file1(archivo,'1')
	394	nombre02 = file1(archivo,'2')
	395	fichero=open(CarpetaDeTrabajo+'FormatoControlCentral.txt','w')
	396	fichero.write(nombre02+'\n')
	397	fichero.write(str(ne)+'\n')
	398	for i in range(1,17):
	399
	400	if i<10:
	401	nmod = '0'+str(i)
	402	else: nmod = str(i)
	403
	404
	405	fichero.write('S'+nmod+'\n')
	406	for j in range(1,ne+1):
	407	ruta=CarpetaDeTrabajo+str(j)+'.txt'
	408	lu=CapturaValoresEnArchivo(ruta,polarizacion='up')
	409	ld=CapturaValoresEnArchivo(ruta,polarizacion='dw')
	410	part1=''
	411	part2=''
	412	if lu[i-1]=='1.0': part1='000'
	413	if lu[i-1]=='2.0': part1='001'
	414	if lu[i-1]=='3.0': part1='010'
	415	if lu[i-1]=='0.0': part1='011'
	416	if lu[i-1]=='0.5': part1='100'
	417	if lu[i-1]=='1.5': part1='101'
	418	if lu[i-1]=='2.5': part1='110'
	419	if lu[i-1]=='3.5': part1='111'
	420	if ld[i-1]=='1.0': part2='000'
	421	if ld[i-1]=='2.0': part2='001'
	422	if ld[i-1]=='3.0': part2='010'
	423	if ld[i-1]=='0.0': part2='011'
	424	if ld[i-1]=='0.5': part2='100'
	425	if ld[i-1]=='1.5': part2='101'
	426	if ld[i-1]=='2.5': part2='110'
	427	if ld[i-1]=='3.5': part2='111'
	428	fichero.write(part1+part2+'\n')
	429	fichero.write('------'+'\n')
	430	fichero.close()
	431
	432	def CreaFormatoFinal2():
	433	ne=NumeroDeExperimentos(archivo)
	434
	435	#nombre01 = file1(archivo,'1')
	436	nombre02 = file1(archivo,'2')
	437	fichero=open(CarpetaDeTrabajo+'FormatoControlCentral.txt','w')
	438	fichero.write(nombre02+'\n')
	439	fichero.write(str(ne)+'\n')
	440
	441	for i in range(1,65):
	442
	443	if i<10:
	444	nmod = '0'+str(i)
	445	else: nmod = str(i)
	446
	447	fichero.write("ABS_" + nmod+'\n')
	448
	449	for j in range(1,ne+1):
	450	ruta=CarpetaDeTrabajo+str(j)+'.txt'
	451	lu=CapturaValoresEnArchivo2(ruta,polarizacion='up')
	452	ld=CapturaValoresEnArchivo2(ruta,polarizacion='dw')
	453	part1=''
	454	part2=''
	455	if lu[i-1]=='1.0': part1='000'
	456	if lu[i-1]=='2.0': part1='001'
	457	if lu[i-1]=='3.0': part1='010'
	458	if lu[i-1]=='0.0': part1='011'
	459	if lu[i-1]=='0.5': part1='100'
	460	if lu[i-1]=='1.5': part1='101'
	461	if lu[i-1]=='2.5': part1='110'
	462	if lu[i-1]=='3.5': part1='111'
	463	if ld[i-1]=='1.0': part2='000'
	464	if ld[i-1]=='2.0': part2='001'
	465	if ld[i-1]=='3.0': part2='010'
	466	if ld[i-1]=='0.0': part2='011'
	467	if ld[i-1]=='0.5': part2='100'
	468	if ld[i-1]=='1.5': part2='101'
	469	if ld[i-1]=='2.5': part2='110'
	470	if ld[i-1]=='3.5': part2='111'
	471	fichero.write(part1+part2+'\n')
	472	fichero.write('------'+'\n')
	473	fichero.close()
	474
	475	def EliminaArchivosEnLaCarpeta():
	476	ne=NumeroDeExperimentos(archivo)
	477	for i in range(1,ne+1):
	478	os.remove(CarpetaDeTrabajo+str(i)+'.txt')
	479
	480	CreaFicherosPrevios()
	481	CreaFormatoFinal2()
	482	EliminaArchivosEnLaCarpeta()
	483
	484	##########
	485
	486	if __name__ == '__main__':
	487
	488	filename = "experimento1.abs"
	489
	490	absObj = ABSClient()
	491	# absObj.sendFile(filename)
	492	# absObj.changeBeam("0")
	493	absObj.changeBeam("1")
	494	# absObj.changeBeam("2")
	495	# absObj.changeBeam("3")
	496	# absObj.changeBeam("4")
	497	# absObj.changeBeam("5")
	498	# absObj.changeBeam("6")
	499	# absObj.changeBeam("7")
	500	# absObj.getStatus(5) No newline at end of file

trunk/absroot/source/abspy/bin/client3.py created 10644 +97 0

@@ -0,0 +1,97
	1	import library3
	2	import os.path
	3
	4	class ABSClient(object):
	5
	6	def __init__(self,ipSource="192.168.1.117", iDSource="Clnt_01", ipDestino="192.168.1.117", iDDestino = "CeCnMod", portDestino=7000):
	7
	8	self.ipSource = ipSource
	9	self.iDSource = iDSource
	10	self.ipDestino = ipDestino
	11	self.iDDestino = iDDestino
	12	self.portDestino = portDestino
	13
	14	self.createObjects()
	15
	16	def createObjects(self):
	17
	18	self.commObj = library3.TCPComm(self.ipSource, self.iDSource, self.ipDestino, self.iDDestino, self.portDestino)
	19	#self.wFiles = library3.FilesStuff()
	20
	21	def __ConnectionWithCentralControl(self, cmd, data):
	22
	23	self.commObj.open_socket()
	24	self.commObj.sendData(cmd = cmd, data = data, ipDestino = self.ipDestino)
	25	ipSource, ipDestino, cmd, output = self.commObj.waitData()
	26	self.commObj.close_socket()
	27
	28	return output
	29
	30	# def abs2ControlModuleFormatFile(self, filename):
	31	#
	32	# #From matriz to control module format
	33	# self.wFiles.toCentralControlFormat(filename)
	34	# FileName = "CentralControlFormat.txt"
	35	# F_Obj = open(FileName,"r")
	36	# FileList = F_Obj.readlines()
	37	# F_Obj.close()
	38	# FileStr = "".join(FileList)
	39	#
	40	# return FileStr
	41
	42	def sendFile(self, filename):
	43
	44	data = self.__readFile(filename)
	45	self.__ConnectionWithCentralControl(cmd = "SNDF", data = data)
	46
	47	def changeBeam(self, newBeam):
	48
	49	self.__ConnectionWithCentralControl(cmd = "CHGB", data = newBeam)
	50
	51	def __writeFile(self, filename, data):
	52
	53	fobj = open(filename,"w")
	54	fobj.writelines(data)
	55	fobj.close()
	56
	57	def __readFile(self, filename):
	58
	59	fobj = open(filename,"r")
	60	listData = fobj.readlines()
	61	fobj.close()
	62	tmp = "".join(listData)
	63	#Adding filename to the begining of the data
	64	newfilename = os.path.split(filename)[1]
	65	#data = filename + '\n' + tmp
	66	data = newfilename + '\n' + tmp
	67	return data
	68
	69
	70	def getControlModuleStatus(self, data):
	71
	72	data = self.__ConnectionWithCentralControl(cmd = "ANST", data = data)
	73	self.__writeFile("report.txt", data)
	74
	75	def getControlModulePhase(self, opt, u = "50", pw = "10"):
	76
	77	if opt == '0':
	78	data = self.__ConnectionWithCentralControl(cmd = "LWPH", data = u + '/' + pw + '/')
	79	elif opt == '1':
	80	data = self.__ConnectionWithCentralControl(cmd = "BGPH", data = u + '/' + pw + '/')
	81	elif opt == '2':
	82	data = self.__ConnectionWithCentralControl(cmd = "cBPH", data = u + '/' + pw + '/')
	83	else:
	84	data = self.__ConnectionWithCentralControl(cmd = "cLPH", data = u + '/' + pw + '/')
	85	# self.__writeFile("report.txt", data)
	86
	87	def getConnectionStatus(self):
	88
	89	data = self.__ConnectionWithCentralControl(cmd = "NTST", data = "none")
	90	self.__writeFile("connection_status.txt", data)
	91
	92	if __name__ == '__main__':
	93
	94	filename = "experimento1.abs"
	95
	96	absObj = ABSClient()
	97	absObj.sendFile(filename)

trunk/absroot/source/abspy/bin/experimento1.abs created 10644 +231 0

@@ -0,0 +1,231
	1	title ='MST-ISR 2009 (NS-Up)'
	2
	3	#Experiments = 12
	4
	5	1 =
	6	[[0.5,0.5,0.5,0.5,1.5,0.5,0.5,0.5],$
	7	[2.0,1.0,1.0,1.0,3.0,1.0,1.0,1.0],$
	8	[0.0,0.5,0.5,0.5,0.0,0.5,0.5,0.5],$
	9	[3.5,0.5,0.5,0.5,2.5,0.5,0.5,0.5],$
	10	[1.0,1.0,1.0,1.0,1.0,2.0,3.0,0.0],$
	11	[0.5,0.5,0.5,1.0,2.0,3.0,0.0,1.0],$
	12	[1.0,1.0,1.0,1.0,3.0,0.0,1.0,2.0],$
	13	[0.5,0.5,0.5,0.5,0.0,1.0,2.0,3.0]]
	14
	15	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	16	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	17	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	18	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	19	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	20	[0.5,0.5,0.5,1.0,1.0,1.0,1.0,1.0],$
	21	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	22	[0.5,0.5,0.5,0.5,1.0,1.0,1.0,1.0]]
	23
	24	2 =
	25	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	26	[1.0,1.0,1.0,0.0,1.0,1.0,1.0,1.0],$
	27	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	28	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	29	[1.0,1.0,1.0,1.0,2.0,3.0,0.0,1.0],$
	30	[0.5,0.5,0.5,1.0,3.0,0.0,1.0,2.0],$
	31	[1.0,1.0,1.0,1.0,0.0,1.0,2.0,3.0],$
	32	[0.5,0.5,0.5,0.5,1.0,2.0,3.0,0.0]]
	33
	34	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	35	[1.0,1.0,0.0,0.0,1.0,1.0,1.0,1.0],$
	36	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	37	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	38	[1.0,1.0,1.0,1.0,2.0,2.0,2.0,2.0],$
	39	[0.5,0.5,0.5,1.0,2.0,2.0,2.0,2.0],$
	40	[1.0,1.0,1.0,1.0,2.0,2.0,2.0,2.0],$
	41	[0.5,0.5,0.5,0.5,2.0,2.0,2.0,2.0]]
	42
	43	3 =
	44	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	45	[1.0,1.0,0.0,1.0,1.0,1.0,1.0,1.0],$
	46	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	47	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	48	[1.0,1.0,1.0,1.0,3.0,3.0,3.0,3.0],$
	49	[0.5,0.5,0.5,1.0,3.0,3.0,3.0,3.0],$
	50	[1.0,1.0,1.0,1.0,3.0,3.0,3.0,3.0],$
	51	[0.5,0.5,0.5,0.5,3.0,3.0,3.0,3.0]]
	52
	53	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	54	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	55	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	56	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	57	[1.0,1.0,1.0,1.0,3.0,3.0,3.0,3.0],$
	58	[0.5,0.5,0.5,1.0,3.0,3.0,3.0,3.0],$
	59	[1.0,1.0,1.0,1.0,3.0,3.0,3.0,3.0],$
	60	[0.5,0.5,0.5,0.5,3.0,3.0,3.0,3.0]]
	61
	62	4 =
	63	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	64	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	65	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	66	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	67	[1.0,1.0,1.0,1.0,0.0,1.0,2.0,3.0],$
	68	[0.5,0.5,0.5,1.0,1.0,2.0,3.0,0.0],$
	69	[1.0,1.0,1.0,1.0,2.0,3.0,0.0,1.0],$
	70	[0.5,0.5,0.5,0.5,3.0,0.0,1.0,2.0]]
	71
	72	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	73	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	74	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	75	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	76	[1.0,1.0,1.0,1.0,0.0,0.0,0.0,0.0],$
	77	[0.5,0.5,0.5,1.0,0.0,0.0,0.0,0.0],$
	78	[1.0,1.0,1.0,1.0,0.0,0.0,0.0,0.0],$
	79	[0.5,0.5,0.5,0.5,0.0,0.0,0.0,0.0]]
	80
	81	5 =
	82	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	83	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	84	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	85	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	86	[1.0,1.0,1.0,1.0,0.5,1.5,2.5,3.5],$
	87	[0.5,0.5,0.5,1.0,1.5,2.5,3.5,0.5],$
	88	[1.0,1.0,1.0,1.0,2.5,3.5,0.5,1.5],$
	89	[0.5,0.5,0.5,0.5,3.5,0.5,1.5,2.5]]
	90
	91	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	92	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	93	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	94	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	95	[1.0,1.0,1.0,1.0,0.5,0.5,0.5,0.5],$
	96	[0.5,0.5,0.5,1.0,0.5,0.5,0.5,0.5],$
	97	[1.0,1.0,1.0,1.0,0.5,0.5,0.5,0.5],$
	98	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5]]
	99
	100	6=
	101	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	102	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	103	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	104	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	105	[1.0,1.0,1.0,1.0,1.5,1.5,1.5,1.5],$
	106	[0.5,0.5,0.5,1.0,1.5,1.5,1.5,1.5],$
	107	[1.0,1.0,1.0,1.0,1.5,1.5,1.5,1.5],$
	108	[0.5,0.5,0.5,0.5,1.5,1.5,1.5,1.5]]
	109
	110	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	111	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	112	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	113	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	114	[1.0,1.0,1.0,1.0,1.5,1.5,1.5,1.5],$
	115	[0.5,0.5,0.5,1.0,1.5,1.5,1.5,1.5],$
	116	[1.0,1.0,1.0,1.0,1.5,1.5,1.5,1.5],$
	117	[0.5,0.5,0.5,0.5,1.5,1.5,1.5,1.5]]
	118
	119	7 =
	120	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	121	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	122	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	123	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	124	[1.0,1.0,1.0,1.0,2.5,2.5,2.5,2.5],$
	125	[0.5,0.5,0.5,1.0,2.5,2.5,2.5,2.5],$
	126	[1.0,1.0,1.0,1.0,2.5,2.5,2.5,2.5],$
	127	[0.5,0.5,0.5,0.5,2.5,2.5,2.5,2.5]]
	128
	129	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	130	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	131	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	132	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	133	[1.0,1.0,1.0,1.0,2.5,2.5,2.5,2.5],$
	134	[0.5,0.5,0.5,1.0,2.5,2.5,2.5,2.5],$
	135	[1.0,1.0,1.0,1.0,2.5,2.5,2.5,2.5],$
	136	[0.5,0.5,0.5,0.5,2.5,2.5,2.5,2.5]]
	137	8 =
		No newline at end of file
	138	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	139	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	140	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	141	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	142	[1.0,1.0,1.0,1.0,3.5,3.5,3.5,3.5],$
	143	[0.5,0.5,0.5,1.0,3.5,3.5,3.5,3.5],$
	144	[1.0,1.0,1.0,1.0,3.5,3.5,3.5,3.5],$
	145	[0.5,0.5,0.5,0.5,3.5,3.5,3.5,3.5]]
	146
	147	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	148	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	149	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	150	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	151	[1.0,1.0,1.0,1.0,3.5,3.5,3.5,3.5],$
	152	[0.5,0.5,0.5,1.0,3.5,3.5,3.5,3.5],$
	153	[1.0,1.0,1.0,1.0,3.5,3.5,3.5,3.5],$
	154	[0.5,0.5,0.5,0.5,3.5,3.5,3.5,3.5]]
	155
	156	9 =
	157	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	158	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	159	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	160	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	161	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	162	[0.5,0.5,0.5,1.0,1.0,1.0,1.0,1.0],$
	163	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	164	[0.5,0.5,0.5,0.5,1.0,1.0,1.0,1.0]]
	165
	166	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	167	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	168	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	169	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	170	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	171	[0.5,0.5,0.5,1.0,1.0,1.0,1.0,1.0],$
	172	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	173	[0.5,0.5,0.5,0.5,1.0,1.0,1.0,1.0]]
	174
	175	10 =
	176	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	177	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	178	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	179	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	180	[1.0,1.0,1.0,1.0,2.0,2.0,2.0,2.0],$
	181	[0.5,0.5,0.5,1.0,2.0,2.0,2.0,2.0],$
	182	[1.0,1.0,1.0,1.0,2.0,2.0,2.0,2.0],$
	183	[0.5,0.5,0.5,0.5,2.0,2.0,2.0,2.0]]
	184
	185	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	186	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	187	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	188	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	189	[1.0,1.0,1.0,1.0,2.0,2.0,2.0,2.0],$
	190	[0.5,0.5,0.5,1.0,2.0,2.0,2.0,2.0],$
	191	[1.0,1.0,1.0,1.0,2.0,2.0,2.0,2.0],$
	192	[0.5,0.5,0.5,0.5,2.0,2.0,2.0,2.0]]
	193
	194	11 =
	195	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	196	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	197	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	198	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	199	[1.0,1.0,1.0,1.0,3.0,3.0,3.0,3.0],$
	200	[0.5,0.5,0.5,1.0,3.0,3.0,3.0,3.0],$
	201	[1.0,1.0,1.0,1.0,3.0,3.0,3.0,3.0],$
	202	[0.5,0.5,0.5,0.5,3.0,3.0,3.0,3.0]]
	203
	204	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	205	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	206	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	207	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	208	[1.0,1.0,1.0,1.0,3.0,3.0,3.0,3.0],$
	209	[0.5,0.5,0.5,1.0,3.0,3.0,3.0,3.0],$
	210	[1.0,1.0,1.0,1.0,3.0,3.0,3.0,3.0],$
	211	[0.5,0.5,0.5,0.5,3.0,3.0,3.0,3.0]]
	212
	213	12 =
	214	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	215	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	216	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	217	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	218	[1.0,1.0,1.0,1.0,0.0,0.0,0.0,0.0],$
	219	[0.5,0.5,0.5,1.0,0.0,0.0,0.0,0.0],$
	220	[1.0,1.0,1.0,1.0,0.0,0.0,0.0,0.0],$
	221	[0.5,0.5,0.5,0.5,0.0,0.0,0.0,0.0]]
	222
	223	[[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	224	[1.0,1.0,1.0,1.0,1.0,1.0,1.0,1.0],$
	225	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	226	[0.5,0.5,0.5,0.5,0.5,0.5,0.5,0.5],$
	227	[1.0,1.0,1.0,1.0,0.0,0.0,0.0,0.0],$
	228	[0.5,0.5,0.5,1.0,0.0,0.0,0.0,0.0],$
	229	[1.0,1.0,1.0,1.0,0.0,0.0,0.0,0.0],$
	230	[0.5,0.5,0.5,0.5,0.0,0.0,0.0,0.0]]
	231

trunk/absroot/source/abspy/bin/library.py created 10644 +209 0

@@ -0,0 +1,209
	1	#import tftpy
	2	import socket
	3
	4	class UDPComm:
	5
	6	__HEADER = "ABS"
	7
	8	def __init__(self, ipSource, ipDestino, portDestino, asServer=False):
	9
	10	self.ipSource = ipSource
	11	self.ipDestino = ipDestino
	12	self.portDestino = portDestino
	13	self.addr = (ipDestino,portDestino)
	14	self.answer = "none" #test
	15	self.mode = "none"
	16
	17
	18	self.openSocket(asServer)
	19
	20	def openSocket(self, asServer):
	21
	22	#self.socket_c = socket.socket(AF_INET,SOCK_DGRAM)
	23	self.socket_c = socket.socket(socket.AF_INET, socket.SOCK_DGRAM,0)
	24	# self.socket_c.connect((self.ipDestino, self.portDestino))
	25
	26	if asServer:
	27	self.configAsServer()
	28	self.mode = "server"
	29	else:
	30	self.configAsClient()
	31	self.mode = "client"
	32
	33	def configAsClient(self):
	34	#Configurar broadcast
	35	self.socket_c.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
	36
	37	def configAsServer(self):
	38
	39	self.socket_c.bind(self.addr)
	40	print "\nServer initialized"
	41
	42	def waitData(self, nbytes = 16384):
	43
	44	print "\nWaiting some data"
	45	trama_rx, self.answer = self.socket_c.recvfrom(nbytes)
	46	print "\nThis socket has received some data from:"
	47	print self.answer
	48	ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx)
	49
	50	return ipSource, ipDestino, cmd, data
	51
	52	def sendData(self, cmd, data):
	53
	54	if self.portDestino == 7000:
	55	trama_tx = self.__HEADER + ":" + str(self.ipSource) + ":" + str(self.ipDestino) + ":" + str(cmd) + ":" + str(data) + ":"
	56	else:
	57	trama_tx = data
	58
	59	if self.mode == "client":
	60	destiny = self.addr
	61	else:
	62	destiny = self.answer
	63	# Send messages
	64	if(self.socket_c.sendto(trama_tx, destiny)):
	65	print "Sending message:[" + trama_tx + "] to " + str(destiny)
	66
	67	def __getTrama(self, trama):
	68
	69	FrameList = trama.split(':')
	70
	71	header = FrameList[0]
	72	ipSource = FrameList[1]
	73	ipDestino = FrameList[2]
	74	cmd = FrameList[3]
	75	data = FrameList[4]
	76	trash = FrameList[5]
	77
	78	return ipSource, ipDestino, cmd, data
	79
	80	class TCPComm:
	81
	82	__HEADER = "JRO"
	83	__TYPE = "ABS"
	84
	85	def __init__(self, ipSource, ipDestino, portDestino, asServer=False):
	86
	87	self.ipSource = ipSource
	88	self.ipDestino = ipDestino
	89	self.portDestino = portDestino
	90	self.addr = (ipDestino,portDestino)
	91
	92	self.sc = "none"
	93	self.answer = "none" #test
	94	self.mode = "none"
	95	self.len = 0
	96	self.crc = 0
	97
	98	self.openSocket(asServer)
	99
	100	def openSocket(self, asServer):
	101
	102	#self.socket_c = socket.socket(AF_INET,SOCK_DGRAM)
	103	# self.socket_c = socket.socket()
	104	# self.socket_c.connect((self.ipDestino, self.portDestino))
	105
	106	if asServer:
	107	self.socket_c = socket.socket()
	108	# self.configAsServer()
	109	self.socket_c.bind(self.addr)
	110	self.mode = "server"
	111	else:
	112	# self.configAsClient()
	113	self.mode = "client" #Socket is opened at the sendData function
	114
	115	# def configAsClient(self):
	116	#Buscar broadcast TCP
	117	# self.socket_c.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
	118	# self.socket_c.connect(self.addr)
	119	# pass
	120
	121	# def configAsServer(self):
	122	#
	123	# self.socket_c.bind(self.addr)
	124
	125	def waitData(self, nbytes = 1024):
	126
	127	print "\nWaiting some client."
	128
	129	if self.mode == "client":
	130	# Short data through ethernet
	131	trama_rx = self.socket_c.recv(nbytes)
	132	else:
	133	self.socket_c.listen(1)
	134	sc, addr = self.socket_c.accept()
	135	self.sc = sc
	136	self.answer = addr
	137	# Big data through ethernet
	138	trama_rx = ""
	139	while True:
	140	tmp = self.sc.recv(nbytes)
	141	trama_rx = trama_rx + tmp
	142	if trama_rx[-4:] == "quit":
	143	break
	144
	145	print "\nThis socket has received some data."
	146
	147	ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx)
	148
	149	return ipSource, ipDestino, cmd, data
	150
	151	def sendData(self, cmd, data, id):
	152
	153	trama_tx = self.__HEADER + ":" + self.__TYPE + ":" + str(self.ipSource) + ":" + str(self.ipDestino) + ":" + str(self.len) + ":" + str(cmd) + ":" + str(data) + ":" + str(self.crc)
	154
	155	if self.portDestino == 7000:
	156	trama_tx = trama_tx + ":" + "quit"
	157	# Send messages
	158	if self.mode == "client":
	159	host = "192.168.1." + str(id)
	160	self.socket_c.connect((host, self.portDestino))
	161	self.socket_c.send(trama_tx)
	162	else:
	163	self.sc.send(trama_tx)
	164	print "Sending message:[" + trama_tx + "]"
	165
	166	def __getTrama(self, trama):
	167
	168	FrameList = trama.split(':')
	169
	170	header = FrameList[0]
	171	TypeOfInstrument = FrameList[1]
	172	ipSource = FrameList[2]
	173	ipDestino = FrameList[3]
	174	len = FrameList[4]
	175	cmd = FrameList[5]
	176	data = FrameList[6]
	177	crc = FrameList[7]
	178	trash = FrameList[8]
	179
	180	return ipSource, ipDestino, cmd, data
	181
	182	def close_socket(self):
	183	self.socket_c.close()
	184
	185	def open_socket(self):
	186	self.socket_c = socket.socket()
	187
	188	#class FTPComm:
	189	#
	190	# ftp_servidor = 'ftp.servidor.com'
	191	# ftp_usuario = 'miusuario'
	192	# ftp_clave = 'miclave'
	193	# ftp_raiz = '/public_html'
	194	#
	195	# def __init__(self):
	196	#
	197	# self.client = tftpy.TftpClient(self.ftp_servidor, '69')
	198	#
	199	#
	200	# def sendFile(self, filename):
	201	#
	202	# self.client.upload(filename)
	203	#
	204	#if __name__ == '__main__':
	205	#
	206	# obj = FTPComm()
	207
	208
	209	No newline at end of file

trunk/absroot/source/abspy/bin/library2.py created 10644 +165 0

@@ -0,0 +1,165
	1	import socket
	2
	3	class TCPComm:
	4
	5	__HEADER = "JRO"
	6	__TYPE = "ABS"
	7
	8	def __init__(self, ipSource, ipDestino, portDestino, asServer=False):
	9
	10	self.ipSource = ipSource
	11	self.ipDestino = ipDestino
	12	self.portDestino = portDestino
	13	self.addr = (ipDestino,portDestino)
	14
	15	self.sc = "none"
	16	self.answer = "none" #test
	17	self.asServer = False
	18	self.len = 0
	19	self.crc = 0
	20
	21	self.openSocket(asServer)
	22
	23	def openSocket(self, asServer):
	24
	25	#self.socket_c = socket.socket(AF_INET,SOCK_DGRAM)
	26	# self.socket_c = socket.socket()
	27	# self.socket_c.connect((self.ipDestino, self.portDestino))
	28
	29	if asServer:
	30	self.socket_c = socket.socket()
	31	# self.configAsServer()
	32	self.socket_c.bind(self.addr)
	33	self.asServer = True
	34	else:
	35	# self.configAsClient()
	36	self.asServer = False #Socket is opened at the sendData function
	37
	38	# def configAsClient(self):
	39	#Buscar broadcast TCP
	40	# self.socket_c.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
	41	# self.socket_c.connect(self.addr)
	42	# pass
	43
	44	# def configAsServer(self):
	45	#
	46	# self.socket_c.bind(self.addr)
	47
	48	def waitData(self, nbytes = 1024):
	49
	50	print "\nWaiting some client."
	51
	52	if self.asServer == False:
	53	# Short data through ethernet
	54	trama_rx = self.socket_c.recv(nbytes)
	55	else:
	56	self.socket_c.listen(1)
	57	sc, addr = self.socket_c.accept()
	58	self.sc = sc
	59	self.answer = addr
	60	# Big data through ethernet
	61	trama_rx = ""
	62	while True:
	63	tmp = self.sc.recv(nbytes)
	64	trama_rx = trama_rx + tmp
	65	if trama_rx[-4:] == "quit":
	66	break
	67
	68	print "\nThis socket has received some data."
	69
	70	ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx)
	71
	72	return ipSource, ipDestino, cmd, data
	73
	74	def waitServer(self, nbytes = 1024):
	75
	76	print "\nWaiting some client."
	77	self.socket_c.listen(1)
	78	sc, addr = self.socket_c.accept()
	79	self.sc = sc
	80	self.answer = addr
	81	# Big data through ethernet
	82	trama_rx = ""
	83	while True:
	84	tmp = self.sc.recv(nbytes)
	85	trama_rx = trama_rx + tmp
	86	if trama_rx[-4:] == "quit":
	87	break
	88
	89	print "\nThis socket has received some data from: " + str(self.answer)
	90
	91	ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx)
	92
	93	return ipSource, ipDestino, cmd, data
	94
	95	def waitClient(self, nbytes = 1024):
	96
	97	print "\nWaiting the server."
	98	# Short data through ethernet
	99	trama_rx = self.socket_c.recv(nbytes)
	100
	101	print "\nThis socket has received this data: " + str(trama_rx)
	102
	103	ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx)
	104
	105	return ipSource, ipDestino, cmd, data
	106
	107	def sendData(self, cmd, data, id):
	108
	109	trama_tx = self.__HEADER + ":" + self.__TYPE + ":" + str(self.ipSource) + ":" + str(self.ipDestino) + \
	110	":" + str(self.len) + ":" + str(cmd) + ":" + str(data) + ":" + str(self.crc)
	111
	112	if self.portDestino == 7000:
	113	trama_tx = trama_tx + ":" + "quit"
	114	# Send messages
	115	if self.asServer == False:
	116	host = "192.168.1." + str(id)
	117	self.socket_c.connect((host, self.portDestino))
	118	self.socket_c.send(trama_tx)
	119	else:
	120	self.sc.send(trama_tx)
	121	print "Sending message:[" + trama_tx + "]"
	122
	123	def sendData2(self, cmd, data, ipDestino):
	124
	125	trama_tx = self.__HEADER + ":" + self.__TYPE + ":" + str(self.ipSource) + ":" + str(ipDestino) + \
	126	":" + str(self.len) + ":" + str(cmd) + ":" + str(data) + ":" + str(self.crc) + ":" + "quit"
	127
	128	if self.asServer == True:
	129	self.SendAsServer(trama_tx)
	130	else:
	131	self.SendAsClient(ipDestino, trama_tx)
	132
	133	def SendAsServer(self, trama_tx):
	134
	135	self.sc.send(trama_tx)
	136	print "Sending message:[" + trama_tx + "] to: " + str(self.answer)
	137
	138
	139	def SendAsClient(self, ipDestino, trama_tx):
	140
	141	self.socket_c.connect((ipDestino, self.portDestino))
	142	self.socket_c.send(trama_tx)
	143	print "Sending message:[" + trama_tx + "] to: " + ipDestino
	144
	145	def __getTrama(self, trama):
	146
	147	FrameList = trama.split(':')
	148
	149	header = FrameList[0]
	150	TypeOfInstrument = FrameList[1]
	151	ipSource = FrameList[2]
	152	ipDestino = FrameList[3]
	153	len = FrameList[4]
	154	cmd = FrameList[5]
	155	data = FrameList[6]
	156	crc = FrameList[7]
	157	trash = FrameList[8]
	158
	159	return ipSource, ipDestino, cmd, data
	160
	161	def close_socket(self):
	162	self.socket_c.close()
	163
	164	def open_socket(self):
	165	self.socket_c = socket.socket() No newline at end of file

trunk/absroot/source/abspy/bin/library3.py created 10644 +537 0

This diff has been collapsed as it changes many lines, (537 lines changed) Show them Hide them
	@@ -0,0 +1,537
		1	# Needed for the FilesStuff class
		2	import os
		3	import numpy as np
		4	# Needed for the TCPComm class
		5	import socket
		6
		7	class TCPComm:
		8
		9	__HEADER = "JRO"
		10	__TYPE = "ABS"
		11
		12	def __init__(self, ipSource, iDSource, ipDestino, iDDestino, portDestino, asServer=False):
		13
		14	self.ipSource = ipSource
		15	self.iDSource = iDSource
		16	self.ipDestino = ipDestino
		17	self.iDDestino = iDDestino
		18	self.portDestino = portDestino
		19	self.addr = (ipDestino,portDestino)
		20
		21	self.sc = "none"
		22	self.answer = "none" #test
		23	self.asServer = False
		24	self.len = "000000"
		25	self.crc = "0"
		26
		27	self.openSocket(asServer)
		28
		29	def openSocket(self, asServer):
		30
		31	#self.socket_c = socket.socket(AF_INET,SOCK_DGRAM)
		32	# self.socket_c = socket.socket()
		33	# self.socket_c.connect((self.ipDestino, self.portDestino))
		34
		35	if asServer:
		36	self.socket_c = socket.socket()
		37	# self.configAsServer()
		38	self.socket_c.bind(self.addr)
		39	self.asServer = True
		40	else:
		41	# self.configAsClient()
		42	self.asServer = False #Socket is opened at the sendData function
		43
		44	# def configAsClient(self):
		45	#Buscar broadcast TCP
		46	# self.socket_c.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
		47	# self.socket_c.connect(self.addr)
		48	# pass
		49
		50	# def configAsServer(self):
		51	#
		52	# self.socket_c.bind(self.addr)
		53
		54	def waitData(self):
		55	if self.asServer == True:
		56	trama_rx, l = self.waitAsServer()
		57	else:
		58	trama_rx, l = self.waitAsClient()
		59
		60	ipSource, ipDestino, cmd, data = self.__getTrama(trama_rx, l)
		61
		62	return ipSource, ipDestino, cmd, data
		63
		64	def waitAsClient2(self, nbytes = 1024):
		65	print "\nWaiting the server."
		66	# Short data through ethernet
		67	trama_rx = self.socket_c.recv(nbytes)
		68	print "\nThis socket has received this data: " + str(trama_rx)
		69
		70	return trama_rx
		71
		72	def waitAsServer2(self, nbytes = 1024):
		73	print "\nWaiting some client."
		74	self.socket_c.listen(1)
		75	sc, addr = self.socket_c.accept()
		76	self.sc = sc
		77	self.answer = addr
		78	# Big data through ethernet
		79	trama_rx = ""
		80	while True:
		81	tmp = self.sc.recv(nbytes)
		82	trama_rx = trama_rx + tmp
		83	if trama_rx[-4:] == "quit":
		84	break
		85
		86	print "\nThis socket has received some data from: " + str(self.answer)
		87
		88	return trama_rx
		89
		90	def waitAsServer(self, nbytes = 1024):
		91	print "\nWaiting some client."
		92	self.socket_c.listen(1)
		93	sc, addr = self.socket_c.accept()
		94	self.sc = sc
		95	self.answer = addr
		96	# Big data through ethernet
		97	cnt = 0;
		98	first = 0;
		99	trama_rx = ""
		100	while True:
		101	tmp = self.sc.recv(nbytes)
		102	trama_rx = trama_rx + tmp
		103	cnt = len(trama_rx)
		104	if first == 0:
		105	first = 1
		106	lng = int(trama_rx[20:26])
		107	frm_lng= lng + 31 # 31 bytes are fixed and added to the data size to get the frame size
		108	if cnt == frm_lng:
		109	break
		110
		111	print "\nThis socket has received some data from: " + str(self.answer)
		112
		113	return trama_rx, lng
		114
		115	def waitAsClient(self, nbytes = 1024):
		116	print "\nWaiting the server."
		117	# Short data through ethernet
		118	try:
		119	trama_rx = self.socket_c.recv(nbytes)
		120	lng = int(trama_rx[20:26])
		121	except:
		122	print "Waiting error"
		123	trama_rx = "Error"
		124	lng = 0
		125	else:
		126	print "\nThis socket has received this data: " + str(trama_rx)
		127
		128	return trama_rx, lng
		129
		130	def sendData2(self, cmd, data, ipDestino):
		131
		132	trama_tx = self.__HEADER + ":" + self.__TYPE + ":" + str(self.ipSource) + ":" + str(ipDestino) + \
		133	":" + str(self.len) + ":" + str(cmd) + ":" + str(data) + ":" + str(self.crc) + ":" + "quit"
		134
		135	if self.asServer == True:
		136	self.SendAsServer(trama_tx)
		137	else:
		138	self.SendAsClient(ipDestino, trama_tx)
		139
		140	def sendData(self, cmd, data, ipDestino):
		141
		142	trama_tx = self.__HEADER + self.__TYPE + self.iDSource + \
		143	self.iDDestino + self.len + str(cmd) + str(data) + self.crc
		144
		145	self.len = self.int2str(len(data))
		146
		147	trama_tx = self.__HEADER + self.__TYPE + self.iDSource + \
		148	self.iDDestino + self.len + str(cmd) + str(data) + self.crc
		149
		150	if self.asServer == True:
		151	self.SendAsServer(trama_tx)
		152	else:
		153	self.SendAsClient(ipDestino, trama_tx)
		154
		155	def SendAsServer(self, trama_tx):
		156
		157	self.sc.send(trama_tx)
		158	print "Sending message:[" + trama_tx + "] to: " + str(self.answer)
		159
		160
		161	def SendAsClient(self, ipDestino, trama_tx):
		162
		163	try:
		164	self.socket_c.connect((ipDestino, self.portDestino))
		165	except:
		166	print "Connection error with:" + ipDestino
		167	else:
		168	self.socket_c.send(trama_tx)
		169	print "Sending message:[" + trama_tx + "] to: " + ipDestino
		170
		171	def __getTrama2(self, trama):
		172
		173	FrameList = trama.split(':')
		174
		175	header = FrameList[0]
		176	TypeOfInstrument = FrameList[1]
		177	ipSource = FrameList[2]
		178	ipDestino = FrameList[3]
		179	len = FrameList[4]
		180	cmd = FrameList[5]
		181	data = FrameList[6]
		182	crc = FrameList[7]
		183	trash = FrameList[8]
		184
		185	return ipSource, ipDestino, cmd, data
		186
		187	def __getTrama(self, trama, l):
		188
		189	header = trama[0:3]
		190	TypeOfInstrument = trama[3:6]
		191	ipSource = trama[6:13]
		192	ipDestino = trama[13:20]
		193	len = trama[20:26]
		194	cmd = trama[26:30]
		195	data = trama[30:30+int(l)]
		196	crc = trama[30+ int(l):]
		197
		198	return ipSource, ipDestino, cmd, data
		199
		200	def close_socket(self):
		201	self.socket_c.close()
		202
		203	def open_socket(self):
		204	self.socket_c = socket.socket()
		205
		206	def int2str(self, n):
		207
		208	str_n = str(n)
		209	l_n = len(str_n)
		210	if l_n == 1:
		211	str_n = "00000" + str_n
		212	elif l_n == 2:
		213	str_n = "0000" + str_n
		214	elif l_n == 3:
		215	str_n = "000" + str_n
		216	elif l_n == 4:
		217	str_n = "00" + str_n
		218	elif l_n == 5:
		219	str_n = "0" + str_n
		220	return str_n
		221
		222	class FilesStuff():
		223
		224	def lst2string(self, lst):
		225	string=''
		226	for i in lst:
		227	string=string+i
		228	return string
		229
		230	def string2lst(self, string):
		231	lst = []
		232	for i in string:
		233	lst.append(i)
		234	return lst
		235
		236
		237	def file1(self, filename, type):
		238	lst = self.string2lst(filename)
		239	fin = -1
		240	t = len(lst)
		241	for i in np.arange(-1,-t,-1):
		242	if lst[i]=='/':
		243	fin=i
		244	break
		245	if type == '1':
		246	nombre2 = lst[fin+1:]
		247	nombre2[-1]='s'
		248	nombre2 = self.lst2string(nombre2)
		249	return nombre2
		250	if type == '2':
		251	nombre2 = lst[fin+1:]
		252	nombre2[-1]='1'
		253	nombre2 = self.lst2string(nombre2)
		254	return nombre2
		255
		256
		257	def EliminaSaltoDeLinea(self,cadena):
		258	i = 0
		259	for elemento in cadena:
		260	if elemento =='\n' or elemento =='\r':
		261	pass
		262	else:
		263	i=i+1
		264	return cadena [:i]
		265
		266	def NumeroDeExperimentos(self, path):
		267	fichero1=open(path,'r')
		268	cont=0
		269	for cadena in fichero1:
		270	cont=cont+1
		271	if cont==3:
		272	nexp=''
		273	pos=0
		274	for elemento in cadena:
		275	pos=pos+1
		276	if elemento=='=':
		277	nexp=int(cadena[pos:])
		278	return nexp
		279	fichero1.close()
		280
		281	def Paridad(self, numero):
		282	if numero%2==0: return 'par'
		283	elif numero%2==1: return 'impar'
		284
		285	def EvaluaCadena(self,cadena):
		286	if len(cadena)>35:
		287	if cadena[-1]=='$':
		288	return cadena[-35:-2]
		289	elif cadena[-1]==']':
		290	return cadena[-34:-1]
		291	else:
		292	return None
		293
		294	def GuardaEnLista(self,path):
		295	fichero=open(path,'r')
		296	lista=[]
		297	for cadena in fichero:
		298	cadena = self.EliminaSaltoDeLinea(cadena)
		299	cadena = self.EvaluaCadena(cadena)
		300	if cadena != None:
		301	lista.append(cadena)
		302	fichero.close()
		303	return lista
		304
		305	def CreaFicherosPrevios(self, path, archivo):
		306	vector = self.GuardaEnLista(archivo)
		307	for i in range(1,self.NumeroDeExperimentos(archivo)+1):
		308	fichero =open(path + str(i)+ '.txt','w')
		309	for j in range(0,16):
		310	fichero.write(vector[j+16*(i-1)]+'\n')
		311	fichero.close()
		312
		313	def CapturaValoresEnArchivo(self, path, polarizacion='up'):
		314	fichero =open(path,'r')
		315	cnt=0
		316	lstup=[]
		317	lstdw=[]
		318	for cadena in fichero:
		319	cnt=cnt+1
		320	if cnt==1:
		321	nu01=cadena[1:4]
		322	nu02=cadena[5:8]
		323	nu03=cadena[9:12]
		324	nu04=cadena[13:16]
		325	eu01=cadena[17:20]
		326	eu02=cadena[21:24]
		327	eu03=cadena[25:28]
		328	eu04=cadena[29:32]
		329	if cnt==2:
		330	nu05=cadena[1:4]
		331	nu06=cadena[5:8]
		332	nu07=cadena[9:12]
		333	nu08=cadena[13:16]
		334	eu05=cadena[17:20]
		335	eu06=cadena[21:24]
		336	eu07=cadena[25:28]
		337	eu08=cadena[29:32]
		338	if cnt==3:
		339	nu09=cadena[1:4]
		340	nu10=cadena[5:8]
		341	nu11=cadena[9:12]
		342	nu12=cadena[13:16]
		343	eu09=cadena[17:20]
		344	eu10=cadena[21:24]
		345	eu11=cadena[25:28]
		346	eu12=cadena[29:32]
		347	if cnt==4:
		348	nu13=cadena[1:4]
		349	nu14=cadena[5:8]
		350	nu15=cadena[9:12]
		351	nu16=cadena[13:16]
		352	eu13=cadena[17:20]
		353	eu14=cadena[21:24]
		354	eu15=cadena[25:28]
		355	eu16=cadena[29:32]
		356	if cnt==5:
		357	wu01=cadena[1:4]
		358	wu02=cadena[5:8]
		359	wu03=cadena[9:12]
		360	wu04=cadena[13:16]
		361	su01=cadena[17:20]
		362	su02=cadena[21:24]
		363	su03=cadena[25:28]
		364	su04=cadena[29:32]
		365	if cnt==6:
		366	wu05=cadena[1:4]
		367	wu06=cadena[5:8]
		368	wu07=cadena[9:12]
		369	wu08=cadena[13:16]
		370	su05=cadena[17:20]
		371	su06=cadena[21:24]
		372	su07=cadena[25:28]
		373	su08=cadena[29:32]
		374	if cnt==7:
		375	wu09=cadena[1:4]
		376	wu10=cadena[5:8]
		377	wu11=cadena[9:12]
		378	wu12=cadena[13:16]
		379	su09=cadena[17:20]
		380	su10=cadena[21:24]
		381	su11=cadena[25:28]
		382	su12=cadena[29:32]
		383	if cnt==8:
		384	wu13=cadena[1:4]
		385	wu14=cadena[5:8]
		386	wu15=cadena[9:12]
		387	wu16=cadena[13:16]
		388	su13=cadena[17:20]
		389	su14=cadena[21:24]
		390	su15=cadena[25:28]
		391	su16=cadena[29:32]
		392	if cnt==9:
		393	nd01=cadena[1:4]
		394	nd02=cadena[5:8]
		395	nd03=cadena[9:12]
		396	nd04=cadena[13:16]
		397	ed01=cadena[17:20]
		398	ed02=cadena[21:24]
		399	ed03=cadena[25:28]
		400	ed04=cadena[29:32]
		401	if cnt==10:
		402	nd05=cadena[1:4]
		403	nd06=cadena[5:8]
		404	nd07=cadena[9:12]
		405	nd08=cadena[13:16]
		406	ed05=cadena[17:20]
		407	ed06=cadena[21:24]
		408	ed07=cadena[25:28]
		409	ed08=cadena[29:32]
		410	if cnt==11:
		411	nd09=cadena[1:4]
		412	nd10=cadena[5:8]
		413	nd11=cadena[9:12]
		414	nd12=cadena[13:16]
		415	ed09=cadena[17:20]
		416	ed10=cadena[21:24]
		417	ed11=cadena[25:28]
		418	ed12=cadena[29:32]
		419	if cnt==12:
		420	nd13=cadena[1:4]
		421	nd14=cadena[5:8]
		422	nd15=cadena[9:12]
		423	nd16=cadena[13:16]
		424	ed13=cadena[17:20]
		425	ed14=cadena[21:24]
		426	ed15=cadena[25:28]
		427	ed16=cadena[29:32]
		428	if cnt==13:
		429	wd01=cadena[1:4]
		430	wd02=cadena[5:8]
		431	wd03=cadena[9:12]
		432	wd04=cadena[13:16]
		433	sd01=cadena[17:20]
		434	sd02=cadena[21:24]
		435	sd03=cadena[25:28]
		436	sd04=cadena[29:32]
		437	if cnt==14:
		438	wd05=cadena[1:4]
		439	wd06=cadena[5:8]
		440	wd07=cadena[9:12]
		441	wd08=cadena[13:16]
		442	sd05=cadena[17:20]
		443	sd06=cadena[21:24]
		444	sd07=cadena[25:28]
		445	sd08=cadena[29:32]
		446	if cnt==15:
		447	wd09=cadena[1:4]
		448	wd10=cadena[5:8]
		449	wd11=cadena[9:12]
		450	wd12=cadena[13:16]
		451	sd09=cadena[17:20]
		452	sd10=cadena[21:24]
		453	sd11=cadena[25:28]
		454	sd12=cadena[29:32]
		455	if cnt==16:
		456	wd13=cadena[1:4]
		457	wd14=cadena[5:8]
		458	wd15=cadena[9:12]
		459	wd16=cadena[13:16]
		460	sd13=cadena[17:20]
		461	sd14=cadena[21:24]
		462	sd15=cadena[25:28]
		463	sd16=cadena[29:32]
		464	blck_1_up = [nu01,nu02,nu03,nu04,eu01,eu02,eu03,eu04,nu05,nu06,nu07,nu08,eu05,eu06,eu07,eu08]
		465	blck_1_dw = [nd01,nd02,nd03,nd04,ed01,ed02,ed03,ed04,nd05,nd06,nd07,nd08,ed05,ed06,ed07,ed08]
		466	blck_2_up = [nu09,nu10,nu11,nu12,eu09,eu10,eu11,eu12,nu13,nu14,nu15,nu16,eu13,eu14,eu15,eu16]
		467	blck_2_dw = [nd09,nd10,nd11,nd12,ed09,ed10,ed11,ed12,nd13,nd14,nd15,nd16,ed13,ed14,ed15,ed16]
		468	blck_3_up = [wu01,wu02,wu03,wu04,su01,su02,su03,su04,wu05,wu06,wu07,wu08,su05,su06,su07,su08]
		469	blck_3_dw = [wd01,wd02,wd03,wd04,sd01,sd02,sd03,sd04,wd05,wd06,wd07,wd08,sd05,sd06,sd07,sd08]
		470	blck_4_up = [wu09,wu10,wu11,wu12,su09,su10,su11,su12,wu13,wu14,wu15,wu16,su13,su14,su15,su16]
		471	blck_4_dw = [wd09,wd10,wd11,wd12,sd09,sd10,sd11,sd12,wd13,wd14,wd15,wd16,sd13,sd14,sd15,sd16]
		472
		473	lstup = blck_1_up + blck_2_up + blck_3_up + blck_4_up
		474	lstdw = blck_1_dw + blck_2_dw + blck_3_dw + blck_4_dw
		475
		476	if polarizacion=='up':
		477	return lstup
		478	elif polarizacion=='dw':
		479	return lstdw
		480	fichero.close()
		481
		482	def CreaFormatoFinal(self, path, filename):
		483	ne=self.NumeroDeExperimentos(filename)
		484
		485	#nombre01 = file1(archivo,'1')
		486	nombre02 = self.file1(filename,'2')
		487	fichero=open(path + 'CentralControlFormat.txt','w')
		488	fichero.write(nombre02+'\n')
		489	fichero.write(str(ne)+'\n')
		490
		491	for i in range(1,65):
		492
		493	if i<10:
		494	nmod = '0'+str(i)
		495	else: nmod = str(i)
		496
		497	fichero.write("ABS_" + nmod+'\n')
		498
		499	for j in range(1,ne+1):
		500	ruta=path+str(j)+'.txt'
		501	lu=self.CapturaValoresEnArchivo(ruta,polarizacion='up')
		502	ld=self.CapturaValoresEnArchivo(ruta,polarizacion='dw')
		503	part1=''
		504	part2=''
		505	if lu[i-1]=='1.0': part1='000'
		506	if lu[i-1]=='2.0': part1='001'
		507	if lu[i-1]=='3.0': part1='010'
		508	if lu[i-1]=='0.0': part1='011'
		509	if lu[i-1]=='0.5': part1='100'
		510	if lu[i-1]=='1.5': part1='101'
		511	if lu[i-1]=='2.5': part1='110'
		512	if lu[i-1]=='3.5': part1='111'
		513	if ld[i-1]=='1.0': part2='000'
		514	if ld[i-1]=='2.0': part2='001'
		515	if ld[i-1]=='3.0': part2='010'
		516	if ld[i-1]=='0.0': part2='011'
		517	if ld[i-1]=='0.5': part2='100'
		518	if ld[i-1]=='1.5': part2='101'
		519	if ld[i-1]=='2.5': part2='110'
		520	if ld[i-1]=='3.5': part2='111'
		521	fichero.write(part1+part2+'\n')
		522	fichero.write('------'+'\n')
		523	fichero.close()
		524
		525	def EliminaArchivosEnLaCarpeta(self, path, filename):
		526	ne=self.NumeroDeExperimentos(filename)
		527	for i in range(1,ne+1):
		528	os.remove(path + str(i)+'.txt')
		529
		530
		531	def toCentralControlFormat(self, filename):
		532	""" Funcion que genera un archivo para el control central"""
		533
		534	path = os.getcwd() + '/'
		535	self.CreaFicherosPrevios(path, filename)
		536	self.CreaFormatoFinal(path, filename)
		537	self.EliminaArchivosEnLaCarpeta(path, filename)

trunk/absroot/source/abspy/bin/module_status.txt created 10644 +66 0

@@ -0,0 +1,66
	1	Status of modules
	2	----------------
	3	192.168.1.1 [1 1]
	4	192.168.1.2 [0 0]
	5	192.168.1.3 [0 0]
	6	192.168.1.4 [0 0]
	7	192.168.1.5 [0 0]
	8	192.168.1.6 [0 0]
	9	192.168.1.7 [0 0]
	10	192.168.1.8 [0 0]
	11	192.168.1.9 [0 0]
	12	192.168.1.10 [0 0]
	13	192.168.1.11 [0 0]
	14	192.168.1.12 [0 0]
	15	192.168.1.13 [0 0]
	16	192.168.1.14 [0 0]
	17	192.168.1.15 [0 0]
	18	192.168.1.16 [0 0]
	19	192.168.1.17 [0 0]
	20	192.168.1.18 [0 0]
	21	192.168.1.19 [0 0]
	22	192.168.1.20 [0 0]
	23	192.168.1.21 [0 0]
	24	192.168.1.22 [0 0]
	25	192.168.1.23 [0 0]
	26	192.168.1.24 [0 0]
	27	192.168.1.25 [0 0]
	28	192.168.1.26 [0 0]
	29	192.168.1.27 [0 0]
	30	192.168.1.28 [0 0]
	31	192.168.1.29 [0 0]
	32	192.168.1.30 [0 0]
	33	192.168.1.31 [0 0]
	34	192.168.1.32 [0 0]
	35	192.168.1.33 [0 0]
	36	192.168.1.34 [0 0]
	37	192.168.1.35 [0 0]
	38	192.168.1.36 [0 0]
	39	192.168.1.37 [0 0]
	40	192.168.1.38 [0 0]
	41	192.168.1.39 [0 0]
	42	192.168.1.40 [0 0]
	43	192.168.1.41 [0 0]
	44	192.168.1.42 [0 0]
	45	192.168.1.43 [0 0]
	46	192.168.1.44 [0 0]
	47	192.168.1.45 [0 0]
	48	192.168.1.46 [0 0]
	49	192.168.1.47 [0 0]
	50	192.168.1.48 [0 0]
	51	192.168.1.49 [0 0]
	52	192.168.1.50 [0 0]
	53	192.168.1.51 [0 0]
	54	192.168.1.52 [0 0]
	55	192.168.1.53 [0 0]
	56	192.168.1.54 [0 0]
	57	192.168.1.55 [0 0]
	58	192.168.1.56 [0 0]
	59	192.168.1.57 [0 0]
	60	192.168.1.58 [0 0]
	61	192.168.1.59 [0 0]
	62	192.168.1.60 [0 0]
	63	192.168.1.61 [0 0]
	64	192.168.1.62 [0 0]
	65	192.168.1.63 [0 0]
	66	192.168.1.64 [0 0]

trunk/absroot/source/abspy/bin/server.py created 10644 +281 0

@@ -0,0 +1,281
	1	import os
	2	import library
	3	import time
	4
	5	class ABSServer:
	6
	7	def __init__(self,ipSource="localhost", ipDestino="192.168.1.117", portDestino=7000, ipDestino2="192.168.1.255", portDestino2=5500, ftpPortDestino=None):
	8
	9	self.ipSource = ipSource
	10	self.ipDestino = ipDestino
	11	self.portDestino = portDestino
	12
	13	self.ipDestino2 = ipDestino2
	14	self.portDestino2 = portDestino2
	15
	16	self.ftpPortDestino = ftpPortDestino
	17	self.experiment_name = "default"
	18	self.tx_buffer = "default"
	19
	20	self.createObjects()
	21
	22	def createObjects(self):
	23
	24	asServer = True
	25	self.commServerObj = library.UDPComm(self.ipSource, self.ipDestino, self.portDestino, asServer)
	26	self.commClientObj = library.UDPComm(self.ipSource, self.ipDestino2, self.portDestino2)
	27	#self.ftpCommObj = library.FTPComm(self.ipSource, self.ipDestino, self.ftpPortDestino)
	28
	29
	30	def waitRequest(self):
	31
	32	ipSource, ipDestino, cmd, self.datarx = self.commServerObj.waitData()
	33
	34	datarpta = "OK"
	35
	36	if cmd == "SNDF":
	37	self.sendFile2Modules()
	38	pass
	39
	40	if cmd == "CHGB":
	41	self.changeBeam()
	42
	43	if cmd == "ANST":
	44	self.getStatus(mode=3)
	45	datarpta = self.tx_buffer
	46
	47	self.commServerObj.sendData(cmd=cmd, data=datarpta)
	48
	49	def checkModule(self, address):
	50
	51	cmd = "ping -c 1 -w 1 192.168.1."+ str(address) + " >> /dev/null"
	52	status = os.system(cmd)
	53
	54	if status == 256:
	55	return False
	56
	57	return True
	58
	59	def __writeReport(self, enaModules):
	60
	61	status_array = ["Status of modules\n"]
	62	status_array.append("----------------\n")
	63
	64	for address in range(1,65):
	65	if address in enaModules:
	66	# status_array.append("192.168.1." + str(base + i + 1) + " [1 1]\n")
	67	status_array.append("192.168.1." + str(address) + " [1 1]\n")
	68	else:
	69	status_array.append("192.168.1." + str(address) + " [0 0]\n")
	70
	71	f = open("module_status.txt","w")
	72	f.writelines(status_array)
	73	f.close()
	74
	75	def checkAntenna(self):
	76
	77	"""
	78	Direccion de los modulos de las antenas:
	79
	80	Norte : 01-16
	81	Este : 17-32
	82	Oeste: : 33-48
	83	Sur : 49-64
	84
	85	"""
	86
	87	enaModules = []
	88
	89	for address in range(1,65):
	90	if self.checkModule(address):
	91	enaModules.append(address)
	92
	93	self.__writeReport(enaModules)
	94	return enaModules
	95
	96	def sendFile2Modules(self):
	97
	98	#Needed for the loop
	99	rx_frame_list = self.datarx.split('\n',2)
	100
	101	self.experiment_name = rx_frame_list[0]
	102	experiment_number = rx_frame_list[1]
	103	str_control_modules = rx_frame_list[2]
	104
	105	lst_control_modules = str_control_modules.split("------\n")
	106
	107	enaModules = self.checkAntenna()
	108
	109	for address in range(1,65):
	110
	111	if address not in enaModules:
	112	continue
	113
	114	self.__writeModuleFile(self.experiment_name, lst_control_modules[address-1])
	115
	116	cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c put " + self.experiment_name
	117	print cmd
	118	os.system(cmd)
	119
	120	self.__loadFile()
	121
	122	def __writeModuleFile(self, filename, str):
	123
	124	fobj = open(filename,"w")
	125	fobj.write(filename + "\n")
	126	fobj.write("------\n")
	127	fobj.write(str)
	128	fobj.write("------\n")
	129	fobj.close()
	130
	131	def __readModuleFile(self, filename):
	132
	133	fobj1 = open(filename,"r")
	134	file_list_1 = fobj1.readlines()
	135	fobj1.close()
	136	content_str = ''.join(file_list_1[2:-1])
	137
	138	return content_str
	139
	140	def __loadFile(self):
	141
	142	#Working with the UDP socket
	143	self.commClientObj.sendData("none", "CARGA:" + self.experiment_name + ":")
	144	self.commClientObj.sendData("none", "CAMBIA:0:")
	145
	146	def changeBeam(self):
	147
	148	#rpta = self.commClientObj.sendTxRxCommand(cmd='CAMBIA', data="0")
	149	self.commClientObj.sendData("none", "CAMBIA:" + self.datarx + ":")
	150
	151	def getStatus(self,mode):
	152
	153	if mode == 1:
	154	self.__getStsMode1()
	155	elif mode == 2:
	156	self.__getStsMode2()
	157	else:
	158	self.__getStsMode3()
	159
	160
	161	def __getStsMode1(self):
	162	#rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
	163	self.commClientObj.sendData("CHEQUEO:" + self.datarx + ":")
	164	seconds = int (self.datarx)
	165	# Give 5 seconds to the control modules
	166	time.sleep(seconds)
	167	# Checking the module connection
	168	module_list = self.connection_status(10)
	169	#Generating the complete report
	170	module = 1
	171	number_of_modules = 16
	172	filename1 = "Verificacion"
	173	filename2 = "report.txt"
	174	fobj2 = open(filename2,"w")
	175	fobj2.write("Verification_file\n")
	176	fobj2.write("-----------------\n")
	177	fobj2.close()
	178	while module <= number_of_modules:
	179	if module_list[module -1] == "1":
	180	#Preparing and doing the tftp command
	181	cmd = "tftp -m binary 192.168.1."+ str(base + module) +" 69 -c get " + filename1
	182	print cmd
	183	os.system(cmd)
	184	# Getting data from the control module file
	185	fobj1 = open(filename1,"r")
	186	file_list_1 = fobj1.readlines()
	187	fobj1.close()
	188	content = file_list_1[2:-1]
	189	#
	190	fobj2 = open(filename2,"a")
	191	if base == 10:
	192	fobj2.write("S" + str(module) + "\n")
	193	else:
	194	fobj2.write("N" + str(module) + "\n")
	195	fobj2.writelines(content)
	196	fobj2.write("------\n")
	197	fobj2.close()
	198	module = module + 1
	199
	200	def __getStsMode2(self):
	201
	202	#rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
	203	self.commClientObj.sendData("CHEQUEO:" + self.datarx + ":")
	204	seconds = int (self.datarx)
	205	# Give 5 seconds to the control modules
	206	time.sleep(seconds)
	207	# Checking the module connection
	208	enaModules = self.checkAntenna()
	209	#Generating the complete report
	210	filename1 = "Verificacion"
	211	line1 = "Verification_file\n"
	212	line2 = "-----------------\n"
	213	report_list = [line1, line2]
	214
	215	for address in range(1,65):
	216
	217	if address not in enaModules:
	218	continue
	219	#Preparing and doing the tftp command
	220	cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c get " + filename1
	221	print cmd
	222	os.system(cmd)
	223	#Sub_header
	224	report_list.append("ABS_" + str(address) + "\n")
	225	# Content
	226	fobj1 = open(filename1,"r")
	227	file_list_1 = fobj1.readlines()
	228	fobj1.close()
	229	content = ''.join(file_list_1[2:-1])
	230	report_list.append(content)
	231	#Ending
	232	report_list.append("------\n")
	233	#print "\nFinalizado"
	234	self.tx_buffer = ''.join(report_list)
	235
	236	def __AddingHeader(self,content_list, title):
	237
	238	line1 = title + "\n"
	239	line2 = "-----------------\n"
	240	header_list = [line1, line2]
	241	verification_list = header_list + content_list
	242	# Arming the frame
	243	self.tx_buffer = ''.join(verification_list)
	244
	245	def __getModuleFile(self, filename):
	246
	247	enaModules = self.checkAntenna()
	248	content_list = []
	249	for address in range(1,65):
	250
	251	if address not in enaModules:
	252	continue
	253	#Preparing and doing the tftp command
	254	cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c get " + filename
	255	print cmd
	256	os.system(cmd)
	257	#Sub_header
	258	content_list.append("ABS_" + str(address) + "\n")
	259	# From module file to list
	260	content_str = self.__readModuleFile(filename)
	261	content_list.append(content_str)
	262	content_list.append("------\n")
	263
	264	self.__AddingHeader(content_list, title = "Verification_file")
	265
	266	def __getStsMode3(self):
	267
	268	self.commClientObj.sendData("none", "CHEQUEO:" + self.datarx + ":")
	269	seconds = int (self.datarx)
	270	# Give 5 seconds to the control modules
	271	time.sleep(seconds)
	272
	273	self.__getModuleFile(filename = "Verificacion")
	274
	275
	276	if __name__ == '__main__':
	277
	278	absObj = ABSServer()
	279
	280	while 1:
	281	absObj.waitRequest() No newline at end of file

trunk/absroot/source/abspy/bin/server2.py created 10644 +369 0

@@ -0,0 +1,369
	1	import os
	2	import library2
	3	import time
	4
	5	class ABSServer:
	6
	7	def __init__(self,ipSource="localhost", ipDestino="192.168.1.117", portDestino=7000, ipDestino2="192.168.1.11", portDestino2=5500):
	8
	9	self.ipSource = ipSource
	10	self.ipDestino = ipDestino
	11	self.portDestino = portDestino
	12
	13	self.ipDestino2 = ipDestino2
	14	self.portDestino2 = portDestino2
	15
	16	self.tx_buffer = "default"
	17	self.rx_buffer = "default"
	18
	19	self.createObjects()
	20
	21	def createObjects(self):
	22
	23	asServer = True
	24	self.commServerObj = library2.TCPComm("Central_Control", self.ipDestino, self.portDestino, asServer)
	25	self.commClientObj = library2.TCPComm("Central_Control", self.ipDestino2, self.portDestino2)
	26
	27	def waitRequest(self):
	28
	29	# Using rx buffer
	30	ipSource, ipDestino, cmd, self.rx_buffer = self.commServerObj.waitServer()
	31
	32	if cmd == "SNDF":
	33	datarpta = self.sendFile2Modules(mode=2, cmd = cmd)
	34
	35	if cmd == "CHGB":
	36	datarpta = self.changeBeam(cmd = cmd)
	37
	38	if cmd == "ANST":
	39	self.getStatus(mode=4, cmd = cmd)
	40	# Using tx buffer
	41	datarpta = self.tx_buffer
	42
	43	self.commServerObj.sendData2(cmd=cmd, data=datarpta, ipDestino = ipSource)
	44
	45	def checkModule(self, address):
	46
	47	cmd = "ping -c 1 -w 1 192.168.1."+ str(address) + " >> /dev/null"
	48	status = os.system(cmd)
	49
	50	if status == 256:
	51	return False
	52
	53	return True
	54
	55	def __writeReport(self, enaModules):
	56
	57	status_array = ["Status of modules\n"]
	58	status_array.append("----------------\n")
	59
	60	for address in range(1,65):
	61	if address in enaModules:
	62	status_array.append("192.168.1." + str(address) + " [1 1]\n")
	63	else:
	64	status_array.append("192.168.1." + str(address) + " [0 0]\n")
	65
	66	f = open("module_status.txt","w")
	67	f.writelines(status_array)
	68	f.close()
	69
	70	def checkAntenna(self):
	71
	72	"""
	73	Direccion de los modulos de las antenas:
	74
	75	Norte : 01-16
	76	Este : 17-32
	77	Oeste: : 33-48
	78	Sur : 49-64
	79
	80	"""
	81
	82	enaModules = []
	83
	84	for address in range(1,65):
	85	if self.checkModule(address):
	86	enaModules.append(address)
	87
	88	self.__writeReport(enaModules)
	89	return enaModules
	90
	91	def sendFile2Modules(self, mode, cmd):
	92
	93	if mode == 1:
	94	self.__sendFile2Modules1()
	95	else:
	96	self.__sendFile2Modules2(cmd)
	97
	98	def __sendFile2Modules1(self):
	99
	100	#Needed for the loop
	101	rx_frame_list = self.rx_buffer.split('\n',2)
	102
	103	self.experiment_name = rx_frame_list[0]
	104	experiment_number = rx_frame_list[1]
	105	str_control_modules = rx_frame_list[2]
	106
	107	lst_control_modules = str_control_modules.split("------\n")
	108
	109	# enaModules = self.checkAntenna()
	110	enaModules = [11,12,13,14]
	111
	112	for address in range(1,65):
	113
	114	if address not in enaModules:
	115	continue
	116
	117	self.__writeModuleFile(self.experiment_name, lst_control_modules[address-1])
	118
	119	cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c put " + self.experiment_name
	120	print cmd
	121	os.system(cmd)
	122
	123	self.__loadFile()
	124
	125	def __sendFile2Modules2(self,cmd):
	126
	127	#Needed for the loop
	128	rx_frame_list = self.rx_buffer.split('\n',2)
	129	correct = 0
	130	failure = 0
	131	header = rx_frame_list[0] + "\n"
	132	str_control_modules = rx_frame_list[2]
	133
	134	lst_control_modules = str_control_modules.split("------\n")
	135
	136	# enaModules = self.checkAntenna()
	137	enaModules = [11,12,13,14]
	138
	139	for id in range(1,65):
	140
	141	if id not in enaModules:
	142	continue
	143	#tcp client needed
	144	self.commClientObj.open_socket()
	145	ip = "192.168.1." + str(id)
	146	self.commClientObj.sendData2(cmd, header + lst_control_modules[id-1], ip)
	147	ipSource, ipDestino, cmd, tmp = self.commClientObj.waitClient()
	148	self.commClientObj.close_socket()
	149
	150	if tmp == "OK":
	151	correct = correct + 1
	152	else:
	153	failure = failure + 1
	154
	155	if correct == len(enaModules):
	156	rpta = "OK"
	157	else:
	158	rpta = "Failure"
	159
	160	return rpta
	161
	162
	163	def __writeModuleFile(self, filename, str):
	164
	165	fobj = open(filename,"w")
	166	fobj.write(filename + "\n")
	167	fobj.write("------\n")
	168	fobj.write(str)
	169	fobj.write("------\n")
	170	fobj.close()
	171
	172	def __readModuleFile(self, filename):
	173
	174	fobj1 = open(filename,"r")
	175	file_list_1 = fobj1.readlines()
	176	fobj1.close()
	177	content_str = ''.join(file_list_1[2:-1])
	178
	179	return content_str
	180
	181	def __loadFile(self):
	182
	183	#Working with the UDP socket
	184	self.commClientObj.sendData("none", "CARGA:" + self.experiment_name + ":")
	185	self.commClientObj.sendData("none", "CAMBIA:0:")
	186
	187	def changeBeam(self, cmd):
	188
	189	correct = 0
	190	failure = 0
	191	# enaModules = self.checkAntenna()
	192	enaModules = [11,12,13,14]
	193
	194	for id in range(1,65):
	195	if id not in enaModules:
	196	continue
	197
	198	self.commClientObj.open_socket()
	199	ip = "192.168.1." + str(id)
	200	self.commClientObj.sendData2(cmd, self.rx_buffer, ip)
	201	# ipSource, ipDestino, cmd, tmp = self.commClientObj.waitData()
	202	ipSource, ipDestino, cmd, tmp = self.commClientObj.waitClient()
	203	self.commClientObj.close_socket()
	204
	205	if tmp == "OK":
	206	correct = correct + 1
	207	else:
	208	failure = failure + 1
	209
	210	if correct == len(enaModules):
	211	rpta = "OK"
	212	else:
	213	rpta = "Failure"
	214
	215	return rpta
	216
	217	def getStatus(self, mode, cmd):
	218
	219	if mode == 1:
	220	self.__getStsMode1()
	221	elif mode == 2:
	222	self.__getStsMode2()
	223	elif mode == 3:
	224	self.__getStsMode3()
	225	else:
	226	self.__getStsMode4(cmd)
	227
	228
	229	def __getStsMode1(self):
	230	#rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
	231	self.commClientObj.sendData("CHEQUEO:" + self.rx_buffer + ":")
	232	seconds = int (self.rx_buffer)
	233	# Give 5 seconds to the control modules
	234	time.sleep(seconds)
	235	# Checking the module connection
	236	module_list = self.connection_status(10)
	237	#Generating the complete report
	238	module = 1
	239	number_of_modules = 16
	240	filename1 = "Verificacion"
	241	filename2 = "report.txt"
	242	fobj2 = open(filename2,"w")
	243	fobj2.write("Verification_file\n")
	244	fobj2.write("-----------------\n")
	245	fobj2.close()
	246	while module <= number_of_modules:
	247	if module_list[module -1] == "1":
	248	#Preparing and doing the tftp command
	249	cmd = "tftp -m binary 192.168.1."+ str(base + module) +" 69 -c get " + filename1
	250	print cmd
	251	os.system(cmd)
	252	# Getting data from the control module file
	253	fobj1 = open(filename1,"r")
	254	file_list_1 = fobj1.readlines()
	255	fobj1.close()
	256	content = file_list_1[2:-1]
	257	#
	258	fobj2 = open(filename2,"a")
	259	if base == 10:
	260	fobj2.write("S" + str(module) + "\n")
	261	else:
	262	fobj2.write("N" + str(module) + "\n")
	263	fobj2.writelines(content)
	264	fobj2.write("------\n")
	265	fobj2.close()
	266	module = module + 1
	267
	268	def __getStsMode2(self):
	269
	270	#rpta = self.commClientObj.sendTxRxCommand(cmd='CHEQUEO', data="0")
	271	self.commClientObj.sendData("CHEQUEO:" + self.rx_buffer + ":")
	272	seconds = int (self.rx_buffer)
	273	# Give 5 seconds to the control modules
	274	time.sleep(seconds)
	275	# Checking the module connection
	276	enaModules = self.checkAntenna()
	277	#Generating the complete report
	278	filename1 = "Verificacion"
	279	line1 = "Verification_file\n"
	280	line2 = "-----------------\n"
	281	report_list = [line1, line2]
	282
	283	for address in range(1,65):
	284
	285	if address not in enaModules:
	286	continue
	287	#Preparing and doing the tftp command
	288	cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c get " + filename1
	289	print cmd
	290	os.system(cmd)
	291	#Sub_header
	292	report_list.append("ABS_" + str(address) + "\n")
	293	# Content
	294	fobj1 = open(filename1,"r")
	295	file_list_1 = fobj1.readlines()
	296	fobj1.close()
	297	content = ''.join(file_list_1[2:-1])
	298	report_list.append(content)
	299	#Ending
	300	report_list.append("------\n")
	301	#print "\nFinalizado"
	302	self.tx_buffer = ''.join(report_list)
	303
	304	def __AddingHeader(self,content_list, title):
	305
	306	line1 = title + "\n"
	307	line2 = "-----------------\n"
	308	header_list = [line1, line2]
	309	verification_list = header_list + content_list
	310	# Arming the frame
	311	self.tx_buffer = ''.join(verification_list)
	312
	313	def __getModuleFile(self, filename):
	314
	315	enaModules = self.checkAntenna()
	316	content_list = []
	317	for address in range(1,65):
	318
	319	if address not in enaModules:
	320	continue
	321	#Preparing and doing the tftp command
	322	cmd = "tftp -m binary 192.168.1."+ str(address) +" 69 -c get " + filename
	323	print cmd
	324	os.system(cmd)
	325	#Sub_header
	326	content_list.append("ABS_" + str(address) + "\n")
	327	# From module file to list
	328	content_str = self.__readModuleFile(filename)
	329	content_list.append(content_str)
	330	content_list.append("------\n")
	331
	332	self.__AddingHeader(content_list, title = "Verification_file")
	333
	334	def __getStsMode3(self):
	335
	336	self.commClientObj.sendData("none", "CHEQUEO:" + self.rx_buffer + ":")
	337	seconds = int (self.rx_buffer)
	338	# Give 5 seconds to the control modules
	339	time.sleep(seconds)
	340
	341	self.__getModuleFile(filename = "Verificacion")
	342
	343	def __getStsMode4(self, cmd):
	344
	345	content_str = ""
	346	# enaModules = self.checkAntenna()
	347	enaModules = [11,12,13,14]
	348
	349	for id in range(1,65):
	350	if id not in enaModules:
	351	continue
	352
	353	self.commClientObj.open_socket()
	354	ip = "192.168.1." + str(id)
	355	self.commClientObj.sendData2(cmd, self.rx_buffer, ip)
	356	ipSource, ipDestino, cmd, tmp = self.commClientObj.waitClient()
	357	self.commClientObj.close_socket()
	358
	359	content_str = content_str + tmp
	360	# self.__AddingHeader(content_list, title = "Verification_file")
	361	#Using tx buffer
	362	self.tx_buffer = content_str
	363
	364	if __name__ == '__main__':
	365
	366	absObj = ABSServer()
	367
	368	while 1:
	369	absObj.waitRequest() No newline at end of file

trunk/absroot/source/abspy/bin/server3.py created 10644 +399 0

@@ -0,0 +1,399
	1	import os
	2	import library3
	3	import time
	4	import threading
	5
	6	class ABSServer:
	7
	8	def __init__(self,ipSource="localhost", ipDestino="192.168.1.117", portDestino=7000, ipDestino2="192.168.1.11", portDestino2=5500, rx_buffer = "default"):
	9
	10	self.ipSource = ipSource
	11	self.ipDestino = ipDestino
	12	self.portDestino = portDestino
	13
	14	self.ipDestino2 = ipDestino2
	15	self.portDestino2 = portDestino2
	16
	17	self.tx_buffer = "default"
	18	# self.rx_buffer = "default"
	19	self.rx_buffer = rx_buffer
	20	self.enaModules = []
	21	self.bits = []
	22	self.phase = []
	23	self.txFile = []
	24	self.rxFile = []
	25
	26	self.createObjects()
	27
	28	print "Checking control modules, please wait ..."
	29	self.enaModules = self.checkAntenna()
	30	print "Starting automatic control module status."
	31	self.__StartingAutomaticControlModules()
	32	self.__AutomaticControlModules()
	33
	34	def createObjects(self):
	35
	36	asServer = True
	37	self.commServerObj = library3.TCPComm("Central_Control", "CeCnMod", self.ipDestino, "CnMod01", self.portDestino, asServer)
	38	self.commClientObj = library3.TCPComm("Central_Control", "CeCnMod", self.ipDestino2, "CnMod01", self.portDestino2)
	39	self.wFiles = library3.FilesStuff()
	40
	41	def waitRequest(self):
	42
	43	#Using rx buffer
	44	# ipSource, ipDestino, cmd, self.rx_buffer = self.commServerObj.waitData()
	45	ipSource, ipDestino, cmd, rx_buffer = self.commServerObj.waitData()
	46
	47	if cmd == "SNDF":
	48	datarpta = self.__sendFile2Modules(cmd = cmd, rx_buffer = rx_buffer)
	49
	50	if cmd == "GETF":
	51	datarpta = self.__getFileFromModules(cmd = cmd, rx_buffer = rx_buffer)
	52
	53	if cmd == "CHGB":
	54	datarpta = self.__changeBeam(cmd = cmd, rx_buffer = rx_buffer)
	55
	56	if cmd == "ANST":
	57	datarpta = self.__getControlModuleStatus(cmd = cmd, rx_buffer = rx_buffer)
	58
	59	if cmd == "BGPH":
	60	datarpta = self.__getControlModuleBigPhase(cmd = cmd, rx_buffer = rx_buffer)
	61
	62	if cmd == "LWPH":
	63	datarpta = self.__getControlModuleLowPhase(cmd = cmd, rx_buffer = rx_buffer)
	64
	65	if cmd == "NTST":
	66	datarpta = self.__getConnectionStatus(cmd = cmd, rx_buffer = rx_buffer)
	67
	68	self.commServerObj.sendData(cmd=cmd, data=datarpta, ipDestino = ipSource)
	69
	70	def checkModule(self, address):
	71
	72	cmd = "ping -c 1 -w 1 192.168.1."+ str(address) + " >> /dev/null"
	73	status = os.system(cmd)
	74
	75	if status == 256:
	76	return False
	77
	78	return True
	79
	80	def __writeReport(self, enaModules):
	81
	82	status_array = ["Status of modules\n"]
	83	status_array.append("----------------\n")
	84
	85	for address in range(1,65):
	86	if address in enaModules:
	87	status_array.append("192.168.1." + str(address) + " [1 1]\n")
	88	else:
	89	status_array.append("192.168.1." + str(address) + " [0 0]\n")
	90
	91	filename = "module_status.txt"
	92	self.__writeFile(filename,status_array)
	93	# f = open("module_status.txt","w")
	94	# f.writelines(status_array)
	95	# f.close()
	96
	97
	98	def __CreateFile(self, filename):
	99
	100	fobj = open(filename,"w")
	101	fobj.close()
	102
	103	def __writeNewFile(self, filename, data):
	104
	105	fobj = open(filename,"w")
	106	fobj.writelines(data)
	107	fobj.close()
	108
	109	def __writeFile(self, filename, data):
	110
	111	fobj = open(filename,"a")
	112	fobj.writelines(data)
	113	fobj.close()
	114
	115	def checkAntenna(self):
	116
	117	"""
	118	Direccion de los modulos de las antenas:
	119
	120	Norte : 01-16
	121	Este : 17-32
	122	Oeste: : 33-48
	123	Sur : 49-64
	124
	125	"""
	126
	127	enaModules2 = []
	128
	129	for address in range(1,65):
	130	if self.checkModule(address):
	131	enaModules2.append(address)
	132
	133	self.__writeReport(enaModules2)
	134	return enaModules2
	135
	136	def __ConnectionWithControlModules(self,data,cmd,id):
	137
	138	self.commClientObj.open_socket()
	139	ip = "192.168.1." + str(id)
	140	self.commClientObj.sendData(cmd, data, ip)
	141	ipSource, ipDestino, cmd, tmp = self.commClientObj.waitData()
	142	self.commClientObj.close_socket()
	143
	144	return tmp
	145
	146	def abs2ControlModuleFormatFile(self, filename):
	147
	148	#From matriz to control module format
	149	self.wFiles.toCentralControlFormat(filename)
	150	FileName = "CentralControlFormat.txt"
	151	F_Obj = open(FileName,"r")
	152	FileList = F_Obj.readlines()
	153	F_Obj.close()
	154	FileStr = "".join(FileList)
	155
	156	return FileStr
	157
	158	def __All2Blocks(self,input):
	159
	160	rx_frame_lst = input.split('\n',2)
	161
	162	header = rx_frame_lst[0] + "\n"
	163	control_modules_str = rx_frame_lst[2]
	164	control_modules_lst = control_modules_str.split("------\n")
	165
	166	return header, control_modules_lst
	167
	168
	169	def __sendFile2Modules(self,cmd, rx_buffer):
	170
	171	# rx_buffer_lst = self.rx_buffer.split('\n',1)
	172	rx_buffer_lst = rx_buffer.split('\n',1)
	173	#Getting the filename from the begining of data
	174	filename = rx_buffer_lst[0]
	175	tmp = rx_buffer_lst[1]
	176	self.__writeFile(filename,tmp)
	177	data = self.abs2ControlModuleFormatFile(filename)
	178	#Needed for the loop
	179	header, control_modules_lst = self.__All2Blocks(data)
	180	correct = 0
	181
	182	for id in range(1,65):
	183
	184	if id not in self.enaModules:
	185	continue
	186
	187	if self.__ConnectionWithControlModules(header + control_modules_lst[id-1], cmd, id) == "OK":
	188	correct = correct + 1
	189
	190	if correct == len(self.enaModules):
	191	rpta = "OK"
	192	else:
	193	rpta = "Failure"
	194
	195	return rpta
	196
	197	def __getFileFromModules(self, cmd, rx_buffer):
	198
	199	for id in range(1,65):
	200	if id not in self.enaModules:
	201	continue
	202
	203	file = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
	204	del self.rxFile[id-1]
	205	self.rxFile.insert(id-1, file)
	206
	207	def __changeBeam(self, cmd, rx_buffer):
	208
	209	correct = 0
	210	# enaModules = self.checkAntenna()
	211	# enaModules = [11,12,13,14]
	212
	213	for id in range(1,65):
	214	if id not in self.enaModules:
	215	continue
	216
	217	if self.__ConnectionWithControlModules(rx_buffer,cmd,id) == "OK":
	218	correct = correct + 1
	219
	220	if correct == len(self.enaModules):
	221	rpta = "OK"
	222	else:
	223	rpta = "Failure"
	224
	225	return rpta
	226
	227	def __getControlModuleStatus(self, cmd, rx_buffer):
	228
	229	# all_blocks = ""
	230	# all_blocks = []
	231	# enaModules = self.checkAntenna()
	232	# enaModules = [11,12,13,14]
	233
	234	for id in range(1,65):
	235	if id not in self.enaModules:
	236	continue
	237
	238	bits = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
	239	del self.bits[id-1]
	240	self.bits.insert(id-1, bits)
	241
	242	# all_blocks.append(one_block)
	243	#Using tx buffer
	244
	245	# return all_blocks
	246
	247	def __getControlModuleBigPhase(self, cmd, rx_buffer):
	248
	249	# all_blocks = ""
	250	all_blocks = []
	251	# enaModules = self.checkAntenna()
	252	# enaModules = [11,12,13,14]
	253
	254	for id in range(1,65):
	255	if id not in self.enaModules:
	256	continue
	257
	258	one_block = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
	259
	260	# all_blocks = all_blocks + one_block
	261	all_blocks.append(one_block)
	262	#Using tx buffer
	263	return all_blocks
	264
	265	def __getControlModuleLowPhase(self, cmd, rx_buffer):
	266
	267	# all_blocks = ""
	268	# all_blocks = []
	269	# enaModules = self.checkAntenna()
	270	# enaModules = [11,12,13,14]
	271
	272	for id in range(1,65):
	273	if id not in self.enaModules:
	274	continue
	275
	276	phase = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
	277	del self.phase[id-1]
	278	self.phase.insert(id-1, phase)
	279	# all_blocks = all_blocks + one_block
	280	# all_blocks.append(one_block)
	281	#Using tx buffer
	282	# return all_blocks
	283
	284	def __getConnectionStatus(self, cmd, rx_buffer):
	285
	286	ena = self.checkAntenna()
	287	print ena
	288	self.enaModules = ena
	289
	290	blockLst = []
	291
	292	for id in range(1,65):
	293	if id not in self.enaModules:
	294	continue
	295
	296	blockStr = self.__ConnectionWithControlModules(rx_buffer,cmd,id)
	297	blockLst.append(blockStr + ", 192.168.1." + str(id) + "\n")
	298	#Using tx buffer
	299	all_blocks = "".join(blockLst)
	300
	301	return all_blocks
	302
	303	def getConnectionStatus(self, cmd):
	304
	305	ena = self.checkAntenna()
	306	self.enaModules = ena
	307
	308	blockLst = []
	309
	310	for id in range(1,65):
	311	if id not in self.enaModules:
	312	continue
	313
	314	blockStr = self.__ConnectionWithControlModules(self.rx_buffer,cmd,id)
	315	blockLst.append(blockStr + ", 192.168.1." + str(id) + "\n")
	316	#Using tx buffer
	317	self.tx_buffer = "".join(blockLst)
	318	print self.tx_buffer
	319
	320	return self.tx_buffer
	321
	322	def getControlModuleStatus(self, cmd):
	323
	324	all_blocks = ""
	325	# enaModules = self.checkAntenna()
	326	# enaModules = [11,12,13,14]
	327
	328	for id in range(1,65):
	329	if id not in self.enaModules:
	330	continue
	331
	332	one_block = self.__ConnectionWithControlModules(self.rx_buffer,cmd,id)
	333
	334	all_blocks = all_blocks + one_block
	335	#Using tx buffer
	336	print all_blocks
	337	self.tx_buffer = all_blocks
	338
	339	return all_blocks
	340
	341	def __StartingAutomaticControlModules(self):
	342
	343	#Starting file
	344	self.__CreateFile("Monitoring.txt")
	345	# data = "MOD.\t BITS\t\t PHASE\n"
	346	# self.__writeFile("Monitoring.txt", data)
	347	#Starting lists
	348	self.txFile = list("------\n------\n------\n" for i in range(64))
	349	self.rxFile = list("------\n------\n------\n" for i in range(64))
	350	self.bits = list("------\n------\n------\n" for i in range(64))
	351	self.phase = list("----- -----\n----- -----\n----- -----\n" for i in range(64))
	352
	353	def __AutomaticControlModules(self):
	354
	355	cmd = "GETF"
	356	rx_buffer = "experimento1.ab1" + "\n"
	357	self.__getFileFromModules(cmd = cmd, rx_buffer = rx_buffer)
	358
	359	print self.rxFile
	360
	361	cmd = "ANST"
	362	rx_buffer = "1"
	363	self.__getControlModuleStatus(cmd = cmd, rx_buffer = rx_buffer)
	364
	365	cmd = "LWPH"
	366	rx_buffer = "0"
	367	self.__getControlModuleLowPhase(cmd = cmd, rx_buffer = rx_buffer)
	368	print "Saving file..."
	369
	370
	371	print self.bits
	372	print self.phase
	373
	374	self.__WritingMonitoringFile()
	375
	376	threading.Timer(60, self.__AutomaticControlModules).start()
	377
	378	def __WritingMonitoringFile(self):
	379	filename = "Monitoring.txt"
	380	data = '===============================' + '\n'
	381	self.__writeFile(filename, data)
	382	data = time.strftime('\t' + "%d%b%Y %I:%M:%S %p" + '\n', time.localtime())
	383	self.__writeFile(filename, data)
	384	data = "MOD.\t BITS\t\t PHASE\n"
	385	self.__writeFile(filename, data)
	386	data = '===============================' + '\n'
	387	self.__writeFile(filename, data)
	388	for i in range(64):
	389	tmp = self.bits[i].split('\n',3)
	390	self.__writeFile(filename, ' ' + str(i + 1) + '\t\t' + tmp[2])
	391	tmp = self.phase[i].split('\n',3)
	392	self.__writeFile(filename, '\t\t' + tmp[2] + '\n')
	393
	394	if __name__ == '__main__':
	395
	396	absObj = ABSServer()
	397
	398	while 1:
	399	absObj.waitRequest() No newline at end of file

trunk/absroot/source/abspy/scripts/changeBeam.py +2 -3

             import optparse, os, sys
-            pathFile = os.getcwd()
+            pathFile = os.path.dirname(os.path.abspath(__file__))
             sys.path.append(os.path.split(pathFile)[0])
-            from abscontrol.client3 import ABSClient
+            from bin.client3 import ABSClient
             class changeBeam(object):
             usage = "::::::::::::\n"
             if __name__ == '__main__':

trunk/absroot/source/abspy/scripts/sendFile.py +3 -4

             import optparse, os, sys
-            pathFile = os.getcwd()
+            pathFile = os.path.dirname(os.path.abspath(__file__))
             sys.path.append(os.path.split(pathFile)[0])
-            from abscontrol.client3 import ABSClient
+            from bin.client3 import ABSClient
             class sendFile(object):
                     if os.path.exists(filename):
                         absObj = ABSClient(ipDestino="10.10.10.97")
                         absObj.sendFile(filename)
-                        pass
+                        #pass
                     else:
                         print "No file"
             usage = "::::::::::::\n"
             if __name__ == '__main__':

trunk/absroot/source/abspy/abscontrol removed 0 0

NO CONTENT: file was removed

General Comments 0

Write
Preview

You need to be logged in to leave comments. Login now

No TODOs yet

	Site-wide shortcuts
/	Use quick search box
g h	Goto home page
g g	Goto my private gists page
g G	Goto my public gists page
g 0-9	Goto bookmarked items from 0-9
n r	New repository page
n g	New gist page

	Repositories
g s	Goto summary page
g c	Goto changelog page
g f	Goto files page
g F	Goto files page with file search activated
g p	Goto pull requests page
g o	Goto repository settings
g O	Goto repository access permissions settings
t s	Toggle sidebar on some pages