Classes | Macros | Functions | Variables
test95.c File Reference
#include "MQTTAsync.h"
#include <string.h>
#include <stdlib.h>
#include "Thread.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 test95.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 MAXMSGS   30;
 
#define START_TIME_TYPE   struct timeval
 

Functions

void assert3PendingTokens (MQTTAsync c)
 
long elapsed (START_TIME_TYPE start_time)
 
void getopts (int argc, char **argv)
 
void handleTrace (enum MQTTASYNC_TRACE_LEVELS level, char *message)
 
void logProperties (MQTTProperties *props)
 
int main (int argc, char **argv)
 
void myassert (char *filename, int lineno, char *description, int value, char *format,...)
 
void MyLog (int LOGA_level, char *format,...)
 
void MySleep (long milliseconds)
 
START_TIME_TYPE start_clock (void)
 
int test1 (struct Options options)
 
int test1_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
 
void test1cConnected (void *context, char *cause)
 
void test1cOnConnect (void *context, MQTTAsync_successData5 *response)
 
void test1cOnFailure (void *context, MQTTAsync_failureData5 *response)
 
void test1dOnConnect (void *context, MQTTAsync_successData5 *response)
 
void test1dOnFailure (void *context, MQTTAsync_failureData5 *response)
 
void test1donSubscribe (void *context, MQTTAsync_successData5 *response)
 
int test2 (struct Options options)
 
int test2_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
 
void test2cConnected (void *context, char *cause)
 
void test2cOnConnect (void *context, MQTTAsync_successData5 *response)
 
void test2cOnFailure (void *context, MQTTAsync_failureData5 *response)
 
void test2dOnConnect (void *context, MQTTAsync_successData5 *response)
 
void test2dOnFailure (void *context, MQTTAsync_failureData5 *response)
 
void test2donSubscribe (void *context, MQTTAsync_successData5 *response)
 
int test3 (struct Options options)
 
int test3_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
 
void test3cConnected (void *context, char *cause)
 
void test3cOnConnect (void *context, MQTTAsync_successData5 *response)
 
void test3cOnFailure (void *context, MQTTAsync_failureData5 *response)
 
void test3dOnConnect (void *context, MQTTAsync_successData5 *response)
 
void test3dOnFailure (void *context, MQTTAsync_failureData5 *response)
 
void test3donSubscribe (void *context, MQTTAsync_successData5 *response)
 
int test4 (struct Options options)
 
int test4_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
 
void test4cConnected (void *context, char *cause)
 
void test4cOnConnect (void *context, MQTTAsync_successData5 *response)
 
void test4cOnFailure (void *context, MQTTAsync_failureData5 *response)
 
void test4dOnConnect (void *context, MQTTAsync_successData5 *response)
 
void test4dOnFailure (void *context, MQTTAsync_failureData5 *response)
 
void test4donSubscribe (void *context, MQTTAsync_successData5 *response)
 
int test5 (struct Options options)
 
int test5_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
 
void test5cConnected (void *context, char *cause)
 
void test5cOnConnect (void *context, MQTTAsync_successData5 *response)
 
void test5cOnFailure (void *context, MQTTAsync_failureData5 *response)
 
void test5dOnConnect (void *context, MQTTAsync_successData5 *response)
 
void test5dOnFailure (void *context, MQTTAsync_failureData5 *response)
 
void test5donSubscribe (void *context, MQTTAsync_successData5 *response)
 
int test6 (struct Options options)
 
int test7 (struct Options options)
 
int test7_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
 
void test7cConnected (void *context, char *cause)
 
void test7cOnConnectFailure (void *context, MQTTAsync_failureData5 *response)
 
void test7cOnConnectSuccess (void *context, MQTTAsync_successData5 *response)
 
void test7dOnConnectFailure (void *context, MQTTAsync_failureData5 *response)
 
void test7dOnConnectSuccess (void *context, MQTTAsync_successData5 *response)
 
void test7donSubscribe (void *context, MQTTAsync_successData5 *response)
 
void usage (void)
 
void waitForNoPendingTokens (MQTTAsync c)
 
void write_test_result (void)
 

Variables

char * cur_output = output
 
int failures = 0
 
START_TIME_TYPE global_start_time
 
struct Options options
 
char output [3000]
 
int test1_messages_received = 0
 
int test1_will_message_received = 0
 
int test1c_connected = 0
 
int test1dReady = 0
 
int test1Finished = 0
 
int test1OnFailureCalled = 0
 
int test2_messages_received = 0
 
int test2_will_message_received = 0
 
int test2c_connected = 0
 
int test2dReady = 0
 
int test2Finished = 0
 
int test2OnFailureCalled = 0
 
int test3_messages_received = 0
 
int test3_will_message_received = 0
 
int test3c_connected = 0
 
int test3dReady = 0
 
int test3Finished = 0
 
int test3OnFailureCalled = 0
 
int test4_messages_received = 0
 
int test4_will_message_received = 0
 
int test4c_connected = 0
 
int test4dReady = 0
 
int test4Finished = 0
 
int test4OnFailureCalled = 0
 
