Merge branch 'v4-0-test' of git://git.samba.org/samba into 4-0-local

[jelmer/samba4-debian.git] / source / dsdb / repl / drepl_service.h

diff --git a/source/dsdb/repl/drepl_service.h b/source/dsdb/repl/drepl_service.h
index fb4fe2e50041e6a12d54be4b3fee80a11cbcee14..0847a016f73d9308a8e49334c410ab9f2b8b0937 100644 (file)
--- a/source/dsdb/repl/drepl_service.h
+++ b/source/dsdb/repl/drepl_service.h
@@ -6,7 +6,7 @@
     
    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; either version 2 of the License, or
+   the Free Software Foundation; either version 3 of the License, or
    (at your option) any later version.
    
    This program is distributed in the hope that it will be useful,
@@ -15,14 +15,98 @@
    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., 675 Mass Ave, Cambridge, MA 02139, USA.
+   along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
 */
 
 #ifndef _DSDB_REPL_DREPL_SERVICE_H_
 #define _DSDB_REPL_DREPL_SERVICE_H_
 
+#include "librpc/gen_ndr/ndr_drsuapi_c.h"
+
+struct dreplsrv_service;
+struct dreplsrv_partition;
+
+struct dreplsrv_drsuapi_connection {
+       /*
+        * this pipe pointer is also the indicator
+        * for a valid connection
+        */
+       struct dcerpc_pipe *pipe;
+
+       DATA_BLOB gensec_skey;
+       struct drsuapi_DsBindInfo28 remote_info28;
+       struct policy_handle bind_handle;
+};
+
+struct dreplsrv_out_connection {
+       struct dreplsrv_out_connection *prev, *next;
+
+       struct dreplsrv_service *service;
+
+       /*
+        * the binding for the outgoing connection
+        */
+       struct dcerpc_binding *binding;
+
+       /* the out going connection to the source dsa */
+       struct dreplsrv_drsuapi_connection *drsuapi;
+};
+
+struct dreplsrv_partition_source_dsa {
+       struct dreplsrv_partition_source_dsa *prev, *next;
+
+       struct dreplsrv_partition *partition;
+
+       /*
+        * the cached repsFrom value for this source dsa
+        *
+        * it needs to be updated after each DsGetNCChanges() call
+        * to the source dsa
+        *
+        * repsFrom1 == &_repsFromBlob.ctr.ctr1
+        */
+       struct repsFromToBlob _repsFromBlob;
+       struct repsFromTo1 *repsFrom1;
+
+       /* the reference to the source_dsa and its outgoing connection */
+       struct dreplsrv_out_connection *conn;
+};
+
+struct dreplsrv_partition {
+       struct dreplsrv_partition *prev, *next;
+
+       struct dreplsrv_service *service;
+
+       /* the dn of the partition */
+       struct ldb_dn *dn;
+       struct drsuapi_DsReplicaObjectIdentifier nc;
+
+       /* 
+        * uptodate vector needs to be updated before and after each DsGetNCChanges() call
+        *
+        * - before: we need to use our own invocationId together with our highestCommitedUsn
+        * - after: we need to merge in the remote uptodatevector, to avoid reading it again
+        */
+       struct replUpToDateVectorCtr2 uptodatevector;
+       struct drsuapi_DsReplicaCursorCtrEx uptodatevector_ex;
+
+       /*
+        * a linked list of all source dsa's we replicate from
+        */
+       struct dreplsrv_partition_source_dsa *sources;
+};
+
+struct dreplsrv_out_operation {
+       struct dreplsrv_out_operation *prev, *next;
+
+       struct dreplsrv_service *service;
+
+       struct dreplsrv_partition_source_dsa *source_dsa;
+
+       struct composite_context *creq;
+};
+
 struct dreplsrv_service {
        /* the whole drepl service is in one task */
        struct task_server *task;
@@ -41,6 +125,14 @@ struct dreplsrv_service {
         */
        struct ldb_context *samdb;
 
+       /* the guid of our NTDS Settings object, which never changes! */
+       struct GUID ntds_guid;
+       /*
+        * the struct holds the values used for outgoing DsBind() calls,
+        * so that we need to set them up only once
+        */
+       struct drsuapi_DsBindInfo28 bind_info28;
+
        /* some stuff for periodic processing */
        struct {
                /*
@@ -58,8 +150,26 @@ struct dreplsrv_service {
                struct timed_event *te;
        } periodic;
 
+       /*
+        * the list of partitions we need to replicate
+        */
+       struct dreplsrv_partition *partitions;
+
+       /*
+        * the list of cached connections
+        */
+       struct dreplsrv_out_connection *connections;
+
+       struct {        
+               /* the pointer to the current active operation */
+               struct dreplsrv_out_operation *current;
+
+               /* the list of pending operations */
+               struct dreplsrv_out_operation *pending;
+       } ops;
 };
 
+#include "dsdb/repl/drepl_out_helpers.h"
 #include "dsdb/repl/drepl_service_proto.h"
 
 #endif /* _DSDB_REPL_DREPL_SERVICE_H_ */