diff options
Diffstat (limited to 'module/FileDatabase.py')
| -rw-r--r-- | module/FileDatabase.py | 19 |
1 files changed, 16 insertions, 3 deletions
diff --git a/module/FileDatabase.py b/module/FileDatabase.py index 6e6537f38..4bcb63764 100644 --- a/module/FileDatabase.py +++ b/module/FileDatabase.py @@ -562,15 +562,17 @@ class FileDatabaseBackend(Thread): self.c = self.conn.cursor() #self.c.execute("PRAGMA synchronous = OFF") self._createTables() - self.c.close() + + self.used = 0 while True: try: f, args, async = self.jobs.get() + self.used += 1 if f == "quit": return True - self.c = self.conn.cursor() + if self.used > 300: #recycle connection + self.recycleConnection() res = f(*args) - self.c.close() if not async: self.res.put(res) except Exception, e: #@TODO log etc @@ -582,6 +584,17 @@ class FileDatabaseBackend(Thread): self.syncSave() self.jobs.put(("quit", "", 0)) + def recycleConnection(self): + self.manager.core.log.debug("Recycle sqlite connection") + self.conn.commit() + self.c.close() + self.conn.close() + del self.c + del self.conn + self.conn = sqlite3.connect("files.db") + self.c = self.conn.cursor() + self.used = 0 + def _checkVersion(self): """ check db version and delete it if needed""" if not exists("files.version"): |