>From af555ccfa228ea931d1eb31cc1dedd6f6d3580ce Mon Sep 17 00:00:00 2001 From: Jakub Hrozek Date: Mon, 26 Nov 2012 13:18:59 +0100 Subject: [PATCH 1/4] MEMBEROF: split processing the member modify into a separate function This will allow to process ghost users in a similar fashion --- src/ldb_modules/memberof.c | 117 +++++++++++++++++++++++++++------------------ 1 file changed, 70 insertions(+), 47 deletions(-) diff --git a/src/ldb_modules/memberof.c b/src/ldb_modules/memberof.c index c796ecde2de03ae13e330c64bad9e2af3c156740..38372d940656e78f92361467c397211379cd102e 100644 --- a/src/ldb_modules/memberof.c +++ b/src/ldb_modules/memberof.c @@ -145,7 +145,8 @@ struct mbof_mod_ctx { const struct ldb_message_element *membel; struct ldb_message *entry; - struct mbof_dn_array *to_add; + struct mbof_dn_array *mb_add; + struct mbof_dn_array *mb_remove; struct ldb_message *msg; bool terminate; @@ -2258,7 +2259,7 @@ static int mbof_del_progeny(struct mbof_del_operation *delop) /* see if there are follow functions to run */ if (del_ctx->follow_mod) { return mbof_mod_add(del_ctx->follow_mod, - del_ctx->follow_mod->to_add); + del_ctx->follow_mod->mb_add); } /* ok, no more ops, this means our job is done */ @@ -2529,7 +2530,7 @@ static int mbof_del_muop_callback(struct ldb_request *req, /* see if there are follow functions to run */ else if (del_ctx->follow_mod) { return mbof_mod_add(del_ctx->follow_mod, - del_ctx->follow_mod->to_add); + del_ctx->follow_mod->mb_add); } else { return ldb_module_done(ctx->req, @@ -2641,7 +2642,7 @@ static int mbof_del_ghop_callback(struct ldb_request *req, /* see if there are follow functions to run */ else if (del_ctx->follow_mod) { return mbof_mod_add(del_ctx->follow_mod, - del_ctx->follow_mod->to_add); + del_ctx->follow_mod->mb_add); } else { return ldb_module_done(ctx->req, @@ -2689,6 +2690,11 @@ static int mbof_orig_mod(struct mbof_mod_ctx *mod_ctx); static int mbof_orig_mod_callback(struct ldb_request *req, struct ldb_reply *ares); static int mbof_mod_process(struct mbof_mod_ctx *mod_ctx, bool *done); +static int mbof_mod_process_membel(TALLOC_CTX *mem_ctx, struct ldb_context *ldb, + struct ldb_message *entry, + const struct ldb_message_element *membel, + struct mbof_dn_array **_added, + struct mbof_dn_array **_removed); static int mbof_mod_delete(struct mbof_mod_ctx *mod_ctx, struct mbof_dn_array *del); static int mbof_fill_dn_array(TALLOC_CTX *memctx, @@ -2912,63 +2918,96 @@ static int mbof_orig_mod_callback(struct ldb_request *req, static int mbof_mod_process(struct mbof_mod_ctx *mod_ctx, bool *done) { - const struct ldb_message_element *el; struct ldb_context *ldb; struct mbof_ctx *ctx; - struct mbof_dn_array *removed; - struct mbof_dn_array *added; - int i, j, ret; + int ret; ctx = mod_ctx->ctx; ldb = ldb_module_get_ctx(ctx->module); - switch (mod_ctx->membel->flags) { + ret = mbof_mod_process_membel(mod_ctx, ldb, mod_ctx->entry, mod_ctx->membel, + &mod_ctx->mb_add, &mod_ctx->mb_remove); + if (ret != LDB_SUCCESS) { + return ret; + } + + /* Process the operations */ + if (mod_ctx->mb_remove && mod_ctx->mb_remove->num) { + return mbof_mod_delete(mod_ctx, mod_ctx->mb_remove); + } + + if (mod_ctx->mb_add && mod_ctx->mb_add->num) { + return mbof_mod_add(mod_ctx, mod_ctx->mb_add); + } + + /* the replacement function resulted in a null op, + * nothing to do, return happily */ + *done = true; + return LDB_SUCCESS; +} + +static int mbof_mod_process_membel(TALLOC_CTX *mem_ctx, + struct ldb_context *ldb, + struct ldb_message *entry, + const struct ldb_message_element *membel, + struct mbof_dn_array **_added, + struct mbof_dn_array **_removed) +{ + const struct ldb_message_element *el; + struct mbof_dn_array *removed = NULL; + struct mbof_dn_array *added = NULL; + int i, j, ret; + + if (!membel) { + /* Nothing to do.. */ + return LDB_SUCCESS; + } + + switch (membel->flags) { case LDB_FLAG_MOD_ADD: - ret = mbof_fill_dn_array(mod_ctx, ldb, mod_ctx->membel, &added); + ret = mbof_fill_dn_array(mem_ctx, ldb, membel, &added); if (ret != LDB_SUCCESS) { return ret; } - - return mbof_mod_add(mod_ctx, added); + break; case LDB_FLAG_MOD_DELETE: - if (mod_ctx->membel->num_values == 0) { - el = ldb_msg_find_element(mod_ctx->entry, DB_MEMBER); + if (membel->num_values == 0) { + el = ldb_msg_find_element(entry, DB_MEMBER); } else { - el = mod_ctx->membel; + el = membel; } if (!el) { /* nothing to do really */ - *done = true; - return LDB_SUCCESS; + break; } - ret = mbof_fill_dn_array(mod_ctx, ldb, el, &removed); + ret = mbof_fill_dn_array(mem_ctx, ldb, el, &removed); if (ret != LDB_SUCCESS) { return ret; } - - return mbof_mod_delete(mod_ctx, removed); + break; case LDB_FLAG_MOD_REPLACE: removed = NULL; - el = ldb_msg_find_element(mod_ctx->entry, DB_MEMBER); + el = ldb_msg_find_element(entry, DB_MEMBER); if (el) { - ret = mbof_fill_dn_array(mod_ctx, ldb, el, &removed); + ret = mbof_fill_dn_array(mem_ctx, ldb, el, &removed); if (ret != LDB_SUCCESS) { return ret; } } added = NULL; - el = mod_ctx->membel; + el = membel; if (el) { - ret = mbof_fill_dn_array(mod_ctx, ldb, el, &added); + ret = mbof_fill_dn_array(mem_ctx, ldb, el, &added); if (ret != LDB_SUCCESS) { + talloc_free(removed); return ret; } } @@ -2995,31 +3034,15 @@ static int mbof_mod_process(struct mbof_mod_ctx *mod_ctx, bool *done) } } } + break; - /* if we need to add something put it away so that it - * can be done after all delete operations are over */ - if (added && added->num) { - mod_ctx->to_add = added; - } - - /* if we have something to remove do it first */ - if (removed && removed->num) { - return mbof_mod_delete(mod_ctx, removed); - } - - /* if there is nothing to remove and we have stuff to add - * do it right away */ - if (mod_ctx->to_add) { - return mbof_mod_add(mod_ctx, added); - } - - /* the replacement function resulted in a null op, - * nothing to do, return happily */ - *done = true; - return LDB_SUCCESS; + default: + return LDB_ERR_OPERATIONS_ERROR; } - return LDB_ERR_OPERATIONS_ERROR; + *_added = added; + *_removed = removed; + return LDB_SUCCESS; } static int mbof_mod_add(struct mbof_mod_ctx *mod_ctx, @@ -3107,7 +3130,7 @@ static int mbof_mod_delete(struct mbof_mod_ctx *mod_ctx, } /* add followup function if we also have stuff to add */ - if (mod_ctx->to_add) { + if (mod_ctx->mb_add) { del_ctx->follow_mod = mod_ctx; } -- 1.8.0.1