Commit 3a5ac831 authored by Scott Vokes's avatar Scott Vokes
Browse files

Add timeoutSeconds field to KineticSessionConfig and use as default timeout.

parent 33a09e0d

include/kinetic_types.h

+3 −0
Original line number Diff line number Diff line
@@ -139,6 +139,9 @@ typedef struct _KineticSessionConfig { 


    /// Set to `true' to enable SSL for for this session

    bool useSsl;



    /// Operation timeout. If 0, use the default (10 seconds).

    uint16_t timeoutSeconds;

} KineticSessionConfig;



/**

src/lib/kinetic_allocator.c

+1 −0
Original line number Diff line number Diff line
@@ -44,6 +44,7 @@ KineticSession* KineticAllocator_NewSession(struct bus * b, KineticSessionConfig 
    // Update pointer to copy of key data

    session->config.hmacKey.data = session->config.keyData;

    strncpy(session->config.host, config->host, sizeof(session->config.host));

    session->timeoutSeconds = config->timeoutSeconds;



    return session;

}

src/lib/kinetic_types_internal.c

+1 −0
Original line number Diff line number Diff line
@@ -460,6 +460,7 @@ void KineticOperation_Init(KineticOperation* op, KineticSession const * const se 
    KINETIC_ASSERT(session->connection != NULL);

    *op = (KineticOperation) {

        .connection = session->connection,

        .timeoutSeconds = session->timeoutSeconds,

    };

}

src/lib/kinetic_types_internal.h

+3 −0
Original line number Diff line number Diff line
@@ -71,6 +71,9 @@ struct _KineticSession { 
    // Client must call KineticAdminClient_DestroySession when finished with a session to shutdown

    // a session cleanly and free the `connection`.

    struct _KineticConnection* connection;



    // Default timeout.

    uint16_t timeoutSeconds;

};