/usr/lib/tuned/pmqos-static.py is in tuned-utils 2.9.0-1.
This file is owned by root:root, with mode 0o755.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 | #!/usr/bin/python
#
# pmqos-static.py: Simple daemon for setting static PM QoS values. It is a part
# of 'tuned' and it should not be called manually.
#
# Copyright (C) 2011 Red Hat, Inc.
# Authors: Jan Vcelak <jvcelak@redhat.com>
#
# This program is free software; you can redistribute it and/or
# modify it under the terms of the GNU General Public License
# as published by the Free Software Foundation; either version 2
# of the License, or (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
#
import os
import signal
import struct
import sys
import time
# Used interface is described in Linux kernel documentation:
# Documentation/power/pm_qos_interface.txt
ALLOWED_INTERFACES = [ "cpu_dma_latency", "network_latency", "network_throughput" ]
PIDFILE = "/var/run/tuned/pmqos-static.pid"
def do_fork():
pid = os.fork()
if pid > 0:
sys.exit(0)
def close_fds():
s_in = file('/dev/null', 'r')
s_out = file('/dev/null', 'a+')
s_err = file('/dev/null', 'a+', 0)
os.dup2(s_in.fileno(), sys.stdin.fileno())
os.dup2(s_out.fileno(), sys.stdout.fileno())
os.dup2(s_err.fileno(), sys.stderr.fileno())
def write_pidfile():
f = os.open(PIDFILE, os.O_CREAT | os.O_TRUNC | os.O_WRONLY, 0644)
os.write(f, "%d" % os.getpid())
os.close(f)
def daemonize():
do_fork()
os.chdir("/")
os.setsid()
os.umask(0)
do_fork()
close_fds()
def set_pmqos(name, value):
filename = "/dev/%s" % name
bin_value = struct.pack("i", int(value))
try:
fd = os.open(filename, os.O_WRONLY)
except OSError:
print >>sys.stderr, "Cannot open (%s)." % filename
return None
os.write(fd, bin_value)
return fd
def sleep_forever():
while True:
time.sleep(86400)
def sigterm_handler(signum, frame):
global pmqos_fds
if type(pmqos_fds) is list:
for fd in pmqos_fds:
os.close(fd)
sys.exit(0)
def run_daemon(options):
try:
daemonize()
write_pidfile()
signal.signal(signal.SIGTERM, sigterm_handler)
except Exception, e:
print >>sys.stderr, "Cannot daemonize (%s)." % e
return False
global pmqos_fds
pmqos_fds = []
for (name, value) in options.items():
try:
new_fd = set_pmqos(name, value)
if new_fd is not None:
pmqos_fds.append(new_fd)
except:
# we are daemonized
pass
if len(pmqos_fds) > 0:
sleep_forever()
else:
return False
def kill_daemon(force = False):
try:
with open(PIDFILE, "r") as pidfile:
daemon_pid = int(pidfile.read())
except IOError, e:
if not force: print >>sys.stderr, "Cannot open PID file (%s)." % e
return False
try:
os.kill(daemon_pid, signal.SIGTERM)
except OSError, e:
if not force: print >>sys.stderr, "Cannot terminate the daemon (%s)." % e
return False
try:
os.unlink(PIDFILE)
except OSError, e:
if not force: print >>sys.stderr, "Cannot delete the PID file (%s)." % e
return False
return True
if __name__ == "__main__":
disable = False
options = {}
for option in sys.argv[1:]:
if option == "disable":
disable = True
break
try:
(name, value) = option.split("=")
except ValueError:
name = option
value = None
if name in ALLOWED_INTERFACES and len(value) > 0:
options[name] = value
else:
print >>sys.stderr, "Invalid option (%s)." % option
if disable:
sys.exit(0 if kill_daemon() else 1)
if len(options) == 0:
print >>sys.stderr, "No options set. Not starting."
sys.exit(1)
kill_daemon(True)
run_daemon(options)
sys.exit(1)
|