/mandos/trunk : revision 1256

To get this branch, use:

bzr branch
http://bzr.recompile.se/loggerhead/mandos/trunk

« back to all changes in this revision

Viewing changes to mandos

Committer: Teddy Hogeborn
Date: 2022-04-24 15:59:10 UTC
Revision ID: teddy@recompile.se-20220424155910-yj2kjjc01jo9405u

dracut-module/password-agent.c: Update testing code

* dracut-module/password-agent.c: Update testing code.

Show diffs side-by-side

added added

removed removed

mandos

# "AvahiService" class, and some lines in "main".

# Everything else is

# This file is part of Mandos.

143

if sys.version_info < (3, 2):

144

configparser.Configparser = configparser.SafeConfigParser

145

146

version = "1.8.16"

146

version = "1.8.14"

147

stored_state_file = "clients.pickle"

148

149

log = logging.getLogger(os.path.basename(sys.argv[0]))

1045

if getattr(self, "enabled", False):

1046

# Already enabled

1047

return

1048

self.expires = datetime.datetime.utcnow() + self.timeout

1048

1049

self.enabled = True

1049

1050

self.last_enabled = datetime.datetime.utcnow()

1050

1051

self.init_checker()

1073

1074

def __del__(self):

1074

1075

self.disable()

1075

1076

def init_checker(self, randomize_start=False):

1077

# Schedule a new checker to be started a randomly selected

1078

# time (a fraction of 'interval') from now. This spreads out

1079

# the startup of checkers over time when the server is

1080

# started.

1077

def init_checker(self):

1078

# Schedule a new checker to be started an 'interval' from now,

1079

# and every interval from then on.

1081

1080

if self.checker_initiator_tag is not None:

1082

1081

GLib.source_remove(self.checker_initiator_tag)

1083

interval_milliseconds = int(self.interval.total_seconds()

1084

* 1000)

1085

if randomize_start:

1086

delay_milliseconds = random.randrange(

1087

interval_milliseconds + 1)

1088

else:

1089

delay_milliseconds = interval_milliseconds

1090

1082

self.checker_initiator_tag = GLib.timeout_add(

1091

delay_milliseconds, self.start_checker, randomize_start)

1092

delay = datetime.timedelta(0, 0, 0, delay_milliseconds)

1093

# A checker might take up to an 'interval' of time, so we can

1094

# expire at the soonest one interval after a checker was

1095

# started. Since the initial checker is delayed, the expire

1096

# time might have to be extended.

1097

now = datetime.datetime.utcnow()

1098

self.expires = now + delay + self.interval

1099

# Schedule a disable() at expire time

1083

random.randrange(int(self.interval.total_seconds() * 1000

1084

+ 1)),

1085

self.start_checker)

1086

# Schedule a disable() when 'timeout' has passed

1100

1087

if self.disable_initiator_tag is not None:

1101

1088

GLib.source_remove(self.disable_initiator_tag)

1102

1089

self.disable_initiator_tag = GLib.timeout_add(

1103

int((self.expires - now).total_seconds() * 1000),

1104

self.disable)

1090

int(self.timeout.total_seconds() * 1000), self.disable)

1091

# Also start a new checker *right now*.

1092

self.start_checker()

1105

1093

1106

1094

def checker_callback(self, source, condition, connection,

1107

1095

command):

1150

1138

def need_approval(self):

1151

1139

self.last_approval_request = datetime.datetime.utcnow()

1152

1140

1153

def start_checker(self, start_was_randomized=False):

1141

def start_checker(self):

1154

1142

"""Start a new checker subprocess if one is not running.

1155

1143

1156

1144

If a checker already exists, leave it running and do

1206

1194

GLib.IOChannel.unix_new(pipe[0].fileno()),

1207

1195

GLib.PRIORITY_DEFAULT, GLib.IO_IN,

1208

1196

self.checker_callback, pipe[0], command)

1209

if start_was_randomized:

1210

# We were started after a random delay; Schedule a new

1211

# checker to be started an 'interval' from now, and every

1212

# interval from then on.

1213

now = datetime.datetime.utcnow()

1214

self.checker_initiator_tag = GLib.timeout_add(

1215

int(self.interval.total_seconds() * 1000),

1216

self.start_checker)

1217

self.expires = max(self.expires, now + self.interval)

1218

# Don't start a new checker again after same random delay

1219

return False

1220

1197

# Re-run this periodically if run by GLib.timeout_add

1221

1198

return True

1222

1199

3632

3609

mandos_dbus_service.client_added_signal(client)

3633

3610

# Need to initiate checking of clients

3634

3611

if client.enabled:

3635

client.init_checker(randomize_start=True)

3612

client.init_checker()

3636

3613

3637

3614

tcp_server.enable()

3638

3615

tcp_server.server_activate()

3733

3710

# default-directory dir)

3734

3711

# (erase-buffer)

3735

3712

# (compilation-mode))

3736

# (let ((process-result

3737

# (let ((inhibit-read-only t))

3738

# (process-file-shell-command

3739

# (funcall get-command-line extra) nil "*Test*"))))

3740

# (and (numberp process-result)

3741

# (= process-result 0))))

3713

# (let ((inhibit-read-only t))

3714

# (= (process-file-shell-command

3715

# (funcall get-command-line extra)

3716

# nil "*Test*") 0)))

3742

3717

# get-command-line:

3743

3718

# (lambda (&optional extra)

3744

3719

# (let ((quoted-script

Older »