version 1.103, 2008/11/05 19:53:32
|
version 1.104, 2008/11/06 15:00:44
|
Line 31 import md5
|
Line 31 import md5
|
from DownloadBasket import DownloadBasketFinallyThread |
from DownloadBasket import DownloadBasketFinallyThread |
from types import * |
from types import * |
import pickle |
import pickle |
|
import tempfile |
|
|
def makelist(mySet): |
def makelist(mySet): |
x = list(mySet) |
x = list(mySet) |
Line 538 class uploadATFThread(Thread):
|
Line 539 class uploadATFThread(Thread):
|
ctx2=ctx.cdliRoot |
ctx2=ctx.cdliRoot |
|
|
#get temporary file for staging the downloaded and splitted files |
#get temporary file for staging the downloaded and splitted files |
dir=mkdtemp() |
dir=tempfile.mkdtemp() |
|
|
|
|
changed=[] # changed files |
changed=[] # changed files |
Line 1654 class CDLIBasketVersion(Implicit,Persist
|
Line 1655 class CDLIBasketVersion(Implicit,Persist
|
|
|
self.REQUEST.RESPONSE.write("# locked files end\n") |
self.REQUEST.RESPONSE.write("# locked files end\n") |
|
|
del self.basketContainer.resultHash[threadName] |
#del self.basketContainer.resultHash[threadName] |
del self.basketContainer.resultLockedHash[threadName] |
#del self.basketContainer.resultLockedHash[threadName] |
|
|
def numberOfItems(self): |
def numberOfItems(self): |
"""return anzahl der elemente im basket""" |
"""return anzahl der elemente im basket""" |
Line 2983 class CDLIRoot(Folder):
|
Line 2984 class CDLIRoot(Folder):
|
logging.debug("dir:"+repr(stObj.returnValue['changed'])) |
logging.debug("dir:"+repr(stObj.returnValue['changed'])) |
for x in stObj.returnValue['changed']: |
for x in stObj.returnValue['changed']: |
ob=self.CDLICatalog.search({'title':x[0]}) |
ob=self.CDLICatalog.search({'title':x[0]}) |
|
try: |
self.cdliRoot.updateOrAddToFileBTree(ob[0].getObject()) |
self.cdliRoot.updateOrAddToFileBTree(ob[0].getObject()) |
|
except: |
|
logging.error("uploadATFfinally - cannot update Object %s Error: %s %s"%(ob[1],sys.exc_info()[0],sys.exc_info()[1])) |
if RESPONSE is not None: |
if RESPONSE is not None: |
RESPONSE.redirect(self.absolute_url()) |
RESPONSE.redirect(self.absolute_url()) |
|
|