#include "MQTTClient.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 test10.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 |
Enumerations | |
| enum | msgTypes { CONNECT = 1, CONNACK, PUBLISH, PUBACK, PUBREC, PUBREL, PUBCOMP, SUBSCRIBE, SUBACK, UNSUBSCRIBE, UNSUBACK, PINGREQ, PINGRESP, DISCONNECT, AUTH, CONNECT, PUBLISH, SUBSCRIBE, SUBSCRIBE_MANY, UNSUBSCRIBE, CONNECT = 1, CONNACK, PUBLISH, PUBACK, PUBREC, PUBREL, PUBCOMP, SUBSCRIBE, SUBACK, UNSUBSCRIBE, UNSUBACK, PINGREQ, PINGRESP, DISCONNECT, AUTH } |
Variables | |
| static int | blocking_found = 0 |
| MQTTClient | c |
| char * | cur_output = output |
| MQTTClient | d |
| int | failures = 0 |
| START_TIME_TYPE | global_start_time |
| static int | messages_arrived = 0 |
| struct Options | options |
| char | output [3000] |
| struct { | |
| int packet_type | |
| int published | |
| enum MQTTReasonCodes rc | |
| } | test_qos_1_2_errors_globals |
| struct { | |
| char * correlation_id | |
| int messages_arrived | |
| char * request_topic | |
| char * response_topic | |
| } | test_request_response_globals |
| struct { | |
| int messages_arrived | |
| char * shared_topic | |
| char * topic | |
| } | test_shared_subscriptions_globals |
| struct { | |
| int messages_arrived | |
| char * topic | |
| } | test_subscribe_options_globals |
| struct { | |
| int disconnected | |
| } | test_topic_aliases_globals |
| int | tests = 0 |
| FILE * | xml |
Detailed Description
MQTT V5 specific tests for the MQTT C client
- topic aliases
- subscription ids
- session expiry
- payload format
- flow control
- QoS 2 exchange termination
- request/response
- shared subscriptions
- server initiated disconnect
- auth packets
- server assigned clientid returned in a property
- server defined keepalive
- subscribe failure
Definition in file test10.c.
Macro Definition Documentation
Enumeration Type Documentation
| enum msgTypes |
Function Documentation
| void disconnected | ( | void * | context, |
| MQTTProperties * | props, | ||
| enum MQTTReasonCodes | rc | ||
| ) |
| long elapsed | ( | START_TIME_TYPE | start_time | ) |
| void logProperties | ( | MQTTProperties * | props | ) |
| int messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTClient_message * | message | ||
| ) |
| void myassert | ( | char * | filename, |
| int | lineno, | ||
| char * | description, | ||
| int | value, | ||
| char * | format, | ||
| ... | |||
| ) |
| void published | ( | void * | context, |
| int | msgid, | ||
| int | packet_type, | ||
| MQTTProperties * | props, | ||
| enum MQTTReasonCodes | rc | ||
| ) |
| START_TIME_TYPE start_clock | ( | void | ) |
| int test2_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTClient_message * | message | ||
| ) |
| int test_flow_control_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTClient_message * | message | ||
| ) |
| void test_flow_control_trace_callback | ( | enum MQTTCLIENT_TRACE_LEVELS | level, |
| char * | message | ||
| ) |
| int test_request_response_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTClient_message * | message | ||
| ) |
| int test_shared_subscriptions_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTClient_message * | message | ||
| ) |
| int test_subscribe_options_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTClient_message * | message | ||
| ) |
| int test_subscription_ids_messageArrived | ( | void * | context, |
| char * | topicName, | ||
| int | topicLen, | ||
| MQTTClient_message * | message | ||
| ) |
| void test_trace_callback | ( | enum MQTTCLIENT_TRACE_LEVELS | level, |
| char * | message | ||
| ) |
Variable Documentation
| START_TIME_TYPE global_start_time |
| struct Options options |
Initial value:
=
{
"tcp://localhost:1883",
NULL,
"tcp://localhost:1884",
0,
0,
0,
1,
}
| enum MQTTReasonCodes rc |
| struct { ... } test_qos_1_2_errors_globals |
Initial value:
| struct { ... } test_request_response_globals |
Initial value:
=
{
"my response topic",
"my request topic",
0,
"request no 1",
}
| struct { ... } test_shared_subscriptions_globals |
Initial value:
=
{
"$share/share_test/#",
"a",
0,
}
| struct { ... } test_subscribe_options_globals |
Initial value:
=
{
"my response topic",
0,
}
| struct { ... } test_topic_aliases_globals |
Initial value:
=
{
0,
}