[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.3 and 1.2.2.6

version 1.2.2.3, 2012/04/24 08:06:09 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;
         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);
Line 22  srv_Socket(cfg_root_t * __restrict cfg) Line 26  srv_Socket(cfg_root_t * __restrict cfg)
         } else          } else
                 AIT_FREE_VAL(&v);                  AIT_FREE_VAL(&v);
   
        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, &sa.sa, sa.sa.sa_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.3  
changed lines
  Added in v.1.2.2.6

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