Return to utils.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

Annotation of mqtt/src/utils.c, revision 1.3

1.2       misho       1: #include "global.h"
1.3     ! misho       2: #include "mqttd.h"
        !             3: #include "mqttd_calls.h"
1.2       misho       4: 
                      5: 
1.3     ! misho       6: inline int
        !             7: srv_Socket(cfg_root_t * __restrict cfg)
1.2       misho       8: {
1.3     ! misho       9:        int s = -1;
        !            10:        ait_val_t v;
1.2       misho      11:        u_short port;
1.3     ! misho      12:        io_sockaddr_t sa = {{ 0 }};
1.2       misho      13: 
                     14:        ioTRACE(2);
                     15: 
1.3     ! misho      16:        assert(cfg);
        !            17: 
        !            18:        cfg_loadAttribute(cfg, "mqttd", "port", &v, MQTT_PORT);
        !            19:        port = strtol(AIT_GET_STR(&v), NULL, 0);
        !            20:        AIT_FREE_VAL(&v);
        !            21:        cfg_loadAttribute(cfg, "mqttd", "listen", &v, MQTT_HOST);
        !            22:        if (!io_gethostbyname(AIT_GET_STR(&v), port, &sa)) {
        !            23:                ioLIBERR(io);
        !            24:                AIT_FREE_VAL(&v);
1.2       misho      25:                return -1;
1.3     ! misho      26:        } else
        !            27:                AIT_FREE_VAL(&v);
1.2       misho      28: 
1.3     ! misho      29:        s = mqtt_srv_Create(&sa.sa, sa.sa.sa_len);
1.2       misho      30:        if (s == -1) {
1.3     ! misho      31:                ioLIBERR(mqtt);
1.2       misho      32:                return -1;
                     33:        }
                     34: 
1.3     ! misho      35:        ioDEBUG(7, "Created socket=%d\n", s);
1.2       misho      36:        return s;
                     37: }
                     38: 
1.3     ! misho      39: inline int
1.2       misho      40: srv_Close(int s)
                     41: {
                     42:        ioTRACE(2);
                     43: 
1.3     ! misho      44:        ioDEBUG(7, "Closing socket=%d\n", s);
        !            45:        return mqtt_srv_Destroy(s);
1.2       misho      46: }