2011-09-12 16:19:57 -07:00
|
|
|
/*
|
2012-05-02 15:21:36 -07:00
|
|
|
* Copyright (c) 2011, 2012 Nicira, Inc.
|
2011-09-12 16:19:57 -07:00
|
|
|
*
|
|
|
|
* 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.
|
|
|
|
*/
|
|
|
|
|
|
|
|
#include <config.h>
|
|
|
|
|
|
|
|
#include "learn.h"
|
|
|
|
|
|
|
|
#include "byte-order.h"
|
|
|
|
#include "dynamic-string.h"
|
|
|
|
#include "meta-flow.h"
|
|
|
|
#include "nx-match.h"
|
2012-01-12 15:48:19 -08:00
|
|
|
#include "ofp-errors.h"
|
2011-09-12 16:19:57 -07:00
|
|
|
#include "ofp-util.h"
|
|
|
|
#include "ofpbuf.h"
|
|
|
|
#include "openflow/openflow.h"
|
|
|
|
#include "unaligned.h"
|
|
|
|
|
|
|
|
static ovs_be16
|
|
|
|
get_be16(const void **pp)
|
|
|
|
{
|
|
|
|
const ovs_be16 *p = *pp;
|
|
|
|
ovs_be16 value = *p;
|
|
|
|
*pp = p + 1;
|
|
|
|
return value;
|
|
|
|
}
|
|
|
|
|
|
|
|
static ovs_be32
|
|
|
|
get_be32(const void **pp)
|
|
|
|
{
|
|
|
|
const ovs_be32 *p = *pp;
|
|
|
|
ovs_be32 value = get_unaligned_be32(p);
|
|
|
|
*pp = p + 1;
|
|
|
|
return value;
|
|
|
|
}
|
|
|
|
|
|
|
|
static uint64_t
|
|
|
|
get_bits(int n_bits, const void **p)
|
|
|
|
{
|
|
|
|
int n_segs = DIV_ROUND_UP(n_bits, 16);
|
|
|
|
uint64_t value;
|
|
|
|
|
|
|
|
value = 0;
|
|
|
|
while (n_segs-- > 0) {
|
|
|
|
value = (value << 16) | ntohs(get_be16(p));
|
|
|
|
}
|
|
|
|
return value;
|
|
|
|
}
|
|
|
|
|
2011-12-28 12:42:14 -08:00
|
|
|
static void
|
|
|
|
get_subfield(int n_bits, const void **p, struct mf_subfield *sf)
|
|
|
|
{
|
|
|
|
sf->field = mf_from_nxm_header(ntohl(get_be32(p)));
|
|
|
|
sf->ofs = ntohs(get_be16(p));
|
|
|
|
sf->n_bits = n_bits;
|
|
|
|
}
|
|
|
|
|
2011-09-12 16:19:57 -07:00
|
|
|
static unsigned int
|
|
|
|
learn_min_len(uint16_t header)
|
|
|
|
{
|
|
|
|
int n_bits = header & NX_LEARN_N_BITS_MASK;
|
|
|
|
int src_type = header & NX_LEARN_SRC_MASK;
|
|
|
|
int dst_type = header & NX_LEARN_DST_MASK;
|
|
|
|
unsigned int min_len;
|
|
|
|
|
|
|
|
min_len = 0;
|
|
|
|
if (src_type == NX_LEARN_SRC_FIELD) {
|
|
|
|
min_len += sizeof(ovs_be32); /* src_field */
|
|
|
|
min_len += sizeof(ovs_be16); /* src_ofs */
|
|
|
|
} else {
|
|
|
|
min_len += DIV_ROUND_UP(n_bits, 16);
|
|
|
|
}
|
|
|
|
if (dst_type == NX_LEARN_DST_MATCH ||
|
|
|
|
dst_type == NX_LEARN_DST_LOAD) {
|
|
|
|
min_len += sizeof(ovs_be32); /* dst_field */
|
|
|
|
min_len += sizeof(ovs_be16); /* dst_ofs */
|
|
|
|
}
|
|
|
|
return min_len;
|
|
|
|
}
|
|
|
|
|
2012-01-12 15:48:19 -08:00
|
|
|
static enum ofperr
|
2011-09-12 16:19:57 -07:00
|
|
|
learn_check_header(uint16_t header, size_t len)
|
|
|
|
{
|
|
|
|
int src_type = header & NX_LEARN_SRC_MASK;
|
|
|
|
int dst_type = header & NX_LEARN_DST_MASK;
|
|
|
|
|
|
|
|
/* Check for valid src and dst type combination. */
|
|
|
|
if (dst_type == NX_LEARN_DST_MATCH ||
|
|
|
|
dst_type == NX_LEARN_DST_LOAD ||
|
|
|
|
(dst_type == NX_LEARN_DST_OUTPUT &&
|
|
|
|
src_type == NX_LEARN_SRC_FIELD)) {
|
|
|
|
/* OK. */
|
|
|
|
} else {
|
2012-01-12 15:48:19 -08:00
|
|
|
return OFPERR_OFPBAC_BAD_ARGUMENT;
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
/* Check that the arguments don't overrun the end of the action. */
|
|
|
|
if (len < learn_min_len(header)) {
|
2012-01-12 15:48:19 -08:00
|
|
|
return OFPERR_OFPBAC_BAD_LEN;
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Checks that 'learn' (which must be at least 'sizeof *learn' bytes long) is a
|
|
|
|
* valid action on 'flow'. */
|
2012-01-12 15:48:19 -08:00
|
|
|
enum ofperr
|
2011-09-12 16:19:57 -07:00
|
|
|
learn_check(const struct nx_action_learn *learn, const struct flow *flow)
|
|
|
|
{
|
|
|
|
struct cls_rule rule;
|
|
|
|
const void *p, *end;
|
|
|
|
|
|
|
|
cls_rule_init_catchall(&rule, 0);
|
|
|
|
|
|
|
|
if (learn->flags & ~htons(OFPFF_SEND_FLOW_REM)
|
2012-02-15 10:37:03 -08:00
|
|
|
|| learn->pad
|
2011-09-12 16:19:57 -07:00
|
|
|
|| learn->table_id == 0xff) {
|
2012-01-12 15:48:19 -08:00
|
|
|
return OFPERR_OFPBAC_BAD_ARGUMENT;
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
end = (char *) learn + ntohs(learn->len);
|
|
|
|
for (p = learn + 1; p != end; ) {
|
|
|
|
uint16_t header = ntohs(get_be16(&p));
|
|
|
|
int n_bits = header & NX_LEARN_N_BITS_MASK;
|
|
|
|
int src_type = header & NX_LEARN_SRC_MASK;
|
|
|
|
int dst_type = header & NX_LEARN_DST_MASK;
|
|
|
|
|
2012-01-12 15:48:19 -08:00
|
|
|
enum ofperr error;
|
2011-09-12 16:19:57 -07:00
|
|
|
uint64_t value;
|
|
|
|
|
|
|
|
if (!header) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
error = learn_check_header(header, (char *) end - (char *) p);
|
|
|
|
if (error) {
|
|
|
|
return error;
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Check the source. */
|
|
|
|
if (src_type == NX_LEARN_SRC_FIELD) {
|
2011-12-28 12:42:14 -08:00
|
|
|
struct mf_subfield src;
|
2011-09-12 16:19:57 -07:00
|
|
|
|
2011-12-28 12:42:14 -08:00
|
|
|
get_subfield(n_bits, &p, &src);
|
|
|
|
error = mf_check_src(&src, flow);
|
2011-09-12 16:19:57 -07:00
|
|
|
if (error) {
|
|
|
|
return error;
|
|
|
|
}
|
|
|
|
value = 0;
|
|
|
|
} else {
|
|
|
|
value = get_bits(n_bits, &p);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Check the destination. */
|
|
|
|
if (dst_type == NX_LEARN_DST_MATCH || dst_type == NX_LEARN_DST_LOAD) {
|
2011-12-28 12:42:14 -08:00
|
|
|
struct mf_subfield dst;
|
2011-09-12 16:19:57 -07:00
|
|
|
|
2011-12-28 12:42:14 -08:00
|
|
|
get_subfield(n_bits, &p, &dst);
|
2011-09-27 13:10:58 -07:00
|
|
|
error = (dst_type == NX_LEARN_DST_LOAD
|
2011-12-28 12:42:14 -08:00
|
|
|
? mf_check_dst(&dst, &rule.flow)
|
|
|
|
: mf_check_src(&dst, &rule.flow));
|
2011-09-12 16:19:57 -07:00
|
|
|
if (error) {
|
|
|
|
return error;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (dst_type == NX_LEARN_DST_MATCH
|
|
|
|
&& src_type == NX_LEARN_SRC_IMMEDIATE) {
|
2012-04-11 17:08:13 -07:00
|
|
|
if (n_bits <= 64) {
|
|
|
|
mf_set_subfield(&dst, value, &rule);
|
|
|
|
} else {
|
|
|
|
/* We're only setting subfields to allow us to check
|
|
|
|
* prerequisites. No prerequisite depends on the value of
|
|
|
|
* a field that is wider than 64 bits. So just skip
|
|
|
|
* setting it entirely. */
|
2012-06-27 01:09:44 +12:00
|
|
|
BUILD_ASSERT_DECL(FLOW_WC_SEQ == 12);
|
2012-04-11 17:08:13 -07:00
|
|
|
}
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (!is_all_zeros(p, (char *) end - (char *) p)) {
|
2012-01-12 15:48:19 -08:00
|
|
|
return OFPERR_OFPBAC_BAD_ARGUMENT;
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
learn_execute(const struct nx_action_learn *learn, const struct flow *flow,
|
|
|
|
struct ofputil_flow_mod *fm)
|
|
|
|
{
|
|
|
|
const void *p, *end;
|
|
|
|
struct ofpbuf actions;
|
|
|
|
|
|
|
|
cls_rule_init_catchall(&fm->cr, ntohs(learn->priority));
|
2012-03-24 01:02:26 -07:00
|
|
|
fm->cookie = htonll(0);
|
|
|
|
fm->cookie_mask = htonll(0);
|
|
|
|
fm->new_cookie = learn->cookie;
|
2011-09-12 16:19:57 -07:00
|
|
|
fm->table_id = learn->table_id;
|
|
|
|
fm->command = OFPFC_MODIFY_STRICT;
|
|
|
|
fm->idle_timeout = ntohs(learn->idle_timeout);
|
|
|
|
fm->hard_timeout = ntohs(learn->hard_timeout);
|
|
|
|
fm->buffer_id = UINT32_MAX;
|
|
|
|
fm->out_port = OFPP_NONE;
|
|
|
|
fm->flags = ntohs(learn->flags) & OFPFF_SEND_FLOW_REM;
|
|
|
|
fm->actions = NULL;
|
|
|
|
fm->n_actions = 0;
|
|
|
|
|
|
|
|
ofpbuf_init(&actions, 64);
|
|
|
|
|
2012-02-15 10:37:03 -08:00
|
|
|
if (learn->fin_idle_timeout || learn->fin_hard_timeout) {
|
|
|
|
struct nx_action_fin_timeout *naft;
|
|
|
|
|
|
|
|
naft = ofputil_put_NXAST_FIN_TIMEOUT(&actions);
|
|
|
|
naft->fin_idle_timeout = learn->fin_idle_timeout;
|
|
|
|
naft->fin_hard_timeout = learn->fin_hard_timeout;
|
|
|
|
}
|
|
|
|
|
2011-09-12 16:19:57 -07:00
|
|
|
for (p = learn + 1, end = (char *) learn + ntohs(learn->len); p != end; ) {
|
|
|
|
uint16_t header = ntohs(get_be16(&p));
|
|
|
|
int n_bits = header & NX_LEARN_N_BITS_MASK;
|
|
|
|
int src_type = header & NX_LEARN_SRC_MASK;
|
|
|
|
int dst_type = header & NX_LEARN_DST_MASK;
|
2012-04-11 17:08:13 -07:00
|
|
|
union mf_subvalue value;
|
2011-09-12 16:19:57 -07:00
|
|
|
|
2011-12-28 12:42:14 -08:00
|
|
|
struct mf_subfield dst;
|
2012-04-11 17:08:13 -07:00
|
|
|
int chunk, ofs;
|
2011-09-12 16:19:57 -07:00
|
|
|
|
|
|
|
if (!header) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
if (src_type == NX_LEARN_SRC_FIELD) {
|
2011-12-28 12:42:14 -08:00
|
|
|
struct mf_subfield src;
|
2011-09-12 16:19:57 -07:00
|
|
|
|
2011-12-28 12:42:14 -08:00
|
|
|
get_subfield(n_bits, &p, &src);
|
2012-04-11 17:08:13 -07:00
|
|
|
mf_read_subfield(&src, flow, &value);
|
2011-09-12 16:19:57 -07:00
|
|
|
} else {
|
2012-04-11 17:08:13 -07:00
|
|
|
int p_bytes = 2 * DIV_ROUND_UP(n_bits, 16);
|
|
|
|
|
|
|
|
memset(&value, 0, sizeof value);
|
|
|
|
bitwise_copy(p, p_bytes, 0,
|
|
|
|
&value, sizeof value, 0,
|
|
|
|
n_bits);
|
|
|
|
p = (const uint8_t *) p + p_bytes;
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
switch (dst_type) {
|
|
|
|
case NX_LEARN_DST_MATCH:
|
2011-12-28 12:42:14 -08:00
|
|
|
get_subfield(n_bits, &p, &dst);
|
2012-04-11 17:08:13 -07:00
|
|
|
mf_write_subfield(&dst, &value, &fm->cr);
|
2011-09-12 16:19:57 -07:00
|
|
|
break;
|
|
|
|
|
|
|
|
case NX_LEARN_DST_LOAD:
|
2011-12-28 12:42:14 -08:00
|
|
|
get_subfield(n_bits, &p, &dst);
|
2012-04-11 17:08:13 -07:00
|
|
|
for (ofs = 0; ofs < n_bits; ofs += chunk) {
|
|
|
|
struct nx_action_reg_load *load;
|
|
|
|
|
|
|
|
chunk = MIN(n_bits - ofs, 64);
|
|
|
|
|
|
|
|
load = ofputil_put_NXAST_REG_LOAD(&actions);
|
|
|
|
load->ofs_nbits = nxm_encode_ofs_nbits(dst.ofs + ofs, chunk);
|
|
|
|
load->dst = htonl(dst.field->nxm_header);
|
|
|
|
bitwise_copy(&value, sizeof value, ofs,
|
|
|
|
&load->value, sizeof load->value, 0,
|
|
|
|
chunk);
|
|
|
|
}
|
2011-09-12 16:19:57 -07:00
|
|
|
break;
|
|
|
|
|
|
|
|
case NX_LEARN_DST_OUTPUT:
|
2012-04-11 17:08:13 -07:00
|
|
|
if (n_bits <= 16 || is_all_zeros(value.u8, sizeof value - 2)) {
|
|
|
|
ofputil_put_OFPAT10_OUTPUT(&actions)->port = value.be16[7];
|
|
|
|
}
|
2011-09-12 16:19:57 -07:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
fm->actions = ofpbuf_steal_data(&actions);
|
|
|
|
fm->n_actions = actions.size / sizeof(struct ofp_action_header);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
put_be16(struct ofpbuf *b, ovs_be16 x)
|
|
|
|
{
|
|
|
|
ofpbuf_put(b, &x, sizeof x);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
put_be32(struct ofpbuf *b, ovs_be32 x)
|
|
|
|
{
|
|
|
|
ofpbuf_put(b, &x, sizeof x);
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
put_u16(struct ofpbuf *b, uint16_t x)
|
|
|
|
{
|
|
|
|
put_be16(b, htons(x));
|
|
|
|
}
|
|
|
|
|
|
|
|
static void
|
|
|
|
put_u32(struct ofpbuf *b, uint32_t x)
|
|
|
|
{
|
|
|
|
put_be32(b, htonl(x));
|
|
|
|
}
|
|
|
|
|
|
|
|
struct learn_spec {
|
|
|
|
int n_bits;
|
|
|
|
|
|
|
|
int src_type;
|
2011-12-28 12:42:14 -08:00
|
|
|
struct mf_subfield src;
|
2012-04-13 21:24:17 -07:00
|
|
|
union mf_subvalue src_imm;
|
2011-09-12 16:19:57 -07:00
|
|
|
|
|
|
|
int dst_type;
|
2011-12-28 12:42:14 -08:00
|
|
|
struct mf_subfield dst;
|
2011-09-12 16:19:57 -07:00
|
|
|
};
|
|
|
|
|
2012-04-13 21:24:17 -07:00
|
|
|
static void
|
|
|
|
learn_parse_load_immediate(const char *s, struct learn_spec *spec)
|
|
|
|
{
|
|
|
|
const char *full_s = s;
|
|
|
|
const char *arrow = strstr(s, "->");
|
|
|
|
struct mf_subfield dst;
|
|
|
|
union mf_subvalue imm;
|
|
|
|
|
|
|
|
memset(&imm, 0, sizeof imm);
|
|
|
|
if (s[0] == '0' && (s[1] == 'x' || s[1] == 'X') && arrow) {
|
|
|
|
const char *in = arrow - 1;
|
|
|
|
uint8_t *out = imm.u8 + sizeof imm.u8 - 1;
|
|
|
|
int n = arrow - (s + 2);
|
|
|
|
int i;
|
|
|
|
|
|
|
|
for (i = 0; i < n; i++) {
|
|
|
|
int hexit = hexit_value(in[-i]);
|
|
|
|
if (hexit < 0) {
|
|
|
|
ovs_fatal(0, "%s: bad hex digit in value", full_s);
|
|
|
|
}
|
|
|
|
out[-(i / 2)] |= i % 2 ? hexit << 4 : hexit;
|
|
|
|
}
|
|
|
|
s = arrow;
|
|
|
|
} else {
|
|
|
|
imm.be64[1] = htonll(strtoull(s, (char **) &s, 0));
|
|
|
|
}
|
|
|
|
|
|
|
|
if (strncmp(s, "->", 2)) {
|
|
|
|
ovs_fatal(0, "%s: missing `->' following value", full_s);
|
|
|
|
}
|
|
|
|
s += 2;
|
|
|
|
|
|
|
|
s = mf_parse_subfield(&dst, s);
|
|
|
|
if (*s != '\0') {
|
|
|
|
ovs_fatal(0, "%s: trailing garbage following destination", full_s);
|
|
|
|
}
|
|
|
|
|
|
|
|
if (!bitwise_is_all_zeros(&imm, sizeof imm, dst.n_bits,
|
|
|
|
(8 * sizeof imm) - dst.n_bits)) {
|
|
|
|
ovs_fatal(0, "%s: value does not fit into %u bits",
|
|
|
|
full_s, dst.n_bits);
|
|
|
|
}
|
|
|
|
|
|
|
|
spec->n_bits = dst.n_bits;
|
|
|
|
spec->src_type = NX_LEARN_SRC_IMMEDIATE;
|
|
|
|
spec->src_imm = imm;
|
|
|
|
spec->dst_type = NX_LEARN_DST_LOAD;
|
|
|
|
spec->dst = dst;
|
|
|
|
}
|
|
|
|
|
2011-09-12 16:19:57 -07:00
|
|
|
static void
|
|
|
|
learn_parse_spec(const char *orig, char *name, char *value,
|
|
|
|
struct learn_spec *spec)
|
|
|
|
{
|
2011-12-28 12:42:14 -08:00
|
|
|
memset(spec, 0, sizeof *spec);
|
2011-09-12 16:19:57 -07:00
|
|
|
if (mf_from_name(name)) {
|
|
|
|
const struct mf_field *dst = mf_from_name(name);
|
|
|
|
union mf_value imm;
|
|
|
|
char *error;
|
|
|
|
|
|
|
|
error = mf_parse_value(dst, value, &imm);
|
|
|
|
if (error) {
|
|
|
|
ovs_fatal(0, "%s", error);
|
|
|
|
}
|
|
|
|
|
|
|
|
spec->n_bits = dst->n_bits;
|
|
|
|
spec->src_type = NX_LEARN_SRC_IMMEDIATE;
|
2012-04-13 21:24:17 -07:00
|
|
|
memset(&spec->src_imm, 0, sizeof spec->src_imm);
|
|
|
|
memcpy(&spec->src_imm.u8[sizeof spec->src_imm - dst->n_bytes],
|
|
|
|
&imm, dst->n_bytes);
|
2011-09-12 16:19:57 -07:00
|
|
|
spec->dst_type = NX_LEARN_DST_MATCH;
|
2011-12-28 12:42:14 -08:00
|
|
|
spec->dst.field = dst;
|
|
|
|
spec->dst.ofs = 0;
|
|
|
|
spec->dst.n_bits = dst->n_bits;
|
2011-09-12 16:19:57 -07:00
|
|
|
} else if (strchr(name, '[')) {
|
|
|
|
/* Parse destination and check prerequisites. */
|
2011-12-28 12:42:14 -08:00
|
|
|
if (mf_parse_subfield(&spec->dst, name)[0] != '\0') {
|
2011-09-12 16:19:57 -07:00
|
|
|
ovs_fatal(0, "%s: syntax error after NXM field name `%s'",
|
|
|
|
orig, name);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Parse source and check prerequisites. */
|
|
|
|
if (value[0] != '\0') {
|
2011-12-28 12:42:14 -08:00
|
|
|
if (mf_parse_subfield(&spec->src, value)[0] != '\0') {
|
2011-09-12 16:19:57 -07:00
|
|
|
ovs_fatal(0, "%s: syntax error after NXM field name `%s'",
|
|
|
|
orig, value);
|
|
|
|
}
|
2011-12-28 12:42:14 -08:00
|
|
|
if (spec->src.n_bits != spec->dst.n_bits) {
|
|
|
|
ovs_fatal(0, "%s: bit widths of %s (%u) and %s (%u) differ",
|
|
|
|
orig, name, spec->src.n_bits, value,
|
|
|
|
spec->dst.n_bits);
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
} else {
|
2011-12-28 12:42:14 -08:00
|
|
|
spec->src = spec->dst;
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
|
2011-12-28 12:42:14 -08:00
|
|
|
spec->n_bits = spec->src.n_bits;
|
2011-09-12 16:19:57 -07:00
|
|
|
spec->src_type = NX_LEARN_SRC_FIELD;
|
|
|
|
spec->dst_type = NX_LEARN_DST_MATCH;
|
|
|
|
} else if (!strcmp(name, "load")) {
|
|
|
|
if (value[strcspn(value, "[-")] == '-') {
|
2012-04-13 21:24:17 -07:00
|
|
|
learn_parse_load_immediate(value, spec);
|
2011-09-12 16:19:57 -07:00
|
|
|
} else {
|
|
|
|
struct nx_action_reg_move move;
|
|
|
|
|
|
|
|
nxm_parse_reg_move(&move, value);
|
|
|
|
|
|
|
|
spec->n_bits = ntohs(move.n_bits);
|
|
|
|
spec->src_type = NX_LEARN_SRC_FIELD;
|
2011-12-28 12:42:14 -08:00
|
|
|
nxm_decode_discrete(&spec->src,
|
|
|
|
move.src, move.src_ofs, move.n_bits);
|
2011-09-12 16:19:57 -07:00
|
|
|
spec->dst_type = NX_LEARN_DST_LOAD;
|
2011-12-28 12:42:14 -08:00
|
|
|
nxm_decode_discrete(&spec->dst,
|
|
|
|
move.dst, move.dst_ofs, move.n_bits);
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
} else if (!strcmp(name, "output")) {
|
2011-12-28 12:42:14 -08:00
|
|
|
if (mf_parse_subfield(&spec->src, value)[0] != '\0') {
|
2011-09-12 16:19:57 -07:00
|
|
|
ovs_fatal(0, "%s: syntax error after NXM field name `%s'",
|
|
|
|
orig, name);
|
|
|
|
}
|
|
|
|
|
2011-12-28 12:42:14 -08:00
|
|
|
spec->n_bits = spec->src.n_bits;
|
2011-09-12 16:19:57 -07:00
|
|
|
spec->src_type = NX_LEARN_SRC_FIELD;
|
|
|
|
spec->dst_type = NX_LEARN_DST_OUTPUT;
|
|
|
|
} else {
|
|
|
|
ovs_fatal(0, "%s: unknown keyword %s", orig, name);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2012-01-25 16:30:28 -08:00
|
|
|
/* Parses 'arg' as a set of arguments to the "learn" action and appends a
|
|
|
|
* matching NXAST_LEARN action to 'b'. The format parsed is described in
|
|
|
|
* ovs-ofctl(8).
|
|
|
|
*
|
|
|
|
* Prints an error on stderr and aborts the program if 'arg' syntax is invalid.
|
|
|
|
*
|
|
|
|
* If 'flow' is nonnull, then it should be the flow from a cls_rule that is
|
|
|
|
* the matching rule for the learning action. This helps to better validate
|
|
|
|
* the action's arguments.
|
|
|
|
*
|
|
|
|
* Modifies 'arg'. */
|
2011-09-12 16:19:57 -07:00
|
|
|
void
|
|
|
|
learn_parse(struct ofpbuf *b, char *arg, const struct flow *flow)
|
|
|
|
{
|
|
|
|
char *orig = xstrdup(arg);
|
|
|
|
char *name, *value;
|
2012-01-12 15:48:19 -08:00
|
|
|
enum ofperr error;
|
2011-09-12 16:19:57 -07:00
|
|
|
size_t learn_ofs;
|
|
|
|
size_t len;
|
|
|
|
|
|
|
|
struct nx_action_learn *learn;
|
|
|
|
struct cls_rule rule;
|
|
|
|
|
|
|
|
learn_ofs = b->size;
|
|
|
|
learn = ofputil_put_NXAST_LEARN(b);
|
|
|
|
learn->idle_timeout = htons(OFP_FLOW_PERMANENT);
|
|
|
|
learn->hard_timeout = htons(OFP_FLOW_PERMANENT);
|
|
|
|
learn->priority = htons(OFP_DEFAULT_PRIORITY);
|
|
|
|
learn->cookie = htonll(0);
|
|
|
|
learn->flags = htons(0);
|
|
|
|
learn->table_id = 1;
|
|
|
|
|
|
|
|
cls_rule_init_catchall(&rule, 0);
|
|
|
|
while (ofputil_parse_key_value(&arg, &name, &value)) {
|
|
|
|
learn = ofpbuf_at_assert(b, learn_ofs, sizeof *learn);
|
|
|
|
if (!strcmp(name, "table")) {
|
|
|
|
learn->table_id = atoi(value);
|
|
|
|
if (learn->table_id == 255) {
|
|
|
|
ovs_fatal(0, "%s: table id 255 not valid for `learn' action",
|
|
|
|
orig);
|
|
|
|
}
|
|
|
|
} else if (!strcmp(name, "priority")) {
|
|
|
|
learn->priority = htons(atoi(value));
|
|
|
|
} else if (!strcmp(name, "idle_timeout")) {
|
|
|
|
learn->idle_timeout = htons(atoi(value));
|
|
|
|
} else if (!strcmp(name, "hard_timeout")) {
|
|
|
|
learn->hard_timeout = htons(atoi(value));
|
2012-02-15 10:37:03 -08:00
|
|
|
} else if (!strcmp(name, "fin_idle_timeout")) {
|
|
|
|
learn->fin_idle_timeout = htons(atoi(value));
|
|
|
|
} else if (!strcmp(name, "fin_hard_timeout")) {
|
|
|
|
learn->fin_hard_timeout = htons(atoi(value));
|
2011-09-12 16:19:57 -07:00
|
|
|
} else if (!strcmp(name, "cookie")) {
|
|
|
|
learn->cookie = htonll(strtoull(value, NULL, 0));
|
|
|
|
} else {
|
|
|
|
struct learn_spec spec;
|
|
|
|
|
|
|
|
learn_parse_spec(orig, name, value, &spec);
|
|
|
|
|
|
|
|
/* Check prerequisites. */
|
|
|
|
if (spec.src_type == NX_LEARN_SRC_FIELD
|
2012-01-25 16:30:28 -08:00
|
|
|
&& flow && !mf_are_prereqs_ok(spec.src.field, flow)) {
|
2011-09-12 16:19:57 -07:00
|
|
|
ovs_fatal(0, "%s: cannot specify source field %s because "
|
|
|
|
"prerequisites are not satisfied",
|
2011-12-28 12:42:14 -08:00
|
|
|
orig, spec.src.field->name);
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
if ((spec.dst_type == NX_LEARN_DST_MATCH
|
|
|
|
|| spec.dst_type == NX_LEARN_DST_LOAD)
|
2011-12-28 12:42:14 -08:00
|
|
|
&& !mf_are_prereqs_ok(spec.dst.field, &rule.flow)) {
|
2011-09-12 16:19:57 -07:00
|
|
|
ovs_fatal(0, "%s: cannot specify destination field %s because "
|
|
|
|
"prerequisites are not satisfied",
|
2011-12-28 12:42:14 -08:00
|
|
|
orig, spec.dst.field->name);
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
/* Update 'rule' to allow for satisfying destination
|
|
|
|
* prerequisites. */
|
|
|
|
if (spec.src_type == NX_LEARN_SRC_IMMEDIATE
|
2012-04-13 21:24:17 -07:00
|
|
|
&& spec.dst_type == NX_LEARN_DST_MATCH) {
|
|
|
|
mf_write_subfield(&spec.dst, &spec.src_imm, &rule);
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
/* Output the flow_mod_spec. */
|
|
|
|
put_u16(b, spec.n_bits | spec.src_type | spec.dst_type);
|
|
|
|
if (spec.src_type == NX_LEARN_SRC_IMMEDIATE) {
|
2012-04-13 21:24:17 -07:00
|
|
|
int n_bytes = DIV_ROUND_UP(spec.n_bits, 16) * 2;
|
|
|
|
int ofs = sizeof spec.src_imm - n_bytes;
|
|
|
|
ofpbuf_put(b, &spec.src_imm.u8[ofs], n_bytes);
|
2011-09-12 16:19:57 -07:00
|
|
|
} else {
|
2011-12-28 12:42:14 -08:00
|
|
|
put_u32(b, spec.src.field->nxm_header);
|
|
|
|
put_u16(b, spec.src.ofs);
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
if (spec.dst_type == NX_LEARN_DST_MATCH ||
|
|
|
|
spec.dst_type == NX_LEARN_DST_LOAD) {
|
2011-12-28 12:42:14 -08:00
|
|
|
put_u32(b, spec.dst.field->nxm_header);
|
|
|
|
put_u16(b, spec.dst.ofs);
|
2011-09-12 16:19:57 -07:00
|
|
|
} else {
|
|
|
|
assert(spec.dst_type == NX_LEARN_DST_OUTPUT);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
put_u16(b, 0);
|
|
|
|
|
|
|
|
len = b->size - learn_ofs;
|
|
|
|
if (len % 8) {
|
|
|
|
ofpbuf_put_zeros(b, 8 - len % 8);
|
|
|
|
}
|
|
|
|
|
|
|
|
learn = ofpbuf_at_assert(b, learn_ofs, sizeof *learn);
|
|
|
|
learn->len = htons(b->size - learn_ofs);
|
2011-09-27 13:12:04 -07:00
|
|
|
|
|
|
|
/* In theory the above should have caught any errors, but... */
|
2012-01-25 16:30:28 -08:00
|
|
|
if (flow) {
|
|
|
|
error = learn_check(learn, flow);
|
|
|
|
if (error) {
|
|
|
|
ovs_fatal(0, "%s: %s", orig, ofperr_to_string(error));
|
|
|
|
}
|
2011-09-27 13:12:04 -07:00
|
|
|
}
|
|
|
|
free(orig);
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
void
|
|
|
|
learn_format(const struct nx_action_learn *learn, struct ds *s)
|
|
|
|
{
|
|
|
|
struct cls_rule rule;
|
|
|
|
const void *p, *end;
|
|
|
|
|
|
|
|
cls_rule_init_catchall(&rule, 0);
|
|
|
|
|
|
|
|
ds_put_format(s, "learn(table=%"PRIu8, learn->table_id);
|
|
|
|
if (learn->idle_timeout != htons(OFP_FLOW_PERMANENT)) {
|
|
|
|
ds_put_format(s, ",idle_timeout=%"PRIu16, ntohs(learn->idle_timeout));
|
|
|
|
}
|
|
|
|
if (learn->hard_timeout != htons(OFP_FLOW_PERMANENT)) {
|
|
|
|
ds_put_format(s, ",hard_timeout=%"PRIu16, ntohs(learn->hard_timeout));
|
|
|
|
}
|
2012-02-15 10:37:03 -08:00
|
|
|
if (learn->fin_idle_timeout) {
|
|
|
|
ds_put_format(s, ",fin_idle_timeout=%"PRIu16,
|
|
|
|
ntohs(learn->fin_idle_timeout));
|
|
|
|
}
|
|
|
|
if (learn->fin_hard_timeout) {
|
|
|
|
ds_put_format(s, ",fin_hard_timeout=%"PRIu16,
|
|
|
|
ntohs(learn->fin_hard_timeout));
|
|
|
|
}
|
2011-09-12 16:19:57 -07:00
|
|
|
if (learn->priority != htons(OFP_DEFAULT_PRIORITY)) {
|
|
|
|
ds_put_format(s, ",priority=%"PRIu16, ntohs(learn->priority));
|
|
|
|
}
|
|
|
|
if (learn->flags & htons(OFPFF_SEND_FLOW_REM)) {
|
|
|
|
ds_put_cstr(s, ",OFPFF_SEND_FLOW_REM");
|
|
|
|
}
|
|
|
|
if (learn->flags & htons(~OFPFF_SEND_FLOW_REM)) {
|
|
|
|
ds_put_format(s, ",***flags=%"PRIu16"***",
|
|
|
|
ntohs(learn->flags) & ~OFPFF_SEND_FLOW_REM);
|
|
|
|
}
|
|
|
|
if (learn->cookie != htonll(0)) {
|
|
|
|
ds_put_format(s, ",cookie=0x%"PRIx64, ntohll(learn->cookie));
|
|
|
|
}
|
2012-02-15 10:37:03 -08:00
|
|
|
if (learn->pad != 0) {
|
2011-09-12 16:19:57 -07:00
|
|
|
ds_put_cstr(s, ",***nonzero pad***");
|
|
|
|
}
|
|
|
|
|
|
|
|
end = (char *) learn + ntohs(learn->len);
|
|
|
|
for (p = learn + 1; p != end; ) {
|
|
|
|
uint16_t header = ntohs(get_be16(&p));
|
|
|
|
int n_bits = header & NX_LEARN_N_BITS_MASK;
|
|
|
|
|
|
|
|
int src_type = header & NX_LEARN_SRC_MASK;
|
2011-12-28 12:42:14 -08:00
|
|
|
struct mf_subfield src;
|
2011-09-12 16:19:57 -07:00
|
|
|
const uint8_t *src_value;
|
|
|
|
int src_value_bytes;
|
|
|
|
|
|
|
|
int dst_type = header & NX_LEARN_DST_MASK;
|
2011-12-28 12:42:14 -08:00
|
|
|
struct mf_subfield dst;
|
2011-09-12 16:19:57 -07:00
|
|
|
|
2012-01-12 15:48:19 -08:00
|
|
|
enum ofperr error;
|
2011-09-12 16:19:57 -07:00
|
|
|
int i;
|
|
|
|
|
|
|
|
if (!header) {
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
|
|
|
|
error = learn_check_header(header, (char *) end - (char *) p);
|
2012-01-12 15:48:19 -08:00
|
|
|
if (error == OFPERR_OFPBAC_BAD_ARGUMENT) {
|
2011-09-12 16:19:57 -07:00
|
|
|
ds_put_format(s, ",***bad flow_mod_spec header %"PRIx16"***)",
|
|
|
|
header);
|
|
|
|
return;
|
2012-01-12 15:48:19 -08:00
|
|
|
} else if (error == OFPERR_OFPBAC_BAD_LEN) {
|
2011-09-12 16:19:57 -07:00
|
|
|
ds_put_format(s, ",***flow_mod_spec at offset %td is %u bytes "
|
|
|
|
"long but only %td bytes are left***)",
|
|
|
|
(char *) p - (char *) (learn + 1) - 2,
|
|
|
|
learn_min_len(header) + 2,
|
|
|
|
(char *) end - (char *) p + 2);
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
assert(!error);
|
|
|
|
|
|
|
|
/* Get the source. */
|
|
|
|
if (src_type == NX_LEARN_SRC_FIELD) {
|
2011-12-28 12:42:14 -08:00
|
|
|
get_subfield(n_bits, &p, &src);
|
2011-09-12 16:19:57 -07:00
|
|
|
src_value_bytes = 0;
|
|
|
|
src_value = NULL;
|
|
|
|
} else {
|
2011-12-28 12:42:14 -08:00
|
|
|
src.field = NULL;
|
|
|
|
src.ofs = 0;
|
|
|
|
src.n_bits = 0;
|
2011-09-12 16:19:57 -07:00
|
|
|
src_value_bytes = 2 * DIV_ROUND_UP(n_bits, 16);
|
|
|
|
src_value = p;
|
|
|
|
p = (const void *) ((const uint8_t *) p + src_value_bytes);
|
|
|
|
}
|
|
|
|
|
|
|
|
/* Get the destination. */
|
|
|
|
if (dst_type == NX_LEARN_DST_MATCH || dst_type == NX_LEARN_DST_LOAD) {
|
2011-12-28 12:42:14 -08:00
|
|
|
get_subfield(n_bits, &p, &dst);
|
2011-09-12 16:19:57 -07:00
|
|
|
} else {
|
2011-12-28 12:42:14 -08:00
|
|
|
dst.field = NULL;
|
|
|
|
dst.ofs = 0;
|
|
|
|
dst.n_bits = 0;
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
ds_put_char(s, ',');
|
|
|
|
|
|
|
|
switch (src_type | dst_type) {
|
|
|
|
case NX_LEARN_SRC_IMMEDIATE | NX_LEARN_DST_MATCH:
|
2011-12-28 12:42:14 -08:00
|
|
|
if (dst.field && dst.ofs == 0 && n_bits == dst.field->n_bits) {
|
2011-09-12 16:19:57 -07:00
|
|
|
union mf_value value;
|
|
|
|
uint8_t *bytes = (uint8_t *) &value;
|
|
|
|
|
2011-12-28 12:42:14 -08:00
|
|
|
if (src_value_bytes > dst.field->n_bytes) {
|
2011-12-01 08:33:55 -08:00
|
|
|
/* The destination field is an odd number of bytes, which
|
|
|
|
* got rounded up to a multiple of 2 to be put into the
|
|
|
|
* learning action. Skip over the leading byte, which
|
|
|
|
* should be zero anyway. Otherwise the memcpy() below
|
|
|
|
* will overrun the start of 'value'. */
|
2011-12-28 12:42:14 -08:00
|
|
|
int diff = src_value_bytes - dst.field->n_bytes;
|
2011-12-01 08:33:55 -08:00
|
|
|
src_value += diff;
|
|
|
|
src_value_bytes -= diff;
|
|
|
|
}
|
|
|
|
|
2011-09-12 16:19:57 -07:00
|
|
|
memset(&value, 0, sizeof value);
|
2011-12-28 12:42:14 -08:00
|
|
|
memcpy(&bytes[dst.field->n_bytes - src_value_bytes],
|
2011-09-12 16:19:57 -07:00
|
|
|
src_value, src_value_bytes);
|
2011-12-28 12:42:14 -08:00
|
|
|
ds_put_format(s, "%s=", dst.field->name);
|
|
|
|
mf_format(dst.field, &value, NULL, s);
|
2011-09-12 16:19:57 -07:00
|
|
|
} else {
|
2011-12-28 12:42:14 -08:00
|
|
|
mf_format_subfield(&dst, s);
|
2011-09-12 16:19:57 -07:00
|
|
|
ds_put_cstr(s, "=0x");
|
|
|
|
for (i = 0; i < src_value_bytes; i++) {
|
|
|
|
ds_put_format(s, "%02"PRIx8, src_value[i]);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
break;
|
|
|
|
|
|
|
|
case NX_LEARN_SRC_FIELD | NX_LEARN_DST_MATCH:
|
2011-12-28 12:42:14 -08:00
|
|
|
mf_format_subfield(&dst, s);
|
|
|
|
if (src.field != dst.field || src.ofs != dst.ofs) {
|
2011-09-12 16:19:57 -07:00
|
|
|
ds_put_char(s, '=');
|
2011-12-28 12:42:14 -08:00
|
|
|
mf_format_subfield(&src, s);
|
2011-09-12 16:19:57 -07:00
|
|
|
}
|
|
|
|
break;
|
|
|
|
|
|
|
|
case NX_LEARN_SRC_IMMEDIATE | NX_LEARN_DST_LOAD:
|
|
|
|
ds_put_cstr(s, "load:0x");
|
|
|
|
for (i = 0; i < src_value_bytes; i++) {
|
|
|
|
ds_put_format(s, "%02"PRIx8, src_value[i]);
|
|
|
|
}
|
|
|
|
ds_put_cstr(s, "->");
|
2011-12-28 12:42:14 -08:00
|
|
|
mf_format_subfield(&dst, s);
|
2011-09-12 16:19:57 -07:00
|
|
|
break;
|
|
|
|
|
|
|
|
case NX_LEARN_SRC_FIELD | NX_LEARN_DST_LOAD:
|
|
|
|
ds_put_cstr(s, "load:");
|
2011-12-28 12:42:14 -08:00
|
|
|
mf_format_subfield(&src, s);
|
2011-09-12 16:19:57 -07:00
|
|
|
ds_put_cstr(s, "->");
|
2011-12-28 12:42:14 -08:00
|
|
|
mf_format_subfield(&dst, s);
|
2011-09-12 16:19:57 -07:00
|
|
|
break;
|
|
|
|
|
|
|
|
case NX_LEARN_SRC_FIELD | NX_LEARN_DST_OUTPUT:
|
|
|
|
ds_put_cstr(s, "output:");
|
2011-12-28 12:42:14 -08:00
|
|
|
mf_format_subfield(&src, s);
|
2011-09-12 16:19:57 -07:00
|
|
|
break;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
if (!is_all_zeros(p, (char *) end - (char *) p)) {
|
|
|
|
ds_put_cstr(s, ",***nonzero trailer***");
|
|
|
|
}
|
|
|
|
ds_put_char(s, ')');
|
|
|
|
}
|