| @@ -10,6 +10,9 from jroIO_base import LOCALTIME, JRODataReader, JRODataWriter | |||
|
|
10 | 10 | from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation |
|
|
11 | 11 | from schainpy.model.data.jroheaderIO import PROCFLAG, BasicHeader, SystemHeader, RadarControllerHeader, ProcessingHeader |
|
|
12 | 12 | from schainpy.model.data.jrodata import Voltage |
|
|
13 | import zmq | |
|
|
14 | import tempfile | |
|
|
15 | from StringIO import StringIO | |
|
|
13 | 16 | # from _sha import blocksize |
|
|
14 | 17 | |
|
|
15 | 18 | class VoltageReader(JRODataReader, ProcessingUnit): |
| @@ -58,7 +61,7 class VoltageReader(JRODataReader, ProcessingUnit): | |||
|
|
58 | 61 | optchar = "D" |
|
|
59 | 62 | dataOut = None |
|
|
60 | 63 | |
|
|
61 | def __init__(self): | |
|
|
64 | def __init__(self, **kwargs): | |
|
|
62 | 65 | """ |
|
|
63 | 66 | Inicializador de la clase VoltageReader para la lectura de datos de voltage. |
|
|
64 | 67 | |
| @@ -77,7 +80,7 class VoltageReader(JRODataReader, ProcessingUnit): | |||
|
|
77 | 80 | None |
|
|
78 | 81 | """ |
|
|
79 | 82 | |
|
|
80 | ProcessingUnit.__init__(self) | |
|
|
83 | ProcessingUnit.__init__(self, **kwargs) | |
|
|
81 | 84 | |
|
|
82 | 85 | self.isConfig = False |
|
|
83 | 86 | |
| @@ -189,6 +192,7 class VoltageReader(JRODataReader, ProcessingUnit): | |||
|
|
189 | 192 | self.blocksize = pts2read |
|
|
190 | 193 | |
|
|
191 | 194 | |
|
|
195 | ||
|
|
192 | 196 | def readBlock(self): |
|
|
193 | 197 | """ |
|
|
194 | 198 | readBlock lee el bloque de datos desde la posicion actual del puntero del archivo |
| @@ -438,24 +442,19 class VoltageReader(JRODataReader, ProcessingUnit): | |||
|
|
438 | 442 | self.flagDiscontinuousBlock |
|
|
439 | 443 | self.flagIsNewBlock |
|
|
440 | 444 | """ |
|
|
441 | ||
|
|
442 | 445 | if self.flagNoMoreFiles: |
|
|
443 | 446 | self.dataOut.flagNoData = True |
|
|
444 | 447 | print 'Process finished' |
|
|
445 | 448 | return 0 |
|
|
446 | ||
|
|
447 | 449 | self.flagDiscontinuousBlock = 0 |
|
|
448 | 450 | self.flagIsNewBlock = 0 |
|
|
449 | ||
|
|
450 | 451 | if self.__hasNotDataInBuffer(): |
|
|
451 | ||
|
|
452 | 452 | if not( self.readNextBlock() ): |
|
|
453 | 453 | return 0 |
|
|
454 | 454 | |
|
|
455 | 455 | self.getFirstHeader() |
|
|
456 | 456 | |
|
|
457 | 457 | self.reshapeData() |
|
|
458 | ||
|
|
459 | 458 | if self.datablock is None: |
|
|
460 | 459 | self.dataOut.flagNoData = True |
|
|
461 | 460 | return 0 |
| @@ -546,7 +545,7 class VoltageWriter(JRODataWriter, Operation): | |||
|
|
546 | 545 | shapeBuffer = None |
|
|
547 | 546 | |
|
|
548 | 547 | |
|
|
549 | def __init__(self): | |
|
|
548 | def __init__(self, **kwargs): | |
|
|
550 | 549 |
""" |
|
|
551 | 550 | Inicializador de la clase VoltageWriter para la escritura de datos de espectros. |
|
|
552 | 551 | |
| @@ -555,7 +554,7 class VoltageWriter(JRODataWriter, Operation): | |||
|
|
555 | 554 | |
|
|
556 | 555 | Return: None |
|
|
557 | 556 | """ |
|
|
558 | Operation.__init__(self) | |
|
|
557 | Operation.__init__(self, **kwargs) | |
|
|
559 | 558 | |
|
|
560 | 559 | self.nTotalBlocks = 0 |
|
|
561 | 560 | |
General Comments 0
You need to be logged in to leave comments.
Login now