diff options
| -rw-r--r-- | bitbake/lib/bb/daemonize.py | 148 |
1 files changed, 14 insertions, 134 deletions
diff --git a/bitbake/lib/bb/daemonize.py b/bitbake/lib/bb/daemonize.py index a4664ad76b..a5a9d868d0 100644 --- a/bitbake/lib/bb/daemonize.py +++ b/bitbake/lib/bb/daemonize.py | |||
| @@ -1,51 +1,15 @@ | |||
| 1 | """ | 1 | """ |
| 2 | Python Daemonizing helper | 2 | Python Daemonizing helper |
| 3 | 3 | ||
| 4 | Configurable daemon behaviors: | 4 | Originally based on code Copyright (C) 2005 Chad J. Schroeder but now heavily modified |
| 5 | 5 | to allow a function to be daemonized and return for bitbake use by Richard Purdie | |
| 6 | 1.) The current working directory set to the "/" directory. | ||
| 7 | 2.) The current file creation mode mask set to 0. | ||
| 8 | 3.) Close all open files (1024). | ||
| 9 | 4.) Redirect standard I/O streams to "/dev/null". | ||
| 10 | |||
| 11 | A failed call to fork() now raises an exception. | ||
| 12 | |||
| 13 | References: | ||
| 14 | 1) Advanced Programming in the Unix Environment: W. Richard Stevens | ||
| 15 | http://www.apuebook.com/apue3e.html | ||
| 16 | 2) The Linux Programming Interface: Michael Kerrisk | ||
| 17 | http://man7.org/tlpi/index.html | ||
| 18 | 3) Unix Programming Frequently Asked Questions: | ||
| 19 | http://www.faqs.org/faqs/unix-faq/programmer/faq/ | ||
| 20 | |||
| 21 | Modified to allow a function to be daemonized and return for | ||
| 22 | bitbake use by Richard Purdie | ||
| 23 | """ | 6 | """ |
| 24 | 7 | ||
| 25 | __author__ = "Chad J. Schroeder" | 8 | import os |
| 26 | __copyright__ = "Copyright (C) 2005 Chad J. Schroeder" | 9 | import sys |
| 27 | __version__ = "0.2" | ||
| 28 | |||
| 29 | # Standard Python modules. | ||
| 30 | import os # Miscellaneous OS interfaces. | ||
| 31 | import sys # System-specific parameters and functions. | ||
| 32 | import io | 10 | import io |
| 33 | import traceback | 11 | import traceback |
| 34 | 12 | ||
| 35 | # Default daemon parameters. | ||
| 36 | # File mode creation mask of the daemon. | ||
| 37 | # For BitBake's children, we do want to inherit the parent umask. | ||
| 38 | UMASK = None | ||
| 39 | |||
| 40 | # Default maximum for the number of available file descriptors. | ||
| 41 | MAXFD = 1024 | ||
| 42 | |||
| 43 | # The standard I/O file descriptors are redirected to /dev/null by default. | ||
| 44 | if (hasattr(os, "devnull")): | ||
| 45 | REDIRECT_TO = os.devnull | ||
| 46 | else: | ||
| 47 | REDIRECT_TO = "/dev/null" | ||
| 48 | |||
| 49 | def createDaemon(function, logfile): | 13 | def createDaemon(function, logfile): |
| 50 | """ | 14 | """ |
| 51 | Detach a process from the controlling terminal and run it in the | 15 | Detach a process from the controlling terminal and run it in the |
| @@ -67,36 +31,6 @@ def createDaemon(function, logfile): | |||
| 67 | # leader of the new process group, we call os.setsid(). The process is | 31 | # leader of the new process group, we call os.setsid(). The process is |
| 68 | # also guaranteed not to have a controlling terminal. | 32 | # also guaranteed not to have a controlling terminal. |
| 69 | os.setsid() | 33 | os.setsid() |
| 70 | |||
| 71 | # Is ignoring SIGHUP necessary? | ||
| 72 | # | ||
| 73 | # It's often suggested that the SIGHUP signal should be ignored before | ||
| 74 | # the second fork to avoid premature termination of the process. The | ||
| 75 | # reason is that when the first child terminates, all processes, e.g. | ||
| 76 | # the second child, in the orphaned group will be sent a SIGHUP. | ||
| 77 | # | ||
| 78 | # "However, as part of the session management system, there are exactly | ||
| 79 | # two cases where SIGHUP is sent on the death of a process: | ||
| 80 | # | ||
| 81 | # 1) When the process that dies is the session leader of a session that | ||
| 82 | # is attached to a terminal device, SIGHUP is sent to all processes | ||
| 83 | # in the foreground process group of that terminal device. | ||
| 84 | # 2) When the death of a process causes a process group to become | ||
| 85 | # orphaned, and one or more processes in the orphaned group are | ||
| 86 | # stopped, then SIGHUP and SIGCONT are sent to all members of the | ||
| 87 | # orphaned group." [2] | ||
| 88 | # | ||
| 89 | # The first case can be ignored since the child is guaranteed not to have | ||
| 90 | # a controlling terminal. The second case isn't so easy to dismiss. | ||
| 91 | # The process group is orphaned when the first child terminates and | ||
| 92 | # POSIX.1 requires that every STOPPED process in an orphaned process | ||
| 93 | # group be sent a SIGHUP signal followed by a SIGCONT signal. Since the | ||
| 94 | # second child is not STOPPED though, we can safely forego ignoring the | ||
| 95 | # SIGHUP signal. In any case, there are no ill-effects if it is ignored. | ||
| 96 | # | ||
| 97 | # import signal # Set handlers for asynchronous events. | ||
| 98 | # signal.signal(signal.SIGHUP, signal.SIG_IGN) | ||
| 99 | |||
| 100 | try: | 34 | try: |
| 101 | # Fork a second child and exit immediately to prevent zombies. This | 35 | # Fork a second child and exit immediately to prevent zombies. This |
| 102 | # causes the second child process to be orphaned, making the init | 36 | # causes the second child process to be orphaned, making the init |
| @@ -110,77 +44,23 @@ def createDaemon(function, logfile): | |||
| 110 | except OSError as e: | 44 | except OSError as e: |
| 111 | raise Exception("%s [%d]" % (e.strerror, e.errno)) | 45 | raise Exception("%s [%d]" % (e.strerror, e.errno)) |
| 112 | 46 | ||
| 113 | if (pid == 0): # The second child. | 47 | if (pid != 0): |
| 114 | # We probably don't want the file mode creation mask inherited from | ||
| 115 | # the parent, so we give the child complete control over permissions. | ||
| 116 | if UMASK is not None: | ||
| 117 | os.umask(UMASK) | ||
| 118 | else: | ||
| 119 | # Parent (the first child) of the second child. | 48 | # Parent (the first child) of the second child. |
| 49 | # exit() or _exit()? | ||
| 50 | # _exit is like exit(), but it doesn't call any functions registered | ||
| 51 | # with atexit (and on_exit) or any registered signal handlers. It also | ||
| 52 | # closes any open file descriptors. Using exit() may cause all stdio | ||
| 53 | # streams to be flushed twice and any temporary files may be unexpectedly | ||
| 54 | # removed. It's therefore recommended that child branches of a fork() | ||
| 55 | # and the parent branch(es) of a daemon use _exit(). | ||
| 120 | os._exit(0) | 56 | os._exit(0) |
| 121 | else: | 57 | else: |
| 122 | # exit() or _exit()? | ||
| 123 | # _exit is like exit(), but it doesn't call any functions registered | ||
| 124 | # with atexit (and on_exit) or any registered signal handlers. It also | ||
| 125 | # closes any open file descriptors. Using exit() may cause all stdio | ||
| 126 | # streams to be flushed twice and any temporary files may be unexpectedly | ||
| 127 | # removed. It's therefore recommended that child branches of a fork() | ||
| 128 | # and the parent branch(es) of a daemon use _exit(). | ||
| 129 | os.waitpid(pid, 0) | 58 | os.waitpid(pid, 0) |
| 130 | return | 59 | return |
| 131 | 60 | ||
| 132 | # Close all open file descriptors. This prevents the child from keeping | 61 | # The second child. |
| 133 | # open any file descriptors inherited from the parent. There is a variety | ||
| 134 | # of methods to accomplish this task. Three are listed below. | ||
| 135 | # | ||
| 136 | # Try the system configuration variable, SC_OPEN_MAX, to obtain the maximum | ||
| 137 | # number of open file descriptors to close. If it doesn't exist, use | ||
| 138 | # the default value (configurable). | ||
| 139 | # | ||
| 140 | # try: | ||
| 141 | # maxfd = os.sysconf("SC_OPEN_MAX") | ||
| 142 | # except (AttributeError, ValueError): | ||
| 143 | # maxfd = MAXFD | ||
| 144 | # | ||
| 145 | # OR | ||
| 146 | # | ||
| 147 | # if (os.sysconf_names.has_key("SC_OPEN_MAX")): | ||
| 148 | # maxfd = os.sysconf("SC_OPEN_MAX") | ||
| 149 | # else: | ||
| 150 | # maxfd = MAXFD | ||
| 151 | # | ||
| 152 | # OR | ||
| 153 | # | ||
| 154 | # Use the getrlimit method to retrieve the maximum file descriptor number | ||
| 155 | # that can be opened by this process. If there is no limit on the | ||
| 156 | # resource, use the default value. | ||
| 157 | # | ||
| 158 | import resource # Resource usage information. | ||
| 159 | maxfd = resource.getrlimit(resource.RLIMIT_NOFILE)[1] | ||
| 160 | if (maxfd == resource.RLIM_INFINITY): | ||
| 161 | maxfd = MAXFD | ||
| 162 | |||
| 163 | # Iterate through and close all file descriptors. | ||
| 164 | # for fd in range(0, maxfd): | ||
| 165 | # try: | ||
| 166 | # os.close(fd) | ||
| 167 | # except OSError: # ERROR, fd wasn't open to begin with (ignored) | ||
| 168 | # pass | ||
| 169 | |||
| 170 | # Redirect the standard I/O file descriptors to the specified file. Since | ||
| 171 | # the daemon has no controlling terminal, most daemons redirect stdin, | ||
| 172 | # stdout, and stderr to /dev/null. This is done to prevent side-effects | ||
| 173 | # from reads and writes to the standard I/O file descriptors. | ||
| 174 | |||
| 175 | # This call to open is guaranteed to return the lowest file descriptor, | ||
| 176 | # which will be 0 (stdin), since it was closed above. | ||
| 177 | # os.open(REDIRECT_TO, os.O_RDWR) # standard input (0) | ||
| 178 | |||
| 179 | # Duplicate standard input to standard output and standard error. | ||
| 180 | # os.dup2(0, 1) # standard output (1) | ||
| 181 | # os.dup2(0, 2) # standard error (2) | ||
| 182 | 62 | ||
| 183 | # Replace those fds with our own | 63 | # Replace standard fds with our own |
| 184 | si = open('/dev/null', 'r') | 64 | si = open('/dev/null', 'r') |
| 185 | os.dup2(si.fileno(), sys.stdin.fileno()) | 65 | os.dup2(si.fileno(), sys.stdin.fileno()) |
| 186 | 66 | ||
