128
128
if sys.version_info < (3, 2):
129
129
configparser.Configparser = configparser.SafeConfigParser
132
132
stored_state_file = "clients.pickle"
134
134
logger = logging.getLogger()
1151
1150
kwargs=popen_args)
1152
1151
self.checker.start()
1153
1152
self.checker_callback_tag = GLib.io_add_watch(
1154
GLib.IOChannel.unix_new(pipe[0].fileno()),
1155
GLib.PRIORITY_DEFAULT, GLib.IO_IN,
1153
pipe[0].fileno(), GLib.PRIORITY_DEFAULT, GLib.IO_IN,
1156
1154
self.checker_callback, pipe[0], command)
1157
1155
# Re-run this periodically if run by GLib.timeout_add
2682
2680
def add_pipe(self, parent_pipe, proc):
2683
2681
# Call "handle_ipc" for both data and EOF events
2684
2682
GLib.io_add_watch(
2685
GLib.IOChannel.unix_new(parent_pipe.fileno()),
2686
GLib.PRIORITY_DEFAULT, GLib.IO_IN | GLib.IO_HUP,
2683
parent_pipe.fileno(), GLib.PRIORITY_DEFAULT,
2684
GLib.IO_IN | GLib.IO_HUP,
2687
2685
functools.partial(self.handle_ipc,
2688
2686
parent_pipe=parent_pipe,
2729
2727
GLib.io_add_watch(
2730
GLib.IOChannel.unix_new(parent_pipe.fileno()),
2731
GLib.PRIORITY_DEFAULT, GLib.IO_IN | GLib.IO_HUP,
2728
parent_pipe.fileno(), GLib.PRIORITY_DEFAULT,
2729
GLib.IO_IN | GLib.IO_HUP,
2732
2730
functools.partial(self.handle_ipc,
2733
2731
parent_pipe=parent_pipe,
2766
2764
def rfc3339_duration_to_delta(duration):
2767
2765
"""Parse an RFC 3339 "duration" and return a datetime.timedelta
2769
>>> rfc3339_duration_to_delta("P7D") == datetime.timedelta(7)
2771
>>> rfc3339_duration_to_delta("PT60S") == datetime.timedelta(0, 60)
2773
>>> rfc3339_duration_to_delta("PT60M") == datetime.timedelta(0, 3600)
2775
>>> rfc3339_duration_to_delta("PT24H") == datetime.timedelta(1)
2777
>>> rfc3339_duration_to_delta("P1W") == datetime.timedelta(7)
2779
>>> rfc3339_duration_to_delta("PT5M30S") == datetime.timedelta(0, 330)
2781
>>> rfc3339_duration_to_delta("P1DT3M20S") == datetime.timedelta(1, 200)
2767
>>> rfc3339_duration_to_delta("P7D")
2768
datetime.timedelta(7)
2769
>>> rfc3339_duration_to_delta("PT60S")
2770
datetime.timedelta(0, 60)
2771
>>> rfc3339_duration_to_delta("PT60M")
2772
datetime.timedelta(0, 3600)
2773
>>> rfc3339_duration_to_delta("PT24H")
2774
datetime.timedelta(1)
2775
>>> rfc3339_duration_to_delta("P1W")
2776
datetime.timedelta(7)
2777
>>> rfc3339_duration_to_delta("PT5M30S")
2778
datetime.timedelta(0, 330)
2779
>>> rfc3339_duration_to_delta("P1DT3M20S")
2780
datetime.timedelta(1, 200)
2785
2783
# Parsing an RFC 3339 duration with regular expressions is not
2865
2863
def string_to_delta(interval):
2866
2864
"""Parse a string and return a datetime.timedelta
2868
>>> string_to_delta('7d') == datetime.timedelta(7)
2870
>>> string_to_delta('60s') == datetime.timedelta(0, 60)
2872
>>> string_to_delta('60m') == datetime.timedelta(0, 3600)
2874
>>> string_to_delta('24h') == datetime.timedelta(1)
2876
>>> string_to_delta('1w') == datetime.timedelta(7)
2878
>>> string_to_delta('5m 30s') == datetime.timedelta(0, 330)
2866
>>> string_to_delta('7d')
2867
datetime.timedelta(7)
2868
>>> string_to_delta('60s')
2869
datetime.timedelta(0, 60)
2870
>>> string_to_delta('60m')
2871
datetime.timedelta(0, 3600)
2872
>>> string_to_delta('24h')
2873
datetime.timedelta(1)
2874
>>> string_to_delta('1w')
2875
datetime.timedelta(7)
2876
>>> string_to_delta('5m 30s')
2877
datetime.timedelta(0, 330)
3252
3250
if isinstance(s, bytes)
3253
3251
else s) for s in
3254
3252
value["client_structure"]]
3255
# .name, .host, and .checker_command
3256
for k in ("name", "host", "checker_command"):
3254
for k in ("name", "host"):
3257
3255
if isinstance(value[k], bytes):
3258
3256
value[k] = value[k].decode("utf-8")
3259
3257
if "key_id" not in value:
3269
3267
for key, value in
3270
3268
bytes_old_client_settings.items()}
3271
3269
del bytes_old_client_settings
3272
# .host and .checker_command
3273
3271
for value in old_client_settings.values():
3274
for attribute in ("host", "checker_command"):
3275
if isinstance(value[attribute], bytes):
3276
value[attribute] = (value[attribute]
3272
if isinstance(value["host"], bytes):
3273
value["host"] = (value["host"]
3278
3275
os.remove(stored_state_path)
3279
3276
except IOError as e:
3280
3277
if e.errno == errno.ENOENT:
3606
3603
# End of Avahi example code
3609
GLib.IOChannel.unix_new(tcp_server.fileno()),
3610
GLib.PRIORITY_DEFAULT, GLib.IO_IN,
3611
lambda *args, **kwargs: (tcp_server.handle_request
3612
(*args[2:], **kwargs) or True))
3605
GLib.io_add_watch(tcp_server.fileno(), GLib.PRIORITY_DEFAULT,
3607
lambda *args, **kwargs:
3608
(tcp_server.handle_request
3609
(*args[2:], **kwargs) or True))
3614
3611
logger.debug("Starting main loop")
3615
3612
main_loop.run()