processor.h

Go to the documentation of this file.

/* Copyright (C) 2015-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_processor_h_
#define _das_processor_h_
 
#include <das3/stream.h>
#include <das3/oob.h>
 
#ifdef __cplusplus
extern "C" {
#endif
 
 
typedef DasErrCode (*DasStreamHandler)(DasStream* sd, void* ud);
 
typedef DasErrCode (*PktDescHandler)(DasStream* sd, PktDesc* pd, void* ud);
 
typedef DasErrCode (*PktRedefHandler)(DasStream* sd, DasDesc* pd, void* ud);
      
typedef DasErrCode (*PktDataHandler)(PktDesc* pd, void* ud);
 
 
typedef DasErrCode (*DsDescHandler)(DasStream* sd, int pi, DasDs* dd, void* ud);
 
typedef DasErrCode (*DsDataHandler)(DasStream* sd, int pi, DasDs* dd, void* ud);
 
typedef DasErrCode (*RawDataHandler)(
   DasStream* sd, int pi, DasDesc* dd, const DasBuf* pb, void* ud
);
 
typedef DasErrCode (*CloseHandler)(DasStream* sd, void* ud);
 
typedef DasErrCode (*ExceptionHandler)(OobExcept* se, void* ud);
 
typedef DasErrCode (*CommentHandler)(OobComment* se, void* ud);
 
 
typedef struct _streamHandler {
   DasStreamHandler streamDescHandler;
    
   PktDescHandler pktDescHandler;
   
   PktRedefHandler pktRedefHandler;
    
   PktDataHandler pktDataHandler;
 
   DsDescHandler dsDescHandler;
 
   DsDataHandler dsDataHandler;
 
   RawDataHandler rawDataHandler;
 
    
   ExceptionHandler exceptionHandler;
    
   CommentHandler commentHandler;
   
   CloseHandler closeHandler;
   
   void* userData;
    
} StreamHandler;
 
DAS_API void StreamHandler_init(StreamHandler* pThis, void* pUserData);
 
DAS_API StreamHandler* new_StreamHandler(void* pUserData);
 
DAS_API void del_StreamHandler(StreamHandler* pThis);
 
#ifdef __cplusplus
}
#endif
 
#endif /* _das_processor_h_ */