routing-module.h

Go to the documentation of this file.

/*
 * Copyright (c) 2006 Regents of the SIGNET lab, University of Padova.
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. Neither the name of the University of Padova (SIGNET lab) nor the 
 *    names of its contributors may be used to endorse or promote products 
 *    derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 
 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 
 * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR 
 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 
 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 
 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 
 * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 
 * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 
 * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 
 * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

#ifndef _ROUTING_MODULE_
#define _ROUTING_MODULE_

#include <module.h>
#include <clmessage.h>
#include <cltracer.h>
#include "mrcl-address.h"
#include "metric.h"
#include "utility.h"
#include "routing-queue.h"

extern ClMessage_t CL_ROUTEMESSAGE;

#define ROUTEREACHABLE_VERBOSITY 5
#define ROUTE_REACHABLE_ALLOC_INFO_PER_TIME 10

#define CTRL_PKT_DROP_VERBOSITY 10
#define CTRL_PKT_DROP_MSG "CTRL"

class RouteReachable : public ClMessage
{
public:
        RouteReachable(int source);
        virtual ~RouteReachable();
        void setAddress(char *a);
        char *getAddress();
        void addRouteInfo(RouteInfo *i);
        int length();
        RouteInfo *getRouteInfo(int id);
        RouteInfo **getRouteInfo();
        void empty();
        int isMyIP();
        void setMyIP();
        void processed(int value);
        int processed();
        int getIndex(int id);
private:
        RouteInfo **info_;
        int nInfo_;
        int *modules_;
        int nModules_;
        int infoLen_;
        char addr_[MRCL_ADDRESS_MAX_LEN];
        int myIP_;
        int processed_;
};



// class RouteReachableTracer : public ClMessageTracer
// {
//      public:
//              RouteReachableTracer();
//              void format(ClMessage *m, ClSAP *sap);
// };


struct ModuleRoute
{
        DinArray modules;
        double w;
        Reachability reachability;
};

class MrclRouting : public Module
{
        friend class RoutingQueue;
public:
        MrclRouting();
        virtual ~MrclRouting();
        virtual int command(int argc, const char*const* argv);
        virtual int recvSyncClMsg(ClMessage *m);
        void recv(Packet* p);
protected:
        virtual int controlPacket(Packet *p) = 0;
        virtual char *getNextHop(Packet *p) = 0;
        int getRoute(MrclAddress *a, Packet *p, int i);
        int getRoute(char *addr, Packet *p, int i);
        virtual int canIReach(char *a, Metric ***m)=0;
        virtual void forward(Packet *p) = 0;
        virtual void resolve(Packet *p) = 0;
        void addAddress(MrclAddress *a);
        MrclAddress *getAddress(int i);
        int nAddresses();
        int isMyAddress(char *addr);
        int overheadLength_;
private:        
        int getConfiguration(char *a, int source = -1);
        int findNextLeaf(int i = -1);
        MrclAddress **addresses_;
        int nAddresses_;
        RouteReachable *rr_;
        double lastGetConfiguration_;
        DinArray routes_;
        double delayUp_;
        double delayDown_;
};


#endif

---