int test5_messages_received = 0
 
int test5_will_message_received = 0
 
int test5c_connected = 0
 
int test5dReady = 0
 
int test5Finished = 0
 
int test5OnFailureCalled = 0
 
int test7_messages_received = 0
 
int test7_will_message_received = 0
 
int test7c_connected = 0
 
int test7dReady = 0
 
int test7Finished = 0
 
int test7OnFailureCalled = 0
 
char test_topic [100]
 
int tests = 0
 
char unique [50]
 
char willTopic [100]
 
FILE * xml
 

Detailed Description

Offline buffering and automatic reconnect tests for the Paho Asynchronous MQTT C client

Definition in file test95.c.

Macro Definition Documentation

#define ARRAY_SIZE (   a)    (sizeof(a) / sizeof(a[0]))

Definition at line 44 of file test95.c.

#define assert (   a,
  b,
  c,
  d 
)    myassert(__FILE__, __LINE__, a, b, c, d)

Definition at line 203 of file test95.c.

#define assert1 (   a,
  b,
  c,
  d,
  e 
)    myassert(__FILE__, __LINE__, a, b, c, d, e)

Definition at line 204 of file test95.c.

#define LOGA_DEBUG   0

Definition at line 100 of file test95.c.

#define LOGA_INFO   1

Definition at line 101 of file test95.c.

#define MAXMSGS   30;

Definition at line 206 of file test95.c.

#define START_TIME_TYPE   struct timeval

Definition at line 167 of file test95.c.

Function Documentation

void assert3PendingTokens ( MQTTAsync  c)

Definition at line 318 of file test95.c.

long elapsed ( START_TIME_TYPE  start_time)

Definition at line 193 of file test95.c.

void getopts ( int  argc,
char **  argv 
)

Definition at line 66 of file test95.c.

void handleTrace ( enum MQTTASYNC_TRACE_LEVELS  level,
char *  message 
)

Definition at line 2229 of file test95.c.

void logProperties ( MQTTProperties *  props)

Definition at line 254 of file test95.c.

int main ( int  argc,
char **  argv 
)

Definition at line 2235 of file test95.c.

void myassert ( char *  filename,
int  lineno,
char *  description,
int  value,
char *  format,
  ... 
)

Definition at line 229 of file test95.c.

void MyLog ( int  LOGA_level,
char *  format,
  ... 
)

Definition at line 105 of file test95.c.

void MySleep ( long  milliseconds)

Definition at line 142 of file test95.c.

START_TIME_TYPE start_clock ( void  )

Definition at line 169 of file test95.c.

int test1 ( struct Options  options)

Definition at line 488 of file test95.c.

int test1_messageArrived ( void *  context,
char *  topicName,
int  topicLen,
MQTTAsync_message *  message 
)

Definition at line 372 of file test95.c.

void test1cConnected ( void *  context,
char *  cause 
)

Definition at line 479 of file test95.c.

void test1cOnConnect ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 424 of file test95.c.

void test1cOnFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 408 of file test95.c.

void test1dOnConnect ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 459 of file test95.c.

void test1dOnFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 416 of file test95.c.

void test1donSubscribe ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 450 of file test95.c.

int test2 ( struct Options  options)

Definition at line 813 of file test95.c.

int test2_messageArrived ( void *  context,
char *  topicName,
int  topicLen,
MQTTAsync_message *  message 
)

Definition at line 716 of file test95.c.

void test2cConnected ( void *  context,
char *  cause 
)

Definition at line 804 of file test95.c.

void test2cOnConnect ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 754 of file test95.c.

void test2cOnFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 738 of file test95.c.

void test2dOnConnect ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 784 of file test95.c.

void test2dOnFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 746 of file test95.c.

void test2donSubscribe ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 775 of file test95.c.

int test3 ( struct Options  options)

Definition at line 1085 of file test95.c.

int test3_messageArrived ( void *  context,
char *  topicName,
int  topicLen,
MQTTAsync_message *  message 
)

Definition at line 988 of file test95.c.

void test3cConnected ( void *  context,
char *  cause 
)

Definition at line 1076 of file test95.c.

void test3cOnConnect ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 1026 of file test95.c.

void test3cOnFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 1010 of file test95.c.

void test3dOnConnect ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 1056 of file test95.c.

void test3dOnFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 1018 of file test95.c.

void test3donSubscribe ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 1047 of file test95.c.

int test4 ( struct Options  options)

Definition at line 1353 of file test95.c.

int test4_messageArrived ( void *  context,
char *  topicName,
int  topicLen,
MQTTAsync_message *  message 
)

Definition at line 1255 of file test95.c.

void test4cConnected ( void *  context,
char *  cause 
)

Definition at line 1344 of file test95.c.

void test4cOnConnect ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 1294 of file test95.c.

void test4cOnFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 1278 of file test95.c.

void test4dOnConnect ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 1324 of file test95.c.

void test4dOnFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 1286 of file test95.c.

void test4donSubscribe ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 1315 of file test95.c.

int test5 ( struct Options  options)

Definition at line 1619 of file test95.c.

