X-Git-Url: http://git.cascardo.eti.br/?a=blobdiff_plain;f=ofproto%2Fbond.h;h=9a5ea9e21040aa46ceb2f6646df3554bc28418ca;hb=730b985b03f79b5bd9c46edb8f1dc77a7db92547;hp=5b3814e85a86c5a8bce7d17066b5fc0b3195b6c6;hpb=9a54394ac99e955cf23d8b45cc75ae08316a50f8;p=cascardo%2Fovs.git diff --git a/ofproto/bond.h b/ofproto/bond.h index 5b3814e85..9a5ea9e21 100644 --- a/ofproto/bond.h +++ b/ofproto/bond.h @@ -1,5 +1,5 @@ /* - * Copyright (c) 2008, 2009, 2010, 2011 Nicira, Inc. + * Copyright (c) 2008, 2009, 2010, 2011, 2014 Nicira, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -19,12 +19,13 @@ #include #include - +#include "ofproto-provider.h" #include "packets.h" struct flow; struct netdev; struct ofpbuf; +struct ofproto_dpif; enum lacp_status; /* How flows are balanced among bond slaves. */ @@ -51,21 +52,25 @@ struct bond_settings { int up_delay; /* ms before enabling an up slave. */ int down_delay; /* ms before disabling a down slave. */ - /* Legacy compatibility. */ - bool fake_iface; /* Update fake stats for netdev 'name'? */ bool lacp_fallback_ab_cfg; /* Fallback to active-backup on LACP failure. */ + + struct eth_addr active_slave_mac; + /* The MAC address of the interface + that was active during the last + ovs run. */ }; /* Program startup. */ void bond_init(void); /* Basics. */ -struct bond *bond_create(const struct bond_settings *); +struct bond *bond_create(const struct bond_settings *, + struct ofproto_dpif *ofproto); void bond_unref(struct bond *); struct bond *bond_ref(const struct bond *); bool bond_reconfigure(struct bond *, const struct bond_settings *); -void bond_slave_register(struct bond *, void *slave_, struct netdev *); +void bond_slave_register(struct bond *, void *slave_, ofp_port_t ofport, struct netdev *); void bond_slave_set_netdev(struct bond *, void *slave_, struct netdev *); void bond_slave_unregister(struct bond *, const void *slave); @@ -76,9 +81,11 @@ void bond_slave_set_may_enable(struct bond *, void *slave_, bool may_enable); /* Special MAC learning support for SLB bonding. */ bool bond_should_send_learning_packets(struct bond *); -struct ofpbuf *bond_compose_learning_packet(struct bond *, - const uint8_t eth_src[ETH_ADDR_LEN], - uint16_t vlan, void **port_aux); +struct dp_packet *bond_compose_learning_packet(struct bond *, + const struct eth_addr eth_src, + uint16_t vlan, void **port_aux); +bool bond_get_changed_active_slave(const char *name, struct eth_addr *mac, + bool force); /* Packet processing. */ enum bond_verdict { @@ -87,7 +94,7 @@ enum bond_verdict { BV_DROP_IF_MOVED /* Drop if we've learned a different port. */ }; enum bond_verdict bond_check_admissibility(struct bond *, const void *slave_, - const uint8_t dst[ETH_ADDR_LEN]); + const struct eth_addr dst); void *bond_choose_output_slave(struct bond *, const struct flow *, struct flow_wildcards *, uint16_t vlan); @@ -96,4 +103,24 @@ void bond_account(struct bond *, const struct flow *, uint16_t vlan, uint64_t n_bytes); void bond_rebalance(struct bond *); +/* Recirculation + * + * Only balance_tcp mode uses recirculation. + * + * When recirculation is used, each bond port is assigned with a unique + * recirc_id. The output action to the bond port will be replaced by + * a Hash action, followed by a RECIRC action. + * + * ... actions= ... HASH(hash(L4)), RECIRC(recirc_id) .... + * + * On handling first output packet, 256 post recirculation flows are installed: + * + * recirc_id=, dp_hash=<[0..255]>/0xff, actions: output + * + * Bond module pulls stats from those post recirculation rules. If rebalancing + * is needed, those rules are updated with new output actions. +*/ +void bond_update_post_recirc_rules(struct bond *, const bool force); +bool bond_may_recirc(const struct bond *, uint32_t *recirc_id, + uint32_t *hash_bias); #endif /* bond.h */