das2/stream.h

Go to the documentation of this file.

#ifndef _das2_stream_h_
#define _das2_stream_h_

#include <stdbool.h>
#include <das2/packet.h>

#define STREAMDESC_CMP_SZ 48
#define STREAMDESC_VER_SZ 48

typedef struct stream_descriptor{
   Descriptor base;

   PktDesc* pktDesc[100];

   /* Common properties */
   char compression[STREAMDESC_CMP_SZ];
   char version[STREAMDESC_VER_SZ];
   bool bDescriptorSent;
     
    void* pUser;  
} StreamDesc;


StreamDesc* new_StreamDesc(void);

StreamDesc* new_StreamDesc_str(DasBuf* pBuf);

StreamDesc* StreamDesc_copy(const StreamDesc* pThis);


void del_StreamDesc(StreamDesc* pThis);

size_t StreamDesc_getNPktDesc(const StreamDesc* pThis);

ErrorCode StreamDesc_addPktDesc(StreamDesc* pThis, PktDesc* pPd, int nPktId);


void StreamDesc_setMonotonic(StreamDesc* pThis, bool isMonotonic );

void StreamDesc_addStdProps(StreamDesc* pThis);

void StreamDesc_addCmdLineProp(StreamDesc* pThis, int argc, char* argv[] );

PktDesc* StreamDesc_createPktDesc(StreamDesc* pThis, DasEncoding* pXEncoder, 
                                  UnitType xUnits );

PktDesc* StreamDesc_clonePktDesc(StreamDesc* pThis, const PktDesc* pd);
                                        
PktDesc* StreamDesc_clonePktDescById(
   StreamDesc* pThis, const StreamDesc* pOther, int nPktId
);

bool StreamDesc_isValidId(const StreamDesc* pThis, int nPktId);
                                        
PktDesc* StreamDesc_getPktDesc(const StreamDesc* pThis, int id);

ErrorCode StreamDesc_freePktDesc(StreamDesc* pThis, int nPktId);

int StreamDesc_getOffset(StreamDesc* pThis);

ErrorCode StreamDesc_encode(StreamDesc* pThis, DasBuf* pBuf);

Descriptor* Das2Desc_decode(DasBuf* pBuf);

#endif /* _das2_stream_h_ */

---