#include <ctype.h>
#include <errno.h>
#include <limits.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <io.h>
#include <sys/types.h>
#include "daqc.h"
#include "daqc_private.h"
#include "daqc_response.h"
#include "daqc_internal.h"
#include "daqc_net.h"
#include "nds_auth.h"
#include "nds_logging.h"
#include "nds_os.h"
#include "nds2.h"
#include "daq_bsd_string.h"

Include dependency graph for nds2_access.c:

Classes
struct	nds2_chan_status

Macros
#define	NFDS(x) ( x + 1 )

#define	NDS2_VERSION_1_REVISION 0

#define	BUF_LENGTH 512UL

#define	MAX_TYPESTR_LENGTH 16

Functions
static int	get_version_and_revision (daq_t *daq)

static int	nds2_recv_channels_impl (daq_t daq, daq_channel_t channel, int num_channels, int num_channels_received, time_t gps, enum chantype type, const char pat, const char *METHOD)

static int	nds2_recv_hash_impl (daq_t daq, void hash, int hash_len, time_t gps, enum chantype type, const char pat, const char *METHOD)

int	nds2_connect (daq_t daq, const char host, int port)

int	nds2_disconnect (daq_t *daq)

int	nds2_get_last_message (daq_t daq, char message, size_t maxlen, int *str_len)

int	nds2_recv_channel_hash (daq_t daq, void hash, int *length, time_t gps, enum chantype type)

int	nds2_recv_hash_by_pattern (daq_t daq, void hash, int length, time_t gps, enum chantype type, const char pat)

int	nds2_recv_channel_list (daq_t daq, daq_channel_t channel, int num_channels, int *num_channels_received, time_t gps, enum chantype type)

int	nds2_recv_channels_by_pattern (daq_t daq, daq_channel_t channel, int num_channels, int num_channels_received, time_t gps, enum chantype type, const char pat)

int	nds2_recv_epoch_list (daq_t daq, char epochs, size_t max_len, int *str_len)

static size_t	_nds2_get_name_list (daq_t daq, char dst, size_t size)
	Print the name string. More...

int	nds2_recv_source_data (daq_t daq, char list, size_t max_len, time_t gps, long *str_len)

int	nds2_recv_source_list (daq_t daq, char list, size_t max_len, time_t gps, long *str_len)

int	nds2_request_check (daq_t *daq, time_t start, time_t end)

int	nds2_request_data (daq_t *daq, time_t start, time_t end, time_t dt)

int	nds2_receive_reconfigure (daq_t *daq, size_t block_len)

int	nds2_set_epoch (daq_t daq, const char epoch)

int	nds2_startup (void)

Macro Definition Documentation

#define BUF_LENGTH 512UL

#define MAX_TYPESTR_LENGTH 16

#define NDS2_VERSION_1_REVISION 0

#define NFDS ( x ) ( x + 1 )

Function Documentation

static size_t _nds2_get_name_list	(	daq_t *	daq,
		char *	dst,
		size_t	size
	)

static

Print the name string.

Parameters

daq	The daq structure
dst	Destination pointer
size	The max size of dst, including the NULL terminator

Returns: the number of bytes required to hold this information

Note: if dst is NULL or size == 0 no output is done (ie it only counts the number of bytes it would have taken to write the data).

static int get_version_and_revision ( daq_t * daq )

static

int nds2_connect	(	daq_t *	daq,
		const char *	host,
		int	port
	)

int nds2_disconnect ( daq_t * daq )

int nds2_get_last_message	(	daq_t *	daq,
		char *	message,
		size_t	maxlen,
		int *	str_len
	)

int nds2_receive_reconfigure	(	daq_t *	daq,
		size_t	block_len
	)

int nds2_recv_channel_hash	(	daq_t *	daq,
		void *	hash,
		int *	length,
		time_t	gps,
		enum chantype	type
	)

int nds2_recv_channel_list	(	daq_t *	daq,
		daq_channel_t *	channel,
		int	num_channels,
		int *	num_channels_received,
		time_t	gps,
		enum chantype	type
	)

int nds2_recv_channels_by_pattern	(	daq_t *	daq,
		daq_channel_t *	channel,
		int	num_channels,
		int *	num_channels_received,
		time_t	gps,
		enum chantype	type,
		const char *	pat
	)

static int nds2_recv_channels_impl	(	daq_t *	daq,
		daq_channel_t *	channel,
		int	num_channels,
		int *	num_channels_received,
		time_t	gps,
		enum chantype	type,
		const char *	pat,
		const char *	METHOD
	)

static

Static internal function to implement nds2_recv_channel_list() and nds2_recv_channels_by_pattern().

int nds2_recv_epoch_list	(	daq_t *	daq,
		char *	epochs,
		size_t	max_len,
		int *	str_len
	)

int nds2_recv_hash_by_pattern	(	daq_t *	daq,
		void *	hash,
		int *	length,
		time_t	gps,
		enum chantype	type,
		const char *	pat
	)

static int nds2_recv_hash_impl	(	daq_t *	daq,
		void *	hash,
		int *	hash_len,
		time_t	gps,
		enum chantype	type,
		const char *	pat,
		const char *	METHOD
	)

static

Static internal function to implement nds2_recv_channel_hash() and nds2_recv_hash_by_pattern().

int nds2_recv_source_data	(	daq_t *	daq,
		char *	list,
		size_t	max_len,
		time_t	gps,
		long *	str_len
	)

int nds2_recv_source_list	(	daq_t *	daq,
		char *	list,
		size_t	max_len,
		time_t	gps,
		long *	str_len
	)

int nds2_request_check	(	daq_t *	daq,
		time_t	start,
		time_t	end
	)

int nds2_request_data	(	daq_t *	daq,
		time_t	start,
		time_t	end,
		time_t	dt
	)

int nds2_set_epoch	(	daq_t *	daq,
		const char *	epoch
	)

int nds2_startup ( void )

Classes

Macros

Functions

Macro Definition Documentation

Function Documentation