Revision f93f2016 daemons/ganeti-masterd
b/daemons/ganeti-masterd | ||
---|---|---|
108 | 108 |
"""Add task to workerpool to process request. |
109 | 109 |
|
110 | 110 |
""" |
111 |
(pid, uid, gid) = utils.GetSocketCredentials(request) |
|
112 |
logging.info("Accepted connection from pid=%s, uid=%s, gid=%s", |
|
113 |
pid, uid, gid) |
|
114 |
|
|
111 | 115 |
self.request_workers.AddTask(self, request, client_address) |
112 | 116 |
|
117 |
def handle_error(self, request, client_address): |
|
118 |
logging.exception("Error while handling request") |
|
119 |
|
|
113 | 120 |
@utils.SignalHandled([signal.SIGINT, signal.SIGTERM]) |
114 | 121 |
def serve_forever(self, signal_handlers=None): # pylint: disable-msg=W0221 |
115 | 122 |
"""Handle one request at a time until told to quit.""" |
Also available in: Unified diff