[BACK]Return to utils.c CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / mqtt / src

Diff for /mqtt/src/utils.c between versions 1.2.2.2 and 1.2.2.6

version 1.2.2.2, 2012/04/15 21:44:33 version 1.2.2.6, 2012/06/29 15:43:13
Line 1 Line 1
 #include "global.h"  #include "global.h"
   #include "mqttd.h"
   #include "mqttd_calls.h"
   
   
intinline int
 srv_Socket(cfg_root_t * __restrict cfg)  srv_Socket(cfg_root_t * __restrict cfg)
 {  {
        int s = -1, n = 1;        int s = -1;
        struct hostent *host; 
         ait_val_t v;          ait_val_t v;
         u_short port;          u_short port;
        io_sockaddr_t sa;        io_sockaddr_t sa = {{ 0 }};
   
         ioTRACE(2);          ioTRACE(2);
   
           assert(cfg);
   
         cfg_loadAttribute(cfg, "mqttd", "port", &v, MQTT_PORT);          cfg_loadAttribute(cfg, "mqttd", "port", &v, MQTT_PORT);
         port = strtol(AIT_GET_STR(&v), NULL, 0);          port = strtol(AIT_GET_STR(&v), NULL, 0);
         AIT_FREE_VAL(&v);          AIT_FREE_VAL(&v);
         cfg_loadAttribute(cfg, "mqttd", "listen", &v, MQTT_HOST);          cfg_loadAttribute(cfg, "mqttd", "listen", &v, MQTT_HOST);
        if (!io_gethostbyname(AIT_GET_STR(&v), port, &sa)) {
        host = gethostbyname(AIT_GET_STR(&v));                ioLIBERR(io);
        AIT_FREE_VAL(&v);                AIT_FREE_VAL(&v);
        if (!host) { 
                ioERROR(h_errno, "%s", hstrerror(h_errno)); 
                 return -1;                  return -1;
        }        } else
        switch (host->h_addrtype) {                AIT_FREE_VAL(&v);
                case AF_INET: 
                        sa.sin.sin_len = sizeof(struct sockaddr_in); 
                        sa.sin.sin_family = AF_INET; 
                        sa.sin.sin_port = htons(port); 
                        memcpy(&sa.sin.sin_addr, host->h_addr, sizeof sa.sin.sin_addr); 
                        break; 
                case AF_INET6: 
                        sa.sin6.sin6_len = sizeof(struct sockaddr_in6); 
                        sa.sin6.sin6_family = AF_INET6; 
                        sa.sin6.sin6_port = htons(port); 
                        memcpy(&sa.sin6.sin6_addr, host->h_addr, sizeof sa.sin6.sin6_addr); 
                        break; 
                default: 
                        ioERROR(host->h_addrtype, "unsupported socket type"); 
                        return -1; 
        } 
   
        s = socket(sa.ss.ss_family, SOCK_STREAM, 0);        s = mqtt_srv_Create(&sa.sa, sa.sa.sa_len);
         if (s == -1) {          if (s == -1) {
                ioSYSERR(0);                ioLIBERR(mqtt);
                 return -1;                  return -1;
         }          }
         if (setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &n, sizeof n) == -1) {  
                 ioSYSERR(0);  
                 close(s);  
                 return -1;  
         }  
         if (bind(s, (struct sockaddr*) &sa.ss, sa.ss.ss_len) == -1) {  
                 ioSYSERR(0);  
                 close(s);  
                 return -1;  
         }  
   
         return s;          return s;
 }  }
   
intinline int
 srv_Close(int s)  srv_Close(int s)
 {  {
         ioTRACE(2);          ioTRACE(2);
   
        if (s > STDERR_FILENO)        return mqtt_srv_Destroy(s);
                shutdown(s, SHUT_RDWR);}
   
        return close(s);inline int
 srv_Will(struct tagSession * __restrict sess)
 {
         int ret = 0;
 
         ioTRACE(2);
 
         ret = mqtt_msgPUBLISH(sess->sess_buf, sess->sess_will.topic, 0xDEAD, 0, 1, 0, 
                         sess->sess_will.msg, sess->sess_will.msg ? strlen(sess->sess_will.msg) : 0);
         if (ret == -1)
                 return -1;      /* error */
         else
                 return cmdPUBLISH(sess->sess_srv, ret, sess);
 }  }
Removed from v.1.2.2.2  
changed lines
  Added in v.1.2.2.6

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>