From b6a76136b1f30e2214cae41d0c8d222ad0e78ac8 2019-08-08 19:41:43
From: Alexander Valdez <alexander.valdez@jro.igp.gob.pe>
Date: 2019-08-08 19:41:43
Subject: [PATCH] Se realizar la lectura en modo online  llamando al metodo digitalRFReader(self.path) en reemplazo del metodo reload(), grabando previamente el path de lectura o directorio superior donde se almacena la data. Adicionalmente, se ha definido un tiempo de espera de 3 segundos para dar tiempo suficiente al programa de adquisicion de generar archivos.

El archivo jroIO_digitalRF.py utiliza la libreria digital_rf cuya version actual  es la 2.62( 2017 ) ,esta libreria no tiene definido el metodo o clase reload, este metodo existe en la version 2.0(2014), si uno revisa el archivo jroIO_usrp.py, esta unidad de lectura trabaja con la version 2.0  llamada digital_rf_hdf5, para hacer uso de esta unidad de lectura se instalan los programas correspondiente pero el formato y la informacion difiere un poco de la version actual. Se infiere entonces que al desarrollar del archivo jroIO_digitalRF.py,  esperaba que la libreria aun tenga  incluido el metodo reload con el update de las versiones pero este ya no es parte del  desarrollo, Se realizo la consulta al desarrollador actual de digitalRF Ryan Voltz si se iba a incluir a futuro pero indico que no era necesario.

---

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