equal
deleted
inserted
replaced
85 hook.Operation.__init__(self, session) |
85 hook.Operation.__init__(self, session) |
86 |
86 |
87 def commit_event(self): |
87 def commit_event(self): |
88 """the observed connections pool has been commited""" |
88 """the observed connections pool has been commited""" |
89 try: |
89 try: |
90 self.repo.close(self.cnxid) |
90 self.session.repo.close(self.cnxid) |
91 except BadConnectionId: |
91 except BadConnectionId: |
92 pass # already closed |
92 pass # already closed |
93 |
93 |
94 |
94 |
95 class CloseDeletedUserSessionsHook(SyncSessionHook): |
95 class CloseDeletedUserSessionsHook(SyncSessionHook): |
130 |
130 |
131 def commit_event(self): |
131 def commit_event(self): |
132 """the observed connections pool has been commited""" |
132 """the observed connections pool has been commited""" |
133 cwprop = self.cwprop |
133 cwprop = self.cwprop |
134 if not cwprop.for_user: |
134 if not cwprop.for_user: |
135 self.repo.vreg['propertyvalues'][cwprop.pkey] = cwprop.value |
135 self.session.vreg['propertyvalues'][cwprop.pkey] = cwprop.value |
136 # if for_user is set, update is handled by a ChangeCWPropertyOp operation |
136 # if for_user is set, update is handled by a ChangeCWPropertyOp operation |
137 |
137 |
138 |
138 |
139 class AddCWPropertyHook(SyncSessionHook): |
139 class AddCWPropertyHook(SyncSessionHook): |
140 __regid__ = 'addcwprop' |
140 __regid__ = 'addcwprop' |