schain Commit - r961:80664bd78a14 · Jicamarca Repository

receiving as unit reader

José Chávez -

r961:80664bd78a14

parent child

Context file:

r961:80664bd78a14

Collapse all files

schainpy/trash created 644 +1 0

	@@ -0,0 +1,1
				1	You should install "digital_rf_hdf5" module if you want to read USRP data

schain.xml +1 -1

	@@ -1,1 +1,1
	1	<Project description="A schain project" id="191" name="project"><ReadUnit datatype="Voltage" id="1911" inputId="0" name="VoltageReader"><Operation id="19111" name="run" priority="1" type="self"><Parameter format="str" id="191111" name="datatype" value="VoltageReader" /><Parameter format="str" id="191112" name="path" value="/home/nanosat/schain" /><Parameter format="date" id="191113" name="startDate" value="1970/01/01" /><Parameter format="date" id="191114" name="endDate" value="2017/12/31" /><Parameter format="time" id="191115" name="startTime" value="00:00:00" /><Parameter format="time" id="191116" name="endTime" value="23:59:59" /><Parameter format="int" id="191118" name="walk" value="1" /><Parameter format="int" id="191119" name="verbose" value="1" /><Parameter format="int" id="191120" name="online" value="0" /></Operation></ReadUnit><ProcUnit datatype="Voltage" id="1912" inputId="1911" name="VoltageProc"><Operation id="19121" name="run" priority="1" type="self" /><Operation id="19122" name="ProfileSelector" priority="2" type="other"><Parameter format="intlist" id="191221" name="profileRangeList" value="120,183" /></Operation><Operation id="19123" name="RTIPlot" priority="3" type="~~plott~~er"><Parameter format="str" id="191231" name="wintitle" value="Jicamarca Radio Observatory" /><Parameter format="int" id="191232" name="showprofile" value="0" /><Parameter format="int" id="191233" name="xmin" value="0" /><Parameter format="int" id="191234" name="xmax" value="24" /><Parameter format="str" id="191235" name="figpath" value="/home/nanosat/schain/figs" /><Parameter format="int" id="191236" name="wr_period" value="5" /><Parameter format="int" id="191237" name="exp_code" value="22" /></Operation></ProcUnit></Project> No newline at end of file		1	<Project description="A schain project" id="191" name="project"><ReadUnit datatype="VoltageReader" id="1911" inputId="0" name="VoltageReader"><Operation id="19111" name="run" priority="1" type="self"><Parameter format="str" id="191111" name="datatype" value="VoltageReader" /><Parameter format="str" id="191112" name="path" value="/home/nanosat/schain" /><Parameter format="date" id="191113" name="startDate" value="1970/01/01" /><Parameter format="date" id="191114" name="endDate" value="2017/12/31" /><Parameter format="time" id="191115" name="startTime" value="00:00:00" /><Parameter format="time" id="191116" name="endTime" value="23:59:59" /><Parameter format="int" id="191118" name="walk" value="1" /><Parameter format="int" id="191119" name="verbose" value="1" /><Parameter format="int" id="191120" name="online" value="0" /></Operation></ReadUnit><ProcUnit datatype="VoltageProc" id="1912" inputId="1911" name="VoltageProc"><Operation id="19121" name="run" priority="1" type="self" /><Operation id="19122" name="ProfileSelector" priority="2" type="other"><Parameter format="intlist" id="191221" name="profileRangeList" value="120,183" /></Operation><Operation id="19123" name="RTIPlot" priority="3" type="other"><Parameter format="str" id="191231" name="wintitle" value="Jicamarca Radio Observatory" /><Parameter format="int" id="191232" name="showprofile" value="0" /><Parameter format="int" id="191233" name="xmin" value="0" /><Parameter format="int" id="191234" name="xmax" value="24" /><Parameter format="str" id="191235" name="figpath" value="/home/nanosat/schain/figs" /><Parameter format="int" id="191236" name="wr_period" value="5" /><Parameter format="int" id="191237" name="exp_code" value="22" /></Operation></ProcUnit></Project> No newline at end of file

schainpy/model/io/jroIO_base.py +20 -4

             import fnmatch
             import inspect
             import time, datetime
-            #import h5py
             import traceback
             try:
                             skip=None,
                             cursor=None,
                             warnings=True,
-                            verbose=True):
+                            verbose=True,
+                            server=None):
+                    if server is not None:
+                        server = kwargs.get('server', 'zmq.pipe')
+                        if 'tcp://' in server:
+                            address = server
+                        else:
+                            address = 'ipc:///tmp/%s' % server
+                        self.address = address
+                        self.context = zmq.Context()
+                        self.receiver = self.context.socket(zmq.PULL)
+                        self.receiver.bind(self.address)
+                        time.sleep(0.5)
+                        print '[Starting] ReceiverData from {}'.format(self.address)
+                    else:
                         if path == None:
                             raise ValueError, "[Reading] The path is not valid"
                             self.path = path
                             self.foldercounter = foldercounter
                             last_set = None
                         else:
                             print "[Reading] Searching files in offline mode ..."
                             pathList, filenameList = self.__searchFilesOffLine(path, startDate=startDate, endDate=endDate,
                             skip=None,
                             cursor=None,
                             warnings=True,
+                            server=None,
                             verbose=True, **kwargs):
                     if not(self.isConfig):
                                     skip=skip,
                                     cursor=cursor,
                                     warnings=warnings,
+                                    server=None,
                                     verbose=verbose)
                         self.isConfig = True
+                    if self.server is None:
                         self.getData()
+                    else:
+                        self.getFromZMQ()
             class JRODataWriter(JRODataIO):

schainpy/model/io/jroIO_voltage.py +7 0

             from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation
             from schainpy.model.data.jroheaderIO import PROCFLAG, BasicHeader, SystemHeader, RadarControllerHeader, ProcessingHeader
             from schainpy.model.data.jrodata import Voltage
+            import zmq
             # from _sha import blocksize
             class VoltageReader(JRODataReader, ProcessingUnit):
                     return
+                def getFromZMQ(self):
+                    self.dataOut = self.receiver.recv_pyobj()
+                    print '[Receiving] {} - {}'.format(self.dataOut.type,
+                                                       self.dataOut.datatime.ctime())
                 def getData(self):
                     """
                     getData obtiene una unidad de datos del buffer de lectura, un perfil,  y la copia al objeto self.dataOut

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