mirror of
https://git.openldap.org/openldap/openldap.git
synced 2024-12-21 03:10:25 +08:00
80 lines
1.6 KiB
C
80 lines
1.6 KiB
C
/* $OpenLDAP$ */
|
|
/*
|
|
* Copyright 2003 The OpenLDAP Foundation, Redwood City, California, USA
|
|
* All rights reserved.
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted only as authorized by the OpenLDAP
|
|
* Public License. A copy of this license is available at
|
|
* http://www.OpenLDAP.org/license.html or in file LICENSE in the
|
|
* top-level directory of the distribution.
|
|
*/
|
|
|
|
#ifdef LDAP_SYNCREPL
|
|
|
|
typedef struct re_s {
|
|
struct timeval next_sched;
|
|
struct timeval interval;
|
|
LDAP_STAILQ_ENTRY(re_s) tnext; /* it includes running */
|
|
LDAP_STAILQ_ENTRY(re_s) rnext;
|
|
ldap_pvt_thread_start_t *routine;
|
|
void *arg;
|
|
} re_t;
|
|
|
|
typedef struct runqueue_s {
|
|
LDAP_STAILQ_HEAD(l, re_s) task_list;
|
|
LDAP_STAILQ_HEAD(rl, re_s) run_list;
|
|
ldap_pvt_thread_mutex_t rq_mutex;
|
|
} runqueue_t;
|
|
|
|
LDAP_F( void )
|
|
ldap_pvt_runqueue_insert(
|
|
struct runqueue_s* rq,
|
|
time_t interval,
|
|
ldap_pvt_thread_start_t* routine,
|
|
void *arg
|
|
);
|
|
|
|
LDAP_F( void )
|
|
ldap_pvt_runqueue_remove(
|
|
struct runqueue_s* rq,
|
|
struct re_s* entry
|
|
);
|
|
|
|
LDAP_F( struct re_s* )
|
|
ldap_pvt_runqueue_next_sched(
|
|
struct runqueue_s* rq,
|
|
struct timeval** next_run
|
|
);
|
|
|
|
LDAP_F( void )
|
|
ldap_pvt_runqueue_runtask(
|
|
struct runqueue_s* rq,
|
|
struct re_s* entry
|
|
);
|
|
|
|
LDAP_F( void )
|
|
ldap_pvt_runqueue_stoptask(
|
|
struct runqueue_s* rq,
|
|
struct re_s* entry
|
|
);
|
|
|
|
LDAP_F( int )
|
|
ldap_pvt_runqueue_isrunning(
|
|
struct runqueue_s* rq,
|
|
struct re_s* entry
|
|
);
|
|
|
|
LDAP_F( void )
|
|
ldap_pvt_runqueue_resched(
|
|
struct runqueue_s* rq,
|
|
struct re_s* entry
|
|
);
|
|
|
|
LDAP_F( int )
|
|
ldap_pvt_runqueue_persistent_backload(
|
|
struct runqueue_s* rq
|
|
);
|
|
|
|
#endif
|