#include "MQTTAsync.h"#include <string.h>#include <stdlib.h>#include <sys/time.h>#include <sys/socket.h>#include <unistd.h>#include <errno.h>#include <stdarg.h>#include <time.h>#include <sys/timeb.h>
Include dependency graph for test11.c:
Go to the source code of this file.
Classes | |
| struct | Options |
Macros | |
| #define | ARRAY_SIZE(a) (sizeof(a) / sizeof(a[0])) |
| #define | assert(a, b, c, d) myassert(__FILE__, __LINE__, a, b, c, d) |
| #define | assert1(a, b, c, d, e) myassert(__FILE__, __LINE__, a, b, c, d, e) |
| #define | LOGA_DEBUG 0 |
| #define | LOGA_INFO 1 |
| #define | mqsleep sleep |
| #define | START_TIME_TYPE struct timeval |
Detailed Description
Tests for the Paho Asynchronous MQTT C client
Definition in file test11.c.
Macro Definition Documentation
Function Documentation
| long elapsed | ( | START_TIME_TYPE | start_time | ) |
| void flow_control_trace_callback | ( | enum MQTTASYNC_TRACE_LEVELS | level, |
| char * | message | ||
| ) |
| void logProperties | ( | MQTTProperties * | props | ) |
| void myassert | ( | char * | filename, |
| int | lineno, | ||
| char * | description, | ||
| int | value, | ||
| char * | format, | ||
| ... | |||
| ) |
| START_TIME_TYPE start_clock | ( | void | ) |
| void test1_onDisconnect | ( | void * | context, |
| MQTTAsync_successData * | response | ||
| ) |
| void test_client_topic_aliases_disconnected | ( | void * | context, |
| MQTTProperties * | props, | ||
| enum MQTTReasonCodes | rc | ||
| ) |
| int test_client_topic_aliases_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTAsync_message * | message | ||
| ) |
| void test_client_topic_aliases_onConnect | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_client_topic_aliases_onSubscribe | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_error_reporting_onConnect | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_error_reporting_onSubscribe | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_error_reporting_onUnsubscribe | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| int test_flow_control_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTAsync_message * | message | ||
| ) |
| void test_flow_control_onConnect | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_flow_control_onSubscribe | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_qos_1_2_errors_onConnect | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_qos_1_2_errors_onPublishFailure | ( | void * | context, |
| MQTTAsync_failureData5 * | response | ||
| ) |
| void test_qos_1_2_errors_onPublishFailure2 | ( | void * | context, |
| MQTTAsync_failureData5 * | response | ||
| ) |
| void test_qos_1_2_errors_onPublishFailure3 | ( | void * | context, |
| MQTTAsync_failureData5 * | response | ||
| ) |
| void test_qos_1_2_errors_onPublishSuccess | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| int test_request_response_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTAsync_message * | message | ||
| ) |
| void test_request_response_onConnect | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_request_response_onSubscribe | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| int test_server_topic_aliases_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTAsync_message * | message | ||
| ) |
| void test_server_topic_aliases_onConnect | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_server_topic_aliases_onSubscribe | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| int test_shared_subscriptions_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTAsync_message * | message | ||
| ) |
| void test_shared_subscriptions_onConnectc | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_shared_subscriptions_onConnectd | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_shared_subscriptions_onSubscribe | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| int test_subscribeOptions_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTAsync_message * | message | ||
| ) |
| void test_subscribeOptions_onConnect | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_subscribeOptions_onSubscribe | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| int test_subscription_ids_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTAsync_message * | message | ||
| ) |
| void test_subscription_ids_onConnect | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void test_subscription_ids_onSubscribe | ( | void * | context, |
| MQTTAsync_successData5 * | response | ||
| ) |
| void trace_callback | ( | enum MQTTASYNC_TRACE_LEVELS | level, |
| char * | message | ||
| ) |
Variable Documentation
| START_TIME_TYPE global_start_time |
| struct Options options |
Initial value:
=
{
"localhost:1883",
0,
-1,
10000,
1,
}
| struct { ... } test_client_topic_aliases_globals |
Initial value:
=
{
0, "client topic aliases topic", 0
}
| struct { ... } test_error_reporting_globals |
Initial value:
=
{
"error reporting topic", 0, 0
}
| struct { ... } test_flow_control_globals |
Initial value:
=
{
"flow control topic", 0, 0, 65535, 0
}
| struct { ... } test_qos_1_2_errors_globals |
Initial value:
=
{
0, "test_qos_1_2_errors"
}
| struct { ... } test_request_response_globals |
Initial value:
=
{
0,
"test_7_request",
"test_7_response",
"test_7_correlation_id",
0
}
| struct { ... } test_server_topic_aliases_globals |
Initial value:
=
{
"server topic aliases topic", 0, 0, 3
}
| struct { ... } test_shared_subscriptions_globals |
Initial value:
=
{
"$share/share_test/any",
"any",
0,
0,
10,
}
| struct { ... } test_subscribeOptions_globals |
Initial value:
=
{
0,
"subscribe options topic",
"+",
0
}
| struct { ... } test_subscription_ids_globals |
Initial value:
=
{
"server subscription ids topic", 0, 0
}