test8.c File Reference

#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 test8.c:

Go to the source code of this file.

Classes
struct	client_data
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
#define	TEST3_CLIENTS   10

Functions
long	elapsed (START_TIME_TYPE start_time)
void	getopts (int argc, char **argv)
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,...)
START_TIME_TYPE	start_clock (void)
int	test1 (struct Options options)
int	test1_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
void	test1_onConnect (void *context, MQTTAsync_successData *response)
void	test1_onConnectFailure (void *context, MQTTAsync_failureData *response)
void	test1_onDisconnect (void *context, MQTTAsync_successData *response)
void	test1_onSubscribe (void *context, MQTTAsync_successData *response)
void	test1_onUnsubscribe (void *context, MQTTAsync_successData *response)
int	test2 (struct Options options)
void	test2_onConnect (void *context, MQTTAsync_successData *response)
void	test2_onFailure (void *context, MQTTAsync_failureData *response)
int	test3 (struct Options options)
int	test3_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
void	test3_onConnect (void *context, MQTTAsync_successData *response)
void	test3_onDisconnect (void *context, MQTTAsync_successData *response)
void	test3_onFailure (void *context, MQTTAsync_failureData *response)
void	test3_onPublish (void *context, MQTTAsync_successData *response)
void	test3_onSubscribe (void *context, MQTTAsync_successData *response)
void	test3_onUnsubscribe (void *context, MQTTAsync_successData *response)
int	test4 (struct Options options)
int	test4_messageArrived (void *context, char *topicName, int topicLen, MQTTAsync_message *message)
void	test4_onConnect (void *context, MQTTAsync_successData *response)
void	test4_onPublish (void *context, MQTTAsync_successData *response)
void	test4_onSubscribe (void *context, MQTTAsync_successData *response)
void	test5_onConnect (void *context, MQTTAsync_successData *response)
void	test5_onConnectFailure (void *context, MQTTAsync_failureData *response)
int	test5a (struct Options options)
int	test5b (struct Options options)
int	test5c (struct Options options)
void	trace_callback (enum MQTTASYNC_TRACE_LEVELS level, char *message)
void	usage (void)

Variables
int	failures = 0
START_TIME_TYPE	global_start_time
struct Options	options
int	test2_onFailure_called = 0
void *	test4_payload = NULL
int	test4_payloadlen = 0
int	test5_onConnect_called = 0
int	test5_onFailure_called = 0
volatile int	test_finished = 0
char *	test_topic = "async test topic"
int	tests = 0

Detailed Description

Tests for the Paho MQTT Async C client

Definition in file test8.c.

Macro Definition Documentation

#define ARRAY_SIZE

(

a

)

(sizeof(a) / sizeof(a[0]))

Definition at line 36 of file test8.c.

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

Definition at line 195 of file test8.c.

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

Definition at line 196 of file test8.c.

#define LOGA_DEBUG   0

Definition at line 92 of file test8.c.

#define LOGA_INFO   1

Definition at line 93 of file test8.c.

#define mqsleep   sleep

Definition at line 153 of file test8.c.

#define START_TIME_TYPE   struct timeval

Definition at line 154 of file test8.c.

#define TEST3_CLIENTS   10

Function Documentation

long elapsed

(

START_TIME_TYPE

start_time

)

Definition at line 181 of file test8.c.

void getopts	(	int	argc,
		char **	argv
	)

Definition at line 58 of file test8.c.

int main	(	int	argc,
		char **	argv
	)

Definition at line 1102 of file test8.c.

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

Definition at line 203 of file test8.c.

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

Definition at line 97 of file test8.c.

START_TIME_TYPE start_clock

(

void

)

Definition at line 156 of file test8.c.

int test1

(

struct Options

options

)

Definition at line 333 of file test8.c.

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

Definition at line 249 of file test8.c.

void test1_onConnect	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 300 of file test8.c.

void test1_onConnectFailure	(	void *	context,
		MQTTAsync_failureData *	response
	)

Definition at line 317 of file test8.c.

void test1_onDisconnect	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 226 of file test8.c.

void test1_onSubscribe	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 283 of file test8.c.

void test1_onUnsubscribe	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 234 of file test8.c.

int test2

(

struct Options

options

)

Definition at line 424 of file test8.c.

void test2_onConnect	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 409 of file test8.c.

void test2_onFailure	(	void *	context,
		MQTTAsync_failureData *	response
	)

Definition at line 400 of file test8.c.

int test3

(

struct Options

options

)

Definition at line 632 of file test8.c.

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

Definition at line 532 of file test8.c.

void test3_onConnect	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 596 of file test8.c.

void test3_onDisconnect	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 502 of file test8.c.

void test3_onFailure	(	void *	context,
		MQTTAsync_failureData *	response
	)

Definition at line 613 of file test8.c.

void test3_onPublish	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 510 of file test8.c.

void test3_onSubscribe	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 578 of file test8.c.

void test3_onUnsubscribe	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 517 of file test8.c.

int test4

(

struct Options

options

)

Definition at line 822 of file test8.c.

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

Definition at line 712 of file test8.c.

void test4_onConnect	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 800 of file test8.c.

void test4_onPublish	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 705 of file test8.c.

void test4_onSubscribe	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 777 of file test8.c.

void test5_onConnect	(	void *	context,
		MQTTAsync_successData *	response
	)

Definition at line 888 of file test8.c.

void test5_onConnectFailure	(	void *	context,
		MQTTAsync_failureData *	response
	)

Definition at line 898 of file test8.c.

int test5a

(

struct Options

options

)

Definition at line 913 of file test8.c.

int test5b

(

struct Options

options

)

Definition at line 975 of file test8.c.

int test5c

(

struct Options

options

)

Definition at line 1037 of file test8.c.

void trace_callback	(	enum MQTTASYNC_TRACE_LEVELS	level,
		char *	message
	)

Definition at line 1095 of file test8.c.

void usage

(

void

)

Definition at line 38 of file test8.c.

Variable Documentation

int failures = 0

Definition at line 200 of file test8.c.

START_TIME_TYPE global_start_time

Definition at line 192 of file test8.c.

struct Options options

Initial value:

=
{
        "tcp://localhost:1883",
        0,
        -1,
        5000000,
}

int test2_onFailure_called = 0

Definition at line 398 of file test8.c.

void* test4_payload = NULL

Definition at line 702 of file test8.c.

int test4_payloadlen = 0

Definition at line 703 of file test8.c.

int test5_onConnect_called = 0

Definition at line 885 of file test8.c.

int test5_onFailure_called = 0

Definition at line 886 of file test8.c.

volatile int test_finished = 0

Definition at line 221 of file test8.c.

char* test_topic = "async test topic"

Definition at line 223 of file test8.c.

int tests = 0

Definition at line 199 of file test8.c.