openldap/servers/slapd/daemon.c

1741 lines
40 KiB
C
Raw Normal View History

/* $OpenLDAP$ */
1999-08-07 07:07:46 +08:00
/*
2000-05-13 10:47:56 +08:00
* Copyright 1998-2000 The OpenLDAP Foundation, All Rights Reserved.
1999-08-07 07:07:46 +08:00
* COPYING RESTRICTIONS APPLY, see COPYRIGHT file
*/
1998-10-25 09:41:42 +08:00
#include "portable.h"
1998-08-09 08:43:13 +08:00
#include <stdio.h>
1998-10-25 09:41:42 +08:00
#include <ac/ctype.h>
#include <ac/errno.h>
#include <ac/signal.h>
#include <ac/socket.h>
#include <ac/string.h>
#include <ac/time.h>
#include <ac/unistd.h>
#include "ldap_pvt.h"
#include "lutil.h"
#include "slap.h"
1998-10-25 09:41:42 +08:00
#ifdef HAVE_TCPD
#include <tcpd.h>
int allow_severity = LOG_INFO;
int deny_severity = LOG_NOTICE;
1998-10-25 09:41:42 +08:00
#endif /* TCP Wrappers */
#ifdef LDAP_PF_LOCAL
#include <sys/stat.h>
#endif /* LDAP_PF_LOCAL */
/* globals */
time_t starttime;
ber_socket_t dtblsize;
typedef union slap_sockaddr {
struct sockaddr sa_addr;
struct sockaddr_in sa_in_addr;
#ifdef LDAP_PF_INET6
struct sockaddr_in6 sa_in6_addr;
#endif
#ifdef LDAP_PF_LOCAL
struct sockaddr_un sa_un_addr;
#endif
} Sockaddr;
typedef struct slap_listener {
char* sl_url;
char* sl_name;
1999-07-14 21:16:13 +08:00
#ifdef HAVE_TLS
int sl_is_tls;
1999-07-14 21:16:13 +08:00
#endif
ber_socket_t sl_sd;
Sockaddr sl_sa;
#define sl_addr sl_sa.sa_in_addr
} Listener;
1999-07-20 04:48:19 +08:00
Listener **slap_listeners = NULL;
1998-08-09 08:43:13 +08:00
2000-10-17 14:36:22 +08:00
#define SLAPD_LISTEN 10
static ber_socket_t wake_sds[2];
#ifdef NO_THREADS
static int waking;
#define WAKE_LISTENER(w) \
((w && !waking) ? tcp_write( wake_sds[1], "0", 1 ), waking=1 : 0)
#else
#define WAKE_LISTENER(w) \
do { if (w) tcp_write( wake_sds[1], "0", 1 ); } while(0)
#endif
#ifdef HAVE_NT_SERVICE_MANAGER
/* in nt_main.c */
extern ldap_pvt_thread_cond_t started_event;
extern int is_NT_Service;
#endif
#ifndef HAVE_WINSOCK
static
#endif
volatile sig_atomic_t slapd_shutdown = 0;
static struct slap_daemon {
ldap_pvt_thread_mutex_t sd_mutex;
int sd_nactives;
#ifndef HAVE_WINSOCK
/* In winsock, accept() returns values higher than dtblsize
so don't bother with this optimization */
int sd_nfds;
#endif
fd_set sd_actives;
fd_set sd_readers;
fd_set sd_writers;
} slap_daemon;
#ifdef HAVE_SLP
/*
* SLP related functions
*/
#include <slp.h>
#define LDAP_SRVTYPE_PREFIX "service:ldap://"
2001-05-03 03:44:21 +08:00
#define LDAPS_SRVTYPE_PREFIX "service:ldaps://"
static char** slapd_srvurls = NULL;
static SLPHandle slapd_hslp = 0;
void slapd_slp_init( const char* urls ) {
int i;
slapd_srvurls = str2charray( urls, " " );
2001-05-05 06:50:51 +08:00
if( slapd_srvurls == NULL ) return;
2001-05-03 03:44:21 +08:00
/* find and expand INADDR_ANY URLs */
for( i=0; slapd_srvurls[i] != NULL; i++ ) {
if( strcmp( slapd_srvurls[i], "ldap:///" ) == 0) {
2001-05-03 03:44:21 +08:00
char *host = ldap_pvt_get_fqdn( NULL );
if ( host != NULL ) {
slapd_srvurls[i] = (char *) realloc( slapd_srvurls[i],
strlen( host ) +
sizeof( LDAP_SRVTYPE_PREFIX ) );
strcpy( slapd_srvurls[i], LDAP_SRVTYPE_PREFIX );
strcat( slapd_srvurls[i], host );
ch_free( host );
}
} else if ( strcmp( slapd_srvurls[i], "ldaps:///" ) == 0) {
char *host = ldap_pvt_get_fqdn( NULL );
if ( host != NULL ) {
slapd_srvurls[i] = (char *) realloc( slapd_srvurls[i],
strlen( host ) +
sizeof( LDAPS_SRVTYPE_PREFIX ) );
strcpy( slapd_srvurls[i], LDAPS_SRVTYPE_PREFIX );
strcat( slapd_srvurls[i], host );
ch_free( host );
}
}
}
/* open the SLP handle */
2001-05-03 03:44:21 +08:00
SLPOpen( "en", 0, &slapd_hslp );
}
void slapd_slp_deinit() {
2001-05-05 06:50:51 +08:00
if( slapd_srvurls == NULL ) return;
2001-05-03 03:44:21 +08:00
charray_free( slapd_srvurls );
slapd_srvurls = NULL;
/* close the SLP handle */
SLPClose( slapd_hslp );
}
void slapd_slp_regreport(
SLPHandle hslp,
SLPError errcode,
void* cookie )
{
/* empty report */
}
void slapd_slp_reg() {
int i;
for( i=0; slapd_srvurls[i] != NULL; i++ ) {
2001-05-03 03:44:21 +08:00
if( strncmp( slapd_srvurls[i], LDAP_SRVTYPE_PREFIX,
sizeof( LDAP_SRVTYPE_PREFIX ) - 1 ) == 0 ||
strncmp( slapd_srvurls[i], LDAPS_SRVTYPE_PREFIX,
sizeof( LDAPS_SRVTYPE_PREFIX ) - 1 ) == 0 )
{
SLPReg( slapd_hslp,
slapd_srvurls[i],
SLP_LIFETIME_MAXIMUM,
"ldap",
"",
1,
slapd_slp_regreport,
NULL );
}
}
}
void slapd_slp_dereg() {
int i;
for( i=0; slapd_srvurls[i] != NULL; i++ ) {
SLPDereg( slapd_hslp,
slapd_srvurls[i],
slapd_slp_regreport,
NULL );
}
}
#endif /* HAVE_SLP */
/*
* Add a descriptor to daemon control
*/
static void slapd_add(ber_socket_t s) {
ldap_pvt_thread_mutex_lock( &slap_daemon.sd_mutex );
assert( !FD_ISSET( s, &slap_daemon.sd_actives ));
assert( !FD_ISSET( s, &slap_daemon.sd_readers ));
assert( !FD_ISSET( s, &slap_daemon.sd_writers ));
#ifndef HAVE_WINSOCK
if (s >= slap_daemon.sd_nfds) {
slap_daemon.sd_nfds = s + 1;
}
#endif
FD_SET( s, &slap_daemon.sd_actives );
FD_SET( s, &slap_daemon.sd_readers );
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL1,
"slapd_add: added %ld%s%s\n",
(long)s,
FD_ISSET(s, &slap_daemon.sd_readers) ? "r" : "",
FD_ISSET(s, &slap_daemon.sd_writers) ? "w" : "" ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_CONNS, "daemon: added %ld%s%s\n",
(long) s,
FD_ISSET(s, &slap_daemon.sd_readers) ? "r" : "",
FD_ISSET(s, &slap_daemon.sd_writers) ? "w" : "" );
2001-01-16 03:17:29 +08:00
#endif
ldap_pvt_thread_mutex_unlock( &slap_daemon.sd_mutex );
}
/*
* Remove the descriptor from daemon control
*/
void slapd_remove(ber_socket_t s, int wake) {
ldap_pvt_thread_mutex_lock( &slap_daemon.sd_mutex );
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL1,
"slapd_remove: removing %ld%s%s\n",
(long) s,
FD_ISSET(s, &slap_daemon.sd_readers) ? "r" : "",
FD_ISSET(s, &slap_daemon.sd_writers) ? "w" : "" ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_CONNS, "daemon: removing %ld%s%s\n",
(long) s,
FD_ISSET(s, &slap_daemon.sd_readers) ? "r" : "",
FD_ISSET(s, &slap_daemon.sd_writers) ? "w" : "" );
2001-01-16 03:17:29 +08:00
#endif
FD_CLR( s, &slap_daemon.sd_actives );
FD_CLR( s, &slap_daemon.sd_readers );
FD_CLR( s, &slap_daemon.sd_writers );
ldap_pvt_thread_mutex_unlock( &slap_daemon.sd_mutex );
WAKE_LISTENER(wake);
}
void slapd_clr_write(ber_socket_t s, int wake) {
ldap_pvt_thread_mutex_lock( &slap_daemon.sd_mutex );
assert( FD_ISSET( s, &slap_daemon.sd_actives) );
FD_CLR( s, &slap_daemon.sd_writers );
ldap_pvt_thread_mutex_unlock( &slap_daemon.sd_mutex );
WAKE_LISTENER(wake);
}
void slapd_set_write(ber_socket_t s, int wake) {
ldap_pvt_thread_mutex_lock( &slap_daemon.sd_mutex );
assert( FD_ISSET( s, &slap_daemon.sd_actives) );
if (!FD_ISSET(s, &slap_daemon.sd_writers))
FD_SET( (unsigned) s, &slap_daemon.sd_writers );
ldap_pvt_thread_mutex_unlock( &slap_daemon.sd_mutex );
WAKE_LISTENER(wake);
}
void slapd_clr_read(ber_socket_t s, int wake) {
ldap_pvt_thread_mutex_lock( &slap_daemon.sd_mutex );
assert( FD_ISSET( s, &slap_daemon.sd_actives) );
FD_CLR( s, &slap_daemon.sd_readers );
ldap_pvt_thread_mutex_unlock( &slap_daemon.sd_mutex );
WAKE_LISTENER(wake);
}
void slapd_set_read(ber_socket_t s, int wake) {
ldap_pvt_thread_mutex_lock( &slap_daemon.sd_mutex );
assert( FD_ISSET( s, &slap_daemon.sd_actives) );
if (!FD_ISSET(s, &slap_daemon.sd_readers))
FD_SET( s, &slap_daemon.sd_readers );
ldap_pvt_thread_mutex_unlock( &slap_daemon.sd_mutex );
WAKE_LISTENER(wake);
}
static void slapd_close(ber_socket_t s) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL1,
"slapd_close: closing %ld\n", (long)s ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_CONNS, "daemon: closing %ld\n",
(long) s, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
tcp_close(s);
}
2000-10-18 08:35:09 +08:00
static void slap_free_listener_addresses(struct sockaddr **sal)
{
struct sockaddr **sap;
if (sal == NULL) {
return;
}
for (sap = sal; *sap != NULL; sap++) {
ch_free(*sap);
}
ch_free(sal);
}
/* port = 0 indicates AF_LOCAL */
static int slap_get_listener_addresses(
const char *host,
unsigned short port,
struct sockaddr ***sal)
{
struct sockaddr **sap;
#ifdef LDAP_PF_LOCAL
if ( port == 0 ) {
*sal = ch_malloc(2 * sizeof(void *));
if (*sal == NULL) {
return -1;
}
sap = *sal;
*sap = ch_malloc(sizeof(struct sockaddr_un));
if (*sap == NULL)
goto errexit;
sap[1] = NULL;
if ( strlen(host) >
(sizeof(((struct sockaddr_un *)*sap)->sun_path) - 1) ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_get_listener_addresses: domain socket path (%s) too long in URL\n",
host ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"daemon: domain socket path (%s) too long in URL",
host, 0, 0);
2001-01-16 03:17:29 +08:00
#endif
goto errexit;
}
(void)memset( (void *)*sap, '\0', sizeof(struct sockaddr_un) );
(*sap)->sa_family = AF_LOCAL;
strcpy( ((struct sockaddr_un *)*sap)->sun_path, host );
} else
#endif
{
#ifdef HAVE_GETADDRINFO
struct addrinfo hints, *res, *sai;
int n, err;
char serv[7];
memset( &hints, '\0', sizeof(hints) );
hints.ai_flags = AI_PASSIVE;
hints.ai_socktype = SOCK_STREAM;
hints.ai_family = AF_UNSPEC;
snprintf(serv, sizeof serv, "%d", port);
if (err = getaddrinfo(host, serv, &hints, &res)) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_get_listener_addresses: getaddrinfo failed: %s\n",
AC_GAI_STRERROR(err) ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY, "daemon: getaddrinfo failed: %s\n",
2000-11-24 13:30:52 +08:00
AC_GAI_STRERROR(err), 0, 0);
2001-01-16 03:17:29 +08:00
#endif
return -1;
}
sai = res;
for (n=2; (sai = sai->ai_next) != NULL; n++) {
/* EMPTY */ ;
}
*sal = ch_malloc(n * sizeof(void *));
if (*sal == NULL) {
return -1;
}
sai = res;
sap = *sal;
do {
switch (sai->ai_family) {
# ifdef LDAP_PF_INET6
case AF_INET6:
*sap = ch_malloc(sizeof(struct sockaddr_in6));
if (*sap == NULL) {
freeaddrinfo(res);
goto errexit;
}
*(struct sockaddr_in6 *)*sap =
*((struct sockaddr_in6 *)sai->ai_addr);
break;
# endif
case AF_INET:
*sap = ch_malloc(sizeof(struct sockaddr_in));
if (*sap == NULL) {
freeaddrinfo(res);
goto errexit;
}
*(struct sockaddr_in *)*sap =
*((struct sockaddr_in *)sai->ai_addr);
break;
default:
*sap = NULL;
break;
}
if (*sap != NULL) {
(*sap)->sa_family = sai->ai_family;
sap++;
}
} while ((sai = sai->ai_next) != NULL);
*sap = NULL;
freeaddrinfo(res);
#else
struct in_addr in;
if ( host == NULL ) {
in.s_addr = htonl(INADDR_ANY);
} else if ( !inet_aton( host, &in ) ) {
struct hostent *he = gethostbyname( host );
if( he == NULL ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_get_listener_addresses: invalid host %s\n",
host ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"daemon: invalid host %s", host, 0, 0);
2001-01-16 03:17:29 +08:00
#endif
return -1;
}
AC_MEMCPY( &in, he->h_addr, sizeof( in ) );
}
*sal = ch_malloc(2 * sizeof(void *));
if (*sal == NULL) {
return -1;
}
sap = *sal;
*sap = ch_malloc(sizeof(struct sockaddr_in));
if (*sap == NULL) {
goto errexit;
}
sap[1] = NULL;
(void)memset( (void *)*sap, '\0', sizeof(struct sockaddr_in) );
(*sap)->sa_family = AF_INET;
((struct sockaddr_in *)*sap)->sin_port = htons(port);
((struct sockaddr_in *)*sap)->sin_addr = in;
#endif
}
return 0;
errexit:
slap_free_listener_addresses(*sal);
return -1;
}
static Listener * slap_open_listener(
const char* url )
{
int tmp, rc;
Listener l;
Listener *li;
LDAPURLDesc *lud;
unsigned short port;
int err, addrlen;
struct sockaddr **sal, **psal;
rc = ldap_url_parse( url, &lud );
if( rc != LDAP_URL_SUCCESS ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slap_open_listener: listen URL \"%s\" parse error %d\n",
url, rc ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"daemon: listen URL \"%s\" parse error=%d\n",
url, rc, 0 );
2001-01-16 03:17:29 +08:00
#endif
return NULL;
}
#ifndef HAVE_TLS
if( ldap_pvt_url_scheme2tls( lud->lud_scheme ) ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_open_listener: TLS is not supported (%s)\n",
url ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"daemon: TLS not supported (%s)\n",
url, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
ldap_free_urldesc( lud );
return NULL;
}
if(! lud->lud_port ) {
lud->lud_port = LDAP_PORT;
}
#else
l.sl_is_tls = ldap_pvt_url_scheme2tls( lud->lud_scheme );
1999-07-20 04:48:19 +08:00
if(! lud->lud_port ) {
lud->lud_port = l.sl_is_tls ? LDAPS_PORT : LDAP_PORT;
}
#endif
port = (unsigned short) lud->lud_port;
if ( ldap_pvt_url_scheme2proto(lud->lud_scheme) == LDAP_PROTO_IPC ) {
#ifdef LDAP_PF_LOCAL
if ( lud->lud_host == NULL || lud->lud_host[0] == '\0' ) {
err = slap_get_listener_addresses(LDAPI_SOCK, 0, &sal);
} else {
err = slap_get_listener_addresses(lud->lud_host, 0, &sal);
}
#else
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_open_listener: URL scheme is not supported: %s\n",
url ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY, "daemon: URL scheme not supported: %s",
url, 0, 0);
2001-01-16 03:17:29 +08:00
#endif
ldap_free_urldesc( lud );
return NULL;
#endif
} else {
if( lud->lud_host == NULL || lud->lud_host[0] == '\0'
|| strcmp(lud->lud_host, "*") == 0 )
{
err = slap_get_listener_addresses(NULL, port, &sal);
} else {
err = slap_get_listener_addresses(lud->lud_host, port, &sal);
}
}
ldap_free_urldesc( lud );
if ( err ) {
return NULL;
}
psal = sal;
while ( *sal != NULL ) {
switch( (*sal)->sa_family ) {
case AF_INET:
#ifdef LDAP_PF_INET6
case AF_INET6:
#endif
#ifdef LDAP_PF_LOCAL
case AF_LOCAL:
#endif
break;
default:
sal++;
continue;
}
l.sl_sd = socket( (*sal)->sa_family, SOCK_STREAM, 0);
if ( l.sl_sd == AC_SOCKET_INVALID ) {
2000-06-26 13:23:33 +08:00
int err = sock_errno();
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slap_open_listener: socket() failed errno=%d (%s)\n",
err, sock_errstr(err) ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"daemon: socket() failed errno=%d (%s)\n", err,
sock_errstr(err), 0 );
2001-01-16 03:17:29 +08:00
#endif
sal++;
continue;
}
#ifndef HAVE_WINSOCK
if ( l.sl_sd >= dtblsize ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slap_open_listener: listener descriptor %ld is too great %ld\n",
(long)l.sl_sd, (long)dtblsize ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"daemon: listener descriptor %ld is too great %ld\n",
(long) l.sl_sd, (long) dtblsize, 0 );
2001-01-16 03:17:29 +08:00
#endif
tcp_close( l.sl_sd );
sal++;
continue;
}
#endif
#ifdef LDAP_PF_LOCAL
if ( (*sal)->sa_family == AF_LOCAL ) {
unlink ( ((struct sockaddr_un *)*sal)->sun_path );
} else
#endif
{
#ifdef SO_REUSEADDR
/* enable address reuse */
tmp = 1;
rc = setsockopt( l.sl_sd, SOL_SOCKET, SO_REUSEADDR,
(char *) &tmp, sizeof(tmp) );
if ( rc == AC_SOCKET_ERROR ) {
int err = sock_errno();
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_open_listener: setsockopt( %ld, SO_REUSEADDR ) failed errno %d (%s)\n",
(long)l.sl_sd, err, sock_errstr(err) ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"slapd(%ld): setsockopt(SO_REUSEADDR) failed errno=%d (%s)\n",
(long) l.sl_sd, err, sock_errstr(err) );
2001-01-16 03:17:29 +08:00
#endif
}
#endif
}
switch( (*sal)->sa_family ) {
case AF_INET:
addrlen = sizeof(struct sockaddr_in);
break;
#ifdef LDAP_PF_INET6
case AF_INET6:
addrlen = sizeof(struct sockaddr_in6);
break;
#endif
#ifdef LDAP_PF_LOCAL
case AF_LOCAL:
addrlen = sizeof(struct sockaddr_un);
break;
#endif
}
if (!bind(l.sl_sd, *sal, addrlen))
break;
err = sock_errno();
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_open_listener: bind(%ld) failed errno=%d (%s)\n",
(long)l.sl_sd, err, sock_errstr(err) ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY, "daemon: bind(%ld) failed errno=%d (%s)\n",
(long) l.sl_sd, err, sock_errstr(err) );
2001-01-16 03:17:29 +08:00
#endif
tcp_close( l.sl_sd );
sal++;
} /* while ( *sal != NULL ) */
if ( *sal == NULL ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_open_listener: bind(%ld) failed.\n", (long)l.sl_sd ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY, "daemon: bind(%ld) failed\n",
(long) l.sl_sd, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
slap_free_listener_addresses(psal);
return NULL;
}
switch ( (*sal)->sa_family ) {
#ifdef LDAP_PF_LOCAL
case AF_LOCAL: {
char *addr = ((struct sockaddr_un *)*sal)->sun_path;
if ( chmod( addr, S_IRWXU ) < 0 ) {
2000-06-26 13:23:33 +08:00
int err = sock_errno();
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_open_listener: fchmod(%ld) failed errno=%d (%s)\n",
(long)l.sl_sd, err, sock_errstr(err) ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY, "daemon: fchmod(%ld) failed errno=%d (%s)",
(long) l.sl_sd, err, sock_errstr(err) );
2001-01-16 03:17:29 +08:00
#endif
tcp_close( l.sl_sd );
slap_free_listener_addresses(psal);
return NULL;
}
l.sl_name = ch_malloc( strlen(addr) + sizeof("PATH=") );
sprintf( l.sl_name, "PATH=%s", addr );
} break;
#endif /* LDAP_PF_LOCAL */
case AF_INET: {
char *s;
2001-05-10 07:41:16 +08:00
#if defined( HAVE_GETADDRINFO ) && defined( HAVE_INET_NTOP )
char addr[INET_ADDRSTRLEN];
inet_ntop( AF_INET, &((struct sockaddr_in *)*sal)->sin_addr,
addr, sizeof(addr) );
s = addr;
2001-01-24 08:08:15 +08:00
port = ((struct sockaddr_in *)*sal) ->sin_port;
#else
s = inet_ntoa( l.sl_addr.sin_addr );
2001-01-24 08:08:15 +08:00
port = l.sl_addr.sin_port;
#endif
l.sl_name = ch_malloc( sizeof("IP=255.255.255.255:65535") );
sprintf( l.sl_name, "IP=%s:%d",
s != NULL ? s : "unknown" , port );
} break;
#ifdef LDAP_PF_INET6
case AF_INET6: {
char addr[INET6_ADDRSTRLEN];
inet_ntop( AF_INET6, &((struct sockaddr_in6 *)*sal)->sin6_addr,
addr, sizeof addr);
2001-01-24 08:08:15 +08:00
port = ((struct sockaddr_in6 *)*sal)->sin6_port;
l.sl_name = ch_malloc( strlen(addr) + sizeof("IP= 65535") );
sprintf( l.sl_name, "IP=%s %d", addr, port );
} break;
#endif /* LDAP_PF_INET6 */
default:
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_open_listener: unsupported address family (%d)\n",
(int)(*sal)->sa_family ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY, "daemon: unsupported address family (%d)\n",
(int) (*sal)->sa_family, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
break;
}
slap_free_listener_addresses(psal);
l.sl_url = ch_strdup( url );
li = ch_malloc( sizeof( Listener ) );
*li = l;
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_RESULTS,
"slap_open_listener: daemon initialzed %s\n", l.sl_url ));
2001-01-16 03:17:29 +08:00
#else
1999-07-20 04:48:19 +08:00
Debug( LDAP_DEBUG_TRACE, "daemon: initialized %s\n",
l.sl_url, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
return li;
}
static int sockinit(void);
static int sockdestroy(void);
int slapd_daemon_init( const char *urls )
1998-08-09 08:43:13 +08:00
{
int i, rc;
char **u;
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ARGS,
"slapd_daemon_init: %s\n",
urls ? urls : "<null>" ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ARGS, "daemon_init: %s\n",
urls ? urls : "<null>", 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
1999-09-06 12:42:20 +08:00
if( (rc = sockinit()) != 0 ) {
return rc;
}
1998-08-09 08:43:13 +08:00
1998-10-25 09:41:42 +08:00
#ifdef HAVE_SYSCONF
1998-08-18 07:26:25 +08:00
dtblsize = sysconf( _SC_OPEN_MAX );
1998-10-25 09:41:42 +08:00
#elif HAVE_GETDTABLESIZE
1998-08-18 07:26:25 +08:00
dtblsize = getdtablesize();
1998-10-25 09:41:42 +08:00
#else
1999-04-02 00:32:11 +08:00
dtblsize = FD_SETSIZE;
1998-10-25 09:41:42 +08:00
#endif
1998-08-18 07:26:25 +08:00
#ifdef FD_SETSIZE
1998-08-09 09:05:15 +08:00
if(dtblsize > FD_SETSIZE) {
dtblsize = FD_SETSIZE;
}
#endif /* !FD_SETSIZE */
1998-08-18 07:26:25 +08:00
/* open a pipe (or something equivalent connected to itself).
* we write a byte on this fd whenever we catch a signal. The main
* loop will be select'ing on this socket, and will wake up when
* this byte arrives.
*/
if( (rc = lutil_pair( wake_sds )) < 0 ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slap_daemon_init: lutil_pair() failed rc=%d\n", rc ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"daemon: lutil_pair() failed rc=%d\n", rc, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
return rc;
}
FD_ZERO( &slap_daemon.sd_readers );
FD_ZERO( &slap_daemon.sd_writers );
1998-08-09 08:43:13 +08:00
if( urls == NULL ) {
1999-07-20 04:48:19 +08:00
urls = "ldap:///";
}
1998-08-09 08:43:13 +08:00
u = str2charray( urls, " " );
1998-08-09 08:43:13 +08:00
1999-07-20 04:48:19 +08:00
if( u == NULL || u[0] == NULL ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slap_daemon_init: no urls (%s) provided.\n", urls ));
2001-01-16 03:17:29 +08:00
#else
1999-07-20 04:48:19 +08:00
Debug( LDAP_DEBUG_ANY, "daemon_init: no urls (%s) provided.\n",
urls, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
return -1;
}
1999-07-20 04:48:19 +08:00
for( i=0; u[i] != NULL; i++ ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL1,
"slap_daemon_init: listen on %s\n.", u[i] ));
2001-01-16 03:17:29 +08:00
#else
1999-07-20 04:48:19 +08:00
Debug( LDAP_DEBUG_TRACE, "daemon_init: listen on %s\n",
u[i], 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
}
1999-07-20 04:48:19 +08:00
if( i == 0 ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_daemon_init: no listeners to open (%s)\n", urls ));
2001-01-16 03:17:29 +08:00
#else
1999-07-20 04:48:19 +08:00
Debug( LDAP_DEBUG_ANY, "daemon_init: no listeners to open (%s)\n",
urls, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
1999-08-19 19:44:44 +08:00
charray_free( u );
1999-07-20 04:48:19 +08:00
return -1;
}
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slap_daemon_init: %d listeners to open...\n", i ));
2001-01-16 03:17:29 +08:00
#else
1999-07-20 04:48:19 +08:00
Debug( LDAP_DEBUG_TRACE, "daemon_init: %d listeners to open...\n",
i, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
slap_listeners = ch_malloc( (i+1)*sizeof(Listener *) );
1999-07-20 04:48:19 +08:00
for(i = 0; u[i] != NULL; i++ ) {
slap_listeners[i] = slap_open_listener( u[i] );
if( slap_listeners[i] == NULL ) {
1999-08-19 19:44:44 +08:00
charray_free( u );
return -1;
}
}
slap_listeners[i] = NULL;
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL1,
"slap_daemon_init: %d listeners opened\n", i ));
2001-01-16 03:17:29 +08:00
#else
1999-08-19 08:40:18 +08:00
Debug( LDAP_DEBUG_TRACE, "daemon_init: %d listeners opened\n",
1999-07-20 04:48:19 +08:00
i, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
#ifdef HAVE_SLP
slapd_slp_init( urls );
slapd_slp_reg();
#endif
charray_free( u );
ldap_pvt_thread_mutex_init( &slap_daemon.sd_mutex );
1999-07-20 04:48:19 +08:00
return !i;
}
int
slapd_daemon_destroy(void)
{
connections_destroy();
tcp_close( wake_sds[1] );
tcp_close( wake_sds[0] );
sockdestroy();
#ifdef HAVE_SLP
slapd_slp_dereg();
slapd_slp_deinit();
#endif
return 0;
}
static void *
slapd_daemon_task(
void *ptr
)
{
1999-07-14 21:16:13 +08:00
int l;
1999-09-01 14:37:46 +08:00
time_t last_idle_check = slap_get_time();
time( &starttime );
for ( l = 0; slap_listeners[l] != NULL; l++ ) {
if ( slap_listeners[l]->sl_sd == AC_SOCKET_INVALID )
continue;
2000-10-17 14:36:22 +08:00
if ( listen( slap_listeners[l]->sl_sd, SLAPD_LISTEN ) == -1 ) {
int err = sock_errno();
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slapd_daemon_task: listen( %s, 5 ) failed errno=%d (%s)\n",
slap_listeners[l]->sl_url, err, sock_errstr(err) ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
1999-08-19 08:40:18 +08:00
"daemon: listen(%s, 5) failed errno=%d (%s)\n",
slap_listeners[l]->sl_url, err,
sock_errstr(err) );
2001-01-16 03:17:29 +08:00
#endif
return( (void*)-1 );
1998-08-09 08:43:13 +08:00
}
slapd_add( slap_listeners[l]->sl_sd );
1998-08-09 08:43:13 +08:00
}
#ifdef HAVE_NT_SERVICE_MANAGER
if ( started_event != NULL ) {
ldap_pvt_thread_cond_signal( &started_event );
}
#endif
/* initialization complete. Here comes the loop. */
1998-08-09 08:43:13 +08:00
while ( !slapd_shutdown ) {
ber_socket_t i;
int ns;
int at;
ber_socket_t nfds;
#define SLAPD_EBADF_LIMIT 16
int ebadf = 0;
#define SLAPD_IDLE_CHECK_LIMIT 4
1999-09-01 14:37:46 +08:00
time_t now = slap_get_time();
fd_set readfds;
fd_set writefds;
Sockaddr from;
#if defined(SLAPD_RLOOKUPS)
2001-01-18 00:35:53 +08:00
struct hostent *hp;
#endif
struct timeval zero;
1998-08-09 08:43:13 +08:00
struct timeval *tvp;
if( global_idletimeout > 0 && difftime(
last_idle_check+global_idletimeout/SLAPD_IDLE_CHECK_LIMIT,
now ) < 0 )
{
connections_timeout_idle(now);
}
1998-08-09 08:43:13 +08:00
FD_ZERO( &writefds );
FD_ZERO( &readfds );
zero.tv_sec = 0;
zero.tv_usec = 0;
ldap_pvt_thread_mutex_lock( &slap_daemon.sd_mutex );
#ifdef FD_SET_MANUAL_COPY
for( s = 0; s < nfds; s++ ) {
if(FD_ISSET( &slap_sd_readers, s )) {
FD_SET( s, &readfds );
}
if(FD_ISSET( &slap_sd_writers, s )) {
FD_SET( s, &writefds );
1998-08-09 08:43:13 +08:00
}
}
#else
AC_MEMCPY( &readfds, &slap_daemon.sd_readers, sizeof(fd_set) );
AC_MEMCPY( &writefds, &slap_daemon.sd_writers, sizeof(fd_set) );
#endif
assert(!FD_ISSET(wake_sds[0], &readfds));
FD_SET( wake_sds[0], &readfds );
for ( l = 0; slap_listeners[l] != NULL; l++ ) {
if ( slap_listeners[l]->sl_sd == AC_SOCKET_INVALID )
continue;
if (!FD_ISSET(slap_listeners[l]->sl_sd, &readfds))
FD_SET( slap_listeners[l]->sl_sd, &readfds );
1999-07-14 21:16:13 +08:00
}
#ifndef HAVE_WINSOCK
nfds = slap_daemon.sd_nfds;
#else
nfds = dtblsize;
#endif
ldap_pvt_thread_mutex_unlock( &slap_daemon.sd_mutex );
1998-08-09 08:43:13 +08:00
at = ldap_pvt_thread_pool_backload(&connection_pool);
#if defined( HAVE_YIELDING_SELECT ) || defined( NO_THREADS )
tvp = NULL;
1998-08-09 08:43:13 +08:00
#else
tvp = at ? &zero : NULL;
1998-08-09 08:43:13 +08:00
#endif
for ( l = 0; slap_listeners[l] != NULL; l++ ) {
if ( slap_listeners[l]->sl_sd == AC_SOCKET_INVALID )
continue;
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL1,
"slapd_daemon_task: select: listen=%d active_threads=%d tvp=%s\n",
slap_listeners[l]->sl_sd, at, tvp == NULL ? "NULL" : "zero" ));
2001-01-16 03:17:29 +08:00
#else
1999-07-14 21:16:13 +08:00
Debug( LDAP_DEBUG_CONNS,
"daemon: select: listen=%d active_threads=%d tvp=%s\n",
slap_listeners[l]->sl_sd, at,
tvp == NULL ? "NULL" : "zero" );
2001-01-16 03:17:29 +08:00
#endif
1999-07-14 21:16:13 +08:00
}
1998-08-09 08:43:13 +08:00
switch(ns = select( nfds, &readfds,
#ifdef HAVE_WINSOCK
/* don't pass empty fd_set */
( writefds.fd_count > 0 ? &writefds : NULL ),
#else
&writefds,
#endif
NULL, tvp ))
{
case -1: { /* failure - try again */
int err = sock_errno();
if( err == EBADF
#ifdef WSAENOTSOCK
/* you'd think this would be EBADF */
|| err == WSAENOTSOCK
#endif
) {
if (++ebadf < SLAPD_EBADF_LIMIT)
continue;
1999-06-11 05:11:21 +08:00
}
if( err != EINTR ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slapd_daemon_task: select failed (%d): %s\n",
err, sock_errstr(err) ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_CONNS,
"daemon: select failed (%d): %s\n",
err, sock_errstr(err), 0 );
2001-01-16 03:17:29 +08:00
#endif
slapd_shutdown = -1;
}
}
1998-08-09 08:43:13 +08:00
continue;
case 0: /* timeout - let threads run */
1999-06-11 05:11:21 +08:00
ebadf = 0;
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL2,
"slapd_daemon_task: select timeout - yielding\n" ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_CONNS, "daemon: select timeout - yielding\n",
1998-08-09 08:43:13 +08:00
0, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
ldap_pvt_thread_yield();
1998-08-09 08:43:13 +08:00
continue;
default: /* something happened - deal with it */
if( slapd_shutdown ) continue;
1999-06-11 05:11:21 +08:00
ebadf = 0;
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL2,
"slapd_daemon_task: activity on %d descriptors\n", ns ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_CONNS, "daemon: activity on %d descriptors\n",
ns, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
/* FALL THRU */
1998-08-09 08:43:13 +08:00
}
if( FD_ISSET( wake_sds[0], &readfds ) ) {
char c[BUFSIZ];
tcp_read( wake_sds[0], c, sizeof(c) );
#ifdef NO_THREADS
waking = 0;
#endif
continue;
}
for ( l = 0; slap_listeners[l] != NULL; l++ ) {
2000-10-18 08:35:09 +08:00
ber_socket_t s;
socklen_t len = sizeof(from);
long id;
2000-08-26 09:14:05 +08:00
slap_ssf_t ssf = 0;
char *authid = NULL;
char *dnsname;
char *peeraddr;
#ifdef LDAP_PF_LOCAL
char peername[MAXPATHLEN + sizeof("PATH=")];
#elif defined(LDAP_PF_INET6)
char peername[sizeof("IP=ffff:ffff:ffff:ffff:ffff:ffff:ffff:ffff 65535")];
2000-06-09 07:12:52 +08:00
#else
1999-07-23 04:37:56 +08:00
char peername[sizeof("IP=255.255.255.255:65336")];
#endif /* LDAP_PF_LOCAL */
2000-06-09 07:12:52 +08:00
peername[0] = '\0';
if ( slap_listeners[l]->sl_sd == AC_SOCKET_INVALID )
continue;
if ( !FD_ISSET( slap_listeners[l]->sl_sd, &readfds ) )
1999-07-14 21:16:13 +08:00
continue;
s = accept( slap_listeners[l]->sl_sd,
(struct sockaddr *) &from, &len );
if ( s == AC_SOCKET_INVALID ) {
int err = sock_errno();
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slapd_daemon_task: accept(%ld) failed errno=%d (%s)\n",
(long)slap_listeners[l]->sl_sd, err, sock_errstr(err) ));
2001-01-16 03:17:29 +08:00
#else
1998-08-09 08:43:13 +08:00
Debug( LDAP_DEBUG_ANY,
"daemon: accept(%ld) failed errno=%d (%s)\n",
(long) slap_listeners[l]->sl_sd, err,
sock_errstr(err) );
2001-01-16 03:17:29 +08:00
#endif
ldap_pvt_thread_yield();
1998-08-09 08:43:13 +08:00
continue;
}
#ifndef HAVE_WINSOCK
/* make sure descriptor number isn't too great */
if ( s >= dtblsize ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slapd_daemon_task: %ld beyond descriptor table size %ld\n",
(long)s, (long)dtblsize ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"daemon: %ld beyond descriptor table size %ld\n",
(long) s, (long) dtblsize, 0 );
2001-01-16 03:17:29 +08:00
#endif
slapd_close(s);
ldap_pvt_thread_yield();
continue;
}
#endif
#ifdef LDAP_DEBUG
ldap_pvt_thread_mutex_lock( &slap_daemon.sd_mutex );
/* newly accepted stream should not be in any of the FD SETS */
assert( !FD_ISSET( s, &slap_daemon.sd_actives) );
assert( !FD_ISSET( s, &slap_daemon.sd_readers) );
assert( !FD_ISSET( s, &slap_daemon.sd_writers) );
ldap_pvt_thread_mutex_unlock( &slap_daemon.sd_mutex );
#endif
#if defined( SO_KEEPALIVE ) || defined( TCP_NODELAY )
#ifdef LDAP_PF_LOCAL
/* for IPv4 and IPv6 sockets only */
if ( from.sa_addr.sa_family != AF_LOCAL )
#endif /* LDAP_PF_LOCAL */
{
int rc;
int tmp;
#ifdef SO_KEEPALIVE
/* enable keep alives */
tmp = 1;
rc = setsockopt( s, SOL_SOCKET, SO_KEEPALIVE,
(char *) &tmp, sizeof(tmp) );
if ( rc == AC_SOCKET_ERROR ) {
int err = sock_errno();
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slapd_daemon_task: setsockopt( %ld, SO_KEEPALIVE) failed errno=%d (%s)\n",
(long)s, err, sock_errstr(err) ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"slapd(%ld): setsockopt(SO_KEEPALIVE) failed "
"errno=%d (%s)\n", (long) s, err, sock_errstr(err) );
2001-01-16 03:17:29 +08:00
#endif
}
#endif
#ifdef TCP_NODELAY
/* enable no delay */
tmp = 1;
rc = setsockopt( s, IPPROTO_TCP, TCP_NODELAY,
(char *)&tmp, sizeof(tmp) );
if ( rc == AC_SOCKET_ERROR ) {
int err = sock_errno();
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slapd_daemon_task: setsockopt( %ld, TCP_NODELAY) failed errno=%d (%s)\n",
(long)s, err, sock_errstr(err) ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"slapd(%ld): setsockopt(TCP_NODELAY) failed "
"errno=%d (%s)\n", (long) s, err, sock_errstr(err) );
2001-01-16 03:17:29 +08:00
#endif
}
#endif
}
#endif
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL1,
"slapd_daemon_task: new connection on %ld\n", (long)s ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_CONNS, "daemon: new connection on %ld\n",
(long) s, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
switch ( from.sa_addr.sa_family ) {
# ifdef LDAP_PF_LOCAL
case AF_LOCAL:
sprintf( peername, "PATH=%s", from.sa_un_addr.sun_path );
ssf = LDAP_PVT_SASL_LOCAL_SSF;
break;
#endif /* LDAP_PF_LOCAL */
# ifdef LDAP_PF_INET6
case AF_INET6:
if ( IN6_IS_ADDR_V4MAPPED(&from.sa_in6_addr.sin6_addr) ) {
peeraddr = inet_ntoa( *((struct in_addr *)
&from.sa_in6_addr.sin6_addr.s6_addr[12]) );
sprintf( peername, "IP=%s:%d",
peeraddr != NULL ? peeraddr : "unknown",
(unsigned) ntohs( from.sa_in6_addr.sin6_port ) );
} else {
char addr[INET6_ADDRSTRLEN];
sprintf( peername, "IP=%s %d",
inet_ntop( AF_INET6,
&from.sa_in6_addr.sin6_addr,
addr, sizeof addr) ? addr : "unknown",
(unsigned) ntohs( from.sa_in6_addr.sin6_port ) );
}
break;
# endif /* LDAP_PF_INET6 */
case AF_INET:
peeraddr = inet_ntoa( from.sa_in_addr.sin_addr );
1999-07-23 04:37:56 +08:00
sprintf( peername, "IP=%s:%d",
peeraddr != NULL ? peeraddr : "unknown",
(unsigned) ntohs( from.sa_in_addr.sin_port ) );
break;
1998-08-09 08:43:13 +08:00
default:
slapd_close(s);
continue;
}
if ( ( from.sa_addr.sa_family == AF_INET )
#ifdef LDAP_PF_INET6
|| ( from.sa_addr.sa_family == AF_INET6 )
#endif
) {
#ifdef SLAPD_RLOOKUPS
# ifdef LDAP_PF_INET6
if ( from.sa_addr.sa_family == AF_INET6 )
hp = gethostbyaddr(
(char *)&(from.sa_in6_addr.sin6_addr),
sizeof(from.sa_in6_addr.sin6_addr),
AF_INET6 );
else
2000-10-17 04:04:42 +08:00
# endif /* LDAP_PF_INET6 */
hp = gethostbyaddr(
(char *) &(from.sa_in_addr.sin_addr),
sizeof(from.sa_in_addr.sin_addr),
AF_INET );
dnsname = hp ? ldap_pvt_str2lower( hp->h_name ) : NULL;
#else
dnsname = NULL;
#endif /* SLAPD_RLOOKUPS */
1998-10-25 09:41:42 +08:00
#ifdef HAVE_TCPD
if ( !hosts_ctl("slapd",
dnsname != NULL ? dnsname : STRING_UNKNOWN,
peeraddr != NULL ? peeraddr : STRING_UNKNOWN,
STRING_UNKNOWN ))
{
/* DENY ACCESS */
Statslog( LDAP_DEBUG_ANY,
"fd=%ld host access from %s (%s) denied.\n",
(long) s,
dnsname != NULL ? dnsname : "unknown",
peeraddr != NULL ? peeraddr : "unknown",
0, 0 );
slapd_close(s);
continue;
}
1998-10-25 09:41:42 +08:00
#endif /* HAVE_TCPD */
}
id = connection_init(s,
slap_listeners[l]->sl_url,
1999-07-28 02:49:32 +08:00
dnsname != NULL ? dnsname : "unknown",
peername,
slap_listeners[l]->sl_name,
#ifdef HAVE_TLS
slap_listeners[l]->sl_is_tls,
#else
0,
#endif
ssf,
authid );
if( authid ) ch_free(authid);
if( id < 0 ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_INFO,
"slapd_daemon_task: connection_init(%ld, %s, %s) failed.\n",
(long)s, peername, slap_listeners[l]->sl_name ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
"daemon: connection_init(%ld, %s, %s) failed.\n",
(long) s,
peername,
slap_listeners[l]->sl_name );
2001-01-16 03:17:29 +08:00
#endif
slapd_close(s);
continue;
}
Statslog( LDAP_DEBUG_STATS,
"daemon: conn=%ld fd=%ld connection from %s (%s) accepted.\n",
id, (long) s,
peername,
slap_listeners[l]->sl_name,
0 );
slapd_add( s );
continue;
1998-08-09 08:43:13 +08:00
}
#ifdef LDAP_DEBUG
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL2,
"slapd_daemon_task: activity on " ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_CONNS, "daemon: activity on:", 0, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
1999-04-02 00:32:11 +08:00
#ifdef HAVE_WINSOCK
for ( i = 0; i < readfds.fd_count; i++ ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL2,
2001-02-02 22:49:35 +08:00
" %d%s", readfds.fd_array[i], "r", 0 ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_CONNS, " %d%s",
readfds.fd_array[i], "r", 0 );
2001-01-16 03:17:29 +08:00
#endif
1999-04-02 00:32:11 +08:00
}
for ( i = 0; i < writefds.fd_count; i++ ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL2,
" %d%s", writefds.fd_array[i], "w" ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_CONNS, " %d%s",
writefds.fd_array[i], "w", 0 );
2001-01-16 03:17:29 +08:00
#endif
1999-04-02 00:32:11 +08:00
}
2001-01-16 03:17:29 +08:00
1999-04-02 00:32:11 +08:00
#else
for ( i = 0; i < nfds; i++ ) {
int r, w;
1999-07-14 21:16:13 +08:00
int is_listener = 0;
1998-08-09 08:43:13 +08:00
for ( l = 0; slap_listeners[l] != NULL; l++ ) {
if ( i == slap_listeners[l]->sl_sd ) {
1999-07-14 21:16:13 +08:00
is_listener = 1;
break;
}
}
if ( is_listener ) {
continue;
}
1998-08-09 08:43:13 +08:00
r = FD_ISSET( i, &readfds );
w = FD_ISSET( i, &writefds );
1999-07-14 21:16:13 +08:00
if ( r || w ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL2,
" %d%s%s", i,
r ? "r" : "", w ? "w" : "" ));
2001-01-16 03:17:29 +08:00
#else
1998-08-09 08:43:13 +08:00
Debug( LDAP_DEBUG_CONNS, " %d%s%s", i,
r ? "r" : "", w ? "w" : "" );
2001-01-16 03:17:29 +08:00
#endif
1998-08-09 08:43:13 +08:00
}
}
1999-04-02 00:32:11 +08:00
#endif
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL2, "\n" ));
2001-01-16 03:17:29 +08:00
#else
1998-08-09 08:43:13 +08:00
Debug( LDAP_DEBUG_CONNS, "\n", 0, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
#endif
1998-08-09 08:43:13 +08:00
/* loop through the writers */
1999-04-02 00:32:11 +08:00
#ifdef HAVE_WINSOCK
for ( i = 0; i < writefds.fd_count; i++ )
#else
for ( i = 0; i < nfds; i++ )
#endif
{
ber_socket_t wd;
1999-07-14 21:16:13 +08:00
int is_listener = 0;
#ifdef HAVE_WINSOCK
wd = writefds.fd_array[i];
#else
if( ! FD_ISSET( i, &writefds ) ) {
continue;
}
wd = i;
#endif
for ( l = 0; slap_listeners[l] != NULL; l++ ) {
if ( i == slap_listeners[l]->sl_sd ) {
1999-07-14 21:16:13 +08:00
is_listener = 1;
break;
}
}
if ( is_listener ) {
1999-04-02 00:32:11 +08:00
continue;
}
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL2,
"slapd_daemon_task: write active on %d\n", wd ));
2001-01-16 03:17:29 +08:00
#else
1999-04-02 00:32:11 +08:00
Debug( LDAP_DEBUG_CONNS,
"daemon: write active on %d\n",
wd, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
/*
* NOTE: it is possible that the connection was closed
* and that the stream is now inactive.
* connection_write() must valid the stream is still
* active.
*/
if ( connection_write( wd ) < 0 ) {
Vienna Bulk Commit This commit includes many changes. All changes compile under NT but have not been tested under UNIX. A Summary of changes (likely incomplete): NT changes: Removed lint. Clean up configuration support for "Debug", "Release", "SDebug", and "SRelease" configurations. Share output directories for clients, libraries, and slapd. (maybe they should be combined further and moved to build/{,S}{Debug,Release}). Enable threading when _MT is defined. Enable debuging when _DEBUG is defined. Disable setting of NDEBUG under Release/SRelease. Asserts are disabled in <ac/assert.h> when LDAP_DEBUG is not defined. Added 'build/main.dsp' Master project. Removed non-slapd projects from slapd.dsp (see main.dsp). Removed replaced many uses of _WIN32 macro with feature based macros. ldap_cdefs.h changes #define LDAP_CONST const (see below) #define LDAP_F(type) LDAP_F_PRE type LDAP_F_POST To allow specifiers to be added before and after the type declaration. (For DLL handling) LBER/LDAP changes Namespace changes: s/lber_/ber_/ for here and there. s/NAME_ERROR/LDAP_NAME_ERROR/g Deleted NULLMSG and other NULL* macros for namespace reasons. "const" libraries. Installed headers (ie: lber.h, ldap.h) use LDAP_CONST macro. Normally set to 'const' when __STDC__. Can be set externally to enable/disable 'constification' of external interface. Internal interface always uses 'const'. Did not fix warnings in -lldif (in lieu of new LDIF parser). Added _ext API implementations (excepting search and bind). Need to implement ldap_int_get_controls() for reponses with controls. Added numberous assert() checks. LDAP_R _MT defines HAVE_NT_THREADS Added numberous assert() checks. Changed ldap_pthread_t back to unsigned long. Used cast to HANDLE in _join(). LDBM Replaced _WIN32 with HAVE_SYSLOG ud Added version string if MKVERSION is not defined. (MKVERSION needs to be set under UNIX). slapd Made connection sockbuf field a pointer to a sockbuf. This removed slap.h dependency on lber-int.h. lber-int.h now only included by those files needing to mess with the sockbuf. Used ber_* functions/macros to access sockbuf internals whenever possible. Added version string if MKVERSION is not defined. (MKVERSION needs to be set under UNIX). Removed FD_SET unsigned lint slapd/tools Used EXEEXT to added ".exe" to routines. Need to define EXEEXT under UNIX. ldappasswd Added ldappasswd.dsp. Ported to NT. Used getpid() to seed rand(). nt_debug Minor cleanup. Added "portable.h" include and used <ac/*.h> where appropriate. Added const to char* format argument.
1999-05-19 09:12:33 +08:00
FD_CLR( (unsigned) wd, &readfds );
slapd_close( wd );
1999-04-02 00:32:11 +08:00
}
}
#ifdef HAVE_WINSOCK
for ( i = 0; i < readfds.fd_count; i++ )
1999-04-02 00:32:11 +08:00
#else
for ( i = 0; i < nfds; i++ )
#endif
{
ber_socket_t rd;
1999-07-14 21:16:13 +08:00
int is_listener = 0;
#ifdef HAVE_WINSOCK
rd = readfds.fd_array[i];
#else
if( ! FD_ISSET( i, &readfds ) ) {
1998-08-09 08:43:13 +08:00
continue;
}
rd = i;
1999-04-02 00:32:11 +08:00
#endif
for ( l = 0; slap_listeners[l] != NULL; l++ ) {
if ( rd == slap_listeners[l]->sl_sd ) {
1999-07-14 21:16:13 +08:00
is_listener = 1;
break;
}
}
if ( is_listener ) {
1999-04-02 00:32:11 +08:00
continue;
}
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_DETAIL2,
"slapd_daemon_task: read activity on %d\n", rd ));
2001-01-16 03:17:29 +08:00
#else
1999-04-02 00:32:11 +08:00
Debug ( LDAP_DEBUG_CONNS,
"daemon: read activity on %d\n", rd, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
/*
* NOTE: it is possible that the connection was closed
* and that the stream is now inactive.
* connection_read() must valid the stream is still
* active.
*/
1998-08-09 08:43:13 +08:00
if ( connection_read( rd ) < 0 ) {
slapd_close( rd );
1998-08-09 08:43:13 +08:00
}
}
ldap_pvt_thread_yield();
1998-08-09 08:43:13 +08:00
}
if( slapd_shutdown > 0 ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_CRIT,
"slapd_daemon_task: shutdown requested and initiated.\n"));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_TRACE,
"daemon: shutdown requested and initiated.\n",
0, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
} else if ( slapd_shutdown < 0 ) {
#ifdef HAVE_NT_SERVICE_MANAGER
if (slapd_shutdown == -1)
2001-01-18 00:35:53 +08:00
{
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_CRIT,
"slapd_daemon_task: shutdown initiated by Service Manager.\n"));
2001-01-16 03:17:29 +08:00
#else
2001-01-18 00:35:53 +08:00
Debug( LDAP_DEBUG_TRACE,
"daemon: shutdown initiated by Service Manager.\n",
0, 0, 0);
2001-01-16 03:17:29 +08:00
#endif
2001-01-18 00:35:53 +08:00
}
else
#endif
2001-01-18 00:35:53 +08:00
{
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_CRIT,
"slapd_daemon_task: abnormal condition, shutdown initiated.\n" ));
2001-01-16 03:17:29 +08:00
#else
2001-01-18 00:35:53 +08:00
Debug( LDAP_DEBUG_TRACE,
"daemon: abnormal condition, shutdown initiated.\n",
0, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
2001-01-18 00:35:53 +08:00
}
} else {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_CRIT,
"slapd_daemon_task: no active streams, shutdown initiated.\n" ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_TRACE,
2001-01-18 00:35:53 +08:00
"daemon: no active streams, shutdown initiated.\n",
0, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
}
for ( l = 0; slap_listeners[l] != NULL; l++ ) {
if ( slap_listeners[l]->sl_sd != AC_SOCKET_INVALID ) {
#ifdef LDAP_PF_LOCAL
if ( slap_listeners[l]->sl_sa.sa_addr.sa_family == AF_LOCAL ) {
unlink( slap_listeners[l]->sl_sa.sa_un_addr.sun_path );
}
#endif /* LDAP_PF_LOCAL */
slapd_close( slap_listeners[l]->sl_sd );
break;
1999-07-14 21:16:13 +08:00
}
}
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_CRIT,
"slapd_daemon_task: shutdown waiting for %d threads to terminate.\n",
ldap_pvt_thread_pool_backload(&connection_pool) ));
2001-01-16 03:17:29 +08:00
#else
1998-08-09 08:43:13 +08:00
Debug( LDAP_DEBUG_ANY,
"slapd shutdown: waiting for %d threads to terminate\n",
ldap_pvt_thread_pool_backload(&connection_pool), 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
ldap_pvt_thread_pool_destroy(&connection_pool, 1);
1998-08-09 08:43:13 +08:00
return NULL;
1998-08-09 08:43:13 +08:00
}
int slapd_daemon( void )
{
int rc;
connections_init();
#define SLAPD_LISTENER_THREAD 1
#if defined( SLAPD_LISTENER_THREAD )
{
ldap_pvt_thread_t listener_tid;
/* listener as a separate THREAD */
rc = ldap_pvt_thread_create( &listener_tid,
0, slapd_daemon_task, NULL );
if ( rc != 0 ) {
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_ERR,
"slapd_daemon: listener ldap_pvt_thread_create failed (%d).\n", rc ));
2001-01-16 03:17:29 +08:00
#else
Debug( LDAP_DEBUG_ANY,
2001-01-18 00:35:53 +08:00
"listener ldap_pvt_thread_create failed (%d)\n", rc, 0, 0 );
2001-01-16 03:17:29 +08:00
#endif
return rc;
}
/* wait for the listener thread to complete */
ldap_pvt_thread_join( listener_tid, (void *) NULL );
2001-01-18 00:35:53 +08:00
}
#else
/* experimental code */
slapd_daemon_task( NULL );
#endif
return 0;
}
int sockinit(void)
{
#if defined( HAVE_WINSOCK2 )
WORD wVersionRequested;
WSADATA wsaData;
int err;
wVersionRequested = MAKEWORD( 2, 0 );
err = WSAStartup( wVersionRequested, &wsaData );
if ( err != 0 ) {
/* Tell the user that we couldn't find a usable */
2001-01-18 00:35:53 +08:00
/* WinSock DLL. */
return -1;
}
/* Confirm that the WinSock DLL supports 2.0.*/
/* Note that if the DLL supports versions greater */
/* than 2.0 in addition to 2.0, it will still return */
2001-01-18 00:35:53 +08:00
/* 2.0 in wVersion since that is the version we */
/* requested. */
if ( LOBYTE( wsaData.wVersion ) != 2 ||
HIBYTE( wsaData.wVersion ) != 0 )
{
/* Tell the user that we couldn't find a usable */
2001-01-18 00:35:53 +08:00
/* WinSock DLL. */
WSACleanup();
return -1;
}
/* The WinSock DLL is acceptable. Proceed. */
#elif defined( HAVE_WINSOCK )
WSADATA wsaData;
if ( WSAStartup( 0x0101, &wsaData ) != 0 ) {
return -1;
}
#endif
return 0;
}
int sockdestroy(void)
{
#if defined( HAVE_WINSOCK2 ) || defined( HAVE_WINSOCK )
WSACleanup();
#endif
return 0;
}
RETSIGTYPE
slap_sig_shutdown( int sig )
1998-08-09 08:43:13 +08:00
{
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_CRIT,
"slap_sig_shutdown: signal %d\n", sig ));
2001-01-16 03:17:29 +08:00
#else
Debug(LDAP_DEBUG_TRACE, "slap_sig_shutdown: signal %d\n", sig, 0, 0);
2001-01-16 03:17:29 +08:00
#endif
/*
* If the NT Service Manager is controlling the server, we don't
* want SIGBREAK to kill the server. For some strange reason,
* SIGBREAK is generated when a user logs out.
*/
#if HAVE_NT_SERVICE_MANAGER && SIGBREAK
if (is_NT_Service && sig == SIGBREAK)
2001-01-16 03:17:29 +08:00
#ifdef NEW_LOGGING
2001-01-18 00:35:53 +08:00
LDAP_LOG(( "connection", LDAP_LEVEL_CRIT,
"slap_sig_shutdown: SIGBREAK ignored.\n" ));
2001-01-16 03:17:29 +08:00
#else
Debug(LDAP_DEBUG_TRACE, "slap_sig_shutdown: SIGBREAK ignored.\n",
0, 0, 0);
2001-01-16 03:17:29 +08:00
#endif
else
#endif
slapd_shutdown = sig;
WAKE_LISTENER(1);
/* reinstall self */
(void) SIGNAL_REINSTALL( sig, slap_sig_shutdown );
1998-08-09 08:43:13 +08:00
}
RETSIGTYPE
slap_sig_wake( int sig )
1998-08-09 08:43:13 +08:00
{
WAKE_LISTENER(1);
/* reinstall self */
(void) SIGNAL_REINSTALL( sig, slap_sig_wake );
1998-08-09 08:43:13 +08:00
}
2000-09-22 01:32:54 +08:00
void slapd_add_internal(ber_socket_t s) {
slapd_add(s);
}