##// END OF EJS Templates
schain-jc
RSS
funcionando en mi compu
José Chávez -
r900:75bc6c54930e
parent child
Show More
Show file before | Show file after | Hide comments
@@ -1,8 +1,7
1 ## ROADMAP
1 ROADMAP FOR SCHAIN BRANCHES
2 ## SCHAIN BRANCHES
2 ===============================
3
3 <Enter>
4 ### BRANCH - SCHAIN_MP
4 ### BRANCH - SCHAIN_MP
5
6 * Revisar si funciona con varios publishers.
5 * Revisar si funciona con varios publishers.
7 * Revisar xRange y reinicialización de gráfico.
6 * Revisar xRange y reinicialización de gráfico.
8 * Grabar cada spectra independientemente.
7 * Grabar cada spectra independientemente.
Show file before | Show file after | Hide comments
@@ -145,6 +145,7 class PublishData(Operation):
145 time.sleep(1)
145 time.sleep(1)
146
146
147
147
148
148 def publish_data(self):
149 def publish_data(self):
149 self.dataOut.finished = False
150 self.dataOut.finished = False
150 if self.mqtt is 1:
151 if self.mqtt is 1:
@@ -306,6 +307,7 class ReceiverData(ProcessingUnit, Process):
306 if evt['event'] == zmq.EVENT_MONITOR_STOPPED:
307 if evt['event'] == zmq.EVENT_MONITOR_STOPPED:
307 break
308 break
308 monitor.close()
309 monitor.close()
310 print("event monitor thread done!")
309
311
310 def initThrottle(self, throttle_value):
312 def initThrottle(self, throttle_value):
311
313
@@ -324,7 +326,6 class ReceiverData(ProcessingUnit, Process):
324 t = self.dataOut.ltctime
326 t = self.dataOut.ltctime
325 self.data['times'].append(t)
327 self.data['times'].append(t)
326 self.data['dataOut'] = self.dataOut
328 self.data['dataOut'] = self.dataOut
327
328 for plottype in self.plottypes:
329 for plottype in self.plottypes:
329
330
330 if plottype == 'spc':
331 if plottype == 'spc':
Show file before | Show file after | Hide comments
@@ -31,9 +31,8 def fiber(cursor, skip, q, dt):
31 procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
31 procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId())
32 # opObj11 = procUnitConfObj2.addParameter(name='pairsList', value='(0,1)', format='pairslist')
32 # opObj11 = procUnitConfObj2.addParameter(name='pairsList', value='(0,1)', format='pairslist')
33 #
33 #
34 procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId())
34 # procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId())
35
35 # opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other')
36 opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other')
37
36
38 #
37 #
39 # opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other')
38 # opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other')
@@ -62,9 +61,9 def fiber(cursor, skip, q, dt):
62 opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other')
61 opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other')
63 opObj12.addParameter(name='zeromq', value=1, format='int')
62 opObj12.addParameter(name='zeromq', value=1, format='int')
64
63
65 opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
64 # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other')
66 opObj13.addParameter(name='zeromq', value=1, format='int')
65 # opObj13.addParameter(name='zeromq', value=1, format='int')
67 opObj13.addParameter(name='server', value="juanca", format='str')
66 # opObj13.addParameter(name='server', value="juanca", format='str')
68
67
69 # opObj12.addParameter(name='delay', value=1, format='int')
68 # opObj12.addParameter(name='delay', value=1, format='int')
70
69
@@ -82,6 +81,6 def fiber(cursor, skip, q, dt):
82
81
83 if __name__ == '__main__':
82 if __name__ == '__main__':
84 parser = argparse.ArgumentParser(description='Set number of parallel processes')
83 parser = argparse.ArgumentParser(description='Set number of parallel processes')
85 parser.add_argument('--nProcess', default=16, type=int)
84 parser.add_argument('--nProcess', default=2, type=int)
86 args = parser.parse_args()
85 args = parser.parse_args()
87 multiSchain(fiber, nProcess=args.nProcess, startDate='2015/09/26', endDate='2015/09/26')
86 multiSchain(fiber, nProcess=args.nProcess, startDate='2015/09/26', endDate='2015/09/26')
Show file before | Show file after | Hide comments
@@ -22,27 +22,26 if __name__ == '__main__':
22 op1 = proc1.addOperation(name='PlotRTIData', optype='other')
22 op1 = proc1.addOperation(name='PlotRTIData', optype='other')
23 op1.addParameter(name='wintitle', value='Julia 150Km', format='str')
23 op1.addParameter(name='wintitle', value='Julia 150Km', format='str')
24 op1.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
24 op1.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
25 op1.addParameter(name='colormap', value='jet', format='str')
26
25
27 op2 = proc1.addOperation(name='PlotCOHData', optype='other')
26 op2 = proc1.addOperation(name='PlotCOHData', optype='other')
28 op2.addParameter(name='wintitle', value='Julia 150Km', format='str')
27 op2.addParameter(name='wintitle', value='Julia 150Km', format='str')
29 op2.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
28 op2.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
30
29 #
31 op6 = proc1.addOperation(name='PlotPHASEData', optype='other')
30 op6 = proc1.addOperation(name='PlotPHASEData', optype='other')
32 op6.addParameter(name='wintitle', value='Julia 150Km', format='str')
31 op6.addParameter(name='wintitle', value='Julia 150Km', format='str')
33 op6.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
32 op6.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
34
33 #
35 proc2 = controllerObj.addProcUnit(name='ReceiverData')
34 # proc2 = controllerObj.addProcUnit(name='ReceiverData')
36 proc2.addParameter(name='server', value='juanca', format='str')
35 # proc2.addParameter(name='server', value='juanca', format='str')
37 proc2.addParameter(name='plottypes', value='snr,dop', format='str')
36 # proc2.addParameter(name='plottypes', value='snr,dop', format='str')
38
37 #
39 op3 = proc2.addOperation(name='PlotSNRData', optype='other')
38 # op3 = proc2.addOperation(name='PlotSNRData', optype='other')
40 op3.addParameter(name='wintitle', value='Julia 150Km', format='str')
39 # op3.addParameter(name='wintitle', value='Julia 150Km', format='str')
41 op3.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
40 # op3.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
42
41 #
43 op4 = proc2.addOperation(name='PlotDOPData', optype='other')
42 # op4 = proc2.addOperation(name='PlotDOPData', optype='other')
44 op4.addParameter(name='wintitle', value='Julia 150Km', format='str')
43 # op4.addParameter(name='wintitle', value='Julia 150Km', format='str')
45 op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
44 # op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str')
46
45
47
46
48
47
Show file before | Show file after | Hide comments
@@ -1,1 +1,1
1 <Project description="HF_EXAMPLE" id="191" name="test01"><ReadUnit datatype="SpectraReader" id="1911" inputId="0" name="SpectraReader"><Operation id="19111" name="run" priority="1" type="self"><Parameter format="str" id="191111" name="datatype" value="SpectraReader" /><Parameter format="str" id="191112" name="path" value="/home/nanosat/data/hysell_data20/pdata" /><Parameter format="date" id="191113" name="startDate" value="2015/09/26" /><Parameter format="date" id="191114" name="endDate" value="2015/09/26" /><Parameter format="time" id="191115" name="startTime" value="00:00:00" /><Parameter format="time" id="191116" name="endTime" value="23:59:59" /><Parameter format="int" id="191118" name="cursor" value="17" /><Parameter format="int" id="191119" name="skip" value="45" /><Parameter format="int" id="191120" name="delay" value="10" /><Parameter format="int" id="191121" name="walk" value="1" /><Parameter format="int" id="191122" name="online" value="0" /></Operation></ReadUnit><ProcUnit datatype="ParametersProc" id="1913" inputId="1911" name="ParametersProc"><Operation id="19131" name="run" priority="1" type="self" /><Operation id="19132" name="SpectralMoments" priority="2" type="other" /><Operation id="19133" name="PublishData" priority="3" type="other"><Parameter format="int" id="191331" name="zeromq" value="1" /><Parameter format="str" id="191332" name="server" value="juanca" /></Operation></ProcUnit><ProcUnit datatype="Spectra" id="1912" inputId="1911" name="SpectraProc"><Operation id="19121" name="run" priority="1" type="self" /><Operation id="19122" name="PublishData" priority="2" type="other"><Parameter format="int" id="191221" name="zeromq" value="1" /></Operation></ProcUnit></Project> No newline at end of file
1 <Project description="HF_EXAMPLE" id="191" name="test01"><ReadUnit datatype="SpectraReader" id="1911" inputId="0" name="SpectraReader"><Operation id="19111" name="run" priority="1" type="self"><Parameter format="str" id="191111" name="datatype" value="SpectraReader" /><Parameter format="str" id="191112" name="path" value="/home/nanosat/data/hysell_data20/pdata" /><Parameter format="date" id="191113" name="startDate" value="2015/09/26" /><Parameter format="date" id="191114" name="endDate" value="2015/09/26" /><Parameter format="time" id="191115" name="startTime" value="00:00:00" /><Parameter format="time" id="191116" name="endTime" value="23:59:59" /><Parameter format="int" id="191118" name="cursor" value="3" /><Parameter format="int" id="191119" name="skip" value="360" /><Parameter format="int" id="191120" name="delay" value="10" /><Parameter format="int" id="191121" name="walk" value="1" /><Parameter format="int" id="191122" name="online" value="0" /></Operation></ReadUnit><ProcUnit datatype="Spectra" id="1912" inputId="1911" name="SpectraProc"><Operation id="19121" name="run" priority="1" type="self" /><Operation id="19122" name="PublishData" priority="2" type="other"><Parameter format="int" id="191221" name="zeromq" value="1" /></Operation></ProcUnit></Project> No newline at end of file
Show file before | Show file after | Hide comments
1 NO CONTENT: file was removed
NO CONTENT: file was removed
General Comments 0
You need to be logged in to leave comments. Login now