Commit 263f2c12 authored by Marshall Pierce's avatar Marshall Pierce
Browse files

use extended info from nonblocking staus

parent 2a1f1c73

src/delete_file_nonblocking.cc

+1 −1
Original line number Diff line number Diff line
@@ -26,7 +26,7 @@ public: 
    }



    void Failure(KineticStatus error) {

        printf("Error!\n");

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

        exit(1);

    }

private:

src/write_file_nonblocking.cc

+1 −2
Original line number Diff line number Diff line
@@ -28,7 +28,7 @@ public: 
        (*remaining_)--;

    }

    void Failure(KineticStatus error) {

        printf("Error!\n");

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

        exit(1);

    }

private:
@@ -88,7 +88,6 @@ int main(int argc, char* argv[]) { 
        remaining++;

        connection->nonblocking().Put(key, "", kinetic::IGNORE_VERSION, record, callback);

        connection->nonblocking().Run(&read_fds, &write_fds, &num_fds);



    }



    auto record = make_shared<KineticRecord>(std::to_string(inputfile_stat.st_size), "", "", Message_Algorithm_SHA1);