mip_cmdqueue.h

Go to the documentation of this file.

 
#pragma once
 
#include <stdint.h>
 
#include "mip_types.h"
#include "mip_result.h"
#include "mip_packet.h"
 
#ifdef __cplusplus
namespace mip {
namespace C {
extern "C" {
#endif
 
 
 
 
 
 
typedef struct mip_pending_cmd
{
    struct mip_pending_cmd*     _next;                 
    uint8_t*                    _response_buffer;      
    union {                                            
        timeout_type            _extra_timeout;        
        timestamp_type          _timeout_time;         
        timestamp_type          _reply_time;           
    };
    uint8_t                     _descriptor_set;       
    uint8_t                     _field_descriptor;     
    uint8_t                     _response_descriptor;  
    union {
        uint8_t                 _response_buffer_size; 
        uint8_t                 _response_length;      
    };                                                 
    volatile enum mip_cmd_result _status;              
} mip_pending_cmd;
 
void mip_pending_cmd_init(mip_pending_cmd* cmd, uint8_t descriptor_set, uint8_t field_descriptor);
void mip_pending_cmd_init_with_timeout(mip_pending_cmd* cmd, uint8_t descriptor_set, uint8_t field_descriptor, timeout_type additional_time);
void mip_pending_cmd_init_with_response(mip_pending_cmd* cmd, uint8_t descriptor_set, uint8_t field_descriptor, uint8_t response_descriptor, uint8_t* response_buffer, uint8_t response_buffer_size);
void mip_pending_cmd_init_full(mip_pending_cmd* cmd, uint8_t descriptor_set, uint8_t field_descriptor, uint8_t response_descriptor, uint8_t* response_buffer, uint8_t response_size, timeout_type additional_time);
 
enum mip_cmd_result mip_pending_cmd_status(const mip_pending_cmd* cmd);
 
const uint8_t* mip_pending_cmd_response(const mip_pending_cmd* cmd);
uint8_t mip_pending_cmd_response_length(const mip_pending_cmd* cmd);
 
bool mip_pending_cmd_check_timeout(const mip_pending_cmd* cmd, timestamp_type now);
 
 
 
typedef struct mip_cmd_queue
{
    mip_pending_cmd* _first_pending_cmd;
    timeout_type     _base_timeout;
} mip_cmd_queue;
 
void mip_cmd_queue_init(mip_cmd_queue* queue, timeout_type base_reply_timeout);
void mip_cmd_queue_enqueue(mip_cmd_queue* queue, mip_pending_cmd* cmd);
void mip_cmd_queue_dequeue(mip_cmd_queue* queue, mip_pending_cmd* cmd);
 
void mip_cmd_queue_clear(mip_cmd_queue* queue);
 
void mip_cmd_queue_update(mip_cmd_queue* queue, timestamp_type timestamp);
 
void mip_cmd_queue_set_base_reply_timeout(mip_cmd_queue* queue, timeout_type timeout);
timeout_type mip_cmd_queue_base_reply_timeout(const mip_cmd_queue* queue);
 
void mip_cmd_queue_process_packet(mip_cmd_queue* queue, const mip_packet* packet, timestamp_type timestamp);
 
 
 
#ifdef __cplusplus
} // namespace C
} // namespace mip
} // extern "C"
#endif