[apple/xnu.git] / iokit / IOKit / IOSharedDataQueue.h

/*
 * Copyright (c) 1998-2000 Apple Computer, Inc. All rights reserved.
 *
 * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
 * 
 * This file contains Original Code and/or Modifications of Original Code
 * as defined in and that are subject to the Apple Public Source License
 * Version 2.0 (the 'License'). You may not use this file except in
 * compliance with the License. The rights granted to you under the License
 * may not be used to create, or enable the creation or redistribution of,
 * unlawful or unlicensed copies of an Apple operating system, or to
 * circumvent, violate, or enable the circumvention or violation of, any
 * terms of an Apple operating system software license agreement.
 * 
 * Please obtain a copy of the License at
 * http://www.opensource.apple.com/apsl/ and read it before using this file.
 * 
 * The 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.
 * 
 * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
 */

#ifndef _IOKIT_IOSHAREDDATAQUEUE_H
#define _IOKIT_IOSHAREDDATAQUEUE_H

#ifdef dequeue
#undef dequeue
#endif

#include <IOKit/IODataQueue.h>

typedef struct _IODataQueueEntry IODataQueueEntry;

/*!
 * @class IOSharedDataQueue : public IODataQueue
 * @abstract A generic queue designed to pass data both from the kernel to a user process and from a user process to the kernel.
 * @discussion The IOSharedDataQueue class is designed to also allow a user process to queue data to kernel code.  IOSharedDataQueue objects are designed to be used in a single producer / single consumer situation.  As such, there are no locks on the data itself.  Because the kernel enqueue and user-space dequeue methods follow a strict set of guidelines, no locks are necessary to maintain the integrity of the data struct.
 *
 * <br>Each data entry can be variable sized, but the entire size of the queue data region (including overhead for each entry) must be specified up front.
 *
 * <br>In order for the IODataQueue instance to notify the user process that data is available, a notification mach port must be set.  When the queue is empty and a new entry is added, a message is sent to the specified port.
 *
 * <br>In order to make the data queue memory available to a user process, the method getMemoryDescriptor() must be used to get an IOMemoryDescriptor instance that can be mapped into a user process.  Typically, the clientMemoryForType() method on an IOUserClient instance will be used to request the IOMemoryDescriptor and then return it to be mapped into the user process.
 */
class IOSharedDataQueue : public IODataQueue
{
    OSDeclareDefaultStructors(IOSharedDataQueue)

    struct ExpansionData { 
        UInt32 queueSize;
    };
    /*! @var reserved
        Reserved for future use.  (Internal use only)  */
    ExpansionData * _reserved;

protected:
    virtual void free();

    UInt32 getQueueSize();
    Boolean setQueueSize(UInt32 size);

public:
    /*!
     * @function withCapacity
     * @abstract Static method that creates a new IOSharedDataQueue instance with the capacity specified in the size parameter.
     * @discussion The actual size of the entire data queue memory region (to be shared into a user process) is equal to the capacity plus the IODataQueueMemory overhead.  This overhead value can be determined from the DATA_QUEUE_MEMORY_HEADER_SIZE macro in <IOKit/IODataQueueShared.h>.  The size of the data queue memory region must include space for the overhead of each IODataQueueEntry.  This entry overhead can be determined from the DATA_QUEUE_ENTRY_HEADER_SIZE macro in <IOKit/IODataQueueShared.h>.<br>  This method allocates a new IODataQueue instance and then calls initWithCapacity() with the given size parameter.  If the initWithCapacity() fails, the new instance is released and zero is returned.
     * @param size The size of the data queue memory region.
     * @result Returns the newly allocated IOSharedDataQueue instance.  Zero is returned on failure.
     */
    static IOSharedDataQueue *withCapacity(UInt32 size);

    /*!
     * @function withEntries
     * @abstract Static method that creates a new IOSharedDataQueue instance with the specified number of entries of the given size.
     * @discussion This method will create a new IOSharedDataQueue instance with enough capacity for numEntries of entrySize.  It does account for the IODataQueueEntry overhead for each entry.  Note that the numEntries and entrySize are simply used to determine the data region size.  They do not actually restrict the size of number of entries that can be added to the queue.<br>  This method allocates a new IODataQueue instance and then calls initWithEntries() with the given numEntries and entrySize parameters.  If the initWithEntries() fails, the new instance is released and zero is returned.
     * @param numEntries Number of entries to allocate space for.
     * @param entrySize Size of each entry.
     * @result Reeturns the newly allocated IOSharedDataQueue instance.  Zero is returned on failure.
     */
    static IOSharedDataQueue *withEntries(UInt32 numEntries, UInt32 entrySize);

