node_stub.c

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.
 *
 */


#include "lib/misc.h"                   /* M0_SET0 */
#include "lib/time.h"                   /* m0_time_t */

#include "net/test/node_stub.h"


static void *node_stub_init(struct m0_net_test_service *svc)
{
        return svc;
}

static void node_stub_fini(void *ctx_)
{
}

static int node_stub_step(void *ctx_)
{
        return 0;
}

static int node_stub_cmd_init(void *ctx_,
                              const struct m0_net_test_cmd *cmd,
                              struct m0_net_test_cmd *reply)
{
        reply->ntc_type = M0_NET_TEST_CMD_INIT_DONE;
        reply->ntc_done.ntcd_errno = 0;
        return 0;
}

static int node_stub_cmd_start(void *ctx_,
                               const struct m0_net_test_cmd *cmd,
                               struct m0_net_test_cmd *reply)
{
        reply->ntc_type = M0_NET_TEST_CMD_START_DONE;
        reply->ntc_done.ntcd_errno = 0;
        return 0;
}

static int node_stub_cmd_stop(void *ctx_,
                              const struct m0_net_test_cmd *cmd,
                              struct m0_net_test_cmd *reply)
{
        m0_net_test_service_state_change(ctx_, M0_NET_TEST_SERVICE_FINISHED);
        reply->ntc_type = M0_NET_TEST_CMD_STOP_DONE;
        reply->ntc_done.ntcd_errno = 0;
        return 0;
}

static int node_stub_cmd_status(void *ctx_,
                                const struct m0_net_test_cmd *cmd,
                                struct m0_net_test_cmd *reply)
{
        struct m0_net_test_cmd_status_data *sd;

        reply->ntc_type = M0_NET_TEST_CMD_STATUS_DATA;
        sd = &reply->ntc_status_data;
        M0_SET0(sd);
        sd->ntcsd_finished = true;
        sd->ntcsd_time_start = m0_time_now();
        sd->ntcsd_time_finish = m0_time_add(sd->ntcsd_time_start,
                                            M0_MKTIME(0, 1));
        return 0;
}

static struct m0_net_test_service_cmd_handler node_stub_cmd_handler[] = {
        {
                .ntsch_type    = M0_NET_TEST_CMD_INIT,
                .ntsch_handler = node_stub_cmd_init,
        },
        {
                .ntsch_type    = M0_NET_TEST_CMD_START,
                .ntsch_handler = node_stub_cmd_start,
        },
        {
                .ntsch_type    = M0_NET_TEST_CMD_STOP,
                .ntsch_handler = node_stub_cmd_stop,
        },
        {
                .ntsch_type    = M0_NET_TEST_CMD_STATUS,
                .ntsch_handler = node_stub_cmd_status,
        },
};

struct m0_net_test_service_ops m0_net_test_node_stub_ops = {
        .ntso_init           = node_stub_init,
        .ntso_fini           = node_stub_fini,
        .ntso_step           = node_stub_step,
        .ntso_cmd_handler    = node_stub_cmd_handler,
        .ntso_cmd_handler_nr = ARRAY_SIZE(node_stub_cmd_handler),
};

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