/usr/include/ptclib/qchannel.h is in libpt-dev 2.10.10~dfsg-4.1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 | /*
* qchannel.h
*
* Class for implementing a serial queue channel in memory.
*
* Portable Windows Library
*
* Copyright (c) 2001 Equivalence Pty. Ltd.
*
* The contents of this file are subject to the Mozilla Public License
* Version 1.0 (the "License"); you may not use this file except in
* compliance with the License. You may obtain a copy of the License at
* http://www.mozilla.org/MPL/
*
* Software distributed under the License is distributed on an "AS IS"
* basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
* the License for the specific language governing rights and limitations
* under the License.
*
* The Original Code is Portable Windows Library.
*
* The Initial Developer of the Original Code is Equivalence Pty. Ltd.
*
* Contributor(s): ______________________________________.
*
* $Revision: 24177 $
* $Author: rjongbloed $
* $Date: 2010-04-05 06:52:04 -0500 (Mon, 05 Apr 2010) $
*/
#ifndef PTLIB_QCHANNEL_H
#define PTLIB_QCHANNEL_H
#ifdef P_USE_PRAGMA
#pragma interface
#endif
/** Class for implementing a serial queue channel in memory.
This implements a simple memory based First In First Out queue. Data
written to an instance of the class may be read from the same instance at
some later time.
The queue will block the read for the Read Timeout if the queue is empty.
Similarly a write will be clocked for Write Timeout if the queue is full.
If there is any data to be read then it returns immediately with those
bytes, so you must check the GetLastReadCount() to determine the actual
number of bytes read and not rely on the count being passed into the read
function.
*/
class PQueueChannel : public PChannel
{
PCLASSINFO(PQueueChannel, PChannel);
public:
/**@name Construction */
//@{
/** Create a new queue channel with the specified maximum size.
*/
PQueueChannel(
PINDEX queueSize = 0 ///< Queue size
);
/**Delete queue and release memory used.
*/
~PQueueChannel();
//@}
/**@name Overrides from class PChannel */
//@{
/**Low level read from the file channel. The read timeout is ignored for
file I/O. The GetLastReadCount() function returns the actual number
of bytes read.
The GetErrorCode() function should be consulted after Read() returns
false to determine what caused the failure.
@return
true indicates that at least one character was read from the channel.
false means no bytes were read due to timeout or some other I/O error.
*/
virtual PBoolean Read(
void * buf, ///< Pointer to a block of memory to receive the read bytes.
PINDEX len ///< Maximum number of bytes to read into the buffer.
);
/**Low level write to the file channel. The write timeout is ignored for
file I/O. The GetLastWriteCount() function returns the actual number
of bytes written.
The GetErrorCode() function should be consulted after Write() returns
false to determine what caused the failure.
@return true if at least len bytes were written to the channel.
*/
virtual PBoolean Write(
const void * buf, ///< Pointer to a block of memory to write.
PINDEX len ///< Number of bytes to write.
);
/** Close the file channel.
@return true if close was OK.
*/
virtual PBoolean Close();
//@}
/**@name Queue manipulation functions */
//@{
/**Open a queue, allocating the queueSize bytes.
*/
virtual PBoolean Open(
PINDEX queueSize ///< Queue size
);
/// Get the queue size.
PINDEX GetSize() const { return queueSize; }
/// Get the current queue length.
PINDEX GetLength() const { return queueLength; }
//@}
protected:
PMutex mutex;
BYTE * queueBuffer;
PINDEX queueSize, queueLength, enqueuePos, dequeuePos;
PSyncPoint unempty;
PSyncPoint unfull;
};
#endif // PTLIB_QCHANNEL_H
// End Of File ///////////////////////////////////////////////////////////////
|