Classes | Macros | Functions | Variables
test9.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 test9.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)
 
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 test10 (struct Options options)
 
int test10_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
 
void test10cOnConnect (void *context, MQTTAsync_successData *response)
 
void test10dOnConnect (void *context, MQTTAsync_successData *response)
 
void test10donSubscribe (void *context, MQTTAsync_successData *response)
 
void test10OnFailure (void *context, MQTTAsync_failureData *response)
 
int test1_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
 
void test1cConnected (void *context, char *cause)
 
void test1cOnConnect (void *context, MQTTAsync_successData *response)
 
void test1cOnFailure (void *context, MQTTAsync_failureData *response)
 
void test1dOnConnect (void *context, MQTTAsync_successData *response)
 
void test1dOnFailure (void *context, MQTTAsync_failureData *response)
 
void test1donSubscribe (void *context, MQTTAsync_successData *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_successData *response)
 
void test2cOnFailure (void *context, MQTTAsync_failureData *response)
 
void test2dOnConnect (void *context, MQTTAsync_successData *response)
 
void test2dOnFailure (void *context, MQTTAsync_failureData *response)
 
void test2donSubscribe (void *context, MQTTAsync_successData *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_successData *response)
 
void test3cOnFailure (void *context, MQTTAsync_failureData *response)
 
void test3dOnConnect (void *context, MQTTAsync_successData *response)
 
void test3dOnFailure (void *context, MQTTAsync_failureData *response)
 
void test3donSubscribe (void *context, MQTTAsync_successData *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_successData *response)
 
void test4cOnFailure (void *context, MQTTAsync_failureData *response)
 
void test4dOnConnect (void *context, MQTTAsync_successData *response)
 
void test4dOnFailure (void *context, MQTTAsync_failureData *response)
 
void test4donSubscribe (void *context, MQTTAsync_successData *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_successData *response)
 
void test5cOnFailure (void *context, MQTTAsync_failureData *response)
 
void test5dOnConnect (void *context, MQTTAsync_successData *response)
 
void test5dOnFailure (void *context, MQTTAsync_failureData *response)
 
void test5donSubscribe (void *context, MQTTAsync_successData *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_failureData *response)
 
void test7cOnConnectSuccess (void *context, MQTTAsync_successData *response)
 
void test7dOnConnectFailure (void *context, MQTTAsync_failureData *response)
 
void test7dOnConnectSuccess (void *context, MQTTAsync_successData *response)
 
void test7donSubscribe (void *context, MQTTAsync_successData *response)
 
int test8 (struct Options options)
 
int test8_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
 
void test8cOnConnect (void *context, MQTTAsync_successData *response)
 
void test8dOnConnect (void *context, MQTTAsync_successData *response)
 
void test8donSubscribe (void *context, MQTTAsync_successData *response)
 
void test8OnFailure (void *context, MQTTAsync_failureData *response)
 
int test9 (struct Options options)
 
void test9cOnConnect (void *context, MQTTAsync_successData *response)
 
