X-Git-Url: http://git.cascardo.info/?a=blobdiff_plain;f=ofproto%2Fofproto-dpif-rid.h;h=c34d76022ea534d17280096577aba2aead2fac8e;hb=refs%2Fheads%2Frtnetlink;hp=ba968ba93d4bdd2e2f44314db6fd464c663e6d7a;hpb=417509faf2dff3be26f2ab4c9dd45809ec32e5dc;p=cascardo%2Fovs.git diff --git a/ofproto/ofproto-dpif-rid.h b/ofproto/ofproto-dpif-rid.h index ba968ba93..c34d76022 100644 --- a/ofproto/ofproto-dpif-rid.h +++ b/ofproto/ofproto-dpif-rid.h @@ -1,5 +1,5 @@ /* - * Copyright (c) 2014, 2015 Nicira, Inc. + * Copyright (c) 2014, 2015, 2016 Nicira, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -21,22 +21,28 @@ #include #include "cmap.h" -#include "list.h" -#include "ofp-actions.h" #include "ofproto-dpif-mirror.h" +#include "openvswitch/list.h" +#include "openvswitch/ofp-actions.h" #include "ovs-thread.h" +#include "uuid.h" struct ofproto_dpif; struct rule; /* - * Recirculation - * ============= + * Freezing and recirculation + * ========================== + * + * Freezing is a technique for halting and checkpointing packet translation in + * a way that it can be restarted again later. This file has a couple of data + * structures related to freezing in general; their names begin with "frozen". + * + * Recirculation is the use of freezing to allow a frame to re-enter the + * datapath packet processing path to achieve more flexible packet processing, + * such as modifying header fields after MPLS POP action and selecting a slave + * port for bond ports. * - * Recirculation is a technique to allow a frame to re-enter the datapath - * packet processing path to achieve more flexible packet processing, such as - * modifying header fields after MPLS POP action and selecting a slave port for - * bond ports. * * Data path and user space interface * ----------------------------------- @@ -95,17 +101,16 @@ struct rule; * updates. */ BUILD_ASSERT_DECL(FLOW_WC_SEQ == 35); -struct recirc_metadata { +struct frozen_metadata { /* Metadata in struct flow. */ const struct flow_tnl *tunnel; /* Encapsulating tunnel parameters. */ ovs_be64 metadata; /* OpenFlow Metadata. */ uint64_t regs[FLOW_N_XREGS]; /* Registers. */ ofp_port_t in_port; /* Incoming port. */ - ofp_port_t actset_output; /* Output port in action set. */ }; static inline void -recirc_metadata_from_flow(struct recirc_metadata *md, +frozen_metadata_from_flow(struct frozen_metadata *md, const struct flow *flow) { memset(md, 0, sizeof *md); @@ -113,11 +118,10 @@ recirc_metadata_from_flow(struct recirc_metadata *md, md->metadata = flow->metadata; memcpy(md->regs, flow->regs, sizeof md->regs); md->in_port = flow->in_port.ofp_port; - md->actset_output = flow->actset_output; } static inline void -recirc_metadata_to_flow(const struct recirc_metadata *md, +frozen_metadata_to_flow(const struct frozen_metadata *md, struct flow *flow) { if (md->tunnel && flow_tnl_dst_is_set(md->tunnel)) { @@ -128,24 +132,23 @@ recirc_metadata_to_flow(const struct recirc_metadata *md, flow->metadata = md->metadata; memcpy(flow->regs, md->regs, sizeof flow->regs); flow->in_port.ofp_port = md->in_port; - flow->actset_output = md->actset_output; } -/* State that flow translation can save, to restore when recirculation - * occurs. */ -struct recirc_state { - /* Initial table for post-recirculation processing. */ +/* State that flow translation can save, to restore when translation + * resumes. */ +struct frozen_state { + /* Initial table for processing when thawing. */ uint8_t table_id; - /* Pipeline context for post-recirculation processing. */ - struct ofproto_dpif *ofproto; /* Post-recirculation bridge. */ - struct recirc_metadata metadata; /* Flow metadata. */ + /* Pipeline context for processing when thawing. */ + struct uuid ofproto_uuid; /* Bridge to resume from. */ + struct frozen_metadata metadata; /* Flow metadata. */ union mf_subvalue *stack; /* Stack if any. */ size_t n_stack; mirror_mask_t mirrors; /* Mirrors already output. */ - bool conntracked; /* Conntrack occurred prior to recirc. */ + bool conntracked; /* Conntrack occurred prior to freeze. */ - /* Actions to be translated on recirculation. */ + /* Actions to be translated when thawing. */ struct ofpact *ofpacts; size_t ofpacts_len; /* Size of 'ofpacts', in bytes. */ struct ofpact *action_set; @@ -167,25 +170,29 @@ struct recirc_id_node { * * This state should not be modified after inserting a node in the pool, * hence the 'const' to emphasize that. */ - const struct recirc_state state; + const struct frozen_state state; /* Storage for tunnel metadata. */ struct flow_tnl state_metadata_tunnel; }; -void recirc_init(void); - /* This is only used for bonds and will go away when bonds implementation is * updated to use this mechanism instead of internal rules. */ uint32_t recirc_alloc_id(struct ofproto_dpif *); -uint32_t recirc_alloc_id_ctx(const struct recirc_state *); -uint32_t recirc_find_id(const struct recirc_state *); +uint32_t recirc_alloc_id_ctx(const struct frozen_state *); +uint32_t recirc_find_id(const struct frozen_state *); void recirc_free_id(uint32_t recirc_id); void recirc_free_ofproto(struct ofproto_dpif *, const char *ofproto_name); const struct recirc_id_node *recirc_id_node_find(uint32_t recirc_id); +static inline struct recirc_id_node * +recirc_id_node_from_state(const struct frozen_state *state) +{ + return CONTAINER_OF(state, struct recirc_id_node, state); +} + static inline bool recirc_id_node_try_ref_rcu(const struct recirc_id_node *n_) { struct recirc_id_node *node = CONST_CAST(struct recirc_id_node *, n_);