Fix missing variable

This commit is contained in:
Joshua Boniface 2018-11-27 21:26:12 -05:00
parent b8a5073a35
commit 0c7705e70f
2 changed files with 3 additions and 3 deletions

View File

@ -417,7 +417,7 @@ def remove_pool(zk_conn, logger, name):
logger.out('Failed to remove RBD pool {}: {}'.format(name, e), state='e') logger.out('Failed to remove RBD pool {}: {}'.format(name, e), state='e')
return False return False
def run_command(zk_conn, command): def run_command(zk_conn, data, d_osd):
# Get the command and args # Get the command and args
command, args = data.split() command, args = data.split()
@ -550,7 +550,7 @@ def run_command(zk_conn, command):
time.sleep(1) time.sleep(1)
# Adding a new pool # Adding a new pool
if command == 'pool_add': elif command == 'pool_add':
name, pgs = args.split(',') name, pgs = args.split(',')
if this_node.router_state == 'primary': if this_node.router_state == 'primary':

View File

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