TCCS实现之修改ryu和ovs源码实现自定义action

enum ofp_raw_action_type {
	/* ... */

	/* NX1.3+(47): struct nx_action_decap, ... */
	NXAST_RAW_DECAP,

+	/* OF1.0+(30): uint16_t. */
+    OFPAT_RAW_SET_RWND,

	/* ... */
}

#define OFPACTS
	/* ... */
    OFPACT(GOTO_TABLE,      ofpact_goto_table,  ofpact, "goto_table") \
+    OFPACT(SET_RWND,        ofpact_set_rwnd,    ofpact, "set_rwnd")

/* ..., after "struct ofpact_decap { ... }" */

struct ofpact_set_rwnd {
    OFPACT_PADDED_MEMBERS(
        struct ofpact ofpact;
        /* 注意，这里不能使用 char 数组或指针作为变量 */
        uint16_t rwnd;
    );
    // uint8_t data[];
};

/* Returns the ofpact following 'ofpact', except that if 'ofpact' contains
 * nested ofpacts it returns the first one. */
struct ofpact *
ofpact_next_flattened(const struct ofpact *ofpact)
{
	switch (ofpact->type) {
		/* ... */
+		case OFPACT_SET_RWND:
			return ofpact_next(ofpact);
	}
	/* ... */
}

/* ... */

enum ovs_instruction_type
ovs_instruction_type_from_ofpact_type(enum ofpact_type type,
                                      enum ofp_version version)
{
	switch (type) {
	/* ... */
+	case OFPACT_SET_RWND:
	default:
		return OVSINST_OFPIT11_APPLY_ACTIONS;
	/* ... */
	}
}

/* ... */

/* Returns true if 'action' outputs to 'port', false otherwise. */
static bool
ofpact_outputs_to_port(const struct ofpact *ofpact, ofp_port_t port)
{
	switch (ofpact->type) {
	/* ... */
+	case OFPACT_SET_RWND:
	default:
		return false;
	}
}

/* The order in which actions in an action set get executed.  This is only for
 * the actions where only the last instance added is used. */
#define ACTION_SET_ORDER                        \
		/* ... */
    SLOT(OFPACT_DEC_NSH_TTL)					\
+    SLOT(OFPACT_SET_RWND)  

static const struct ofpact_map *
get_ofpact_map(enum ofp_version version)
{
    /* OpenFlow 1.0 actions. */
    static const struct ofpact_map of10[] = {
		/* ... */
+        { OFPACT_SET_RWND, 30},
        { 0, -1 },
    };
	
    /* OpenFlow 1.1 actions. */
    static const struct ofpact_map of11[] = {
		/* ... */
+        { OFPACT_SET_RWND, 30},
        { 0, -1 },
    };
    
    /* OpenFlow 1.2, 1.3, and 1.4 actions. */
    static const struct ofpact_map of12[] = {
		/* ... */
+        { OFPACT_SET_RWND, 30},
        { 0, -1 },
    };
	/* ... */
}

/* Set-RWND instruction. */
static void
encode_SET_RWND(const struct ofpact_set_rwnd *setRwnd,
            enum ofp_version ofp_version OVS_UNUSED,
            struct ofpbuf *out)
{
    put_OFPAT_SET_RWND(out, setRwnd->rwnd);
}

static enum ofperr
decode_OFPAT_RAW_SET_RWND(uint16_t rwnd,
                        enum ofp_version ofp_version OVS_UNUSED,
                        struct ofpbuf *out)
{
    ofpact_put_SET_RWND(out)->rwnd = rwnd;
    return 0;
}

static char * OVS_WARN_UNUSED_RESULT
parse_SET_RWND(char *arg, const struct ofpact_parse_params *pp)
{
    uint16_t rwnd;
    char *error;
    struct ofpact_set_rwnd *setRwnd;

    error = str_to_u16(arg, "cwnnd", &rwnd);
    if (error) return error;

    setRwnd = ofpact_put_SET_RWND(pp->ofpacts);
    setRwnd->rwnd = rwnd;

    return NULL;
}


static void
format_SET_RWND(const struct ofpact_set_rwnd *a,
                const struct ofpact_format_params *fp)
{
    /* Feel free to use e.g. colors.param,
    colors.end around parameter names */
    ds_put_format(fp->s, "%sset_rwnd:%"PRIu32"%s", colors.param, a->rwnd, colors.end);
}

static enum ofperr
check_SET_RWND(const struct ofpact_set_rwnd *a OVS_UNUSED,
                const struct ofpact_check_params *cp OVS_UNUSED)
{
    /* My method needs no checking. Probably. */
    return 0;
}

/* Determine if an datapath action translated from the openflow action
 * can be reversed by another datapath action.
 *
 * Openflow actions that do not emit datapath actions are trivially
 * reversible. Reversiblity of other actions depends on nature of
 * action and their translation.  */
static bool
reversible_actions(const struct ofpact *ofpacts, size_t ofpacts_len)
{
	const struct ofpact *a;

	OFPACT_FOR_EACH (a, ofpacts, ofpacts_len) {
		switch (a->type) {
		/*... */
+		case OFPACT_SET_RWND:
			return false;
		}
	}
	return true;
}

/* ... */

/* Copy actions 'a' through 'end' to ctx->frozen_actions, which will be
 * executed after thawing.  Inserts an UNROLL_XLATE action, if none is already
 * present, before any action that may depend on the current table ID or flow
 * cookie. */
static void
freeze_unroll_actions(const struct ofpact *a, const struct ofpact *end,
                      struct xlate_ctx *ctx)
{
	/* ... */
	switch (a->type) {
+		case OFPACT_SET_RWND:
			/* These may not generate PACKET INs. */
			break;
	}
}

/* ... */

static void
recirc_for_mpls(const struct ofpact *a, struct xlate_ctx *ctx)
{
	/* ... */
	switch (a->type) {
+	case OFPACT_SET_RWND:
	default:
		break;
	}
}

//datapath/flow.h
struct sw_flow_key {
    struct {
		__be16 src;		/* TCP/UDP/SCTP source port. */
		__be16 dst;		/* TCP/UDP/SCTP destination port. */
		__be16 flags;		/* TCP flags. */
+		__be16 window;		/* TCP rwnd size. */
	} tp;
}

//datapath/flow.c
static int key_extract_l3l4(struct sk_buff *skb, struct sw_flow_key *key)
{	
    /*....*/
	/* Transport layer. */
		if (key->ip.proto == IPPROTO_TCP) {
			if (tcphdr_ok(skb)) {
				struct tcphdr *tcp = tcp_hdr(skb);
				key->tp.src = tcp->source;
				key->tp.dst = tcp->dest;
				key->tp.flags = TCP_FLAGS_BE16(tcp);
+				key->tp.window = tcp->window;
			} /*....*/
}