From: Isaku Yamahata <yamah...@valinux.co.jp>

Signed-off-by: Isaku Yamahata <yamah...@valinux.co.jp>
Signed-off-by: Simon Horman <ho...@verge.net.au>

---

v4 [Simon Horman]
* Remove utilities/ovs-ofctl.c hunk, introduced in v3,
  which belongs in a different patch
* Make use of new oxm_writable field in struct mf_subfield
  to implement mf_check_dst_oxm(). This provides more
  strict checking than the previous implementation.
* Do not call pre-requisites explicitly in mf_are_prereqs_ok()
  - It will segfault as flow is NULL
  - It would be called by mf_is_value_valid() if
    flow was not NULL
* Correct byte-order issues in nxm_reg_load_from_openflow12_set_field()
* Add set_field_format() and use it in nxm_format_reg_load()
* Update to use mf_subfield

v3 [Simon Horman]
* Add (now) missing cases to nxm_reg_load_check()

v2 [Isaku Yamahata]
* First post
---
 lib/meta-flow.c |   29 ++++++++++++----
 lib/meta-flow.h |    1 +
 lib/nx-match.c  |  100 +++++++++++++++++++++++++++++++++++++++++++++++++++----
 lib/nx-match.h  |    2 ++
 4 files changed, 120 insertions(+), 12 deletions(-)

diff --git a/lib/meta-flow.c b/lib/meta-flow.c
index a6de1b6..b89d939 100644
--- a/lib/meta-flow.c
+++ b/lib/meta-flow.c
@@ -1703,14 +1703,12 @@ mf_check_src(const struct mf_subfield *sf, const struct 
flow *flow)
     return mf_check__(sf, flow, "source");
 }
 
