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