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