Correct actual problem with this_node

This commit is contained in:
2019-06-18 13:43:54 -04:00
parent d076f9f4eb
commit 080ca3201c
2 changed files with 10 additions and 10 deletions

View File

@ -792,7 +792,7 @@ if enable_storage:
@zk_conn.DataWatch('/ceph/cmd')
def cmd(data, stat, event=''):
if data:
CephInstance.run_command(zk_conn, data.decode('ascii'), d_osd)
CephInstance.run_command(zk_conn, this_node, data.decode('ascii'), d_osd)
# OSD objects
@zk_conn.ChildrenWatch('/ceph/osds')