| @@ -12,12 +12,6 import datetime | |||||
| 12 | import tarfile |
|
12 | import tarfile | |
| 13 |
|
13 | |||
| 14 | import numpy |
|
14 | import numpy | |
| 15 | try: |
|
|||
| 16 | from netCDF4 import Dataset |
|
|||
| 17 | except: |
|
|||
| 18 | log.warning( |
|
|||
| 19 | 'You should install "netCDF4" module if you want to read/write NCDF files' |
|
|||
| 20 | ) |
|
|||
| 21 |
|
15 | |||
| 22 | from utils import folder_in_range |
|
16 | from utils import folder_in_range | |
| 23 |
|
17 | |||
| @@ -26,6 +20,13 from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation | |||||
| 26 | from schainpy.model.data.jrodata import Parameters |
|
20 | from schainpy.model.data.jrodata import Parameters | |
| 27 | from schainpy.utils import log |
|
21 | from schainpy.utils import log | |
| 28 |
|
22 | |||
|
|
23 | try: | |||
|
|
24 | from netCDF4 import Dataset | |||
|
|
25 | except: | |||
|
|
26 | log.warning( | |||
|
|
27 | 'You should install "netCDF4" module if you want to read/write NCDF files' | |||
|
|
28 | ) | |||
|
|
29 | ||||
| 29 | UT1970 = datetime.datetime(1970, 1, 1) - datetime.timedelta(seconds=time.timezone) |
|
30 | UT1970 = datetime.datetime(1970, 1, 1) - datetime.timedelta(seconds=time.timezone) | |
| 30 |
|
31 | |||
| 31 |
|
32 | |||
| @@ -686,18 +686,23 class PlotterReceiver(ProcessingUnit, Process): | |||||
| 686 | if socks.get(self.sender_web) == zmq.POLLIN: |
|
686 | if socks.get(self.sender_web) == zmq.POLLIN: | |
| 687 | reply = self.sender_web.recv_string() |
|
687 | reply = self.sender_web.recv_string() | |
| 688 | if reply == 'ok': |
|
688 | if reply == 'ok': | |
|
|
689 | log.log("Response from server ok", self.name) | |||
| 689 | break |
|
690 | break | |
| 690 | else: |
|
691 | else: | |
| 691 |
|
|
692 | log.warning("Malformed reply from server: {}".format(reply), self.name) | |
| 692 |
|
693 | |||
| 693 | else: |
|
694 | else: | |
| 694 |
|
|
695 | log.warning("No response from server, retrying...", self.name) | |
| 695 | self.sender_web.setsockopt(zmq.LINGER, 0) |
|
696 | self.sender_web.setsockopt(zmq.LINGER, 0) | |
| 696 | self.sender_web.close() |
|
697 | self.sender_web.close() | |
| 697 | self.poll.unregister(self.sender_web) |
|
698 | self.poll.unregister(self.sender_web) | |
| 698 | retries -= 1 |
|
699 | retries -= 1 | |
| 699 | if retries == 0: |
|
700 | if retries == 0: | |
| 700 |
|
|
701 | log.error("Server seems to be offline, abandoning", self.name) | |
|
|
702 | self.sender_web = self.context.socket(zmq.REQ) | |||
|
|
703 | self.sender_web.connect(self.web_address) | |||
|
|
704 | self.poll.register(self.sender_web, zmq.POLLIN) | |||
|
|
705 | time.sleep(1) | |||
| 701 | break |
|
706 | break | |
| 702 | self.sender_web = self.context.socket(zmq.REQ) |
|
707 | self.sender_web = self.context.socket(zmq.REQ) | |
| 703 | self.sender_web.connect(self.web_address) |
|
708 | self.sender_web.connect(self.web_address) | |
General Comments 0
You need to be logged in to leave comments.
Login now