EventQueue.h

Go to the documentation of this file.

//                            Package   : omniEvents
// EventQueue.h               Created   : 2003/12/04
//                            Author    : Alex Tingle
//
//    Copyright (C) 2003 Alex Tingle.
//
//    This file is part of the omniEvents application.
//
//    omniEvents is free software; you can redistribute it and/or
//    modify it under the terms of the GNU Lesser General Public
//    License as published by the Free Software Foundation; either
//    version 2.1 of the License, or (at your option) any later version.
//
//    omniEvents 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
//    Lesser General Public License for more details.
//
//    You should have received a copy of the GNU Lesser General Public
//    License along with this library; if not, write to the Free Software
//    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
//

#ifndef OMNIEVENTS__EVENTQUEUE_H
#define OMNIEVENTS__EVENTQUEUE_H

#ifdef HAVE_CONFIG_H
#  include "config.h"
#endif

#include "Orb.h"
#include "Filter.h"

#include <memory>

#ifdef HAVE_STD_STL
using namespace std;
#endif


namespace OmniEvents {


class EventQueue
{
public:
  class Reader
  {
  public:
    Reader(EventQueue& eventQueue);
    bool moreEvents() const;
    CORBA::Any* nextEvent();
  private:
    EventQueue& _eventQueue;
    int         _next; 
  };

  EventQueue(long size=1023);
  virtual ~EventQueue();
  void setFilter(Filter* filter)
  {
    auto_ptr<Filter> f(filter);
    _filter=f; // MS VC++ 6 has no auto_ptr::reset()
  }

  inline void append(CORBA::Any* event)
  {
    if(!_filter.get() || _filter->keep(*event))
    {
      delete _queue[_next];
      _queue[_next]=event;
      _next=(_next+1)%_size;
    }
  }

private:
  long             _next;
  long             _size;
  CORBA::Any**     _queue;
  auto_ptr<Filter> _filter;

  friend class Reader;
};

}; // end namespace OmniEvents

#endif // OMNIEVENTS__EVENTQUEUE_H

---