doc/forest/_router_in_proc_8h_source.html

#ifndef ROUTERINPROC_H

#define ROUTERINPROC_H


#include <queue>

#include <map>


#include "stdinc.h"

#include "Forest.h"


#include "IfaceTable.h"

#include "LinkTable.h"

#include "ComtreeTable.h"

#include "RouteTable.h"

#include "PacketStore.h"

#include "CtlPkt.h"

#include "QuManager.h"

#include "Quu.h"

#include "IoProcessor.h"

#include "StatsModule.h"

#include "PacketLog.h"


using namespace std::chrono;

using std::thread;

using std::mutex;

using std::unique_lock;


namespace forest {


class Router;


class RouterInProc {

public:

                                RouterInProc(Router*);

                                ~RouterInProc();


                static void start(RouterInProc*);

private:

                const static int numThreads = 100;

                const static int maxReplies = 10000;

                typedef high_resolution_clock::time_point timePoint;


                uint64_t now;


                Router          *rtr;


                int             maxSockNum;

                fd_set          *sockets;

                int             cIf;

                int             nRdy;


                QuManager *qm;


                struct ThreadInfo {

                thread          thred;

                                RouterControl *rc;

                Quu<pktx> q;

                                pktx            px;

                                int             reps;

                                int64_t rcvSeqNum;

        };

                ThreadInfo *tpool;

                List            freeThreads;

                Quu<pair<int,int>> retQ;

                int64_t rcvSeqNum;


                HashSet<comt_t, Hash::u32> *comtSet;

                Repeater *rptr;

                RepeatHandler *repH;


                void            run();

                bool            inBound();

                bool            outBound();


                // booting

                int             bootSock;

                bool            bootStart();

                pktx            bootReceive();

                void            bootSend(pktx);


                // basic forwarding

                pktx            receive();

                void            forward(pktx);

                bool            pktCheck(pktx,int);


                // inband control

                void            handleConnDisc(pktx);

                void            handleRteReply(pktx, int);

                void            sendRteReply(pktx,int);

                void            subUnsub(pktx,int);

};


inline void RouterInProc::forward(pktx px) {

                if (rtr->booting) bootSend(px);

                else rtr->xferQ.enq(px);

}


} // ends namespace


#endif