s4cmd.py
def delete_removed_files(self, source, target):
    '''Remove remote files that are not present in the local source.
       (Obsolete) It is used for old sync command now.
    '''
    message("Deleting files found in %s and not in %s", source, target)
    if os.path.isdir(source):
      unecessary = []
      basepath = S3URL(target).path
      for f in [f for f in self.s3walk(target) if not f['is_dir']]:
        local_name = os.path.join(source, os.path.relpath(S3URL(f['name']).path, basepath))
        if not os.path.isfile(local_name):
          message("%s not found locally, adding to delete queue", local_name)
          unecessary.append(f['name'])
      if len(unecessary) > 0:
        pool = ThreadPool(ThreadUtil, self.opt)
        for del_file in unecessary:
          pool.delete(del_file)
        pool.join()
    else:
      raise Failure('Source "%s" is not a directory.' % target)
def delete_removed_files(self, source, target):
    '''Remove remote files that are not present in the local source.
       (Obsolete) It is used for old sync command now.
    '''
    message("Deleting files found in %s and not in %s", source, target)
    if os.path.isdir(source):
      unecessary = []
      basepath = S3URL(target).path
      for f in [f for f in self.s3walk(target) if not f['is_dir']]:
        local_name = os.path.join(source, os.path.relpath(S3URL(f['name']).path, basepath))
        if not os.path.isfile(local_name):
          message("%s not found locally, adding to delete queue", local_name)
          unecessary.append(f['name'])
      if len(unecessary) > 0:
        pool = ThreadPool(ThreadUtil, self.opt)
        for del_file in unecessary:
          pool.delete(del_file)
        pool.join()
    else:
      raise Failure('Source "%s" is not a directory.' % target)
def delete_removed_files ( self , source , target ) : message ( "Deleting files found in %s and not in %s" , source , target ) if os . path . isdir ( source ) : unecessary = [ ] basepath = S3URL ( target ) . path for f in [ f for f in self . s3walk ( target ) if not f [ 'is_dir' ] ] : local_name = os . path . join ( source , os . path . relpath ( S3URL ( f [ 'name' ] ) . path , basepath ) ) if not os . path . isfile ( local_name ) : message ( "%s not found locally, adding to delete queue" , local_name ) unecessary . append ( f [ 'name' ] ) if len ( unecessary ) > 0 : pool = ThreadPool ( ThreadUtil , self . opt ) for del_file in unecessary : pool . delete ( del_file ) pool . join ( ) else : raise Failure ( 'Source "%s" is not a directory.' % target )
Remove remote files that are not present in the local source.
       (Obsolete) It is used for old sync command now.
Remove remote files that are not present in the local source . ( Obsolete ) It is used for old sync command now .