Commit 434ac692 authored by Marshall Pierce's avatar Marshall Pierce
Browse files

Update callbacks to take a KineticStatus

parent d3140e92

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

        GIT_TAG "d9348e1ee9ce55df828ef953e775205ed3ef46c3"

        BUILD_IN_SOURCE 1

        INSTALL_COMMAND ""

    )

src/delete_file_nonblocking.cc

+2 −2
Original line number Diff line number Diff line
@@ -8,7 +8,7 @@ 


using kinetic::KineticConnectionFactory;

using kinetic::KineticRecord;

using kinetic::StatusCode;

using kinetic::KineticStatus;

using kinetic::SimpleCallbackInterface;

using kinetic::Status;
@@ -25,7 +25,7 @@ public: 
        (*remaining_)--;

    }



    void Failure(StatusCode error) {

    void Failure(KineticStatus error) {

        printf("Error!\n");

        exit(1);

    }

src/read_file_nonblocking.cc

+3 −3
Original line number Diff line number Diff line
@@ -15,7 +15,7 @@ using kinetic::KineticRecord; 
using kinetic::ConnectionOptions;

using kinetic::GetCallbackInterface;

using kinetic::NonblockingKineticConnection;

using kinetic::StatusCode;

using kinetic::KineticStatus;



using std::shared_ptr;

using std::vector;
@@ -36,8 +36,8 @@ public: 
        fflush(stdout);

        (*remaining_)--;

    }

    void Failure(StatusCode error) {

        printf("Error: %d\n", static_cast<int>(error));

    void Failure(KineticStatus error) {

        printf("Error: %d %s\n", static_cast<int>(error.statusCode()), error.message().c_str());

        exit(1);

    }

private:

src/write_file_nonblocking.cc

+2 −2
Original line number Diff line number Diff line
@@ -14,7 +14,7 @@ using kinetic::KineticConnectionFactory; 
using kinetic::Status;

using kinetic::KineticRecord;

using kinetic::PutCallbackInterface;

using kinetic::StatusCode;

using kinetic::KineticStatus;



using std::make_shared;

using std::unique_ptr;
@@ -27,7 +27,7 @@ public: 
        fflush(stdout);

        (*remaining_)--;

    }

    void Failure(StatusCode error) {

    void Failure(KineticStatus error) {

        printf("Error!\n");

        exit(1);

    }