diff --git a/schainpy/model/io/jroIO_digitalRF.py b/schainpy/model/io/jroIO_digitalRF.py index d9e120f..1157426 100644 --- a/schainpy/model/io/jroIO_digitalRF.py +++ b/schainpy/model/io/jroIO_digitalRF.py @@ -1,4 +1,3 @@ - ''' Created on Jul 3, 2014 @@ -57,6 +56,7 @@ class DigitalRFReader(ProcessingUnit): self.__code = None self.dtype = None self.oldAverage = None + self.path = None def close(self): print 'Average of writing to digital rf format is ', self.oldAverage * 1000 @@ -252,6 +252,7 @@ class DigitalRFReader(ProcessingUnit): online delay ''' + self.path = path self.nCohInt = nCohInt self.flagDecodeData = flagDecodeData self.i = 0 @@ -438,7 +439,8 @@ class DigitalRFReader(ProcessingUnit): try: self.digitalReadObj.reload(complete_update=True) except: - self.digitalReadObj.reload() + self.digitalReadObj = digital_rf.DigitalRFReader(self.path) + #self.digitalReadObj.reload() start_index, end_index = self.digitalReadObj.get_bounds( self.__channelNameList[self.__channelList[0]]) @@ -482,6 +484,7 @@ class DigitalRFReader(ProcessingUnit): if self.__thisUnixSample + 2 * self.__samples_to_read > self.__endUTCSecond * self.__sample_rate: print "[Reading] There are no more data into selected time-range" if self.__online: + sleep(3) self.__reload() else: return False