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

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

version 1.2, 2008/10/02 11:42:43 version 1.5, 2008/10/06 13:35:39
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 91  class DownloadBasketFinallyThread(Thread Line 90  class DownloadBasketFinallyThread(Thread
         """print do the download"""          """print do the download"""
         logging.debug("download thread")          logging.debug("download thread")
       
         logging.debug("donwloadBasketasonefile: found basket:"+repr(basketVersion))          logging.debug("downloadBasketasonefile: found basket:"+repr(basketVersion))
         ret=""          ret=""
   
         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):                  
                     #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")
Line 116  class DownloadBasketFinallyThread(Thread Line 123  class DownloadBasketFinallyThread(Thread
                         #ret+=str(object[0].getData())+"\n"                          #ret+=str(object[0].getData())+"\n"
                         files.append(object[0].getFileName())                          files.append(object[0].getFileName())
                     elif current=="yes":                      elif current=="yes":
                         logging.error("ret3")                      #logging.error("ret3")
                         #search current object                          #search current object
                         #founds=self.CDLICatalog.search({'title':object[1].getId().split(".")[0]})                          #founds=self.CDLICatalog.search({'title':object[1].getId().split(".")[0]})
                         obj=self.ctx.getFileObjectLastVersion(object[1].getId())                          obj=self.ctx.getFileObjectLastVersion(object[1].getId())
                         if obj:                          if obj:
                             files.append(obj.getFileName())                              files.append(obj.getFileName())
                         else:                          else:
                             logging.error("donwloadBasketasonefile: don't know: "+repr(object[0].getId()))                          logging.error("downloadBasketasonefile: don't know: "+repr(object[0].getId()))
                         #if len(founds)>0:                                #if len(founds)>0:      
                           #  ret+=str(founds[0].getObject().getLastVersion().getData())+"\n"                            #  ret+=str(founds[0].getObject().getLastVersion().getData())+"\n"
                                               
                   #falls die Datei gesperrit ist nimm sie in die Liste auf.
                   if not((procedure=="downloadAll") or (lockedBy=='') or (lockedBy==user)):
                       #logging.error("ret4")
                       lockedFiles.append((object[0].getId(),lockedBy))
               
                 #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 165  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.5

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