reactor.h

 
#ifndef ASRT_REACTOR_H
#define ASRT_REACTOR_H
 
#ifdef __cplusplus
extern "C" {
#endif
 
#include "../asrtl/chann.h"
#include "../asrtl/core_proto.h"
#include "../asrtl/status.h"
#include "record.h"
 
#include <stdint.h>
 
struct asrt_test
{
        char const*        desc;     
        void*              ptr;      
        asrt_test_callback start_f;  
        struct asrt_test*  next;     
};
 
enum asrt_reactor_state
{
        ASRT_REAC_IDLE        = 1,  
        ASRT_REAC_TEST_EXEC   = 2,  
        ASRT_REAC_TEST_REPORT = 3,  
        ASRT_REAC_WAIT_SEND   = 4,  
};
 
enum asrt_reactor_flags
{
        ASRT_FLAG_DESC      = 0x01,
        ASRT_FLAG_PROTO_VER = 0x02,
        ASRT_FLAG_TC        = 0x04,
        ASRT_FLAG_TI        = 0x08,
        ASRT_FLAG_TSTART    = 0x10,
        ASRT_FLAG_LOCKED    = 0x20,
};
 
// Mask of flags that carry persistent state (not pending work).
// Used to strip passive bits when checking for actionable flags.
#define ASRT_PASSIVE_FLAGS ( ASRT_FLAG_LOCKED )
 
struct asrt_reactor
{
        struct asrt_node node;
        char const*      desc;
 
        struct asrt_test* first_test;
        struct asrt_test* last_test;
 
        enum asrt_reactor_state state;
        struct asrt_reac_wait_send
        {
                enum asrt_reactor_state next_state;
                uint32_t                err_run_id;
                struct asrt_u8d8msg     err_result_msg;
        } wait_send;
        struct asrt_test_input test_info;
        struct asrt_record     record;
 
        uint32_t flags;  // values of asrt_reactor_flags
 
        uint16_t recv_test_info_id;
        uint16_t recv_test_start_id;
        uint32_t recv_test_run_id;
 
        struct asrt_u8d8msg            proto_ver_msg;
        struct asrt_core_desc_msg      desc_msg;
        struct asrt_u8d4msg            tc_msg;
        struct asrt_core_test_info_msg ti_msg;
        struct asrt_u8d8msg            test_start_msg;
        struct asrt_u8d8msg            test_result_msg;
};
 
enum asrt_status asrt_reactor_init(
    struct asrt_reactor*       reac,
    struct asrt_send_req_list* send_queue,
    char const*                desc );
 
enum asrt_status asrt_test_init(
    struct asrt_test*  t,
    char const*        desc,
    void*              ptr,
    asrt_test_callback start_f );
enum asrt_status asrt_reactor_add_test( struct asrt_reactor* reac, struct asrt_test* test );
void asrt_reactor_deinit( struct asrt_reactor* reac );
 
#ifdef __cplusplus
}
#endif
 
#endif