add require libs; install script
This commit is contained in:
@@ -0,0 +1,49 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
# daemon/__init__.py
|
||||
# Part of ‘python-daemon’, an implementation of PEP 3143.
|
||||
#
|
||||
# Copyright © 2009–2015 Ben Finney <ben+python@benfinney.id.au>
|
||||
# Copyright © 2006 Robert Niederreiter
|
||||
#
|
||||
# This is free software: you may copy, modify, and/or distribute this work
|
||||
# under the terms of the Apache License, version 2.0 as published by the
|
||||
# Apache Software Foundation.
|
||||
# No warranty expressed or implied. See the file ‘LICENSE.ASF-2’ for details.
|
||||
|
||||
""" Library to implement a well-behaved Unix daemon process.
|
||||
|
||||
This library implements the well-behaved daemon specification of
|
||||
:pep:`3143`, “Standard daemon process library”.
|
||||
|
||||
A well-behaved Unix daemon process is tricky to get right, but the
|
||||
required steps are much the same for every daemon program. A
|
||||
`DaemonContext` instance holds the behaviour and configured
|
||||
process environment for the program; use the instance as a context
|
||||
manager to enter a daemon state.
|
||||
|
||||
Simple example of usage::
|
||||
|
||||
import daemon
|
||||
|
||||
from spam import do_main_program
|
||||
|
||||
with daemon.DaemonContext():
|
||||
do_main_program()
|
||||
|
||||
Customisation of the steps to become a daemon is available by
|
||||
setting options on the `DaemonContext` instance; see the
|
||||
documentation for that class for each option.
|
||||
|
||||
"""
|
||||
|
||||
from __future__ import (absolute_import, unicode_literals)
|
||||
|
||||
from .daemon import DaemonContext
|
||||
|
||||
|
||||
# Local variables:
|
||||
# coding: utf-8
|
||||
# mode: python
|
||||
# End:
|
||||
# vim: fileencoding=utf-8 filetype=python :
|
||||
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,152 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
# daemon/_metadata.py
|
||||
# Part of ‘python-daemon’, an implementation of PEP 3143.
|
||||
#
|
||||
# Copyright © 2008–2015 Ben Finney <ben+python@benfinney.id.au>
|
||||
#
|
||||
# This is free software: you may copy, modify, and/or distribute this work
|
||||
# under the terms of the Apache License, version 2.0 as published by the
|
||||
# Apache Software Foundation.
|
||||
# No warranty expressed or implied. See the file ‘LICENSE.ASF-2’ for details.
|
||||
|
||||
""" Package metadata for the ‘python-daemon’ distribution. """
|
||||
|
||||
from __future__ import (absolute_import, unicode_literals)
|
||||
|
||||
import json
|
||||
import re
|
||||
import collections
|
||||
import datetime
|
||||
|
||||
import pkg_resources
|
||||
|
||||
|
||||
distribution_name = "python-daemon"
|
||||
version_info_filename = "version_info.json"
|
||||
|
||||
def get_distribution_version_info(filename=version_info_filename):
|
||||
""" Get the version info from the installed distribution.
|
||||
|
||||
:param filename: Base filename of the version info resource.
|
||||
:return: The version info as a mapping of fields. If the
|
||||
distribution is not available, the mapping is empty.
|
||||
|
||||
The version info is stored as a metadata file in the
|
||||
distribution.
|
||||
|
||||
"""
|
||||
version_info = {
|
||||
'release_date': "UNKNOWN",
|
||||
'version': "UNKNOWN",
|
||||
'maintainer': "UNKNOWN",
|
||||
}
|
||||
|
||||
try:
|
||||
distribution = pkg_resources.get_distribution(distribution_name)
|
||||
except pkg_resources.DistributionNotFound:
|
||||
distribution = None
|
||||
|
||||
if distribution is not None:
|
||||
if distribution.has_metadata(version_info_filename):
|
||||
content = distribution.get_metadata(version_info_filename)
|
||||
version_info = json.loads(content)
|
||||
|
||||
return version_info
|
||||
|
||||
version_info = get_distribution_version_info()
|
||||
|
||||
version_installed = version_info['version']
|
||||
|
||||
|
||||
rfc822_person_regex = re.compile(
|
||||
"^(?P<name>[^<]+) <(?P<email>[^>]+)>$")
|
||||
|
||||
ParsedPerson = collections.namedtuple('ParsedPerson', ['name', 'email'])
|
||||
|
||||
def parse_person_field(value):
|
||||
""" Parse a person field into name and email address.
|
||||
|
||||
:param value: The text value specifying a person.
|
||||
:return: A 2-tuple (name, email) for the person's details.
|
||||
|
||||
If the `value` does not match a standard person with email
|
||||
address, the `email` item is ``None``.
|
||||
|
||||
"""
|
||||
result = (None, None)
|
||||
|
||||
match = rfc822_person_regex.match(value)
|
||||
if len(value):
|
||||
if match is not None:
|
||||
result = ParsedPerson(
|
||||
name=match.group('name'),
|
||||
email=match.group('email'))
|
||||
else:
|
||||
result = ParsedPerson(name=value, email=None)
|
||||
|
||||
return result
|
||||
|
||||
author_name = "Ben Finney"
|
||||
author_email = "ben+python@benfinney.id.au"
|
||||
author = "{name} <{email}>".format(name=author_name, email=author_email)
|
||||
|
||||
|
||||
class YearRange:
|
||||
""" A range of years spanning a period. """
|
||||
|
||||
def __init__(self, begin, end=None):
|
||||
self.begin = begin
|
||||
self.end = end
|
||||
|
||||
def __unicode__(self):
|
||||
text = "{range.begin:04d}".format(range=self)
|
||||
if self.end is not None:
|
||||
if self.end > self.begin:
|
||||
text = "{range.begin:04d}–{range.end:04d}".format(range=self)
|
||||
return text
|
||||
|
||||
__str__ = __unicode__
|
||||
|
||||
|
||||
def make_year_range(begin_year, end_date=None):
|
||||
""" Construct the year range given a start and possible end date.
|
||||
|
||||
:param begin_date: The beginning year (text) for the range.
|
||||
:param end_date: The end date (text, ISO-8601 format) for the
|
||||
range, or a non-date token string.
|
||||
:return: The range of years as a `YearRange` instance.
|
||||
|
||||
If the `end_date` is not a valid ISO-8601 date string, the
|
||||
range has ``None`` for the end year.
|
||||
|
||||
"""
|
||||
begin_year = int(begin_year)
|
||||
|
||||
try:
|
||||
end_date = datetime.datetime.strptime(end_date, "%Y-%m-%d")
|
||||
except (TypeError, ValueError):
|
||||
# Specified end_date value is not a valid date.
|
||||
end_year = None
|
||||
else:
|
||||
end_year = end_date.year
|
||||
|
||||
year_range = YearRange(begin=begin_year, end=end_year)
|
||||
|
||||
return year_range
|
||||
|
||||
copyright_year_begin = "2001"
|
||||
build_date = version_info['release_date']
|
||||
copyright_year_range = make_year_range(copyright_year_begin, build_date)
|
||||
|
||||
copyright = "Copyright © {year_range} {author} and others".format(
|
||||
year_range=copyright_year_range, author=author)
|
||||
license = "Apache-2"
|
||||
url = "https://alioth.debian.org/projects/python-daemon/"
|
||||
|
||||
|
||||
# Local variables:
|
||||
# coding: utf-8
|
||||
# mode: python
|
||||
# End:
|
||||
# vim: fileencoding=utf-8 filetype=python :
|
||||
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,926 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
# daemon/daemon.py
|
||||
# Part of ‘python-daemon’, an implementation of PEP 3143.
|
||||
#
|
||||
# Copyright © 2008–2015 Ben Finney <ben+python@benfinney.id.au>
|
||||
# Copyright © 2007–2008 Robert Niederreiter, Jens Klein
|
||||
# Copyright © 2004–2005 Chad J. Schroeder
|
||||
# Copyright © 2003 Clark Evans
|
||||
# Copyright © 2002 Noah Spurrier
|
||||
# Copyright © 2001 Jürgen Hermann
|
||||
#
|
||||
# This is free software: you may copy, modify, and/or distribute this work
|
||||
# under the terms of the Apache License, version 2.0 as published by the
|
||||
# Apache Software Foundation.
|
||||
# No warranty expressed or implied. See the file ‘LICENSE.ASF-2’ for details.
|
||||
|
||||
""" Daemon process behaviour.
|
||||
"""
|
||||
|
||||
from __future__ import (absolute_import, unicode_literals)
|
||||
|
||||
import os
|
||||
import sys
|
||||
import resource
|
||||
import errno
|
||||
import signal
|
||||
import socket
|
||||
import atexit
|
||||
try:
|
||||
# Python 2 has both ‘str’ (bytes) and ‘unicode’ (text).
|
||||
basestring = basestring
|
||||
unicode = unicode
|
||||
except NameError:
|
||||
# Python 3 names the Unicode data type ‘str’.
|
||||
basestring = str
|
||||
unicode = str
|
||||
|
||||
|
||||
class DaemonError(Exception):
|
||||
""" Base exception class for errors from this module. """
|
||||
|
||||
def __init__(self, *args, **kwargs):
|
||||
self._chain_from_context()
|
||||
|
||||
super(DaemonError, self).__init__(*args, **kwargs)
|
||||
|
||||
def _chain_from_context(self):
|
||||
_chain_exception_from_existing_exception_context(self, as_cause=True)
|
||||
|
||||
|
||||
class DaemonOSEnvironmentError(DaemonError, OSError):
|
||||
""" Exception raised when daemon OS environment setup receives error. """
|
||||
|
||||
|
||||
class DaemonProcessDetachError(DaemonError, OSError):
|
||||
""" Exception raised when process detach fails. """
|
||||
|
||||
|
||||
class DaemonContext:
|
||||
""" Context for turning the current program into a daemon process.
|
||||
|
||||
A `DaemonContext` instance represents the behaviour settings and
|
||||
process context for the program when it becomes a daemon. The
|
||||
behaviour and environment is customised by setting options on the
|
||||
instance, before calling the `open` method.
|
||||
|
||||
Each option can be passed as a keyword argument to the `DaemonContext`
|
||||
constructor, or subsequently altered by assigning to an attribute on
|
||||
the instance at any time prior to calling `open`. That is, for
|
||||
options named `wibble` and `wubble`, the following invocation::
|
||||
|
||||
foo = daemon.DaemonContext(wibble=bar, wubble=baz)
|
||||
foo.open()
|
||||
|
||||
is equivalent to::
|
||||
|
||||
foo = daemon.DaemonContext()
|
||||
foo.wibble = bar
|
||||
foo.wubble = baz
|
||||
foo.open()
|
||||
|
||||
The following options are defined.
|
||||
|
||||
`files_preserve`
|
||||
:Default: ``None``
|
||||
|
||||
List of files that should *not* be closed when starting the
|
||||
daemon. If ``None``, all open file descriptors will be closed.
|
||||
|
||||
Elements of the list are file descriptors (as returned by a file
|
||||
object's `fileno()` method) or Python `file` objects. Each
|
||||
specifies a file that is not to be closed during daemon start.
|
||||
|
||||
`chroot_directory`
|
||||
:Default: ``None``
|
||||
|
||||
Full path to a directory to set as the effective root directory of
|
||||
the process. If ``None``, specifies that the root directory is not
|
||||
to be changed.
|
||||
|
||||
`working_directory`
|
||||
:Default: ``'/'``
|
||||
|
||||
Full path of the working directory to which the process should
|
||||
change on daemon start.
|
||||
|
||||
Since a filesystem cannot be unmounted if a process has its
|
||||
current working directory on that filesystem, this should either
|
||||
be left at default or set to a directory that is a sensible “home
|
||||
directory” for the daemon while it is running.
|
||||
|
||||
`umask`
|
||||
:Default: ``0``
|
||||
|
||||
File access creation mask (“umask”) to set for the process on
|
||||
daemon start.
|
||||
|
||||
A daemon should not rely on the parent process's umask value,
|
||||
which is beyond its control and may prevent creating a file with
|
||||
the required access mode. So when the daemon context opens, the
|
||||
umask is set to an explicit known value.
|
||||
|
||||
If the conventional value of 0 is too open, consider setting a
|
||||
value such as 0o022, 0o027, 0o077, or another specific value.
|
||||
Otherwise, ensure the daemon creates every file with an
|
||||
explicit access mode for the purpose.
|
||||
|
||||
`pidfile`
|
||||
:Default: ``None``
|
||||
|
||||
Context manager for a PID lock file. When the daemon context opens
|
||||
and closes, it enters and exits the `pidfile` context manager.
|
||||
|
||||
`detach_process`
|
||||
:Default: ``None``
|
||||
|
||||
If ``True``, detach the process context when opening the daemon
|
||||
context; if ``False``, do not detach.
|
||||
|
||||
If unspecified (``None``) during initialisation of the instance,
|
||||
this will be set to ``True`` by default, and ``False`` only if
|
||||
detaching the process is determined to be redundant; for example,
|
||||
in the case when the process was started by `init`, by `initd`, or
|
||||
by `inetd`.
|
||||
|
||||
`signal_map`
|
||||
:Default: system-dependent
|
||||
|
||||
Mapping from operating system signals to callback actions.
|
||||
|
||||
The mapping is used when the daemon context opens, and determines
|
||||
the action for each signal's signal handler:
|
||||
|
||||
* A value of ``None`` will ignore the signal (by setting the
|
||||
signal action to ``signal.SIG_IGN``).
|
||||
|
||||
* A string value will be used as the name of an attribute on the
|
||||
``DaemonContext`` instance. The attribute's value will be used
|
||||
as the action for the signal handler.
|
||||
|
||||
* Any other value will be used as the action for the
|
||||
signal handler. See the ``signal.signal`` documentation
|
||||
for details of the signal handler interface.
|
||||
|
||||
The default value depends on which signals are defined on the
|
||||
running system. Each item from the list below whose signal is
|
||||
actually defined in the ``signal`` module will appear in the
|
||||
default map:
|
||||
|
||||
* ``signal.SIGTTIN``: ``None``
|
||||
|
||||
* ``signal.SIGTTOU``: ``None``
|
||||
|
||||
* ``signal.SIGTSTP``: ``None``
|
||||
|
||||
* ``signal.SIGTERM``: ``'terminate'``
|
||||
|
||||
Depending on how the program will interact with its child
|
||||
processes, it may need to specify a signal map that
|
||||
includes the ``signal.SIGCHLD`` signal (received when a
|
||||
child process exits). See the specific operating system's
|
||||
documentation for more detail on how to determine what
|
||||
circumstances dictate the need for signal handlers.
|
||||
|
||||
`uid`
|
||||
:Default: ``os.getuid()``
|
||||
|
||||
`gid`
|
||||
:Default: ``os.getgid()``
|
||||
|
||||
The user ID (“UID”) value and group ID (“GID”) value to switch
|
||||
the process to on daemon start.
|
||||
|
||||
The default values, the real UID and GID of the process, will
|
||||
relinquish any effective privilege elevation inherited by the
|
||||
process.
|
||||
|
||||
`prevent_core`
|
||||
:Default: ``True``
|
||||
|
||||
If true, prevents the generation of core files, in order to avoid
|
||||
leaking sensitive information from daemons run as `root`.
|
||||
|
||||
`stdin`
|
||||
:Default: ``None``
|
||||
|
||||
`stdout`
|
||||
:Default: ``None``
|
||||
|
||||
`stderr`
|
||||
:Default: ``None``
|
||||
|
||||
Each of `stdin`, `stdout`, and `stderr` is a file-like object
|
||||
which will be used as the new file for the standard I/O stream
|
||||
`sys.stdin`, `sys.stdout`, and `sys.stderr` respectively. The file
|
||||
should therefore be open, with a minimum of mode 'r' in the case
|
||||
of `stdin`, and mimimum of mode 'w+' in the case of `stdout` and
|
||||
`stderr`.
|
||||
|
||||
If the object has a `fileno()` method that returns a file
|
||||
descriptor, the corresponding file will be excluded from being
|
||||
closed during daemon start (that is, it will be treated as though
|
||||
it were listed in `files_preserve`).
|
||||
|
||||
If ``None``, the corresponding system stream is re-bound to the
|
||||
file named by `os.devnull`.
|
||||
|
||||
"""
|
||||
|
||||
__metaclass__ = type
|
||||
|
||||
def __init__(
|
||||
self,
|
||||
chroot_directory=None,
|
||||
working_directory="/",
|
||||
umask=0,
|
||||
uid=None,
|
||||
gid=None,
|
||||
prevent_core=True,
|
||||
detach_process=None,
|
||||
files_preserve=None,
|
||||
pidfile=None,
|
||||
stdin=None,
|
||||
stdout=None,
|
||||
stderr=None,
|
||||
signal_map=None,
|
||||
):
|
||||
""" Set up a new instance. """
|
||||
self.chroot_directory = chroot_directory
|
||||
self.working_directory = working_directory
|
||||
self.umask = umask
|
||||
self.prevent_core = prevent_core
|
||||
self.files_preserve = files_preserve
|
||||
self.pidfile = pidfile
|
||||
self.stdin = stdin
|
||||
self.stdout = stdout
|
||||
self.stderr = stderr
|
||||
|
||||
if uid is None:
|
||||
uid = os.getuid()
|
||||
self.uid = uid
|
||||
if gid is None:
|
||||
gid = os.getgid()
|
||||
self.gid = gid
|
||||
|
||||
if detach_process is None:
|
||||
detach_process = is_detach_process_context_required()
|
||||
self.detach_process = detach_process
|
||||
|
||||
if signal_map is None:
|
||||
signal_map = make_default_signal_map()
|
||||
self.signal_map = signal_map
|
||||
|
||||
self._is_open = False
|
||||
|
||||
@property
|
||||
def is_open(self):
|
||||
""" ``True`` if the instance is currently open. """
|
||||
return self._is_open
|
||||
|
||||
def open(self):
|
||||
""" Become a daemon process.
|
||||
|
||||
:return: ``None``.
|
||||
|
||||
Open the daemon context, turning the current program into a daemon
|
||||
process. This performs the following steps:
|
||||
|
||||
* If this instance's `is_open` property is true, return
|
||||
immediately. This makes it safe to call `open` multiple times on
|
||||
an instance.
|
||||
|
||||
* If the `prevent_core` attribute is true, set the resource limits
|
||||
for the process to prevent any core dump from the process.
|
||||
|
||||
* If the `chroot_directory` attribute is not ``None``, set the
|
||||
effective root directory of the process to that directory (via
|
||||
`os.chroot`).
|
||||
|
||||
This allows running the daemon process inside a “chroot gaol”
|
||||
as a means of limiting the system's exposure to rogue behaviour
|
||||
by the process. Note that the specified directory needs to
|
||||
already be set up for this purpose.
|
||||
|
||||
* Set the process UID and GID to the `uid` and `gid` attribute
|
||||
values.
|
||||
|
||||
* Close all open file descriptors. This excludes those listed in
|
||||
the `files_preserve` attribute, and those that correspond to the
|
||||
`stdin`, `stdout`, or `stderr` attributes.
|
||||
|
||||
* Change current working directory to the path specified by the
|
||||
`working_directory` attribute.
|
||||
|
||||
* Reset the file access creation mask to the value specified by
|
||||
the `umask` attribute.
|
||||
|
||||
* If the `detach_process` option is true, detach the current
|
||||
process into its own process group, and disassociate from any
|
||||
controlling terminal.
|
||||
|
||||
* Set signal handlers as specified by the `signal_map` attribute.
|
||||
|
||||
* If any of the attributes `stdin`, `stdout`, `stderr` are not
|
||||
``None``, bind the system streams `sys.stdin`, `sys.stdout`,
|
||||
and/or `sys.stderr` to the files represented by the
|
||||
corresponding attributes. Where the attribute has a file
|
||||
descriptor, the descriptor is duplicated (instead of re-binding
|
||||
the name).
|
||||
|
||||
* If the `pidfile` attribute is not ``None``, enter its context
|
||||
manager.
|
||||
|
||||
* Mark this instance as open (for the purpose of future `open` and
|
||||
`close` calls).
|
||||
|
||||
* Register the `close` method to be called during Python's exit
|
||||
processing.
|
||||
|
||||
When the function returns, the running program is a daemon
|
||||
process.
|
||||
|
||||
"""
|
||||
if self.is_open:
|
||||
return
|
||||
|
||||
if self.chroot_directory is not None:
|
||||
change_root_directory(self.chroot_directory)
|
||||
|
||||
if self.prevent_core:
|
||||
prevent_core_dump()
|
||||
|
||||
change_file_creation_mask(self.umask)
|
||||
change_working_directory(self.working_directory)
|
||||
change_process_owner(self.uid, self.gid)
|
||||
|
||||
if self.detach_process:
|
||||
detach_process_context()
|
||||
|
||||
signal_handler_map = self._make_signal_handler_map()
|
||||
set_signal_handlers(signal_handler_map)
|
||||
|
||||
exclude_fds = self._get_exclude_file_descriptors()
|
||||
close_all_open_files(exclude=exclude_fds)
|
||||
|
||||
redirect_stream(sys.stdin, self.stdin)
|
||||
redirect_stream(sys.stdout, self.stdout)
|
||||
redirect_stream(sys.stderr, self.stderr)
|
||||
|
||||
if self.pidfile is not None:
|
||||
self.pidfile.__enter__()
|
||||
|
||||
self._is_open = True
|
||||
|
||||
register_atexit_function(self.close)
|
||||
|
||||
def __enter__(self):
|
||||
""" Context manager entry point. """
|
||||
self.open()
|
||||
return self
|
||||
|
||||
def close(self):
|
||||
""" Exit the daemon process context.
|
||||
|
||||
:return: ``None``.
|
||||
|
||||
Close the daemon context. This performs the following steps:
|
||||
|
||||
* If this instance's `is_open` property is false, return
|
||||
immediately. This makes it safe to call `close` multiple times
|
||||
on an instance.
|
||||
|
||||
* If the `pidfile` attribute is not ``None``, exit its context
|
||||
manager.
|
||||
|
||||
* Mark this instance as closed (for the purpose of future `open`
|
||||
and `close` calls).
|
||||
|
||||
"""
|
||||
if not self.is_open:
|
||||
return
|
||||
|
||||
if self.pidfile is not None:
|
||||
# Follow the interface for telling a context manager to exit,
|
||||
# <URL:http://docs.python.org/library/stdtypes.html#typecontextmanager>.
|
||||
self.pidfile.__exit__(None, None, None)
|
||||
|
||||
self._is_open = False
|
||||
|
||||
def __exit__(self, exc_type, exc_value, traceback):
|
||||
""" Context manager exit point. """
|
||||
self.close()
|
||||
|
||||
def terminate(self, signal_number, stack_frame):
|
||||
""" Signal handler for end-process signals.
|
||||
|
||||
:param signal_number: The OS signal number received.
|
||||
:param stack_frame: The frame object at the point the
|
||||
signal was received.
|
||||
:return: ``None``.
|
||||
|
||||
Signal handler for the ``signal.SIGTERM`` signal. Performs the
|
||||
following step:
|
||||
|
||||
* Raise a ``SystemExit`` exception explaining the signal.
|
||||
|
||||
"""
|
||||
exception = SystemExit(
|
||||
"Terminating on signal {signal_number!r}".format(
|
||||
signal_number=signal_number))
|
||||
raise exception
|
||||
|
||||
def _get_exclude_file_descriptors(self):
|
||||
""" Get the set of file descriptors to exclude closing.
|
||||
|
||||
:return: A set containing the file descriptors for the
|
||||
files to be preserved.
|
||||
|
||||
The file descriptors to be preserved are those from the
|
||||
items in `files_preserve`, and also each of `stdin`,
|
||||
`stdout`, and `stderr`. For each item:
|
||||
|
||||
* If the item is ``None``, it is omitted from the return
|
||||
set.
|
||||
|
||||
* If the item's ``fileno()`` method returns a value, that
|
||||
value is in the return set.
|
||||
|
||||
* Otherwise, the item is in the return set verbatim.
|
||||
|
||||
"""
|
||||
files_preserve = self.files_preserve
|
||||
if files_preserve is None:
|
||||
files_preserve = []
|
||||
files_preserve.extend(
|
||||
item for item in [self.stdin, self.stdout, self.stderr]
|
||||
if hasattr(item, 'fileno'))
|
||||
|
||||
exclude_descriptors = set()
|
||||
for item in files_preserve:
|
||||
if item is None:
|
||||
continue
|
||||
file_descriptor = _get_file_descriptor(item)
|
||||
if file_descriptor is not None:
|
||||
exclude_descriptors.add(file_descriptor)
|
||||
else:
|
||||
exclude_descriptors.add(item)
|
||||
|
||||
return exclude_descriptors
|
||||
|
||||
def _make_signal_handler(self, target):
|
||||
""" Make the signal handler for a specified target object.
|
||||
|
||||
:param target: A specification of the target for the
|
||||
handler; see below.
|
||||
:return: The value for use by `signal.signal()`.
|
||||
|
||||
If `target` is ``None``, return ``signal.SIG_IGN``. If `target`
|
||||
is a text string, return the attribute of this instance named
|
||||
by that string. Otherwise, return `target` itself.
|
||||
|
||||
"""
|
||||
if target is None:
|
||||
result = signal.SIG_IGN
|
||||
elif isinstance(target, basestring):
|
||||
name = target
|
||||
result = getattr(self, name)
|
||||
else:
|
||||
result = target
|
||||
|
||||
return result
|
||||
|
||||
def _make_signal_handler_map(self):
|
||||
""" Make the map from signals to handlers for this instance.
|
||||
|
||||
:return: The constructed signal map for this instance.
|
||||
|
||||
Construct a map from signal numbers to handlers for this
|
||||
context instance, suitable for passing to
|
||||
`set_signal_handlers`.
|
||||
|
||||
"""
|
||||
signal_handler_map = dict(
|
||||
(signal_number, self._make_signal_handler(target))
|
||||
for (signal_number, target) in self.signal_map.items())
|
||||
return signal_handler_map
|
||||
|
||||
|
||||
def _get_file_descriptor(obj):
|
||||
""" Get the file descriptor, if the object has one.
|
||||
|
||||
:param obj: The object expected to be a file-like object.
|
||||
:return: The file descriptor iff the file supports it; otherwise
|
||||
``None``.
|
||||
|
||||
The object may be a non-file object. It may also be a
|
||||
file-like object with no support for a file descriptor. In
|
||||
either case, return ``None``.
|
||||
|
||||
"""
|
||||
file_descriptor = None
|
||||
if hasattr(obj, 'fileno'):
|
||||
try:
|
||||
file_descriptor = obj.fileno()
|
||||
except ValueError:
|
||||
# The item doesn't support a file descriptor.
|
||||
pass
|
||||
|
||||
return file_descriptor
|
||||
|
||||
|
||||
def change_working_directory(directory):
|
||||
""" Change the working directory of this process.
|
||||
|
||||
:param directory: The target directory path.
|
||||
:return: ``None``.
|
||||
|
||||
"""
|
||||
try:
|
||||
os.chdir(directory)
|
||||
except Exception as exc:
|
||||
error = DaemonOSEnvironmentError(
|
||||
"Unable to change working directory ({exc})".format(exc=exc))
|
||||
raise error
|
||||
|
||||
|
||||
def change_root_directory(directory):
|
||||
""" Change the root directory of this process.
|
||||
|
||||
:param directory: The target directory path.
|
||||
:return: ``None``.
|
||||
|
||||
Set the current working directory, then the process root directory,
|
||||
to the specified `directory`. Requires appropriate OS privileges
|
||||
for this process.
|
||||
|
||||
"""
|
||||
try:
|
||||
os.chdir(directory)
|
||||
os.chroot(directory)
|
||||
except Exception as exc:
|
||||
error = DaemonOSEnvironmentError(
|
||||
"Unable to change root directory ({exc})".format(exc=exc))
|
||||
raise error
|
||||
|
||||
|
||||
def change_file_creation_mask(mask):
|
||||
""" Change the file creation mask for this process.
|
||||
|
||||
:param mask: The numeric file creation mask to set.
|
||||
:return: ``None``.
|
||||
|
||||
"""
|
||||
try:
|
||||
os.umask(mask)
|
||||
except Exception as exc:
|
||||
error = DaemonOSEnvironmentError(
|
||||
"Unable to change file creation mask ({exc})".format(exc=exc))
|
||||
raise error
|
||||
|
||||
|
||||
def change_process_owner(uid, gid):
|
||||
""" Change the owning UID and GID of this process.
|
||||
|
||||
:param uid: The target UID for the daemon process.
|
||||
:param gid: The target GID for the daemon process.
|
||||
:return: ``None``.
|
||||
|
||||
Set the GID then the UID of the process (in that order, to avoid
|
||||
permission errors) to the specified `gid` and `uid` values.
|
||||
Requires appropriate OS privileges for this process.
|
||||
|
||||
"""
|
||||
try:
|
||||
os.setgid(gid)
|
||||
os.setuid(uid)
|
||||
except Exception as exc:
|
||||
error = DaemonOSEnvironmentError(
|
||||
"Unable to change process owner ({exc})".format(exc=exc))
|
||||
raise error
|
||||
|
||||
|
||||
def prevent_core_dump():
|
||||
""" Prevent this process from generating a core dump.
|
||||
|
||||
:return: ``None``.
|
||||
|
||||
Set the soft and hard limits for core dump size to zero. On Unix,
|
||||
this entirely prevents the process from creating core dump.
|
||||
|
||||
"""
|
||||
core_resource = resource.RLIMIT_CORE
|
||||
|
||||
try:
|
||||
# Ensure the resource limit exists on this platform, by requesting
|
||||
# its current value.
|
||||
core_limit_prev = resource.getrlimit(core_resource)
|
||||
except ValueError as exc:
|
||||
error = DaemonOSEnvironmentError(
|
||||
"System does not support RLIMIT_CORE resource limit"
|
||||
" ({exc})".format(exc=exc))
|
||||
raise error
|
||||
|
||||
# Set hard and soft limits to zero, i.e. no core dump at all.
|
||||
core_limit = (0, 0)
|
||||
resource.setrlimit(core_resource, core_limit)
|
||||
|
||||
|
||||
def detach_process_context():
|
||||
""" Detach the process context from parent and session.
|
||||
|
||||
:return: ``None``.
|
||||
|
||||
Detach from the parent process and session group, allowing the
|
||||
parent to exit while this process continues running.
|
||||
|
||||
Reference: “Advanced Programming in the Unix Environment”,
|
||||
section 13.3, by W. Richard Stevens, published 1993 by
|
||||
Addison-Wesley.
|
||||
|
||||
"""
|
||||
|
||||
def fork_then_exit_parent(error_message):
|
||||
""" Fork a child process, then exit the parent process.
|
||||
|
||||
:param error_message: Message for the exception in case of a
|
||||
detach failure.
|
||||
:return: ``None``.
|
||||
:raise DaemonProcessDetachError: If the fork fails.
|
||||
|
||||
"""
|
||||
try:
|
||||
pid = os.fork()
|
||||
if pid > 0:
|
||||
os._exit(0)
|
||||
except OSError as exc:
|
||||
error = DaemonProcessDetachError(
|
||||
"{message}: [{exc.errno:d}] {exc.strerror}".format(
|
||||
message=error_message, exc=exc))
|
||||
raise error
|
||||
|
||||
fork_then_exit_parent(error_message="Failed first fork")
|
||||
os.setsid()
|
||||
fork_then_exit_parent(error_message="Failed second fork")
|
||||
|
||||
|
||||
def is_process_started_by_init():
|
||||
""" Determine whether the current process is started by `init`.
|
||||
|
||||
:return: ``True`` iff the parent process is `init`; otherwise
|
||||
``False``.
|
||||
|
||||
The `init` process is the one with process ID of 1.
|
||||
|
||||
"""
|
||||
result = False
|
||||
|
||||
init_pid = 1
|
||||
if os.getppid() == init_pid:
|
||||
result = True
|
||||
|
||||
return result
|
||||
|
||||
|
||||
def is_socket(fd):
|
||||
""" Determine whether the file descriptor is a socket.
|
||||
|
||||
:param fd: The file descriptor to interrogate.
|
||||
:return: ``True`` iff the file descriptor is a socket; otherwise
|
||||
``False``.
|
||||
|
||||
Query the socket type of `fd`. If there is no error, the file is a
|
||||
socket.
|
||||
|
||||
"""
|
||||
result = False
|
||||
|
||||
file_socket = socket.fromfd(fd, socket.AF_INET, socket.SOCK_RAW)
|
||||
|
||||
try:
|
||||
socket_type = file_socket.getsockopt(
|
||||
socket.SOL_SOCKET, socket.SO_TYPE)
|
||||
except socket.error as exc:
|
||||
exc_errno = exc.args[0]
|
||||
if exc_errno == errno.ENOTSOCK:
|
||||
# Socket operation on non-socket.
|
||||
pass
|
||||
else:
|
||||
# Some other socket error.
|
||||
result = True
|
||||
else:
|
||||
# No error getting socket type.
|
||||
result = True
|
||||
|
||||
return result
|
||||
|
||||
|
||||
def is_process_started_by_superserver():
|
||||
""" Determine whether the current process is started by the superserver.
|
||||
|
||||
:return: ``True`` if this process was started by the internet
|
||||
superserver; otherwise ``False``.
|
||||
|
||||
The internet superserver creates a network socket, and
|
||||
attaches it to the standard streams of the child process. If
|
||||
that is the case for this process, return ``True``, otherwise
|
||||
``False``.
|
||||
|
||||
"""
|
||||
result = False
|
||||
|
||||
stdin_fd = sys.__stdin__.fileno()
|
||||
if is_socket(stdin_fd):
|
||||
result = True
|
||||
|
||||
return result
|
||||
|
||||
|
||||
def is_detach_process_context_required():
|
||||
""" Determine whether detaching the process context is required.
|
||||
|
||||
:return: ``True`` iff the process is already detached; otherwise
|
||||
``False``.
|
||||
|
||||
The process environment is interrogated for the following:
|
||||
|
||||
* Process was started by `init`; or
|
||||
|
||||
* Process was started by `inetd`.
|
||||
|
||||
If any of the above are true, the process is deemed to be already
|
||||
detached.
|
||||
|
||||
"""
|
||||
result = True
|
||||
if is_process_started_by_init() or is_process_started_by_superserver():
|
||||
result = False
|
||||
|
||||
return result
|
||||
|
||||
|
||||
def close_file_descriptor_if_open(fd):
|
||||
""" Close a file descriptor if already open.
|
||||
|
||||
:param fd: The file descriptor to close.
|
||||
:return: ``None``.
|
||||
|
||||
Close the file descriptor `fd`, suppressing an error in the
|
||||
case the file was not open.
|
||||
|
||||
"""
|
||||
try:
|
||||
os.close(fd)
|
||||
except EnvironmentError as exc:
|
||||
if exc.errno == errno.EBADF:
|
||||
# File descriptor was not open.
|
||||
pass
|
||||
else:
|
||||
error = DaemonOSEnvironmentError(
|
||||
"Failed to close file descriptor {fd:d} ({exc})".format(
|
||||
fd=fd, exc=exc))
|
||||
raise error
|
||||
|
||||
|
||||
MAXFD = 2048
|
||||
|
||||
def get_maximum_file_descriptors():
|
||||
""" Get the maximum number of open file descriptors for this process.
|
||||
|
||||
:return: The number (integer) to use as the maximum number of open
|
||||
files for this process.
|
||||
|
||||
The maximum is the process hard resource limit of maximum number of
|
||||
open file descriptors. If the limit is “infinity”, a default value
|
||||
of ``MAXFD`` is returned.
|
||||
|
||||
"""
|
||||
limits = resource.getrlimit(resource.RLIMIT_NOFILE)
|
||||
result = limits[1]
|
||||
if result == resource.RLIM_INFINITY:
|
||||
result = MAXFD
|
||||
return result
|
||||
|
||||
|
||||
def close_all_open_files(exclude=set()):
|
||||
""" Close all open file descriptors.
|
||||
|
||||
:param exclude: Collection of file descriptors to skip when closing
|
||||
files.
|
||||
:return: ``None``.
|
||||
|
||||
Closes every file descriptor (if open) of this process. If
|
||||
specified, `exclude` is a set of file descriptors to *not*
|
||||
close.
|
||||
|
||||
"""
|
||||
maxfd = get_maximum_file_descriptors()
|
||||
for fd in reversed(range(maxfd)):
|
||||
if fd not in exclude:
|
||||
close_file_descriptor_if_open(fd)
|
||||
|
||||
|
||||
def redirect_stream(system_stream, target_stream):
|
||||
""" Redirect a system stream to a specified file.
|
||||
|
||||
:param standard_stream: A file object representing a standard I/O
|
||||
stream.
|
||||
:param target_stream: The target file object for the redirected
|
||||
stream, or ``None`` to specify the null device.
|
||||
:return: ``None``.
|
||||
|
||||
`system_stream` is a standard system stream such as
|
||||
``sys.stdout``. `target_stream` is an open file object that
|
||||
should replace the corresponding system stream object.
|
||||
|
||||
If `target_stream` is ``None``, defaults to opening the
|
||||
operating system's null device and using its file descriptor.
|
||||
|
||||
"""
|
||||
if target_stream is None:
|
||||
target_fd = os.open(os.devnull, os.O_RDWR)
|
||||
else:
|
||||
target_fd = target_stream.fileno()
|
||||
os.dup2(target_fd, system_stream.fileno())
|
||||
|
||||
|
||||
def make_default_signal_map():
|
||||
""" Make the default signal map for this system.
|
||||
|
||||
:return: A mapping from signal number to handler object.
|
||||
|
||||
The signals available differ by system. The map will not contain
|
||||
any signals not defined on the running system.
|
||||
|
||||
"""
|
||||
name_map = {
|
||||
'SIGTSTP': None,
|
||||
'SIGTTIN': None,
|
||||
'SIGTTOU': None,
|
||||
'SIGTERM': 'terminate',
|
||||
}
|
||||
signal_map = dict(
|
||||
(getattr(signal, name), target)
|
||||
for (name, target) in name_map.items()
|
||||
if hasattr(signal, name))
|
||||
|
||||
return signal_map
|
||||
|
||||
|
||||
def set_signal_handlers(signal_handler_map):
|
||||
""" Set the signal handlers as specified.
|
||||
|
||||
:param signal_handler_map: A map from signal number to handler
|
||||
object.
|
||||
:return: ``None``.
|
||||
|
||||
See the `signal` module for details on signal numbers and signal
|
||||
handlers.
|
||||
|
||||
"""
|
||||
for (signal_number, handler) in signal_handler_map.items():
|
||||
signal.signal(signal_number, handler)
|
||||
|
||||
|
||||
def register_atexit_function(func):
|
||||
""" Register a function for processing at program exit.
|
||||
|
||||
:param func: A callable function expecting no arguments.
|
||||
:return: ``None``.
|
||||
|
||||
The function `func` is registered for a call with no arguments
|
||||
at program exit.
|
||||
|
||||
"""
|
||||
atexit.register(func)
|
||||
|
||||
|
||||
def _chain_exception_from_existing_exception_context(exc, as_cause=False):
|
||||
""" Decorate the specified exception with the existing exception context.
|
||||
|
||||
:param exc: The exception instance to decorate.
|
||||
:param as_cause: If true, the existing context is declared to be
|
||||
the cause of the exception.
|
||||
:return: ``None``.
|
||||
|
||||
:PEP:`344` describes syntax and attributes (`__traceback__`,
|
||||
`__context__`, `__cause__`) for use in exception chaining.
|
||||
|
||||
Python 2 does not have that syntax, so this function decorates
|
||||
the exception with values from the current exception context.
|
||||
|
||||
"""
|
||||
(existing_exc_type, existing_exc, existing_traceback) = sys.exc_info()
|
||||
if as_cause:
|
||||
exc.__cause__ = existing_exc
|
||||
else:
|
||||
exc.__context__ = existing_exc
|
||||
exc.__traceback__ = existing_traceback
|
||||
|
||||
|
||||
# Local variables:
|
||||
# coding: utf-8
|
||||
# mode: python
|
||||
# End:
|
||||
# vim: fileencoding=utf-8 filetype=python :
|
||||
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,67 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
# daemon/pidfile.py
|
||||
# Part of ‘python-daemon’, an implementation of PEP 3143.
|
||||
#
|
||||
# Copyright © 2008–2015 Ben Finney <ben+python@benfinney.id.au>
|
||||
#
|
||||
# This is free software: you may copy, modify, and/or distribute this work
|
||||
# under the terms of the Apache License, version 2.0 as published by the
|
||||
# Apache Software Foundation.
|
||||
# No warranty expressed or implied. See the file ‘LICENSE.ASF-2’ for details.
|
||||
|
||||
""" Lockfile behaviour implemented via Unix PID files.
|
||||
"""
|
||||
|
||||
from __future__ import (absolute_import, unicode_literals)
|
||||
|
||||
from lockfile.pidlockfile import PIDLockFile
|
||||
|
||||
|
||||
class TimeoutPIDLockFile(PIDLockFile, object):
|
||||
""" Lockfile with default timeout, implemented as a Unix PID file.
|
||||
|
||||
This uses the ``PIDLockFile`` implementation, with the
|
||||
following changes:
|
||||
|
||||
* The `acquire_timeout` parameter to the initialiser will be
|
||||
used as the default `timeout` parameter for the `acquire`
|
||||
method.
|
||||
|
||||
"""
|
||||
|
||||
def __init__(self, path, acquire_timeout=None, *args, **kwargs):
|
||||
""" Set up the parameters of a TimeoutPIDLockFile.
|
||||
|
||||
:param path: Filesystem path to the PID file.
|
||||
:param acquire_timeout: Value to use by default for the
|
||||
`acquire` call.
|
||||
:return: ``None``.
|
||||
|
||||
"""
|
||||
self.acquire_timeout = acquire_timeout
|
||||
super(TimeoutPIDLockFile, self).__init__(path, *args, **kwargs)
|
||||
|
||||
def acquire(self, timeout=None, *args, **kwargs):
|
||||
""" Acquire the lock.
|
||||
|
||||
:param timeout: Specifies the timeout; see below for valid
|
||||
values.
|
||||
:return: ``None``.
|
||||
|
||||
The `timeout` defaults to the value set during
|
||||
initialisation with the `acquire_timeout` parameter. It is
|
||||
passed to `PIDLockFile.acquire`; see that method for
|
||||
details.
|
||||
|
||||
"""
|
||||
if timeout is None:
|
||||
timeout = self.acquire_timeout
|
||||
super(TimeoutPIDLockFile, self).acquire(timeout, *args, **kwargs)
|
||||
|
||||
|
||||
# Local variables:
|
||||
# coding: utf-8
|
||||
# mode: python
|
||||
# End:
|
||||
# vim: fileencoding=utf-8 filetype=python :
|
||||
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,324 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
# daemon/runner.py
|
||||
# Part of ‘python-daemon’, an implementation of PEP 3143.
|
||||
#
|
||||
# Copyright © 2009–2015 Ben Finney <ben+python@benfinney.id.au>
|
||||
# Copyright © 2007–2008 Robert Niederreiter, Jens Klein
|
||||
# Copyright © 2003 Clark Evans
|
||||
# Copyright © 2002 Noah Spurrier
|
||||
# Copyright © 2001 Jürgen Hermann
|
||||
#
|
||||
# This is free software: you may copy, modify, and/or distribute this work
|
||||
# under the terms of the Apache License, version 2.0 as published by the
|
||||
# Apache Software Foundation.
|
||||
# No warranty expressed or implied. See the file ‘LICENSE.ASF-2’ for details.
|
||||
|
||||
""" Daemon runner library.
|
||||
"""
|
||||
|
||||
from __future__ import (absolute_import, unicode_literals)
|
||||
|
||||
import sys
|
||||
import os
|
||||
import signal
|
||||
import errno
|
||||
try:
|
||||
# Python 3 standard library.
|
||||
ProcessLookupError
|
||||
except NameError:
|
||||
# No such class in Python 2.
|
||||
ProcessLookupError = NotImplemented
|
||||
|
||||
import lockfile
|
||||
|
||||
from . import pidfile
|
||||
from .daemon import (basestring, unicode)
|
||||
from .daemon import DaemonContext
|
||||
from .daemon import _chain_exception_from_existing_exception_context
|
||||
|
||||
|
||||
class DaemonRunnerError(Exception):
|
||||
""" Abstract base class for errors from DaemonRunner. """
|
||||
|
||||
def __init__(self, *args, **kwargs):
|
||||
self._chain_from_context()
|
||||
|
||||
super(DaemonRunnerError, self).__init__(*args, **kwargs)
|
||||
|
||||
def _chain_from_context(self):
|
||||
_chain_exception_from_existing_exception_context(self, as_cause=True)
|
||||
|
||||
|
||||
class DaemonRunnerInvalidActionError(DaemonRunnerError, ValueError):
|
||||
""" Raised when specified action for DaemonRunner is invalid. """
|
||||
|
||||
def _chain_from_context(self):
|
||||
# This exception is normally not caused by another.
|
||||
_chain_exception_from_existing_exception_context(self, as_cause=False)
|
||||
|
||||
|
||||
class DaemonRunnerStartFailureError(DaemonRunnerError, RuntimeError):
|
||||
""" Raised when failure starting DaemonRunner. """
|
||||
|
||||
|
||||
class DaemonRunnerStopFailureError(DaemonRunnerError, RuntimeError):
|
||||
""" Raised when failure stopping DaemonRunner. """
|
||||
|
||||
|
||||
class DaemonRunner:
|
||||
""" Controller for a callable running in a separate background process.
|
||||
|
||||
The first command-line argument is the action to take:
|
||||
|
||||
* 'start': Become a daemon and call `app.run()`.
|
||||
* 'stop': Exit the daemon process specified in the PID file.
|
||||
* 'restart': Stop, then start.
|
||||
|
||||
"""
|
||||
|
||||
__metaclass__ = type
|
||||
|
||||
start_message = "started with pid {pid:d}"
|
||||
|
||||
def __init__(self, app):
|
||||
""" Set up the parameters of a new runner.
|
||||
|
||||
:param app: The application instance; see below.
|
||||
:return: ``None``.
|
||||
|
||||
The `app` argument must have the following attributes:
|
||||
|
||||
* `stdin_path`, `stdout_path`, `stderr_path`: Filesystem paths
|
||||
to open and replace the existing `sys.stdin`, `sys.stdout`,
|
||||
`sys.stderr`.
|
||||
|
||||
* `pidfile_path`: Absolute filesystem path to a file that will
|
||||
be used as the PID file for the daemon. If ``None``, no PID
|
||||
file will be used.
|
||||
|
||||
* `pidfile_timeout`: Used as the default acquisition timeout
|
||||
value supplied to the runner's PID lock file.
|
||||
|
||||
* `run`: Callable that will be invoked when the daemon is
|
||||
started.
|
||||
|
||||
"""
|
||||
self.parse_args()
|
||||
self.app = app
|
||||
self.daemon_context = DaemonContext()
|
||||
self.daemon_context.stdin = open(app.stdin_path, 'rt')
|
||||
self.daemon_context.stdout = open(app.stdout_path, 'w+t')
|
||||
self.daemon_context.stderr = open(
|
||||
app.stderr_path, 'w+t', buffering=0)
|
||||
|
||||
self.pidfile = None
|
||||
if app.pidfile_path is not None:
|
||||
self.pidfile = make_pidlockfile(
|
||||
app.pidfile_path, app.pidfile_timeout)
|
||||
self.daemon_context.pidfile = self.pidfile
|
||||
|
||||
def _usage_exit(self, argv):
|
||||
""" Emit a usage message, then exit.
|
||||
|
||||
:param argv: The command-line arguments used to invoke the
|
||||
program, as a sequence of strings.
|
||||
:return: ``None``.
|
||||
|
||||
"""
|
||||
progname = os.path.basename(argv[0])
|
||||
usage_exit_code = 2
|
||||
action_usage = "|".join(self.action_funcs.keys())
|
||||
message = "usage: {progname} {usage}".format(
|
||||
progname=progname, usage=action_usage)
|
||||
emit_message(message)
|
||||
sys.exit(usage_exit_code)
|
||||
|
||||
def parse_args(self, argv=None):
|
||||
""" Parse command-line arguments.
|
||||
|
||||
:param argv: The command-line arguments used to invoke the
|
||||
program, as a sequence of strings.
|
||||
|
||||
:return: ``None``.
|
||||
|
||||
The parser expects the first argument as the program name, the
|
||||
second argument as the action to perform.
|
||||
|
||||
If the parser fails to parse the arguments, emit a usage
|
||||
message and exit the program.
|
||||
|
||||
"""
|
||||
if argv is None:
|
||||
argv = sys.argv
|
||||
|
||||
min_args = 2
|
||||
if len(argv) < min_args:
|
||||
self._usage_exit(argv)
|
||||
|
||||
self.action = unicode(argv[1])
|
||||
if self.action not in self.action_funcs:
|
||||
self._usage_exit(argv)
|
||||
|
||||
def _start(self):
|
||||
""" Open the daemon context and run the application.
|
||||
|
||||
:return: ``None``.
|
||||
:raises DaemonRunnerStartFailureError: If the PID file cannot
|
||||
be locked by this process.
|
||||
|
||||
"""
|
||||
if is_pidfile_stale(self.pidfile):
|
||||
self.pidfile.break_lock()
|
||||
|
||||
try:
|
||||
self.daemon_context.open()
|
||||
except lockfile.AlreadyLocked:
|
||||
error = DaemonRunnerStartFailureError(
|
||||
"PID file {pidfile.path!r} already locked".format(
|
||||
pidfile=self.pidfile))
|
||||
raise error
|
||||
|
||||
pid = os.getpid()
|
||||
message = self.start_message.format(pid=pid)
|
||||
emit_message(message)
|
||||
|
||||
self.app.run()
|
||||
|
||||
def _terminate_daemon_process(self):
|
||||
""" Terminate the daemon process specified in the current PID file.
|
||||
|
||||
:return: ``None``.
|
||||
:raises DaemonRunnerStopFailureError: If terminating the daemon
|
||||
fails with an OS error.
|
||||
|
||||
"""
|
||||
pid = self.pidfile.read_pid()
|
||||
try:
|
||||
os.kill(pid, signal.SIGTERM)
|
||||
except OSError as exc:
|
||||
error = DaemonRunnerStopFailureError(
|
||||
"Failed to terminate {pid:d}: {exc}".format(
|
||||
pid=pid, exc=exc))
|
||||
raise error
|
||||
|
||||
def _stop(self):
|
||||
""" Exit the daemon process specified in the current PID file.
|
||||
|
||||
:return: ``None``.
|
||||
:raises DaemonRunnerStopFailureError: If the PID file is not
|
||||
already locked.
|
||||
|
||||
"""
|
||||
if not self.pidfile.is_locked():
|
||||
error = DaemonRunnerStopFailureError(
|
||||
"PID file {pidfile.path!r} not locked".format(
|
||||
pidfile=self.pidfile))
|
||||
raise error
|
||||
|
||||
if is_pidfile_stale(self.pidfile):
|
||||
self.pidfile.break_lock()
|
||||
else:
|
||||
self._terminate_daemon_process()
|
||||
|
||||
def _restart(self):
|
||||
""" Stop, then start.
|
||||
"""
|
||||
self._stop()
|
||||
self._start()
|
||||
|
||||
action_funcs = {
|
||||
'start': _start,
|
||||
'stop': _stop,
|
||||
'restart': _restart,
|
||||
}
|
||||
|
||||
def _get_action_func(self):
|
||||
""" Get the function for the specified action.
|
||||
|
||||
:return: The function object corresponding to the specified
|
||||
action.
|
||||
:raises DaemonRunnerInvalidActionError: if the action is
|
||||
unknown.
|
||||
|
||||
The action is specified by the `action` attribute, which is set
|
||||
during `parse_args`.
|
||||
|
||||
"""
|
||||
try:
|
||||
func = self.action_funcs[self.action]
|
||||
except KeyError:
|
||||
error = DaemonRunnerInvalidActionError(
|
||||
"Unknown action: {action!r}".format(
|
||||
action=self.action))
|
||||
raise error
|
||||
return func
|
||||
|
||||
def do_action(self):
|
||||
""" Perform the requested action.
|
||||
|
||||
:return: ``None``.
|
||||
|
||||
The action is specified by the `action` attribute, which is set
|
||||
during `parse_args`.
|
||||
|
||||
"""
|
||||
func = self._get_action_func()
|
||||
func(self)
|
||||
|
||||
|
||||
def emit_message(message, stream=None):
|
||||
""" Emit a message to the specified stream (default `sys.stderr`). """
|
||||
if stream is None:
|
||||
stream = sys.stderr
|
||||
stream.write("{message}\n".format(message=message))
|
||||
stream.flush()
|
||||
|
||||
|
||||
def make_pidlockfile(path, acquire_timeout):
|
||||
""" Make a PIDLockFile instance with the given filesystem path. """
|
||||
if not isinstance(path, basestring):
|
||||
error = ValueError("Not a filesystem path: {path!r}".format(
|
||||
path=path))
|
||||
raise error
|
||||
if not os.path.isabs(path):
|
||||
error = ValueError("Not an absolute path: {path!r}".format(
|
||||
path=path))
|
||||
raise error
|
||||
lockfile = pidfile.TimeoutPIDLockFile(path, acquire_timeout)
|
||||
|
||||
return lockfile
|
||||
|
||||
|
||||
def is_pidfile_stale(pidfile):
|
||||
""" Determine whether a PID file is stale.
|
||||
|
||||
:return: ``True`` iff the PID file is stale; otherwise ``False``.
|
||||
|
||||
The PID file is “stale” if its contents are valid but do not
|
||||
match the PID of a currently-running process.
|
||||
|
||||
"""
|
||||
result = False
|
||||
|
||||
pidfile_pid = pidfile.read_pid()
|
||||
if pidfile_pid is not None:
|
||||
try:
|
||||
os.kill(pidfile_pid, signal.SIG_DFL)
|
||||
except ProcessLookupError:
|
||||
# The specified PID does not exist.
|
||||
result = True
|
||||
except OSError as exc:
|
||||
if exc.errno == errno.ESRCH:
|
||||
# Under Python 2, process lookup error is an OSError.
|
||||
# The specified PID does not exist.
|
||||
result = True
|
||||
|
||||
return result
|
||||
|
||||
|
||||
# Local variables:
|
||||
# coding: utf-8
|
||||
# mode: python
|
||||
# End:
|
||||
# vim: fileencoding=utf-8 filetype=python :
|
||||
Binary file not shown.
Binary file not shown.
Executable
+5
@@ -0,0 +1,5 @@
|
||||
#!/bin/sh
|
||||
|
||||
|
||||
mkdir $HOME/bin
|
||||
cp -rp hbd hbdclass.py hbc daemon lockfile $HOME/bin/
|
||||
@@ -0,0 +1,347 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
"""
|
||||
lockfile.py - Platform-independent advisory file locks.
|
||||
|
||||
Requires Python 2.5 unless you apply 2.4.diff
|
||||
Locking is done on a per-thread basis instead of a per-process basis.
|
||||
|
||||
Usage:
|
||||
|
||||
>>> lock = LockFile('somefile')
|
||||
>>> try:
|
||||
... lock.acquire()
|
||||
... except AlreadyLocked:
|
||||
... print 'somefile', 'is locked already.'
|
||||
... except LockFailed:
|
||||
... print 'somefile', 'can\\'t be locked.'
|
||||
... else:
|
||||
... print 'got lock'
|
||||
got lock
|
||||
>>> print lock.is_locked()
|
||||
True
|
||||
>>> lock.release()
|
||||
|
||||
>>> lock = LockFile('somefile')
|
||||
>>> print lock.is_locked()
|
||||
False
|
||||
>>> with lock:
|
||||
... print lock.is_locked()
|
||||
True
|
||||
>>> print lock.is_locked()
|
||||
False
|
||||
|
||||
>>> lock = LockFile('somefile')
|
||||
>>> # It is okay to lock twice from the same thread...
|
||||
>>> with lock:
|
||||
... lock.acquire()
|
||||
...
|
||||
>>> # Though no counter is kept, so you can't unlock multiple times...
|
||||
>>> print lock.is_locked()
|
||||
False
|
||||
|
||||
Exceptions:
|
||||
|
||||
Error - base class for other exceptions
|
||||
LockError - base class for all locking exceptions
|
||||
AlreadyLocked - Another thread or process already holds the lock
|
||||
LockFailed - Lock failed for some other reason
|
||||
UnlockError - base class for all unlocking exceptions
|
||||
AlreadyUnlocked - File was not locked.
|
||||
NotMyLock - File was locked but not by the current thread/process
|
||||
"""
|
||||
|
||||
from __future__ import absolute_import
|
||||
|
||||
import functools
|
||||
import os
|
||||
import socket
|
||||
import threading
|
||||
import warnings
|
||||
|
||||
# Work with PEP8 and non-PEP8 versions of threading module.
|
||||
if not hasattr(threading, "current_thread"):
|
||||
threading.current_thread = threading.currentThread
|
||||
if not hasattr(threading.Thread, "get_name"):
|
||||
threading.Thread.get_name = threading.Thread.getName
|
||||
|
||||
__all__ = ['Error', 'LockError', 'LockTimeout', 'AlreadyLocked',
|
||||
'LockFailed', 'UnlockError', 'NotLocked', 'NotMyLock',
|
||||
'LinkFileLock', 'MkdirFileLock', 'SQLiteFileLock',
|
||||
'LockBase', 'locked']
|
||||
|
||||
|
||||
class Error(Exception):
|
||||
"""
|
||||
Base class for other exceptions.
|
||||
|
||||
>>> try:
|
||||
... raise Error
|
||||
... except Exception:
|
||||
... pass
|
||||
"""
|
||||
pass
|
||||
|
||||
|
||||
class LockError(Error):
|
||||
"""
|
||||
Base class for error arising from attempts to acquire the lock.
|
||||
|
||||
>>> try:
|
||||
... raise LockError
|
||||
... except Error:
|
||||
... pass
|
||||
"""
|
||||
pass
|
||||
|
||||
|
||||
class LockTimeout(LockError):
|
||||
"""Raised when lock creation fails within a user-defined period of time.
|
||||
|
||||
>>> try:
|
||||
... raise LockTimeout
|
||||
... except LockError:
|
||||
... pass
|
||||
"""
|
||||
pass
|
||||
|
||||
|
||||
class AlreadyLocked(LockError):
|
||||
"""Some other thread/process is locking the file.
|
||||
|
||||
>>> try:
|
||||
... raise AlreadyLocked
|
||||
... except LockError:
|
||||
... pass
|
||||
"""
|
||||
pass
|
||||
|
||||
|
||||
class LockFailed(LockError):
|
||||
"""Lock file creation failed for some other reason.
|
||||
|
||||
>>> try:
|
||||
... raise LockFailed
|
||||
... except LockError:
|
||||
... pass
|
||||
"""
|
||||
pass
|
||||
|
||||
|
||||
class UnlockError(Error):
|
||||
"""
|
||||
Base class for errors arising from attempts to release the lock.
|
||||
|
||||
>>> try:
|
||||
... raise UnlockError
|
||||
... except Error:
|
||||
... pass
|
||||
"""
|
||||
pass
|
||||
|
||||
|
||||
class NotLocked(UnlockError):
|
||||
"""Raised when an attempt is made to unlock an unlocked file.
|
||||
|
||||
>>> try:
|
||||
... raise NotLocked
|
||||
... except UnlockError:
|
||||
... pass
|
||||
"""
|
||||
pass
|
||||
|
||||
|
||||
class NotMyLock(UnlockError):
|
||||
"""Raised when an attempt is made to unlock a file someone else locked.
|
||||
|
||||
>>> try:
|
||||
... raise NotMyLock
|
||||
... except UnlockError:
|
||||
... pass
|
||||
"""
|
||||
pass
|
||||
|
||||
|
||||
class _SharedBase(object):
|
||||
def __init__(self, path):
|
||||
self.path = path
|
||||
|
||||
def acquire(self, timeout=None):
|
||||
"""
|
||||
Acquire the lock.
|
||||
|
||||
* If timeout is omitted (or None), wait forever trying to lock the
|
||||
file.
|
||||
|
||||
* If timeout > 0, try to acquire the lock for that many seconds. If
|
||||
the lock period expires and the file is still locked, raise
|
||||
LockTimeout.
|
||||
|
||||
* If timeout <= 0, raise AlreadyLocked immediately if the file is
|
||||
already locked.
|
||||
"""
|
||||
raise NotImplemented("implement in subclass")
|
||||
|
||||
def release(self):
|
||||
"""
|
||||
Release the lock.
|
||||
|
||||
If the file is not locked, raise NotLocked.
|
||||
"""
|
||||
raise NotImplemented("implement in subclass")
|
||||
|
||||
def __enter__(self):
|
||||
"""
|
||||
Context manager support.
|
||||
"""
|
||||
self.acquire()
|
||||
return self
|
||||
|
||||
def __exit__(self, *_exc):
|
||||
"""
|
||||
Context manager support.
|
||||
"""
|
||||
self.release()
|
||||
|
||||
def __repr__(self):
|
||||
return "<%s: %r>" % (self.__class__.__name__, self.path)
|
||||
|
||||
|
||||
class LockBase(_SharedBase):
|
||||
"""Base class for platform-specific lock classes."""
|
||||
def __init__(self, path, threaded=True, timeout=None):
|
||||
"""
|
||||
>>> lock = LockBase('somefile')
|
||||
>>> lock = LockBase('somefile', threaded=False)
|
||||
"""
|
||||
super(LockBase, self).__init__(path)
|
||||
self.lock_file = os.path.abspath(path) + ".lock"
|
||||
self.hostname = socket.gethostname()
|
||||
self.pid = os.getpid()
|
||||
if threaded:
|
||||
t = threading.current_thread()
|
||||
# Thread objects in Python 2.4 and earlier do not have ident
|
||||
# attrs. Worm around that.
|
||||
ident = getattr(t, "ident", hash(t))
|
||||
self.tname = "-%x" % (ident & 0xffffffff)
|
||||
else:
|
||||
self.tname = ""
|
||||
dirname = os.path.dirname(self.lock_file)
|
||||
|
||||
# unique name is mostly about the current process, but must
|
||||
# also contain the path -- otherwise, two adjacent locked
|
||||
# files conflict (one file gets locked, creating lock-file and
|
||||
# unique file, the other one gets locked, creating lock-file
|
||||
# and overwriting the already existing lock-file, then one
|
||||
# gets unlocked, deleting both lock-file and unique file,
|
||||
# finally the last lock errors out upon releasing.
|
||||
self.unique_name = os.path.join(dirname,
|
||||
"%s%s.%s%s" % (self.hostname,
|
||||
self.tname,
|
||||
self.pid,
|
||||
hash(self.path)))
|
||||
self.timeout = timeout
|
||||
|
||||
def is_locked(self):
|
||||
"""
|
||||
Tell whether or not the file is locked.
|
||||
"""
|
||||
raise NotImplemented("implement in subclass")
|
||||
|
||||
def i_am_locking(self):
|
||||
"""
|
||||
Return True if this object is locking the file.
|
||||
"""
|
||||
raise NotImplemented("implement in subclass")
|
||||
|
||||
def break_lock(self):
|
||||
"""
|
||||
Remove a lock. Useful if a locking thread failed to unlock.
|
||||
"""
|
||||
raise NotImplemented("implement in subclass")
|
||||
|
||||
def __repr__(self):
|
||||
return "<%s: %r -- %r>" % (self.__class__.__name__, self.unique_name,
|
||||
self.path)
|
||||
|
||||
|
||||
def _fl_helper(cls, mod, *args, **kwds):
|
||||
warnings.warn("Import from %s module instead of lockfile package" % mod,
|
||||
DeprecationWarning, stacklevel=2)
|
||||
# This is a bit funky, but it's only for awhile. The way the unit tests
|
||||
# are constructed this function winds up as an unbound method, so it
|
||||
# actually takes three args, not two. We want to toss out self.
|
||||
if not isinstance(args[0], str):
|
||||
# We are testing, avoid the first arg
|
||||
args = args[1:]
|
||||
if len(args) == 1 and not kwds:
|
||||
kwds["threaded"] = True
|
||||
return cls(*args, **kwds)
|
||||
|
||||
|
||||
def LinkFileLock(*args, **kwds):
|
||||
"""Factory function provided for backwards compatibility.
|
||||
|
||||
Do not use in new code. Instead, import LinkLockFile from the
|
||||
lockfile.linklockfile module.
|
||||
"""
|
||||
from . import linklockfile
|
||||
return _fl_helper(linklockfile.LinkLockFile, "lockfile.linklockfile",
|
||||
*args, **kwds)
|
||||
|
||||
|
||||
def MkdirFileLock(*args, **kwds):
|
||||
"""Factory function provided for backwards compatibility.
|
||||
|
||||
Do not use in new code. Instead, import MkdirLockFile from the
|
||||
lockfile.mkdirlockfile module.
|
||||
"""
|
||||
from . import mkdirlockfile
|
||||
return _fl_helper(mkdirlockfile.MkdirLockFile, "lockfile.mkdirlockfile",
|
||||
*args, **kwds)
|
||||
|
||||
|
||||
def SQLiteFileLock(*args, **kwds):
|
||||
"""Factory function provided for backwards compatibility.
|
||||
|
||||
Do not use in new code. Instead, import SQLiteLockFile from the
|
||||
lockfile.mkdirlockfile module.
|
||||
"""
|
||||
from . import sqlitelockfile
|
||||
return _fl_helper(sqlitelockfile.SQLiteLockFile, "lockfile.sqlitelockfile",
|
||||
*args, **kwds)
|
||||
|
||||
|
||||
def locked(path, timeout=None):
|
||||
"""Decorator which enables locks for decorated function.
|
||||
|
||||
Arguments:
|
||||
- path: path for lockfile.
|
||||
- timeout (optional): Timeout for acquiring lock.
|
||||
|
||||
Usage:
|
||||
@locked('/var/run/myname', timeout=0)
|
||||
def myname(...):
|
||||
...
|
||||
"""
|
||||
def decor(func):
|
||||
@functools.wraps(func)
|
||||
def wrapper(*args, **kwargs):
|
||||
lock = FileLock(path, timeout=timeout)
|
||||
lock.acquire()
|
||||
try:
|
||||
return func(*args, **kwargs)
|
||||
finally:
|
||||
lock.release()
|
||||
return wrapper
|
||||
return decor
|
||||
|
||||
|
||||
if hasattr(os, "link"):
|
||||
from . import linklockfile as _llf
|
||||
LockFile = _llf.LinkLockFile
|
||||
else:
|
||||
from . import mkdirlockfile as _mlf
|
||||
LockFile = _mlf.MkdirLockFile
|
||||
|
||||
FileLock = LockFile
|
||||
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,73 @@
|
||||
from __future__ import absolute_import
|
||||
|
||||
import time
|
||||
import os
|
||||
|
||||
from . import (LockBase, LockFailed, NotLocked, NotMyLock, LockTimeout,
|
||||
AlreadyLocked)
|
||||
|
||||
|
||||
class LinkLockFile(LockBase):
|
||||
"""Lock access to a file using atomic property of link(2).
|
||||
|
||||
>>> lock = LinkLockFile('somefile')
|
||||
>>> lock = LinkLockFile('somefile', threaded=False)
|
||||
"""
|
||||
|
||||
def acquire(self, timeout=None):
|
||||
try:
|
||||
open(self.unique_name, "wb").close()
|
||||
except IOError:
|
||||
raise LockFailed("failed to create %s" % self.unique_name)
|
||||
|
||||
timeout = timeout if timeout is not None else self.timeout
|
||||
end_time = time.time()
|
||||
if timeout is not None and timeout > 0:
|
||||
end_time += timeout
|
||||
|
||||
while True:
|
||||
# Try and create a hard link to it.
|
||||
try:
|
||||
os.link(self.unique_name, self.lock_file)
|
||||
except OSError:
|
||||
# Link creation failed. Maybe we've double-locked?
|
||||
nlinks = os.stat(self.unique_name).st_nlink
|
||||
if nlinks == 2:
|
||||
# The original link plus the one I created == 2. We're
|
||||
# good to go.
|
||||
return
|
||||
else:
|
||||
# Otherwise the lock creation failed.
|
||||
if timeout is not None and time.time() > end_time:
|
||||
os.unlink(self.unique_name)
|
||||
if timeout > 0:
|
||||
raise LockTimeout("Timeout waiting to acquire"
|
||||
" lock for %s" %
|
||||
self.path)
|
||||
else:
|
||||
raise AlreadyLocked("%s is already locked" %
|
||||
self.path)
|
||||
time.sleep(timeout is not None and timeout / 10 or 0.1)
|
||||
else:
|
||||
# Link creation succeeded. We're good to go.
|
||||
return
|
||||
|
||||
def release(self):
|
||||
if not self.is_locked():
|
||||
raise NotLocked("%s is not locked" % self.path)
|
||||
elif not os.path.exists(self.unique_name):
|
||||
raise NotMyLock("%s is locked, but not by me" % self.path)
|
||||
os.unlink(self.unique_name)
|
||||
os.unlink(self.lock_file)
|
||||
|
||||
def is_locked(self):
|
||||
return os.path.exists(self.lock_file)
|
||||
|
||||
def i_am_locking(self):
|
||||
return (self.is_locked() and
|
||||
os.path.exists(self.unique_name) and
|
||||
os.stat(self.unique_name).st_nlink == 2)
|
||||
|
||||
def break_lock(self):
|
||||
if os.path.exists(self.lock_file):
|
||||
os.unlink(self.lock_file)
|
||||
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,84 @@
|
||||
from __future__ import absolute_import, division
|
||||
|
||||
import time
|
||||
import os
|
||||
import sys
|
||||
import errno
|
||||
|
||||
from . import (LockBase, LockFailed, NotLocked, NotMyLock, LockTimeout,
|
||||
AlreadyLocked)
|
||||
|
||||
|
||||
class MkdirLockFile(LockBase):
|
||||
"""Lock file by creating a directory."""
|
||||
def __init__(self, path, threaded=True, timeout=None):
|
||||
"""
|
||||
>>> lock = MkdirLockFile('somefile')
|
||||
>>> lock = MkdirLockFile('somefile', threaded=False)
|
||||
"""
|
||||
LockBase.__init__(self, path, threaded, timeout)
|
||||
# Lock file itself is a directory. Place the unique file name into
|
||||
# it.
|
||||
self.unique_name = os.path.join(self.lock_file,
|
||||
"%s.%s%s" % (self.hostname,
|
||||
self.tname,
|
||||
self.pid))
|
||||
|
||||
def acquire(self, timeout=None):
|
||||
timeout = timeout if timeout is not None else self.timeout
|
||||
end_time = time.time()
|
||||
if timeout is not None and timeout > 0:
|
||||
end_time += timeout
|
||||
|
||||
if timeout is None:
|
||||
wait = 0.1
|
||||
else:
|
||||
wait = max(0, timeout / 10)
|
||||
|
||||
while True:
|
||||
try:
|
||||
os.mkdir(self.lock_file)
|
||||
except OSError:
|
||||
err = sys.exc_info()[1]
|
||||
if err.errno == errno.EEXIST:
|
||||
# Already locked.
|
||||
if os.path.exists(self.unique_name):
|
||||
# Already locked by me.
|
||||
return
|
||||
if timeout is not None and time.time() > end_time:
|
||||
if timeout > 0:
|
||||
raise LockTimeout("Timeout waiting to acquire"
|
||||
" lock for %s" %
|
||||
self.path)
|
||||
else:
|
||||
# Someone else has the lock.
|
||||
raise AlreadyLocked("%s is already locked" %
|
||||
self.path)
|
||||
time.sleep(wait)
|
||||
else:
|
||||
# Couldn't create the lock for some other reason
|
||||
raise LockFailed("failed to create %s" % self.lock_file)
|
||||
else:
|
||||
open(self.unique_name, "wb").close()
|
||||
return
|
||||
|
||||
def release(self):
|
||||
if not self.is_locked():
|
||||
raise NotLocked("%s is not locked" % self.path)
|
||||
elif not os.path.exists(self.unique_name):
|
||||
raise NotMyLock("%s is locked, but not by me" % self.path)
|
||||
os.unlink(self.unique_name)
|
||||
os.rmdir(self.lock_file)
|
||||
|
||||
def is_locked(self):
|
||||
return os.path.exists(self.lock_file)
|
||||
|
||||
def i_am_locking(self):
|
||||
return (self.is_locked() and
|
||||
os.path.exists(self.unique_name))
|
||||
|
||||
def break_lock(self):
|
||||
if os.path.exists(self.lock_file):
|
||||
for name in os.listdir(self.lock_file):
|
||||
os.unlink(os.path.join(self.lock_file, name))
|
||||
os.rmdir(self.lock_file)
|
||||
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,190 @@
|
||||
# -*- coding: utf-8 -*-
|
||||
|
||||
# pidlockfile.py
|
||||
#
|
||||
# Copyright © 2008–2009 Ben Finney <ben+python@benfinney.id.au>
|
||||
#
|
||||
# This is free software: you may copy, modify, and/or distribute this work
|
||||
# under the terms of the Python Software Foundation License, version 2 or
|
||||
# later as published by the Python Software Foundation.
|
||||
# No warranty expressed or implied. See the file LICENSE.PSF-2 for details.
|
||||
|
||||
""" Lockfile behaviour implemented via Unix PID files.
|
||||
"""
|
||||
|
||||
from __future__ import absolute_import
|
||||
|
||||
import errno
|
||||
import os
|
||||
import time
|
||||
|
||||
from . import (LockBase, AlreadyLocked, LockFailed, NotLocked, NotMyLock,
|
||||
LockTimeout)
|
||||
|
||||
|
||||
class PIDLockFile(LockBase):
|
||||
""" Lockfile implemented as a Unix PID file.
|
||||
|
||||
The lock file is a normal file named by the attribute `path`.
|
||||
A lock's PID file contains a single line of text, containing
|
||||
the process ID (PID) of the process that acquired the lock.
|
||||
|
||||
>>> lock = PIDLockFile('somefile')
|
||||
>>> lock = PIDLockFile('somefile')
|
||||
"""
|
||||
|
||||
def __init__(self, path, threaded=False, timeout=None):
|
||||
# pid lockfiles don't support threaded operation, so always force
|
||||
# False as the threaded arg.
|
||||
LockBase.__init__(self, path, False, timeout)
|
||||
self.unique_name = self.path
|
||||
|
||||
def read_pid(self):
|
||||
""" Get the PID from the lock file.
|
||||
"""
|
||||
return read_pid_from_pidfile(self.path)
|
||||
|
||||
def is_locked(self):
|
||||
""" Test if the lock is currently held.
|
||||
|
||||
The lock is held if the PID file for this lock exists.
|
||||
|
||||
"""
|
||||
return os.path.exists(self.path)
|
||||
|
||||
def i_am_locking(self):
|
||||
""" Test if the lock is held by the current process.
|
||||
|
||||
Returns ``True`` if the current process ID matches the
|
||||
number stored in the PID file.
|
||||
"""
|
||||
return self.is_locked() and os.getpid() == self.read_pid()
|
||||
|
||||
def acquire(self, timeout=None):
|
||||
""" Acquire the lock.
|
||||
|
||||
Creates the PID file for this lock, or raises an error if
|
||||
the lock could not be acquired.
|
||||
"""
|
||||
|
||||
timeout = timeout if timeout is not None else self.timeout
|
||||
end_time = time.time()
|
||||
if timeout is not None and timeout > 0:
|
||||
end_time += timeout
|
||||
|
||||
while True:
|
||||
try:
|
||||
write_pid_to_pidfile(self.path)
|
||||
except OSError as exc:
|
||||
if exc.errno == errno.EEXIST:
|
||||
# The lock creation failed. Maybe sleep a bit.
|
||||
if time.time() > end_time:
|
||||
if timeout is not None and timeout > 0:
|
||||
raise LockTimeout("Timeout waiting to acquire"
|
||||
" lock for %s" %
|
||||
self.path)
|
||||
else:
|
||||
raise AlreadyLocked("%s is already locked" %
|
||||
self.path)
|
||||
time.sleep(timeout is not None and timeout / 10 or 0.1)
|
||||
else:
|
||||
raise LockFailed("failed to create %s" % self.path)
|
||||
else:
|
||||
return
|
||||
|
||||
def release(self):
|
||||
""" Release the lock.
|
||||
|
||||
Removes the PID file to release the lock, or raises an
|
||||
error if the current process does not hold the lock.
|
||||
|
||||
"""
|
||||
if not self.is_locked():
|
||||
raise NotLocked("%s is not locked" % self.path)
|
||||
if not self.i_am_locking():
|
||||
raise NotMyLock("%s is locked, but not by me" % self.path)
|
||||
remove_existing_pidfile(self.path)
|
||||
|
||||
def break_lock(self):
|
||||
""" Break an existing lock.
|
||||
|
||||
Removes the PID file if it already exists, otherwise does
|
||||
nothing.
|
||||
|
||||
"""
|
||||
remove_existing_pidfile(self.path)
|
||||
|
||||
|
||||
def read_pid_from_pidfile(pidfile_path):
|
||||
""" Read the PID recorded in the named PID file.
|
||||
|
||||
Read and return the numeric PID recorded as text in the named
|
||||
PID file. If the PID file cannot be read, or if the content is
|
||||
not a valid PID, return ``None``.
|
||||
|
||||
"""
|
||||
pid = None
|
||||
try:
|
||||
pidfile = open(pidfile_path, 'r')
|
||||
except IOError:
|
||||
pass
|
||||
else:
|
||||
# According to the FHS 2.3 section on PID files in /var/run:
|
||||
#
|
||||
# The file must consist of the process identifier in
|
||||
# ASCII-encoded decimal, followed by a newline character.
|
||||
#
|
||||
# Programs that read PID files should be somewhat flexible
|
||||
# in what they accept; i.e., they should ignore extra
|
||||
# whitespace, leading zeroes, absence of the trailing
|
||||
# newline, or additional lines in the PID file.
|
||||
|
||||
line = pidfile.readline().strip()
|
||||
try:
|
||||
pid = int(line)
|
||||
except ValueError:
|
||||
pass
|
||||
pidfile.close()
|
||||
|
||||
return pid
|
||||
|
||||
|
||||
def write_pid_to_pidfile(pidfile_path):
|
||||
""" Write the PID in the named PID file.
|
||||
|
||||
Get the numeric process ID (“PID”) of the current process
|
||||
and write it to the named file as a line of text.
|
||||
|
||||
"""
|
||||
open_flags = (os.O_CREAT | os.O_EXCL | os.O_WRONLY)
|
||||
open_mode = 0o644
|
||||
pidfile_fd = os.open(pidfile_path, open_flags, open_mode)
|
||||
pidfile = os.fdopen(pidfile_fd, 'w')
|
||||
|
||||
# According to the FHS 2.3 section on PID files in /var/run:
|
||||
#
|
||||
# The file must consist of the process identifier in
|
||||
# ASCII-encoded decimal, followed by a newline character. For
|
||||
# example, if crond was process number 25, /var/run/crond.pid
|
||||
# would contain three characters: two, five, and newline.
|
||||
|
||||
pid = os.getpid()
|
||||
pidfile.write("%s\n" % pid)
|
||||
pidfile.close()
|
||||
|
||||
|
||||
def remove_existing_pidfile(pidfile_path):
|
||||
""" Remove the named PID file if it exists.
|
||||
|
||||
Removing a PID file that doesn't already exist puts us in the
|
||||
desired state, so we ignore the condition if the file does not
|
||||
exist.
|
||||
|
||||
"""
|
||||
try:
|
||||
os.remove(pidfile_path)
|
||||
except OSError as exc:
|
||||
if exc.errno == errno.ENOENT:
|
||||
pass
|
||||
else:
|
||||
raise
|
||||
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,156 @@
|
||||
from __future__ import absolute_import, division
|
||||
|
||||
import time
|
||||
import os
|
||||
|
||||
try:
|
||||
unicode
|
||||
except NameError:
|
||||
unicode = str
|
||||
|
||||
from . import LockBase, NotLocked, NotMyLock, LockTimeout, AlreadyLocked
|
||||
|
||||
|
||||
class SQLiteLockFile(LockBase):
|
||||
"Demonstrate SQL-based locking."
|
||||
|
||||
testdb = None
|
||||
|
||||
def __init__(self, path, threaded=True, timeout=None):
|
||||
"""
|
||||
>>> lock = SQLiteLockFile('somefile')
|
||||
>>> lock = SQLiteLockFile('somefile', threaded=False)
|
||||
"""
|
||||
LockBase.__init__(self, path, threaded, timeout)
|
||||
self.lock_file = unicode(self.lock_file)
|
||||
self.unique_name = unicode(self.unique_name)
|
||||
|
||||
if SQLiteLockFile.testdb is None:
|
||||
import tempfile
|
||||
_fd, testdb = tempfile.mkstemp()
|
||||
os.close(_fd)
|
||||
os.unlink(testdb)
|
||||
del _fd, tempfile
|
||||
SQLiteLockFile.testdb = testdb
|
||||
|
||||
import sqlite3
|
||||
self.connection = sqlite3.connect(SQLiteLockFile.testdb)
|
||||
|
||||
c = self.connection.cursor()
|
||||
try:
|
||||
c.execute("create table locks"
|
||||
"("
|
||||
" lock_file varchar(32),"
|
||||
" unique_name varchar(32)"
|
||||
")")
|
||||
except sqlite3.OperationalError:
|
||||
pass
|
||||
else:
|
||||
self.connection.commit()
|
||||
import atexit
|
||||
atexit.register(os.unlink, SQLiteLockFile.testdb)
|
||||
|
||||
def acquire(self, timeout=None):
|
||||
timeout = timeout if timeout is not None else self.timeout
|
||||
end_time = time.time()
|
||||
if timeout is not None and timeout > 0:
|
||||
end_time += timeout
|
||||
|
||||
if timeout is None:
|
||||
wait = 0.1
|
||||
elif timeout <= 0:
|
||||
wait = 0
|
||||
else:
|
||||
wait = timeout / 10
|
||||
|
||||
cursor = self.connection.cursor()
|
||||
|
||||
while True:
|
||||
if not self.is_locked():
|
||||
# Not locked. Try to lock it.
|
||||
cursor.execute("insert into locks"
|
||||
" (lock_file, unique_name)"
|
||||
" values"
|
||||
" (?, ?)",
|
||||
(self.lock_file, self.unique_name))
|
||||
self.connection.commit()
|
||||
|
||||
# Check to see if we are the only lock holder.
|
||||
cursor.execute("select * from locks"
|
||||
" where unique_name = ?",
|
||||
(self.unique_name,))
|
||||
rows = cursor.fetchall()
|
||||
if len(rows) > 1:
|
||||
# Nope. Someone else got there. Remove our lock.
|
||||
cursor.execute("delete from locks"
|
||||
" where unique_name = ?",
|
||||
(self.unique_name,))
|
||||
self.connection.commit()
|
||||
else:
|
||||
# Yup. We're done, so go home.
|
||||
return
|
||||
else:
|
||||
# Check to see if we are the only lock holder.
|
||||
cursor.execute("select * from locks"
|
||||
" where unique_name = ?",
|
||||
(self.unique_name,))
|
||||
rows = cursor.fetchall()
|
||||
if len(rows) == 1:
|
||||
# We're the locker, so go home.
|
||||
return
|
||||
|
||||
# Maybe we should wait a bit longer.
|
||||
if timeout is not None and time.time() > end_time:
|
||||
if timeout > 0:
|
||||
# No more waiting.
|
||||
raise LockTimeout("Timeout waiting to acquire"
|
||||
" lock for %s" %
|
||||
self.path)
|
||||
else:
|
||||
# Someone else has the lock and we are impatient..
|
||||
raise AlreadyLocked("%s is already locked" % self.path)
|
||||
|
||||
# Well, okay. We'll give it a bit longer.
|
||||
time.sleep(wait)
|
||||
|
||||
def release(self):
|
||||
if not self.is_locked():
|
||||
raise NotLocked("%s is not locked" % self.path)
|
||||
if not self.i_am_locking():
|
||||
raise NotMyLock("%s is locked, but not by me (by %s)" %
|
||||
(self.unique_name, self._who_is_locking()))
|
||||
cursor = self.connection.cursor()
|
||||
cursor.execute("delete from locks"
|
||||
" where unique_name = ?",
|
||||
(self.unique_name,))
|
||||
self.connection.commit()
|
||||
|
||||
def _who_is_locking(self):
|
||||
cursor = self.connection.cursor()
|
||||
cursor.execute("select unique_name from locks"
|
||||
" where lock_file = ?",
|
||||
(self.lock_file,))
|
||||
return cursor.fetchone()[0]
|
||||
|
||||
def is_locked(self):
|
||||
cursor = self.connection.cursor()
|
||||
cursor.execute("select * from locks"
|
||||
" where lock_file = ?",
|
||||
(self.lock_file,))
|
||||
rows = cursor.fetchall()
|
||||
return not not rows
|
||||
|
||||
def i_am_locking(self):
|
||||
cursor = self.connection.cursor()
|
||||
cursor.execute("select * from locks"
|
||||
" where lock_file = ?"
|
||||
" and unique_name = ?",
|
||||
(self.lock_file, self.unique_name))
|
||||
return not not cursor.fetchall()
|
||||
|
||||
def break_lock(self):
|
||||
cursor = self.connection.cursor()
|
||||
cursor.execute("delete from locks"
|
||||
" where lock_file = ?",
|
||||
(self.lock_file,))
|
||||
self.connection.commit()
|
||||
Binary file not shown.
Binary file not shown.
@@ -0,0 +1,70 @@
|
||||
from __future__ import absolute_import
|
||||
|
||||
import os
|
||||
import time
|
||||
|
||||
from . import (LockBase, NotLocked, NotMyLock, LockTimeout,
|
||||
AlreadyLocked)
|
||||
|
||||
|
||||
class SymlinkLockFile(LockBase):
|
||||
"""Lock access to a file using symlink(2)."""
|
||||
|
||||
def __init__(self, path, threaded=True, timeout=None):
|
||||
# super(SymlinkLockFile).__init(...)
|
||||
LockBase.__init__(self, path, threaded, timeout)
|
||||
# split it back!
|
||||
self.unique_name = os.path.split(self.unique_name)[1]
|
||||
|
||||
def acquire(self, timeout=None):
|
||||
# Hopefully unnecessary for symlink.
|
||||
# try:
|
||||
# open(self.unique_name, "wb").close()
|
||||
# except IOError:
|
||||
# raise LockFailed("failed to create %s" % self.unique_name)
|
||||
timeout = timeout if timeout is not None else self.timeout
|
||||
end_time = time.time()
|
||||
if timeout is not None and timeout > 0:
|
||||
end_time += timeout
|
||||
|
||||
while True:
|
||||
# Try and create a symbolic link to it.
|
||||
try:
|
||||
os.symlink(self.unique_name, self.lock_file)
|
||||
except OSError:
|
||||
# Link creation failed. Maybe we've double-locked?
|
||||
if self.i_am_locking():
|
||||
# Linked to out unique name. Proceed.
|
||||
return
|
||||
else:
|
||||
# Otherwise the lock creation failed.
|
||||
if timeout is not None and time.time() > end_time:
|
||||
if timeout > 0:
|
||||
raise LockTimeout("Timeout waiting to acquire"
|
||||
" lock for %s" %
|
||||
self.path)
|
||||
else:
|
||||
raise AlreadyLocked("%s is already locked" %
|
||||
self.path)
|
||||
time.sleep(timeout / 10 if timeout is not None else 0.1)
|
||||
else:
|
||||
# Link creation succeeded. We're good to go.
|
||||
return
|
||||
|
||||
def release(self):
|
||||
if not self.is_locked():
|
||||
raise NotLocked("%s is not locked" % self.path)
|
||||
elif not self.i_am_locking():
|
||||
raise NotMyLock("%s is locked, but not by me" % self.path)
|
||||
os.unlink(self.lock_file)
|
||||
|
||||
def is_locked(self):
|
||||
return os.path.islink(self.lock_file)
|
||||
|
||||
def i_am_locking(self):
|
||||
return (os.path.islink(self.lock_file)
|
||||
and os.readlink(self.lock_file) == self.unique_name)
|
||||
|
||||
def break_lock(self):
|
||||
if os.path.islink(self.lock_file): # exists && link
|
||||
os.unlink(self.lock_file)
|
||||
Binary file not shown.
Binary file not shown.
Reference in New Issue
Block a user