Commit bd57477d authored by Manuel Wudka-Robles's avatar Manuel Wudka-Robles
Browse files

Merge pull request #10 from Seagate/features/put-mode 

use WriteMode
parents 423dba52 d805272a

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 "d91b9075f4d7f0460413940ddf5dfa0045aed6f4"

        GIT_TAG "aec51b65cec4fda90ed4f1ac50e5ba4d01bf4dce"

        BUILD_IN_SOURCE 1

        INSTALL_COMMAND ""

    )

src/delete_file_blocking.cc

+2 −3
Original line number Diff line number Diff line
@@ -6,7 +6,6 @@ 


#include "kinetic/connection_options.h"

#include "kinetic/kinetic_connection_factory.h"

#include "value_factory.h"

#include "socket_wrapper.h"



using com::seagate::kinetic::proto::Message_Algorithm_SHA1;
@@ -60,7 +59,7 @@ int main(int argc, char* argv[]) { 


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

        std::string key(key_buffer);

        if (connection->blocking().Delete(key, "", true).ok()) {

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

            printf(".");

        } else {

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

    }



    if (!connection->blocking().Delete(kinetic_key, "", true).ok()) {

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

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

    }

src/delete_file_nonblocking.cc

+2 −3
Original line number Diff line number Diff line
@@ -6,7 +6,6 @@ 


#include "kinetic/connection_options.h"

#include "kinetic/kinetic_connection_factory.h"

#include "value_factory.h"

#include "socket_wrapper.h"



using kinetic::KineticConnectionFactory;
@@ -79,11 +78,11 @@ int main(int argc, char* argv[]) { 
        sprintf(key_buffer, "%s-%10" PRId64, kinetic_key, i);

        remaining++;

        std::string key(key_buffer);

        connection->nonblocking().Delete(key, "", true, &callback);

        connection->nonblocking().Delete(key, "", kinetic::IGNORE_VERSION, &callback);

    }



    remaining++;

    connection->nonblocking().Delete(kinetic_key, "", true, &callback);

    connection->nonblocking().Delete(kinetic_key, "", kinetic::IGNORE_VERSION, &callback);





    fd_set read_fds, write_fds;

src/firmware_update.cc

+0 −1
Original line number Diff line number Diff line
@@ -7,7 +7,6 @@ 


#include "kinetic/connection_options.h"

#include "kinetic/kinetic_connection_factory.h"

#include "value_factory.h"



using kinetic::KineticConnectionFactory;

using kinetic::Status;

src/ise.cc

+0 −1
Original line number Diff line number Diff line
@@ -6,7 +6,6 @@ 


#include "kinetic/connection_options.h"

#include "kinetic/kinetic_connection_factory.h"

#include "value_factory.h"



using kinetic::KineticConnectionFactory;

using kinetic::Status;