ldmcpp.h

// New ldm include file
// The standard LDM includes don't work too well with the GCC C++ compiler
// So this is a hacked version
// This is all credit to and copyright of UCAR

#ifdef USE_SYSTEM_LDM_HEADERS
#include <pq.h>
#define _LDMCPP_H
#endif

#ifndef _LDMCPP_H
#define _LDMCPP_H


//#include <rpc/rpc.h>
#include <sys/types.h>  /* off_t, mode_t */
#include <stddef.h>     /* size_t */
#include <stdlib.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <sys/time.h>
#include <regex.h>



/*
 *   Copyright 1994, University Corporation for Atmospheric Research
 *   See ../COPYRIGHT file for copying and redistribution conditions.
 */
/* $Id: prod_class.h,v 1.17.18.1 2005/01/21 21:34:57 steve Exp $ */


extern const char* ldm_version;


typedef struct timeval timestampt;

extern const struct timeval TS_NONE; /* an invalid time */
extern const struct timeval TS_ZERO; /* the beginning of time */
extern const struct timeval TS_ENDT; /* the end of time */



typedef u_int feedtypet;

struct prod_spec {
        feedtypet feedtype;
        char *pattern;
        regex_t rgx;    /* volatile, not sent over the wire */
};
typedef struct prod_spec prod_spec;

/*
 * prod_class is a set of products
 */

struct prod_class {
        timestampt from;
        timestampt to;
        struct {
                u_int psa_len;
                prod_spec *psa_val;
        } psa;
};
typedef struct prod_class prod_class;

typedef unsigned char signaturet[16];

/*
 * pkey: product identification string (Not used as a key anymore).
 * max length of pkey, _POSIX_PATH_MAX.
 */
typedef char *keyt;


/*
 * prod_info describes a specific data product.
 * (not a class of products).
 *
 */

struct prod_info {
        timestampt arrival;
        signaturet signature;
        char *origin;
        feedtypet feedtype;
        u_int seqno;
        keyt ident;
        u_int sz;
};
typedef struct prod_info prod_info;


#ifndef _PROD_CLASS_H_
#define _PROD_CLASS_H_

/*
 * Define a set of products
 */
extern const prod_class _clss_all;
#define PQ_CLASS_ALL    (&_clss_all)
extern const prod_spec _spec_all;
#define PQ_SPEC_ALL     (&_spec_all)


extern void
free_prod_class(prod_class *clssp);

extern prod_class *
new_prod_class(u_int psa_len);

#endif /* !_PROD_CLASS_H_ */


#ifndef _PQ_H
#define _PQ_H

/*
 * The functions below return ENOERR upon success.
 * Upon failure, the return something else :-).
 * (Usually, that something else will be the a system
 * error (errno.h), don't count on it making sense.)
 */
#ifndef ENOERR
#define ENOERR 0
#endif 
#define PQ_CORRUPT      -1

typedef struct pqueue pqueue; /* private, implemented in pq.c */


/*
 * pflags arg to pq_open() and pq_create()
 */
#define PQ_DEFAULT      0x00
#define PQ_NOCLOBBER    0x01    /* Don't destroy existing file on create */
#define PQ_READONLY     0x02    /* Default is read/write */
#define PQ_NOLOCK       0x04    /* Disable locking */
#define PQ_PRIVATE      0x08    /* mmap() the file MAP_PRIVATE, default MAP_SHARED */
#define PQ_NOGROW       0x10    /* If pq_create(), must have intialsz */
#define PQ_NOMAP        0x20    /* Use malloc/read/write/free instead of mmap() */
#define PQ_MAPRGNS      0x40    /* Map region by region, default whole file */
#define PQ_SPARSE       0x80    /* Created as sparse file, zero blocks unallocated */
/* N.B.: bits 0x1000 (and above) in use internally */

extern int
pq_create(const char *path, mode_t mode, int pflags,
        size_t align, off_t initialsz, size_t nproducts,
        pqueue **pqp);

extern int
pq_open(const char *path,
        int pflags,
        pqueue **pqp);

extern int 
pq_close(pqueue *pq);



/* prototype for 4th arg to pq_sequence() */
typedef int pq_seqfunc(const prod_info *infop, const void *datap,
        void *xprod, size_t len,
        void *otherargs);

/*
 * Which direction the cursor moves in pq_sequence().
 */
typedef enum {
        TV_LT = -1,
        TV_EQ =  0,
        TV_GT =  1
} pq_match;


/*
 * Step thru the time sorted inventory according to 'mt',
 * and the current cursor value.
 *
 * If(mt == TV_LT), pq_sequence() will get a product
 * whose queue insertion timestamp is strictly less than
 * the current cursor value.
 *
 * If(mt == TV_GT), pq_sequence() will get a product
 * whose queue insertion timestamp is strictly greater than
 * the current cursor value.
 *
 * If(mt == TV_EQ), pq_sequence() will get a product
 * whose queue insertion timestamp is equal to
 * the current cursor value.
 *
 * If no product is in the inventory which which meets the
 * above spec, return PQUEUE_END.
 *
 * Otherwise, if the product info matches class,
 * execute ifMatch(xprod, len, otherargs) and return the
 * return value from ifMatch().
 */
#define PQUEUE_END (-1) /* return value indicating end of queue */
extern int
pq_sequence(pqueue *pq, pq_match mt,
        const prod_class *clssp, pq_seqfunc *ifMatch, void *otherargs);

/*
 * Suspend yourself (sleep) until
 * one of the following events occurs:
 *   You recieve a signal that you handle.
 *   You recieve SIGCONT (as send from an insert proc indicating
 *      data is available).
 *   "maxsleep" seconds elapse.
 *   If "maxsleep" is zero, you could sleep forever. 
 */
extern unsigned
pq_suspend(unsigned int maxsleep);
#endif /* !_PQ_H */



#endif

---