From eb60268405c6862aa48a83127a8c364cc9f78615 2018-07-18 14:32:15
From: Juan C. Espinoza <juan.espinoza@jro.igp.gob.pe>
Date: 2018-07-18 14:32:15
Subject: [PATCH] Multiprocessing for BLTR (sswma) data

---

diff --git a/schainpy/model/io/bltrIO_param.py b/schainpy/model/io/bltrIO_param.py
index 546fc99..ba86596 100644
--- a/schainpy/model/io/bltrIO_param.py
+++ b/schainpy/model/io/bltrIO_param.py
@@ -13,7 +13,7 @@ import datetime
 
 import numpy
 
-from schainpy.model.proc.jroproc_base import ProcessingUnit
+from schainpy.model.proc.jroproc_base import ProcessingUnit, MPDecorator
 from schainpy.model.data.jrodata import Parameters
 from schainpy.model.io.jroIO_base import JRODataReader, isNumber
 from schainpy.utils import log
@@ -83,7 +83,7 @@ DATA_STRUCTURE = numpy.dtype([
     ('sea_algorithm', '<u4')
 ])
 
-
+@MPDecorator
 class BLTRParamReader(JRODataReader, ProcessingUnit):
     '''
     Boundary Layer and Tropospheric Radar (BLTR) reader, Wind velocities and SNR from *.sswma files
@@ -185,7 +185,6 @@ class BLTRParamReader(JRODataReader, ProcessingUnit):
         file_id = self.fileIndex
 
         if file_id == len(self.fileList):
-            log.success('No more files in the folder', 'BLTRParamReader')
             self.flagNoMoreFiles = 1
             return 0
         
@@ -240,7 +239,7 @@ class BLTRParamReader(JRODataReader, ProcessingUnit):
 
         pointer = self.fp.tell()
         header_rec = numpy.fromfile(self.fp, REC_HEADER_STRUCTURE, 1)
-        self.nchannels = header_rec['nchan'][0] / 2
+        self.nchannels = int(header_rec['nchan'][0] / 2)
         self.kchan = header_rec['nrxs'][0]
         self.nmodes = header_rec['nmodes'][0]
         self.nranges = header_rec['nranges'][0]
@@ -357,8 +356,7 @@ class BLTRParamReader(JRODataReader, ProcessingUnit):
         '''
         if self.flagNoMoreFiles:
             self.dataOut.flagNoData = True
-            log.success('No file left to process', 'BLTRParamReader')
-            return 0
+            self.dataOut.error = (1, 'No More files to read')
 
         if not self.readNextBlock():
             self.dataOut.flagNoData = True
diff --git a/schainpy/model/proc/bltrproc_parameters.py b/schainpy/model/proc/bltrproc_parameters.py
index 6a63540..fbc5f54 100644
--- a/schainpy/model/proc/bltrproc_parameters.py
+++ b/schainpy/model/proc/bltrproc_parameters.py
@@ -12,10 +12,10 @@ from time import gmtime
 
 from numpy import transpose
 
-from .jroproc_base import ProcessingUnit, Operation
+from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation, MPDecorator
 from schainpy.model.data.jrodata import Parameters
 
-
+@MPDecorator
 class BLTRParametersProc(ProcessingUnit):    
     '''
     Processing unit for BLTR parameters data (winds)
@@ -39,13 +39,12 @@ class BLTRParametersProc(ProcessingUnit):
         self.dataOut.year - Experiment year
     '''
 
-    def __init__(self, **kwargs):
+    def __init__(self):
         '''
         Inputs: None           
         '''
-        ProcessingUnit.__init__(self, **kwargs)
+        ProcessingUnit.__init__(self)
         self.dataOut = Parameters()
-        self.isConfig = False
 
     def setup(self, mode):
         '''