Commit f4f504d3 authored by Job Vranish's avatar Job Vranish
Browse files

fixed remaining system tests

parent bcdf29e3

test/system/test_system_async_io.c

+3 −4
Original line number Diff line number Diff line
@@ -60,7 +60,6 @@ KineticStatus wait_for_put_finish(FileTransferProgress* const transfer); 
static int put_chunk_of_file(FileTransferProgress* transfer);

static void put_chunk_of_file_finished(KineticCompletionData* kinetic_data, void* client_data);





void test_kinetic_client_should_store_a_binary_object_split_across_entries_via_ovelapped_asynchronous_IO_operations(void)

{

    // Initialize kinetic-c and configure sessions
@@ -74,10 +73,10 @@ void test_kinetic_client_should_store_a_binary_object_split_across_entries_via_o 
            .hmacKey = ByteArray_CreateWithCString(HmacKeyString),

        },

    };

    KineticClient_Init("stdout", 0);

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



    // Establish connection

    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));
@@ -103,7 +102,7 @@ void test_kinetic_client_should_store_a_binary_object_split_across_entries_via_o 


    // Shutdown client connection and cleanup

    KineticClient_DestroyConnection(&session);

    KineticClient_Shutdown();

    KineticClient_Shutdown(client);

}

test/system/test_system_bus.c

+0 −21
Original line number Diff line number Diff line
@@ -53,27 +53,6 @@ void tearDown(void) 


}



enum socket_state {

    STATE_UNINIT = 0,

    STATE_AWAITING_HEADER,

    STATE_AWAITING_BODY,

};



enum unpack_error {

    UNPACK_ERROR_UNDEFINED,

    UNPACK_ERROR_SUCCESS,

    UNPACK_ERROR_INVALID_HEADER,

    UNPACK_ERROR_PAYLOAD_MALLOC_FAIL,

};



typedef struct {

    enum socket_state state;

    KineticPDUHeader header;

    enum unpack_error unpack_status;

    size_t accumulated;

    uint8_t buf[];

} socket_info;



static void log_cb(log_event_t event, int log_level, const char *msg, void *udata) {

    (void)udata;

    const char *event_str = bus_log_event_str(event);

test/system/test_system_overlapped_io.c

+4 −4
Original line number Diff line number Diff line
@@ -53,15 +53,15 @@ struct kinetic_thread_arg { 


static void* kinetic_put(void* kinetic_arg);





KineticClient * client;

void setUp(void)

{

    KineticClient_Init("stdout", 0);

    client = KineticClient_Init("stdout", 0);

}



void tearDown(void)

{

    KineticClient_Shutdown();

    KineticClient_Shutdown(client);

}



void test_kinetic_client_should_be_able_to_store_an_arbitrarily_large_binary_object_and_split_across_entries_via_ovelapped_IO_operations(void)
@@ -100,7 +100,7 @@ void test_kinetic_client_should_be_able_to_store_an_arbitrarily_large_binary_obj 
            kt_arg[i].session.config = sessionConfig;

            TEST_ASSERT_EQUAL_KineticStatus(

                KINETIC_STATUS_SUCCESS,

                KineticClient_CreateConnection(&kt_arg[i].session));

                KineticClient_CreateConnection(&kt_arg[i].session, client));

            strcpy(kt_arg[i].ip, sessionConfig.host);



            // Create a ByteBuffer for consuming chunks of data out of for overlapped PUTs

test/system/test_system_p2pop.c

+1 −0
Original line number Diff line number Diff line
@@ -19,6 +19,7 @@ 
*/

#include "system_test_fixture.h"

#include "kinetic_client.h"

#include <stdlib.h>



static SystemTestFixture Fixture;