Experimental code to hopefully fix #37

This commit is contained in:
Florian Bach 2022-10-17 13:53:30 +02:00
parent 6c6a313849
commit b05e631418
2 changed files with 83 additions and 18 deletions

View File

@ -1,5 +1,7 @@
from lxml import etree from lxml import etree
import base64 import base64
import random
import time
#@@CALIBRE_COMPAT_CODE@@ #@@CALIBRE_COMPAT_CODE@@
@ -553,6 +555,15 @@ def updateLoanReturnData(fulfillmentResultToken, forceTestBehaviour=False):
if forceTestBehaviour: if forceTestBehaviour:
return new_loan_record return new_loan_record
addLoanRecordToConfigFile(new_loan_record)
return True
def addLoanRecordToConfigFile(new_loan_record):
try: try:
import calibre_plugins.deacsm.prefs as prefs # type: ignore import calibre_plugins.deacsm.prefs as prefs # type: ignore
deacsmprefs = prefs.ACSMInput_Prefs() deacsmprefs = prefs.ACSMInput_Prefs()
@ -560,6 +571,47 @@ def updateLoanReturnData(fulfillmentResultToken, forceTestBehaviour=False):
print("Exception while reading config file") print("Exception while reading config file")
return False return False
error_counter = 0
last_token = None
while True:
if error_counter >= 10:
print("Took us 10 attempts to acquire loan token lock, still didn't work.")
print("(still the same token %s)" % (deacsmprefs["loan_identifier_token"]))
print("If you see this error message please open a bug report.")
# "Mark" the current access with a random token, to prevent multiple instances
# of the plugin overwriting eachother's data.
deacsmprefs.refresh()
if deacsmprefs["loan_identifier_token"] == 0:
random_identifier = random.getrandbits(64)
deacsmprefs.set("loan_identifier_token", random_identifier)
deacsmprefs.commit()
deacsmprefs.refresh()
if random_identifier != deacsmprefs["loan_identifier_token"]:
#print("we broke another thread's token, try again")
last_token = deacsmprefs["loan_identifier_token"]
error_counter = error_counter + 1
continue
else:
if last_token != deacsmprefs["loan_identifier_token"]:
#print("Token changed in the meantime ...")
# Give it another 5 tries
error_counter = max(0, error_counter - 5)
pass
last_token = deacsmprefs["loan_identifier_token"]
#print("waiting on another thread ...")
sleeptime = random.randrange(2, 10) / 1000
print(str(sleeptime))
time.sleep(sleeptime)
error_counter = error_counter + 1
continue
# Okay, now this thread can "use" the config list, and no other thread should overwrite it ...
# Check if that exact loan is already in the list, and if so, delete it: # Check if that exact loan is already in the list, and if so, delete it:
done = False done = False
while not done: while not done:
@ -575,13 +627,19 @@ def updateLoanReturnData(fulfillmentResultToken, forceTestBehaviour=False):
# The config widget can then read this and present a list of not-yet-returned # The config widget can then read this and present a list of not-yet-returned
# books, and can then return them. # books, and can then return them.
# Also, the config widget is responsible for cleaning up that list once a book's validity period is up. # Also, the config widget is responsible for cleaning up that list once a book's validity period is up.
deacsmprefs["list_of_rented_books"].append(new_loan_record) deacsmprefs["list_of_rented_books"].append(new_loan_record)
print("DEBUG, list of books:") # Okay, now we added our loan record.
print(deacsmprefs["list_of_rented_books"]) # Remove the identifier token so other threads can use the config again:
deacsmprefs.commit()
deacsmprefs.refresh()
if deacsmprefs["loan_identifier_token"] != random_identifier:
print("Another thread stole the loan token while we were working with it - that's not supposed to happen ...")
print("If you see this message, please open a bug report.")
return False
deacsmprefs.writeprefs() deacsmprefs.set("loan_identifier_token", 0)
deacsmprefs.commit()
return True return True

View File

@ -29,6 +29,8 @@ class ACSMInput_Prefs():
self.deacsmprefs.defaults['detailed_logging'] = False self.deacsmprefs.defaults['detailed_logging'] = False
self.deacsmprefs.defaults['delete_acsm_after_fulfill'] = False self.deacsmprefs.defaults['delete_acsm_after_fulfill'] = False
self.deacsmprefs.defaults['loan_identifier_token'] = 0
self.deacsmprefs.defaults['list_of_rented_books'] = [] self.deacsmprefs.defaults['list_of_rented_books'] = []
if self.deacsmprefs['list_of_rented_books'] == []: if self.deacsmprefs['list_of_rented_books'] == []:
@ -52,6 +54,11 @@ class ACSMInput_Prefs():
raise Exception("Why does the account folder not exist?") raise Exception("Why does the account folder not exist?")
def refresh(self):
return self.deacsmprefs.refresh()
def commit(self):
return self.deacsmprefs.commit()
def __getitem__(self,kind = None): def __getitem__(self,kind = None):
if kind is not None: if kind is not None: