Commit 447c5903 authored by Andrew Mitchell's avatar Andrew Mitchell
Browse files

Bumped client version and updated uses of WriteMode

parent bbe8dc9e

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 "https://github.com/Seagate/kinetic-cpp-client.git"

        GIT_TAG "161c2b7005c7c2b33e6de8197869efb4454d000b"

        GIT_TAG "9e8ea1af7f3c3e748c03286549c445683d4d7b22"

        BUILD_IN_SOURCE 1

        INSTALL_COMMAND ""

    )

src/delete_file_blocking.cc

+2 −2
Original line number Diff line number Diff line
@@ -75,7 +75,7 @@ int main(int argc, char* argv[]) { 


        sprintf(key_buffer, "%s-%10" PRId64, kinetic_key, i);

        std::string key(key_buffer);

        if (blocking_connection->Delete(key, "", kinetic::IGNORE_VERSION).ok()) {

        if (blocking_connection->Delete(key, "", kinetic::WriteMode::IGNORE_VERSION).ok()) {

            printf(".");

        } else {

            printf("X");
@@ -83,7 +83,7 @@ int main(int argc, char* argv[]) { 
        fflush(stdout);

    }



    if (!blocking_connection->Delete(kinetic_key, "", kinetic::IGNORE_VERSION).ok()) {

    if (!blocking_connection->Delete(kinetic_key, "", kinetic::WriteMode::IGNORE_VERSION).ok()) {

        printf("Unable to delete metadata\n");

    }

src/delete_file_nonblocking.cc

+2 −2
Original line number Diff line number Diff line
@@ -103,11 +103,11 @@ int main(int argc, char* argv[]) { 
        sprintf(key_buffer, "%s-%10" PRId64, kinetic_key, i);

        remaining++;

        std::string key(key_buffer);

        nonblocking_connection->Delete(key, "", kinetic::IGNORE_VERSION, callback);

        nonblocking_connection->Delete(key, "", kinetic::WriteMode::IGNORE_VERSION, callback);

    }



    remaining++;

    nonblocking_connection->Delete(kinetic_key, "", kinetic::IGNORE_VERSION, callback);

    nonblocking_connection->Delete(kinetic_key, "", kinetic::WriteMode::IGNORE_VERSION, callback);





    fd_set read_fds, write_fds;

src/write_file_blocking.cc

+2 −2
Original line number Diff line number Diff line
@@ -68,7 +68,7 @@ int example_main( 
        if(!blocking_connection->Put(

                key,

                "",

                kinetic::IGNORE_VERSION,

                kinetic::WriteMode::IGNORE_VERSION,

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

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

            return 1;
@@ -82,7 +82,7 @@ int example_main( 
    if (!blocking_connection->Put(

            FLAGS_kinetic_key,

            "",

            kinetic::IGNORE_VERSION,

            kinetic::WriteMode::IGNORE_VERSION,

            KineticRecord(to_string(inputfile_stat.st_size), "", "", Message_Algorithm_SHA1)).ok()) {

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

        return 1;

src/write_file_blocking_threads.cc

+2 −2
Original line number Diff line number Diff line
@@ -114,7 +114,7 @@ int main(int argc, char* argv[]) { 
    if (!blocking_connection->Put(

            kinetic_key,

            "",

            kinetic::IGNORE_VERSION,

            kinetic::WriteMode::IGNORE_VERSION,

            KineticRecord(std::to_string(inputfile_stat.st_size), "", "", Message_Algorithm_SHA1)).ok()) {

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

        return 1;
@@ -151,7 +151,7 @@ void put_range(int64_t start, int64_t end, int64_t total_size, const char* kinet 
        KineticStatus status = blocking_connection->Put(

                    key,

                    "",

                    kinetic::IGNORE_VERSION,

                    kinetic::WriteMode::IGNORE_VERSION,

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

        if(!status.ok()) {

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