diff --git a/attributs.py b/attributs.py index 4cac70d..5113767 100644 --- a/attributs.py +++ b/attributs.py @@ -255,6 +255,7 @@ class Attr(object): optional = True conn = None unique = False + concurent = True unique_exclue = [] #: Le nom de l'attribut dans le schéma LDAP ldap_name = None @@ -817,6 +818,7 @@ class droits(Attr): class solde(Attr): python_type = float singlevalue = True + concurent = False optional = True legend = u"Solde d'impression" can_modify = [imprimeur, nounou, tresorier] diff --git a/objets.py b/objets.py index b700b89..6ab58e2 100644 --- a/objets.py +++ b/objets.py @@ -590,6 +590,14 @@ class CransLdapObject(object): cranslib.deprecated.usage("Des locks ne devrait être ajoutés que dans un context manager", level=2) self.conn.lockholder.addlock(attr, str(attribut), self.lockId) locked.append((attr, str(attribut), self.lockId)) + # On lock si l'attribut ne supporte pas les modifications concurente (comme pour le solde) si : + # * on effectue réellement un modification sur l'attribut + # * on a pas déjà effectuer un modification qui nous a déjà fait acquérir le lock + if not attribut.concurent and self._modifs.get(attr, []) == self.attrs.get(attr, []) and attrs_before_verif != self.attrs.get(attr, []): + if not self.in_context: + cranslib.deprecated.usage("Des locks ne devrait être ajoutés que dans un context manager", level=2) + self.conn.lockholder.addlock("dn", "%s_%s" % (self.dn.replace('=', '-').replace(',','_'), attr), self.lockId) + locked.append(("dn", "%s_%s" % (self.dn.replace('=', '-').replace(',','_'), attr), self.lockId)) except ldap_locks.LockError: # Si on ne parvient pas à prendre le lock pour l'une des valeurs # on libère les locks pris jusque là et on propage l'erreur