amps.h

Go to the documentation of this file.

#ifndef _AMPS_H_
#define _AMPS_H_

#ifdef _WIN32
#include <WinSock2.h>
#else
#include <netdb.h>
#include <netinet/ip.h>
#include <errno.h>
#include <pthread.h>
#include <unistd.h>
#endif
#include <string.h>
#include <time.h>
#include <stdio.h>
#include "amps_generated.h"

#define AMPSDLL

#ifdef _WIN32
#define AMPS_USLEEP(x) Sleep((DWORD)(x)/(DWORD)1000);
#define AMPS_YIELD() SwitchToThread()
#else
#define AMPS_USLEEP(x) usleep((unsigned int)(x));
#define AMPS_YIELD() pthread_yield()
#endif

#ifdef _WIN32
typedef SOCKET AMPS_SOCKET;
#else
typedef int AMPS_SOCKET;
#endif
#ifndef _WIN32
typedef int32_t amps_int32_t;
typedef uint32_t amps_uint32_t;
typedef int64_t amps_int64_t;
typedef uint64_t amps_uint64_t;
#else
typedef unsigned __int64   amps_uint64_t;
typedef __int64            amps_int64_t;
typedef unsigned __int32   amps_uint32_t;
typedef __int32            amps_int32_t;
#endif

#if defined(_WIN32) || defined(__SSE_4_2__)
#define AMPS_SSE_42 1
#endif

#ifdef __cplusplus
extern "C" {
#endif

    typedef char amps_char;

    typedef void* amps_handle;

    typedef enum
    {
        AMPS_E_OK,
        AMPS_E_MEMORY,
        AMPS_E_COMMAND,
        AMPS_E_CONNECTION,
        AMPS_E_TOPIC,
        AMPS_E_FILTER,
        AMPS_E_RETRY,
        AMPS_E_DISCONNECTED,
        AMPS_E_CONNECTION_REFUSED,
        AMPS_E_STREAM,
        AMPS_E_URI,
        AMPS_E_TRANSPORT_TYPE,
        AMPS_E_USAGE,
        AMPS_E_SSL
    } amps_result;

    typedef amps_result(*amps_handler)(amps_handle, void*);
    typedef void(*amps_predisconnect_handler)(amps_handle, unsigned, void*);


    amps_handle AMPSDLL amps_client_create(
        const amps_char*   clientName);

    amps_result AMPSDLL amps_client_set_name(
        amps_handle handle,
        const amps_char*   clientName);

    amps_result AMPSDLL amps_client_connect(
        amps_handle handle,
        const amps_char*  uri);

    void AMPSDLL amps_client_disconnect(
        amps_handle handle);

    void AMPSDLL amps_client_destroy(
        amps_handle handle);

    size_t amps_client_get_error(
        amps_handle  client,
        amps_char*   errorMessageOut,
        size_t       bufferSize);

    amps_result amps_client_send(
        amps_handle client,
        amps_handle message);

    amps_result amps_client_send_with_version(
        amps_handle client,
        amps_handle message,
        unsigned* version_out);


    void amps_client_set_message_handler(
        amps_handle client,
        amps_handler messageHandler,
        void* userData);

    void amps_client_set_predisconnect_handler(
        amps_handle client,
        amps_predisconnect_handler predisconnectHandler,
        void* userData);

    void amps_client_set_disconnect_handler(
        amps_handle client,
        amps_handler disconnectHandler,
        void* userData);

    amps_handle amps_client_get_transport(
        amps_handle client);

    amps_result
    amps_client_attempt_reconnect(amps_handle client, unsigned version);

    amps_handle amps_message_create(amps_handle client);

    amps_handle amps_message_copy(amps_handle message);

    void amps_message_destroy(amps_handle message);

    void amps_message_reset(amps_handle message);

    void amps_message_get_field_value(
        amps_handle message,
        FieldId field,
        const amps_char**  value_ptr,
        size_t* length_ptr);

    void amps_message_set_field_value(
        amps_handle message,
        FieldId field,
        const amps_char* value,
        size_t   length);

    void amps_message_assign_field_value(
        amps_handle message,
        FieldId field,
        const amps_char* value,
        size_t   length);

    void amps_message_set_field_value_nts(
        amps_handle message,
        FieldId field,
        const amps_char* value);


    void amps_message_set_field_guid(
        amps_handle message,
        FieldId field);

    void amps_message_set_data(
        amps_handle message,
        const amps_char* value,
        size_t   length);

    void amps_message_assign_data(
        amps_handle message,
        const amps_char* value,
        size_t   length);

    void amps_message_set_data_nts(
        amps_handle message,
        const amps_char* value);

    void amps_message_get_data(
        amps_handle message,
        amps_char** value_ptr,
        size_t*     length_ptr);

    unsigned long amps_message_get_field_long(
        amps_handle message,
        FieldId field);

    amps_uint64_t amps_message_get_field_uint64(
        amps_handle message,
        FieldId field);

    amps_result amps_client_set_read_timeout(
        amps_handle client,
        int readTimeout);


    amps_result amps_client_set_idle_time(
        amps_handle client,
        int idleTime);

typedef void(*amps_transport_filter_function)(const unsigned char*,size_t,short,void*);

    amps_result amps_client_set_transport_filter_function(
        amps_handle client,
        amps_transport_filter_function filter,
        void* userData);

    AMPS_SOCKET
    amps_tcp_get_socket(amps_handle transport);

    void*
    amps_tcps_get_SSL(amps_handle transport);

/*
 * Returns the current wall-clock time in milliseconds
 */
    amps_uint64_t
    amps_now(void);


int amps_ssl_init(const char* dllPath_);

int amps_ssl_set_verify(int mode_);

int amps_ssl_load_verify_locations(const char* caFile_, const char* caPath_);

void amps_ssl_free(void);

const char* amps_ssl_get_error(void);


/*
 * Internal API for use by the python client.
 */
void amps_set_waiting_function(void*);
void amps_invoke_waiting_function(void);

#ifdef __cplusplus
}
#ifndef _AMPS_BUILD_C_CLIENT
#include <ampsplusplus.hpp>
#endif
#endif

#endif