void ObjectSample::UploadObjectProgress()

in sample/src/object/ObjectSample.cc [319:365]

• 39 lines of code
• 4 McCabe index (conditional complexity)

void ObjectSample::UploadObjectProgress() 
{
    //case 1: checkpoint dir is not enabled
    {
        UploadObjectRequest request(bucket_, "UploadObjectProgress", Config::FileToUpload);

        TransferProgress progressCallback = { ProgressCallback , this };
        request.setTransferProgress(progressCallback);
        auto outcome = client->ResumableUploadObject(request);
        if (outcome.isSuccess()) {
            std::cout << __FUNCTION__ << "[" << this << "]" << " success, ETag:" << outcome.result().ETag() << std::endl;
        }
        else {
            PrintError(__FUNCTION__, outcome.error());
        }
    }

    //case 2: checkpoint dir is enabled
    {
        UploadObjectRequest request(bucket_, "UploadObjectProgress", Config::FileToUpload, Config::CheckpointDir);
  
        TransferProgress progressCallback = { ProgressCallback , this };
        request.setTransferProgress(progressCallback);
        auto outcome = client->ResumableUploadObject(request);
        if (outcome.isSuccess()) {
            std::cout << __FUNCTION__ << "[" << this << "]" << " success, ETag:" << outcome.result().ETag() << std::endl;
        }
        else {
            PrintError(__FUNCTION__, outcome.error());
        }
    }

    //case 3: checkpoint dir, multi threads is enabled
    {
        UploadObjectRequest request(bucket_, "UploadObjectProgress", Config::FileToUpload, Config::CheckpointDir, DefaultPartSize, 4);

        TransferProgress progressCallback = { ProgressCallback , this };
        request.setTransferProgress(progressCallback);
        auto outcome = client->ResumableUploadObject(request);
        if (outcome.isSuccess()) {
            std::cout << __FUNCTION__ << "[" << this << "]" << " success, ETag:" << outcome.result().ETag() << std::endl;
        }
        else {
            PrintError(__FUNCTION__, outcome.error());
        }
    }
}