mirror of
https://git.openldap.org/openldap/openldap.git
synced 2025-01-30 13:30:57 +08:00
Remove global_backendsyncfreq code (code has been pushed down into back-ldbm).
This commit is contained in:
parent
6a6fd6059d
commit
a9097044ea
@ -74,7 +74,6 @@ ldap_back_initialize(
|
||||
bi->bi_db_open = 0;
|
||||
bi->bi_db_close = 0;
|
||||
bi->bi_db_destroy = ldap_back_db_destroy;
|
||||
bi->bi_db_sync = 0;
|
||||
|
||||
bi->bi_op_bind = ldap_back_bind;
|
||||
bi->bi_op_unbind = 0;
|
||||
|
@ -122,7 +122,6 @@ ldbm_back_db_config(
|
||||
}
|
||||
|
||||
li->li_dbsyncfreq = i;
|
||||
li->li_dbwritesync = 0;
|
||||
|
||||
if ( argc > 2 ) {
|
||||
i = atoi( argv[2] );
|
||||
|
@ -46,7 +46,7 @@ ldbm_cache_open(
|
||||
flags |= LDBM_NOLOCKING;
|
||||
}
|
||||
|
||||
if( li->li_dbwritesync && global_backendsyncfreq == 0) {
|
||||
if( li->li_dbwritesync && li->li_dbsyncfreq == 0) {
|
||||
flags |= LDBM_SYNC;
|
||||
} else {
|
||||
flags |= LDBM_NOSYNC;
|
||||
|
@ -52,7 +52,6 @@ ldbm_back_initialize(
|
||||
bi->bi_db_open = ldbm_back_db_open;
|
||||
bi->bi_db_close = ldbm_back_db_close;
|
||||
bi->bi_db_destroy = ldbm_back_db_destroy;
|
||||
bi->bi_db_sync = ldbm_cache_sync;
|
||||
|
||||
bi->bi_op_bind = ldbm_back_bind;
|
||||
bi->bi_op_unbind = ldbm_back_unbind;
|
||||
|
@ -105,7 +105,6 @@ meta_back_initialize(
|
||||
bi->bi_db_open = 0;
|
||||
bi->bi_db_close = 0;
|
||||
bi->bi_db_destroy = meta_back_db_destroy;
|
||||
bi->bi_db_sync = 0;
|
||||
|
||||
bi->bi_op_bind = meta_back_bind;
|
||||
bi->bi_op_unbind = 0;
|
||||
|
@ -40,7 +40,6 @@ passwd_back_initialize(
|
||||
bi->bi_db_open = 0;
|
||||
bi->bi_db_close = 0;
|
||||
bi->bi_db_destroy = 0;
|
||||
bi->bi_db_sync = 0;
|
||||
|
||||
bi->bi_op_bind = 0;
|
||||
bi->bi_op_unbind = 0;
|
||||
|
@ -44,7 +44,6 @@ shell_back_initialize(
|
||||
bi->bi_db_open = 0;
|
||||
bi->bi_db_close = 0;
|
||||
bi->bi_db_destroy = shell_back_db_destroy;
|
||||
bi->bi_db_sync = 0;
|
||||
|
||||
bi->bi_op_bind = shell_back_bind;
|
||||
bi->bi_op_unbind = shell_back_unbind;
|
||||
|
@ -49,7 +49,6 @@ int sql_back_initialize(
|
||||
bi->bi_db_open = backsql_db_open;
|
||||
bi->bi_db_close = backsql_db_close;
|
||||
bi->bi_db_destroy = backsql_db_destroy;
|
||||
bi->bi_db_sync = 0;
|
||||
|
||||
#ifdef BACKSQL_ALL_DONE
|
||||
bi->bi_op_abandon = backsql_abandon;
|
||||
|
@ -333,45 +333,6 @@ int backend_num( Backend *be )
|
||||
return -1;
|
||||
}
|
||||
|
||||
|
||||
int backend_sync( Backend *be )
|
||||
{
|
||||
int i;
|
||||
int rc = 0;
|
||||
|
||||
if( be != NULL ) {
|
||||
/* sync a specific backend database */
|
||||
|
||||
if ( be->bd_info->bi_nDB == 0 ) {
|
||||
/* no database of this type, we never opened it */
|
||||
return 0;
|
||||
}
|
||||
|
||||
if ( be->bd_info->bi_db_sync ) {
|
||||
be->bd_info->bi_db_sync( be );
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
/* sync each backend database */
|
||||
for( i = 0; i < nBackendDB; i++ ) {
|
||||
if ( backendDB[i].bd_info->bi_db_sync ) {
|
||||
rc = backendDB[i].bd_info->bi_db_sync(
|
||||
&backendDB[i] );
|
||||
}
|
||||
|
||||
if(rc != 0) {
|
||||
Debug( LDAP_DEBUG_ANY,
|
||||
"backend_sync: bi_sync %s failed!\n",
|
||||
backendDB[i].be_type, 0, 0 );
|
||||
}
|
||||
}
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
||||
int backend_shutdown( Backend *be )
|
||||
{
|
||||
int i;
|
||||
|
@ -34,7 +34,6 @@ slap_ssf_set_t global_ssf_set;
|
||||
char *replogfile;
|
||||
int global_lastmod = ON;
|
||||
int global_idletimeout = 0;
|
||||
int global_backendsyncfreq = 0;
|
||||
char *global_host = NULL;
|
||||
char *global_realm = NULL;
|
||||
char *ldap_srvtab = "";
|
||||
@ -1741,33 +1740,6 @@ read_config( const char *fname )
|
||||
|
||||
global_idletimeout = i;
|
||||
|
||||
/* set backend sync frequency */
|
||||
} else if ( strcasecmp( cargv[0], "backendsyncfreq" ) == 0 ) {
|
||||
#ifndef NO_THREADS
|
||||
int i;
|
||||
if ( cargc < 2 ) {
|
||||
Debug( LDAP_DEBUG_ANY,
|
||||
"%s: line %d: missing frquency value in \"backendsyncfreq <seconds>\" line\n",
|
||||
fname, lineno, 0 );
|
||||
return 1;
|
||||
}
|
||||
|
||||
i = atoi( cargv[1] );
|
||||
|
||||
if( i < 0 ) {
|
||||
Debug( LDAP_DEBUG_ANY,
|
||||
"%s: line %d: frquency value (%d) invalid \"backendsyncfreq <seconds>\" line\n",
|
||||
fname, lineno, i );
|
||||
return 1;
|
||||
}
|
||||
|
||||
global_backendsyncfreq = i;
|
||||
#else
|
||||
Debug( LDAP_DEBUG_ANY,
|
||||
"\"dbsyncfreq\" not supported in non-threaded environment\n");
|
||||
return 1;
|
||||
#endif
|
||||
|
||||
/* include another config file */
|
||||
} else if ( strcasecmp( cargv[0], "include" ) == 0 ) {
|
||||
if ( cargc < 2 ) {
|
||||
|
@ -1628,38 +1628,6 @@ slapd_daemon_task(
|
||||
}
|
||||
|
||||
|
||||
static void *
|
||||
sync_daemon(
|
||||
void *ptr
|
||||
)
|
||||
{
|
||||
sleep( 1 );
|
||||
|
||||
Debug( LDAP_DEBUG_ANY, "synchronizer starting\n", 0, 0, 0 );
|
||||
|
||||
while (!slapd_shutdown) {
|
||||
|
||||
sleep( global_backendsyncfreq );
|
||||
|
||||
/*
|
||||
How do we wait for slapd to be idle?
|
||||
Maybe this would work ?
|
||||
while (ldap_pvt_thread_pool_backload(&connection_pool) != 0)
|
||||
sleep(1);
|
||||
*/
|
||||
|
||||
if (!slapd_shutdown) {
|
||||
Debug( LDAP_DEBUG_TRACE, "synchronizing\n", 0, 0, 0 );
|
||||
backend_sync( NULL );
|
||||
}
|
||||
}
|
||||
|
||||
Debug( LDAP_DEBUG_ANY, "synchronizer stopping\n", 0, 0, 0 );
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
|
||||
int slapd_daemon( void )
|
||||
{
|
||||
int rc;
|
||||
@ -1670,7 +1638,6 @@ int slapd_daemon( void )
|
||||
#if defined( SLAPD_LISTENER_THREAD )
|
||||
{
|
||||
ldap_pvt_thread_t listener_tid;
|
||||
ldap_pvt_thread_t sync_tid;
|
||||
|
||||
/* listener as a separate THREAD */
|
||||
rc = ldap_pvt_thread_create( &listener_tid,
|
||||
@ -1686,27 +1653,9 @@ int slapd_daemon( void )
|
||||
#endif
|
||||
return rc;
|
||||
}
|
||||
|
||||
/* sync thread */
|
||||
if ( global_backendsyncfreq > 0 )
|
||||
{
|
||||
rc = ldap_pvt_thread_create( &sync_tid,
|
||||
0, sync_daemon, NULL );
|
||||
|
||||
if ( rc != 0 )
|
||||
{
|
||||
Debug( LDAP_DEBUG_ANY,
|
||||
"sync ldap_pvt_thread_create failed (%d)\n", rc, 0, 0 );
|
||||
}
|
||||
}
|
||||
|
||||
/* wait for the listener thread to complete */
|
||||
ldap_pvt_thread_join( listener_tid, (void *) NULL );
|
||||
|
||||
if ( global_backendsyncfreq > 0 )
|
||||
{
|
||||
ldap_pvt_thread_join( sync_tid, (void *) NULL );
|
||||
}
|
||||
}
|
||||
#else
|
||||
/* experimental code */
|
||||
|
@ -823,7 +823,6 @@ LDAP_SLAPD_F (int) g_argc;
|
||||
LDAP_SLAPD_F (slap_access_t) global_default_access;
|
||||
LDAP_SLAPD_F (int) global_lastmod;
|
||||
LDAP_SLAPD_F (int) global_idletimeout;
|
||||
LDAP_SLAPD_F (int) global_backendsyncfreq;
|
||||
LDAP_SLAPD_F (int) global_schemacheck;
|
||||
LDAP_SLAPD_F (char) *global_host;
|
||||
LDAP_SLAPD_F (char) *global_realm;
|
||||
|
@ -990,7 +990,6 @@ struct slap_backend_info {
|
||||
int (*bi_db_open) LDAP_P((Backend *bd));
|
||||
int (*bi_db_close) LDAP_P((Backend *bd));
|
||||
int (*bi_db_destroy) LDAP_P((Backend *db));
|
||||
int (*bi_db_sync) LDAP_P((Backend *db));
|
||||
|
||||
/* LDAP Operations Handling Routines */
|
||||
int (*bi_op_bind) LDAP_P(( BackendDB *bd,
|
||||
|
Loading…
Reference in New Issue
Block a user