Lines 76-93
class MyRequestHandler(SocketServer.BaseRequestHandler):
|
Link Here
|
---|
|
76 |
pass |
76 |
pass |
77 |
|
77 |
|
78 |
|
78 |
|
79 |
class ForkingTCPServer(SocketServer.ForkingTCPServer): |
79 |
class ForkingServer(SocketServer.UnixStreamServer, SocketServer.ForkingMixIn): |
80 |
|
80 |
|
81 |
"""UDM server listening on UNIX socket.""" |
81 |
"""UDM server listening on UNIX socket.""" |
82 |
address_family = socket.AF_UNIX |
82 |
address_family = socket.AF_UNIX |
83 |
allow_reuse_address = 1 |
|
|
84 |
|
85 |
def server_bind(self): |
86 |
SocketServer.TCPServer.server_bind(self) |
87 |
_host, port = self.socket.getsockname()[:2] |
88 |
self.server_name = 'localhost' # socket.getfqdn(host) |
89 |
self.server_port = port |
90 |
|
91 |
|
83 |
|
92 |
def server_main(args): |
84 |
def server_main(args): |
93 |
"""UDM command line server.""" |
85 |
"""UDM command line server.""" |
Lines 138-144
def server_main(args):
|
Link Here
|
---|
|
138 |
ud.debug(ud.ADMIN, ud.WARN, 'daemon [%s] baseconfig key directory/manager/cmd/timeout not set, setting to default (%s seconds)' % (os.getpid(), timeout)) |
130 |
ud.debug(ud.ADMIN, ud.WARN, 'daemon [%s] baseconfig key directory/manager/cmd/timeout not set, setting to default (%s seconds)' % (os.getpid(), timeout)) |
139 |
|
131 |
|
140 |
try: |
132 |
try: |
141 |
sock = ForkingTCPServer(socket_path, MyRequestHandler) |
133 |
sock = ForkingServer(socket_path, MyRequestHandler) |
142 |
os.chmod(socket_path, 0o600) |
134 |
os.chmod(socket_path, 0o600) |
143 |
except: |
135 |
except: |
144 |
print >> sys.stderr, 'E: Failed creating socket (%s). Daemon stopped.' % socket_path |
136 |
print >> sys.stderr, 'E: Failed creating socket (%s). Daemon stopped.' % socket_path |
Lines 153-158
def server_main(args):
|
Link Here
|
---|
|
153 |
except IOError: |
145 |
except IOError: |
154 |
print >> sys.stderr, 'E: Can`t write runfile' |
146 |
print >> sys.stderr, 'E: Can`t write runfile' |
155 |
|
147 |
|
|
|
148 |
signal.signal(signal.SIGTERM, lambda s, f: sys.exit(1)) |
156 |
try: |
149 |
try: |
157 |
while True: |
150 |
while True: |
158 |
rlist, _wlist, _xlist = select([sock], [], [], float(timeout)) |
151 |
rlist, _wlist, _xlist = select([sock], [], [], float(timeout)) |