diff options
Diffstat (limited to 'ldap/servers/plugins/replication/repl5.h')
| -rw-r--r-- | ldap/servers/plugins/replication/repl5.h | 480 |
1 files changed, 480 insertions, 0 deletions
diff --git a/ldap/servers/plugins/replication/repl5.h b/ldap/servers/plugins/replication/repl5.h new file mode 100644 index 00000000..d936cbea --- /dev/null +++ b/ldap/servers/plugins/replication/repl5.h @@ -0,0 +1,480 @@ +/** BEGIN COPYRIGHT BLOCK + * Copyright 2001 Sun Microsystems, Inc. + * Portions copyright 1999, 2001-2003 Netscape Communications Corporation. + * All rights reserved. + * END COPYRIGHT BLOCK **/ + +/* repl5.h - 5.0 replication header */ + +#ifndef _REPL5_H_ +#define _REPL5_H_ + +#include <limits.h> +#include <time.h> +#include <stdio.h> +#include <string.h> +#ifndef _WIN32 +#include <sys/param.h> +#endif /* _WIN32 */ + +#include "portable.h" /* GGOODREPL - is this cheating? */ +#include "repl_shared.h" +#include "llist.h" +#include "repl5_ruv.h" +#include "cl4.h" + +/* DS 5.0 replication protocol OIDs */ +#define REPL_START_NSDS50_REPLICATION_REQUEST_OID "2.16.840.1.113730.3.5.3" +#define REPL_END_NSDS50_REPLICATION_REQUEST_OID "2.16.840.1.113730.3.5.5" +#define REPL_NSDS50_REPLICATION_ENTRY_REQUEST_OID "2.16.840.1.113730.3.5.6" +#define REPL_NSDS50_REPLICATION_RESPONSE_OID "2.16.840.1.113730.3.5.4" +#define REPL_NSDS50_UPDATE_INFO_CONTROL_OID "2.16.840.1.113730.3.4.13" +#define REPL_NSDS50_INCREMENTAL_PROTOCOL_OID "2.16.840.1.113730.3.6.1" +#define REPL_NSDS50_TOTAL_PROTOCOL_OID "2.16.840.1.113730.3.6.2" + +/* DS 5.0 replication protocol error codes */ +#define NSDS50_REPL_REPLICA_READY 0x00 /* Replica ready, go ahead */ +#define NSDS50_REPL_REPLICA_BUSY 0x01 /* Replica busy, try later */ +#define NSDS50_REPL_EXCESSIVE_CLOCK_SKEW 0x02 /* Supplier clock too far ahead */ +#define NSDS50_REPL_PERMISSION_DENIED 0x03 /* Bind DN not allowed to send updates */ +#define NSDS50_REPL_DECODING_ERROR 0x04 /* Consumer couldn't decode extended operation */ +#define NSDS50_REPL_UNKNOWN_UPDATE_PROTOCOL 0x05 /* Consumer doesn't understand suplier's update protocol */ +#define NSDS50_REPL_NO_SUCH_REPLICA 0x06 /* Consumer holds no such replica */ +#define NSDS50_REPL_BELOW_PURGEPOINT 0x07 /* Supplier provided a CSN below the consumer's purge point */ +#define NSDS50_REPL_INTERNAL_ERROR 0x08 /* Something bad happened on consumer */ +#define NSDS50_REPL_REPLICA_RELEASE_SUCCEEDED 0x09 /* Replica released successfully */ +#define NSDS50_REPL_LEGACY_CONSUMER 0x0A /* replica is a legacy consumer */ +#define NSDS50_REPL_REPLICAID_ERROR 0x0B /* replicaID doesn't seem to be unique */ +#define NSDS50_REPL_DISABLED 0x0C /* replica suffix is disabled */ +#define NSDS50_REPL_UPTODATE 0x0D /* replica is uptodate */ +#define NSDS50_REPL_REPLICA_NO_RESPONSE 0xff /* No response received */ + +/* Protocol status */ +#define PROTOCOL_STATUS_UNKNOWN 701 +#define PROTOCOL_STATUS_INCREMENTAL_AWAITING_CHANGES 702 +#define PROTOCOL_STATUS_INCREMENTAL_ACQUIRING_REPLICA 703 +#define PROTOCOL_STATUS_INCREMENTAL_RELEASING_REPLICA 704 +#define PROTOCOL_STATUS_INCREMENTAL_SENDING_UPDATES 705 +#define PROTOCOL_STATUS_INCREMENTAL_BACKING_OFF 706 +#define PROTOCOL_STATUS_INCREMENTAL_NEEDS_TOTAL_UPDATE 707 +#define PROTOCOL_STATUS_INCREMENTAL_FATAL_ERROR 708 +#define PROTOCOL_STATUS_TOTAL_ACQUIRING_REPLICA 709 +#define PROTOCOL_STATUS_TOTAL_RELEASING_REPLICA 710 +#define PROTOCOL_STATUS_TOTAL_SENDING_DATA 711 + +/* To Allow Consumer Initialisation when adding an agreement - */ +#define STATE_PERFORMING_TOTAL_UPDATE 501 +#define STATE_PERFORMING_INCREMENTAL_UPDATE 502 + +#define MAX_NUM_OF_MASTERS 64 +#define REPL_SESSION_ID_SIZE 64 + +/* Attribute names for replication agreement attributes */ +extern const char *type_nsds5ReplicaHost; +extern const char *type_nsds5ReplicaPort; +extern const char *type_nsds5TransportInfo; +extern const char *type_nsds5ReplicaBindDN; +extern const char *type_nsds5ReplicaCredentials; +extern const char *type_nsds5ReplicaBindMethod; +extern const char *type_nsds5ReplicaRoot; +extern const char *type_nsds5ReplicatedAttributeList; +extern const char *type_nsds5ReplicaUpdateSchedule; +extern const char *type_nsds5ReplicaInitialize; +extern const char *type_nsds5ReplicaTimeout; +extern const char *type_nsds5ReplicaBusyWaitTime; +extern const char *type_nsds5ReplicaSessionPauseTime; + +/* To Allow Consumer Initialisation when adding an agreement - */ +extern const char *type_nsds5BeginReplicaRefresh; + +/* replica related attributes */ +extern const char *attr_replicaId; +extern const char *attr_replicaRoot; +extern const char *attr_replicaType; +extern const char *attr_replicaBindDn; +extern const char *attr_state; +extern const char *attr_flags; +extern const char *attr_replicaName; +extern const char *attr_replicaReferral; +extern const char *type_ruvElement; +extern const char *type_replicaPurgeDelay; +extern const char *type_replicaChangeCount; +extern const char *type_replicaTombstonePurgeInterval; +extern const char *type_replicaLegacyConsumer; +extern const char *type_ruvElementUpdatetime; + +/* multimaster plugin points */ +int multimaster_preop_bind (Slapi_PBlock *pb); +int multimaster_preop_add (Slapi_PBlock *pb); +int multimaster_preop_delete (Slapi_PBlock *pb); +int multimaster_preop_modify (Slapi_PBlock *pb); +int multimaster_preop_modrdn (Slapi_PBlock *pb); +int multimaster_preop_search (Slapi_PBlock *pb); +int multimaster_preop_compare (Slapi_PBlock *pb); +int multimaster_bepreop_add (Slapi_PBlock *pb); +int multimaster_bepreop_delete (Slapi_PBlock *pb); +int multimaster_bepreop_modify (Slapi_PBlock *pb); +int multimaster_bepreop_modrdn (Slapi_PBlock *pb); +int multimaster_bepostop_modrdn (Slapi_PBlock *pb); +int multimaster_bepostop_delete (Slapi_PBlock *pb); +int multimaster_postop_bind (Slapi_PBlock *pb); +int multimaster_postop_add (Slapi_PBlock *pb); +int multimaster_postop_delete (Slapi_PBlock *pb); +int multimaster_postop_modify (Slapi_PBlock *pb); +int multimaster_postop_modrdn (Slapi_PBlock *pb); + +/* In repl5_init.c */ +char* get_thread_private_agmtname (); +void set_thread_private_agmtname (const char *agmtname); +void* get_thread_private_cache (); +void set_thread_private_cache (void *buf); +char* get_repl_session_id (Slapi_PBlock *pb, char *id, CSN **opcsn); + +/* In repl_extop.c */ +int multimaster_extop_StartNSDS50ReplicationRequest(Slapi_PBlock *pb); +int multimaster_extop_EndNSDS50ReplicationRequest(Slapi_PBlock *pb); +int extop_noop(Slapi_PBlock *pb); +struct berval *NSDS50StartReplicationRequest_new(const char *protocol_oid, + const char *repl_root, char **extra_referrals, CSN *csn); +struct berval *NSDS50EndReplicationRequest_new(char *repl_root); +int decode_repl_ext_response(struct berval *data, int *response_code, + struct berval ***ruv_bervals); + +/* In repl5_total.c */ +int multimaster_extop_NSDS50ReplicationEntry(Slapi_PBlock *pb); + +/* In repl_controls.c */ +int create_NSDS50ReplUpdateInfoControl(const char *uuid, + const char *superior_uuid, const CSN *csn, + LDAPMod **modify_mods, LDAPControl **ctrlp); +void destroy_NSDS50ReplUpdateInfoControl(LDAPControl **ctrlp); +int decode_NSDS50ReplUpdateInfoControl(LDAPControl **controlsp, + char **uuid, char **newsuperior_uuid, CSN **csn, LDAPMod ***modrdn_mods); + +/* In repl5_replsupplier.c */ +typedef struct repl_supplier Repl_Supplier; +Repl_Supplier *replsupplier_init(Slapi_Entry *e); +void replsupplier_configure(Repl_Supplier *rs, Slapi_PBlock *pb); +void replsupplier_start(Repl_Supplier *rs); +void replsupplier_stop(Repl_Supplier *rs); +void replsupplier_destroy(Repl_Supplier **rs); +void replsupplier_notify(Repl_Supplier *rs, PRUint32 eventmask); +PRUint32 replsupplier_get_status(Repl_Supplier *rs); + +/* In repl5_plugins.c */ +int multimaster_set_local_purl(); +const char *multimaster_get_local_purl(); +PRBool multimaster_started(); + +/* In repl5_schedule.c */ +typedef struct schedule Schedule; +typedef void (*window_state_change_callback)(void *arg, PRBool opened); +Schedule *schedule_new(window_state_change_callback callback_fn, void *callback_arg, const char *session_id); +void schedule_destroy(Schedule *s); +int schedule_set(Schedule *sch, Slapi_Attr *attr); +char **schedule_get(Schedule *sch); +int schedule_in_window_now(Schedule *sch); +PRTime schedule_next(Schedule *sch); +int schedule_notify(Schedule *sch, Slapi_PBlock *pb); +void schedule_set_priority_attributes(Schedule *sch, char **prio_attrs, int override_schedule); +void schedule_set_startup_delay(Schedule *sch, size_t startup_delay); +void schedule_set_maximum_backlog(Schedule *sch, size_t max_backlog); +void schedule_notify_session(Schedule *sch, PRTime session_end_time, unsigned int flags); +#define REPLICATION_SESSION_SUCCESS 0 + +/* In repl5_bos.c */ +typedef struct repl_bos Repl_Bos; + +/* In repl5_agmt.c */ +typedef struct repl5agmt Repl_Agmt; +#define TRANSPORT_FLAG_SSL 1 +#define TRANSPORT_FLAG_TLS 2 +#define BINDMETHOD_SIMPLE_AUTH 1 +#define BINDMETHOD_SSL_CLIENTAUTH 2 +Repl_Agmt *agmt_new_from_entry(Slapi_Entry *e); +Repl_Agmt *agmt_new_from_pblock(Slapi_PBlock *pb); +void agmt_delete(void **ra); +const Slapi_DN *agmt_get_dn_byref(const Repl_Agmt *ra); +int agmt_get_auto_initialize(const Repl_Agmt *ra); +long agmt_get_timeout(const Repl_Agmt *ra); +long agmt_get_busywaittime(const Repl_Agmt *ra); +long agmt_get_pausetime(const Repl_Agmt *ra); +int agmt_start(Repl_Agmt *ra); +int agmt_stop(Repl_Agmt *ra); +int agmt_replicate_now(Repl_Agmt *ra); +char *agmt_get_hostname(const Repl_Agmt *ra); +int agmt_get_port(const Repl_Agmt *ra); +PRUint32 agmt_get_transport_flags(const Repl_Agmt *ra); +char *agmt_get_binddn(const Repl_Agmt *ra); +struct berval *agmt_get_credentials(const Repl_Agmt *ra); +int agmt_get_bindmethod(const Repl_Agmt *ra); +Slapi_DN *agmt_get_replarea(const Repl_Agmt *ra); +int agmt_is_fractional(const Repl_Agmt *ra); +int agmt_is_fractional_attr(const Repl_Agmt *ra, const char *attrname); +int agmt_is_50_mm_protocol(const Repl_Agmt *ra); +int agmt_matches_name(const Repl_Agmt *ra, const Slapi_DN *name); +int agmt_replarea_matches(const Repl_Agmt *ra, const Slapi_DN *name); +int agmt_schedule_in_window_now(const Repl_Agmt *ra); +int agmt_set_schedule_from_entry( Repl_Agmt *ra, const Slapi_Entry *e ); +int agmt_set_timeout_from_entry( Repl_Agmt *ra, const Slapi_Entry *e ); +int agmt_set_busywaittime_from_entry( Repl_Agmt *ra, const Slapi_Entry *e ); +int agmt_set_pausetime_from_entry( Repl_Agmt *ra, const Slapi_Entry *e ); +int agmt_set_credentials_from_entry( Repl_Agmt *ra, const Slapi_Entry *e ); +int agmt_set_binddn_from_entry( Repl_Agmt *ra, const Slapi_Entry *e ); +int agmt_set_bind_method_from_entry( Repl_Agmt *ra, const Slapi_Entry *e ); +int agmt_set_transportinfo_from_entry( Repl_Agmt *ra, const Slapi_Entry *e ); +const char *agmt_get_long_name(const Repl_Agmt *ra); +int agmt_initialize_replica(const Repl_Agmt *agmt); +void agmt_replica_init_done (const Repl_Agmt *agmt); +void agmt_notify_change(Repl_Agmt *ra, Slapi_PBlock *pb); +Object* agmt_get_consumer_ruv (Repl_Agmt *ra); +ReplicaId agmt_get_consumer_rid ( Repl_Agmt *ra, void *conn ); +int agmt_set_consumer_ruv (Repl_Agmt *ra, RUV *ruv); +void agmt_update_consumer_ruv (Repl_Agmt *ra); +CSN* agmt_get_consumer_schema_csn (Repl_Agmt *ra); +void agmt_set_consumer_schema_csn (Repl_Agmt *ra, CSN *csn); +void agmt_set_last_update_in_progress (Repl_Agmt *ra, PRBool in_progress); +void agmt_set_last_update_start (Repl_Agmt *ra, time_t start_time); +void agmt_set_last_update_end (Repl_Agmt *ra, time_t end_time); +void agmt_set_last_update_status (Repl_Agmt *ra, int ldaprc, int replrc, const char *msg); +void agmt_set_update_in_progress (Repl_Agmt *ra, PRBool in_progress); +void agmt_set_last_init_start (Repl_Agmt *ra, time_t start_time); +void agmt_set_last_init_end (Repl_Agmt *ra, time_t end_time); +void agmt_set_last_init_status (Repl_Agmt *ra, int ldaprc, int replrc, const char *msg); +void agmt_inc_last_update_changecount (Repl_Agmt *ra, ReplicaId rid, int skipped); +void agmt_get_changecount_string (Repl_Agmt *ra, char *buf, int bufsize); + +typedef struct replica Replica; + +/* In repl5_agmtlist.c */ +int agmtlist_config_init(); +void agmtlist_shutdown(); +void agmtlist_notify_all(Slapi_PBlock *pb); +Object* agmtlist_get_first_agreement_for_replica (Replica *r); +Object* agmtlist_get_next_agreement_for_replica (Replica *r, Object *prev); + + +/* In repl5_backoff.c */ +typedef struct backoff_timer Backoff_Timer; +#define BACKOFF_FIXED 1 +#define BACKOFF_EXPONENTIAL 2 +#define BACKOFF_RANDOM 3 +Backoff_Timer *backoff_new(int timer_type, int initial_interval, int max_interval); +time_t backoff_reset(Backoff_Timer *bt, slapi_eq_fn_t callback, void *callback_data); +time_t backoff_step(Backoff_Timer *bt); +int backoff_expired(Backoff_Timer *bt, int margin); +void backoff_delete(Backoff_Timer **btp); + +/* In repl5_connection.c */ +typedef struct repl_connection Repl_Connection; +typedef enum +{ + CONN_OPERATION_SUCCESS, + CONN_OPERATION_FAILED, + CONN_NOT_CONNECTED, + CONN_SUPPORTS_DS5_REPL, + CONN_DOES_NOT_SUPPORT_DS5_REPL, + CONN_SCHEMA_UPDATED, + CONN_SCHEMA_NO_UPDATE_NEEDED, + CONN_LOCAL_ERROR, + CONN_BUSY, + CONN_SSL_NOT_ENABLED, + CONN_TIMEOUT +} ConnResult; +Repl_Connection *conn_new(Repl_Agmt *agmt); +ConnResult conn_connect(Repl_Connection *conn); +void conn_disconnect(Repl_Connection *conn); +void conn_delete(Repl_Connection *conn); +void conn_get_error(Repl_Connection *conn, int *operation, int *error); +ConnResult conn_send_add(Repl_Connection *conn, const char *dn, LDAPMod **attrs, + LDAPControl *update_control, LDAPControl ***returned_controls); +ConnResult conn_send_delete(Repl_Connection *conn, const char *dn, + LDAPControl *update_control, LDAPControl ***returned_controls); +ConnResult conn_send_modify(Repl_Connection *conn, const char *dn, LDAPMod **mods, + LDAPControl *update_control, LDAPControl ***returned_controls); +ConnResult conn_send_rename(Repl_Connection *conn, const char *dn, + const char *newrdn, const char *newparent, int deleteoldrdn, + LDAPControl *update_control, LDAPControl ***returned_controls); +ConnResult conn_send_extended_operation(Repl_Connection *conn, const char *extop_oid, + struct berval *payload, char **retoidp, struct berval **retdatap, + LDAPControl *update_control, LDAPControl ***returned_controls); +const char *conn_get_status(Repl_Connection *conn); +void conn_start_linger(Repl_Connection *conn); +void conn_cancel_linger(Repl_Connection *conn); +ConnResult conn_replica_supports_ds5_repl(Repl_Connection *conn); +ConnResult conn_read_entry_attribute(Repl_Connection *conn, const char *dn, char *type, + struct berval ***returned_bvals); +ConnResult conn_push_schema(Repl_Connection *conn, CSN **remotecsn); +void conn_set_timeout(Repl_Connection *conn, long timeout); +void conn_set_agmt_changed(Repl_Connection *conn); + +/* In repl5_protocol.c */ +typedef struct repl_protocol Repl_Protocol; +Repl_Protocol *prot_new(Repl_Agmt *agmt, int protocol_state); +void prot_start(Repl_Protocol *rp); +Repl_Agmt *prot_get_agreement(Repl_Protocol *rp); +/* initiate total protocol */ +void prot_initialize_replica(Repl_Protocol *rp); +/* stop protocol session in progress */ +void prot_stop(Repl_Protocol *rp); +void prot_delete(Repl_Protocol **rpp); +void prot_free(Repl_Protocol **rpp); +PRBool prot_set_active_protocol (Repl_Protocol *rp, PRBool total); +void prot_clear_active_protocol (Repl_Protocol *rp); +Repl_Connection *prot_get_connection(Repl_Protocol *rp); +void prot_resume(Repl_Protocol *rp, int wakeup_action); +void prot_notify_update(Repl_Protocol *rp); +void prot_notify_agmt_changed(Repl_Protocol *rp, char * agmt_name); +void prot_notify_window_opened (Repl_Protocol *rp); +void prot_notify_window_closed (Repl_Protocol *rp); +Object *prot_get_replica_object(Repl_Protocol *rp); +void prot_replicate_now(Repl_Protocol *rp); + +/* In repl5_replica.c */ +typedef enum +{ + REPLICA_TYPE_UNKNOWN, + REPLICA_TYPE_PRIMARY, + REPLICA_TYPE_READONLY, + REPLICA_TYPE_UPDATABLE, + REPLICA_TYPE_END +} ReplicaType; + +#define RUV_STORAGE_ENTRY_UNIQUEID "ffffffff-ffffffff-ffffffff-ffffffff" +#define START_ITERATION_ENTRY_UNIQUEID "00000000-00000000-00000000-00000000" +#define START_ITERATION_ENTRY_DN "cn=start iteration" + +typedef int (*FNEnumReplica) (Replica *r, void *arg); + +/* this function should be called to construct the replica object + from the data already in the DIT */ +Replica *replica_new(const Slapi_DN *root); +/* this function should be called to construct the replica object + during addition of the replica over LDAP */ +Replica *replica_new_from_entry (Slapi_Entry *e, char *errortext, PRBool is_add_operation); +void replica_destroy(void **arg); +PRBool replica_get_exclusive_access(Replica *r, PRBool *isInc, int connid, int opid, + const char *locking_purl, + char **current_purl); +void replica_relinquish_exclusive_access(Replica *r, int connid, int opid); +PRBool replica_get_tombstone_reap_active(const Replica *r); +const Slapi_DN *replica_get_root(const Replica *r); +const char *replica_get_name(const Replica *r); +ReplicaId replica_get_rid (const Replica *r); +void replica_set_rid (Replica *r, ReplicaId rid); +PRBool replica_is_initialized (const Replica *r); +Object *replica_get_ruv (const Replica *r); +/* replica now owns the RUV */ +void replica_set_ruv (Replica *r, RUV *ruv); +Object *replica_get_csngen (const Replica *r); +ReplicaType replica_get_type (const Replica *r); +void replica_set_type (Replica *r, ReplicaType type); +PRBool replica_is_legacy_consumer (const Replica *r); +void replica_set_legacy_consumer (Replica *r, PRBool legacy); +char *replica_get_legacy_purl (const Replica *r); +void replica_set_legacy_purl (Replica *r, const char *purl); +PRBool replica_is_updatedn (const Replica *r, const Slapi_DN *sdn); +void replica_set_updatedn (Replica *r, const Slapi_ValueSet *vs, int mod_op); +char *replica_get_generation (const Replica *r); +/* currently supported flags */ +#define REPLICA_LOG_CHANGES 0x1 /* enable change logging */ +PRBool replica_is_flag_set (const Replica *r, PRUint32 flag); +void replica_set_flag (Replica *r, PRUint32 flag, PRBool clear); +void replica_replace_flags (Replica *r, PRUint32 flags); +void replica_dump(Replica *r); +void replica_set_enabled (Replica *r, PRBool enable); +Object *replica_get_replica_from_dn (const Slapi_DN *dn); +void replica_update_ruv(Replica *replica, const CSN *csn, const char *replica_purl); +Object *replica_get_replica_for_op (Slapi_PBlock *pb); +/* the functions below manipulate replica hash */ +int replica_init_name_hash (); +void replica_destroy_name_hash (); +int replica_add_by_name (const char *name, Object *replica); +int replica_delete_by_name (const char *name); +Object* replica_get_by_name (const char *name); +void replica_flush(Replica *r); +void replica_get_referrals(const Replica *r, char ***referrals); +void replica_set_referrals(Replica *r,const Slapi_ValueSet *vs); +int replica_update_csngen_state (Replica *r, const RUV *ruv); +CSN *replica_get_purge_csn(const Replica *r); +int replica_log_ruv_elements (const Replica *r); +void replica_enumerate_replicas (FNEnumReplica fn, void *arg); +int replica_reload_ruv (Replica *r); +int replica_check_for_data_reload (Replica *r, void *arg); +/* the functions below manipulate replica dn hash */ +int replica_init_dn_hash (); +void replica_destroy_dn_hash (); +int replica_add_by_dn (const char *dn); +int replica_delete_by_dn (const char *dn); +int replica_is_being_configured (const char *dn); +const CSN * _get_deletion_csn(Slapi_Entry *e); +int legacy_consumer_init_referrals (Replica *r); +void consumer5_set_mapping_tree_state_for_replica(const Replica *r, RUV *supplierRuv); +Object *replica_get_for_backend (const char *be_name); +void replica_set_purge_delay (Replica *r, PRUint32 purge_delay); +void replica_set_tombstone_reap_interval (Replica *r, long interval); +void replica_update_ruv_consumer (Replica *r, RUV *supplier_ruv); +void replica_set_ruv_dirty (Replica *r); +void replica_write_ruv (Replica *r); +/* The functions below handles the state flag */ +/* Current internal state flags */ +/* The replica can be busy and not other flag, + * it means that the protocol has ended, but the work is not done yet. + * It happens on total protocol, the end protocol has been received, + * and the thread waits for import to finish + */ +#define REPLICA_IN_USE 1 /* The replica is busy */ +#define REPLICA_INCREMENTAL_IN_PROGRESS 2 /* Set only between start and stop inc */ +#define REPLICA_TOTAL_IN_PROGRESS 4 /* Set only between start and stop total */ +#define REPLICA_AGREEMENTS_DISABLED 8 /* Replica is offline */ +PRBool replica_is_state_flag_set(Replica *r, PRInt32 flag); +void replica_set_state_flag (Replica *r, PRUint32 flag, PRBool clear); +void replica_enable_replication (Replica *r); +void replica_disable_replication (Replica *r, Object *r_obj); +int replica_start_agreement(Replica *r, Repl_Agmt *ra); + +CSN* replica_generate_next_csn ( Slapi_PBlock *pb, const CSN *basecsn ); +int replica_get_attr ( Slapi_PBlock *pb, const char *type, void *value ); + +/* mapping tree extensions manipulation */ +void multimaster_mtnode_extension_init (); +void multimaster_mtnode_extension_destroy (); +void multimaster_mtnode_construct_replicas (); + +void multimaster_be_state_change (void *handle, char *be_name, int old_be_state, int new_be_state); + +/* In repl5_replica_config.c */ +int replica_config_init(); +void replica_config_destroy (); + +/* replutil.c */ +LDAPControl* create_managedsait_control (); +LDAPControl* create_backend_control(Slapi_DN *sdn); +void repl_set_mtn_state_and_referrals(const Slapi_DN *sdn, const char *mtn_state, + const RUV *ruv, char **ruv_referrals, + char **other_referrals); +void repl_set_repl_plugin_path(const char *path); + +/* repl5_updatedn_list.c */ +typedef void *ReplicaUpdateDNList; +typedef int (*FNEnumDN)(Slapi_DN *dn, void *arg); +ReplicaUpdateDNList replica_updatedn_list_new(const Slapi_Entry *entry); +void replica_updatedn_list_free(ReplicaUpdateDNList list); +void replica_updatedn_list_replace(ReplicaUpdateDNList list, const Slapi_ValueSet *vs); +void replica_updatedn_list_delete(ReplicaUpdateDNList list, const Slapi_ValueSet *vs); +void replica_updatedn_list_add(ReplicaUpdateDNList list, const Slapi_ValueSet *vs); +PRBool replica_updatedn_list_ismember(ReplicaUpdateDNList list, const Slapi_DN *dn); +char *replica_updatedn_list_to_string(ReplicaUpdateDNList list, const char *delimiter); +void replica_updatedn_list_enumerate(ReplicaUpdateDNList list, FNEnumDN fn, void *arg); + +/* enabling developper traces for MMR to understand the total/inc protocol state machines */ +#ifdef DEV_DEBUG +#define SLAPI_LOG_DEV_DEBUG SLAPI_LOG_FATAL +#define dev_debug(a) slapi_log_error(SLAPI_LOG_DEV_DEBUG, "DEV_DEBUG", "%s\n", a) +#else +#define dev_debug(a) +#endif + +void repl5_set_debug_timeout(const char *val); + +#endif /* _REPL5_H_ */ |