void test9OnFailure (void *context, MQTTAsync_failureData *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 test10_messages_received = 0
 
int test10cConnected = 0
 
int test10dConnected = 0
 
int test10dSubscribed = 0
 
int test10Finished = 0
 
int test10MessageSeqno = 3
 
int test10MessagesToSend = 6
 
int test10OnFailureCalled = 0
 
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
 
int test8_messages_received = 0
 
int test8cConnected = 0
 
int test8dConnected = 0
 
int test8dSubscribed = 0
 
int test8Finished = 0
 
int test8OnFailureCalled = 0
 
int test9_messages_received = 0
 
int test9cConnected = 0
 
int test9Finished = 0
 
int test9OnFailureCalled = 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 test9.c.

Macro Definition Documentation

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

Definition at line 43 of file test9.c.

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

Definition at line 202 of file test9.c.

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

Definition at line 203 of file test9.c.

#define LOGA_DEBUG   0

Definition at line 99 of file test9.c.

#define LOGA_INFO   1

Definition at line 100 of file test9.c.

#define MAXMSGS   30;

Definition at line 205 of file test9.c.

#define START_TIME_TYPE   struct timeval

Definition at line 166 of file test9.c.

Function Documentation

void assert3PendingTokens ( MQTTAsync  c)

Definition at line 278 of file test9.c.

long elapsed ( START_TIME_TYPE  start_time)

Definition at line 192 of file test9.c.

void getopts ( int  argc,
char **  argv 
)

Definition at line 65 of file test9.c.

void handleTrace ( enum MQTTASYNC_TRACE_LEVELS  level,
char *  message 
)

Definition at line 314 of file test9.c.

int main ( int  argc,
char **  argv 
)

Definition at line 2679 of file test9.c.

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

Definition at line 228 of file test9.c.

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

Definition at line 104 of file test9.c.

void MySleep ( long  milliseconds)

Definition at line 141 of file test9.c.

START_TIME_TYPE start_clock ( void  )

Definition at line 168 of file test9.c.

int test1 ( struct Options  options)

Definition at line 430 of file test9.c.

int test10 ( struct Options  options)

Definition at line 2496 of file test9.c.

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

Definition at line 2433 of file test9.c.

void test10cOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 2486 of file test9.c.

void test10dOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 2459 of file test9.c.

void test10donSubscribe ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 2452 of file test9.c.

void test10OnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 2478 of file test9.c.

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

Definition at line 334 of file test9.c.

void test1cConnected ( void *  context,
char *  cause 
)

Definition at line 421 of file test9.c.

void test1cOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 372 of file test9.c.

void test1cOnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 356 of file test9.c.

void test1dOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 401 of file test9.c.

void test1dOnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 364 of file test9.c.

void test1donSubscribe ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 393 of file test9.c.

int test2 ( struct Options  options)

Definition at line 690 of file test9.c.

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

Definition at line 594 of file test9.c.

void test2cConnected ( void *  context,
char *  cause 
)

Definition at line 681 of file test9.c.

void test2cOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 632 of file test9.c.

void test2cOnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 616 of file test9.c.

void test2dOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 661 of file test9.c.

void test2dOnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 624 of file test9.c.

void test2donSubscribe ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 653 of file test9.c.

int test3 ( struct Options  options)

Definition at line 960 of file test9.c.

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

Definition at line 864 of file test9.c.

void test3cConnected ( void *  context,
char *  cause 
)

Definition at line 951 of file test9.c.

void test3cOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 902 of file test9.c.

void test3cOnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 886 of file test9.c.

void test3dOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 931 of file test9.c.

void test3dOnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 894 of file test9.c.

void test3donSubscribe ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 923 of file test9.c.

int test4 ( struct Options  options)

Definition at line 1218 of file test9.c.

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

Definition at line 1122 of file test9.c.

void test4cConnected ( void *  context,
char *  cause 
)

Definition at line 1209 of file test9.c.

void test4cOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 1160 of file test9.c.

void test4cOnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 1144 of file test9.c.

void test4dOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 1189 of file test9.c.

void test4dOnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 1152 of file test9.c.

void test4donSubscribe ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 1181 of file test9.c.

int test5 ( struct Options  options)

Definition at line 1475 of file test9.c.

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

Definition at line 1385 of file test9.c.

void test5cConnected ( void *  context,
char *  cause 
)

Definition at line 1466 of file test9.c.

void test5cOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 1419 of file test9.c.

void test5cOnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 1403 of file test9.c.

void test5dOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 1448 of file test9.c.

void test5dOnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 1411 of file test9.c.

void test5donSubscribe ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 1440 of file test9.c.

int test6 ( struct Options  options)

Definition at line 1630 of file test9.c.

int test7 ( struct Options  options)

Definition at line 1890 of file test9.c.

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

Definition at line 1804 of file test9.c.

void test7cConnected ( void *  context,
char *  cause 
)

Definition at line 1822 of file test9.c.

void test7cOnConnectFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 1830 of file test9.c.

void test7cOnConnectSuccess ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 1838 of file test9.c.

void test7dOnConnectFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 1854 of file test9.c.

void test7dOnConnectSuccess ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 1871 of file test9.c.

void test7donSubscribe ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 1863 of file test9.c.

int test8 ( struct Options  options)

Definition at line 2133 of file test9.c.

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

Definition at line 2074 of file test9.c.

void test8cOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 2123 of file test9.c.

void test8dOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 2096 of file test9.c.

void test8donSubscribe ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 2089 of file test9.c.

void test8OnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 2115 of file test9.c.

int test9 ( struct Options  options)

Definition at line 2321 of file test9.c.

void test9cOnConnect ( void *  context,
MQTTAsync_successData *  response 
)

Definition at line 2312 of file test9.c.

void test9OnFailure ( void *  context,
MQTTAsync_failureData *  response 
)

Definition at line 2304 of file test9.c.

void usage ( void  )

Definition at line 45 of file test9.c.

void waitForNoPendingTokens ( MQTTAsync  c)

Definition at line 253 of file test9.c.

void write_test_result ( void  )

Definition at line 215 of file test9.c.

Variable Documentation

char* cur_output = output

Definition at line 212 of file test9.c.

int failures = 0

Definition at line 208 of file test9.c.

START_TIME_TYPE global_start_time

Definition at line 210 of file test9.c.

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

Definition at line 211 of file test9.c.

int test10_messages_received = 0

Definition at line 2424 of file test9.c.

int test10cConnected = 0

Definition at line 2427 of file test9.c.

int test10dConnected = 0

Definition at line 2428 of file test9.c.

int test10dSubscribed = 0

Definition at line 2429 of file test9.c.

int test10Finished = 0

Definition at line 2425 of file test9.c.

int test10MessageSeqno = 3

Definition at line 2431 of file test9.c.

int test10MessagesToSend = 6

Definition at line 2430 of file test9.c.

int test10OnFailureCalled = 0

Definition at line 2426 of file test9.c.

int test1_messages_received = 0

Definition at line 332 of file test9.c.

int test1_will_message_received = 0

Definition at line 331 of file test9.c.

int test1c_connected = 0

Definition at line 419 of file test9.c.

int test1dReady = 0

Definition at line 389 of file test9.c.

int test1Finished = 0

Definition at line 352 of file test9.c.

int test1OnFailureCalled = 0

Definition at line 354 of file test9.c.

int test2_messages_received = 0

Definition at line 592 of file test9.c.

int test2_will_message_received = 0

Definition at line 591 of file test9.c.

int test2c_connected = 0

Definition at line 679 of file test9.c.

int test2dReady = 0

Definition at line 649 of file test9.c.

int test2Finished = 0

Definition at line 612 of file test9.c.

int test2OnFailureCalled = 0

Definition at line 614 of file test9.c.

int test3_messages_received = 0

Definition at line 862 of file test9.c.

int test3_will_message_received = 0

Definition at line 861 of file test9.c.

int test3c_connected = 0

Definition at line 949 of file test9.c.

int test3dReady = 0

Definition at line 919 of file test9.c.

int test3Finished = 0

Definition at line 882 of file test9.c.

int test3OnFailureCalled = 0

Definition at line 884 of file test9.c.

int test4_messages_received = 0

Definition at line 1120 of file test9.c.

int test4_will_message_received = 0

Definition at line 1119 of file test9.c.

int test4c_connected = 0

Definition at line 1207 of file test9.c.

int test4dReady = 0

Definition at line 1177 of file test9.c.

int test4Finished = 0

Definition at line 1140 of file test9.c.

int test4OnFailureCalled = 0

Definition at line 1142 of file test9.c.

int test5_messages_received = 0

Definition at line 1380 of file test9.c.

int test5_will_message_received = 0

Definition at line 1379 of file test9.c.

int test5c_connected = 0

Definition at line 1383 of file test9.c.

int test5dReady = 0

Definition at line 1436 of file test9.c.

int test5Finished = 0

Definition at line 1381 of file test9.c.

int test5OnFailureCalled = 0

Definition at line 1382 of file test9.c.

int test7_messages_received = 0

Definition at line 1799 of file test9.c.

int test7_will_message_received = 0

Definition at line 1798 of file test9.c.

int test7c_connected = 0

Definition at line 1797 of file test9.c.

int test7dReady = 0

Definition at line 1802 of file test9.c.

int test7Finished = 0

Definition at line 1800 of file test9.c.

int test7OnFailureCalled = 0

Definition at line 1801 of file test9.c.

int test8_messages_received = 0

Definition at line 2067 of file test9.c.

int test8cConnected = 0

Definition at line 2070 of file test9.c.

int test8dConnected = 0

Definition at line 2071 of file test9.c.

int test8dSubscribed = 0

Definition at line 2072 of file test9.c.

int test8Finished = 0

Definition at line 2068 of file test9.c.

int test8OnFailureCalled = 0

Definition at line 2069 of file test9.c.

int test9_messages_received = 0

Definition at line 2299 of file test9.c.

int test9cConnected = 0

Definition at line 2302 of file test9.c.

int test9Finished = 0

Definition at line 2300 of file test9.c.

int test9OnFailureCalled = 0

Definition at line 2301 of file test9.c.

char test_topic[100]

Definition at line 391 of file test9.c.

int tests = 0

Definition at line 207 of file test9.c.

char unique[50]

Definition at line 41 of file test9.c.

char willTopic

Definition at line 390 of file test9.c.

FILE* xml

Definition at line 209 of file test9.c.


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