source: vendor/3.5.2/source3/winbindd/wb_seqnums.c

/*
   Unix SMB/CIFS implementation.

   async seqnums, update the seqnums in winbindd_cache.c

   Copyright (C) Volker Lendecke 2009

   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 3 of the License, or
   (at your option) any later version.

   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   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, see <http://www.gnu.org/licenses/>.
*/

#include "includes.h"
#include "winbindd.h"
#include "librpc/gen_ndr/cli_wbint.h"

struct wb_seqnums_state {
        int num_domains;
        int num_received;

        struct tevent_req **subreqs;
        struct winbindd_domain **domains;
        NTSTATUS *stati;
        uint32_t *seqnums;
};

static void wb_seqnums_done(struct tevent_req *subreq);

struct tevent_req *wb_seqnums_send(TALLOC_CTX *mem_ctx,
                                   struct tevent_context *ev)
{
        struct tevent_req *req;
        struct wb_seqnums_state *state;
        struct winbindd_domain *domain;
        int i;

        req = tevent_req_create(mem_ctx, &state, struct wb_seqnums_state);
        if (req == NULL) {
                return NULL;
        }
        state->num_received = 0;
        state->num_domains = 0;

        for (domain = domain_list(); domain != NULL; domain = domain->next) {
                state->num_domains += 1;
        }

        state->subreqs = talloc_array(state, struct tevent_req *,
                                      state->num_domains);
        state->domains = talloc_array(state, struct winbindd_domain *,
                                      state->num_domains);
        state->stati = talloc_array(state, NTSTATUS, state->num_domains);
        state->seqnums = talloc_array(state, uint32_t, state->num_domains);

        if ((state->subreqs == NULL) || (state->domains == NULL) ||
            (state->stati == NULL) || (state->seqnums == NULL)) {
                tevent_req_nterror(req, NT_STATUS_NO_MEMORY);
                return tevent_req_post(req, ev);
        }

        i = 0;

        for (domain = domain_list(); domain != NULL; domain = domain->next) {
                state->domains[i] = domain;
                state->subreqs[i] = wb_seqnum_send(state->subreqs, ev, domain);
                if (tevent_req_nomem(state->subreqs[i], req)) {
                        /* Don't even start all the other requests */
                        TALLOC_FREE(state->subreqs);
                        return tevent_req_post(req, ev);
                }
                tevent_req_set_callback(state->subreqs[i], wb_seqnums_done,
                                        req);
                i += 1;
        }
        return req;
}

static void wb_seqnums_done(struct tevent_req *subreq)
{
        struct tevent_req *req = tevent_req_callback_data(
                subreq, struct tevent_req);
        struct wb_seqnums_state *state = tevent_req_data(
                req, struct wb_seqnums_state);
        NTSTATUS status;
        uint32_t seqnum;
        int i;

        status = wb_seqnum_recv(subreq, &seqnum);

        for (i=0; i<state->num_domains; i++) {
                if (subreq == state->subreqs[i]) {
                        break;
                }
        }
        if (i < state->num_domains) {
                /* found one */

                state->subreqs[i] = NULL;
                state->stati[i] = status;
                if (NT_STATUS_IS_OK(status)) {
                        state->seqnums[i] = seqnum;

                        /*
                         * This first assignment might be removed
                         * later
                         */
                        state->domains[i]->sequence_number = seqnum;

                        if (!wcache_store_seqnum(state->domains[i]->name,
                                                 state->seqnums[i],
                                                 time(NULL))) {
                                DEBUG(1, ("wcache_store_seqnum failed for "
                                          "domain %s\n",
                                          state->domains[i]->name));
                        }
                }
        }

        TALLOC_FREE(subreq);

        state->num_received += 1;

        if (state->num_received >= state->num_domains) {
                tevent_req_done(req);
        }
}

NTSTATUS wb_seqnums_recv(struct tevent_req *req, TALLOC_CTX *mem_ctx,
                         int *num_domains, struct winbindd_domain ***domains,
                         NTSTATUS **stati, uint32_t **seqnums)
{
        struct wb_seqnums_state *state = tevent_req_data(
                req, struct wb_seqnums_state);
        NTSTATUS status;

        if (tevent_req_is_nterror(req, &status)) {
                return status;
        }
        *num_domains = state->num_domains;
        *domains = talloc_move(mem_ctx, &state->domains);
        *stati = talloc_move(mem_ctx, &state->stati);
        *seqnums = talloc_move(mem_ctx, &state->seqnums);
        return NT_STATUS_OK;
}