Skip to content
Snippets Groups Projects
Commit 8fe05e4c authored by jkerdreu's avatar jkerdreu
Browse files

Oops limit rate on process_tx_msg not rx_msg

git-svn-id: https://redmine.imt-atlantique.fr/svn/xaal/code/Python/trunk@2151 b32b6428-25c9-4566-ad07-03861ab6144f
parent 2b43f647
No related branches found
No related tags found
No related merge requests found
......@@ -88,7 +88,9 @@ class Engine(object):
self.send_msg(temp)
# try to limit rate
cnt = cnt + 1
if cnt > config.queue_size: break
if cnt > config.queue_size:
time.sleep(0.2)
break
def send_msg(self, msg):
......@@ -211,9 +213,7 @@ class Engine(object):
self.process_attributesChange()
# only flush some message, to limit rate
cnt = cnt + 1
if cnt > config.queue_size:
time.sleep(0.02)
break
if cnt > config.queue_size: break
msg = self.receive_msg()
def handle_request(self, msg):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment