| 
version 1.4, 2012/07/03 12:46:01
 | 
version 1.4.4.2, 2013/07/16 14:34:58
 | 
| 
 Line 12  terms:
 | 
 Line 12  terms:
 | 
 |  All of the documentation and software included in the ELWIX and AITNET | 
  All of the documentation and software included in the ELWIX and AITNET | 
 |  Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> | 
  Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> | 
 |   | 
   | 
| Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012 | Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013 | 
 |          by Michael Pounov <misho@elwix.org>.  All rights reserved. | 
          by Michael Pounov <misho@elwix.org>.  All rights reserved. | 
 |   | 
   | 
 |  Redistribution and use in source and binary forms, with or without | 
  Redistribution and use in source and binary forms, with or without | 
| 
 Line 54  srv_Socket(cfg_root_t * __restrict cfg)
 | 
 Line 54  srv_Socket(cfg_root_t * __restrict cfg)
 | 
 |          int s = -1; | 
          int s = -1; | 
 |          ait_val_t v; | 
          ait_val_t v; | 
 |          u_short port; | 
          u_short port; | 
|         io_sockaddr_t sa = {{ 0 }}; |         sockaddr_t sa = {{ 0 }}; | 
 |   | 
   | 
|         ioTRACE(2); |         ETRACE(); | 
 |   | 
   | 
 |          assert(cfg); | 
          assert(cfg); | 
 |   | 
   | 
| 
 Line 64  srv_Socket(cfg_root_t * __restrict cfg)
 | 
 Line 64  srv_Socket(cfg_root_t * __restrict cfg)
 | 
 |          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)) { |         if (!e_gethostbyname(AIT_GET_STR(&v), port, &sa)) { | 
|                 ioLIBERR(io); |                 ELIBERR(elwix); | 
 |                  AIT_FREE_VAL(&v); | 
                  AIT_FREE_VAL(&v); | 
 |                  return -1; | 
                  return -1; | 
 |          } else | 
          } else | 
| 
 Line 73  srv_Socket(cfg_root_t * __restrict cfg)
 | 
 Line 73  srv_Socket(cfg_root_t * __restrict cfg)
 | 
 |   | 
   | 
 |          s = mqtt_srv_Create(&sa.sa, sa.sa.sa_len); | 
          s = mqtt_srv_Create(&sa.sa, sa.sa.sa_len); | 
 |          if (s == -1) { | 
          if (s == -1) { | 
|                 ioLIBERR(mqtt); |                 ELIBERR(mqtt); | 
 |                  return -1; | 
                  return -1; | 
 |          } | 
          } | 
 |   | 
   | 
|         ioDEBUG(7, "Created socket=%d\n", s); |         EVERBOSE(7, "Created socket=%d\n", s); | 
 |          return s; | 
          return s; | 
 |  } | 
  } | 
 |   | 
   | 
 |  inline int | 
  inline int | 
 |  srv_Close(int s) | 
  srv_Close(int s) | 
 |  { | 
  { | 
|         ioTRACE(2); |         ETRACE(); | 
 |   | 
   | 
|         ioDEBUG(7, "Closing socket=%d\n", s); |         EVERBOSE(7, "Closing socket=%d\n", s); | 
 |          return mqtt_srv_Destroy(s); | 
          return mqtt_srv_Destroy(s); | 
 |  } | 
  } |