src/add-ons/media/media-add-ons/dvb/PacketQueue.h

   1 /*
   2  * Copyright (c) 2004-2007 Marcus Overhagen <marcus@overhagen.de>
   3  *
   4  * Permission is hereby granted, free of charge, to any person
   5  * obtaining a copy of this software and associated documentation
   6  * files (the "Software"), to deal in the Software without restriction,
   7  * including without limitation the rights to use, copy, modify,
   8  * merge, publish, distribute, sublicense, and/or sell copies of
   9  * the Software, and to permit persons to whom the Software is
  10  * furnished to do so, subject to the following conditions:
  11  *
  12  * The above copyright notice and this permission notice shall be
  13  * included in all copies or substantial portions of the Software.
  14  *
  15  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  16  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
  17  * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  18  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
  19  * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
  20  * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
  21  * FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR
  22  * OTHER DEALINGS IN THE SOFTWARE.
  23  */
  24
  25 #ifndef __PACKET_QUEUE_H
  26 #define __PACKET_QUEUE_H
  27
  28 #include <OS.h>
  29
  30 class Packet;
  31
  32 class PacketQueue
  33 {
  34 public:
  35                                         PacketQueue(int max_packets = 5);
  36                                         ~PacketQueue();
  37
  38         status_t                Insert(Packet *packet);
  39         status_t                Remove(Packet **packet);
  40
  41         // peeks into queue and delivers a copy
  42         status_t                Peek(Packet **packet);
  43
  44         void                    Flush(bigtime_t timeout);
  45
  46         void                    Terminate();
  47         void                    Restart();
  48
  49 private:
  50         void                    Empty();
  51
  52                                         // not implemented
  53                                         PacketQueue(const PacketQueue & clone);
  54                                         PacketQueue & operator=(PacketQueue & clone);
  55
  56 private:
  57
  58         Packet                  **fQueue;
  59         sem_id                  fSem;
  60         volatile bool   fTerminate;
  61
  62         int                             fWriteIndex;
  63         int                             fReadIndex;
  64         int                             fMaxPackets;
  65         int32                   fPacketCount;
  66 };
  67
  68
  69 #endif