nds1_access.c File Reference

#include "daq_bsd_string.h"
#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 "nds1.h"
#include "nds_logging.h"
#include "nds_os.h"

Include dependency graph for nds1_access.c:

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

Functions
static int	nds_str_endswith (const char *str, const char *end)
static ssize_t	nds_str_lastindex (const char *str, int ch)
static int	_nds1_retrieve_version (daq_t *daq, int *v, int *rv)
int	nds1_reconnect (daq_t *daq)
int	nds1_connect (daq_t *daq, const char *host, int port)
int	nds1_disconnect (daq_t *daq)
int	nds1_get_last_message (daq_t *daq, char *buf, size_t max_len, int *str_len)
static void	cvthex (const char **s, char *buf, void *x)
static daq_data_t	nds1_get_trend_data_type (const char *trend_name, daq_data_t base_channel_type)
static void	_nl_to_null (char *s)
static int	_nds1_read_sc3_string (nds_socket_type sock, size_t max_len, char *buf)
static int	_nds1_read_sc3_number (nds_socket_type sock, size_t max_len, char *buf, long *out)
static int	_nds1_read_sc3_double (nds_socket_type sock, size_t max_len, char *buf, double *out)
static int	nds1_recv_channels_sc3 (daq_t *daq, daq_channel_t *channel, int num_channels, int *num_channels_received, const char *name)
static int	nds1_recv_channels_impl (daq_t *daq, daq_channel_t *channel, int num_channels, int *num_channels_received, const char *name)
int	nds1_recv_channels (daq_t *daq, daq_channel_t *channel, int num_channels, int *num_channels_received)
int	nds1_recv_channel (daq_t *daq, daq_channel_t *channel, const char *name)
int	nds1_request_check (daq_t *daq, time_t start, time_t end)
int	nds1_request_data (daq_t *daq, time_t start, time_t dt)
int	nds1_receive_reconfigure (daq_t *daq, size_t block_len)
int	nds1_startup (void)

Macro Definition Documentation

CHAN_BUF_SIZE_MAX

#define CHAN_BUF_SIZE_MAX   149 + 1

NFDS

#define NFDS

(

x

)

( x + 1 )

Function Documentation

_nds1_read_sc3_double()

static int _nds1_read_sc3_double ( nds_socket_type  sock, size_t  max_len, char *  buf, double *  out  )

static

_nds1_read_sc3_number()

static int _nds1_read_sc3_number ( nds_socket_type  sock, size_t  max_len, char *  buf, long *  out  )

static

_nds1_read_sc3_string()

static int _nds1_read_sc3_string ( nds_socket_type  sock, size_t  max_len, char *  buf  )

static

_nds1_retrieve_version()

static int _nds1_retrieve_version ( daq_t *  daq, int *  v, int *  rv  )

static

_nl_to_null()

static void _nl_to_null ( char *  s )

static

cvthex()

static void cvthex ( const char **  s, char *  buf, void *  x  )

static

nds1_connect()

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

nds1_disconnect()

int nds1_disconnect

(

daq_t *

daq

)

nds1_get_last_message()

int nds1_get_last_message	(	daq_t *	daq,
		char *	buf,
		size_t	max_len,
		int *	str_len
	)

nds1_get_trend_data_type()

static daq_data_t nds1_get_trend_data_type ( const char *  trend_name, daq_data_t  base_channel_type  )

static

nds1_receive_reconfigure()

int nds1_receive_reconfigure	(	daq_t *	daq,
		size_t	block_len
	)

nds1_reconnect()

int nds1_reconnect

(

daq_t *

daq

)

nds1_recv_channel()

int nds1_recv_channel	(	daq_t *	daq,
		daq_channel_t *	channel,
		const char *	name
	)

nds1_recv_channels()

int nds1_recv_channels	(	daq_t *	daq,
		daq_channel_t *	channel,
		int	num_channels,
		int *	num_channels_received
	)

nds1_recv_channels_impl()

static int nds1_recv_channels_impl ( daq_t *  daq, daq_channel_t *  channel, int  num_channels, int *  num_channels_received, const char *  name  )

static

nds1_recv_channels_sc3()

static int nds1_recv_channels_sc3 ( daq_t *  daq, daq_channel_t *  channel, int  num_channels, int *  num_channels_received, const char *  name  )

static

Cannot use daq_send as status channels 3 { ... } does not send a response code on success, only error.

nds1_request_check()

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

nds1_request_data()

int nds1_request_data	(	daq_t *	daq,
		time_t	start,
		time_t	dt
	)

nds1_startup()

int nds1_startup

(

void

)

nds_str_endswith()

static int nds_str_endswith ( const char *  str, const char *  end  )

static

nds_str_lastindex()

static ssize_t nds_str_lastindex ( const char *  str, int  ch  )

static