rdwr_fom.c

Go to the documentation of this file.

/*
 * Copyright (c) 2012-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.
 *
 */


#include "lib/errno.h"
#include "lib/memory.h"
#include "ut/ut.h"
#include "fop/fom_long_lock.h"

struct test_request;

struct fom_rdwr {
        struct m0_fom                    fr_gen;
        struct m0_long_lock_link         fr_link;

        /* Long lock UT test data */
        struct test_request             *fr_req;
        size_t                           fr_seqn;
};

static size_t fom_rdwr_home_locality(const struct m0_fom *fom);
static void fop_rdwr_fom_fini(struct m0_fom *fom);
static int fom_rdwr_tick(struct m0_fom *fom);

extern struct m0_reqh_service_type ut_long_lock_service_type;
static const struct m0_fom_ops fom_rdwr_ops = {
        .fo_fini          = fop_rdwr_fom_fini,
        .fo_tick          = fom_rdwr_tick,
        .fo_home_locality = fom_rdwr_home_locality
};

const struct m0_fom_type_ops fom_rdwr_type_ops = {
        .fto_create = NULL
};

struct m0_fom_type rdwr_fom_type;

static size_t fom_rdwr_home_locality(const struct m0_fom *fom)
{
        static size_t locality = 0;

        M0_PRE(fom != NULL);
        return locality++;
}

static int rdwr_fom_create(struct m0_fom **m, struct m0_reqh *reqh)
{
        struct m0_fom                   *fom;
        struct fom_rdwr                 *fom_obj;

        M0_PRE(m != NULL);

        M0_ALLOC_PTR(fom_obj);
        M0_UT_ASSERT(fom_obj != NULL);

        fom = &fom_obj->fr_gen;
        m0_fom_init(fom, &rdwr_fom_type, &fom_rdwr_ops, NULL, NULL, reqh);
        m0_long_lock_link_init(&fom_obj->fr_link, fom, NULL);

        *m = fom;
        return 0;
}

static void fop_rdwr_fom_fini(struct m0_fom *fom)
{
        struct fom_rdwr *fom_obj;

        fom_obj = container_of(fom, struct fom_rdwr, fr_gen);
        m0_fom_fini(fom);
        m0_long_lock_link_fini(&fom_obj->fr_link);
        m0_free(fom_obj);

        return;
}

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