src/sends/sends_main.hh

/* -*- mode: c++; c-basic-offset: 4; -*- */
#ifndef SENDS_MAIN_HH
#define SENDS_MAIN_HH

#include "authorize.hh"
#include "concentrator.hh"
#include "parse_stage.hh"
#include "lookup_stage.hh"
#include "fetch_stage.hh"
#include "write_stage.hh"

namespace sends {

    class transaction;

    class sends_main {
    public:
        sends_main(int argc, const char* argv[]);

        ~sends_main(void);

        void configure(void);

        void doit(void);

    private:
        //------------------------------  Parameter storage data types
        typedef std::map<std::string, seda_stage::stage_pars> stage_par_map;
        typedef stage_par_map::iterator       stage_par_iter;
        typedef stage_par_map::const_iterator const_stage_par_iter;
        typedef stage_par_map::value_type     stage_par_node;

    private:
        authorize    mAuthPool;
        concentrator mConcPool;
        parse_stage  mParsePool;
        lookup_stage mLookupPool;
        fetch_stage  mFetchPool;
        write_stage  mWritePool;
        tran_queue   tranQ;
        std::vector<transaction*> tranVec;

        //------------------------------  Parameters
        stage_par_map mStageParMap;
        int           mSmallBufSize;
        int           mSmallBufCount;
        int           mLargeBufSize;
        int           mLargeBufCount;
        int           mTransCount;
        std::string   mListenAddr;
        int           mListenQueue;
        typedef std::pair<unsigned int, unsigned int> allow_node;
        std::vector<allow_node> mAllowVect;
    };

}


#endif  // !defined(SENDS_MAIN_HH)

---