Commit 069c1a9c authored by Job Vranish's avatar Job Vranish
Browse files

cleaned up some of the examples

parent e069e351

src/examples/get_key_range.c

+4 −3
Original line number Diff line number Diff line
@@ -47,8 +47,9 @@ int main(int argc, char** argv) 
            .hmacKey = ByteArray_CreateWithCString(HmacKeyString)

        }

    };

    KineticClient_Init("stdout", 0);

    status = KineticClient_CreateConnection(&session);

    KineticClient * client = KineticClient_Init("stdout", 0);

    if (client == NULL) { return 1; }

    status = KineticClient_CreateConnection(&session, client);

    if (status != KINETIC_STATUS_SUCCESS) {

        fprintf(stderr, "Connection to host '%s' failed w/ status: %s\n",

            session.config.host, Kinetic_GetStatusDescription(status));
@@ -105,7 +106,7 @@ int main(int argc, char** argv) 


    // Shutdown client connection and cleanup

    KineticClient_DestroyConnection(&session);

    KineticClient_Shutdown();

    KineticClient_Shutdown(client);

    printf("Key range retrieved successfully!\n");



    return 0;

src/examples/write_file_blocking.c

+4 −3
Original line number Diff line number Diff line
@@ -109,8 +109,9 @@ int main(int argc, char** argv) 
        }

    };

    write_args* writeArgs = calloc(1, sizeof(write_args));

    KineticClient_Init("stdout", 0);

    status = KineticClient_CreateConnection(&session);

    KineticClient * client = KineticClient_Init("stdout", 0);

    if (client == NULL) { return 1; }

    status = KineticClient_CreateConnection(&session, client);

    if (status != KINETIC_STATUS_SUCCESS) {

        fprintf(stderr, "Connection to host '%s' failed w/ status: %s\n",

            session.config.host, Kinetic_GetStatusDescription(status));
@@ -144,7 +145,7 @@ int main(int argc, char** argv) 


    // Shutdown client connection and cleanup

    KineticClient_DestroyConnection(writeArgs->session);

    KineticClient_Shutdown();

    KineticClient_Shutdown(client);

    free(writeArgs);

    free(buf);

src/examples/write_file_blocking_threads.c

+4 −3
Original line number Diff line number Diff line
@@ -97,7 +97,8 @@ int main(int argc, char** argv) 
    }



    // Initialize kinetic-c and configure sessions

    KineticClient_Init("stdout", 0);

    KineticClient * client = KineticClient_Init("stdout", 0);

    if (client == NULL) { return 1; }



    write_args* writeArgs = calloc(NUM_FILES, sizeof(write_args));

    if (writeArgs == NULL) {
@@ -117,7 +118,7 @@ int main(int argc, char** argv) 


        // Establish connection

        writeArgs[i].session = (KineticSession){.config = config};

        status = KineticClient_CreateConnection(&writeArgs[i].session);

        status = KineticClient_CreateConnection(&writeArgs[i].session, client);

        if (status != KINETIC_STATUS_SUCCESS) {

            fprintf(stderr, "Failed connecting to the Kinetic device w/status: %s\n",

                Kinetic_GetStatusDescription(status));
@@ -164,7 +165,7 @@ int main(int argc, char** argv) 
    }



    // Shutdown client connection and cleanup

    KineticClient_Shutdown();

    KineticClient_Shutdown(client);

    free(writeArgs);

    free(buf);

src/examples/write_file_nonblocking.c

+4 −3
Original line number Diff line number Diff line
@@ -53,7 +53,8 @@ int main(int argc, char** argv) 
    (void)argv;



    // Initialize kinetic-c and establish session

    KineticClient_Init("stdout", 0);

    KineticClient * client = KineticClient_Init("stdout", 0);

    if (client == NULL) { return 1; }

    const char HmacKeyString[] = "asdfasdf";

    const KineticSessionConfig config = {

        .host = "localhost",
@@ -63,7 +64,7 @@ int main(int argc, char** argv) 
        .hmacKey = ByteArray_CreateWithCString(HmacKeyString),

    };

    KineticSession session = {.config = config};

    KineticStatus status = KineticClient_CreateConnection(&session);

    KineticStatus status = KineticClient_CreateConnection(&session, client);

    if (status != KINETIC_STATUS_SUCCESS) {

        fprintf(stderr, "Failed connecting to the Kinetic device w/status: %s\n",

            Kinetic_GetStatusDescription(status));
@@ -89,7 +90,7 @@ int main(int argc, char** argv) 


    // Shutdown client connection and cleanup

    KineticClient_DestroyConnection(&session);

    KineticClient_Shutdown();

    KineticClient_Shutdown(client);



    return 0;

}

src/examples/write_file_nonblocking_threads.c

+4 −3
Original line number Diff line number Diff line
@@ -92,10 +92,11 @@ int main(int argc, char** argv) 
            .hmacKey = ByteArray_CreateWithCString(HmacKeyString),

        }

    };

    KineticClient_Init("stdout", 0);

    KineticClient * client = KineticClient_Init("stdout", 0);

    if (client == NULL) { return 1; }



    // Establish connection

    KineticStatus status = KineticClient_CreateConnection(&session);

    KineticStatus status = KineticClient_CreateConnection(&session, client);

    if (status != KINETIC_STATUS_SUCCESS) {

        fprintf(stdout, "Failed connecting to the Kinetic device w/status: %s\n",

            Kinetic_GetStatusDescription(status));
@@ -157,7 +158,7 @@ int main(int argc, char** argv) 
    

    // Shutdown client connection and cleanup

    KineticClient_DestroyConnection(&session);

    KineticClient_Shutdown();

    KineticClient_Shutdown(client);



    return success ? 0 : -1;

}