proxy_thr.cpp File Reference

#include "../include/zmq.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include <time.h>
#include <stdarg.h>
#include <string>
#include "platform.hpp"
#include <pthread.h>
#include <unistd.h>

Include dependency graph for proxy_thr.cpp:

Go to the source code of this file.

Classes
struct	proxy_hwm_cfg_t

Macros
#define	ARRAY_SIZE(x)   (sizeof (x) / sizeof (*x))
#define	ASSERT_EXPR_SAFE(x)   assert (x)
#define	HWM   10000
#define	TEST_ASSERT_SUCCESS_ERRNO(expr)   test_assert_success_message_errno_helper (expr, NULL, #expr)

Functions
int	main (int argc, char *argv[])
static void	proxy_thread_main (void *pvoid)
static void	publisher_thread_main (void *pvoid)
static void	set_hwm (void *skt)
static void	subscriber_thread_main (void *pvoid)
void	terminate_proxy (const proxy_hwm_cfg_t *cfg)
int	test_assert_success_message_errno_helper (int rc_, const char *msg_, const char *expr_)

Variables
static uint64_t	message_count = 0
static size_t	message_size = 0

Macro Definition Documentation

ARRAY_SIZE

#define ARRAY_SIZE

(

x

)

(sizeof (x) / sizeof (*x))

Definition at line 44 of file proxy_thr.cpp.

ASSERT_EXPR_SAFE

#define ASSERT_EXPR_SAFE

(

x

)

assert (x)

Definition at line 58 of file proxy_thr.cpp.

HWM

#define HWM   10000

Definition at line 41 of file proxy_thr.cpp.

TEST_ASSERT_SUCCESS_ERRNO

#define TEST_ASSERT_SUCCESS_ERRNO

(

expr

)

test_assert_success_message_errno_helper (expr, NULL, #expr)

Definition at line 47 of file proxy_thr.cpp.

Function Documentation

main()

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 298 of file proxy_thr.cpp.

proxy_thread_main()

static void proxy_thread_main ( void *  pvoid )

static

Definition at line 205 of file proxy_thr.cpp.

publisher_thread_main()

static void publisher_thread_main ( void *  pvoid )

static

Definition at line 103 of file proxy_thr.cpp.

set_hwm()

static void set_hwm ( void *  skt )

static

Definition at line 92 of file proxy_thr.cpp.

subscriber_thread_main()

static void subscriber_thread_main ( void *  pvoid )

static

Definition at line 166 of file proxy_thr.cpp.

terminate_proxy()

void terminate_proxy

(

const proxy_hwm_cfg_t *

cfg

)

Definition at line 274 of file proxy_thr.cpp.

test_assert_success_message_errno_helper()

int test_assert_success_message_errno_helper	(	int	rc_,
		const char *	msg_,
		const char *	expr_
	)

Definition at line 76 of file proxy_thr.cpp.

Variable Documentation

message_count

uint64_t message_count = 0

static

Definition at line 62 of file proxy_thr.cpp.

message_size

size_t message_size = 0

static

Definition at line 63 of file proxy_thr.cpp.