nds2_access.c File Reference

#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 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_name_list_length (daq_t *daq)
static size_t	_nds2_get_name_list (daq_t *daq, char *p)
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

BUF_LENGTH

#define BUF_LENGTH   512UL

MAX_TYPESTR_LENGTH

#define MAX_TYPESTR_LENGTH   16

NDS2_VERSION_1_REVISION

#define NDS2_VERSION_1_REVISION   0

NFDS

#define NFDS

(

x

)

( x + 1 )

Function Documentation

_nds2_get_name_list()

static size_t _nds2_get_name_list ( daq_t *  daq, char *  p  )

static

_nds2_name_list_length()

static size_t _nds2_name_list_length ( daq_t *  daq )

static

get_version_and_revision()

static int get_version_and_revision ( daq_t *  daq )

static

nds2_connect()

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

nds2_disconnect()

int nds2_disconnect

(

daq_t *

daq

)

nds2_get_last_message()

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

nds2_receive_reconfigure()

int nds2_receive_reconfigure	(	daq_t *	daq,
		size_t	block_len
	)

nds2_recv_channel_hash()

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

nds2_recv_channel_list()

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
	)

nds2_recv_channels_by_pattern()

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
	)

nds2_recv_channels_impl()

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().

nds2_recv_epoch_list()

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

nds2_recv_hash_by_pattern()

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

nds2_recv_hash_impl()

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().

nds2_recv_source_data()

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

nds2_recv_source_list()

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

nds2_request_check()

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

nds2_request_data()

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

nds2_set_epoch()

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

nds2_startup()

int nds2_startup

(

void

)