cfibtable.h

/*
 * cfibtable.h
 *
 *  Created on: 15.07.2013
 *      Author: andreas
 */

#ifndef CFIB_H_
#define CFIB_H_ 1

#include <map>
#include <ostream>
#include <exception>
#include <inttypes.h>

#include <rofl/common/crofbase.h>
#include <rofl/common/crofdpt.h>
#include <rofl/common/caddress.h>

#include "cfibentry.h"

namespace rofl {
namespace examples {
namespace ethswctld {

class cfibtable : public cfibentry_env {
public:

        static
        cfibtable&
        add_fib(
                        const rofl::cdptid& dptid) {
                if (cfibtable::fibtables.find(dptid) != cfibtable::fibtables.end()) {
                        delete cfibtable::fibtables[dptid];
                        cfibtable::fibtables.erase(dptid);
                }
                new cfibtable(dptid);
                return *(cfibtable::fibtables[dptid]);
        };

        static
        cfibtable&
        set_fib(
                        const rofl::cdptid& dptid) {
                if (cfibtable::fibtables.find(dptid) == cfibtable::fibtables.end()) {
                        new cfibtable(dptid);
                }
                return *(cfibtable::fibtables[dptid]);
        };

        static
        const cfibtable&
        get_fib(
                        const rofl::cdptid& dptid) {
                if (cfibtable::fibtables.find(dptid) == cfibtable::fibtables.end()) {
                        throw exceptions::eFibNotFound("cfibtable::get_fib() dptid not found");
                }
                return *(cfibtable::fibtables.at(dptid));
        };

        static
        void
        drop_fib(
                        const rofl::cdptid& dptid) {
                if (cfibtable::fibtables.find(dptid) == cfibtable::fibtables.end()) {
                        return;
                }
                delete cfibtable::fibtables[dptid];
                cfibtable::fibtables.erase(dptid);
        };

        static
        bool
        has_fib(
                        const rofl::cdptid& dptid) {
                return (not (cfibtable::fibtables.find(dptid) == cfibtable::fibtables.end()));
        };

public:

        void
        clear() {
                for (std::map<rofl::caddress_ll, cfibentry*>::iterator
                                it = ftable.begin(); it != ftable.end(); ++it) {
                        delete it->second;
                }
                ftable.clear();
        };

        cfibentry&
        add_fib_entry(
                        const rofl::caddress_ll& hwaddr,
                        uint32_t portno) {
                if (hwaddr.is_multicast() || hwaddr.is_null()) {
                        throw exceptions::eFibInval("cfibtable::add_fib_entry() hwaddr validation failed");
                }
                if (ftable.find(hwaddr) != ftable.end()) {
                        drop_fib_entry(hwaddr);
                }
                ftable[hwaddr] = new cfibentry(this, dptid, hwaddr, portno);
                return *(ftable[hwaddr]);
        };

        cfibentry&
        set_fib_entry(
                        const rofl::caddress_ll& hwaddr,
                        uint32_t portno) {
                if (hwaddr.is_multicast() || hwaddr.is_null()) {
                        throw exceptions::eFibInval("cfibtable::set_fib_entry() hwaddr validation failed");
                }
                if (ftable.find(hwaddr) == ftable.end()) {
                        ftable[hwaddr] = new cfibentry(this, dptid, hwaddr, portno);
                }
                return *(ftable[hwaddr]);
        };

        cfibentry&
        set_fib_entry(
                        const rofl::caddress_ll& hwaddr) {
                if (hwaddr.is_multicast() || hwaddr.is_null()) {
                        throw exceptions::eFibInval("cfibtable::set_fib_entry() hwaddr validation failed");
                }
                if (ftable.find(hwaddr) == ftable.end()) {
                        throw exceptions::eFibNotFound("cfibtable::set_fib_entry() hwaddr not found");
                }
                return *(ftable[hwaddr]);
        };

        const cfibentry&
        get_fib_entry(
                        const rofl::caddress_ll& hwaddr) const {
                if (hwaddr.is_multicast() || hwaddr.is_null()) {
                        throw exceptions::eFibInval("cfibtable::get_fib_entry() hwaddr validation failed");
                }
                if (ftable.find(hwaddr) == ftable.end()) {
                        throw exceptions::eFibNotFound("cfibtable::set_fib_entry() hwaddr not found");
                }
                return *(ftable.at(hwaddr));
        };

        void
        drop_fib_entry(
                        const rofl::caddress_ll& hwaddr) {
                if (ftable.find(hwaddr) == ftable.end()) {
                        return;
                }
                cfibentry* fibentry = ftable[hwaddr];
                ftable.erase(hwaddr);
                delete fibentry;
        };

        bool
        has_fib_entry(
                        const rofl::caddress_ll& hwaddr) const {
                return (not (ftable.find(hwaddr) == ftable.end()));
        };

private:

        cfibtable(
                        const rofl::cdptid& dptid) :
                dptid(dptid) {
                cfibtable::fibtables[dptid] = this;
        };

        virtual
        ~cfibtable() {
                clear();
                cfibtable::fibtables.erase(dptid);
        };

private:

        /*
         * methods overwritten from cfibentry_env
         */

        virtual void
        fib_timer_expired(
                        const rofl::caddress_ll& hwaddr)
        { drop_fib_entry(hwaddr); };

        virtual void
        fib_port_update(
                        const cfibentry& entry)
        {};

public:

        friend std::ostream&
        operator<< (std::ostream& os, cfibtable const& fib) {
                try {
                        os << rofl::indent(0) << "<cfibtable dpid:" << "dpid: "
                                        << rofl::crofdpt::get_dpt(fib.dptid).get_dpid().str() << " >" << std::endl;
                } catch (rofl::eRofDptNotFound& e) {
                        os << rofl::indent(0) << "<cfibtable dptid:" << "dpid: " << fib.dptid << " >" << std::endl;
                }
                rofl::indent i(2);
                for (std::map<rofl::caddress_ll, cfibentry*>::const_iterator
                                it = fib.ftable.begin(); it != fib.ftable.end(); ++it) {
                        os << *(it->second);
                }
                return os;
        };

private:

        static std::map<rofl::cdptid, cfibtable*> fibtables;
        rofl::cdptid dptid;
        std::map<rofl::caddress_ll, cfibentry*> ftable;
};

}; // namespace ethswctld
}; // namespace examples
}; // namespace rofl

#endif /* CFIB_H_ */