test_peer_base.cc

xorp源码hg

    /* Return value declarations */
    try {
	XrlCmdError e = test_peer_0_1_connect(
	    xa_inputs.get_string("host"),
	    xa_inputs.get_uint32("port"));
	if (e != XrlCmdError::OKAY()) {
	    XLOG_WARNING("Handling method for %s failed: %s",
            		 "test_peer/0.1/connect", e.str().c_str());
	    return e;
        }
    } catch (const XrlArgs::XrlAtomNotFound& e) {
	XLOG_ERROR("Argument not found");
	return XrlCmdError::BAD_ARGS();
    }
    return XrlCmdError::OKAY();
}

const XrlCmdError
XrlTestPeerTargetBase::handle_test_peer_0_1_listen(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */)
{
    if (xa_inputs.size() != 2) {
	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",
            XORP_UINT_CAST(2), XORP_UINT_CAST(xa_inputs.size()), "test_peer/0.1/listen");
	return XrlCmdError::BAD_ARGS();
    }

    /* Return value declarations */
    try {
	XrlCmdError e = test_peer_0_1_listen(
	    xa_inputs.get_string("address"),
	    xa_inputs.get_uint32("port"));
	if (e != XrlCmdError::OKAY()) {
	    XLOG_WARNING("Handling method for %s failed: %s",
            		 "test_peer/0.1/listen", e.str().c_str());
	    return e;
        }
    } catch (const XrlArgs::XrlAtomNotFound& e) {
	XLOG_ERROR("Argument not found");
	return XrlCmdError::BAD_ARGS();
    }
    return XrlCmdError::OKAY();
}

const XrlCmdError
XrlTestPeerTargetBase::handle_test_peer_0_1_bind(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */)
{
    if (xa_inputs.size() != 2) {
	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",
            XORP_UINT_CAST(2), XORP_UINT_CAST(xa_inputs.size()), "test_peer/0.1/bind");
	return XrlCmdError::BAD_ARGS();
    }

    /* Return value declarations */
    try {
	XrlCmdError e = test_peer_0_1_bind(
	    xa_inputs.get_string("address"),
	    xa_inputs.get_uint32("port"));
	if (e != XrlCmdError::OKAY()) {
	    XLOG_WARNING("Handling method for %s failed: %s",
            		 "test_peer/0.1/bind", e.str().c_str());
	    return e;
        }
    } catch (const XrlArgs::XrlAtomNotFound& e) {
	XLOG_ERROR("Argument not found");
	return XrlCmdError::BAD_ARGS();
    }
    return XrlCmdError::OKAY();
}

const XrlCmdError
XrlTestPeerTargetBase::handle_test_peer_0_1_send(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */)
{
    if (xa_inputs.size() != 1) {
	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",
            XORP_UINT_CAST(1), XORP_UINT_CAST(xa_inputs.size()), "test_peer/0.1/send");
	return XrlCmdError::BAD_ARGS();
    }

    /* Return value declarations */
    try {
	XrlCmdError e = test_peer_0_1_send(
	    xa_inputs.get_binary("data"));
	if (e != XrlCmdError::OKAY()) {
	    XLOG_WARNING("Handling method for %s failed: %s",
            		 "test_peer/0.1/send", e.str().c_str());
	    return e;
        }
    } catch (const XrlArgs::XrlAtomNotFound& e) {
	XLOG_ERROR("Argument not found");
	return XrlCmdError::BAD_ARGS();
    }
    return XrlCmdError::OKAY();
}

const XrlCmdError
XrlTestPeerTargetBase::handle_test_peer_0_1_disconnect(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */)
{
    if (xa_inputs.size() != 0) {
	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",
            XORP_UINT_CAST(0), XORP_UINT_CAST(xa_inputs.size()), "test_peer/0.1/disconnect");
	return XrlCmdError::BAD_ARGS();
    }

    /* Return value declarations */
    try {
	XrlCmdError e = test_peer_0_1_disconnect();
	if (e != XrlCmdError::OKAY()) {
	    XLOG_WARNING("Handling method for %s failed: %s",
            		 "test_peer/0.1/disconnect", e.str().c_str());
	    return e;
        }
    } catch (const XrlArgs::XrlAtomNotFound& e) {
	XLOG_ERROR("Argument not found");
	return XrlCmdError::BAD_ARGS();
    }
    return XrlCmdError::OKAY();
}

const XrlCmdError
XrlTestPeerTargetBase::handle_test_peer_0_1_reset(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */)
{
    if (xa_inputs.size() != 0) {
	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",
            XORP_UINT_CAST(0), XORP_UINT_CAST(xa_inputs.size()), "test_peer/0.1/reset");
	return XrlCmdError::BAD_ARGS();
    }

    /* Return value declarations */
    try {
	XrlCmdError e = test_peer_0_1_reset();
	if (e != XrlCmdError::OKAY()) {
	    XLOG_WARNING("Handling method for %s failed: %s",
            		 "test_peer/0.1/reset", e.str().c_str());
	    return e;
        }
    } catch (const XrlArgs::XrlAtomNotFound& e) {
	XLOG_ERROR("Argument not found");
	return XrlCmdError::BAD_ARGS();
    }
    return XrlCmdError::OKAY();
}

