Skip to content

看了下,和上一个issues的log是一样的,应该是mq没有保护好的问题把 #59

@tottilin

Description

@tottilin

Exception in thread Thread-2:
Traceback (most recent call last):
File "/usr/local/lib/python2.7/threading.py", line 551, in *bootstrap_inner
self.run()
File "/usr/local/lib/python2.7/threading.py", line 504, in run
self.__target(_self.__args, _self.__kwargs)
File "/usr/crawl/code/cola-code/cola/core/mq/__init
.py", line 103, in _init_process
self.put(objs, flush=flush)
File "/usr/crawl/code/cola-code/cola/core/mq/node.py", line 407, in put
self._remote_or_local_batch_put(addr, self.caches[addr])
File "/usr/crawl/code/cola-code/cola/core/mq/node.py", line 348, in _remote_or_local_batch_put
self.mq_node.batch_put(objs)
File "/usr/crawl/code/cola-code/cola/core/mq/node.py", line 151, in batch_put
self.put(obs, force=force, priority=priority)
File "/usr/crawl/code/cola-code/cola/core/mq/node.py", line 125, in put
priority_store.put(objs, force=force)
File "/usr/crawl/code/cola-code/cola/core/mq/store.py", line 291, in put
result = self.put_one(obj, force, commit=False)
File "/usr/crawl/code/cola-code/cola/core/mq/store.py", line 266, in put_one
pos = self._seek_writable_pos(m)
File "/usr/crawl/code/cola-code/cola/core/mq/store.py", line 228, in _seek_writable_pos
size, = struct.unpack('I', map_handle[pos:pos+4])
TypeError: 'NoneType' object has no attribute 'getitem'

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions