ag.c

Go to the documentation of this file.

/* -*- C -*- */
/*
 * Copyright (c) 2017-2020 Seagate Technology LLC and/or its Affiliates
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 *
 * For any questions about this software or licensing,
 * please email opensource@seagate.com or cortx-questions@seagate.com.
 *
 */


#define M0_TRACE_SUBSYSTEM M0_TRACE_SUBSYS_DIXCM
#include "lib/trace.h"

#include "lib/memory.h"
#include "lib/errno.h"
#include "lib/misc.h"

#include "fid/fid.h"
#include "dix/cm/cp.h"
#include "dix/cm/cm.h"
#include "cm/proxy.h"

static uint64_t dix_cp_ag_local_cp_nr(const struct m0_cm_aggr_group *ag)
{
        /* There is always one aggregation group per copy packet. */
        return 1;
}

static void dix_cp_ag_fini(struct m0_cm_aggr_group *ag)
{
        M0_PRE(ag != NULL);
        M0_ENTRY("ag %p", ag);
        m0_cm_aggr_group_fini(ag);
        m0_free(ag);
        M0_LEAVE();
}

static bool dix_cp_ag_can_fini(const struct m0_cm_aggr_group *ag)
{
        return true;
}

static bool dix_cm_ag_is_frozen_on(struct m0_cm_aggr_group *ag,
                                   struct m0_cm_proxy *pxy)
{
        return false;
}

static const struct m0_cm_aggr_group_ops dix_cm_ag_ops = {
        .cago_local_cp_nr  = &dix_cp_ag_local_cp_nr,
        .cago_fini         = &dix_cp_ag_fini,
        .cago_ag_can_fini  = &dix_cp_ag_can_fini,
        .cago_is_frozen_on = &dix_cm_ag_is_frozen_on
};

M0_INTERNAL int m0_dix_cm_ag_alloc(struct m0_cm *cm,
                                   const struct m0_cm_ag_id *id,
                                   bool has_incoming,
                                   struct m0_cm_aggr_group **out)
{
        struct m0_cm_aggr_group *ag = NULL;

        M0_ENTRY("cm: %p, ag id:%p", cm, id);
        M0_PRE(cm != NULL && id != NULL && out != NULL);
        M0_PRE(m0_cm_is_locked(cm));

        ID_INCOMING_LOG("ag alloc", id, has_incoming);

        *out = NULL;

        /* Allocate new aggregation group. */
        M0_ALLOC_PTR(ag);
        if (ag == NULL)
                return M0_ERR(-ENOMEM);

        m0_cm_aggr_group_init(ag, cm, id, has_incoming, &dix_cm_ag_ops);
        *out = ag;

        M0_LEAVE("ag: %p", ag);
        return M0_RC(0);
}

#undef M0_TRACE_SUBSYSTEM

/*
 *  Local variables:
 *  c-indentation-style: "K&R"
 *  c-basic-offset: 8
 *  tab-width: 8
 *  fill-column: 79
 *  scroll-step: 1
 *  End:
 */