Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Ticket 47388 - RFE to implement RFC4533 -ver2
Bug Description: Request to implement RFC4533 in ds 389 Fix Description: This fix impements the content synchronization as a directory server plugin, using the retro changelog to provide synchronization with cookies. The design is presented here: http://port389.org/wiki/Content_synchronization_plugin https://fedorahosted.org/389/ticket/47388 Reviewed by: nkinder, Thanks
- Loading branch information
Showing
16 changed files
with
2,799 additions
and
10 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,22 @@ | ||
| dn: cn=Content Synchronization,cn=plugins,cn=config | ||
| objectclass: top | ||
| objectclass: nsSlapdPlugin | ||
| cn: Content Synchronization | ||
| nsslapd-pluginpath: libcontentsync-plugin | ||
| nsslapd-plugininitfunc: sync_init | ||
| nsslapd-plugintype: object | ||
| nsslapd-pluginenabled: off | ||
| nsslapd-plugin-depends-on-named: Retro Changelog Plugin | ||
| # these will be replaced when the server loads the plugin | ||
| nsslapd-pluginId: ID | ||
| nsslapd-pluginVersion: PACKAGE_VERSION | ||
| nsslapd-pluginVendor: VENDOR | ||
| nsslapd-pluginDescription: DESC | ||
|
|
||
| dn: oid=1.3.6.1.4.1.4203.1.9.1.1,cn=features,cn=config | ||
| objectClass: top | ||
| objectClass: directoryServerFeature | ||
| oid: 1.3.6.1.4.1.4203.1.9.1.1 | ||
| cn: Sync Request Control | ||
| aci: (targetattr != "aci")(version 3.0; acl "Sync Request Control"; allow( read | ||
| , search ) userdn = "ldap:///all";) |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,196 @@ | ||
| /** BEGIN COPYRIGHT BLOCK | ||
| * This Program is free software; you can redistribute it and/or modify it under | ||
| * the terms of the GNU General Public License as published by the Free Software | ||
| * Foundation; version 2 of the License. | ||
| * | ||
| * This Program is distributed in the hope that it will be useful, but WITHOUT | ||
| * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS | ||
| * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details. | ||
| * | ||
| * You should have received a copy of the GNU General Public License along with | ||
| * this Program; if not, write to the Free Software Foundation, Inc., 59 Temple | ||
| * Place, Suite 330, Boston, MA 02111-1307 USA. | ||
| * | ||
| * In addition, as a special exception, Red Hat, Inc. gives You the additional | ||
| * right to link the code of this Program with code not covered under the GNU | ||
| * General Public License ("Non-GPL Code") and to distribute linked combinations | ||
| * including the two, subject to the limitations in this paragraph. Non-GPL Code | ||
| * permitted under this exception must only link to the code of this Program | ||
| * through those well defined interfaces identified in the file named EXCEPTION | ||
| * found in the source code files (the "Approved Interfaces"). The files of | ||
| * Non-GPL Code may instantiate templates or use macros or inline functions from | ||
| * the Approved Interfaces without causing the resulting work to be covered by | ||
| * the GNU General Public License. Only Red Hat, Inc. may make changes or | ||
| * additions to the list of Approved Interfaces. You must obey the GNU General | ||
| * Public License in all respects for all of the Program code and other code used | ||
| * in conjunction with the Program except the Non-GPL Code covered by this | ||
| * exception. If you modify this file, you may extend this exception to your | ||
| * version of the file, but you are not obligated to do so. If you do not wish to | ||
| * provide this exception without modification, you must delete this exception | ||
| * statement from your version and license this file solely under the GPL without | ||
| * exception. | ||
| * | ||
| * | ||
| * Copyright (C) 2013 Red Hat, Inc. | ||
| * All rights reserved. | ||
| * END COPYRIGHT BLOCK **/ | ||
|
|
||
| #ifdef HAVE_CONFIG_H | ||
| # include <config.h> | ||
| #endif | ||
|
|
||
| /** | ||
| * LDAP content synchronization plug-in | ||
| */ | ||
|
|
||
| #include <stdio.h> | ||
| #include <string.h> | ||
| #include "slapi-plugin.h" | ||
|
|
||
| #define PLUGIN_NAME "content-sync-plugin" | ||
|
|
||
| #define SYNC_PLUGIN_SUBSYSTEM "content-sync-plugin" | ||
| #define SYNC_PREOP_DESC "content-sync-preop-subplugin" | ||
| #define SYNC_POSTOP_DESC "content-sync-postop-subplugin" | ||
|
|
||
| #define OP_FLAG_SYNC_PERSIST 0x01 | ||
|
|
||
| #define E_SYNC_REFRESH_REQUIRED 0x1000 | ||
|
|
||
| #define CL_ATTR_CHANGENUMBER "changenumber" | ||
| #define CL_ATTR_ENTRYDN "targetDn" | ||
| #define CL_ATTR_UNIQUEID "targetUniqueId" | ||
| #define CL_ATTR_CHGTYPE "changetype" | ||
| #define CL_ATTR_NEWSUPERIOR "newsuperior" | ||
| #define CL_SRCH_BASE "cn=changelog" | ||
|
|
||
| typedef struct sync_cookie { | ||
| char *cookie_client_signature; | ||
| char *cookie_server_signature; | ||
| int cookie_change_info; | ||
| } Sync_Cookie; | ||
|
|
||
| typedef struct sync_update { | ||
| char *upd_uuid; | ||
| int upd_chgtype; | ||
| Slapi_Entry *upd_e; | ||
| } Sync_UpdateNode; | ||
|
|
||
| typedef struct sync_callback { | ||
| Slapi_PBlock *orig_pb; | ||
| int changenr; | ||
| int change_start; | ||
| int cb_err; | ||
| Sync_UpdateNode *cb_updates; | ||
| } Sync_CallBackData; | ||
|
|
||
| int sync_register_operation_extension(void); | ||
|
|
||
| int sync_srch_refresh_pre_search(Slapi_PBlock *pb); | ||
| int sync_srch_refresh_post_search(Slapi_PBlock *pb); | ||
| int sync_srch_refresh_pre_entry(Slapi_PBlock *pb); | ||
| int sync_srch_refresh_pre_result(Slapi_PBlock *pb); | ||
| int sync_del_persist_post_op(Slapi_PBlock *pb); | ||
| int sync_mod_persist_post_op(Slapi_PBlock *pb); | ||
| int sync_modrdn_persist_post_op(Slapi_PBlock *pb); | ||
| int sync_add_persist_post_op(Slapi_PBlock *pb); | ||
|
|
||
| int sync_parse_control_value( struct berval *psbvp, ber_int_t *mode, int *reload, char **cookie ); | ||
| int sync_create_state_control( Slapi_Entry *e, LDAPControl **ctrlp, int type, Sync_Cookie *cookie); | ||
| int sync_create_sync_done_control( LDAPControl **ctrlp, int refresh, char *cookie); | ||
| int sync_intermediate_msg (Slapi_PBlock *pb, int tag, Sync_Cookie *cookie, char **uuids); | ||
| int sync_result_msg (Slapi_PBlock *pb, Sync_Cookie *cookie); | ||
| int sync_result_err (Slapi_PBlock *pb, int rc, char *msg); | ||
|
|
||
| Sync_Cookie *sync_cookie_create (Slapi_PBlock *pb); | ||
| void sync_cookie_update (Sync_Cookie *cookie, Slapi_Entry *ec); | ||
| Sync_Cookie *sync_cookie_parse (char *cookie); | ||
| int sync_cookie_isvalid (Sync_Cookie *testcookie, Sync_Cookie *refcookie); | ||
| void sync_cookie_free (Sync_Cookie **freecookie); | ||
| char * sync_cookie2str(Sync_Cookie *cookie); | ||
| int sync_number2int(char *nrstr); | ||
| char *sync_nsuniqueid2uuid(const char *nsuniqueid); | ||
|
|
||
| int sync_is_active (Slapi_Entry *e, Slapi_PBlock *pb); | ||
| int sync_is_active_scope (const Slapi_DN *dn, Slapi_PBlock *pb); | ||
|
|
||
| int sync_refresh_update_content(Slapi_PBlock *pb, Sync_Cookie *client_cookie, Sync_Cookie *session_cookie); | ||
| int sync_refresh_initial_content(Slapi_PBlock *pb, int persist, Sync_Cookie *session_cookie); | ||
| int sync_read_entry_from_changelog( Slapi_Entry *cl_entry, void *cb_data); | ||
| int sync_send_entry_from_changelog( Slapi_PBlock *pb, int chg_req, char *uniqueid); | ||
| void sync_send_deleted_entries (Slapi_PBlock *pb, Sync_UpdateNode *upd, int chg_count, Sync_Cookie *session_cookie); | ||
| void sync_send_modified_entries (Slapi_PBlock *pb, Sync_UpdateNode *upd, int chg_count); | ||
|
|
||
| int sync_persist_initialize (int argc, char **argv); | ||
| PRThread *sync_persist_add (Slapi_PBlock *pb); | ||
| int sync_persist_startup (PRThread *tid, Sync_Cookie *session_cookie); | ||
| int sync_persist_terminate_all (); | ||
| int sync_persist_terminate (PRThread *tid); | ||
|
|
||
| Slapi_PBlock *sync_pblock_copy(Slapi_PBlock *src); | ||
|
|
||
| /* prototype for functions not in slapi-plugin.h */ | ||
| Slapi_ComponentId *plugin_get_default_component_id(); | ||
|
|
||
|
|
||
| /* | ||
| * Structures to handle the persitent phase of | ||
| * Content Synchronization Requests | ||
| * | ||
| * A queue of entries being to be sent by a particular persistent | ||
| * sync thread | ||
| * | ||
| * will be created in post op plugins | ||
| */ | ||
| typedef struct sync_queue_node { | ||
| Slapi_Entry *sync_entry; | ||
| LDAPControl *pe_ctrls[2]; /* XXX ?? XXX */ | ||
| struct sync_queue_node *sync_next; | ||
| int sync_chgtype; | ||
| } SyncQueueNode; | ||
|
|
||
| /* | ||
| * Information about a single sync search | ||
| * | ||
| * will be created when a content sync control with | ||
| * mode == 3 is decoded | ||
| */ | ||
| typedef struct sync_request { | ||
| Slapi_PBlock *req_pblock; | ||
| PRLock *req_lock; | ||
| PRThread *req_tid; | ||
| char *req_orig_base; | ||
| Slapi_Filter *req_filter; | ||
| PRInt32 req_complete; | ||
| Sync_Cookie *req_cookie; | ||
| SyncQueueNode *ps_eq_head; | ||
| SyncQueueNode *ps_eq_tail; | ||
| int req_active; | ||
| struct sync_request *req_next; | ||
| } SyncRequest; | ||
|
|
||
| /* | ||
| * A list of established persistent synchronization searches. | ||
| * | ||
| * will be initialized at plugin initialization | ||
| */ | ||
| #define SYNC_MAX_CONCURRENT 10 | ||
| typedef struct sync_request_list { | ||
| Slapi_RWLock *sync_req_rwlock; /* R/W lock struct to serialize access */ | ||
| SyncRequest *sync_req_head; /* Head of list */ | ||
| PRLock *sync_req_cvarlock; /* Lock for cvar */ | ||
| PRCondVar *sync_req_cvar; /* ps threads sleep on this */ | ||
| int sync_req_max_persist; | ||
| int sync_req_cur_persist; | ||
| } SyncRequestList; | ||
|
|
||
| #define SYNC_FLAG_ADD_STATE_CTRL 0x01 | ||
| #define SYNC_FLAG_ADD_DONE_CTRL 0x02 | ||
| #define SYNC_FLAG_NO_RESULT 0x04 | ||
| #define SYNC_FLAG_SEND_INTERMEDIATE 0x08 | ||
|
|
||
| typedef struct sync_op_info { | ||
| int send_flag; /* hint for preop plugins what to send */ | ||
| Sync_Cookie *cookie; /* cookie to add in control */ | ||
| } SyncOpInfo; | ||
|
|
Oops, something went wrong.