X-Git-Url: https://git.sur5r.net/?a=blobdiff_plain;f=servers%2Fslapd%2Fback-bdb%2Fproto-bdb.h;h=5ec4228d434f27007586aed40c257c16dfbbaa35;hb=282f6bc32d942d866edde41e8c35a96ae5b040c5;hp=cdea9803e190411fc29f2d066bf0051eca884bc4;hpb=cc21d814b3a553d57f06e8af4feb9b5eb66a444c;p=openldap diff --git a/servers/slapd/back-bdb/proto-bdb.h b/servers/slapd/back-bdb/proto-bdb.h index cdea9803e1..5ec4228d43 100644 --- a/servers/slapd/back-bdb/proto-bdb.h +++ b/servers/slapd/back-bdb/proto-bdb.h @@ -1,6 +1,6 @@ /* $OpenLDAP$ */ /* - * Copyright 2000-2002 The OpenLDAP Foundation, All Rights Reserved. + * Copyright 2000-2003 The OpenLDAP Foundation, All Rights Reserved. * COPYING RESTRICTIONS APPLY, see COPYRIGHT file */ @@ -58,9 +58,12 @@ bdb_db_cache( * dn2entry.c */ int bdb_dn2entry_rw LDAP_P(( BackendDB *be, DB_TXN *tid, - struct berval *dn, Entry **e, Entry **matched, int flags, int rw )); -#define bdb_dn2entry_r(be, tid, dn, e, m, f) bdb_dn2entry_rw((be), (tid), (dn), (e), (m), (f), 0) -#define bdb_dn2entry_w(be, tid, dn, e, m, f) bdb_dn2entry_rw((be), (tid), (dn), (e), (m), (f), 1) + struct berval *dn, Entry **e, Entry **matched, int flags, int rw, + u_int32_t locker, DB_LOCK *lock)); +#define bdb_dn2entry_r(be, tid, dn, e, m, f, locker, lock) \ + bdb_dn2entry_rw((be), (tid), (dn), (e), (m), (f), 0, locker, lock) +#define bdb_dn2entry_w(be, tid, dn, e, m, f, locker, lock) \ + bdb_dn2entry_rw((be), (tid), (dn), (e), (m), (f), 1, locker, lock) /* * dn2id.c @@ -69,14 +72,16 @@ int bdb_dn2id( BackendDB *be, DB_TXN *tid, struct berval *dn, - ID *id ); + ID *id, + int flags ); int bdb_dn2id_matched( BackendDB *be, DB_TXN *tid, struct berval *dn, ID *id, - ID *id2 ); + ID *id2, + int flags ); int bdb_dn2id_add( BackendDB *be, @@ -93,7 +98,8 @@ int bdb_dn2id_delete( int bdb_dn2id_children( BackendDB *be, DB_TXN *tid, - struct berval *dn ); + struct berval *dn, + int flags ); int bdb_dn2idl( @@ -152,9 +158,13 @@ int bdb_id2entry_rw( DB_TXN *tid, ID id, Entry **e, - int rw ); -#define bdb_id2entry_r(be, tid, id, e) bdb_id2entry_rw((be), (tid), (id), (e), 0) -#define bdb_id2entry_w(be, tid, id, e) bdb_id2entry_rw((be), (tid), (id), (e), 1) + int rw, + u_int32_t locker, + DB_LOCK *lock ); +#define bdb_id2entry_r(be, tid, id, e, locker, lock) \ + bdb_id2entry_rw((be), (tid), (id), (e), 0, locker, lock) +#define bdb_id2entry_w(be, tid, id, e, locker, lock) \ + bdb_id2entry_rw((be), (tid), (id), (e), 1, locker, lock) void bdb_entry_free ( Entry *e ); @@ -290,6 +300,17 @@ int bdb_modify_internal( char *textbuf, size_t textlen ); +/* + * operational.c + */ +int +bdb_hasSubordinates( + BackendDB *be, + Connection *conn, + Operation *op, + Entry *e, + int *hasSubordinates ); + /* * passwd.c */ @@ -301,13 +322,24 @@ BI_op_extended bdb_exop_passwd; */ void bdb_cache_entry_commit( Entry *e ); -void bdb_cache_return_entry_rw( Cache *cache, Entry *e, int rw ); -#define bdb_cache_return_entry_r(c, e) bdb_cache_return_entry_rw((c), (e), 0) -#define bdb_cache_return_entry_w(c, e) bdb_cache_return_entry_rw((c), (e), 1) +void bdb_cache_return_entry_rw( DB_ENV *env, Cache *cache, Entry *e, + int rw, DB_LOCK *lock ); +#define bdb_cache_return_entry_r(env, c, e, l) \ + bdb_cache_return_entry_rw((env), (c), (e), 0, (l)) +#define bdb_cache_return_entry_w(env, c, e, l) \ + bdb_cache_return_entry_rw((env), (c), (e), 1, (l)) +void bdb_unlocked_cache_return_entry_rw( Cache *cache, Entry *e, int rw ); +#define bdb_unlocked_cache_return_entry_r( c, e ) \ + bdb_unlocked_cache_return_entry_rw((c), (e), 0) +#define bdb_unlocked_cache_return_entry_w( c, e ) \ + bdb_unlocked_cache_return_entry_rw((c), (e), 1) int bdb_cache_add_entry_rw( - Cache *cache, - Entry *e, - int rw + DB_ENV *env, + Cache *cache, + Entry *e, + int rw, + u_int32_t locker, + DB_LOCK *lock ); int bdb_cache_update_entry( Cache *cache, @@ -319,9 +351,12 @@ ID bdb_cache_find_entry_ndn2id( struct berval *ndn ); Entry* bdb_cache_find_entry_id( - Cache *cache, - ID id, - int rw + DB_ENV *env, + Cache *cache, + ID id, + int rw, + u_int32_t locker, + DB_LOCK *lock ); int bdb_cache_delete_entry( Cache *cache, @@ -329,6 +364,118 @@ int bdb_cache_delete_entry( ); void bdb_cache_release_all( Cache *cache ); +/* + * lcup.c + */ + +#ifdef LDAP_CLIENT_UPDATE +int bdb_abandon( + BackendDB *be, + Connection *conn, + ber_int_t id +); +#endif + +#if defined(LDAP_CLIENT_UPDATE) || defined(LDAP_SYNC) +int bdb_add_psearch_spec( + BackendDB *be, + Connection *conn, + Operation *op, + struct berval *base, + struct berval *nbase, + int scope, + int deref, + int slimit, + int tlimit, + Filter *filter, + struct berval *fstr, + AttributeName *attrs, + int attrsonly, + int protocol +); + +int bdb_psearch( + BackendDB *be, + Connection *conn, + Operation *op, + Operation *ps_op, + Entry *entry, + int psearch_type +); +#endif + +/* + * search.c + */ + +#ifdef LDAP_CLIENT_UPDATE +int +bdb_build_lcup_update_ctrl( + Connection *conn, + Operation *op, + Entry *e, + int entry_count, + LDAPControl **ctrls, + int num_ctrls, + struct berval *latest_entrycsn_bv, + int isdeleted ); + +int +bdb_build_lcup_done_ctrl( + Connection *conn, + Operation *op, + LDAPControl **ctrls, + int num_ctrls, + struct berval *latest_entrycsn_bv ); +#endif + +#ifdef LDAP_SYNC +int +bdb_build_sync_state_ctrl( + Connection *conn, + Operation *op, + Entry *e, + int entry_sync_state, + LDAPControl **ctrls, + int num_ctrls, + int send_cookie, + struct berval *latest_entrycsn_bv ); + +int +bdb_build_sync_done_ctrl( + Connection *conn, + Operation *op, + LDAPControl **ctrls, + int num_ctrls, + int send_cookie, + struct berval *latest_entrycsn_bv ); + +int +bdb_send_ldap_intermediate( + Connection *conn, + Operation *op, + ber_int_t err, + const char *matched, + const char *text, + BerVarray refs, + const char *rspoid, + int state, + struct berval *cookie, + LDAPControl **ctrls ); +#endif + +#ifdef BDB_REUSE_LOCKERS + +int bdb_locker_id( Operation *op, DB_ENV *env, int *locker ); + +#endif + +#ifdef HAVE_EBCDIC +char *ebcdic_dberror( int rc ); + +#define db_strerror(x) ebcdic_dberror(x) +#endif + LDAP_END_DECL #endif /* _PROTO_BDB_H */