das2/oob.h

Go to the documentation of this file.

#ifndef _das2_oob_h_
#define _das2_oob_h_

#include <das2/util.h>
#include <das2/buffer.h>

#define EXCEPTION_UNTYPED ""

#define DAS2_EXCEPT_NO_DATA_IN_INTERVAL "NoDataInInterval"
#define DAS2_EXCEPT_ILLEGAL_ARGUMENT    "IllegalArgument"
#define DAS2_EXCEPT_SERVER_ERROR        "ServerError"

typedef enum oob_type {OOB_EXCEPT, OOB_COMMENT} oob_t;

typedef struct out_of_band {
   oob_t pkttype;
   void (*clean)(struct out_of_band* pThis);
} OutOfBand;

void OutOfBand_clean(OutOfBand* pThis);

typedef struct stream_exception {
   OutOfBand base;
   
   char* sType;      /* NoDataInInterval, Exception */
   size_t uTypeLen;
   
   char* sMsg;      /* May be altered by encode function to change " to ' */
   size_t uMsgLen;
   
} OobExcept;

void OobExcept_init(OobExcept* pThis);

void OobExcept_set(OobExcept* pThis, const char* sType, const char* sMsg);

ErrorCode OobExcept_decode(OobExcept* pThis, DasBuf* str);

ErrorCode OobExcept_encode(OobExcept* pThis, DasBuf* pBuf);


typedef struct stream_comment{
   OutOfBand base;
   
   char* sType;
   size_t uTypeLen;
   
   char* sSrc;
   size_t uSrcLen;
   
   char* sVal;
   size_t uValLen;
} OobComment;

void OobComment_init(OobComment* pThis);

ErrorCode OobComment_encode(OobComment* pThis, DasBuf* pBuf);

ErrorCode OobComment_decode(OobComment* pThis, DasBuf* sbuf);


ErrorCode OutOfBand_decode(DasBuf* pBuf, OutOfBand** ppObjs, int* which);


#endif /* _das2_oob_h_ */

---