    /*!
     * @function initWithCapacity
     * @abstract Initializes an IOSharedDataQueue instance with the capacity specified in the size parameter.
     * @discussion The actual size of the entire data queue memory region (to be shared into a user process) is equal to the capacity plus the IODataQueueMemory overhead.  This overhead value can be determined from the DATA_QUEUE_MEMORY_HEADER_SIZE and DATA_QUEUE_MEMORY_APPENDIX_SIZE macro in <IOKit/IODataQueueShared.h>.  The size of the data queue memory region must include space for the overhead of each IODataQueueEntry.  This entry overhead can be determined from the DATA_QUEUE_ENTRY_HEADER_SIZE macro in <IOKit/IODataQueueShared.h>.
     * @param size The size of the data queue memory region.
     * @result Returns true on success and false on failure.
     */
    virtual Boolean initWithCapacity(UInt32 size);

    /*!
     * @function getMemoryDescriptor
     * @abstract Returns a memory descriptor covering the IODataQueueMemory region.
     * @discussion The IOMemoryDescriptor instance returned by this method is intended to be mapped into a user process.  This is the memory region that the IODataQueueClient code operates on.
     * @result Returns a newly allocated IOMemoryDescriptor for the IODataQueueMemory region.  Returns zero on failure.
     */
    virtual IOMemoryDescriptor *getMemoryDescriptor();

    /*!
     * @function peek
     * @abstract Used to peek at the next entry on the queue.
     * @discussion This function can be used to look at the next entry which allows the entry to be received without having to copy it with dequeue.  In order to do this, call peek to get the entry.  Then call dequeue with a NULL data pointer.  That will cause the head to be moved to the next entry, but no memory to be copied.
     * @result Returns a pointer to the next IODataQueueEntry if one is available.  0 (NULL) is returned if the queue is empty.
     */
    virtual IODataQueueEntry * peek();

    /*!
     * @function dequeue
     * @abstract Dequeues the next available entry on the queue and copies it into the given data pointer.
     * @discussion This function will dequeue the next available entry on the queue.  If a data pointer is provided, it will copy the data into the memory region if there is enough space available as specified in the dataSize parameter.  If no data pointer is provided, it will simply move the head value past the current entry.
     * @param data A pointer to the data memory region in which to copy the next entry data on the queue.  If this parameter is 0 (NULL), it will simply move to the next entry.
     * @param dataSize A pointer to the size of the data parameter.  On return, this contains the size of the actual entry data - even if the original size was not large enough.
     * @result Returns true on success and false on failure.  Typically failure means that the queue is empty.
     */
    virtual Boolean dequeue(void *data, UInt32 *dataSize);

    /*!
     * @function enqueue
     * @abstract Enqueues a new entry on the queue.
     * @discussion This method adds a new data entry of dataSize to the queue.  It sets the size parameter of the entry pointed to by the tail value and copies the memory pointed to by the data parameter in place in the queue.  Once that is done, it moves the tail to the next available location.  When attempting to add a new entry towards the end of the queue and there isn't enough space at the end, it wraps back to the beginning.<br>  If the queue is empty when a new entry is added, sendDataAvailableNotification() is called to send a message to the user process that data is now available.
     * @param data Pointer to the data to be added to the queue.
     * @param dataSize Size of the data pointed to by data.
     * @result Returns true on success and false on failure.  Typically failure means that the queue is full.
     */
    virtual Boolean enqueue(void *data, UInt32 dataSize);

    OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 0);
    OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 1);
    OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 2);
    OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 3);
    OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 4);
    OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 5);
    OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 6);
    OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 7);
};

