📄 mld6igmp_base.cc

📁 xorp源码hg
💻 CC
📖 第 1 页 / 共 5 页
字号:
{    if (xa_inputs.size() != 5) {	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",            XORP_UINT_CAST(5), XORP_UINT_CAST(xa_inputs.size()), "mfea_client/0.1/add_vif_addr6");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_add_vif_addr6(	    xa_inputs.get_string("vif_name"),	    xa_inputs.get_ipv6("addr"),	    xa_inputs.get_ipv6net("subnet"),	    xa_inputs.get_ipv6("broadcast"),	    xa_inputs.get_ipv6("peer"));	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/add_vif_addr6", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_delete_vif_addr4(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()), "mfea_client/0.1/delete_vif_addr4");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_delete_vif_addr4(	    xa_inputs.get_string("vif_name"),	    xa_inputs.get_ipv4("addr"));	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/delete_vif_addr4", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_delete_vif_addr6(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()), "mfea_client/0.1/delete_vif_addr6");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_delete_vif_addr6(	    xa_inputs.get_string("vif_name"),	    xa_inputs.get_ipv6("addr"));	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/delete_vif_addr6", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_set_vif_flags(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */){    if (xa_inputs.size() != 8) {	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",            XORP_UINT_CAST(8), XORP_UINT_CAST(xa_inputs.size()), "mfea_client/0.1/set_vif_flags");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_set_vif_flags(	    xa_inputs.get_string("vif_name"),	    xa_inputs.get_bool("is_pim_register"),	    xa_inputs.get_bool("is_p2p"),	    xa_inputs.get_bool("is_loopback"),	    xa_inputs.get_bool("is_multicast"),	    xa_inputs.get_bool("is_broadcast"),	    xa_inputs.get_bool("is_up"),	    xa_inputs.get_uint32("mtu"));	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/set_vif_flags", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_set_all_vifs_done(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()), "mfea_client/0.1/set_all_vifs_done");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_set_all_vifs_done();	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/set_all_vifs_done", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_is_vif_setup_completed(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()), "mfea_client/0.1/is_vif_setup_completed");	return XrlCmdError::BAD_ARGS();    }    if (pxa_outputs == 0) {	XLOG_FATAL("Return list empty");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    bool is_completed;    try {	XrlCmdError e = mfea_client_0_1_is_vif_setup_completed(	    is_completed);	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/is_vif_setup_completed", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    /* Marshall return values */    try {	pxa_outputs->add("is_completed", is_completed);    } catch (const XrlArgs::XrlAtomFound& ) {	XLOG_FATAL("Duplicate atom name"); /* XXX Should never happen */    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_recv_protocol_message4(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */){    if (xa_inputs.size() != 11) {	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",            XORP_UINT_CAST(11), XORP_UINT_CAST(xa_inputs.size()), "mfea_client/0.1/recv_protocol_message4");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_recv_protocol_message4(	    xa_inputs.get_string("xrl_sender_name"),	    xa_inputs.get_string("protocol_name"),	    xa_inputs.get_uint32("protocol_id"),	    xa_inputs.get_string("vif_name"),	    xa_inputs.get_uint32("vif_index"),	    xa_inputs.get_ipv4("source_address"),	    xa_inputs.get_ipv4("dest_address"),	    xa_inputs.get_int32("ip_ttl"),	    xa_inputs.get_int32("ip_tos"),	    xa_inputs.get_bool("is_router_alert"),	    xa_inputs.get_binary("protocol_message"));	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/recv_protocol_message4", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_recv_protocol_message6(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */){    if (xa_inputs.size() != 11) {	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",            XORP_UINT_CAST(11), XORP_UINT_CAST(xa_inputs.size()), "mfea_client/0.1/recv_protocol_message6");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_recv_protocol_message6(	    xa_inputs.get_string("xrl_sender_name"),	    xa_inputs.get_string("protocol_name"),	    xa_inputs.get_uint32("protocol_id"),	    xa_inputs.get_string("vif_name"),	    xa_inputs.get_uint32("vif_index"),	    xa_inputs.get_ipv6("source_address"),	    xa_inputs.get_ipv6("dest_address"),	    xa_inputs.get_int32("ip_ttl"),	    xa_inputs.get_int32("ip_tos"),	    xa_inputs.get_bool("is_router_alert"),	    xa_inputs.get_binary("protocol_message"));	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/recv_protocol_message6", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_recv_kernel_signal_message4(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */){    if (xa_inputs.size() != 9) {	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",            XORP_UINT_CAST(9), XORP_UINT_CAST(xa_inputs.size()), "mfea_client/0.1/recv_kernel_signal_message4");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_recv_kernel_signal_message4(	    xa_inputs.get_string("xrl_sender_name"),	    xa_inputs.get_string("protocol_name"),	    xa_inputs.get_uint32("protocol_id"),	    xa_inputs.get_uint32("message_type"),	    xa_inputs.get_string("vif_name"),	    xa_inputs.get_uint32("vif_index"),	    xa_inputs.get_ipv4("source_address"),	    xa_inputs.get_ipv4("dest_address"),	    xa_inputs.get_binary("protocol_message"));	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/recv_kernel_signal_message4", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_recv_kernel_signal_message6(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */){    if (xa_inputs.size() != 9) {	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",            XORP_UINT_CAST(9), XORP_UINT_CAST(xa_inputs.size()), "mfea_client/0.1/recv_kernel_signal_message6");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_recv_kernel_signal_message6(	    xa_inputs.get_string("xrl_sender_name"),	    xa_inputs.get_string("protocol_name"),	    xa_inputs.get_uint32("protocol_id"),	    xa_inputs.get_uint32("message_type"),	    xa_inputs.get_string("vif_name"),	    xa_inputs.get_uint32("vif_index"),	    xa_inputs.get_ipv6("source_address"),	    xa_inputs.get_ipv6("dest_address"),	    xa_inputs.get_binary("protocol_message"));	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/recv_kernel_signal_message6", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_recv_dataflow_signal4(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */){    if (xa_inputs.size() != 15) {	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",            XORP_UINT_CAST(15), XORP_UINT_CAST(xa_inputs.size()), "mfea_client/0.1/recv_dataflow_signal4");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_recv_dataflow_signal4(	    xa_inputs.get_string("xrl_sender_name"),	    xa_inputs.get_ipv4("source_address"),	    xa_inputs.get_ipv4("group_address"),	    xa_inputs.get_uint32("threshold_interval_sec"),	    xa_inputs.get_uint32("threshold_interval_usec"),	    xa_inputs.get_uint32("measured_interval_sec"),	    xa_inputs.get_uint32("measured_interval_usec"),	    xa_inputs.get_uint32("threshold_packets"),	    xa_inputs.get_uint32("threshold_bytes"),	    xa_inputs.get_uint32("measured_packets"),	    xa_inputs.get_uint32("measured_bytes"),	    xa_inputs.get_bool("is_threshold_in_packets"),	    xa_inputs.get_bool("is_threshold_in_bytes"),	    xa_inputs.get_bool("is_geq_upcall"),	    xa_inputs.get_bool("is_leq_upcall"));	if (e != XrlCmdError::OKAY()) {	    XLOG_WARNING("Handling method for %s failed: %s",            		 "mfea_client/0.1/recv_dataflow_signal4", e.str().c_str());	    return e;        }    } catch (const XrlArgs::XrlAtomNotFound& e) {	XLOG_ERROR("Argument not found");	return XrlCmdError::BAD_ARGS();    }    return XrlCmdError::OKAY();}const XrlCmdErrorXrlMld6igmpTargetBase::handle_mfea_client_0_1_recv_dataflow_signal6(const XrlArgs& xa_inputs, XrlArgs* /* pxa_outputs */){    if (xa_inputs.size() != 15) {	XLOG_ERROR("Wrong number of arguments (%u != %u) handling %s",            XORP_UINT_CAST(15), XORP_UINT_CAST(xa_inputs.size()), "mfea_client/0.1/recv_dataflow_signal6");	return XrlCmdError::BAD_ARGS();    }    /* Return value declarations */    try {	XrlCmdError e = mfea_client_0_1_recv_dataflow_signal6(	    xa_inputs.get_string("xrl_sender_name"),	    xa_inputs.get_ipv6("source_address"),	    xa_inputs.get_ipv6("group_address"),	    xa_inputs.get_uint32("threshold_interval_sec"),	    xa_inputs.get_uint32("threshold_interval_usec"),	    xa_inputs.get_uint32("measured_interval_sec"),	    xa_inputs.get_uint32("measured_interval_usec"),	    xa_inputs.get_uint32("threshold_packets"),	    xa_inputs.get_uint32("threshold_bytes"),	    xa_inputs.get_uint32("measured_packets"),	    xa_inputs.get_uint32("measured_bytes"),
⌨️ 快捷键说明

复制代码 Ctrl + C
搜索代码 Ctrl + F
全屏模式 F11
切换主题 Ctrl + Shift + D
显示快捷键 ?
增大字号 Ctrl + =
减小字号 Ctrl + -