acq.hpp

#ifndef __ACQ_HPP__
#define __ACQ_HPP__

#include <boost/thread/thread.hpp>
#include "param.hpp"
#include "paramip.hpp"
#include "paramdisk.hpp"
#include "fill.hpp"


namespace ipsi
{
  
  template<class T, size_t N, class F>
  class acq
  {
  public:
    acq(    buffer_t*       buff    ,
            boost::mutex*   lock    ,
            size_t*         cur     ,
            size_t*         send    ,
            bool*           run     ,
            bool*           ready   , 
            Param*          param   , 
            Caminfo*        ci      );
    
    acq( const acq& src );
    
    ~acq(); 
    
    void operator()();
    
  private:
    Connection* c;
    
    unsigned int    mIdx    ;
    buffer_t        *mBuffer;
    boost::mutex    *mLock  ;
    unsigned int    *mCur   ,
      *mSend  ;
    bool            *mRun   ;
    bool             mRun2  ;
    bool            *mReady ;
    
    F               mFunc   ;
    Param*          mParam  ;
    
    Caminfo*        mCi     ; 
    
  };
  
#include "acq.impl.hpp"
  
}
#endif

---