#include "includes.h"
#include "smb_launchd.h"
extern pstring user_socket_options;
static int init_sockets_smbd(const char *smb_ports, int listenset[FD_SETSIZE])
{
int num_interfaces = iface_count();
char * ports;
int num_sockets = 0;
int i, s;
if (!smb_ports) {
ports = lp_smb_ports();
if (!ports || !*ports) {
ports = smb_xstrdup(SMB_PORTS);
} else {
ports = smb_xstrdup(ports);
}
} else {
ports = smb_xstrdup(smb_ports);
}
if (lp_interfaces() && lp_bind_interfaces_only()) {
for(i = 0; i < num_interfaces; i++) {
struct in_addr *ifip = iface_n_ip(i);
fstring tok;
const char *ptr;
if(ifip == NULL) {
DEBUG(0,("init_sockets_smbd: interface %d has NULL IP address !\n", i));
continue;
}
for (ptr=ports; next_token(&ptr, tok, " \t,", sizeof(tok)); ) {
unsigned port = atoi(tok);
if (port == 0) {
continue;
}
s = listenset[num_sockets] = open_socket_in(SOCK_STREAM, port, 0, ifip->s_addr, True);
if(s == -1)
return 0;
set_socket_options(s,"SO_KEEPALIVE");
set_socket_options(s,user_socket_options);
set_blocking(s,False);
if (listen(s, SMBD_LISTEN_BACKLOG) == -1) {
DEBUG(0,("listen: %s\n",strerror(errno)));
close(s);
return 0;
}
num_sockets++;
if (num_sockets >= FD_SETSIZE) {
DEBUG(0,("init_sockets_smbd: Too many sockets to bind to\n"));
return 0;
}
}
}
} else {
fstring tok;
const char *ptr;
num_interfaces = 1;
for (ptr=ports; next_token(&ptr, tok, " \t,", sizeof(tok)); ) {
unsigned port = atoi(tok);
if (port == 0) continue;
s = open_socket_in(SOCK_STREAM, port, 0,
interpret_addr(lp_socket_address()),True);
if (s == -1)
return 0;
set_socket_options(s,"SO_KEEPALIVE");
set_socket_options(s,user_socket_options);
set_blocking(s,False);
if (listen(s, SMBD_LISTEN_BACKLOG) == -1) {
DEBUG(0,("init_sockets_smbd: listen: %s\n",
strerror(errno)));
close(s);
return 0;
}
listenset[num_sockets] = s;
num_sockets++;
if (num_sockets >= FD_SETSIZE) {
DEBUG(0,("init_sockets_smbd: Too many sockets to bind to\n"));
return 0;
}
}
}
SAFE_FREE(ports);
return num_sockets;
}
static int init_sockets_launchd(const struct smb_launch_info *linfo,
const char * smb_ports,
int listenset[FD_SETSIZE])
{
int num_sockets;
int i;
if (!linfo->num_sockets) {
return init_sockets_smbd(smb_ports, listenset);
}
num_sockets = MIN(FD_SETSIZE, linfo->num_sockets);
memcpy(listenset, linfo->socket_list, num_sockets * sizeof(int));
for (i = 0; i < num_sockets; ++i) {
set_socket_options(listenset[i], "SO_KEEPALIVE");
set_socket_options(listenset[i], user_socket_options);
set_blocking(listenset[i], False);
}
return num_sockets;
}
int smbd_sockinit(const char *cmdline_ports, int listenset[FD_SETSIZE],
struct timeval *idle)
{
int num_sockets;
struct smb_launch_info linfo;
ZERO_STRUCTP(idle);
if (smb_launchd_checkin(&linfo)) {
num_sockets = init_sockets_launchd(&linfo,
cmdline_ports,
listenset);
idle->tv_sec = linfo.idle_timeout_secs;
smb_launchd_checkout(&linfo);
} else {
num_sockets = init_sockets_smbd(cmdline_ports,
listenset);
}
return num_sockets;
}