equeue: unlock lockfile at boot.

parent c05d3348
...@@ -89,7 +89,9 @@ class EqueueServer(SocketServer.ThreadingUnixStreamServer): ...@@ -89,7 +89,9 @@ class EqueueServer(SocketServer.ThreadingUnixStreamServer):
self.setDB(self.options.database[0]) self.setDB(self.options.database[0])
# Lock to only have one command running at the time # Lock to only have one command running at the time
self.thread_lock = threading.Lock() self.thread_lock = threading.Lock()
# Lockfile is used by other commands to know if an import is ongoing.
self.lockfile = LockFile(self.options.lockfile) self.lockfile = LockFile(self.options.lockfile)
self.lockfile.break_lock()
def setLogger(self, logfile, loglevel): def setLogger(self, logfile, loglevel):
self.logger = logging.getLogger("EQueue") self.logger = logging.getLogger("EQueue")
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment