X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslurpd%2Fslurp.h;h=26368bd4876fa2e1c4ffc08afedee795f49ceaf7;hb=3cad129608cda1c80acc15c364537f017fa454c7;hp=4e1e96ab2c2446458884a13a9f0ee7304d048db7;hpb=a3ac3be6a7b0dd405c940ea62f7aa6af6dbe6caf;p=openldap diff --git a/servers/slurpd/slurp.h b/servers/slurpd/slurp.h index 4e1e96ab2c..26368bd487 100644 --- a/servers/slurpd/slurp.h +++ b/servers/slurpd/slurp.h @@ -1,3 +1,4 @@ +/* $OpenLDAP$ */ /* * Copyright (c) 1996 Regents of the University of Michigan. * All rights reserved. @@ -20,18 +21,21 @@ #endif #include +#include +#include #include +#include -#include +#include -#include "lber.h" -#include "ldap.h" +#include +#undef ldap_debug #define ldap_debug slurp_debug #include "ldap_log.h" -#include "lthread.h" -#include "ldapconfig.h" +#include "ldap_pvt_thread.h" +#include "ldap_defaults.h" #include "ldif.h" @@ -84,6 +88,8 @@ #define T_DELETECTSTR "delete" #define T_DELETECT 6 #define T_MODRDNCTSTR "modrdn" +#define T_MODDNCTSTR "moddn" +#define T_RENAMECTSTR "rename" #define T_MODRDNCT 7 #define T_MODOPADDSTR "add" @@ -96,7 +102,8 @@ #define T_MODSEP 11 #define T_NEWRDNSTR "newrdn" -#define T_DRDNFLAGSTR "deleteoldrdn" +#define T_DELOLDRDNSTR "deleteoldrdn" +#define T_NEWSUPSTR "newsuperior" #define T_ERR -1 @@ -183,7 +190,7 @@ struct ri { struct stel *ri_stel; /* pointer to Stel for this replica */ unsigned long ri_seq; /* seq number of last repl */ - pthread_t ri_tid; /* ID of thread for this replica */ + ldap_pvt_thread_t ri_tid; /* ID of thread for this replica */ /* Member functions */ int (*ri_process) LDAP_P(( Ri * )); /* process the next repl entry */ @@ -217,7 +224,7 @@ typedef struct re Re; struct re { /* Private data */ - pthread_mutex_t + ldap_pvt_thread_mutex_t re_mutex; /* mutex for this Re */ int re_refcnt; /* ref count, 0 = done */ char *re_timestamp; /* timestamp of this re */ @@ -262,9 +269,9 @@ struct rq { time_t rq_lasttrim; /* Last time we trimmed file */ /* Public data */ - pthread_mutex_t + ldap_pvt_thread_mutex_t rq_mutex; /* mutex for whole queue */ - pthread_cond_t + ldap_pvt_thread_cond_t rq_more; /* condition var - more work added */ /* Member functions */ @@ -308,7 +315,7 @@ typedef struct stel { typedef struct st St; struct st { /* Private data */ - pthread_mutex_t + ldap_pvt_thread_mutex_t st_mutex; /* mutex to serialize access */ Stel **st_data; /* array of pointers to Stel structs */ int st_nreplicas; /* number of repl hosts */