src/achpipe-bin.c File Reference

#include <pthread.h>
#include <signal.h>
#include <stdlib.h>
#include <stdio.h>
#include <assert.h>
#include <unistd.h>
#include <stdarg.h>
#include <string.h>
#include <time.h>
#include <errno.h>
#include <inttypes.h>
#include "ach.h"
#include "achutil.h"

Defines
#define	INIT_BUF_SIZE   512
	Initial size of ach frame buffer.
Functions
void	verbprintf (int level, const char fmt[],...)
	print stuff based on verbosity level
void	hard_assert (int test, const char fmt[],...)
	Check test, if false, print error and abort.
void	publish (FILE *fin, char *chan_name)
	publishing loop
void	subscribe (FILE *fin, FILE *fout, char *chan_name)
	subscribing loop
void	sighandler_install ()
	setup the signal handler
int	main (int argc, char **argv)
	main
Variables
char	opt_chan_name [ACH_CHAN_NAME_MAX+2] = {0}
	CLI option: channel name.
char	opt_remote_chan_name [ACH_CHAN_NAME_MAX+2] = {0}
	CLI option: remote channel name.
int	opt_pub = 0
	CLI option: publish mode.
int	opt_sub = 0
	CLI option: subscribe mode.
int	opt_verbosity = 0
	CLI option: verbosity level.
int	opt_last = 0
	CLI option: send only most recent frames.
int	opt_sync = 0
	CLI option: synchronous mode.
double	opt_freq = 0
	CLI option: frequency.
int	sig_received = 0
	got a signel yet?

---

Detailed Description

Author:

Neil T. Dantam

Bug:

does not fail gracefully when the channel can't be opened

Todo:

Extend protocol so that it only sends frames when requested

---

Function Documentation

void hard_assert	(	int	test,
		const char	fmt[],
			...
	)

Check test, if false, print error and abort.