File syn_modbus_master.h

File List > proto > syn_modbus_master.h

Go to the documentation of this file

#ifndef SYN_MODBUS_MASTER_H
#define SYN_MODBUS_MASTER_H

#include "../common/syn_defs.h"
#include "syn_modbus.h"

#ifdef __cplusplus
extern "C" {
#endif

typedef enum {
    SYN_MB_MASTER_STATE_IDLE = 0,
    SYN_MB_MASTER_STATE_WAITING_RESPONSE,
    SYN_MB_MASTER_STATE_COMPLETE,
    SYN_MB_MASTER_STATE_TIMEOUT,
    SYN_MB_MASTER_STATE_ERROR,
} SYN_ModbusMaster_State;

typedef struct {
    SYN_ModbusMaster_State state; 
    uint8_t buf[256]; 
    uint16_t rx_len;  
    uint16_t tx_len;  
    uint8_t slave_addr;  
    uint8_t func_code;   
    uint16_t start_addr; 
    uint16_t count;      
    uint32_t request_tick_ms;   
    uint32_t timeout_ms;        
    uint32_t last_byte_tick_ms; 
    uint8_t response_fc;    
    uint8_t exception_code; 
    uint16_t read_data[125]; 
    uint16_t read_count;     
} SYN_ModbusMaster;

void syn_modbus_master_init(SYN_ModbusMaster *m, uint32_t timeout_ms);

SYN_Status syn_modbus_master_read_holding(SYN_ModbusMaster *m, uint8_t slave_addr,
                                          uint16_t start_addr, uint16_t count);

SYN_Status syn_modbus_master_read_input(SYN_ModbusMaster *m, uint8_t slave_addr,
                                        uint16_t start_addr, uint16_t count);

SYN_Status syn_modbus_master_write_single(SYN_ModbusMaster *m, uint8_t slave_addr,
                                          uint16_t reg_addr, uint16_t value);

SYN_Status syn_modbus_master_write_multiple(SYN_ModbusMaster *m, uint8_t slave_addr,
                                            uint16_t start_addr, uint16_t count,
                                            const uint16_t *values);

SYN_Status syn_modbus_master_read_coils(SYN_ModbusMaster *m, uint8_t slave_addr,
                                        uint16_t start_addr, uint16_t count);

SYN_Status syn_modbus_master_read_discrete_inputs(SYN_ModbusMaster *m, uint8_t slave_addr,
                                                  uint16_t start_addr, uint16_t count);

SYN_Status syn_modbus_master_write_single_coil(SYN_ModbusMaster *m, uint8_t slave_addr,
                                               uint16_t coil_addr, bool state);

SYN_Status syn_modbus_master_write_multiple_coils(SYN_ModbusMaster *m, uint8_t slave_addr,
                                                  uint16_t start_addr, uint16_t count,
                                                  const uint8_t *coil_bytes);

SYN_Status syn_modbus_master_mask_write_register(SYN_ModbusMaster *m, uint8_t slave_addr,
                                                 uint16_t reg_addr, uint16_t and_mask,
                                                 uint16_t or_mask);

SYN_Status syn_modbus_master_read_fifo_queue(SYN_ModbusMaster *m, uint8_t slave_addr,
                                             uint16_t fifo_addr);

SYN_Status syn_modbus_master_report_server_id(SYN_ModbusMaster *m, uint8_t slave_addr);

void syn_modbus_master_feed(SYN_ModbusMaster *m, uint8_t byte);

SYN_ModbusMaster_State syn_modbus_master_process(SYN_ModbusMaster *m, uint32_t current_tick_ms);

/* ── Modbus Master Polling & Transaction Queue ──────────────────────────── */

typedef void (*SYN_ModbusMasterCallback)(uint8_t slave_addr, uint8_t func_code,
                                         const uint16_t *data, uint16_t count, SYN_Status status,
                                         void *user_ctx);

typedef struct {
    uint8_t slave_addr;
    uint8_t func_code;
    uint16_t start_addr;
    uint16_t count;
    uint16_t write_value;
    SYN_ModbusMasterCallback callback;
    void *user_ctx;
} SYN_ModbusMasterQuery;

#ifndef SYN_MODBUS_QUEUE_SIZE
#define SYN_MODBUS_QUEUE_SIZE 16
#endif

typedef struct {
    SYN_ModbusMasterQuery queries[SYN_MODBUS_QUEUE_SIZE];
    uint8_t head;
    uint8_t tail;
    uint8_t count;
    uint8_t max_retries;
    uint8_t retry_count;
} SYN_ModbusMasterQueue;

void syn_modbus_master_queue_init(SYN_ModbusMasterQueue *q, uint8_t max_retries);

SYN_Status syn_modbus_master_queue_push(SYN_ModbusMasterQueue *q,
                                        const SYN_ModbusMasterQuery *query);

SYN_Status syn_modbus_master_queue_step(SYN_ModbusMaster *m, SYN_ModbusMasterQueue *q,
                                        uint32_t now_ms);

#ifdef __cplusplus
}
#endif

#endif /* SYN_MODBUS_MASTER_H */