#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>
Go to the source code of this file.
Classes | |
struct | Clients |
struct | MQTTClients |
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 |
Functions | |
long | elapsed (START_TIME_TYPE start_time) |
void | getopts (int argc, char **argv) |
int | main (int argc, char **argv) |
void | multiThread_deliveryComplete (void *context, MQTTClient_deliveryToken dt) |
int | multiThread_messageArrived (void *context, char *topicName, int topicLen, MQTTClient_message *m) |
void | multiThread_sendAndReceive (MQTTClient *c, int qos, char *test_topic) |
int | myassert (char *filename, int lineno, char *description, int value, char *format,...) |
void | MyLog (int LOGA_level, char *format,...) |
static unsigned int | onPSKAuth (const char *hint, char *identity, unsigned int max_identity_len, unsigned char *psk, unsigned int max_psk_len, void *context) |
void | singleThread_sendAndReceive (MQTTClient *c, int qos, char *test_topic) |
START_TIME_TYPE | start_clock (void) |
int | test1 (struct Options options) |
int | test2a_m (struct Options options) |
int | test2a_s (struct Options options) |
int | test2b (struct Options options) |
int | test2c (struct Options options) |
int | test2e_s (struct Options options) |
int | test3a_m (struct Options options) |
int | test3a_s (struct Options options) |
int | test3b (struct Options options) |
int | test4_m (struct Options options) |
int | test4_s (struct Options options) |
int | test5a (struct Options options) |
int | test5b (struct Options options) |
int | test5c (struct Options options) |
int | test6 (struct Options options) |
void | usage (void) |
void | write_test_result (void) |
Variables | |
char * | cur_output = output |
int | failures = 0 |
START_TIME_TYPE | global_start_time |
volatile int | multiThread_arrivedcount = 0 |
int | multiThread_deliveryCompleted = 0 |
MQTTClient_message | multiThread_pubmsg = MQTTClient_message_initializer |
struct Options | options |
char | output [3000] |
char * | persistenceStore = NULL |
char * | test_map [] |
int | tests = 0 |
FILE * | xml |
SSL tests for the Eclipse Paho MQTT C client
Definition in file test3.c.
long elapsed | ( | START_TIME_TYPE | start_time | ) |
void multiThread_deliveryComplete | ( | void * | context, |
MQTTClient_deliveryToken | dt | ||
) |
int multiThread_messageArrived | ( | void * | context, |
char * | topicName, | ||
int | topicLen, | ||
MQTTClient_message * | m | ||
) |
void multiThread_sendAndReceive | ( | MQTTClient * | c, |
int | qos, | ||
char * | test_topic | ||
) |
int myassert | ( | char * | filename, |
int | lineno, | ||
char * | description, | ||
int | value, | ||
char * | format, | ||
... | |||
) |
|
static |
void singleThread_sendAndReceive | ( | MQTTClient * | c, |
int | qos, | ||
char * | test_topic | ||
) |
START_TIME_TYPE start_clock | ( | void | ) |
START_TIME_TYPE global_start_time |
MQTTClient_message multiThread_pubmsg = MQTTClient_message_initializer |
struct Options options |
char* test_map[] |