/* -*- c++ -*- */
/*
 * Copyright 2008 Free Software Foundation, Inc.
 * 
 * This file is part of GNU Radio
 * 
 * GNU Radio is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 3, or (at your option)
 * any later version.
 * 
 * GNU Radio is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public License along
 * with this program; if not, write to the Free Software Foundation, Inc.,
 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */
#ifndef INCLUDED_RING_H
#define INCLUDED_RING_H

#include <gnuradio/omnithread.h>
#include <stddef.h>
#include <vector>
#include <boost/shared_ptr.hpp>

namespace usrp2 {

  class ring;
  typedef boost::shared_ptr<ring> ring_sptr;

  class ring
  {
  private:
 
    size_t d_max;
    size_t d_read_ind;
    size_t d_write_ind;

    struct ring_desc
    {
      void *d_base;
      size_t d_len;
    };
    std::vector<ring_desc> d_ring;

    omni_mutex d_mutex;
    omni_condition d_not_empty;

    void inc_read_ind()
    {
      if (d_read_ind + 1 >= d_max)
	d_read_ind = 0;
      else
	d_read_ind = d_read_ind + 1;
    }

    void inc_write_ind()
    {
      if (d_write_ind + 1 >= d_max)
	d_write_ind = 0;
      else
	d_write_ind = d_write_ind + 1;
    }
        
    bool empty() const { return d_read_ind == d_write_ind; }
    bool full() const { return (d_write_ind+1)%d_max == d_read_ind; }

  public:
    
    ring(unsigned int entries);

    void wait_for_not_empty();

    bool enqueue(void *p, size_t len);
    bool dequeue(void **p, size_t *len);
  };

}  // namespace usrp2

#endif /* INCLUDED_RING_H */