54 	struct re_s* entry;  in ldap_pvt_runqueue_insert()  local
56 	entry = (struct re_s *) LDAP_CALLOC( 1, sizeof( struct re_s ));  in ldap_pvt_runqueue_insert()
57 	if ( entry ) {  in ldap_pvt_runqueue_insert()
58 		entry->interval.tv_sec = interval;  in ldap_pvt_runqueue_insert()
59 		entry->interval.tv_usec = 0;  in ldap_pvt_runqueue_insert()
60 		entry->next_sched.tv_sec = time( NULL );  in ldap_pvt_runqueue_insert()
61 		entry->next_sched.tv_usec = 0;  in ldap_pvt_runqueue_insert()
62 		entry->routine = routine;  in ldap_pvt_runqueue_insert()
63 		entry->arg = arg;  in ldap_pvt_runqueue_insert()
64 		entry->tname = tname;  in ldap_pvt_runqueue_insert()
65 		entry->tspec = tspec;  in ldap_pvt_runqueue_insert()
66 		LDAP_STAILQ_INSERT_HEAD( &rq->task_list, entry, tnext );  in ldap_pvt_runqueue_insert()
68 	return entry;  in ldap_pvt_runqueue_insert()
90 	struct re_s* entry  in ldap_pvt_runqueue_remove()  argument
96 		if ( e == entry)  in ldap_pvt_runqueue_remove()
100 	assert( e == entry );  in ldap_pvt_runqueue_remove()
102 	LDAP_STAILQ_REMOVE( &rq->task_list, entry, re_s, tnext );  in ldap_pvt_runqueue_remove()
104 	LDAP_FREE( entry );  in ldap_pvt_runqueue_remove()
113 	struct re_s* entry;  in ldap_pvt_runqueue_next_sched()  local
115 	entry = LDAP_STAILQ_FIRST( &rq->task_list );  in ldap_pvt_runqueue_next_sched()
116 	if ( entry == NULL || entry->next_sched.tv_sec == 0 ) {  in ldap_pvt_runqueue_next_sched()
119 		*next_run = entry->next_sched;  in ldap_pvt_runqueue_next_sched()
120 		return entry;  in ldap_pvt_runqueue_next_sched()
127 	struct re_s* entry  in ldap_pvt_runqueue_runtask()  argument
130 	LDAP_STAILQ_INSERT_TAIL( &rq->run_list, entry, rnext );  in ldap_pvt_runqueue_runtask()
136 	struct re_s* entry  in ldap_pvt_runqueue_stoptask()  argument
139 	LDAP_STAILQ_REMOVE( &rq->run_list, entry, re_s, rnext );  in ldap_pvt_runqueue_stoptask()
145 	struct re_s* entry  in ldap_pvt_runqueue_isrunning()  argument
151 		if ( e == entry ) {  in ldap_pvt_runqueue_isrunning()
161 	struct re_s* entry,  in ldap_pvt_runqueue_resched()  argument
169 		if ( e == entry )  in ldap_pvt_runqueue_resched()
173 	assert ( e == entry );  in ldap_pvt_runqueue_resched()
175 	LDAP_STAILQ_REMOVE( &rq->task_list, entry, re_s, tnext );  in ldap_pvt_runqueue_resched()
178 		entry->next_sched.tv_sec = time( NULL ) + entry->interval.tv_sec;  in ldap_pvt_runqueue_resched()
180 		entry->next_sched.tv_sec = 0;  in ldap_pvt_runqueue_resched()
184 		LDAP_STAILQ_INSERT_HEAD( &rq->task_list, entry, tnext );  in ldap_pvt_runqueue_resched()
185 	} else if ( entry->next_sched.tv_sec == 0 ) {  in ldap_pvt_runqueue_resched()
186 		LDAP_STAILQ_INSERT_TAIL( &rq->task_list, entry, tnext );  in ldap_pvt_runqueue_resched()
192 					LDAP_STAILQ_INSERT_HEAD( &rq->task_list, entry, tnext );  in ldap_pvt_runqueue_resched()
194 					LDAP_STAILQ_INSERT_AFTER( &rq->task_list, prev, entry, tnext );  in ldap_pvt_runqueue_resched()
197 			} else if ( e->next_sched.tv_sec > entry->next_sched.tv_sec ) {  in ldap_pvt_runqueue_resched()
199 					LDAP_STAILQ_INSERT_HEAD( &rq->task_list, entry, tnext );  in ldap_pvt_runqueue_resched()
201 					LDAP_STAILQ_INSERT_AFTER( &rq->task_list, prev, entry, tnext );  in ldap_pvt_runqueue_resched()
207 		LDAP_STAILQ_INSERT_TAIL( &rq->task_list, entry, tnext );  in ldap_pvt_runqueue_resched()