Return to utils.c CVS log

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

change server to use new mqtt lib api calls

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