]> git.sur5r.net Git - openldap/blobdiff - servers/slurpd/ri.c
Fix idl_insert_key() return codes.
[openldap] / servers / slurpd / ri.c
index d2aa7de252ea527d92f10480fc37c864436a029b..ff65b2c4845f65e8c90ed8763caf984534a86dbf 100644 (file)
@@ -20,7 +20,9 @@
 #include "portable.h"
 
 #include <stdio.h>
-#include <stdlib.h>
+
+#include <ac/stdlib.h>
+#include <ac/string.h>
 #include <ac/signal.h>
 
 #include "slurp.h"
@@ -60,7 +62,7 @@ Ri_process(
     while ( !sglob->slurpd_shutdown &&
            (( re = rq->rq_gethead( rq )) == NULL )) {
        /* No work - wait on condition variable */
-       pthread_cond_wait( &rq->rq_more, &rq->rq_mutex );
+       ldap_pvt_thread_cond_wait( &rq->rq_more, &rq->rq_mutex );
     }
 
     /*
@@ -84,7 +86,7 @@ Ri_process(
                rc = do_ldap( ri, re, &errmsg );
                switch ( rc ) {
                case DO_LDAP_ERR_RETRYABLE:
-                   tsleep( RETRY_SLEEP_TIME );
+                   ldap_pvt_thread_sleep( RETRY_SLEEP_TIME );
                    Debug( LDAP_DEBUG_ANY,
                            "Retrying operation for DN %s on replica %s:%d\n",
                            re->re_dn, ri->ri_hostname, ri->ri_port );
@@ -120,7 +122,7 @@ Ri_process(
                return 0;
            }
            /* No work - wait on condition variable */
-           pthread_cond_wait( &rq->rq_more, &rq->rq_mutex );
+           ldap_pvt_thread_cond_wait( &rq->rq_more, &rq->rq_mutex );
        }
        re->re_decrefcnt( re );
        re = new_re;
@@ -135,7 +137,7 @@ Ri_process(
 
 /*
  * Wake a replication thread which may be sleeping.
- * Send it a SIG(STKFLT|USR1).
+ * Send it a LDAP_SIGUSR1.
  */
 static void
 Ri_wake(
@@ -145,8 +147,7 @@ Ri_wake(
     if ( ri == NULL ) {
        return;
     }
-    pthread_kill( ri->ri_tid, LDAP_SIGUSR1 );
-    (void) SIGNAL( LDAP_SIGUSR1, do_nothing );
+    ldap_pvt_thread_kill( ri->ri_tid, LDAP_SIGUSR1 );
 }