DataBuffer.h

// -*- indent-tabs-mode: nil -*-

#ifndef __ARC_DATABUFFER_H__
#define __ARC_DATABUFFER_H__

#include <arc/Thread.h>
#include <arc/data/DataSpeed.h>

namespace Arc {

  class CheckSum;


  class DataBuffer {
  private:
    int set_counter;
    Glib::Mutex lock;
    Glib::Cond cond;
    typedef struct {
      char *start;
      bool taken_for_read;
      bool taken_for_write;
      unsigned int size;
      unsigned int used;
      unsigned long long int offset;
    } buf_desc;
    unsigned long long int eof_pos;
    buf_desc *bufs;
    int bufs_n;
    bool eof_read_flag;
    bool eof_write_flag;
    bool error_read_flag;
    bool error_write_flag;
    bool error_transfer_flag;
    bool cond_wait();
    class checksum_desc {
     public:
      checksum_desc(CheckSum *sum)
        : sum(sum),
          offset(0),
          ready(true) {}
      CheckSum *sum;
      unsigned long long int offset;
      bool ready;
    };
    std::list<checksum_desc> checksums;

  public:
    DataSpeed speed;
    operator bool() const {
      return (bufs != 0);
    }

    DataBuffer(unsigned int size = 65536, int blocks = 3);

    DataBuffer(CheckSum *cksum, unsigned int size = 65536, int blocks = 3);
    ~DataBuffer();

    bool set(CheckSum *cksum = NULL, unsigned int size = 65536,
             int blocks = 3);

    int add(CheckSum *cksum);

    char* operator[](int n);

    bool for_read(int& handle, unsigned int& length, bool wait);

    bool for_read();

    bool is_read(int handle, unsigned int length,
                 unsigned long long int offset);

    bool is_read(char *buf, unsigned int length,
                 unsigned long long int offset);

    bool for_write(int& handle, unsigned int& length,
                   unsigned long long int& offset, bool wait);

    bool for_write();

    bool is_written(int handle);

    bool is_written(char *buf);

    bool is_notwritten(int handle);

    bool is_notwritten(char *buf);

    void eof_read(bool v);

    void eof_write(bool v);

    void error_read(bool v);

    void error_write(bool v);
    bool eof_read();
    bool eof_write();
    bool error_read();
    bool error_write();
    bool error_transfer();
    bool error();

    bool wait_any();

    bool wait_used();

    bool wait_for_read();

    bool wait_for_write();

    bool checksum_valid(int index) const;
    bool checksum_valid() const;

    const CheckSum* checksum_object(int index) const;
    const CheckSum* checksum_object() const;
    bool wait_eof_read();
    bool wait_read();
    bool wait_eof_write();
    bool wait_write();
    bool wait_eof();
    unsigned long long int eof_position() const {
      return eof_pos;
    }

    unsigned int buffer_size() const;
  };

} // namespace Arc

#endif // __ARC_DATABUFFER_H__