schain-jc Commit - r1220:dd4695cf07ce

Se añade el metodo fix_publish y se editan los metodos listen y publish, en el ultimo se colocaun pequeño retardo aplicado exclusivamente durante la comunacion desde la unidad de lectura, las demas operaciones se realizan igual.

Alexander Valdez -

r1220:dd4695cf07ce

parent child

Context file:

r1220:dd4695cf07ce

Collapse all files

schainpy/model/proc/jroproc_base.py +16 -2

                          self.kwargs = kwargs
                          self.sender = None
                          self.receiver = None
+                         self.i        = 0
                          self.name = BaseClass.__name__
                          if 'plot' in self.name.lower() and not self.name.endswith('_'):
                              self.name = '{}{}'.format(self.CODE.upper(), 'Plot')
                              self.inputId = args[0]
                              self.project_id = args[1]
                              self.typeProc = "Operation"
+                     def fix_publish(self,valor,multiple1):
+                         return True if valor%multiple1 ==0 else False
                      def subscribe(self):
                          '''
                          '''
                          This function waits for objects and deserialize using pickle
                          '''
-                         data = pickle.loads(self.receiver.recv_multipart()[1])
+                         try:
+                         	data = pickle.loads(self.receiver.recv_multipart()[1])
+                         except zmq.ZMQError as e:
+                             if e.errno == zmq.ETERM:
+                             	print (e.errno)
                          return data
                      def publish(self, data, id):
                          '''
                          This function publish an object, to a specific topic.
+                         The fix method only affect inputId None which is Read Unit
+                         Use value between 64  80, you should notice a little retard in processing
                          '''
+                         if self.inputId is None:
+                             self.i+=1
+                             if self.fix_publish(self.i,80) == True:#  value n
+                                 time.sleep(0.01)
                          self.sender.send_multipart([str(id).encode(), pickle.dumps(data)])
                      def runReader(self):

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