Update cluster store status with a single atomic write() operation.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@930055 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 7 insertions, 0 deletions

diff --git a/python/qpid/brokertest.py b/python/qpid/brokertest.py
index 2f064f59b6..3608a959b1 100644
--- a/python/qpid/brokertest.py
+++ b/python/qpid/brokertest.py
@@ -373,6 +373,13 @@ class Broker(Popen):
         try: self.connect().close()
         except: raise RethrownException("Broker %s failed ready test"%self.name)
 
+    def store_state(self):
+        uuids = open(os.path.join(self.datadir, "cluster", "store.status")).readlines()
+        null_uuid="00000000-0000-0000-0000-000000000000\n"
+        if uuids[0] == null_uuid: return "empty"
+        if uuids[1] == null_uuid: return "dirty"
+        return "clean"
+        
 class Cluster:
     """A cluster of brokers in a test."""