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

Update examples to use new API

parent 858a432a

src/delete_file_nonblocking.cc

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


    KineticConnectionFactory kinetic_connection_factory = kinetic::NewKineticConnectionFactory();



    kinetic::BlockingKineticConnection* kinetic_connection;

    if(!kinetic_connection_factory.NewBlockingConnection(options, &kinetic_connection).ok()) {

    kinetic::ConnectionHandle* connection;

    if(!kinetic_connection_factory.NewConnection(options, &connection).ok()) {

        printf("Unable to connect\n");

        return 1;

    }





    KineticRecord* record;

    if(!kinetic_connection->Get(kinetic_key, &record).ok()) {

    if(!connection->blocking().Get(kinetic_key, &record).ok()) {

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

        return 1;

    }
@@ -76,12 +76,6 @@ int main(int argc, char* argv[]) { 
    delete record;

    printf("Deleting file of size %llu\n", file_size);





    delete kinetic_connection;



    kinetic::NonblockingKineticConnection* connection;

    kinetic_connection_factory.NewNonblockingConnection(options, &connection);



    char key_buffer[100];

    int remaining = 0;

    for (int64_t i = 0; i < file_size; i += 1024*1024) {
@@ -94,18 +88,18 @@ int main(int argc, char* argv[]) { 
        remaining++;

        DeleteCallback* callback = new DeleteCallback(&remaining);

        std::string key(key_buffer);

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

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

    }



    remaining++;

    connection->Delete(kinetic_key, "", true, new DeleteCallback(&remaining));

    connection->nonblocking().Delete(kinetic_key, "", true, new DeleteCallback(&remaining));





    fd_set read_fds, write_fds;

    int num_fds = 0;

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

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

    while (remaining > 0) {

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

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

    }



    printf("\nDone!\n");

src/firmware_update.cc

+3 −3
Original line number Diff line number Diff line
@@ -37,8 +37,8 @@ int main(int argc, char* argv[]) { 


    kinetic::KineticConnectionFactory kinetic_connection_factory = kinetic::NewKineticConnectionFactory();



    kinetic::BlockingKineticConnection* kinetic_connection;

    if (!kinetic_connection_factory.NewBlockingConnection(options, &kinetic_connection).ok()) {

    kinetic::ConnectionHandle* connection;

    if (!kinetic_connection_factory.NewConnection(options, &connection).ok()) {

        printf("Unable to connect\n");

        return 1;

    }
@@ -52,7 +52,7 @@ int main(int argc, char* argv[]) { 
        contents << in.rdbuf();

    }



    if (!kinetic_connection->UpdateFirmware(contents.str()).ok()) {

    if (!connection->blocking().UpdateFirmware(contents.str()).ok()) {

        printf("Unable to send firmware\n");

        return 1;

    }

src/ise.cc

+3 −3
Original line number Diff line number Diff line
@@ -36,8 +36,8 @@ int main(int argc, char* argv[]) { 


    kinetic::KineticConnectionFactory kinetic_connection_factory = kinetic::NewKineticConnectionFactory();



    kinetic::BlockingKineticConnection* kinetic_connection;

    if (!kinetic_connection_factory.NewBlockingConnection(options, &kinetic_connection).ok()) {

    kinetic::ConnectionHandle* connection;

    if (!kinetic_connection_factory.NewConnection(options, &connection).ok()) {

        printf("Unable to connect\n");

        return 1;

    }
@@ -51,7 +51,7 @@ int main(int argc, char* argv[]) { 
        printf("Performing ISE on %s:%d with pin %s\n", host, port, argv[3]);

    }



    bool success = kinetic_connection->InstantSecureErase(pin).ok();

    bool success = connection->blocking().InstantSecureErase(pin).ok();



    if (pin) {

        delete pin;

src/kineticstat.cc

+4 −4
Original line number Diff line number Diff line
@@ -41,8 +41,8 @@ int main(int argc, char* argv[]) { 


    kinetic::KineticConnectionFactory kinetic_connection_factory = kinetic::NewKineticConnectionFactory();



    kinetic::BlockingKineticConnection* kinetic_connection;

    if(!kinetic_connection_factory.NewBlockingConnection(options, &kinetic_connection).ok()) {

    kinetic::ConnectionHandle* connection;

    if(!kinetic_connection_factory.NewConnection(options, &connection).ok()) {

        printf("Unable to connect\n");

        return 1;

    }
@@ -50,7 +50,7 @@ int main(int argc, char* argv[]) { 
    if (argc == 2) {

        // User just specified host so dump everything

        DriveLog drive_log;

        if(!kinetic_connection->GetLog(&drive_log).ok()) {

        if(!connection->blocking().GetLog(&drive_log).ok()) {

            printf("Unable to get log\n");

            return 1;

        }
@@ -64,7 +64,7 @@ int main(int argc, char* argv[]) { 
        int report_number = 0;

        while (true) {

            DriveLog drive_log;

            if(!kinetic_connection->GetLog(&drive_log).ok()) {

            if(!connection->blocking().GetLog(&drive_log).ok()) {

                printf("Unable to get log\n");

                return 1;

            }

src/read_file_blocking.cc

+4 −4
Original line number Diff line number Diff line
@@ -40,15 +40,15 @@ int main(int argc, char* argv[]) { 


    KineticConnectionFactory kinetic_connection_factory = kinetic::NewKineticConnectionFactory();



    kinetic::BlockingKineticConnection* kinetic_connection;

    if(!kinetic_connection_factory.NewBlockingConnection(options, &kinetic_connection).ok()) {

    kinetic::ConnectionHandle* connection;

    if(!kinetic_connection_factory.NewConnection(options, &connection).ok()) {

        printf("Unable to connect\n");

        return 1;

    }





    KineticRecord* record;

    if(!kinetic_connection->Get(kinetic_key, &record).ok()) {

    if(!connection->blocking().Get(kinetic_key, &record).ok()) {

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

        return 1;

    }
@@ -82,7 +82,7 @@ int main(int argc, char* argv[]) { 
        std::string key(key_buffer);



        KineticRecord* record;

        if(!kinetic_connection->Get(key, &record).ok()) {

        if(!connection->blocking().Get(key, &record).ok()) {

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

            return 1;

        }