Commit d8021f0b authored by Marshall Pierce's avatar Marshall Pierce
Browse files

use latest client version; improve logging output

parent 45012796

CMakeLists.txt

+1 −1
Original line number Diff line number Diff line
@@ -18,7 +18,7 @@ else(USE_LOCAL_KINETIC_CLIENT) 
        kinetic_cpp_client

        PREFIX "vendor"

        GIT_REPOSITORY "git@github.com:Seagate/Kinetic-C-Client.git"

        GIT_TAG "510bc7dea3ab162abc87ac87c2e933ea0833a7bc"

        GIT_TAG "f994d581aa0193dc1a8bfc6a83067caaa70f0b3a"

        BUILD_IN_SOURCE 1

        INSTALL_COMMAND ""

    )

src/write_file_blocking_threads.cc

+10 −7
Original line number Diff line number Diff line
@@ -16,6 +16,7 @@ using com::seagate::kinetic::proto::Message_Algorithm_SHA1; 
using kinetic::KineticConnectionFactory;

using kinetic::BlockingKineticConnection;

using kinetic::Status;

using kinetic::KineticStatus;

using kinetic::KineticRecord;

using kinetic::ConnectionOptions;

using kinetic::ConnectionHandle;
@@ -129,18 +130,20 @@ void put_range(int64_t start, int64_t end, int64_t total_size, const char* kinet 


        std::string key(key_buffer);

        std::string value(inputfile_data + i, value_size);

        if(!handle->blocking().Put(

        KineticStatus status = handle->blocking().Put(

                    key,

                    "",

                    kinetic::IGNORE_VERSION,

                KineticRecord(value, "", "", Message_Algorithm_SHA1)).ok()) {

            printf("Unable to write chunk\n");

                    KineticRecord(value, "", "", Message_Algorithm_SHA1));

        if(!status.ok()) {

            printf("Unable to write chunk: %d %s\n", static_cast<int>(status.statusCode()),

                status.message().c_str());

            return;

        }

        printf(".");

        fflush(stdout);

    }

    printf("\n");

    printf("\nThread done\n");



    if (close(file)) {

        printf("Unable to close file\n");