#endif /* _IOKIT_IOSHAREDDATAQUEUE_H */
Commit	Line	Data
2d21ac55 A	1	/*
	2	* Copyright (c) 1998-2000 Apple Computer, Inc. All rights reserved.
	3	*
	4	* @APPLE_OSREFERENCE_LICENSE_HEADER_START@
	5	*
	6	* This file contains Original Code and/or Modifications of Original Code
	7	* as defined in and that are subject to the Apple Public Source License
	8	* Version 2.0 (the 'License'). You may not use this file except in
	9	* compliance with the License. The rights granted to you under the License
	10	* may not be used to create, or enable the creation or redistribution of,
	11	* unlawful or unlicensed copies of an Apple operating system, or to
	12	* circumvent, violate, or enable the circumvention or violation of, any
	13	* terms of an Apple operating system software license agreement.
	14	*
	15	* Please obtain a copy of the License at
	16	* http://www.opensource.apple.com/apsl/ and read it before using this file.
	17	*
	18	* The Original Code and all software distributed under the License are
	19	* distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
	20	* EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
	21	* INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
	22	* FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
	23	* Please see the License for the specific language governing rights and
	24	* limitations under the License.
	25	*
	26	* @APPLE_OSREFERENCE_LICENSE_HEADER_END@
	27	*/
	28
	29	#ifndef _IOKIT_IOSHAREDDATAQUEUE_H
	30	#define _IOKIT_IOSHAREDDATAQUEUE_H
	31
	32	#ifdef dequeue
	33	#undef dequeue
	34	#endif
	35
	36	#include <IOKit/IODataQueue.h>
	37
	38	typedef struct _IODataQueueEntry IODataQueueEntry;
	39
	40	/*!
	41	* @class IOSharedDataQueue : public IODataQueue
	42	* @abstract A generic queue designed to pass data both from the kernel to a user process and from a user process to the kernel.
	43	* @discussion The IOSharedDataQueue class is designed to also allow a user process to queue data to kernel code. IOSharedDataQueue objects are designed to be used in a single producer / single consumer situation. As such, there are no locks on the data itself. Because the kernel enqueue and user-space dequeue methods follow a strict set of guidelines, no locks are necessary to maintain the integrity of the data struct.
	44	*
	45	* <br>Each data entry can be variable sized, but the entire size of the queue data region (including overhead for each entry) must be specified up front.
	46	*
	47	* <br>In order for the IODataQueue instance to notify the user process that data is available, a notification mach port must be set. When the queue is empty and a new entry is added, a message is sent to the specified port.
	48	*
	49	* <br>In order to make the data queue memory available to a user process, the method getMemoryDescriptor() must be used to get an IOMemoryDescriptor instance that can be mapped into a user process. Typically, the clientMemoryForType() method on an IOUserClient instance will be used to request the IOMemoryDescriptor and then return it to be mapped into the user process.
	50	*/
	51	class IOSharedDataQueue : public IODataQueue
	52	{
	53	OSDeclareDefaultStructors(IOSharedDataQueue)
	54
	55	struct ExpansionData {
143464d5	56	UInt32 queueSize;
2d21ac55 A	57	};
	58	/*! @var reserved
	59	Reserved for future use. (Internal use only) */
	60	ExpansionData * _reserved;
	61
	62	protected:
	63	virtual void free();
	64
143464d5 A	65	UInt32 getQueueSize();
	66	Boolean setQueueSize(UInt32 size);
	67
2d21ac55 A	68	public:
	69	/*!
	70	* @function withCapacity
	71	* @abstract Static method that creates a new IOSharedDataQueue instance with the capacity specified in the size parameter.
	72	* @discussion The actual size of the entire data queue memory region (to be shared into a user process) is equal to the capacity plus the IODataQueueMemory overhead. This overhead value can be determined from the DATA_QUEUE_MEMORY_HEADER_SIZE macro in <IOKit/IODataQueueShared.h>. The size of the data queue memory region must include space for the overhead of each IODataQueueEntry. This entry overhead can be determined from the DATA_QUEUE_ENTRY_HEADER_SIZE macro in <IOKit/IODataQueueShared.h>.<br> This method allocates a new IODataQueue instance and then calls initWithCapacity() with the given size parameter. If the initWithCapacity() fails, the new instance is released and zero is returned.
	73	* @param size The size of the data queue memory region.
	74	* @result Returns the newly allocated IOSharedDataQueue instance. Zero is returned on failure.
	75	*/
	76	static IOSharedDataQueue *withCapacity(UInt32 size);
	77
	78	/*!
	79	* @function withEntries
	80	* @abstract Static method that creates a new IOSharedDataQueue instance with the specified number of entries of the given size.
	81	* @discussion This method will create a new IOSharedDataQueue instance with enough capacity for numEntries of entrySize. It does account for the IODataQueueEntry overhead for each entry. Note that the numEntries and entrySize are simply used to determine the data region size. They do not actually restrict the size of number of entries that can be added to the queue.<br> This method allocates a new IODataQueue instance and then calls initWithEntries() with the given numEntries and entrySize parameters. If the initWithEntries() fails, the new instance is released and zero is returned.
	82	* @param numEntries Number of entries to allocate space for.
	83	* @param entrySize Size of each entry.
	84	* @result Reeturns the newly allocated IOSharedDataQueue instance. Zero is returned on failure.
	85	*/
	86	static IOSharedDataQueue *withEntries(UInt32 numEntries, UInt32 entrySize);
	87
	88	/*!
	89	* @function initWithCapacity
	90	* @abstract Initializes an IOSharedDataQueue instance with the capacity specified in the size parameter.
	91	* @discussion The actual size of the entire data queue memory region (to be shared into a user process) is equal to the capacity plus the IODataQueueMemory overhead. This overhead value can be determined from the DATA_QUEUE_MEMORY_HEADER_SIZE and DATA_QUEUE_MEMORY_APPENDIX_SIZE macro in <IOKit/IODataQueueShared.h>. The size of the data queue memory region must include space for the overhead of each IODataQueueEntry. This entry overhead can be determined from the DATA_QUEUE_ENTRY_HEADER_SIZE macro in <IOKit/IODataQueueShared.h>.
	92	* @param size The size of the data queue memory region.
	93	* @result Returns true on success and false on failure.
	94	*/
	95	virtual Boolean initWithCapacity(UInt32 size);
	96
	97	/*!
	98	* @function getMemoryDescriptor
	99	* @abstract Returns a memory descriptor covering the IODataQueueMemory region.
	100	* @discussion The IOMemoryDescriptor instance returned by this method is intended to be mapped into a user process. This is the memory region that the IODataQueueClient code operates on.
	101	* @result Returns a newly allocated IOMemoryDescriptor for the IODataQueueMemory region. Returns zero on failure.
	102	*/
	103	virtual IOMemoryDescriptor *getMemoryDescriptor();
	104
	105	/*!
	106	* @function peek
	107	* @abstract Used to peek at the next entry on the queue.
	108	* @discussion This function can be used to look at the next entry which allows the entry to be received without having to copy it with dequeue. In order to do this, call peek to get the entry. Then call dequeue with a NULL data pointer. That will cause the head to be moved to the next entry, but no memory to be copied.
	109	* @result Returns a pointer to the next IODataQueueEntry if one is available. 0 (NULL) is returned if the queue is empty.
	110	*/
	111	virtual IODataQueueEntry * peek();
	112
	113	/*!
	114	* @function dequeue
	115	* @abstract Dequeues the next available entry on the queue and copies it into the given data pointer.
	116	* @discussion This function will dequeue the next available entry on the queue. If a data pointer is provided, it will copy the data into the memory region if there is enough space available as specified in the dataSize parameter. If no data pointer is provided, it will simply move the head value past the current entry.
	117	* @param data A pointer to the data memory region in which to copy the next entry data on the queue. If this parameter is 0 (NULL), it will simply move to the next entry.
	118	* @param dataSize A pointer to the size of the data parameter. On return, this contains the size of the actual entry data - even if the original size was not large enough.
	119	* @result Returns true on success and false on failure. Typically failure means that the queue is empty.
	120	*/
	121	virtual Boolean dequeue(void data, UInt32 dataSize);
	122
143464d5 A	123	/*!
	124	* @function enqueue
	125	* @abstract Enqueues a new entry on the queue.
	126	* @discussion This method adds a new data entry of dataSize to the queue. It sets the size parameter of the entry pointed to by the tail value and copies the memory pointed to by the data parameter in place in the queue. Once that is done, it moves the tail to the next available location. When attempting to add a new entry towards the end of the queue and there isn't enough space at the end, it wraps back to the beginning.<br> If the queue is empty when a new entry is added, sendDataAvailableNotification() is called to send a message to the user process that data is now available.
	127	* @param data Pointer to the data to be added to the queue.
	128	* @param dataSize Size of the data pointed to by data.
	129	* @result Returns true on success and false on failure. Typically failure means that the queue is full.
	130	*/
	131	virtual Boolean enqueue(void *data, UInt32 dataSize);
	132
2d21ac55 A	133	OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 0);
	134	OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 1);
	135	OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 2);
	136	OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 3);
	137	OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 4);
	138	OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 5);
	139	OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 6);
	140	OSMetaClassDeclareReservedUnused(IOSharedDataQueue, 7);
	141	};
	142
	143	#endif /* _IOKIT_IOSHAREDDATAQUEUE_H */