2 Unix SMB/CIFS mplementation.
3 DSDB replication service
5 Copyright (C) Stefan Metzmacher 2007
7 This program is free software; you can redistribute it and/or modify
8 it under the terms of the GNU General Public License as published by
9 the Free Software Foundation; either version 3 of the License, or
10 (at your option) any later version.
12 This program is distributed in the hope that it will be useful,
13 but WITHOUT ANY WARRANTY; without even the implied warranty of
14 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 GNU General Public License for more details.
17 You should have received a copy of the GNU General Public License
18 along with this program. If not, see <http://www.gnu.org/licenses/>.
22 #ifndef _DSDB_REPL_DREPL_SERVICE_H_
23 #define _DSDB_REPL_DREPL_SERVICE_H_
25 #include "librpc/gen_ndr/ndr_drsuapi_c.h"
27 struct dreplsrv_service
;
28 struct dreplsrv_partition
;
30 struct dreplsrv_drsuapi_connection
{
32 * this pipe pointer is also the indicator
33 * for a valid connection
35 struct dcerpc_pipe
*pipe
;
36 struct dcerpc_binding_handle
*drsuapi_handle
;
38 DATA_BLOB gensec_skey
;
39 struct drsuapi_DsBindInfo28 remote_info28
;
40 struct policy_handle bind_handle
;
43 struct dreplsrv_out_connection
{
44 struct dreplsrv_out_connection
*prev
, *next
;
46 struct dreplsrv_service
*service
;
49 * the binding for the outgoing connection
51 struct dcerpc_binding
*binding
;
53 /* the out going connection to the source dsa */
54 struct dreplsrv_drsuapi_connection
*drsuapi
;
56 /* used to force the GC principal name */
57 const char *principal_name
;
60 struct dreplsrv_partition_source_dsa
{
61 struct dreplsrv_partition_source_dsa
*prev
, *next
;
63 struct dreplsrv_partition
*partition
;
66 * the cached repsFrom value for this source dsa
68 * it needs to be updated after each DsGetNCChanges() call
71 * repsFrom1 == &_repsFromBlob.ctr.ctr1
73 struct repsFromToBlob _repsFromBlob
;
74 struct repsFromTo1
*repsFrom1
;
76 /* the last uSN when we sent a notify */
79 /* the reference to the source_dsa and its outgoing connection */
80 struct dreplsrv_out_connection
*conn
;
83 struct dreplsrv_partition
{
84 struct dreplsrv_partition
*prev
, *next
;
86 struct dreplsrv_service
*service
;
88 /* the dn of the partition */
90 struct drsuapi_DsReplicaObjectIdentifier nc
;
93 * uptodate vector needs to be updated before and after each DsGetNCChanges() call
95 * - before: we need to use our own invocationId together with our highestCommitedUsn
96 * - after: we need to merge in the remote uptodatevector, to avoid reading it again
98 struct replUpToDateVectorCtr2 uptodatevector
;
99 struct drsuapi_DsReplicaCursorCtrEx uptodatevector_ex
;
102 * a linked list of all source dsa's we replicate from
104 struct dreplsrv_partition_source_dsa
*sources
;
107 * a linked list of all source dsa's we will notify,
108 * that are not also in sources
110 struct dreplsrv_partition_source_dsa
*notifies
;
115 typedef void (*dreplsrv_extended_callback_t
)(struct dreplsrv_service
*,
117 enum drsuapi_DsExtendedError
,
120 struct dreplsrv_out_operation
{
121 struct dreplsrv_out_operation
*prev
, *next
;
122 time_t schedule_time
;
124 struct dreplsrv_service
*service
;
126 struct dreplsrv_partition_source_dsa
*source_dsa
;
128 /* replication options - currently used by DsReplicaSync */
130 enum drsuapi_DsExtendedOperation extended_op
;
132 enum drsuapi_DsExtendedError extended_ret
;
133 dreplsrv_extended_callback_t callback
;
137 struct dreplsrv_notify_operation
{
138 struct dreplsrv_notify_operation
*prev
, *next
;
139 time_t schedule_time
;
141 struct dreplsrv_service
*service
;
144 struct dreplsrv_partition_source_dsa
*source_dsa
;
146 uint32_t replica_flags
;
149 struct dreplsrv_service
{
150 /* the whole drepl service is in one task */
151 struct task_server
*task
;
153 /* the time the service was started */
154 struct timeval startup_time
;
157 * system session info
158 * with machine account credentials
160 struct auth_session_info
*system_session_info
;
163 * a connection to the local samdb
165 struct ldb_context
*samdb
;
167 /* the guid of our NTDS Settings object, which never changes! */
168 struct GUID ntds_guid
;
170 * the struct holds the values used for outgoing DsBind() calls,
171 * so that we need to set them up only once
173 struct drsuapi_DsBindInfo28 bind_info28
;
175 /* some stuff for periodic processing */
178 * the interval between to periodic runs
183 * the timestamp for the next event,
184 * this is the timstamp passed to event_add_timed()
186 struct timeval next_event
;
188 /* here we have a reference to the timed event the schedules the periodic stuff */
189 struct tevent_timer
*te
;
192 /* some stuff for notify processing */
195 * the interval between notify runs
200 * the timestamp for the next event,
201 * this is the timstamp passed to event_add_timed()
203 struct timeval next_event
;
205 /* here we have a reference to the timed event the schedules the notifies */
206 struct tevent_timer
*te
;
210 * the list of partitions we need to replicate
212 struct dreplsrv_partition
*partitions
;
215 * the list of cached connections
217 struct dreplsrv_out_connection
*connections
;
220 /* the pointer to the current active operation */
221 struct dreplsrv_out_operation
*current
;
223 /* the list of pending operations */
224 struct dreplsrv_out_operation
*pending
;
226 /* the list of pending notify operations */
227 struct dreplsrv_notify_operation
*notifies
;
229 /* an active notify operation */
230 struct dreplsrv_notify_operation
*n_current
;
233 bool rid_alloc_in_progress
;
238 #include "lib/messaging/irpc.h"
239 #include "dsdb/repl/drepl_out_helpers.h"
240 #include "dsdb/repl/drepl_service_proto.h"
242 #endif /* _DSDB_REPL_DREPL_SERVICE_H_ */