2 Unix SMB/CIFS mplementation.
3 Helper functions for applying replicated objects
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 2 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, write to the Free Software
19 Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
24 #include "dsdb/samdb/samdb.h"
25 #include "lib/ldb/include/ldb_errors.h"
26 #include "lib/util/dlinklist.h"
27 #include "librpc/gen_ndr/ndr_misc.h"
28 #include "librpc/gen_ndr/ndr_drsuapi.h"
29 #include "librpc/gen_ndr/ndr_drsblobs.h"
31 static WERROR dsdb_convert_object(struct ldb_context *ldb,
32 const struct dsdb_schema *schema,
33 struct dsdb_extended_replicated_objects *ctr,
34 const struct drsuapi_DsReplicaObjectListItemEx *in,
36 struct dsdb_extended_replicated_object *out)
41 struct ldb_message *msg;
42 struct replPropertyMetaDataBlob md;
43 struct ldb_val md_value;
44 struct drsuapi_DsReplicaObjMetaDataCtr mdc;
45 struct ldb_val guid_value;
46 NTTIME whenChanged = 0;
48 const char *whenChanged_s;
50 const struct ldb_val *rdn_value;
51 const struct dsdb_attribute *rdn_attr;
53 struct drsuapi_DsReplicaAttribute *name_a;
54 struct drsuapi_DsReplicaMetaData *name_d;
55 struct replPropertyMetaData1 *rdn_m;
56 struct drsuapi_DsReplicaObjMetaData *rdn_mc;
59 if (!in->object.identifier) {
63 if (!in->object.identifier->dn || !in->object.identifier->dn[0]) {
67 msg = ldb_msg_new(mem_ctx);
68 W_ERROR_HAVE_NO_MEMORY(msg);
70 msg->dn = ldb_dn_new(msg, ldb, in->object.identifier->dn);
71 W_ERROR_HAVE_NO_MEMORY(msg->dn);
73 rdn_name = ldb_dn_get_rdn_name(msg->dn);
74 rdn_attr = dsdb_attribute_by_lDAPDisplayName(schema, rdn_name);
78 rdn_attid = rdn_attr->attributeID_id;
79 rdn_value = ldb_dn_get_rdn_val(msg->dn);
81 msg->num_elements = in->object.attribute_ctr.num_attributes;
82 msg->elements = talloc_array(msg, struct ldb_message_element,
84 W_ERROR_HAVE_NO_MEMORY(msg->elements);
86 for (i=0; i < msg->num_elements; i++) {
87 status = dsdb_attribute_drsuapi_to_ldb(schema,
88 &in->object.attribute_ctr.attributes[i],
89 msg->elements, &msg->elements[i]);
90 W_ERROR_NOT_OK_RETURN(status);
93 if (in->object.attribute_ctr.num_attributes != 0 && !in->meta_data_ctr) {
97 if (in->object.attribute_ctr.num_attributes != in->meta_data_ctr->count) {
103 md.ctr.ctr1.count = in->meta_data_ctr->count;
104 md.ctr.ctr1.reserved = 0;
105 md.ctr.ctr1.array = talloc_array(mem_ctx,
106 struct replPropertyMetaData1,
107 md.ctr.ctr1.count + 1);
108 W_ERROR_HAVE_NO_MEMORY(md.ctr.ctr1.array);
110 mdc.count = in->meta_data_ctr->count;
112 mdc.array = talloc_array(mem_ctx,
113 struct drsuapi_DsReplicaObjMetaData,
115 W_ERROR_HAVE_NO_MEMORY(mdc.array);
117 for (i=0; i < in->meta_data_ctr->count; i++) {
118 struct drsuapi_DsReplicaAttribute *a;
119 struct drsuapi_DsReplicaMetaData *d;
120 struct replPropertyMetaData1 *m;
121 struct drsuapi_DsReplicaObjMetaData *mc;
123 a = &in->object.attribute_ctr.attributes[i];
124 d = &in->meta_data_ctr->meta_data[i];
125 m = &md.ctr.ctr1.array[i];
129 m->version = d->version;
130 m->orginating_time = d->orginating_time;
131 m->orginating_invocation_id = d->orginating_invocation_id;
132 m->orginating_usn = d->orginating_usn;
135 mc->attribute_name = dsdb_lDAPDisplayName_by_id(schema, a->attid);
136 mc->version = d->version;
137 mc->originating_last_changed = d->orginating_time;
138 mc->originating_dsa_invocation_id= d->orginating_invocation_id;
139 mc->originating_usn = d->orginating_usn;
142 if (d->orginating_time > whenChanged) {
143 whenChanged = d->orginating_time;
146 if (a->attid == DRSUAPI_ATTRIBUTE_name) {
149 rdn_m = &md.ctr.ctr1.array[md.ctr.ctr1.count];
150 rdn_mc = &mdc.array[mdc.count];
158 ret = ldb_msg_add_value(msg, rdn_attr->lDAPDisplayName, rdn_value, NULL);
159 if (ret != LDB_SUCCESS) {
163 nt_status = ndr_push_struct_blob(&guid_value, msg, &in->object.identifier->guid,
164 (ndr_push_flags_fn_t)ndr_push_GUID);
165 if (!NT_STATUS_IS_OK(nt_status)) {
166 return ntstatus_to_werror(nt_status);
168 ret = ldb_msg_add_value(msg, "objectGUID", &guid_value, NULL);
169 if (ret != LDB_SUCCESS) {
173 whenChanged_t = nt_time_to_unix(whenChanged);
174 whenChanged_s = ldb_timestring(msg, whenChanged_t);
175 W_ERROR_HAVE_NO_MEMORY(whenChanged_s);
176 ret = ldb_msg_add_string(msg, "whenChanged", whenChanged_s);
177 if (ret != LDB_SUCCESS) {
181 rdn_m->attid = rdn_attid;
182 rdn_m->version = name_d->version;
183 rdn_m->orginating_time = name_d->orginating_time;
184 rdn_m->orginating_invocation_id = name_d->orginating_invocation_id;
185 rdn_m->orginating_usn = name_d->orginating_usn;
186 rdn_m->local_usn = 0;
189 rdn_mc->attribute_name = rdn_attr->lDAPDisplayName;
190 rdn_mc->version = name_d->version;
191 rdn_mc->originating_last_changed = name_d->orginating_time;
192 rdn_mc->originating_dsa_invocation_id = name_d->orginating_invocation_id;
193 rdn_mc->originating_usn = name_d->orginating_usn;
194 rdn_mc->local_usn = 0;
197 nt_status = ndr_push_struct_blob(&md_value, msg, &md,
198 (ndr_push_flags_fn_t)ndr_push_replPropertyMetaDataBlob);
199 if (!NT_STATUS_IS_OK(nt_status)) {
200 return ntstatus_to_werror(nt_status);
202 ret = ldb_msg_add_value(msg, "replPropertyMetaData", &md_value, NULL);
203 if (ret != LDB_SUCCESS) {
207 if (lp_parm_bool(-1, "become dc", "dump objects", False)) {
208 struct ldb_ldif ldif;
209 fprintf(stdout, "#\n");
210 ldif.changetype = LDB_CHANGETYPE_NONE;
212 ldb_ldif_write_file(ldb, stdout, &ldif);
213 NDR_PRINT_DEBUG(drsuapi_DsReplicaObjMetaDataCtr, &mdc);
220 WERROR dsdb_extended_replicated_objects_commit(struct ldb_context *ldb,
221 const char *partition_dn,
222 const struct dsdb_schema *schema,
224 const struct drsuapi_DsGetNCChangesCtr1 *ctr1,
225 const struct drsuapi_DsGetNCChangesCtr6 *ctr6,
227 struct dsdb_extended_replicated_objects **_out)
230 struct dsdb_extended_replicated_objects *out;
231 struct ldb_result *ext_res;
232 const struct drsuapi_DsReplicaOIDMapping_Ctr *mapping_ctr;
233 uint32_t object_count;
234 struct drsuapi_DsReplicaObjectListItemEx *first_object;
235 struct drsuapi_DsReplicaObjectListItemEx *cur;
241 mapping_ctr = &ctr1->mapping_ctr;
242 object_count = ctr1->object_count;
243 first_object = ctr1->first_object;
246 mapping_ctr = &ctr6->mapping_ctr;
247 object_count = ctr6->object_count;
248 first_object = ctr6->first_object;
251 return WERR_INVALID_PARAM;
254 status = dsdb_verify_oid_mappings(schema, mapping_ctr);
255 W_ERROR_NOT_OK_RETURN(status);
257 out = talloc_zero(mem_ctx, struct dsdb_extended_replicated_objects);
258 W_ERROR_HAVE_NO_MEMORY(out);
260 out->partition_dn = ldb_dn_new(out, ldb, partition_dn);
261 W_ERROR_HAVE_NO_MEMORY(out->partition_dn);
263 out->num_objects = object_count;
264 out->objects = talloc_array(out,
265 struct dsdb_extended_replicated_object,
267 W_ERROR_HAVE_NO_MEMORY(out->objects);
269 for (i=0, cur = first_object; cur; cur = cur->next_object, i++) {
270 if (i == out->num_objects) {
274 status = dsdb_convert_object(ldb, schema, out, cur, out->objects, &out->objects[i]);
275 W_ERROR_NOT_OK_RETURN(status);
277 if (i != out->num_objects) {
281 /* TODO: handle linked attributes */
283 ret = ldb_extended(ldb, DSDB_EXTENDED_REPLICATED_OBJECTS_OID, out, &ext_res);
284 if (ret != LDB_SUCCESS) {
285 DEBUG(0,("Failed to apply records: %d\n",
290 talloc_free(ext_res);