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/>.
23 #include "dsdb/samdb/samdb.h"
24 #include "auth/auth.h"
25 #include "smbd/service.h"
26 #include "lib/events/events.h"
27 #include "lib/messaging/irpc.h"
28 #include "dsdb/repl/drepl_service.h"
29 #include "lib/ldb/include/ldb_errors.h"
30 #include "../lib/util/dlinklist.h"
31 #include "librpc/gen_ndr/ndr_misc.h"
32 #include "librpc/gen_ndr/ndr_drsuapi.h"
33 #include "librpc/gen_ndr/ndr_drsblobs.h"
34 #include "param/param.h"
36 WERROR
dreplsrv_load_partitions(struct dreplsrv_service
*s
)
39 struct ldb_dn
*basedn
;
41 struct ldb_message_element
*el
;
42 static const char *attrs
[] = { "hasMasterNCs", NULL
};
46 basedn
= samdb_ntds_settings_dn(s
->samdb
);
47 W_ERROR_HAVE_NO_MEMORY(basedn
);
49 ret
= ldb_search(s
->samdb
, s
, &r
, basedn
, LDB_SCOPE_BASE
, attrs
,
51 if (ret
!= LDB_SUCCESS
) {
53 } else if (r
->count
!= 1) {
58 el
= ldb_msg_find_element(r
->msgs
[0], "hasMasterNCs");
63 for (i
=0; el
&& i
< el
->num_values
; i
++) {
64 const char *v
= (const char *)el
->values
[i
].data
;
66 struct dreplsrv_partition
*p
;
68 pdn
= ldb_dn_new(s
, s
->samdb
, v
);
69 if (!ldb_dn_validate(pdn
)) {
73 p
= talloc_zero(s
, struct dreplsrv_partition
);
74 W_ERROR_HAVE_NO_MEMORY(p
);
76 p
->dn
= talloc_steal(p
, pdn
);
78 DLIST_ADD(s
->partitions
, p
);
80 DEBUG(2, ("dreplsrv_partition[%s] loaded\n", v
));
85 status
= dreplsrv_refresh_partitions(s
);
86 W_ERROR_NOT_OK_RETURN(status
);
91 WERROR
dreplsrv_out_connection_attach(struct dreplsrv_service
*s
,
92 const struct repsFromTo1
*rft
,
93 struct dreplsrv_out_connection
**_conn
)
95 struct dreplsrv_out_connection
*cur
, *conn
= NULL
;
98 if (!rft
->other_info
) {
102 if (!rft
->other_info
->dns_name
) {
106 hostname
= rft
->other_info
->dns_name
;
108 for (cur
= s
->connections
; cur
; cur
= cur
->next
) {
109 if (strcmp(cur
->binding
->host
, hostname
) == 0) {
119 conn
= talloc_zero(s
, struct dreplsrv_out_connection
);
120 W_ERROR_HAVE_NO_MEMORY(conn
);
124 binding_str
= talloc_asprintf(conn
, "ncacn_ip_tcp:%s[krb5,seal]",
126 W_ERROR_HAVE_NO_MEMORY(binding_str
);
127 nt_status
= dcerpc_parse_binding(conn
, binding_str
, &conn
->binding
);
128 talloc_free(binding_str
);
129 if (!NT_STATUS_IS_OK(nt_status
)) {
130 return ntstatus_to_werror(nt_status
);
133 DLIST_ADD_END(s
->connections
, conn
, struct dreplsrv_out_connection
*);
135 DEBUG(2,("dreplsrv_out_connection_attach(%s): create\n", conn
->binding
->host
));
137 DEBUG(2,("dreplsrv_out_connection_attach(%s): attach\n", conn
->binding
->host
));
144 static WERROR
dreplsrv_partition_add_source_dsa(struct dreplsrv_service
*s
,
145 struct dreplsrv_partition
*p
,
146 const struct ldb_val
*val
)
149 enum ndr_err_code ndr_err
;
150 struct dreplsrv_partition_source_dsa
*source
, *s2
;
152 source
= talloc_zero(p
, struct dreplsrv_partition_source_dsa
);
153 W_ERROR_HAVE_NO_MEMORY(source
);
155 ndr_err
= ndr_pull_struct_blob(val
, source
,
156 &source
->_repsFromBlob
,
157 (ndr_pull_flags_fn_t
)ndr_pull_repsFromToBlob
);
158 if (!NDR_ERR_CODE_IS_SUCCESS(ndr_err
)) {
159 NTSTATUS nt_status
= ndr_map_error2ntstatus(ndr_err
);
161 return ntstatus_to_werror(nt_status
);
163 /* NDR_PRINT_DEBUG(repsFromToBlob, &source->_repsFromBlob); */
164 if (source
->_repsFromBlob
.version
!= 1) {
166 return WERR_DS_DRA_INTERNAL_ERROR
;
169 source
->partition
= p
;
170 source
->repsFrom1
= &source
->_repsFromBlob
.ctr
.ctr1
;
172 status
= dreplsrv_out_connection_attach(s
, source
->repsFrom1
, &source
->conn
);
173 W_ERROR_NOT_OK_RETURN(status
);
175 /* remove any existing source with the same GUID */
176 for (s2
=p
->sources
; s2
; s2
=s2
->next
) {
177 if (GUID_compare(&s2
->repsFrom1
->source_dsa_obj_guid
,
178 &source
->repsFrom1
->source_dsa_obj_guid
) == 0) {
179 talloc_free(s2
->repsFrom1
->other_info
);
180 *s2
->repsFrom1
= *source
->repsFrom1
;
181 talloc_steal(s2
, s2
->repsFrom1
->other_info
);
187 DLIST_ADD_END(p
->sources
, source
, struct dreplsrv_partition_source_dsa
*);
192 convert from one udv format to the other
194 static WERROR
udv_convert(TALLOC_CTX
*mem_ctx
,
195 const struct replUpToDateVectorCtr2
*udv
,
196 struct drsuapi_DsReplicaCursorCtrEx
*udv_ex
)
201 udv_ex
->reserved1
= 0;
202 udv_ex
->reserved2
= 0;
203 udv_ex
->count
= udv
->count
;
204 udv_ex
->cursors
= talloc_array(mem_ctx
, struct drsuapi_DsReplicaCursor
, udv
->count
);
205 W_ERROR_HAVE_NO_MEMORY(udv_ex
->cursors
);
207 for (i
=0; i
<udv
->count
; i
++) {
208 udv_ex
->cursors
[i
].source_dsa_invocation_id
= udv
->cursors
[i
].source_dsa_invocation_id
;
209 udv_ex
->cursors
[i
].highest_usn
= udv
->cursors
[i
].highest_usn
;
216 static WERROR
dreplsrv_refresh_partition(struct dreplsrv_service
*s
,
217 struct dreplsrv_partition
*p
)
220 struct dom_sid
*nc_sid
;
221 struct ldb_message_element
*orf_el
= NULL
;
222 struct ldb_result
*r
;
225 TALLOC_CTX
*mem_ctx
= talloc_new(p
);
226 static const char *attrs
[] = {
233 DEBUG(2, ("dreplsrv_refresh_partition(%s)\n",
234 ldb_dn_get_linearized(p
->dn
)));
236 ret
= ldb_search(s
->samdb
, mem_ctx
, &r
, p
->dn
, LDB_SCOPE_BASE
, attrs
,
238 if (ret
!= LDB_SUCCESS
) {
239 talloc_free(mem_ctx
);
243 talloc_free(discard_const(p
->nc
.dn
));
245 p
->nc
.dn
= ldb_dn_alloc_linearized(p
, p
->dn
);
246 W_ERROR_HAVE_NO_MEMORY(p
->nc
.dn
);
247 p
->nc
.guid
= samdb_result_guid(r
->msgs
[0], "objectGUID");
248 nc_sid
= samdb_result_dom_sid(p
, r
->msgs
[0], "objectSid");
254 talloc_free(p
->uptodatevector
.cursors
);
255 talloc_free(p
->uptodatevector_ex
.cursors
);
256 ZERO_STRUCT(p
->uptodatevector
);
257 ZERO_STRUCT(p
->uptodatevector_ex
);
259 ret
= dsdb_load_udv_v2(s
->samdb
, p
->dn
, p
, &p
->uptodatevector
.cursors
, &p
->uptodatevector
.count
);
260 if (ret
== LDB_SUCCESS
) {
261 status
= udv_convert(p
, &p
->uptodatevector
, &p
->uptodatevector_ex
);
262 W_ERROR_NOT_OK_RETURN(status
);
265 orf_el
= ldb_msg_find_element(r
->msgs
[0], "repsFrom");
267 for (i
=0; i
< orf_el
->num_values
; i
++) {
268 status
= dreplsrv_partition_add_source_dsa(s
, p
, &orf_el
->values
[i
]);
269 W_ERROR_NOT_OK_RETURN(status
);
273 talloc_free(mem_ctx
);
278 WERROR
dreplsrv_refresh_partitions(struct dreplsrv_service
*s
)
281 struct dreplsrv_partition
*p
;
283 for (p
= s
->partitions
; p
; p
= p
->next
) {
284 status
= dreplsrv_refresh_partition(s
, p
);
285 W_ERROR_NOT_OK_RETURN(status
);