Revision 85352a77
| b/snf-pithos-backend/pithos/backends/modular.py | ||
|---|---|---|
| 109 | 109 |
|
| 110 | 110 |
def fn(self, *args, **kw): |
| 111 | 111 |
self.wrapper.execute() |
| 112 |
serials = self.serials |
|
| 113 |
self.messages = [] |
|
| 112 | 114 |
try: |
| 113 |
self.messages = [] |
|
| 114 | 115 |
ret = func(self, *args, **kw) |
| 115 | 116 |
for m in self.messages: |
| 116 | 117 |
self.queue.send(*m) |
| 117 |
serials = self.serials |
|
| 118 | 118 |
if serials: |
| 119 | 119 |
self.quotaholder.accept_commission( |
| 120 | 120 |
context = {},
|
| ... | ... | |
| 1254 | 1254 |
key = '1', |
| 1255 | 1255 |
clientkey = 'pithos', |
| 1256 | 1256 |
ownerkey = '', |
| 1257 |
provisions = () |
|
| 1257 |
provisions = (('pithos+', 'diskspace', size),)
|
|
| 1258 | 1258 |
) |
| 1259 | 1259 |
self.serials.append(serial) |
| 1260 | 1260 |
|
Also available in: Unified diff