store.h

Go to the documentation of this file.

/*!**********************************************************************
*
* @copyright Copyright (C) 2016 Siemens Aktiengesellschaft.\n
*            All rights reserved.
*
*************************************************************************
*
* @file     store.h
* @date     Sep 26, 2016
* @brief    Store module header file.
*
************************************************************************/

#ifndef STORE_H_
#define STORE_H_
#include "data_types.h"

typedef enum E_STORE_DATA_TYPE
{
    STORE_DATA_TIME_SERIES,              
    STORE_DATA_EVENT_LIST,               
    STORE_DATA_FILE,                     
    STORE_DATA_CUSTOM,                   
    STORE_DATA_STREAM,                   
    STORE_DATA_DATA_SOURCE_CONFIGURATION 
} E_STORE_DATA_TYPE;

typedef enum E_STORE_DATA_STATE
{
    DATA_STATE_INITIAL,         
    DATA_STATE_PREPARED,        
    DATA_STATE_WRITTEN,         
    DATA_STATE_STREAMING,       
    DATA_STATE_SENT 
} E_STORE_DATA_STATE;

typedef struct store_data_stream_info_t
{
    mcl_size_t meta_stream_index;    
    mcl_size_t payload_stream_index; 
    string_t *tuple_subboundary;     
    int meta_state;                  
    int payload_state;               
} store_data_stream_info_t;

typedef struct store_data_t
{
    void *data;                            
    E_STORE_DATA_TYPE type;                
    E_STORE_DATA_STATE state;              
    string_t *meta;                        
    mcl_uint8_t *payload_buffer;           
    mcl_size_t payload_size;               
    store_data_stream_info_t *stream_info; 
} store_data_t;

typedef struct mcl_store_t
{
    mcl_bool_t streamable;      

    list_t *high_priority_list; 

    list_t *low_priority_list;  
} store_t;

void store_data_set_state(store_data_t *store_data, E_STORE_DATA_STATE state);

E_STORE_DATA_STATE store_data_get_state(store_data_t *store_data);

E_MCL_ERROR_CODE store_data_remove(list_t *store_list, list_node_t *store_data_node);

mcl_size_t store_get_data_count(store_t *store);

#endif //STORE_H_