data_queue.hpp

Go to the documentation of this file.

/*
 * Copyright (C) Sergey P. Derevyago, 2008-2009.
 *
 * Permission to copy, use, modify, sell and distribute this software is granted
 * provided this copyright notice appears in all copies.
 * This software is provided "as is" without express or implied warranty, and
 * with no claim as to its suitability for any purpose.
 *
 */

#ifndef __DERS__DATA_QUEUE_HPP__
#define __DERS__DATA_QUEUE_HPP__

#include <ders/config.hpp>
#include <ders/data_io.hpp>

namespace ders {  // ::ders

class object_io : virtual public destroyable {
 public:
      virtual bool read_from(data_in& in)=0;
      virtual void write_to(data_out& out) const=0;
};

class data_queue : virtual public destroyable {
 public:
      enum result { ok, empt, intr };

      virtual bool is_intr()=0;
      virtual void set_intr(bool val)=0;

      virtual result read_obj(object_io& rdr, bool wait=true)=0;
      virtual result write_obj(const object_io& wrtr)=0;
};

typedef sh_ptr<data_queue> sh_data_queue;

sh_data_queue new_data_queue(mem_pool& mp, int rsrv=10*1024);

sh_data_queue new_data_queue(sh_data_io dio);

}  // namespace ::ders

#endif  // __DERS__DATA_QUEUE_HPP__

---