add exception handle for openapi-selector
This commit is contained in:
@ -539,14 +539,17 @@ class HmiRequest(object):
|
||||
sel.unregister(conn)
|
||||
conn.close()
|
||||
|
||||
sel = selectors.DefaultSelector()
|
||||
sel.register(sock, selectors.EVENT_READ, to_read)
|
||||
try:
|
||||
sel = selectors.DefaultSelector()
|
||||
sel.register(sock, selectors.EVENT_READ, to_read)
|
||||
|
||||
while self.t_bool:
|
||||
events = sel.select()
|
||||
for key, mask in events:
|
||||
callback = key.data
|
||||
callback(key.fileobj, mask)
|
||||
while self.t_bool:
|
||||
events = sel.select()
|
||||
for key, mask in events:
|
||||
callback = key.data
|
||||
callback(key.fileobj, mask)
|
||||
except Exception as Err:
|
||||
logger.warning(Err)
|
||||
|
||||
def unpackage_xs(self, sock):
|
||||
def to_read(conn, mask):
|
||||
@ -559,14 +562,17 @@ class HmiRequest(object):
|
||||
sel.unregister(conn)
|
||||
conn.close()
|
||||
|
||||
sel = selectors.DefaultSelector()
|
||||
sel.register(sock, selectors.EVENT_READ, to_read)
|
||||
try:
|
||||
sel = selectors.DefaultSelector()
|
||||
sel.register(sock, selectors.EVENT_READ, to_read)
|
||||
|
||||
while self.t_bool:
|
||||
events = sel.select()
|
||||
for key, mask in events:
|
||||
callback = key.data
|
||||
callback(key.fileobj, mask)
|
||||
while self.t_bool:
|
||||
events = sel.select()
|
||||
for key, mask in events:
|
||||
callback = key.data
|
||||
callback(key.fileobj, mask)
|
||||
except Exception as Err:
|
||||
logger.warning(Err)
|
||||
|
||||
def gen_id(self, command):
|
||||
_now = time()
|
||||
|
Reference in New Issue
Block a user