main.c File Reference

main flow with zmq related functions More...

#include <czmq.h>
#include "mb.h"

Include dependency graph for main.c:

Macros
#define	VERSION   @MODBUSD_VERSION@
#define	KEY_LOGGER   "syslog"
#define	KEY_IPC_TYPE   "zmq"
#define	KEY_IPC_PUB   "pub"
#define	KEY_IPC_SUB   "sub"
#define	KEY_MB_TYPE   "mbtcp"
#define	KEY_MBTCP_CONN_TIMEOUT   "connect_timeout"

Enumerations
enum	cmd_s {   FC1 = 1, FC2 = 2, FC3 = 3, FC4 = 4,   FC5 = 5, FC6 = 6, FC15 = 15, FC16 = 16,   SET_TCP_TIMEOUT = 50, GET_TCP_TIMEOUT = 51 }

Functions
int	main (int argc, char *argv[])

Variables
long	tcp_conn_timeout_usec
int	enable_syslog = 0
void *	zmq_pub = NULL

Detailed Description

main flow with zmq related functions

Author

Taka Wang

Macro Definition Documentation

#define KEY_IPC_PUB   "pub"

#define KEY_IPC_SUB   "sub"

#define KEY_IPC_TYPE   "zmq"

#define KEY_LOGGER   "syslog"

#define KEY_MB_TYPE   "mbtcp"

#define KEY_MBTCP_CONN_TIMEOUT   "connect_timeout"

#define VERSION   @MODBUSD_VERSION@

Referenced by main().

Enumeration Type Documentation

enum cmd_s

Enumerator
FC1
FC2
FC3
FC4
FC5
FC6
FC15
FC16
SET_TCP_TIMEOUT
GET_TCP_TIMEOUT

{
    FC1             = 1,
    FC2             = 2,
    FC3             = 3,
    FC4             = 4,
    FC5             = 5,
    FC6             = 6,
    FC15            = 15,
    FC16            = 16,
    SET_TCP_TIMEOUT = 50,
    GET_TCP_TIMEOUT = 51
} cmd_s;

Function Documentation

int main	(	int	argc,
		char *	argv[]
	)

References cJSON_Delete(), cJSON_Parse(), enable_syslog, FC1, FC15, FC16, FC2, FC3, FC4, FC5, FC6, GET_TCP_TIMEOUT, json_get_char(), json_get_int(), json_get_long(), LOG, mbtcp_cmd_hanlder(), mbtcp_get_response_timeout(), mbtcp_multi_write_req_fn(), mbtcp_read_bit_req_fn(), mbtcp_read_reg_req_fn(), mbtcp_set_response_timeout(), mbtcp_single_write_req_fn(), set_modbus_fail_resp_str(), SET_TCP_TIMEOUT, VERSION, and zmq_pub.

