schain-jc Commit - r906:a52f011a763e

Update version, fix kwargs for self operations (methods), Add SendToWeb...

Juan C. Espinoza -

r906:a52f011a763e

parent child

Context file:

r906:a52f011a763e

Collapse all files

.gitignore +4 0

@@ -96,3 +96,7 ENV/
96		96
97	# mkdocs documentation	97	# mkdocs documentation
98	/site	98	/site
		99
		100	# eclipse
		101	.project
		102	.pydevproject

schainpy/__init__.py +1 -1

             @author $Author$
             @version $Id$
             '''
-            __version__ = "2.2.5"
  No newline at end of file
+            __version__ = "2.3"
  No newline at end of file

schainpy/controller.py +11 -6

                 def createObject(self, plotter_queue=None):
-                    if self.type == 'self':
+                    if self.type == 'self':
                         raise ValueError, "This operation type cannot be created"
                     if self.type == 'plotter':
                         opObj = Plotter(self.name, plotter_queue)
                     if self.type == 'external' or self.type == 'other':
-                        print self.name
                         className = eval(self.name)
                         kwargs = self.getKwargs()
-                        print kwargs
                         opObj = className(**kwargs)
                     return opObj
                     kwargs = self.getKwargs()
                     procUnitObj = className(**kwargs)
                     for opConfObj in self.opConfObjList:
-                        if opConfObj.type == 'self':
+                        if opConfObj.type=='self' and self.name=='run':
+                            continue
+                        elif opConfObj.type=='self':
+                            procUnitObj.addOperationKwargs(opConfObj.id, **opConfObj.getKwargs())
                             continue
                         opObj = opConfObj.createObject(plotter_queue)
                         self.opObjDict[opConfObj.id] = opObj
                         procUnitObj.addOperation(opObj, opConfObj.id)
                     self.procUnitObj = procUnitObj

schainpy/model/graphics/jroplot_data.py +2 -1

                 def __init__(self, **kwargs):
-                    Operation.__init__(self, **kwargs)
+                    Operation.__init__(self, plot=True, **kwargs)
                     Process.__init__(self)
+                    self.kwargs['code'] = self.CODE
                     self.mp = False
                     self.dataOut = None
                     self.isConfig = False

schainpy/model/proc/jroproc_base.py +23 -7

                     self.dataOut = None
                     self.operations2RunDict = {}
+                    self.operationKwargs = {}
                     self.isConfig = False
                     self.args = args
                     self.kwargs = kwargs
+                def addOperationKwargs(self, objId, **kwargs):
+                    '''
+                    '''
+                    self.operationKwargs[objId] = kwargs
                 def addOperation(self, opObj, objId):
                     """
                     raise NotImplementedError
-                def callMethod(self, name, **kwargs):
+                def callMethod(self, name, opId):
                     """
                     Ejecuta el metodo con el nombre "name" y con argumentos **kwargs de la propia clase.
                             return False
                     else:
                         #Si no es un metodo RUN la entrada es la misma dataOut (interna)
-                        if self.dataOut.isEmpty():
+                        if self.dataOut is not None and self.dataOut.isEmpty():
                             return False
                     #Getting the pointer to method
                     #Executing the self method
                     if hasattr(self, 'mp'):
-                        if self.mp is False:
+                        if name=='run':
-                            self.mp = True
+                            if self.mp is False:
-                            self.start()
+                                self.mp = True
+                                self.start()
+                        else:
+                            methodToCall(**self.operationKwargs[opId])
                     else:
-                        methodToCall(**kwargs)
+                        if name=='run':
+                            methodToCall(**self.kwargs)
+                        else:
+                            methodToCall(**self.operationKwargs[opId])
                     if self.dataOut is None:
                         return False
                     if hasattr(externalProcObj, 'mp'):
                         if externalProcObj.mp is False:
+                            self.operationKwargs[objId] = externalProcObj.kwargs
                             externalProcObj.mp = True
                             externalProcObj.start()
                     else:
                         externalProcObj.run(self.dataOut, **externalProcObj.kwargs)
+                        self.operationKwargs[objId] = externalProcObj.kwargs
                     return True
                         if not opName:
                             raise ValueError, "opName parameter should be defined"
-                        sts = self.callMethod(opName, **self.kwargs)
+                        sts = self.callMethod(opName, opId)
                     elif opType == 'other' or opType == 'external' or opType == 'plotter':

schainpy/model/proc/jroproc_parameters.py 0 -5

                 n = None
-                def __init__(self):
-                    Operation.__init__(self)
                 def __calculateCosDir(self, elev, azim):
                     zen = (90 - elev)*numpy.pi/180
                     azim = azim*numpy.pi/180
             class EWDriftsEstimation(Operation):
-                def __init__(self):
-                    Operation.__init__(self)
                 def __correctValues(self, heiRang, phi, velRadial, SNR):
                     listPhi = phi.tolist()

schainpy/model/utils/jroutils_publish.py +31 -4

                     Process.__init__(self)
                     self.mp = False
                     self.isConfig = False
+                    self.isWebConfig = False
                     self.plottypes =[]
                     self.connections = 0
                     server = kwargs.get('server', 'zmq.pipe')
+                    plot_server = kwargs.get('plot_server', 'zmq.web')
                     if 'tcp://' in server:
                         address = server
                     else:
                         address = 'ipc:///tmp/%s' % server
+                    if 'tcp://' in plot_server:
+                        plot_address = plot_server
+                    else:
+                        plot_address = 'ipc:///tmp/%s' % plot_server
                     self.address = address
+                    self.plot_address = plot_address
                     self.plottypes = [s.strip() for s in kwargs.get('plottypes', 'rti').split(',')]
                     self.realtime = kwargs.get('realtime', False)
                     self.throttle_value = kwargs.get('throttle', 10)
                     self.receiver.bind(self.address)
                     monitor = self.receiver.get_monitor_socket()
                     self.sender = self.context.socket(zmq.PUB)
                     if self.realtime:
                         self.sender_web = self.context.socket(zmq.PUB)
-                        # self.sender_web.setsockopt(zmq.PUBLISH, 'realtime')
+                        self.sender_web.bind(self.plot_address)
-                        self.sender_web.bind("ipc:///tmp/zmq.web")
                     self.sender.bind("ipc:///tmp/zmq.plots")
                     t = Thread(target=self.event_monitor, args=(monitor,))
                             self.started = True
                     return
+                def sendToWeb(self):
+                    if not self.isWebConfig:
+                        context = zmq.Context()
+                        sender_web_config = context.socket(zmq.PUB)
+                        if 'tcp://' in self.plot_address:
+                            print self.plot_address
+                            dum, address, port = self.plot_address.split(':')
+                            conf_address = '{}:{}:{}'.format(dum, address, int(port)+1)
+                        else:
+                            conf_address = self.plot_address + '.config'
+                        sender_web_config.bind(conf_address)
+                        for kwargs in self.operationKwargs.values():
+                            if 'plot' in kwargs:
+                                sender_web_config.send_string(json.dumps(kwargs))
+                                print kwargs
+                        self.isWebConfig = True

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