| @@ -12,12 +12,6 import datetime | |||
|
|
12 | 12 | import tarfile |
|
|
13 | 13 | |
|
|
14 | 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 | 16 | from utils import folder_in_range |
|
|
23 | 17 | |
| @@ -26,6 +20,13 from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation | |||
|
|
26 | 20 | from schainpy.model.data.jrodata import Parameters |
|
|
27 | 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 | 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 | 686 | if socks.get(self.sender_web) == zmq.POLLIN: |
|
|
687 | 687 | reply = self.sender_web.recv_string() |
|
|
688 | 688 | if reply == 'ok': |
|
|
689 | log.log("Response from server ok", self.name) | |
|
|
689 | 690 | break |
|
|
690 | 691 | else: |
|
|
691 |
|
|
|
|
692 | log.warning("Malformed reply from server: {}".format(reply), self.name) | |
|
|
692 | 693 | |
|
|
693 | 694 | else: |
|
|
694 |
|
|
|
|
695 | log.warning("No response from server, retrying...", self.name) | |
|
|
695 | 696 | self.sender_web.setsockopt(zmq.LINGER, 0) |
|
|
696 | 697 | self.sender_web.close() |
|
|
697 | 698 | self.poll.unregister(self.sender_web) |
|
|
698 | 699 | retries -= 1 |
|
|
699 | 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 | 706 | break |
|
|
702 | 707 | self.sender_web = self.context.socket(zmq.REQ) |
|
|
703 | 708 | self.sender_web.connect(self.web_address) |
General Comments 0
You need to be logged in to leave comments.
Login now