util.h

Go to the documentation of this file.

/* -*- C -*- */
/*
 * Copyright (c) 2021 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_ISCSERVICE_DEMO_UTIL_H__
#define __MOTR_ISCSERVICE_DEMO_UTIL_H__

#include "iscservice/isc.h"  /* m0_fop_isc */
#include "rpc/rpc_machine.h" /* M0_RPC_DEF_MAX_RPC_MSG_SIZE */

/* Import */
struct m0_fid;
struct isc_req;
struct m0_buf;
struct m0_rpc_link;
struct m0_layout_io_plop;
struct m0_obj;
struct m0_config;
struct m0_client;
enum   m0_conf_service_type;

enum isc_buffer_len {
        CBL_DEFAULT_MAX = M0_RPC_DEF_MAX_RPC_MSG_SIZE >> 2,
        CBL_DEFAULT_MIN = 256,
};

struct isc_req {
        struct m0_buf          cir_result;
        int                    cir_rc;
        struct m0_rpc_session *cir_rpc_sess;
        struct m0_fop_isc      cir_isc_fop;
        struct m0_fop          cir_fop;
        struct m0_layout_plop *cir_plop;
        struct m0_list_link    cir_link;
};

extern struct m0_realm     uber_realm;
extern struct m0_semaphore isc_sem;
extern struct m0_list      isc_reqs;

int  isc_init(struct m0_config*, struct m0_client**);
void isc_fini(struct m0_client*);

uint64_t isc_m0gs(struct m0_obj*, struct m0_client*);

int isc_req_prepare(struct isc_req *, struct m0_buf *args,
                    const struct m0_fid *comp,
                    struct m0_layout_io_plop *iopl, uint32_t reply_len);

int isc_req_send(struct isc_req *req);

void isc_req_fini(struct isc_req *req);

int alloc_segs(struct m0_bufvec *data, struct m0_indexvec *ext,
               struct m0_bufvec *attr, uint64_t bsz, uint32_t cnt);
void free_segs(struct m0_bufvec *data, struct m0_indexvec *ext,
               struct m0_bufvec *attr);
uint64_t set_exts(struct m0_indexvec *ext, uint64_t off, uint64_t bsz);

extern bool  m0trace_on;
extern int   trace_level;
extern char *prog;

enum {
        LOG_ERROR = 0,
        LOG_DEBUG = 1,
        LOG_DEBUG2 = 2
};

#define LOG(_fmt, ...) \
  fprintf(stderr, "%s: %s():%d: "_fmt, prog, __func__, __LINE__, ##__VA_ARGS__)
#define ERR(_fmt, ...) if (trace_level >= LOG_ERROR) LOG(_fmt, ##__VA_ARGS__)
#define ERRS(_fmt, ...) if (trace_level >= LOG_ERROR) \
        LOG(_fmt ": %s\n", ##__VA_ARGS__, strerror(errno))
#define DBG(_fmt, ...) if (trace_level >= LOG_DEBUG) LOG(_fmt, ##__VA_ARGS__)
#define DBG2(_fmt, ...) if (trace_level >= LOG_DEBUG2) LOG(_fmt, ##__VA_ARGS__)

#define CHECK_BSZ_ARGS(bsz, m0bs) \
  if ((bsz) < 1 || (bsz) % PAGE_SIZE) { \
    ERR("bsz(%lu) must be multiple of %luK\n", (m0bs), PAGE_SIZE/1024); \
    return -EINVAL; \
  } \
  if ((m0bs) < 1 || (m0bs) % (bsz)) { \
    ERR("bsz(%lu) must divide m0bs(%lu)\n", (bsz), (m0bs)); \
    return -EINVAL; \
  }

#endif /* __MOTR_ISCSERVICE_DEMO_UTIL_H__ */

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