version 1.3, 2008/10/06 10:46:46
|
version 1.4, 2008/10/06 12:26:57
|
Line 96 class DownloadBasketFinallyThread(Thread
|
Line 96 class DownloadBasketFinallyThread(Thread
|
self.counter=0 |
self.counter=0 |
#fh=file("/var/tmp/test","w") |
#fh=file("/var/tmp/test","w") |
files=[] |
files=[] |
|
lockedFiles=[] |
objects=basketVersion.getContent() |
objects=basketVersion.getContent() |
self.number=len(objects) |
self.number=len(objects) |
|
logging.error("objects:"+repr(self.number)) |
for object in objects: |
for object in objects: |
|
|
self.counter+=1 |
self.counter+=1 |
Line 114 class DownloadBasketFinallyThread(Thread
|
Line 116 class DownloadBasketFinallyThread(Thread
|
# logging.error(" -"+repr(lockedBy)) |
# logging.error(" -"+repr(lockedBy)) |
# |
# |
if (procedure=="downloadAll") or (lockedBy=='') or (lockedBy==user): |
if (procedure=="downloadAll") or (lockedBy=='') or (lockedBy==user): |
#logging.error("ret1") |
logging.error("ret1") |
if current=="no": #version as they are in the basket |
if current=="no": #version as they are in the basket |
#logging.error("ret2") |
logging.error("ret2") |
#object[0].addToFile2("/var/tmp/test2") |
#object[0].addToFile2("/var/tmp/test2") |
#ret+=str(object[0].getData())+"\n" |
#ret+=str(object[0].getData())+"\n" |
files.append(object[0].getFileName()) |
files.append(object[0].getFileName()) |
Line 132 class DownloadBasketFinallyThread(Thread
|
Line 134 class DownloadBasketFinallyThread(Thread
|
#if len(founds)>0: |
#if len(founds)>0: |
# ret+=str(founds[0].getObject().getLastVersion().getData())+"\n" |
# ret+=str(founds[0].getObject().getLastVersion().getData())+"\n" |
|
|
|
else: |
|
logging.error("ret4") |
|
lockedFiles.append(object[0].getId()) |
|
|
#if lock and lockedBy=='': |
#if lock and lockedBy=='': |
#obj=self.ctx.getFileObject(object[1].getId()) |
#obj=self.ctx.getFileObject(object[1].getId()) |
Line 159 class DownloadBasketFinallyThread(Thread
|
Line 164 class DownloadBasketFinallyThread(Thread
|
if not hasattr(self.ctx,'resultHash'): |
if not hasattr(self.ctx,'resultHash'): |
self.ctx.resultHash={} |
self.ctx.resultHash={} |
self.ctx.resultHash[self.getName()]=files |
self.ctx.resultHash[self.getName()]=files |
|
|
|
if not hasattr(self.ctx,'resultLockedHash'): |
|
self.ctx.resultLockedHash={} |
|
self.ctx.resultLockedHash[self.getName()]=lockedFiles |
|
|
transaction.get().commit() |
transaction.get().commit() |
self.conn.close() |
self.conn.close() |
logging.error("---------download thread:run9") |
logging.error("---------download thread:run9") |