schain-jc Commit - r1061:62f12797e147

10

from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation

10

from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation

11

from schainpy.model.data.jroheaderIO import PROCFLAG, BasicHeader, SystemHeader, RadarControllerHeader, ProcessingHeader

11

from schainpy.model.data.jroheaderIO import PROCFLAG, BasicHeader, SystemHeader, RadarControllerHeader, ProcessingHeader

12

from schainpy.model.data.jrodata import Voltage

12

from schainpy.model.data.jrodata import Voltage

13

import zmq

14

import tempfile

15

from StringIO import StringIO

13

# from _sha import blocksize

16

# from _sha import blocksize

14

17

15

class VoltageReader(JRODataReader, ProcessingUnit):

18

class VoltageReader(JRODataReader, ProcessingUnit):

58

optchar = "D"

61

optchar = "D"

59

dataOut = None

62

dataOut = None

60

63

61

def __init__(self):

64

def __init__(self, **kwargs):

62

"""

65

"""

63

Inicializador de la clase VoltageReader para la lectura de datos de voltage.

66

Inicializador de la clase VoltageReader para la lectura de datos de voltage.

64

67

77

None

80

None

78

"""

81

"""

79

82

80

ProcessingUnit.__init__(self)

83

ProcessingUnit.__init__(self, **kwargs)

81

84

82

self.isConfig = False

85

self.isConfig = False

83

86

189

self.blocksize = pts2read

192

self.blocksize = pts2read

190

193

191

194

195

192

def readBlock(self):

196

def readBlock(self):

193

"""

197

"""

194

readBlock lee el bloque de datos desde la posicion actual del puntero del archivo

198

readBlock lee el bloque de datos desde la posicion actual del puntero del archivo

438

self.flagDiscontinuousBlock

442

self.flagDiscontinuousBlock

439

self.flagIsNewBlock

443

self.flagIsNewBlock

440

"""

444

"""

441

442

if self.flagNoMoreFiles:

445

if self.flagNoMoreFiles:

443

self.dataOut.flagNoData = True

446

self.dataOut.flagNoData = True

444

print 'Process finished'

447

print 'Process finished'

445

return 0

448

return 0

446

447

self.flagDiscontinuousBlock = 0

449

self.flagDiscontinuousBlock = 0

448

self.flagIsNewBlock = 0

450

self.flagIsNewBlock = 0

449

450

if self.__hasNotDataInBuffer():

451

if self.__hasNotDataInBuffer():

451

452

if not( self.readNextBlock() ):

452

if not( self.readNextBlock() ):

453

return 0

453

return 0

454

455

self.getFirstHeader()

455

self.getFirstHeader()

456

457

self.reshapeData()

457

self.reshapeData()

458

459

if self.datablock is None:

458

if self.datablock is None:

460

self.dataOut.flagNoData = True

459

self.dataOut.flagNoData = True

461

return 0

460

return 0

546

shapeBuffer = None

545

shapeBuffer = None

547

546

548

547

549

def __init__(self):

548

def __init__(self, **kwargs):

550

"""

549

"""

551

Inicializador de la clase VoltageWriter para la escritura de datos de espectros.

550

Inicializador de la clase VoltageWriter para la escritura de datos de espectros.

552

551

555

554

556

Return: None

555

Return: None

557

"""

556

"""

558

Operation.__init__(self)

557

Operation.__init__(self, **kwargs)

559

558

560

self.nTotalBlocks = 0

559

self.nTotalBlocks = 0

561

560

	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

             from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation
             from schainpy.model.data.jroheaderIO import PROCFLAG, BasicHeader, SystemHeader, RadarControllerHeader, ProcessingHeader
             from schainpy.model.data.jrodata import Voltage
+            import zmq
+            import tempfile
+            from StringIO import StringIO
             # from _sha import blocksize
             class VoltageReader(JRODataReader, ProcessingUnit):
                 optchar = "D"
                 dataOut = None
-                def __init__(self):
+                def __init__(self, **kwargs):
                     """
                     Inicializador de la clase VoltageReader para la lectura de datos de voltage.
                         None
                     """
-                    ProcessingUnit.__init__(self)
+                    ProcessingUnit.__init__(self, **kwargs)
                     self.isConfig = False
                     self.blocksize = pts2read
                 def readBlock(self):
                     """
                         readBlock lee el bloque de datos desde la posicion actual del puntero del archivo
                             self.flagDiscontinuousBlock
                             self.flagIsNewBlock
                     """
                     if self.flagNoMoreFiles:
                         self.dataOut.flagNoData = True
                         print 'Process finished'
                         return 0
                     self.flagDiscontinuousBlock = 0
                     self.flagIsNewBlock = 0
                     if self.__hasNotDataInBuffer():
                         if not( self.readNextBlock() ):
                             return 0
                         self.getFirstHeader()
                         self.reshapeData()
                     if self.datablock is None:
                         self.dataOut.flagNoData = True
                         return 0
                 shapeBuffer = None
-                def __init__(self):
+                def __init__(self, **kwargs):
                     """
                     Inicializador de la clase VoltageWriter para la escritura de datos de espectros.
                     Return: None
                     """
-                    Operation.__init__(self)
+                    Operation.__init__(self, **kwargs)
                     self.nTotalBlocks = 0