const XrlCmdError
XrlTestPeerTargetBase::handle_test_peer_0_1_terminate(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */)
{
    if (xa_inputs.size() != 0) {
	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",
            XORP_UINT_CAST(0), XORP_UINT_CAST(xa_inputs.size()), "test_peer/0.1/terminate");
	return XrlCmdError::BAD_ARGS();
    }

    /* Return value declarations */
    try {
	XrlCmdError e = test_peer_0_1_terminate();
	if (e != XrlCmdError::OKAY()) {
	    XLOG_WARNING("Handling method for %s failed: %s",
            		 "test_peer/0.1/terminate", e.str().c_str());
	    return e;
        }
    } catch (const XrlArgs::XrlAtomNotFound& e) {
	XLOG_ERROR("Argument not found");
	return XrlCmdError::BAD_ARGS();
    }
    return XrlCmdError::OKAY();
}

void
XrlTestPeerTargetBase::add_handlers()
{
	if (_cmds->add_handler("common/0.1/get_target_name",
	    callback(this, &XrlTestPeerTargetBase::handle_common_0_1_get_target_name)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "common/0.1/get_target_name");
	}
	if (_cmds->add_handler("common/0.1/get_version",
	    callback(this, &XrlTestPeerTargetBase::handle_common_0_1_get_version)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "common/0.1/get_version");
	}
	if (_cmds->add_handler("common/0.1/get_status",
	    callback(this, &XrlTestPeerTargetBase::handle_common_0_1_get_status)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "common/0.1/get_status");
	}
	if (_cmds->add_handler("common/0.1/shutdown",
	    callback(this, &XrlTestPeerTargetBase::handle_common_0_1_shutdown)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "common/0.1/shutdown");
	}
	if (_cmds->add_handler("test_peer/0.1/register",
	    callback(this, &XrlTestPeerTargetBase::handle_test_peer_0_1_register)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "test_peer/0.1/register");
	}
	if (_cmds->add_handler("test_peer/0.1/packetisation",
	    callback(this, &XrlTestPeerTargetBase::handle_test_peer_0_1_packetisation)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "test_peer/0.1/packetisation");
	}
	if (_cmds->add_handler("test_peer/0.1/connect",
	    callback(this, &XrlTestPeerTargetBase::handle_test_peer_0_1_connect)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "test_peer/0.1/connect");
	}
	if (_cmds->add_handler("test_peer/0.1/listen",
	    callback(this, &XrlTestPeerTargetBase::handle_test_peer_0_1_listen)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "test_peer/0.1/listen");
	}
	if (_cmds->add_handler("test_peer/0.1/bind",
	    callback(this, &XrlTestPeerTargetBase::handle_test_peer_0_1_bind)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "test_peer/0.1/bind");
	}
	if (_cmds->add_handler("test_peer/0.1/send",
	    callback(this, &XrlTestPeerTargetBase::handle_test_peer_0_1_send)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "test_peer/0.1/send");
	}
	if (_cmds->add_handler("test_peer/0.1/disconnect",
	    callback(this, &XrlTestPeerTargetBase::handle_test_peer_0_1_disconnect)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "test_peer/0.1/disconnect");
	}
	if (_cmds->add_handler("test_peer/0.1/reset",
	    callback(this, &XrlTestPeerTargetBase::handle_test_peer_0_1_reset)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "test_peer/0.1/reset");
	}
	if (_cmds->add_handler("test_peer/0.1/terminate",
	    callback(this, &XrlTestPeerTargetBase::handle_test_peer_0_1_terminate)) == false) {
	    XLOG_ERROR("Failed to xrl handler finder://%s/%s", "test_peer", "test_peer/0.1/terminate");
	}
	_cmds->finalize();
}

void
XrlTestPeerTargetBase::remove_handlers()
{
	_cmds->remove_handler("common/0.1/get_target_name");
	_cmds->remove_handler("common/0.1/get_version");
	_cmds->remove_handler("common/0.1/get_status");
	_cmds->remove_handler("common/0.1/shutdown");
	_cmds->remove_handler("test_peer/0.1/register");
	_cmds->remove_handler("test_peer/0.1/packetisation");
	_cmds->remove_handler("test_peer/0.1/connect");
	_cmds->remove_handler("test_peer/0.1/listen");
	_cmds->remove_handler("test_peer/0.1/bind");
	_cmds->remove_handler("test_peer/0.1/send");
	_cmds->remove_handler("test_peer/0.1/disconnect");
	_cmds->remove_handler("test_peer/0.1/reset");
	_cmds->remove_handler("test_peer/0.1/terminate");
}