[ovs-dev] [PATCH v7] ofproto: Implement OF1.4 Group & Meter change notification messages
niti Rohilla
niti1489 at gmail.com
Tue Sep 8 12:20:40 UTC 2015
Hi Ben,
Greetings!
This is in reference to the following patch which is under review:
1. [PATCH v7] ofproto: Implement OF1.4 Group & Meter change notification
messages.
Request to kindly provide inputs on the same(if any) or if any action is
required from our end.
Thanks
Niti Rohilla
On Tue, Aug 25, 2015 at 4:41 PM, <niti1489 at gmail.com> wrote:
> From: Niti Rohilla <niti.rohilla at tcs.com>
>
> This patch adds support for Openflow1.4 Group & meter change notification
> messages. In a multi controller environment, when a controller modifies the
> state of group and meter table, the request that successfully modifies this
> state is forwarded to other controllers. Other controllers are informed
> with
> the OFPT_REQUESTFORWARD message. Request forwarding is enabled on a per
> controller channel basis using the Set Asynchronous Configuration Message.
>
> Signed-off-by: Niti Rohilla <niti.rohilla at tcs.com>
> ---
> Following are the changes between v6 and v7:
>
> 1. Rebased with the current master branch.
>
> include/openflow/openflow-1.4.h | 6 +++
> lib/learning-switch.c | 1 +
> lib/ofp-msgs.h | 6 +++
> lib/ofp-print.c | 36 +++++++++++++++
> lib/ofp-util.c | 99
> +++++++++++++++++++++++++++++++++++++++++
> lib/ofp-util.h | 16 +++++++
> lib/rconn.c | 1 +
> ofproto/connmgr.c | 47 +++++++++++++++++++
> ofproto/connmgr.h | 4 ++
> ofproto/ofproto.c | 27 ++++++++---
> tests/ofp-print.at | 46 +++++++++++++++++++
> tests/ofproto.at | 76 +++++++++++++++++++++++++++++++
> 12 files changed, 360 insertions(+), 5 deletions(-)
>
> diff --git a/include/openflow/openflow-1.4.h
> b/include/openflow/openflow-1.4.h
> index 37eef4a..5202fe1 100644
> --- a/include/openflow/openflow-1.4.h
> +++ b/include/openflow/openflow-1.4.h
> @@ -355,6 +355,12 @@ struct ofp14_role_prop_experimenter {
> };
> OFP_ASSERT(sizeof(struct ofp14_role_prop_experimenter) == 12);
>
> +/* Group/Meter request forwarding. */
> +struct ofp14_requestforward {
> + struct ofp_header request; /* Request being forwarded. */
> +};
> +OFP_ASSERT(sizeof(struct ofp14_requestforward) == 8);
> +
> /* Bundle control message types */
> enum ofp14_bundle_ctrl_type {
> OFPBCT_OPEN_REQUEST = 0,
> diff --git a/lib/learning-switch.c b/lib/learning-switch.c
> index 1753cea..7ddf69b 100644
> --- a/lib/learning-switch.c
> +++ b/lib/learning-switch.c
> @@ -419,6 +419,7 @@ lswitch_process_packet(struct lswitch *sw, const
> struct ofpbuf *msg)
> case OFPTYPE_ROLE_REQUEST:
> case OFPTYPE_ROLE_REPLY:
> case OFPTYPE_ROLE_STATUS:
> + case OFPTYPE_REQUESTFORWARD:
> case OFPTYPE_SET_FLOW_FORMAT:
> case OFPTYPE_FLOW_MOD_TABLE_ID:
> case OFPTYPE_SET_PACKET_IN_FORMAT:
> diff --git a/lib/ofp-msgs.h b/lib/ofp-msgs.h
> index 8558e58..132e405 100644
> --- a/lib/ofp-msgs.h
> +++ b/lib/ofp-msgs.h
> @@ -247,6 +247,9 @@ enum ofpraw {
> /* OFPT 1.4+ (30): struct ofp14_role_status, uint8_t[8][]. */
> OFPRAW_OFPT14_ROLE_STATUS,
>
> + /* OFPT 1.4+ (32): struct ofp14_requestforward, uint8_t[8][]. */
> + OFPRAW_OFPT14_REQUESTFORWARD,
> +
> /* OFPT 1.4+ (33): struct ofp14_bundle_ctrl_msg, uint8_t[8][]. */
> OFPRAW_OFPT14_BUNDLE_CONTROL,
>
> @@ -559,6 +562,9 @@ enum ofptype {
> /* Controller role change event messages. */
> OFPTYPE_ROLE_STATUS, /* OFPRAW_OFPT14_ROLE_STATUS. */
>
> + /* Request forwarding by the switch. */
> + OFPTYPE_REQUESTFORWARD, /* OFPRAW_OFPT14_REQUESTFORWARD. */
> +
> OFPTYPE_BUNDLE_CONTROL, /* OFPRAW_OFPT14_BUNDLE_CONTROL. */
>
> OFPTYPE_BUNDLE_ADD_MESSAGE, /* OFPRAW_OFPT14_BUNDLE_ADD_MESSAGE. */
> diff --git a/lib/ofp-print.c b/lib/ofp-print.c
> index 6e32d4d..b2d3b4f 100644
> --- a/lib/ofp-print.c
> +++ b/lib/ofp-print.c
> @@ -3050,6 +3050,38 @@ ofp_print_geneve_table_reply(struct ds *s, const
> struct ofp_header *oh)
> ofputil_uninit_geneve_table(>r.mappings);
> }
>
> +/* This function will print the request forward message. The reason for
> + * request forward is taken from rf.request.type */
> +static void
> +ofp_print_requestforward(struct ds *string, const struct ofp_header *oh)
> +{
> + struct ofputil_requestforward rf;
> + enum ofperr error;
> + enum ofptype type;
> +
> + error = ofputil_decode_requestforward(oh, &rf);
> + if (error) {
> + ofp_print_error(string, error);
> + return;
> + }
> +
> + error = ofptype_decode(&type, rf.request);
> + if (error) {
> + ofp_print_error(string, error);
> + return;
> + }
> +
> + ds_put_cstr(string, " reason=");
> +
> + if (type == OFPTYPE_GROUP_MOD) {
> + ds_put_cstr(string, "group_mod");
> + ofp_print_group_mod(string, rf.request);
> + } else if (type == OFPTYPE_METER_MOD) {
> + ds_put_cstr(string, "meter_mod");
> + ofp_print_meter_mod(string, rf.request);
> + }
> +}
> +
> static void
> ofp_to_string__(const struct ofp_header *oh, enum ofpraw raw,
> struct ds *string, int verbosity)
> @@ -3179,6 +3211,10 @@ ofp_to_string__(const struct ofp_header *oh, enum
> ofpraw raw,
> ofp_print_role_status_message(string, oh);
> break;
>
> + case OFPTYPE_REQUESTFORWARD:
> + ofp_print_requestforward(string, oh);
> + break;
> +
> case OFPTYPE_METER_STATS_REQUEST:
> case OFPTYPE_METER_CONFIG_STATS_REQUEST:
> ofp_print_stats(string, oh);
> diff --git a/lib/ofp-util.c b/lib/ofp-util.c
> index 0a5232d..258af4e 100644
> --- a/lib/ofp-util.c
> +++ b/lib/ofp-util.c
> @@ -5390,6 +5390,104 @@ ofputil_decode_role_status(const struct ofp_header
> *oh,
> return 0;
> }
>
> +/* Re-encodes the "GROUP_MOD" or "METER_MOD" request header for the
> + * 'protocol' in the ofconn. */
> +enum ofperr
> +ofputil_re_encode_requestforward(uint8_t reason,
> + const struct ofp_header *request,
> + struct ofp_header **requestp,
> + enum ofputil_protocol protocol)
> +{
> + enum ofp_version version;
> + struct ofp_header *rf;
> + struct ofpbuf *buf = ofpbuf_new(0);
> + enum ofperr error;
> +
> + version = ofputil_protocol_to_ofp_version(protocol);
> + switch (reason) {
> + case OFPRFR_GROUP_MOD: {
> + struct ofputil_group_mod gm;
> +
> + error = ofputil_decode_group_mod(request, &gm);
> + if (error) {
> + return error;
> + }
> + buf = ofputil_encode_group_mod(version, &gm);
> + break;
> + }
> + case OFPRFR_METER_MOD: {
> + struct ofputil_meter_mod mm;
> + struct ofpbuf bands;
> +
> + ofpbuf_init(&bands, 64);
> + error = ofputil_decode_meter_mod(request, &mm, &bands);
> + if (error) {
> + ofpbuf_uninit(&bands);
> + return error;
> + }
> + buf = ofputil_encode_meter_mod(version, &mm);
> + break;
> + }
> + default:
> + OVS_NOT_REACHED();
> + }
> + rf = buf->data;
> + rf->length = htons(buf->size);
> + rf->xid = request->xid;
> + *requestp = rf;
> + return 0;
> +}
> +
> +/* Encodes "request forward" message encapsulating "GROUP_MOD" or
> "METER_MOD"
> + * request in 'rf'. The OpenFlow version of OFPT_REQUESTFORWARD message
> and
> + * 'rf->request' should be same.
> + * 'rf->request' is not converted from host to network byte order because
> + * "GROUP_MOD" or "METER_MOD" request header in 'rf' is directly
> encapsulated
> + * in request forward message. */
> +struct ofpbuf *
> +ofputil_encode_requestforward(const struct ofputil_requestforward *rf)
> +{
> + struct ofpbuf *buf;
> +
> + buf = ofpraw_alloc_xid(OFPRAW_OFPT14_REQUESTFORWARD,
> rf->request->version,
> + htonl(0), ntohs(rf->request->length));
> + ofpbuf_put(buf, rf->request, ntohs(rf->request->length));
> + return buf;
> +}
> +
> +/* Converts OpenFlow request forward message 'oh' into an abstract
> request
> + * forward in 'rf'. Returns 0 if successful, otherwise an OpenFlow error
> + * code. */
> +enum ofperr
> +ofputil_decode_requestforward(const struct ofp_header *oh,
> + struct ofputil_requestforward *rf)
> +{
> + struct ofpbuf b;
> + enum ofpraw raw;
> + enum ofperr error;
> + size_t inner_len;
> +
> + ofpbuf_use_const(&b, oh, ntohs(oh->length));
> + error = ofpraw_pull(&raw, &b);
> + if (error) {
> + return error;
> + }
> +
> + ovs_assert(raw == OFPRAW_OFPT14_REQUESTFORWARD);
> +
> + rf->request = b.data;
> +
> + if (rf->request->version != oh->version) {
> + return OFPERR_OFPBRC_BAD_VERSION;
> + }
> + inner_len = ntohs(rf->request->length);
> + if (inner_len < sizeof(struct ofp_header) || inner_len > b.size) {
> + return OFPERR_OFPBFC_MSG_BAD_LEN;
> + }
> +
> + return 0;
> +}
> +
> /* Table stats. */
>
> /* OpenFlow 1.0 and 1.1 don't distinguish between a field that cannot be
> @@ -9071,6 +9169,7 @@ ofputil_is_bundlable(enum ofptype type)
> case OFPTYPE_TABLE_FEATURES_STATS_REPLY:
> case OFPTYPE_TABLE_DESC_REPLY:
> case OFPTYPE_ROLE_STATUS:
> + case OFPTYPE_REQUESTFORWARD:
> case OFPTYPE_NXT_GENEVE_TABLE_REQUEST:
> case OFPTYPE_NXT_GENEVE_TABLE_REPLY:
> break;
> diff --git a/lib/ofp-util.h b/lib/ofp-util.h
> index 2668e75..a8de01f 100644
> --- a/lib/ofp-util.h
> +++ b/lib/ofp-util.h
> @@ -861,6 +861,22 @@ struct ofpbuf *ofputil_encode_role_status(
> enum ofperr ofputil_decode_role_status(const struct ofp_header *oh,
> struct ofputil_role_status *rs);
>
> +struct ofputil_requestforward {
> + const struct ofp_header *request;
> +};
> +
> +enum ofperr
> +ofputil_re_encode_requestforward(uint8_t reason,
> + const struct ofp_header *request,
> + struct ofp_header **requestp,
> + enum ofputil_protocol protocol);
> +struct ofpbuf *
> +ofputil_encode_requestforward(const struct ofputil_requestforward *rf);
> +
> +enum ofperr
> +ofputil_decode_requestforward(const struct ofp_header *oh,
> + struct ofputil_requestforward *rf);
> +
> /* Abstract table stats.
> *
> * This corresponds to the OpenFlow 1.3 table statistics structure, which
> only
> diff --git a/lib/rconn.c b/lib/rconn.c
> index 37adfa2..0a9966a 100644
> --- a/lib/rconn.c
> +++ b/lib/rconn.c
> @@ -1403,6 +1403,7 @@ is_admitted_msg(const struct ofpbuf *b)
> case OFPTYPE_ROLE_REQUEST:
> case OFPTYPE_ROLE_REPLY:
> case OFPTYPE_ROLE_STATUS:
> + case OFPTYPE_REQUESTFORWARD:
> case OFPTYPE_SET_FLOW_FORMAT:
> case OFPTYPE_FLOW_MOD_TABLE_ID:
> case OFPTYPE_SET_PACKET_IN_FORMAT:
> diff --git a/ofproto/connmgr.c b/ofproto/connmgr.c
> index b1ba0c6..60f3d9a 100644
> --- a/ofproto/connmgr.c
> +++ b/ofproto/connmgr.c
> @@ -1709,6 +1709,53 @@ connmgr_send_port_status(struct connmgr *mgr,
> struct ofconn *source,
> }
> }
>
> +/* Sends an OFPT_REQUESTFORWARD message with 'request' and 'reason' to
> + * appropriate controllers managed by 'mgr'. For messages caused by a
> + * controller OFPT_GROUP_MOD and OFPT_METER_MOD, specify 'source' as the
> + * controller connection that sent the request; otherwise, specify
> 'source'
> + * as NULL. */
> +enum ofperr
> +connmgr_send_requestforward(struct connmgr *mgr, struct ofconn *source,
> + uint8_t reason, const struct ofp_header *oh)
> +{
> + struct ofputil_requestforward rf;
> + struct ofconn *ofconn;
> + struct ofp_header *request = NULL;
> + enum ofperr error;
> +
> + LIST_FOR_EACH (ofconn, node, &mgr->all_conns) {
> + if (ofconn_receives_async_msg(ofconn, OAM_REQUESTFORWARD,
> reason)) {
> + struct ofpbuf *msg;
> +
> + rf.request = oh;
> + /* For OpenFlow 1.4 and later, it generates
> OFPT_REQUESTFORWARD
> + * for OFPT_GROUP_MOD and OFPT_METER_MOD, but not back to the
> + * originating controller. In a single-controller
> environment, in
> + * particular, this means that it will never generate
> + * OFPT_REQUESTFORWARD for OFPT_GROUP_MOD and OFPT_METER_MOD
> at
> + * all. */
> + if (rconn_get_version(ofconn->rconn) < OFP14_VERSION
> + || ofconn == source) {
> + continue;
> + }
> + /* When the version of GROUP_MOD or METER_MOD request is not
> same
> + * as that of ofconn, then re-encode the GROUP_MOD or
> METER_MOD
> + * request for the protocol in use. */
> + if (oh->version != rconn_get_version(ofconn->rconn)) {
> + error = ofputil_re_encode_requestforward(reason, oh,
> &request,
> +
> ofconn_get_protocol(ofconn));
> + if (error) {
> + return error;
> + }
> + rf.request = request;
> + }
> + msg = ofputil_encode_requestforward(&rf);
> + ofconn_send(ofconn, msg, NULL);
> + }
> + }
> + return 0;
> +}
> +
> /* Sends an OFPT_FLOW_REMOVED or NXT_FLOW_REMOVED message based on 'fr' to
> * appropriate controllers managed by 'mgr'. */
> void
> diff --git a/ofproto/connmgr.h b/ofproto/connmgr.h
> index 7ef583a..2de7f6f 100644
> --- a/ofproto/connmgr.h
> +++ b/ofproto/connmgr.h
> @@ -168,6 +168,10 @@ void connmgr_send_packet_in(struct connmgr *,
> void ofconn_send_role_status(struct ofconn *ofconn, uint32_t role,
> uint8_t reason);
>
> +enum ofperr
> +connmgr_send_requestforward(struct connmgr *, struct ofconn *source,
> + uint8_t reason, const struct ofp_header *);
> +
> /* Fail-open settings. */
> enum ofproto_fail_mode connmgr_get_fail_mode(const struct connmgr *);
> void connmgr_set_fail_mode(struct connmgr *, enum ofproto_fail_mode);
> diff --git a/ofproto/ofproto.c b/ofproto/ofproto.c
> index e9b1472..cb87b63 100644
> --- a/ofproto/ofproto.c
> +++ b/ofproto/ofproto.c
> @@ -5908,6 +5908,11 @@ handle_meter_mod(struct ofconn *ofconn, const
> struct ofp_header *oh)
> break;
> }
>
> + if (!error) {
> + error =connmgr_send_requestforward(ofproto->connmgr, ofconn,
> + OFPRFR_METER_MOD, oh);
> + }
> +
> exit_free_bands:
> ofpbuf_uninit(&bands);
> return error;
> @@ -6575,20 +6580,25 @@ handle_group_mod(struct ofconn *ofconn, const
> struct ofp_header *oh)
>
> switch (gm.command) {
> case OFPGC11_ADD:
> - return add_group(ofproto, &gm);
> + error = add_group(ofproto, &gm);
> + break;
>
> case OFPGC11_MODIFY:
> - return modify_group(ofproto, &gm);
> + error = modify_group(ofproto, &gm);
> + break;
>
> case OFPGC11_DELETE:
> delete_group(ofproto, gm.group_id);
> - return 0;
> + error = 0;
> + break;
>
> case OFPGC15_INSERT_BUCKET:
> - return modify_group(ofproto, &gm);
> + error = modify_group(ofproto, &gm);
> + break;
>
> case OFPGC15_REMOVE_BUCKET:
> - return modify_group(ofproto, &gm);
> + error = modify_group(ofproto, &gm);
> + break;
>
> default:
> if (gm.command > OFPGC11_DELETE) {
> @@ -6597,6 +6607,12 @@ handle_group_mod(struct ofconn *ofconn, const
> struct ofp_header *oh)
> }
> return OFPERR_OFPGMFC_BAD_COMMAND;
> }
> +
> + if (!error) {
> + error = connmgr_send_requestforward(ofproto->connmgr, ofconn,
> + OFPRFR_GROUP_MOD, oh);
> + }
> + return error;
> }
>
> enum ofputil_table_miss
> @@ -7211,6 +7227,7 @@ handle_openflow__(struct ofconn *ofconn, const
> struct ofpbuf *msg)
> case OFPTYPE_TABLE_FEATURES_STATS_REPLY:
> case OFPTYPE_TABLE_DESC_REPLY:
> case OFPTYPE_ROLE_STATUS:
> + case OFPTYPE_REQUESTFORWARD:
> case OFPTYPE_NXT_GENEVE_TABLE_REPLY:
> default:
> if (ofpmsg_is_stat_request(oh)) {
> diff --git a/tests/ofp-print.at b/tests/ofp-print.at
> index 35a6262..8cdcead 100644
> --- a/tests/ofp-print.at
> +++ b/tests/ofp-print.at
> @@ -2675,6 +2675,52 @@ OFPT_ROLE_STATUS (OF1.4) (xid=0xa): role=master
> generation_id=16 reason=configur
> ])
> AT_CLEANUP
>
> +AT_SETUP([OFP_REQUESTFORWARD - OF1.4])
> +AT_KEYWORDS([ofp-print])
> +AT_CHECK([ovs-ofctl ofp-print "\
> +05 20 00 18 00 00 00 02 \
> +05 0f 00 10 02 00 00 00 \
> +00 00 00 00 00 00 00 01 \
> +"], [0], [dnl
> +OFPT_REQUESTFORWARD (OF1.4) (xid=0x2): reason=group_mod
> + ADD group_id=1,type=all
> +])
> +AT_CLEANUP
> +
> +AT_SETUP([OFP_REQUESTFORWARD - OF1.4])
> +AT_KEYWORDS([ofp-print])
> +AT_CHECK([ovs-ofctl ofp-print "\
> +05 20 00 18 00 00 00 02 \
> +05 0f 00 10 02 00 00 00 \
> +00 01 01 00 00 00 00 01 \
> +"], [0], [dnl
> +OFPT_REQUESTFORWARD (OF1.4) (xid=0x2): reason=group_mod
> + MOD group_id=1,type=select
> +])
> +AT_CLEANUP
> +
> +AT_SETUP([OFP_REQUESTFORWARD - OF1.4])
> +AT_KEYWORDS([ofp-print])
> +AT_CHECK([ovs-ofctl ofp-print "\
> +05 20 00 18 00 00 00 02 \
> +05 1d 00 10 02 00 00 00 \
> +00 00 00 00 00 00 00 01 \
> +"], [0], [dnl
> +OFPT_REQUESTFORWARD (OF1.4) (xid=0x2): reason=meter_mod ADD meter=1 bands=
> +])
> +AT_CLEANUP
> +
> +AT_SETUP([OFP_REQUESTFORWARD - OF1.4])
> +AT_KEYWORDS([ofp-print])
> +AT_CHECK([ovs-ofctl ofp-print "\
> +05 20 00 18 00 00 00 02 \
> +05 1d 00 10 02 00 00 00 \
> +00 01 01 00 00 00 00 01 \
> +"], [0], [dnl
> +OFPT_REQUESTFORWARD (OF1.4) (xid=0x2): reason=meter_mod MOD meter=1
> flags:0x100 bands=
> +])
> +AT_CLEANUP
> +
> AT_SETUP([NXT_SET_PACKET_IN])
> AT_KEYWORDS([ofp-print])
> AT_CHECK([ovs-ofctl ofp-print "\
> diff --git a/tests/ofproto.at b/tests/ofproto.at
> index e3f08a8..8fdaae6 100644
> --- a/tests/ofproto.at
> +++ b/tests/ofproto.at
> @@ -2899,6 +2899,82 @@ done
> OVS_VSWITCHD_STOP
> AT_CLEANUP
>
> +dnl This test checks the Group and meter notifications when a group mod
> +dnl command is sent from one controller and the reply is received by
> +dnl other controller.
> +AT_SETUP([ofproto - requestforward (OpenFlow 1.4)])
> +OVS_VSWITCHD_START
> +ON_EXIT([kill `cat c1.pid c2.pid`])
> +
> +# Start two ovs-ofctl controller processes.
> +AT_CAPTURE_FILE([monitor1.log])
> +AT_CAPTURE_FILE([expout1])
> +AT_CAPTURE_FILE([monitor2.log])
> +AT_CAPTURE_FILE([expout2])
> +for i in 1 2; do
> + AT_CHECK([ovs-ofctl -O OpenFlow14 monitor br0 --detach --no-chdir
> --pidfile=`pwd`/c$i.pid --unixctl=`pwd`/c$i])
> +done
> +
> +check_async () {
> + for i in 1 2; do
> + ovs-appctl -t `pwd`/c$i ofctl/barrier
> + ovs-appctl -t `pwd`/c$i ofctl/set-output-file monitor$i.log
> + : > expout$i
> + done
> +
> + printf '\n\n--- check_async %d ---\n\n\n' $1
> + INDEX=$1
> + shift
> +
> + # OFPGC_ADD
> + ovs-appctl -t `pwd`/c2 ofctl/send 050f0010000000020000000000000001
> + if test X"$1" = X"OFPGC_ADD"; then shift;
> + echo >>expout2 "send: OFPT_GROUP_MOD (OF1.4):
> + ADD group_id=1,type=all"
> + echo >>expout1 "OFPT_REQUESTFORWARD (OF1.4): reason=group_mod
> + ADD group_id=1,type=all"
> + fi
> +
> + # OFPGC_MODIFY
> + ovs-appctl -t `pwd`/c2 ofctl/send 050f0010000000020001010000000001
> + if test X"$1" = X"OFPGC_MODIFY"; then shift;
> + echo >>expout2 "send: OFPT_GROUP_MOD (OF1.4):
> + MOD group_id=1,type=select"
> + echo >>expout1 "OFPT_REQUESTFORWARD (OF1.4): reason=group_mod
> + MOD group_id=1,type=select"
> + fi
> +
> + for i in 1 2; do
> + ovs-appctl -t `pwd`/c$i ofctl/barrier
> + echo >>expout$i "OFPT_BARRIER_REPLY (OF1.4):"
> + done
> +
> + # Check output.
> + for i in 1 2; do
> + cp expout$i expout
> + AT_CHECK(
> + [[sed '
> +s/ (xid=0x[0-9a-fA-F]*)//'< monitor$i.log]],
> + [0], [expout])
> + done
> +}
> +
> +# controller 1: Become slave
> +ovs-appctl -t `pwd`/c1 ofctl/send
> 051800180000000300000003000000008000000000000002
> +
> +# controller 2: Become master
> +ovs-appctl -t `pwd`/c2 ofctl/send
> 051800180000000300000002000000008000000000000003
> +
> +# controller 1: Enabled requestforward using set Asynchronous message
> +ovs-appctl -t `pwd`/c1 ofctl/send
> 051c00280000000200000008000000050002000800000002000400080000001a000a000800000003
> +
> +# controller 2: Enabled requestforward using set Asynchronous message
> +ovs-appctl -t `pwd`/c2 ofctl/send
> 051c002800000002000100080000000200030008000000050005000800000005000b000800000003
> +check_async 1 OFPGC_ADD OFPGC_MODIFY
> +
> +OVS_VSWITCHD_STOP
> +AT_CLEANUP
> +
> dnl This test checks that OFPT_PACKET_OUT accepts both OFPP_NONE (as
> dnl specified by OpenFlow 1.0) and OFPP_CONTROLLER (used by some
> dnl controllers despite the spec) as meaning a packet that was generated
> --
> 2.5.0
>
>
More information about the dev
mailing list