cetherswitch.h

#ifndef ETHERSWITCH_H
#define ETHERSWITCH_H 1

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

#include <rofl.h>
#include <rofl/common/caddress.h>
#include <rofl/common/crofbase.h>
#include <rofl/common/crofdpt.h>
#include <rofl/platform/unix/cunixenv.h>
#include <rofl/platform/unix/cdaemon.h>
#include <rofl/common/cparams.h>

#include "cfibtable.h"
#include "cflowtable.h"

namespace rofl {
namespace examples {
namespace ethswctld {



class cetherswitch : public rofl::crofbase {
public:

        static
        int
        run(
                        int argc, char** argv);

private:

        cetherswitch(
                        const rofl::openflow::cofhello_elem_versionbitmap& versionbitmap);

        virtual
        ~cetherswitch();


private:

        virtual void
        handle_dpt_open(
                        rofl::crofdpt& dpt);

        virtual void
        handle_dpt_close(
                        rofl::crofdpt& dpt);

        virtual void
        handle_packet_in(
                        rofl::crofdpt& dpt,
                        const rofl::cauxid& auxid,
                        rofl::openflow::cofmsg_packet_in& msg);

        virtual void
        handle_flow_stats_reply(
                        rofl::crofdpt& dpt,
                        const rofl::cauxid& auxid,
                        rofl::openflow::cofmsg_flow_stats_reply& msg);

        virtual void
        handle_flow_stats_reply_timeout(
                        rofl::crofdpt& dpt,
                        uint32_t xid);

private:

        virtual void
        handle_timeout(
                        int opaque,
                        void* data = (void*)NULL);

        void
        dump_packet_in(
                rofl::crofdpt& dpt,
                rofl::openflow::cofmsg_packet_in& msg);

public:

        friend std::ostream&
        operator<< (std::ostream& os, const cetherswitch& sw) {
                try {
                        os << rofl::indent(0) << "<ethswitch dpid: "
                                        << rofl::crofdpt::get_dpt(sw.dptid).get_dpid().str() << " >" << std::endl;
                } catch (rofl::eRofDptNotFound& e) {
                        os << rofl::indent(0) << "<ethswitch dptid: " << sw.dptid << " >" << std::endl;
                }
                rofl::indent i(2);
                os << cfibtable::set_fib(sw.dptid);
                os << cflowtable::get_flowtable(sw.dptid);
                return os;
        };

private:

        enum cetherswitch_timer_t {
                TIMER_DUMP_FIB          = 1,
                TIMER_GET_FLOW_STATS    = 2,
        };

        rofl::cdptid                dptid;

        rofl::ctimerid              timer_id_dump_fib;
        unsigned int                dump_fib_interval;
        static const unsigned int   DUMP_FIB_DEFAULT_INTERVAL = 60; // seconds

        rofl::ctimerid              timer_id_get_flow_stats;
        unsigned int                get_flow_stats_interval;
        static const unsigned int   GET_FLOW_STATS_DEFAULT_INTERVAL = 30; // seconds
};

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

#endif