[BACK]Return to DownloadBasket.py CVS log [TXT] [DIR] Up to [Repository] / cdli

Diff for /cdli/DownloadBasket.py between versions 1.2 and 1.4

version 1.2, 2008/10/02 11:42:43 version 1.4, 2008/10/06 12:26:57
Line 1 Line 1
   
 from threading import Thread  from threading import Thread
 from ZPublisher.HTTPResponse import HTTPResponse  from ZPublisher.HTTPResponse import HTTPResponse
 from ZPublisher.HTTPRequest import HTTPRequest  from ZPublisher.HTTPRequest import HTTPRequest
Line 97  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
 #                logging.error("ret:"+repr(object[0]))  #                logging.error("ret:"+repr(object[0]))
 #                logging.error("    -"+repr(procedure))  #                logging.error("    -"+repr(procedure))
                   try:
                 lockedBy=object[1].lockedBy                  lockedBy=object[1].lockedBy
                   except:
                       logging.error("no object:"+repr(self.counter))
                       logging.error("no object:"+repr(object))
                       continue
               
 #                lockedBy=""  #                lockedBy=""
 #                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 127  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 154  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")
Removed from v.1.2  
changed lines
  Added in v.1.4

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>