fix(rcf): access error
This commit is contained in:
@ -253,8 +253,8 @@ def rcf_client_agent(ctx, pipe,queue):
|
|||||||
rcfmsg.store(agent.property_map)
|
rcfmsg.store(agent.property_map)
|
||||||
elif agent.state == State.ACTIVE:
|
elif agent.state == State.ACTIVE:
|
||||||
if rcfmsg.id != agent.id:
|
if rcfmsg.id != agent.id:
|
||||||
update_queue.put((rcfmsg.key,rcfmsg.body))
|
# update_queue.put((rcfmsg.key,rcfmsg.body))
|
||||||
# helpers.load(rcfmsg.key,rcfmsg.body)
|
helpers.load(rcfmsg.key,rcfmsg.body)
|
||||||
# logger.info("load")
|
# logger.info("load")
|
||||||
# agent.serial.send_multipart([b"LOAD", umsgpack.packb(rcfmsg.key), umsgpack.packb(rcfmsg.body)])
|
# agent.serial.send_multipart([b"LOAD", umsgpack.packb(rcfmsg.key), umsgpack.packb(rcfmsg.body)])
|
||||||
|
|
||||||
|
@ -324,7 +324,7 @@ class Loader:
|
|||||||
(_load_filter_type(T.PointerProperty), self._load_pointer),
|
(_load_filter_type(T.PointerProperty), self._load_pointer),
|
||||||
(_load_filter_array, self._load_array),
|
(_load_filter_array, self._load_array),
|
||||||
(_load_filter_type(T.CollectionProperty), self._load_collection),
|
(_load_filter_type(T.CollectionProperty), self._load_collection),
|
||||||
(_load_filter_default, self._load_default)
|
# (_load_filter_default, self._load_default)
|
||||||
]
|
]
|
||||||
|
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user