nds2-client - ClientDeveloper
0.16.8
|
#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"
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) |
#define BUF_LENGTH 512UL |
#define MAX_TYPESTR_LENGTH 16 |
#define NDS2_VERSION_1_REVISION 0 |
#define NFDS | ( | x | ) | ( x + 1 ) |
|
static |
|
static |
|
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 |
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 |
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 | ) |