/* * Copyright (c) 2000-2001 Apple Computer, Inc. All Rights Reserved. * * The contents of this file constitute Original Code as defined in and are * subject to the Apple Public Source License Version 1.2 (the 'License'). * You may not use this file except in compliance with the License. Please obtain * a copy of the License at http://www.apple.com/publicsource and read it before * using this file. * * This Original Code and all software distributed under the License are * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER EXPRESS * OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES, INCLUDING WITHOUT * LIMITATION, ANY WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR * PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT. Please see the License for the * specific language governing rights and limitations under the License. */ // // bufferfifo - a Sink that queues data in a FIFO of buffers for retrieval // #ifndef _H_BUFFERFIFO #define _H_BUFFERFIFO #include "streams.h" #include "buffers.h" #include <list> #include <queue> namespace Security { // // A BufferFifo acts as a First-in First-out queue of Buffer objects. // This is usually used as a flexible I/O buffer queue mechanism. // For convenience, a BufferFifo is a Sink, so you can push data // into it directly using the Sink mechanism. // Note that there is currently no mechanism for restricting the // memory footprint of a BufferFifo. // class BufferFifo : public Sink { public: BufferFifo(size_t es = 4096) : bufferLength(es) { } ~BufferFifo(); Buffer *top() const { assert(!mBuffers.empty()); return mBuffers.front(); } Buffer *pop(); void push(Buffer *b) { mBuffers.push(b); } bool isEmpty() const { return mBuffers.empty(); } size_t size() const { return mBuffers.size(); } size_t topLength() const { assert(!isEmpty()); return mBuffers.front()->length(); } // Sink implementation void consume(const void *data, size_t size); private: typedef queue< Buffer *, list<Buffer *> > BufferQueue; BufferQueue mBuffers; const size_t bufferLength; }; } // end namespace Security #endif _H_BUFFERFIFO