telemetry_pipeline.h

Go to the documentation of this file.

 
#ifndef TELEMETRY_PIPELINE_H
#define TELEMETRY_PIPELINE_H
 
#include "modbus_analyzer.h"
#include "slab_pool.h"
 
#define TELEMETRY_PIPELINE_TASK_NAME             ("TELE_PLN") 
#define TELEMETRY_PIPELINE_TASK_STACK_DEPTH      (4096U)      
#define TELEMETRY_PIPELINE_TASK_PRIORITY         (10U)        
#define TELEMETRY_PIPELINE_TASK_CPU_AFFINITY     (0U)         
#define TELEMETRY_PIPELINE_TASK_NOTIFY_STOP_BIT  (1U << 0)    
#define TELEMETRY_PIPELINE_TASK_NOTIFY_FRAME_BIT (1U << 1)    
typedef struct {
    slab_pool_t *slab_ptr; 
    int64_t timestamp_us;  
} telemetry_pipeline_record_t;
 
bool telemetry_pipeline_init (modbus_analyzer_config_t *analyzer_config_ptr,
                              void (*record_ready_cb) (const telemetry_pipeline_record_t *));
 
void telemetry_pipeline_enqueue_raw_frame (const modbus_analyzer_frame_t *raw_frame_ptr);
 
void telemetry_pipeline_deinit (void);
 
#endif