---

nsds_util.h

Go to the documentation of this file.

#if !defined(NSDS_UTIL_H_)

#define NSDS_UTIL_H_


#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>

#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include <stdint.h>
#include <time.h>

int pthread_setconcurrency(int new_level);

// ---------------------------------------------------------------------
typedef enum
{
    SWAIT_SYS_ERR,
    SWAIT_TIMEOUT,
    SWAIT_GOT_DATA
} socket_wait_ret;


#if !defined(bool)
typedef enum 
{
    false, true
} bool;
#endif

#define MAX_CMD_LEN 8192

#define TSTAMP_LEN 32

#define DATUM_LEN 32

#define NUM_CHANNELS 128

static const char BAD_PORT[] = "Invalid port request: bad or missing channel ID";

static const char DATA_BUF_DELIM_CHARS[] = "\t\n\r";

static const char CMD_BUF_DELIM_CHARS[] = " \n\r\t";

/* Function prototypes*/
int tcp_socket_make(const uint16_t SRV_PORT, const int QUEUE_LENGTH);
int tcp_nl_write(const int socket, const char *buf);
int tcp_nl_read(const uint16_t socket, char *buf, const time_t timeout);
int tcp_connect(const char *server, const uint16_t port);
socket_wait_ret tcp_socket_wait(const int socket, const time_t timeout);
char * tcp_peername(const int socket);
int tcp_connect_retry(const char *host, const uint16_t port,
              const time_t retry_delay, const time_t end_time,
              const char *description);
void tcp_close(const int socket_fd);
char *gen_timestamp(void);

#endif

---