persist_data: handle locked db for SELECT

Parallel processes interacting with the persist_data db can quite easily
explode without this.

Signed-off-by: Chris Larson <chris_larson@mentor.com>

1 files changed, 3 insertions, 4 deletions

diff --git a/lib/bb/persist_data.py b/lib/bb/persist_data.py
index 91c089bdf..3c61d9573 100644
--- a/lib/bb/persist_data.py
+++ b/lib/bb/persist_data.py
@@ -94,7 +94,7 @@ class PersistData:
         """
         Return the value of a key for a domain
         """
-        data = self.cursor.execute("SELECT * from %s where key=?;" % domain, [key])
+        data = self._execute("SELECT * from %s where key=?;" % domain, [key])
         for row in data:
             return row[1]
 
@@ -102,7 +102,7 @@ class PersistData:
         """
         Sets the value of a key for a domain
         """
-        data = self.cursor.execute("SELECT * from %s where key=?;" % domain, [key])
+        data = self._execute("SELECT * from %s where key=?;" % domain, [key])
         rows = 0
         for row in data:
             rows = rows + 1
@@ -120,8 +120,7 @@ class PersistData:
     def _execute(self, *query):
         while True:
             try:
-                self.cursor.execute(*query)
-                return
+                return self.cursor.execute(*query)
             except sqlite3.OperationalError as e:
                 if 'database is locked' in str(e):
                     continue