| @@ -16,7 +16,7 from multiprocessing import Process | |||||
| 16 |
|
16 | |||
| 17 | from schainpy.model.proc.jroproc_base import Operation, ProcessingUnit |
|
17 | from schainpy.model.proc.jroproc_base import Operation, ProcessingUnit | |
| 18 |
|
18 | |||
| 19 |
throttle_value = |
|
19 | throttle_value = 5 | |
| 20 |
|
20 | |||
| 21 | class PrettyFloat(float): |
|
21 | class PrettyFloat(float): | |
| 22 | def __repr__(self): |
|
22 | def __repr__(self): | |
| @@ -147,7 +147,7 class PublishData(Operation): | |||||
| 147 | self.zmq_socket = context.socket(zmq.PUSH) |
|
147 | self.zmq_socket = context.socket(zmq.PUSH) | |
| 148 | server = kwargs.get('server', 'zmq.pipe') |
|
148 | server = kwargs.get('server', 'zmq.pipe') | |
| 149 |
|
149 | |||
| 150 |
if ' |
|
150 | if 'tcp://' in server: | |
| 151 | address = server |
|
151 | address = server | |
| 152 | else: |
|
152 | else: | |
| 153 | address = 'ipc:///tmp/%s' % server |
|
153 | address = 'ipc:///tmp/%s' % server | |
General Comments 0
You need to be logged in to leave comments.
Login now