Volttron 进入了一个几乎无休止的循环

Question

我已经安装了大约 40 个代理来运行一些模拟。但是我运行陷入了一些线程错误。错误如下所示。

2019-08-06 10:56:24,120 (socialagent-3.0 16231) ERROR: Exception in thread Thread-31: 2019-08-06 10:56:24,124 (socialagent-3.0 16231) ERROR: Traceback (most recent call last): 2019-08-06 10:56:24,135 (socialagent-3.0 16231) ERROR: File "/usr/lib/python2.7/threading.py", line 801, in __bootstrap_inner

2019-08-06 10:56:24,162 (socialagent-3.0 16231) ERROR:
self.run()

2019-08-06 10:56:24,177 (socialagent-3.0 16231) ERROR: File "/usr/lib/python2.7/threading.py", line 1073, in run

2019-08-06 10:56:24,198 (socialagent-3.0 16231) ERROR:
self.function(*self.args, **self.kwargs)

2019-08-06 10:56:24,201 (socialagent-3.0 16231) ERROR: File "/home/jenny/.volttron/agents/50b42ee5-b6af-4a25-aa89-97e2b1a823e1/socialagent-3.0/social/agent.py", line 145, in enter_phase3

2019-08-06 10:56:24,240 (socialagent-3.0 16231) ERROR:
self.vip.pubsub.publish('pubsub', ids_topic, message=message)

2019-08-06 10:56:24,265 (socialagent-3.0 16231) ERROR: File "/home/jenny/workspace/volttron/volttron/platform/vip/agent/subsystems/pubsub.py", line 607, in publish

2019-08-06 10:56:24,267 (socialagent-3.0 16231) ERROR:
self.vip_socket.send_vip(b'', 'pubsub', frames, result.ident, copy=False)

2019-08-06 10:56:24,279 (socialagent-3.0 16231) ERROR: File "/home/jenny/workspace/volttron/volttron/platform/vip/socket.py", line 404, in send_vip

2019-08-06 10:56:24,326 (socialagent-3.0 16231) ERROR:
with self._sending(flags) as flags:

2019-08-06 10:56:24,327 (socialagent-3.0 16231) ERROR: File "/usr/lib/python2.7/contextlib.py", line 17, in __enter__

2019-08-06 10:56:24,377 (socialagent-3.0 16231) ERROR:
return self.gen.next()

2019-08-06 10:56:24,402 (socialagent-3.0 16231) ERROR: File "/home/jenny/workspace/volttron/volttron/platform/vip/green.py", line 78, in _sending

2019-08-06 10:56:24,413 (socialagent-3.0 16231) ERROR:
while not lock.acquire(not flags & NOBLOCK):

2019-08-06 10:56:24,422 (socialagent-3.0 16231) ERROR: File "/home/jenny/workspace/volttron/env/local/lib/python2.7/site-packages/gevent/lock.py", line 210, in acquire

2019-08-06 10:56:24,427 (socialagent-3.0 16231) ERROR: rc = self._block.acquire(blocking)

2019-08-06 10:56:24,442 (socialagent-3.0 16231) ERROR: File "gevent/_semaphore.py", line 198, in gevent._semaphore.Semaphore.acquire (gevent/gevent._semaphore.c:4117)

2019-08-06 10:56:24,451 (socialagent-3.0 16231) ERROR:
def acquire(self, blocking=True, timeout=None):

2019-08-06 10:56:24,485 (socialagent-3.0 16231) ERROR: File "gevent/_semaphore.py", line 226, in gevent._semaphore.Semaphore.acquire (gevent/gevent._semaphore.c:3944)

2019-08-06 10:56:24,493 (socialagent-3.0 16231) ERROR:
timeout = self._do_wait(timeout)

2019-08-06 10:56:24,503 (socialagent-3.0 16231) ERROR: File "gevent/_semaphore.py", line 166, in gevent._semaphore.Semaphore._do_wait (gevent/gevent._semaphore.c:3178)

2019-08-06 10:56:24,546 (socialagent-3.0 16231) ERROR:
result = get_hub().switch()

2019-08-06 10:56:24,552 (socialagent-3.0 16231) ERROR: File "/home/jenny/workspace/volttron/env/local/lib/python2.7/site-packages/gevent/hub.py", line 609, in switch

2019-08-06 10:56:24,574 (socialagent-3.0 16231) ERROR:
return greenlet.switch(self)

2019-08-06 10:56:24,589 (socialagent-3.0 16231) ERROR: LoopExit: ('This operation would block forever', )

2019-08-06 10:56:24,640 (socialagent-3.0 16231) ERROR:

这正是我在 agent.py 文件第 145 行的内容： self.vip.pubsub.publish('pubsub', ds_topic, message=message) 我已经将消息定义为 message = “something”

当我安装较少的代理时，我根本不会运行遇到这个问题。我正在运行安装一台 1.9GHz 英特尔酷睿 i3 机器；这可能是相关的吗？为了提供尽可能多的有助于诊断问题的信息，我在这里展示了我的代理的一些片段：

from threading import Timer

@Core.receiver("onstart")
def starting(self, sender, **kwargs):
    _log.debug('Subscribing to all relevant topics')
    self.vip.pubsub.subscribe('pubsub', pred_topic, callback=self.from_pred)  


def from_pred(self, peer, sender, bus, topic, headers, message):          
    message_dict = message_parser.mess_conv(message)
    message = "{}: {}".format(statID, message_dict['feat_pro'])
    # Publish to all neighbour topics and to our own topic
    for k in neighbours:
        self.vip.pubsub.publish('pubsub', k, message=message)
    self.vip.pubsub.publish('pubsub', social_topic, message=message)
    # ...and start timer to allow communication for 8s
    timer = Timer(8, self.enter_phase)
    timer.start()

def enter_phase(self):
    # Send a message to IDS to begin phase 
    _log.debug("In agent {}. We have {}".format(stationID, sent_prob))
    if stationID in sent_prob.keys():
        message = "phase3: 1"
    else:
        message = "phase3: 0"
    self.vip.pubsub.publish('pubsub', ds_topic, message=message)

此外，timer = Timer(8, self.enter_phase) 可能是问题的 the/part 吗？我不是这样的开发大师，将不胜感激任何帮助（用简单的语言:)）。

Answer 1

这可能是由于猴子补丁问题造成的。 VOLTTRON 平台代码使用 gevent 打补丁的套接字和未打补丁的线程。

您的代理执行 monkey.patchall() 还是导入执行 gevent monkey.patchall() 的模块？您的代理是否依赖 packages/other 需要未修补套接字的库？如果您的代理需要未修补的 Socket 模块，您可以在代码中导入 Socket 语句后重新加载（套接字）。 VOLTTRON 为 mongo historian（参见 volttron/platform/dbutils/mongoutils.py）执行此操作，因为 pymongo 库需要取消修补套接字和线程模块。

Volttron 进入了一个几乎无休止的循环

Volttron enters what seems like an almost endless loop

volttron