int test5_messageArrived ( void *  context,
char *  topicName,
int  topicLen,
MQTTAsync_message *  message 
)

Definition at line 1528 of file test95.c.

void test5cConnected ( void *  context,
char *  cause 
)

Definition at line 1610 of file test95.c.

void test5cOnConnect ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 1562 of file test95.c.

void test5cOnFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 1546 of file test95.c.

void test5dOnConnect ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 1592 of file test95.c.

void test5dOnFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 1554 of file test95.c.

void test5donSubscribe ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 1583 of file test95.c.

int test6 ( struct Options  options)

Definition at line 1783 of file test95.c.

int test7 ( struct Options  options)

Definition at line 2053 of file test95.c.

int test7_messageArrived ( void *  context,
char *  topicName,
int  topicLen,
MQTTAsync_message *  message 
)

Definition at line 1966 of file test95.c.

void test7cConnected ( void *  context,
char *  cause 
)

Definition at line 1984 of file test95.c.

void test7cOnConnectFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 1992 of file test95.c.

void test7cOnConnectSuccess ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 2000 of file test95.c.

void test7dOnConnectFailure ( void *  context,
MQTTAsync_failureData5 *  response 
)

Definition at line 2016 of file test95.c.

void test7dOnConnectSuccess ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 2034 of file test95.c.

void test7donSubscribe ( void *  context,
MQTTAsync_successData5 *  response 
)

Definition at line 2025 of file test95.c.

void usage ( void  )

Definition at line 46 of file test95.c.

void waitForNoPendingTokens ( MQTTAsync  c)

Definition at line 293 of file test95.c.

void write_test_result ( void  )

Definition at line 216 of file test95.c.

Variable Documentation

char* cur_output = output

Definition at line 213 of file test95.c.

int failures = 0

Definition at line 209 of file test95.c.

START_TIME_TYPE global_start_time

Definition at line 211 of file test95.c.

struct Options options
Initial value:
=
{
"mqtt.eclipse.org:1883",
"localhost:1883",
0,
0,
}
char output[3000]

Definition at line 212 of file test95.c.

int test1_messages_received = 0

Definition at line 370 of file test95.c.

int test1_will_message_received = 0

Definition at line 369 of file test95.c.

int test1c_connected = 0

Definition at line 477 of file test95.c.

int test1dReady = 0

Definition at line 446 of file test95.c.

int test1Finished = 0

Definition at line 404 of file test95.c.

int test1OnFailureCalled = 0

Definition at line 406 of file test95.c.

int test2_messages_received = 0

Definition at line 714 of file test95.c.

int test2_will_message_received = 0

Definition at line 713 of file test95.c.

int test2c_connected = 0

Definition at line 802 of file test95.c.

int test2dReady = 0

Definition at line 771 of file test95.c.

int test2Finished = 0

Definition at line 734 of file test95.c.

int test2OnFailureCalled = 0

Definition at line 736 of file test95.c.

int test3_messages_received = 0

Definition at line 986 of file test95.c.

int test3_will_message_received = 0

Definition at line 985 of file test95.c.

int test3c_connected = 0

Definition at line 1074 of file test95.c.

int test3dReady = 0

Definition at line 1043 of file test95.c.

int test3Finished = 0

Definition at line 1006 of file test95.c.

int test3OnFailureCalled = 0

Definition at line 1008 of file test95.c.

int test4_messages_received = 0

Definition at line 1253 of file test95.c.

int test4_will_message_received = 0

Definition at line 1252 of file test95.c.

int test4c_connected = 0

Definition at line 1342 of file test95.c.

int test4dReady = 0

Definition at line 1311 of file test95.c.

int test4Finished = 0

Definition at line 1274 of file test95.c.

int test4OnFailureCalled = 0

Definition at line 1276 of file test95.c.

int test5_messages_received = 0

Definition at line 1523 of file test95.c.

int test5_will_message_received = 0

Definition at line 1522 of file test95.c.

int test5c_connected = 0

Definition at line 1526 of file test95.c.

int test5dReady = 0

Definition at line 1579 of file test95.c.

int test5Finished = 0

Definition at line 1524 of file test95.c.

int test5OnFailureCalled = 0

Definition at line 1525 of file test95.c.

int test7_messages_received = 0

Definition at line 1961 of file test95.c.

int test7_will_message_received = 0

Definition at line 1960 of file test95.c.

int test7c_connected = 0

Definition at line 1959 of file test95.c.

int test7dReady = 0

Definition at line 1964 of file test95.c.

int test7Finished = 0

Definition at line 1962 of file test95.c.

int test7OnFailureCalled = 0

Definition at line 1963 of file test95.c.

char test_topic[100]

Definition at line 448 of file test95.c.

int tests = 0

Definition at line 208 of file test95.c.

char unique[50]

Definition at line 42 of file test95.c.

char willTopic[100]

Definition at line 447 of file test95.c.

FILE* xml

Definition at line 210 of file test95.c.


plotjuggler
Author(s): Davide Faconti
autogenerated on Sun Dec 6 2020 04:02:49