Khaganat-NeL/opennel-pymanager
Khaganat-NeL/opennel-pymanager
2
0
Fork 0
Code Issues 3 Pull requests Projects Releases Packages Wiki Activity

#88 - ignore BrokenPipeError

Browse source
This commit is contained in:
AleaJactaEst 2019-04-07 11:33:54 +02:00
parent 27e0b30541
commit dab22737c7
1 changed files with 37 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

44
pymanager/manager.py
View file

@ -275,8 +275,13 @@ class ManageHttpRequest(http.server.SimpleHTTPRequestHandler):
return return
self.server.listSemaphore[name].release() self.server.listSemaphore[name].release()
self._set_headers() self._set_headers()
self.wfile.write(bytes(json.dumps(item), "utf-8")) try:
logging.debug("item : %s" % item) self.wfile.write(bytes(json.dumps(item), "utf-8"))
logging.debug("item : %s" % item)
except BrokenPipeError:
# ignore BrokenPipeError: [Errno 32] Broken pipe
logging.debug("BrokenPipeError detected")
pass
def _send_list(self): def _send_list(self):
""" sub-request to list all program available """ """ sub-request to list all program available """
@ -286,7 +291,12 @@ class ManageHttpRequest(http.server.SimpleHTTPRequestHandler):
outjson.setdefault(pos, program) outjson.setdefault(pos, program)
pos += 1 pos += 1
self._set_headers() self._set_headers()
self.wfile.write(bytes(json.dumps(outjson), "utf-8")) try:
self.wfile.write(bytes(json.dumps(outjson), "utf-8"))
except BrokenPipeError:
# ignore BrokenPipeError: [Errno 32] Broken pipe
logging.debug("BrokenPipeError detected")
pass
def _send_shutdown(self): def _send_shutdown(self):
""" Stop all program and stop manager """ """ Stop all program and stop manager """
@ -296,7 +306,12 @@ class ManageHttpRequest(http.server.SimpleHTTPRequestHandler):
self.server.listSemaphore[name].release() self.server.listSemaphore[name].release()
self._set_headers() self._set_headers()
outjson = {'shutdown': 'ok'} outjson = {'shutdown': 'ok'}
self.wfile.write(bytes(json.dumps(outjson), "utf-8")) try:
self.wfile.write(bytes(json.dumps(outjson), "utf-8"))
except BrokenPipeError:
# ignore BrokenPipeError: [Errno 32] Broken pipe
logging.debug("BrokenPipeError detected")
pass
def _send_command_all(self, command): def _send_command_all(self, command):
""" Send specific command on all program """ Send specific command on all program
@ -315,7 +330,12 @@ class ManageHttpRequest(http.server.SimpleHTTPRequestHandler):
self.server.listSemaphore[name].release() self.server.listSemaphore[name].release()
outjson.setdefault(name, item) outjson.setdefault(name, item)
self._set_headers() self._set_headers()
self.wfile.write(bytes(json.dumps(outjson), "utf-8")) try:
self.wfile.write(bytes(json.dumps(outjson), "utf-8"))
except BrokenPipeError:
# ignore BrokenPipeError: [Errno 32] Broken pipe
logging.debug("BrokenPipeError detected")
pass
def _send_action(self): def _send_action(self):
""" send specific action on one program """ """ send specific action on one program """
@ -359,7 +379,12 @@ class ManageHttpRequest(http.server.SimpleHTTPRequestHandler):
return return
self.server.listSemaphore[name].release() self.server.listSemaphore[name].release()
self._set_headers() self._set_headers()
self.wfile.write(bytes(json.dumps(outjson), "utf-8")) try:
self.wfile.write(bytes(json.dumps(outjson), "utf-8"))
except BrokenPipeError:
# ignore BrokenPipeError: [Errno 32] Broken pipe
logging.debug("BrokenPipeError detected")
pass
def _send_command(self, command): def _send_command(self, command):
""" Send specific command on one program """ Send specific command on one program
@ -398,7 +423,12 @@ class ManageHttpRequest(http.server.SimpleHTTPRequestHandler):
self.server.listSemaphore[name].release() self.server.listSemaphore[name].release()
logging.debug("[%s %s] => %s" % (command, name, outjson)) logging.debug("[%s %s] => %s" % (command, name, outjson))
self._set_headers() self._set_headers()
self.wfile.write(bytes(json.dumps(outjson), "utf-8")) try:
self.wfile.write(bytes(json.dumps(outjson), "utf-8"))
except BrokenPipeError:
# ignore BrokenPipeError: [Errno 32] Broken pipe
logging.debug("BrokenPipeError detected")
pass
def check_authentication(self): def check_authentication(self):
if not self.server.authentification: if not self.server.authentification: