version 1.2.2.3, 2012/04/24 08:06:09
|
version 1.3, 2012/07/03 09:02:50
|
Line 1
|
Line 1
|
#include "global.h" |
#include "global.h" |
|
#include "mqttd.h" |
|
#include "mqttd_calls.h" |
|
|
|
|
int | inline 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; |
|
} |
|
|
|
|
ioDEBUG(7, "Created socket=%d\n", s); |
return s; |
return s; |
} |
} |
|
|
int | inline int |
srv_Close(int s) |
srv_Close(int s) |
{ |
{ |
ioTRACE(2); |
ioTRACE(2); |
|
|
if (s > STDERR_FILENO) | ioDEBUG(7, "Closing socket=%d\n", s); |
shutdown(s, SHUT_RDWR); | return mqtt_srv_Destroy(s); |
| |
return close(s); | |
} |
} |