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

Start changing to use blocking API

parent 3bb3cb89

.gitignore

+1 −0
Original line number Diff line number Diff line
@@ -20,3 +20,4 @@ kinetic_cpp_client_examples.xcodeproj/ 
delete_file_nonblocking

write_file_nonblocking

/firmware_update

blocking_example

CMakeLists.txt

+7 −7
Original line number Diff line number Diff line
@@ -58,16 +58,16 @@ macro(add_example_target NAME) 
    )

endmacro(add_example_target)



add_example_target(kineticstat)

add_example_target(async)

add_example_target(ise)

add_example_target(setclusterversion)

add_example_target(setpin)

add_example_target(set_acls)

#add_example_target(kineticstat)

#add_example_target(async)

#add_example_target(ise)

#add_example_target(setclusterversion)

#add_example_target(setpin)

#add_example_target(set_acls)

add_example_target(write_file_blocking)

add_example_target(read_file_blocking)

add_example_target(read_file_nonblocking)

add_example_target(delete_file_nonblocking)

add_example_target(write_file_nonblocking)

add_example_target(firmware_update)

#add_example_target(firmware_update)

src/async.cc

+1 −2
Original line number Diff line number Diff line
@@ -40,8 +40,7 @@ int main(int argc, char* argv[]) { 
    HmacProvider hmac_provider;

    ValueFactory value_factory;

    MessageStreamFactory message_stream_factory(NULL, value_factory);

    kinetic::KineticConnectionFactory kinetic_connection_factory(hmac_provider,

            message_stream_factory);

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



    kinetic::NonblockingKineticConnection *connection;

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

src/delete_file_nonblocking.cc

+8 −11
Original line number Diff line number Diff line
@@ -57,26 +57,23 @@ int main(int argc, char* argv[]) { 
    options.user_id = 1;

    options.hmac_key = "asdfasdf";



    HmacProvider hmac_provider;

    ValueFactory value_factory;

    MessageStreamFactory message_stream_factory(NULL, value_factory);

    kinetic::KineticConnectionFactory kinetic_connection_factory(hmac_provider,

            message_stream_factory);



    kinetic::KineticConnection* kinetic_connection;

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

    KineticConnectionFactory kinetic_connection_factory = kinetic::NewKineticConnectionFactory();



    kinetic::BlockingKineticConnection* kinetic_connection;

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

        printf("Unable to connect\n");

        return 1;

    }





    std::string value;

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

    KineticRecord* record;

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

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

        return 1;

    }



    unsigned int file_size = std::stoi(value);

    unsigned int file_size = std::stoi(record->value());

    delete record;

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

src/firmware_update.cc

+1 −5
Original line number Diff line number Diff line
@@ -36,11 +36,7 @@ int main(int argc, char* argv[]) { 
    options.user_id = 1;

    options.hmac_key = "asdfasdf";



    HmacProvider hmac_provider;

    ValueFactory value_factory;

    MessageStreamFactory message_stream_factory(NULL, value_factory);

    kinetic::KineticConnectionFactory kinetic_connection_factory(hmac_provider,

            message_stream_factory);

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



    kinetic::KineticConnection* kinetic_connection;

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