CosNCopyFileTask.java

package org.apache.hadoop.fs;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;

public class CosNCopyFileTask implements Runnable {
    private static final Logger LOG = LoggerFactory.getLogger(CosNCopyFileTask.class);

    private final NativeFileSystemStore store;

    private final String srcKey;
    private final FileMetadata srcFileMetadata;
    private final String dstKey;
    private final CosNCopyFileContext cosCopyFileContext;

    public CosNCopyFileTask(NativeFileSystemStore store,
                            String srcKey, FileMetadata srcFileMetadata,
                            String dstKey,
                            CosNCopyFileContext cosCopyFileContext) {
        this.store = store;
        this.srcKey = srcKey;
        this.srcFileMetadata = srcFileMetadata;
        this.dstKey = dstKey;
        this.cosCopyFileContext = cosCopyFileContext;
    }

    @Override
    public void run() {
        boolean fail = false;
        try {
            this.store.copy(srcKey, this.srcFileMetadata, dstKey);
        } catch (IOException e) {
            LOG.warn("Exception thrown when copy from {} to {}", this.srcKey, this.dstKey, e);
            fail = true;
        } finally {
            this.cosCopyFileContext.lock();
            if (fail) {
                cosCopyFileContext.setCopySuccess(false);
            }
            cosCopyFileContext.incCopiesFinish();
            cosCopyFileContext.signalAll();
            cosCopyFileContext.unlock();
        }
    }
}