| @@ -1,8 +1,7 | |||
|
|
1 | ## ROADMAP | |
|
|
2 | ## SCHAIN BRANCHES | |
|
|
3 | ||
|
|
1 | ROADMAP FOR SCHAIN BRANCHES | |
|
|
2 | =============================== | |
|
|
3 | <Enter> | |
|
|
4 | 4 | ### BRANCH - SCHAIN_MP |
|
|
5 | ||
|
|
6 | 5 | * Revisar si funciona con varios publishers. |
|
|
7 | 6 | * Revisar xRange y reinicialización de gráfico. |
|
|
8 | 7 | * Grabar cada spectra independientemente. |
| @@ -145,6 +145,7 class PublishData(Operation): | |||
|
|
145 | 145 | time.sleep(1) |
|
|
146 | 146 | |
|
|
147 | 147 | |
|
|
148 | ||
|
|
148 | 149 | def publish_data(self): |
|
|
149 | 150 | self.dataOut.finished = False |
|
|
150 | 151 | if self.mqtt is 1: |
| @@ -306,6 +307,7 class ReceiverData(ProcessingUnit, Process): | |||
|
|
306 | 307 | if evt['event'] == zmq.EVENT_MONITOR_STOPPED: |
|
|
307 | 308 | break |
|
|
308 | 309 | monitor.close() |
|
|
310 | print("event monitor thread done!") | |
|
|
309 | 311 | |
|
|
310 | 312 | def initThrottle(self, throttle_value): |
|
|
311 | 313 | |
| @@ -324,7 +326,6 class ReceiverData(ProcessingUnit, Process): | |||
|
|
324 | 326 | t = self.dataOut.ltctime |
|
|
325 | 327 | self.data['times'].append(t) |
|
|
326 | 328 | self.data['dataOut'] = self.dataOut |
|
|
327 | ||
|
|
328 | 329 | for plottype in self.plottypes: |
|
|
329 | 330 | |
|
|
330 | 331 | if plottype == 'spc': |
| @@ -31,9 +31,8 def fiber(cursor, skip, q, dt): | |||
|
|
31 | 31 | procUnitConfObj2 = controllerObj.addProcUnit(datatype='Spectra', inputId=readUnitConfObj.getId()) |
|
|
32 | 32 | # opObj11 = procUnitConfObj2.addParameter(name='pairsList', value='(0,1)', format='pairslist') |
|
|
33 | 33 | # |
|
|
34 | procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId()) | |
|
|
35 | ||
|
|
36 | opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other') | |
|
|
34 | # procUnitConfObj3 = controllerObj.addProcUnit(datatype='ParametersProc', inputId=readUnitConfObj.getId()) | |
|
|
35 | # opObj11 = procUnitConfObj3.addOperation(name='SpectralMoments', optype='other') | |
|
|
37 | 36 | |
|
|
38 | 37 | # |
|
|
39 | 38 | # opObj11 = procUnitConfObj1.addOperation(name='SpectraPlot', optype='other') |
| @@ -62,9 +61,9 def fiber(cursor, skip, q, dt): | |||
|
|
62 | 61 | opObj12 = procUnitConfObj2.addOperation(name='PublishData', optype='other') |
|
|
63 | 62 | opObj12.addParameter(name='zeromq', value=1, format='int') |
|
|
64 | 63 | |
|
|
65 | opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other') | |
|
|
66 | opObj13.addParameter(name='zeromq', value=1, format='int') | |
|
|
67 | opObj13.addParameter(name='server', value="juanca", format='str') | |
|
|
64 | # opObj13 = procUnitConfObj3.addOperation(name='PublishData', optype='other') | |
|
|
65 | # opObj13.addParameter(name='zeromq', value=1, format='int') | |
|
|
66 | # opObj13.addParameter(name='server', value="juanca", format='str') | |
|
|
68 | 67 | |
|
|
69 | 68 | # opObj12.addParameter(name='delay', value=1, format='int') |
|
|
70 | 69 | |
| @@ -82,6 +81,6 def fiber(cursor, skip, q, dt): | |||
|
|
82 | 81 | |
|
|
83 | 82 | if __name__ == '__main__': |
|
|
84 | 83 | parser = argparse.ArgumentParser(description='Set number of parallel processes') |
|
|
85 |
parser.add_argument('--nProcess', default= |
|
|
|
84 | parser.add_argument('--nProcess', default=2, type=int) | |
|
|
86 | 85 | args = parser.parse_args() |
|
|
87 | 86 | multiSchain(fiber, nProcess=args.nProcess, startDate='2015/09/26', endDate='2015/09/26') |
| @@ -22,27 +22,26 if __name__ == '__main__': | |||
|
|
22 | 22 | op1 = proc1.addOperation(name='PlotRTIData', optype='other') |
|
|
23 | 23 | op1.addParameter(name='wintitle', value='Julia 150Km', format='str') |
|
|
24 | 24 | op1.addParameter(name='save', value='/home/nanosat/Pictures', format='str') |
|
|
25 | op1.addParameter(name='colormap', value='jet', format='str') | |
|
|
26 | 25 | |
|
|
27 | 26 | op2 = proc1.addOperation(name='PlotCOHData', optype='other') |
|
|
28 | 27 | op2.addParameter(name='wintitle', value='Julia 150Km', format='str') |
|
|
29 | 28 | op2.addParameter(name='save', value='/home/nanosat/Pictures', format='str') |
|
|
30 | ||
|
|
29 | # | |
|
|
31 | 30 | op6 = proc1.addOperation(name='PlotPHASEData', optype='other') |
|
|
32 | 31 | op6.addParameter(name='wintitle', value='Julia 150Km', format='str') |
|
|
33 | 32 | op6.addParameter(name='save', value='/home/nanosat/Pictures', format='str') |
|
|
34 | ||
|
|
35 | proc2 = controllerObj.addProcUnit(name='ReceiverData') | |
|
|
36 | proc2.addParameter(name='server', value='juanca', format='str') | |
|
|
37 | proc2.addParameter(name='plottypes', value='snr,dop', format='str') | |
|
|
38 | ||
|
|
39 | op3 = proc2.addOperation(name='PlotSNRData', optype='other') | |
|
|
40 | op3.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
41 | op3.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
42 | ||
|
|
43 | op4 = proc2.addOperation(name='PlotDOPData', optype='other') | |
|
|
44 | op4.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
45 | op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
33 | # | |
|
|
34 | # proc2 = controllerObj.addProcUnit(name='ReceiverData') | |
|
|
35 | # proc2.addParameter(name='server', value='juanca', format='str') | |
|
|
36 | # proc2.addParameter(name='plottypes', value='snr,dop', format='str') | |
|
|
37 | # | |
|
|
38 | # op3 = proc2.addOperation(name='PlotSNRData', optype='other') | |
|
|
39 | # op3.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
40 | # op3.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
41 | # | |
|
|
42 | # op4 = proc2.addOperation(name='PlotDOPData', optype='other') | |
|
|
43 | # op4.addParameter(name='wintitle', value='Julia 150Km', format='str') | |
|
|
44 | # op4.addParameter(name='save', value='/home/nanosat/Pictures', format='str') | |
|
|
46 | 45 | |
|
|
47 | 46 | |
|
|
48 | 47 | |
| @@ -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=" |
|
|
|
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 | |
|
|
1 | NO CONTENT: file was removed |
General Comments 0
You need to be logged in to leave comments.
Login now