src/stages/parse_stage.hh

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

#include "seda_stage.hh"
#include "buffer_pool.hh"

namespace sends {

    const int parse_buffer_length=32768;
    class buffer;

    class parse_stage : public seda_stage {
    public:
        typedef thread::mt_queue<buffer*> buffer_queue;
        // typedef tbb::concurrent_queue<buffer*> buffer_queue;
    public:
        parse_stage(int nThread, int nTrans);

        virtual ~parse_stage(void);

        void filter(transaction* trans);

        void init_thread(void);

        buffer_pool& ref_resource(void);

        virtual void shut(void);

        const char* stage_name(void) const;

    private:
        buffer_pool resource;

        //------------------------------  Statistics
        long        quit_count;
    };

    inline buffer_pool&
    parse_stage::ref_resource(void) {
        return resource;
    }
}

#endif // !defined(SENDS_PARSE_STAGE_HH)

---