1dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand/*-------------------------------------------------------------------------- 2dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandCopyright (c) 2010-2011, Code Aurora Forum. All rights reserved. 3dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 4dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandRedistribution and use in source and binary forms, with or without 5dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchandmodification, are permitted provided that the following conditions are met: 6dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand * Redistributions of source code must retain the above copyright 7dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand notice, this list of conditions and the following disclaimer. 8dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand * Redistributions in binary form must reproduce the above copyright 9dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand notice, this list of conditions and the following disclaimer in the 10dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand documentation and/or other materials provided with the distribution. 11dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand * Neither the name of Code Aurora nor 12dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand the names of its contributors may be used to endorse or promote 13dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand products derived from this software without specific prior written 14dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand permission. 15dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 16dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandTHIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" 17dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandAND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 18dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandIMPLIED WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND 19dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandNON-INFRINGEMENT ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR 20dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandCONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 21dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandEXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 22dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandPROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; 23dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandOR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, 24dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandWHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR 25dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandOTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF 26dd5743ee305c8db17facba3e0176a3d07adc7499Rom LemarchandADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 27dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand--------------------------------------------------------------------------*/ 28dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand#ifndef QUEUE_H 29dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand#define QUEUE_H 30dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 31dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand#include<pthread.h> 32dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand#include <semaphore.h> 33dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand#include <stdio.h> 34dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand#include <string.h> 35dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 36dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand/* Message Queue structure */ 37dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchandstruct video_msgq 38dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand{ 39dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand /* Command to be executed */ 40dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand unsigned int cmd; 41dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 42dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand unsigned int status; 43dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 44dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand /* Client-specific data */ 45dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand void *clientdata; 46dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand}; 47dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 48dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 49dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand/* Thread & Message Queue information */ 50dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchandstruct video_queue_context 51dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand{ 52dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand /* Message Queue related members */ 53dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand pthread_mutex_t mutex; 54dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand sem_t sem_message; 55dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand int commandq_size; 56dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand int dataq_size; 57dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand struct video_msgq *ptr_dataq; 58dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand struct video_msgq *ptr_cmdq; 59dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand int write_dataq ; 60dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand int read_dataq; 61dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand int write_comq ; 62dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand int read_comq ; 63dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 64dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand}; 65dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 66dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchandint check_if_queue_empty ( unsigned int queuetocheck,void* queuecontext ); 67dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 68dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchandstruct video_msgq * queue_get_cmd ( void* queuecontext ); 69dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 70dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 71dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 72dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchandint queue_post_cmdq ( void *queuecontext, 73dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand struct video_msgq *post_msg 74dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand ); 75dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 76dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchandint queue_post_dataq ( void *queuecontext, 77dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand struct video_msgq *post_msg 78dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand ); 79dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand 80dd5743ee305c8db17facba3e0176a3d07adc7499Rom Lemarchand#endif /* QUEUE_H */ 81