console.h

Go to the documentation of this file.

/* -*- C -*- */
/*
 * Copyright (c) 2013-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_NET_TEST_CONSOLE_H__
#define __MOTR_NET_TEST_CONSOLE_H__

#include "lib/time.h"                   /* m0_time_t */
#include "lib/types.h"                  /* m0_bcount_t */

#include "net/test/commands.h"          /* m0_net_test_cmd_ctx */
#include "net/test/node.h"              /* m0_net_test_role */
#include "net/test/slist.h"             /* m0_net_test_slist */


struct m0_net_test_console_cfg {
        char                    *ntcc_addr_console4servers;
        char                    *ntcc_addr_console4clients;
        struct m0_net_test_slist ntcc_servers;
        struct m0_net_test_slist ntcc_clients;
        struct m0_net_test_slist ntcc_data_servers;
        struct m0_net_test_slist ntcc_data_clients;
        m0_time_t                ntcc_cmd_send_timeout;
        m0_time_t                ntcc_cmd_recv_timeout;
        m0_time_t                ntcc_buf_send_timeout;
        m0_time_t                ntcc_buf_recv_timeout;
        m0_time_t                ntcc_buf_bulk_timeout;
        enum m0_net_test_type    ntcc_test_type;
        uint64_t                 ntcc_msg_nr;
        m0_time_t                ntcc_test_time_limit;
        m0_bcount_t              ntcc_msg_size;
        uint64_t                 ntcc_bd_buf_nr_server;
        uint64_t                 ntcc_bd_buf_nr_client;
        m0_bcount_t              ntcc_bd_buf_size;
        uint64_t                 ntcc_bd_nr_max;
        uint64_t                 ntcc_concurrency_server;
        uint64_t                 ntcc_concurrency_client;
};

struct m0_net_test_console_role_ctx {
        struct m0_net_test_cmd_ctx         *ntcrc_cmd;
        struct m0_net_test_cmd_status_data *ntcrc_sd;
        size_t                              ntcrc_nr;
        int                                *ntcrc_errno;
        int                                *ntcrc_status;
        size_t                              ntcrc_recv_errors;
        size_t                              ntcrc_recv_enqueue_errors;
};

struct m0_net_test_console_ctx {
        struct m0_net_test_console_cfg     *ntcc_cfg;
        struct m0_net_test_console_role_ctx ntcc_clients;
        struct m0_net_test_console_role_ctx ntcc_servers;
};

int m0_net_test_console_init(struct m0_net_test_console_ctx *ctx,
                             struct m0_net_test_console_cfg *cfg);

void m0_net_test_console_fini(struct m0_net_test_console_ctx *ctx);

size_t m0_net_test_console_cmd(struct m0_net_test_console_ctx *ctx,
                               enum m0_net_test_role role,
                               enum m0_net_test_cmd_type cmd_type);

#endif /*  __MOTR_NET_TEST_CONSOLE_H__ */

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