33 #include <netinet/ip.h> 41 #include "amps_generated.h" 46 #define AMPS_USLEEP(x) Sleep((DWORD)(x)/(DWORD)1000); 47 #define AMPS_YIELD() SwitchToThread() 48 typedef HANDLE AMPS_THREAD_T;
49 typedef SOCKET AMPS_SOCKET;
50 typedef __int32 amps_int32_t;
51 typedef unsigned __int32 amps_uint32_t;
52 typedef __int64 amps_int64_t;
53 typedef unsigned __int64 amps_uint64_t;
55 #define AMPS_USLEEP(x) usleep((unsigned int)(x)); 56 #define AMPS_YIELD() pthread_yield() 57 typedef pthread_t AMPS_THREAD_T;
58 typedef int AMPS_SOCKET;
59 typedef int32_t amps_int32_t;
60 typedef uint32_t amps_uint32_t;
61 typedef int64_t amps_int64_t;
62 typedef uint64_t amps_uint64_t;
65 #if defined(_WIN32) || defined(__SSE_4_2__) 171 typedef char amps_char;
245 typedef void(*amps_predisconnect_handler)(
amps_handle, unsigned,
void*);
258 const amps_char* clientName);
272 const amps_char* clientName);
283 const amps_char* uri);
311 amps_char* errorMessageOut,
323 amps_handle message);
336 unsigned* version_out);
349 amps_handler messageHandler,
362 amps_predisconnect_handler predisconnectHandler,
375 amps_handler disconnectHandler,
446 const amps_char** value_ptr,
459 const amps_char* value,
472 const amps_char* value,
485 const amps_char* value);
506 const amps_char* value,
517 const amps_char* value,
527 const amps_char* value);
543 amps_char** value_ptr,
654 amps_tcps_get_socket(amps_handle transport);
731 void amps_noOpFn(
void*);
736 void amps_set_waiting_function(
void*);
737 void amps_invoke_waiting_function(
void);
738 void amps_set_remove_route_function(
void*);
739 void amps_invoke_remove_route_function(
void*);
740 void amps_set_copy_route_function(
void*);
741 void* amps_invoke_copy_route_function(
void*);
745 #if !defined(_AMPS_BUILD_C_CLIENT) && !defined(_AMPS_SKIP_AMPSPLUSPLUS) A connection error occured.
Definition: amps.h:201
int amps_ssl_load_verify_locations(const char *caFile_, const char *caPath_)
Configures OpenSSL to use the specified locations for locating CA certificates.
The specified URI is invalid.
Definition: amps.h:229
void amps_message_reset(amps_handle message)
Clears all fields and data in a message.
void amps_message_assign_data(amps_handle message, const amps_char *value, size_t length)
Assigns the data component of an AMPS message, without copying the value.
amps_handle amps_message_copy(amps_handle message)
Creates and returns a handle to a new AMPS message object that is a deep copy of the message passed i...
A Secure Sockets Layer (SSL) error occured.
Definition: amps.h:241
void AMPSDLL amps_client_disconnect(amps_handle handle)
Disconnects from the AMPS server, if connected.
amps_result amps_client_set_read_timeout(amps_handle client, int readTimeout)
Sets a read timeout (seconds), in which if no message is received, the connection is presumed dead...
size_t amps_client_get_error(amps_handle client, amps_char *errorMessageOut, size_t bufferSize)
Returns the last error set on this client.
void amps_message_set_field_value_nts(amps_handle message, FieldId field, const amps_char *value)
Sets the value of a header field in an AMPS message from a null-terminated string.
Success.
Definition: amps.h:189
amps_handle AMPSDLL amps_client_create(const amps_char *clientName)
Functions for creation of an AMPS client.
The specified topic was invalid.
Definition: amps.h:205
void * amps_handle
Opaque handle type used to refer to objects in the AMPS api.
Definition: amps.h:179
amps_result
Return values from amps_xxx functions.
Definition: amps.h:184
void amps_ssl_free(void)
Frees OpenSSL context and shared library.
void(* amps_transport_filter_function)(const unsigned char *, size_t, short, void *)
Prototype for a user-supplied callback function for filtering data before it is sent and after it is ...
Definition: amps.h:601
amps_result AMPSDLL amps_client_connect(amps_handle handle, const amps_char *uri)
Connects to the AMPS server specified in uri.
int amps_ssl_init(const char *dllPath_)
Initializes SSL support in the AMPS Client.
A memory error occured.
Definition: amps.h:193
amps_result amps_client_attempt_reconnect(amps_handle client, unsigned version)
Manually invokes the user-supplied disconnect handler for this client.
amps_result amps_client_set_thread_created_callback(amps_handle client, amps_thread_created_callback callback, void *userData)
Sets a user-supplied callback function to allow thread attributes to set when a new thread is created...
Core type, function, and class declarations for the AMPS C++ client.
The specified filter was invalid.
Definition: amps.h:209
void AMPSDLL amps_client_destroy(amps_handle handle)
Disconnects and destroys an AMPS client object.
void * amps_tcps_get_SSL(amps_handle transport)
Retrieves the SSL object from the underlying TCPS transport.
An error with a command occured.
Definition: amps.h:197
void amps_message_set_field_guid(amps_handle message, FieldId field)
Sets the value of a header field in an AMPS message to a new, globally unique identifier("GUID") ...
amps_handle amps_client_get_transport(amps_handle client)
Returns a handle to the transport set in client, or NULL if no transport is associated with this tran...
amps_result amps_client_send_with_version(amps_handle client, amps_handle message, unsigned *version_out)
Sends a message to the AMPS server.
The server could not be found, or it actively refused our connection.
Definition: amps.h:221
void amps_client_set_message_handler(amps_handle client, amps_handler messageHandler, void *userData)
Sets the message handler function for this client.
void amps_message_get_data(amps_handle message, amps_char **value_ptr, size_t *length_ptr)
Gets the data component of an AMPS message.
amps_handle amps_message_create(amps_handle client)
Functions for creation and manipulation of AMPS messages.
void amps_message_assign_field_value(amps_handle message, FieldId field, const amps_char *value, size_t length)
Assigns the value of a header field in an AMPS message, without copying the value.
void amps_message_set_field_value(amps_handle message, FieldId field, const amps_char *value, size_t length)
Sets the value of a header field in an AMPS message.
AMPS_SOCKET amps_tcp_get_socket(amps_handle transport)
TRANSPORT-SPECIFIC APIS.
void amps_message_set_data_nts(amps_handle message, const amps_char *value)
Sets the data component of an AMPS message.
unsigned long amps_message_get_field_long(amps_handle message, FieldId field)
Gets the long integer value of a header field in an AMPS message.
int amps_ssl_set_verify(int mode_)
Configures OpenSSL to validate the server's certificate when connecting.
void amps_message_get_field_value(amps_handle message, FieldId field, const amps_char **value_ptr, size_t *length_ptr)
Retrieves the value of a header field in an AMPS message.
amps_result amps_client_set_idle_time(amps_handle client, int idleTime)
Sets an idle-time (milliseconds).
The usage of this function is invalid.
Definition: amps.h:237
amps_result AMPSDLL amps_client_set_name(amps_handle handle, const amps_char *clientName)
Sets the name on an amps client object.
amps_result amps_client_set_transport_filter_function(amps_handle client, amps_transport_filter_function filter, void *userData)
Sets a user-supplied callback function for filtering data before it is sent and after it is received...
void amps_message_set_data(amps_handle message, const amps_char *value, size_t length)
Sets the data component of an AMPS message.
amps_result(* amps_thread_created_callback)(AMPS_THREAD_T, void *)
Prototype for a user-supplied callback function to allow thread attributes to be set when a new threa...
Definition: amps.h:627
void amps_client_set_disconnect_handler(amps_handle client, amps_handler disconnectHandler, void *userData)
Sets the disconnect handler function to be called when a disconnect occurs.
A stream error has occured.
Definition: amps.h:225
The operation has not succeeded, but ought to be retried.
Definition: amps.h:213
void amps_client_set_predisconnect_handler(amps_handle client, amps_predisconnect_handler predisconnectHandler, void *userData)
Sets the predisconnect handler function to be called when a disconnect occurs.
The client and server are disconnected.
Definition: amps.h:217
const char * amps_ssl_get_error(void)
Returns the description of the last error from calling amps_ssl_init().
amps_uint64_t amps_message_get_field_uint64(amps_handle message, FieldId field)
Gets the unsigned 64-bit int value of a header field in an AMPS message.
amps_result amps_client_send(amps_handle client, amps_handle message)
Sends a message to the AMPS server.
The specified transport type is invalid.
Definition: amps.h:233
void amps_message_destroy(amps_handle message)
Destroys and frees the memory associated with an AMPS message object.