schain-jc Commit - r1192:fa272605c13d

Multiprocessing for digitalRF just for reading Unit(Task #1461 )

George Yong -

r1192:fa272605c13d

parent child

Context file:

r1192:fa272605c13d

Collapse all files

schainpy/controller.py +7 -4

                      self.name = opElement.get('name')
                      self.type = opElement.get('type')
                      self.priority = opElement.get('priority')
-                     self.project_id = str(project_id)  #yong
+                     self.project_id = str(project_id)
                      # Compatible with old signal chain version
                      # Use of 'run' method instead 'init'
                      '''
                      Instancia de unidades de procesamiento.
                      '''
                      className = eval(self.name)
                      kwargs = self.getKwargs()
                      procUnitObj = className(self.id, self.inputId, self.project_id, **kwargs) # necesitan saber su id y su entrada por fines de ipc
                  def createObjects(self):
-                     for procUnitConfObj in self.procUnitConfObjDict.values():
-                         procUnitConfObj.createObjects()
+                     keys = list(self.procUnitConfObjDict.keys())
+                     keys.sort()
+                     for key in keys:
+                         self.procUnitConfObjDict[key].createObjects()
                  def __handleError(self, procUnitConfObj, modes=None, stdout=True):

schainpy/model/io/jroIO_digitalRF.py +16 -19

              from schainpy.model.data.jroheaderIO import RadarControllerHeader, SystemHeader
              from schainpy.model.data.jrodata import Voltage
-             from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation
+             from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation, MPDecorator
              from time import time
              import pickle
              except:
                  print('You should install "digital_rf" module if you want to read Digital RF data')
+             @MPDecorator
              class DigitalRFReader(ProcessingUnit):
                  '''
                  classdocs
                  '''
-                 def __init__(self, **kwargs):
+                 def __init__(self):
                      '''
                      Constructor
                      '''
-                     ProcessingUnit.__init__(self, **kwargs)
+                     ProcessingUnit.__init__(self)
                      self.dataOut = Voltage()
                      self.__printInfo = True
                              if self.__readNextBlock():
                                  break
                              if self.__thisUnixSample > self.__endUTCSecond * self.__sample_rate:
-                                 return False
+                                 self.dataOut.error = (1, '')
+                                 return
                              if self.__flagDiscontinuousBlock:
                                  print('[Reading] discontinuous block found ... continue with the next block')
-                                 continue
+                                 self.dataOut.error = (1, '')
+                                 return
                              if not self.__online:
-                                 return False
+                                 self.dataOut.error = (1, '')
+                                 return
                              err_counter += 1
                              if err_counter > nTries:
-                                 return False
+                                 self.dataOut.error = (1, '')
+                                 return
                              print('[Reading] waiting %d seconds to read a new block' % seconds)
                              sleep(seconds)
                      if self.profileIndex == self.dataOut.nProfiles:
                          self.profileIndex = 0
-                     return True
+                     return
                  def printInfo(self):
                      '''
                      # self.writeMetadata()
                      ## if self.currentSample == self.__nProfiles: self.currentSample = 0
+                     return dataOut
                  def close(self):
                      print('[Writing] - Closing files ')
                      print('Average of writing to digital rf format is ', self.oldAverage * 1000)
                          pass
-                     # raise
-             if __name__ == '__main__':
-                 readObj = DigitalRFReader()
-                 while True:
-                     readObj.run(path='/home/jchavez/jicamarca/mocked_data/')
-                     # readObj.printInfo()
-                     # readObj.printNumberOfBlock()
  No newline at end of file

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