-/* Checks whether 'sf' is valid for writing a subfield into 'flow'.  Returns 0
- * if so, otherwise an OpenFlow error code (e.g. as returned by
- * ofp_mkerr()). */
-enum ofperr
-mf_check_dst(const struct mf_subfield *sf, const struct flow *flow)
+static enum ofperr
+mf_check_dst__(const struct mf_subfield *sf, const struct flow *flow,
+             bool writable)
 {
     int error = mf_check__(sf, flow, "destination");
-    if (!error && !sf->field->writable) {
+    if (!error && !writable) {
         VLOG_WARN_RL(&rl, "destination field %s is not writable",
                      sf->field->name);
         return OFPERR_OFPBAC_BAD_ARGUMENT;
@@ -1718,6 +1716,25 @@ mf_check_dst(const struct mf_subfield *sf, const struct 
flow *flow)
     return error;
 }
 
+/* Checks whether 'sf' is valid for writing a subfield into 'flow' using
+ * an OpenFlow set-field action.  Returns 0
+ * if so, otherwise an OpenFlow error code (e.g. as returned by
+ * ofp_mkerr()). */
+enum ofperr
+mf_check_dst_oxm(const struct mf_subfield *sf, const struct flow *flow)
+{
+    return mf_check_dst__(sf, flow, sf->field->oxm_writable);
+}
+
+/* Checks whether 'sf' is valid for writing a subfield into 'flow'.  Returns 0
+ * if so, otherwise an OpenFlow error code (e.g. as returned by
+ * ofp_mkerr()). */
+enum ofperr
+mf_check_dst(const struct mf_subfield *sf, const struct flow *flow)
+{
+    return mf_check_dst__(sf, flow, sf->field->writable);
+}
+
 /* Copies the value and wildcard bit pattern for 'mf' from 'match' into the
  * 'value' and 'mask', respectively. */
 void
diff --git a/lib/meta-flow.h b/lib/meta-flow.h
index c9f7f16..74bf994 100644
--- a/lib/meta-flow.h
+++ b/lib/meta-flow.h
@@ -335,6 +335,7 @@ const char *mf_parse_subfield(struct mf_subfield *, const 
char *);
 
 enum ofperr mf_check_src(const struct mf_subfield *, const struct flow *);
 enum ofperr mf_check_dst(const struct mf_subfield *, const struct flow *);
+enum ofperr mf_check_dst_oxm(const struct mf_subfield *, const struct flow *);
 
 /* Parsing and formatting. */
 char *mf_parse(const struct mf_field *, const char *,
diff --git a/lib/nx-match.c b/lib/nx-match.c
index 6fa583e..5773f67 100644
--- a/lib/nx-match.c
+++ b/lib/nx-match.c
@@ -1022,14 +1022,33 @@ nxm_format_reg_move(const struct ofpact_reg_move *move, 
struct ds *s)
     mf_format_subfield(&move->dst, s);
 }
 
+static void
+set_field_format(const struct ofpact_reg_load *load, struct ds *s)
+{
+    const struct mf_field *mf = load->dst.field;
+    union mf_value value;
+
+    assert(load->ofpact.compat == OFPUTIL_OFPAT12_SET_FIELD);
+    ds_put_format(s, "set_field:");
+    memset(&value, 0, sizeof value);
+    bitwise_copy(&load->subvalue, sizeof load->subvalue, load->dst.ofs,
+                 &value, mf->n_bytes, 0, load->dst.n_bits);
+    mf_format(mf, &value, NULL, s);
+    ds_put_format(s, "->%s", mf->name);
+}
+
 void
 nxm_format_reg_load(const struct ofpact_reg_load *load, struct ds *s)
 {
-    ovs_be64 value_be = htonll(0);
-    bitwise_copy(&load->subvalue, sizeof load->subvalue, load->dst.ofs,
-                 &value_be, sizeof value_be, 0, load->dst.n_bits);
-    ds_put_format(s, "load:%#"PRIx64"->", ntohll(value_be));
-    mf_format_subfield(&load->dst, s);
+    if (load->ofpact.compat == OFPUTIL_OFPAT12_SET_FIELD) {
+        set_field_format(load, s);
+    } else {
+        ovs_be64 value_be = htonll(0);
+        bitwise_copy(&load->subvalue, sizeof load->subvalue, load->dst.ofs,
+                     &value_be, sizeof value_be, 0, load->dst.n_bits);
+        ds_put_format(s, "load:%#"PRIx64"->", ntohll(value_be));
+        mf_format_subfield(&load->dst, s);
+    }
 }
 
 enum ofperr
@@ -1073,6 +1092,47 @@ nxm_reg_load_from_openflow(const struct 
nx_action_reg_load *narl,
 
     return nxm_reg_load_check(load, NULL);
 }
+
+enum ofperr
+nxm_reg_load_from_openflow12_set_field(
+    const struct ofp12_action_set_field * oasf, struct ofpbuf *ofpacts)
+{
+    uint16_t oasf_len = ntohs(oasf->len);
+    ovs_be32 *p = (ovs_be32*)oasf->field;
+    uint32_t oxm_header = ntohl(*p);
+    uint8_t oxm_length = NXM_LENGTH(oxm_header);
+    struct ofpact_reg_load *load;
+    const struct mf_field *mf;
+    int i;
+
+    /* ofp12_action_set_field is padded to 64 bits by zero */
+    if (oasf_len != ROUND_UP(sizeof(*oasf) + oxm_length, 8)) {
+        return OFPERR_OFPBAC_BAD_ARGUMENT;
+    }
+    for (i = sizeof(*oasf) + oxm_length; i < oasf_len; i++) {
+        if (((const char*)oasf)[i]) {
+            return OFPERR_OFPBAC_BAD_ARGUMENT;
+        }
+    }
+
+    if (NXM_HASMASK(oxm_header)) {
+        return OFPERR_OFPBAC_BAD_ARGUMENT;
+    }
+    mf = mf_from_nxm_header(oxm_header);
+    if (!mf || mf->oxm_header == 0) {
+        return OFPERR_OFPBAC_BAD_ARGUMENT;
+    }
+    load = ofpact_put_REG_LOAD(ofpacts);
+    load->ofpact.compat = OFPUTIL_OFPAT12_SET_FIELD;
+    load->dst.field = mf;
+    load->dst.ofs = 0;
+    load->dst.n_bits = mf->n_bits;
+    bitwise_copy(oasf + 1, mf->n_bytes, load->dst.ofs,
+                 &load->subvalue, sizeof load->subvalue, load->dst.ofs,
+                 mf->n_bits);
+
+    return nxm_reg_load_check(load, NULL);
+}
 
 enum ofperr
 nxm_reg_move_check(const struct ofpact_reg_move *move, const struct flow *flow)
@@ -1090,7 +1150,23 @@ nxm_reg_move_check(const struct ofpact_reg_move *move, 
const struct flow *flow)
 enum ofperr
 nxm_reg_load_check(const struct ofpact_reg_load *load, const struct flow *flow)
 {
-    return mf_check_dst(&load->dst, flow);
+    const struct mf_field *mf;
+    union mf_value value;
+
+    if (load->ofpact.compat != OFPUTIL_OFPAT12_SET_FIELD) {
+        return mf_check_dst(&load->dst, flow);
+    }
+
+    mf = load->dst.field;
+
+    memset(&value, 0, sizeof value);
+    bitwise_copy(&load->subvalue, sizeof load->subvalue, load->dst.ofs,
+                 &value, load->dst.field->n_bytes, load->dst.ofs,
+                 load->dst.n_bits);
+    if (!mf_is_value_valid(mf, &value)) {
+        return OFPERR_OFPBAC_BAD_ARGUMENT;
+    }
+    return mf_check_dst_oxm(&load->dst, flow);
 }
 
 void
@@ -1113,6 +1189,18 @@ nxm_reg_load_to_nxast(const struct ofpact_reg_load *load,
 {
     struct nx_action_reg_load *narl;
 
+    if (load->ofpact.compat == OFPUTIL_OFPAT12_SET_FIELD) {
+        const struct mf_field *mf = load->dst.field;
+        struct ofp12_action_set_field *oasf;
+
+        oasf = ofputil_put_OFPAT12_SET_FIELD(openflow);
+        *(uint32_t *)oasf->field = mf->oxm_header;
+        memset(oasf + 1, 0, mf->n_bytes);
+        bitwise_copy(&load->subvalue, sizeof load->subvalue, load->dst.ofs,
+                     oasf + 1, mf->n_bytes, load->dst.ofs, load->dst.n_bits);
+        return;
+    }
+
     narl = ofputil_put_NXAST_REG_LOAD(openflow);
     narl->ofs_nbits = nxm_encode_ofs_nbits(load->dst.ofs, load->dst.n_bits);
     narl->dst = htonl(load->dst.field->nxm_header);
diff --git a/lib/nx-match.h b/lib/nx-match.h
index f504ad0..6a57297 100644
--- a/lib/nx-match.h
+++ b/lib/nx-match.h
@@ -65,6 +65,8 @@ enum ofperr nxm_reg_move_from_openflow(const struct 
nx_action_reg_move *,
                                        struct ofpbuf *ofpacts);
 enum ofperr nxm_reg_load_from_openflow(const struct nx_action_reg_load *,
                                        struct ofpbuf *ofpacts);
+enum ofperr nxm_reg_load_from_openflow12_set_field(
+    const struct ofp12_action_set_field * oasf, struct ofpbuf *ofpacts);
 
 enum ofperr nxm_reg_move_check(const struct ofpact_reg_move *,
                                const struct flow *);
-- 
1.7.10.4

_______________________________________________
dev mailing list
dev@openvswitch.org
http://openvswitch.org/mailman/listinfo/dev

Reply via email to