{
    LOG (enable_syslog, "modbusd version: %s", VERSION);

    // @get environemnt variable; 12-Factor
    char *env = getenv (env_conf_path);
    if (env != NULL)
    {
        config_fname = env;
        LOG (enable_syslog, "Get config path from environment variable: %s", env);
    }
    else
    {
        config_fname = argc > 1 ? argv[1] : "./modbusd.json";
        LOG (enable_syslog, "Get config path from flag: %s", config_fname);
    }

    // @load config
    load_config (config_fname, &config_json);

    // @setup zmq
    zctx_t *zmq_context = zctx_new ();                  // init zmq context
    void *zmq_sub = zsocket_new (zmq_context, ZMQ_SUB); // init zmq subscriber: zmq_sub
    zsocket_bind (zmq_sub, ipc_sub);                    // bind zmq subscriber
    zsocket_set_subscribe (zmq_sub, "");                // set zmq subscriber filter
    
    zmq_pub = zsocket_new (zmq_context, ZMQ_PUB);       // init zmq publisher: zmq_pub
    zsocket_bind (zmq_pub, ipc_pub);                    // bind zmq publisher

    LOG (enable_syslog, "start request listener");

    while (!zctx_interrupted) // handle ctrl+c
    {
        zmsg_t *msg = zmsg_recv (zmq_sub); // recv zmsg
        if (msg != NULL)
        {
            // get request mode (ex. tcp, rtu, others)
            zframe_t *frame_mode = zmsg_pop (msg);
            char *mode = zframe_strdup (frame_mode);

            // get request json string
            zframe_t *frame_json = zmsg_pop (msg);
            char *req_json_string = zframe_strdup (frame_json);

            // cleanup zmsg releated resources
            zmsg_destroy (&msg);
            zframe_destroy (&frame_mode);
            zframe_destroy (&frame_json);
            
            LOG (enable_syslog, "recv msg: %s, %s\n", mode, req_json_string);

            // parse json string
            cJSON *req_json_obj = cJSON_Parse (req_json_string);
            char * tid = json_get_char (req_json_obj, "tid");
            
            if (req_json_obj != NULL)
            {
                cmd_s cmd = json_get_int (req_json_obj, "cmd");
                
                // @handle modbus tcp requests
                if (strcmp (mode, "tcp") == 0)
                {
                    LOG (enable_syslog, "@@@req: %d", cmd);

                    switch (cmd)
                    {
                        case FC1:
                            send_modbus_resp (cmd, mbtcp_cmd_hanlder (cmd, req_json_obj, mbtcp_read_bit_req_fn));
                            break;
                        case FC2:
                            send_modbus_resp (cmd, mbtcp_cmd_hanlder (cmd, req_json_obj, mbtcp_read_bit_req_fn));
                            break;
                        case FC3:
                            send_modbus_resp (cmd, mbtcp_cmd_hanlder (cmd, req_json_obj, mbtcp_read_reg_req_fn));
                            break;
                        case FC4:
                            send_modbus_resp (cmd, mbtcp_cmd_hanlder (cmd, req_json_obj, mbtcp_read_reg_req_fn));
                            break;
                        case FC5:
                            send_modbus_resp (cmd, mbtcp_cmd_hanlder (cmd, req_json_obj, mbtcp_single_write_req_fn));
                            break;
                        case FC6:
                            send_modbus_resp (cmd, mbtcp_cmd_hanlder (cmd, req_json_obj, mbtcp_single_write_req_fn));
                            break;
                        case FC15:
                            send_modbus_resp (cmd, mbtcp_cmd_hanlder (cmd, req_json_obj, mbtcp_multi_write_req_fn));
                            break;
                        case FC16:
                            send_modbus_resp (cmd, mbtcp_cmd_hanlder (cmd, req_json_obj, mbtcp_multi_write_req_fn));
                            break;
                        case SET_TCP_TIMEOUT:
                            send_modbus_resp (cmd, mbtcp_set_response_timeout (tid, json_get_long (req_json_obj, "timeout")));
                            break;
                        case GET_TCP_TIMEOUT:
                            send_modbus_resp (cmd, mbtcp_get_response_timeout (tid));
                            break;
                        default: 
                            send_modbus_resp (cmd, set_modbus_fail_resp_str (tid, "unsupport request"));
                            break;
                    }
                }
                // @handle modbus rtu requests
                else if (strcmp (mode, "rtu") == 0)
                {
                    LOG (enable_syslog, "rtu:%d", cmd);
                    send_modbus_resp (-1, set_modbus_fail_resp_str (tid, "TODO"));
                }
                // @unkonw mode
                else
                {
                    send_modbus_resp (-1, set_modbus_fail_resp_str (tid, "unsupport mode"));
                }
            }
            else
            {
                send_modbus_resp (-2, set_modbus_fail_resp_str (tid, "Fail to parse command string"));
            }
            
            // @cleanup cJson object (auto mode)
            cJSON_Delete (req_json_obj);
        }
        else
        {
            //ERR(enable_syslog, "Recv null message");
        }
    }
    
    // @resource clean up
    LOG (enable_syslog, "housekeeping");
    zctx_destroy (&zmq_context);
    save_config (config_fname, config_json); 
}

Here is the call graph for this function:

Variable Documentation

int enable_syslog = 0

Referenced by main().

long tcp_conn_timeout_usec

Referenced by mbtcp_get_response_timeout(), mbtcp_init_handle(), and mbtcp_set_response_timeout().

void* zmq_pub = NULL

Referenced by main().