91
92
if sys.version_info.major == 2:
92
93
__metaclass__ = type
95
# Show warnings by default
96
if not sys.warnoptions:
98
warnings.simplefilter("default")
94
100
# Try to find the value of SO_BINDTODEVICE:
96
102
# This is where SO_BINDTODEVICE is in Python 3.3 (or 3.4?) and
122
128
if sys.version_info < (3, 2):
123
129
configparser.Configparser = configparser.SafeConfigParser
126
132
stored_state_file = "clients.pickle"
128
134
logger = logging.getLogger()
135
logging.captureWarnings(True) # Show warnings via the logging system
1143
1150
kwargs=popen_args)
1144
1151
self.checker.start()
1145
1152
self.checker_callback_tag = GLib.io_add_watch(
1146
pipe[0].fileno(), GLib.IO_IN,
1153
GLib.IOChannel.unix_new(pipe[0].fileno()),
1154
GLib.PRIORITY_DEFAULT, GLib.IO_IN,
1147
1155
self.checker_callback, pipe[0], command)
1148
1156
# Re-run this periodically if run by GLib.timeout_add
2673
2681
def add_pipe(self, parent_pipe, proc):
2674
2682
# Call "handle_ipc" for both data and EOF events
2675
2683
GLib.io_add_watch(
2676
parent_pipe.fileno(),
2677
GLib.IO_IN | GLib.IO_HUP,
2684
GLib.IOChannel.unix_new(parent_pipe.fileno()),
2685
GLib.PRIORITY_DEFAULT, GLib.IO_IN | GLib.IO_HUP,
2678
2686
functools.partial(self.handle_ipc,
2679
2687
parent_pipe=parent_pipe,
2720
2728
GLib.io_add_watch(
2721
parent_pipe.fileno(),
2722
GLib.IO_IN | GLib.IO_HUP,
2729
GLib.IOChannel.unix_new(parent_pipe.fileno()),
2730
GLib.PRIORITY_DEFAULT, GLib.IO_IN | GLib.IO_HUP,
2723
2731
functools.partial(self.handle_ipc,
2724
2732
parent_pipe=parent_pipe,
2757
2765
def rfc3339_duration_to_delta(duration):
2758
2766
"""Parse an RFC 3339 "duration" and return a datetime.timedelta
2760
>>> rfc3339_duration_to_delta("P7D")
2761
datetime.timedelta(7)
2762
>>> rfc3339_duration_to_delta("PT60S")
2763
datetime.timedelta(0, 60)
2764
>>> rfc3339_duration_to_delta("PT60M")
2765
datetime.timedelta(0, 3600)
2766
>>> rfc3339_duration_to_delta("PT24H")
2767
datetime.timedelta(1)
2768
>>> rfc3339_duration_to_delta("P1W")
2769
datetime.timedelta(7)
2770
>>> rfc3339_duration_to_delta("PT5M30S")
2771
datetime.timedelta(0, 330)
2772
>>> rfc3339_duration_to_delta("P1DT3M20S")
2773
datetime.timedelta(1, 200)
2768
>>> rfc3339_duration_to_delta("P7D") == datetime.timedelta(7)
2770
>>> rfc3339_duration_to_delta("PT60S") == datetime.timedelta(0, 60)
2772
>>> rfc3339_duration_to_delta("PT60M") == datetime.timedelta(0, 3600)
2774
>>> rfc3339_duration_to_delta("PT24H") == datetime.timedelta(1)
2776
>>> rfc3339_duration_to_delta("P1W") == datetime.timedelta(7)
2778
>>> rfc3339_duration_to_delta("PT5M30S") == datetime.timedelta(0, 330)
2780
>>> rfc3339_duration_to_delta("P1DT3M20S") == datetime.timedelta(1, 200)
2776
2784
# Parsing an RFC 3339 duration with regular expressions is not
2856
2864
def string_to_delta(interval):
2857
2865
"""Parse a string and return a datetime.timedelta
2859
>>> string_to_delta('7d')
2860
datetime.timedelta(7)
2861
>>> string_to_delta('60s')
2862
datetime.timedelta(0, 60)
2863
>>> string_to_delta('60m')
2864
datetime.timedelta(0, 3600)
2865
>>> string_to_delta('24h')
2866
datetime.timedelta(1)
2867
>>> string_to_delta('1w')
2868
datetime.timedelta(7)
2869
>>> string_to_delta('5m 30s')
2870
datetime.timedelta(0, 330)
2867
>>> string_to_delta('7d') == datetime.timedelta(7)
2869
>>> string_to_delta('60s') == datetime.timedelta(0, 60)
2871
>>> string_to_delta('60m') == datetime.timedelta(0, 3600)
2873
>>> string_to_delta('24h') == datetime.timedelta(1)
2875
>>> string_to_delta('1w') == datetime.timedelta(7)
2877
>>> string_to_delta('5m 30s') == datetime.timedelta(0, 330)
2976
2984
options = parser.parse_args()
2980
fail_count, test_count = doctest.testmod()
2981
sys.exit(os.EX_OK if fail_count == 0 else 1)
2983
2986
# Default values for config file for server-global settings
2984
2987
if gnutls.has_rawpk:
2985
2988
priority = ("SECURE128:!CTYPE-X.509:+CTYPE-RAWPK:!RSA"
3248
3251
if isinstance(s, bytes)
3249
3252
else s) for s in
3250
3253
value["client_structure"]]
3252
for k in ("name", "host"):
3254
# .name, .host, and .checker_command
3255
for k in ("name", "host", "checker_command"):
3253
3256
if isinstance(value[k], bytes):
3254
3257
value[k] = value[k].decode("utf-8")
3255
3258
if "key_id" not in value:
3265
3268
for key, value in
3266
3269
bytes_old_client_settings.items()}
3267
3270
del bytes_old_client_settings
3271
# .host and .checker_command
3269
3272
for value in old_client_settings.values():
3270
if isinstance(value["host"], bytes):
3271
value["host"] = (value["host"]
3273
for attribute in ("host", "checker_command"):
3274
if isinstance(value[attribute], bytes):
3275
value[attribute] = (value[attribute]
3273
3277
os.remove(stored_state_path)
3274
3278
except IOError as e:
3275
3279
if e.errno == errno.ENOENT:
3601
3605
# End of Avahi example code
3603
GLib.io_add_watch(tcp_server.fileno(), GLib.IO_IN,
3604
lambda *args, **kwargs:
3605
(tcp_server.handle_request
3606
(*args[2:], **kwargs) or True))
3608
GLib.IOChannel.unix_new(tcp_server.fileno()),
3609
GLib.PRIORITY_DEFAULT, GLib.IO_IN,
3610
lambda *args, **kwargs: (tcp_server.handle_request
3611
(*args[2:], **kwargs) or True))
3608
3613
logger.debug("Starting main loop")
3609
3614
main_loop.run()
3619
3624
# Must run before the D-Bus bus name gets deregistered
3628
def should_only_run_tests():
3629
parser = argparse.ArgumentParser(add_help=False)
3630
parser.add_argument("--check", action='store_true')
3631
args, unknown_args = parser.parse_known_args()
3632
run_tests = args.check
3634
# Remove --check argument from sys.argv
3635
sys.argv[1:] = unknown_args
3638
# Add all tests from doctest strings
3639
def load_tests(loader, tests, none):
3641
tests.addTests(doctest.DocTestSuite())
3623
3644
if __name__ == '__main__':
3646
if should_only_run_tests():
3647
# Call using ./mandos --check [--verbose]