From 0c7705e70f3f7d7e0e70ca2ce871b3121e804afc Mon Sep 17 00:00:00 2001
From: Joshua Boniface <joshua@boniface.me>
Date: Tue, 27 Nov 2018 21:26:12 -0500
Subject: [PATCH] Fix missing variable

---
 node-daemon/pvcd/CephInstance.py | 4 ++--
 node-daemon/pvcd/Daemon.py       | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/node-daemon/pvcd/CephInstance.py b/node-daemon/pvcd/CephInstance.py
index 675ee792..bd46bb81 100644
--- a/node-daemon/pvcd/CephInstance.py
+++ b/node-daemon/pvcd/CephInstance.py
@@ -417,7 +417,7 @@ def remove_pool(zk_conn, logger, name):
         logger.out('Failed to remove RBD pool {}: {}'.format(name, e), state='e')
         return False
 
-def run_command(zk_conn, command):
+def run_command(zk_conn, data, d_osd):
     # Get the command and args
     command, args = data.split()
 
@@ -550,7 +550,7 @@ def run_command(zk_conn, command):
                 time.sleep(1)
 
     # Adding a new pool
-    if command == 'pool_add':
+    elif command == 'pool_add':
         name, pgs = args.split(',')
 
         if this_node.router_state == 'primary':
diff --git a/node-daemon/pvcd/Daemon.py b/node-daemon/pvcd/Daemon.py
index 48d9c600..ead98153 100644
--- a/node-daemon/pvcd/Daemon.py
+++ b/node-daemon/pvcd/Daemon.py
@@ -674,7 +674,7 @@ def cmd(data, stat, event=''):
         data = ''
 
     if data:
-        CephInstance.run_command(data)
+        CephInstance.run_command(zk_conn, data, d_osd)
 
 # OSD objects
 @zk_conn.ChildrenWatch('/ceph/osds')