ViewVC Help
View File | Revision Log | Show Annotations | Root Listing
root/cvsroot/COMP/CRAB/python/cmscp.py
(Generate patch)

Comparing COMP/CRAB/python/cmscp.py (file contents):
Revision 1.56.2.3 by spiga, Tue Sep 29 16:16:12 2009 UTC vs.
Revision 1.68.2.3 by spiga, Thu Apr 22 14:40:14 2010 UTC

# Line 115 | Line 115 | class cmscp:
115          lcgOpt={'srmv1':'-b -D srmv1  -t 2400 --verbose',
116                  'srmv2':'-b -D srmv2  -t 2400 --verbose'}
117          if self.checkLcgUtils() >= 17:
118 <            lcgOpt={'srmv1':'-b -D srmv1 --srm-timeout 2400 --sendreceive-timeout 240 --connect-timeout 240 --verbose',
119 <                    'srmv2':'-b -D srmv2 --srm-timeout 2400 --sendreceive-timeout 240 --connect-timeout 240 --verbose'}
118 >            lcgOpt={'srmv1':'-b -D srmv1 --srm-timeout 2400 --sendreceive-timeout 2400 --connect-timeout 2400 --verbose',
119 >                    'srmv2':'-b -D srmv2 --srm-timeout 2400 --sendreceive-timeout 2400 --connect-timeout 2400 --verbose'}
120  
121          srmOpt={'srmv1':' -report ./srmcp.report -retry_timeout 480000 -retry_num 3 -streams_num=1 ',
122 <                'srmv2':' -report=./srmcp.report -retry_timeout=480000 -retry_num=3 '}
122 >                'srmv2':' -report=./srmcp.report -retry_timeout=480000 -retry_num=3 -storagetype=permanent '}
123          rfioOpt=''
124  
125          supported_protocol = None
# Line 128 | Line 128 | class cmscp:
128                                   (self.params['srm_version'],srmOpt[self.params['srm_version']])]
129          elif middleware.lower() in ['lsf','caf']:
130              supported_protocol = [('rfio',rfioOpt)]
131 +        elif middleware.lower() in ['pbs']:
132 +            supported_protocol = [('rfio',rfioOpt),('local','')]
133          elif middleware.lower() in ['arc']:
134              supported_protocol = [('srmv2','-debug'),('srmv1','-debug')]
135          else:
# Line 221 | Line 223 | class cmscp:
223              print '\t tfc %s '%tfc
224              print "\t self.params['inputFilesList'] %s \n"%self.params['inputFilesList']
225                  
226 +        #if (str(self.params['lfn']).find("/store/") != -1):
227 +        #    temp = str(self.params['lfn']).split("/store/")
228 +        #    self.params['lfn']= "/store/temp/" + temp[1]
229 +        if (str(self.params['lfn']).find("/store/") == 0):
230 +            temp = str(self.params['lfn']).replace("/store/","/store/temp/",1)
231 +            self.params['lfn']= temp
232 +        
233 +        if ( self.params['lfn'][-1] != '/' ) : self.params['lfn'] = self.params['lfn'] + '/'
234 +            
235          file_backup=[]
236          for input in self.params['inputFilesList']:
237              file = self.params['lfn'] + os.path.basename(input)
# Line 232 | Line 243 | class cmscp:
243                  print '\t surl %s \n'%surl
244                      
245          destination=os.path.dirname(file_backup[0])
235 –        ### FEDE added check for final /
246          if ( destination[-1] != '/' ) : destination = destination + '/'
237 –        #####################################
247          self.params['destination']=destination
248              
249          if self.debug:
# Line 244 | Line 253 | class cmscp:
253                
254          for prot, opt in self.setProtocol( self.params['middleware'] ):
255              if self.debug: print '\tIn LocalCopy trying the stage out with %s utils \n'%prot
256 <            localCopy_results = self.copy( self.params['inputFileList'], prot, opt )
256 >            localCopy_results = self.copy( self.params['inputFileList'], prot, opt, backup='yes' )
257              if localCopy_results.keys() == [''] or localCopy_results.keys() == '' :
258                  results.update(localCopy_results)
259              else:
# Line 312 | Line 321 | class cmscp:
321  
322          return Source_SE, Destination_SE
323  
324 <    def copy( self, list_file, protocol, options ):
324 >    def copy( self, list_file, protocol, options, backup='no' ):
325          """
326          Make the real file copy using SE API
327          """
# Line 324 | Line 333 | class cmscp:
333          try:
334              Source_SE, Destination_SE = self.initializeApi( protocol )
335          except Exception, ex:
336 <            return self.updateReport('', '-1', str(ex))
336 >            for filetocopy in list_file:
337 >                results.update( self.updateReport(filetocopy, '-1', str(ex)))
338 >            return results
339  
340          # create remote dir
341          if Destination_SE.protocol in ['gridftp','rfio','srmv2']:
342              try:
343                  self.createDir( Destination_SE, Destination_SE.protocol )
344              except OperationException, ex:
345 <                return self.updateReport('', '60316', str(ex))
345 >                for filetocopy in list_file:
346 >                    results.update( self.updateReport(filetocopy, '60316', str(ex)))
347 >                return results
348              ## when the client commands are not found (wrong env or really missing)
349              except MissingCommand, ex:
350                  msg = "ERROR %s %s" %(str(ex), str(ex.detail))
351 <                return self.updateReport('', '10041', msg)
351 >                for filetocopy in list_file:
352 >                    results.update( self.updateReport(filetocopy, '10041', msg))
353 >                return results
354 >            except Exception, ex:
355 >                msg = "ERROR %s" %(str(ex))
356 >                for filetocopy in list_file:
357 >                    results.update( self.updateReport(filetocopy, '-1', msg))
358 >                return results
359  
360          ## prepare for real copy  ##
361          try :
# Line 345 | Line 365 | class cmscp:
365          except ProtocolMismatch, ex:
366              msg  = "ERROR : Unable to create SBinterface with %s protocol"%protocol
367              msg += str(ex)
368 <            return self.updateReport('', '-1', msg)
368 >            for filetocopy in list_file:
369 >                results.update( self.updateReport(filetocopy, '-1', msg))
370 >            return results
371  
372          results = {}
373          ## loop over the complete list of files
# Line 358 | Line 380 | class cmscp:
380                  msg = str(ex)  
381              if ErCode == '0':
382                  ErCode, msg = self.makeCopy( sbi, filetocopy , options, protocol,sbi_dest )
383 +                if (ErCode == '0') and (backup == 'yes'):
384 +                    ErCode = '60308'
385              if self.debug : print '\tCopy results for %s is %s'%( os.path.basename(filetocopy), ErCode)
386              results.update( self.updateReport(filetocopy, ErCode, msg))
387          return results
# Line 510 | Line 534 | class cmscp:
534          ErCode = '0'
535          msg = ''
536  
537 <        if  self.params['option'].find('space_token'):
538 <            space_tocken=self.params['option'].split('=')[1]
539 <            if protocol == 'srmv2': option = '%s -space_tocken=%s'%(option,space_tocken)
540 <            if protocol == 'srm-lcg': option = '%s -S %s'%(option,space_tocken)
537 >        if  self.params['option'].find('space_token')>0:
538 >            space_token=self.params['option'].split('=')[1]
539 >            if protocol == 'srmv2': option = '%s -space_token=%s'%(option,space_token)
540 >            if protocol == 'srm-lcg': option = '%s -S %s'%(option,space_token)
541          try:
542              sbi.copy( source_file , dest_file , opt = option)
543          except TransferException, ex:
# Line 637 | Line 661 | class cmscp:
661              reason="'%s'"%reason
662              if file:
663                  if dict['lfn']=='':
664 <                    lfn = '$LFNBaseName/'+os.path.basename(file)
664 >                    lfn = '${LFNBaseName}'+os.path.basename(file)
665                      se  = '$SE'
666 +                    LFNBaseName = '$LFNBaseName'
667                  else:
668                      lfn = dict['lfn']+os.path.basename(file)
669                      se = dict['se']
670 +                    LFNBaseName = os.path.dirname(lfn)
671 +                    if (LFNBaseName[-1] != '/'):
672 +                        LFNBaseName = LFNBaseName + '/'
673                  #dict['lfn'] # to be implemented
674                  txt += 'echo "Report for File: '+file+'"\n'
675                  txt += 'echo "LFN: '+lfn+'"\n'
676                  txt += 'echo "StorageElement: '+se+'"\n'
677                  txt += 'echo "StageOutExitStatusReason = %s" | tee -a $RUNTIME_AREA/$repo\n'%reason
678                  txt += 'echo "StageOutSE = '+se+'" >> $RUNTIME_AREA/$repo\n'
679 <                #txt += 'export LFNBaseName='+lfn+'\n'
679 >                txt += 'export LFNBaseName='+LFNBaseName+'\n'
680                  txt += 'export SE='+se+'\n'
653 –                ### FEDE per CopyData ####
681  
682                  txt += 'export endpoint='+self.params['destination']+'\n'
683                  
# Line 659 | Line 686 | class cmscp:
686              else:
687                  txt += 'echo "StageOutExitStatusReason = %s" | tee -a $RUNTIME_AREA/$repo\n'%reason
688                  cmscp_exit_status = dict['erCode']
662 –                cmscp_exit_status = dict['erCode']
689          txt += '\n'
690          txt += 'export StageOutExitStatus='+str(cmscp_exit_status)+'\n'
691 <        txt +=  'echo "StageOutExitStatus = '+str(cmscp_exit_status)+'" | tee -a $RUNTIME_AREA/$repo\n'
691 >        txt += 'echo "StageOutExitStatus = '+str(cmscp_exit_status)+'" | tee -a $RUNTIME_AREA/$repo\n'
692          outFile.write(str(txt))
693          outFile.close()
694          return

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines