mnt_pump.h

#ifndef MNT_PUMP_H
#define MNT_PUMP_H

#include "timer.h"
#include "mnt_component.h"

class MntPump: public MntComponent 
{
        private:
                int running_;  
        public:

        class PumpTimer : public Timer {
        public :
                MntPump *reader_; 
                void timeout() {
                        reader_->pump_some();
                }
        } pump_timer_;

        MntPump()
        {
        }
 
        inline virtual void 
        start_pumping()
        {
                running_ = 1;
                pump_some();
        }

        inline virtual void 
        stop_pumping()
        {
                running_ = 0;
                eval_instproc("on_stop_pumping");
        }

        inline virtual int 
        pump_some()
        {
                return 0;
        }

        inline virtual int 
        is_running()
        {
                return running_;
        }

        int command(int argc, const char*const* argv);
};

#endif

---