'Process a REVERT job.'

def _revert(self, job, begin):

    self.logger.increment(('partition.delete.count.%s' % (job['local_dev']['device'],)))
    syncd_with = 0
    reverted_objs = {}
    for node in job['sync_to']:
        (success, in_sync_objs) = ssync_sender(self, node, job, job['suffixes'])()
        if success:
            self.rehash_remote(node, job, job['suffixes'])
            syncd_with += 1
            reverted_objs.update(in_sync_objs)
    if (syncd_with >= len(job['sync_to'])):
        self.delete_reverted_objs(job, reverted_objs, job['frag_index'])
    else:
        self.handoffs_remaining += 1
    self.logger.timing_since('partition.delete.timing', begin)
