builder.h

/* Copyright (C) 2017 Chris Piker <chris-piker@uiowa.edu>
 *
 * This file is part of das2C, the Core Das2 C Library.
 *
 * Das2C is free software; you can redistribute it and/or modify it under
 * the terms of the GNU Lesser General Public License version 2.1 as published
 * by the Free Software Foundation.
 *
 * Das2C is distributed in the hope that it will be useful, but WITHOUT ANY
 * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 * FOR A PARTICULAR PURPOSE.  See the GNU Lesser General Public License for
 * more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * version 2.1 along with das2C; if not, see <http://www.gnu.org/licenses/>.
 */
 
#ifndef _das_builder_h_
#define _das_builder_h_
 
#include <das3/processor.h>
#include <das3/dataset.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
struct ds_pd_set{
   PktDesc* pPd;
   DasDs* pDs;
};
 
typedef struct das_builder {
   StreamHandler base;
 
   DasStream* pStream;
 
   bool _released;       /* true if stream taken over by some other object */
 
   /* Das2 allows packet descriptors to be re-defined.  This is annoying but
    * we have to deal with it.  Here's the tracking mechanism
    *
    * lDsMap - The index in this array is a packet ID
    *          The value is the index in lPairs that holds a copy of the packet
    *          descriptor and it's dataset.
    *
    * lPairs -    The dataset and corresponding packet descriptors.
    *
    * If a packet ID is re-defined, first look to see if the new definition is
    * actually something that's been seen before and change the value in lDsMap
    * to the old definition. */
   int lDsMap[MAX_PKTIDS];
 
   size_t uValidPairs;
   struct ds_pd_set* lPairs;
   size_t uSzPairs;
 
} DasDsBldr;
 
DAS_API DasDsBldr* new_DasDsBldr(void);
 
DAS_API void del_DasDsBldr(DasDsBldr* pThis);
 
DAS_API void DasDsBldr_release(DasDsBldr* pThis);
 
DAS_API DasStream* DasDsBldr_getStream(DasDsBldr* pThis);
 
DAS_API DasStream* stream_from_stdin(const char* sProgName);
 
DAS_API DasStream* stream_from_path(const char* sProg, const char* sFile);
 
#ifdef __cplusplus
}
#endif
 
#endif   /* _das_builder_h_ */