req_internal.h

Go to the documentation of this file.

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


#pragma once

#ifndef __MOTR_DIX_REQ_INTERNAL_H__
#define __MOTR_DIX_REQ_INTERNAL_H__

#include "lib/buf.h"    /* m0_buf */
#include "lib/chan.h"   /* m0_chan */
#include "lib/vec.h"    /* m0_bufvec */
#include "lib/tlist.h"  /* m0_tlink */
#include "sm/sm.h"      /* m0_sm_ast */
#include "pool/pool.h"  /* m0_pool_nd_state */
#include "cas/client.h" /* m0_cas_req */

struct m0_dix_req;
struct m0_pool_version;
struct m0_dix_next_resultset;

struct m0_dix_item {
        struct m0_buf dxi_key;
        struct m0_buf dxi_val;
        uint64_t      dxi_pg_unit;
        bool          dxi_del_phase2;
        int           dxi_rc;
};

struct m0_dix_cas_req {
        struct m0_dix_req *ds_parent;
        struct m0_cas_req  ds_creq;
        struct m0_clink    ds_clink;
        int                ds_rc;
};

struct m0_dix_idxop_req {
        struct m0_dix_idxop_ctx *dcr_ctx;
        uint32_t                 dcr_index_no;
        struct m0_pool_version  *dcr_pver;
        struct m0_dix_cas_req   *dcr_creqs;
        uint64_t                 dcr_creqs_nr;
        bool                     dcr_del_phase2;
};

struct m0_dix_idxop_ctx {
        struct m0_dix_idxop_req *dcd_idxop_reqs;
        uint32_t                 dcd_idxop_reqs_nr;
        uint64_t                 dcd_cas_reqs_nr;
        uint64_t                 dcd_completed_nr;
        struct m0_sm_ast         dcd_ast;
};

struct m0_dix_crop_attrs {
        uint64_t cra_item;
};

struct m0_dix_cas_rop {
        struct m0_dix_req        *crp_parent;
        struct m0_cas_req         crp_creq;
        uint32_t                  crp_flags;
        struct m0_clink           crp_clink;
        uint32_t                  crp_sdev_idx;
        uint32_t                  crp_keys_nr;
        uint32_t                  crp_cur_key;
        struct m0_bufvec          crp_keys;
        struct m0_bufvec          crp_vals;
        struct m0_dix_crop_attrs *crp_attrs;
        struct m0_tlink           crp_linkage;
        uint64_t                  crp_magix;
        uint32_t                  crp_pa_idx;
};

struct m0_dix_pg_unit {
        uint32_t               dpu_tgt;

        uint32_t               dpu_sdev_idx;

        enum m0_pool_nd_state  dpu_pd_state;

        bool                   dpu_failed;
        bool                   dpu_is_spare;
        bool                   dpu_del_phase2;
};

struct m0_dix_rec_op {
        struct m0_dix_layout_iter dgp_iter;

        struct m0_buf             dgp_key;

        uint32_t                  dgp_next_tgt;
        uint64_t                  dgp_item;
        struct m0_dix_pg_unit    *dgp_units;
        uint64_t                  dgp_units_nr;
        uint32_t                  dgp_failed_devs_nr;
};

struct m0_dix_rop_ctx {
        struct m0_dix_rec_op   *dg_rec_ops;
        uint32_t                dg_rec_ops_nr;
        struct m0_dix_cas_rop **dg_target_rop;
        struct m0_tl            dg_cas_reqs;
        uint64_t                dg_cas_reqs_nr;
        uint64_t                dg_completed_nr;
        struct m0_pool_version *dg_pver;
        struct m0_sm_ast        dg_ast;
};

M0_TL_DESCR_DECLARE(cas_rop, M0_EXTERN);
M0_TL_DECLARE(cas_rop, M0_INTERNAL, struct m0_dix_cas_rop);

M0_INTERNAL int m0_dix_next_result_prepare(struct m0_dix_req *req);

M0_INTERNAL int m0_dix_rs_init(struct m0_dix_next_resultset  *rs,
                               uint32_t                       start_keys_nr,
                               uint32_t                       sctx_nr);

M0_INTERNAL void m0_dix_rs_fini(struct m0_dix_next_resultset *rs);

#endif /* __MOTR_DIX_REQ_INTERNAL_H__ */

/*
 *  Local variables:
 *  c-indentation-style: "K&R"
 *  c-basic-offset: 8
 *  tab-width: 8
 *  fill-column: 80
 *  scroll-step: 1
 *  End:
 */
/*
 * vim: tabstop=8 shiftwidth=8 noexpandtab textwidth=80 nowrap
 */