From 9a39d739e8e64697661ad97e8a4cda434ad7852c Mon Sep 17 00:00:00 2001
From: "Joshua M. Boniface" <joshua@boniface.me>
Date: Wed, 25 Dec 2019 20:29:17 -0500
Subject: [PATCH] Ensure we empty of flush_thread

---
 node-daemon/pvcd/NodeInstance.py | 1 +
 1 file changed, 1 insertion(+)

diff --git a/node-daemon/pvcd/NodeInstance.py b/node-daemon/pvcd/NodeInstance.py
index ce09e025..4f8fa095 100644
--- a/node-daemon/pvcd/NodeInstance.py
+++ b/node-daemon/pvcd/NodeInstance.py
@@ -156,6 +156,7 @@ class NodeInstance(object):
                         while self.flush_stopper:
                             time.sleep(1)
                     self.flush_stopper = False
+                    self.flush_thread = None
                     # Do flushing in a thread so it doesn't block the migrates out
                     if self.domain_state == 'flush':
                         self.flush_thread = threading.Thread(target=self.flush, args=(), kwargs={})