mirror of
https://github.com/jellyfin/jellyfin-kodi.git
synced 2024-12-25 18:26:15 +00:00
6a9eddd413
Since we are not using self.logMsg, this is needed incase the path contains unicode characters (window username)
40 lines
No EOL
1.2 KiB
Python
40 lines
No EOL
1.2 KiB
Python
import os
|
|
import time
|
|
import errno
|
|
import xbmc
|
|
|
|
class Lock:
|
|
|
|
def __init__(self, filename):
|
|
self.filename = filename
|
|
self.delay = 0.5
|
|
self.timeout = 10
|
|
self.is_locked = False
|
|
self.fd = None
|
|
|
|
def acquire(self):
|
|
start_time = time.time()
|
|
while True:
|
|
try:
|
|
self.fd = os.open(self.filename, os.O_CREAT|os.O_RDWR|os.O_EXCL)
|
|
break;
|
|
except OSError as e:
|
|
if (time.time() - start_time) >= self.timeout:
|
|
xbmc.log("File_Lock_On " + self.filename.encode('utf-8') + " timed out")
|
|
return False
|
|
#xbmc.log("File_Lock_On " + self.filename + " error " + str(e))
|
|
time.sleep(self.delay)
|
|
self.is_locked = True
|
|
xbmc.log("File_Lock_On " + self.filename.encode('utf-8') + " obtained")
|
|
return True
|
|
|
|
def release(self):
|
|
if self.is_locked:
|
|
os.close(self.fd)
|
|
os.unlink(self.filename)
|
|
self.is_locked = False
|
|
xbmc.log("File_Lock_On " + self.filename.encode('utf-8') + " released")
|
|
|
|
def __del__(self):
|
|
self.release()
|
|
|