source: trunk/src/testing/include/sageEvent.h @ 4

/***************************************************************************************
 * SAGE - Scalable Adaptive Graphics Environment
 *
 * Module:  sageEvent.h
 * Author : Byungil Jeong
 *
 *   Description: Queue for event driven control in a SAGE component
 *
 * Copyright (C) 2004 Electronic Visualization Laboratory,
 * University of Illinois at Chicago
 *
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions are met:
 *
 *  * Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 *  * Redistributions in binary form must reproduce the above
 *    copyright notice, this list of conditions and the following disclaimer
 *    in the documentation and/or other materials provided with the distribution.
 *  * Neither the name of the University of Illinois at Chicago nor
 *    the names of its contributors may be used to endorse or promote
 *    products derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
 * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * Direct questions, comments etc about SAGE to sage_users@listserv.uic.edu or
 * http://www.evl.uic.edu/cavern/forum/
 *
*****************************************************************************************/

#ifndef _SAGE_EVENT_H
#define _SAGE_EVENT_H

#include "sageBase.h"
#include <queue>

#define SAGE_EVENT_SIZE 1280

#define EVENT_NEW_MESSAGE    100
#define EVENT_NEW_CONNECTION 101
#define EVENT_READ_BLOCK     102
#define EVENT_REFRESH_SCREEN 103
#define EVENT_SYNC_MESSAGE   104
#define EVENT_APP_CONNECTED  105
#define EVENT_AUDIO_CONNECTION 106

#define EVENT_SLAVE_PERF_INFO  200
#define EVENT_MASTER_PERF_INFO 201
#define EVENT_APP_SHUTDOWN     202
#define EVENT_BRIDGE_SHUTDOWN  203

/**
 * sageEvent
 */
class sageEvent {
public:
   int eventType;
   char eventMsg[SAGE_EVENT_SIZE];
   void *param;


        /**
         * size of the event message.
         * this is updated when eventMsg is allocated or copied by user
         */
        int buflen;

   sageEvent() : eventType(0), param(NULL), buflen(0) {}
   sageEvent(int type, char* msg, void *p = NULL);

   void setMsg(char *msg) { if (msg) strcpy(eventMsg, msg); }
};

/**
 * sageSyncEvent
 * by sungwon
 * With no MAX_INST_NUM fix from Hyejung, sync algorithm can't use array
 * However, there must be upper bound for the number of application instances that can exist simultaneously.
 * Otherwise, there's no way to determine the size of the sync msg (in the 1st phase of syncMaster).
 * So, this is temporary fix to increase the msg size a little bit more.
 * Or this class can be used more cleverly.
 */
class sageSyncEvent : public sageEvent {
        public:
        //char eventMsg[SAGE_SYNC_MSG_LEN]; /**< overrides sageEvent::eventMsg[] */
        char *eventMsg;

        /**
         * sets buflen
         * returns the size of message
         * -1 on error
         */
        int setMsg(char *msg);

        sageSyncEvent() : eventMsg(NULL) {}
        sageSyncEvent(int type, int bl, void *p=NULL);
};

/**
 * sageEventQueue
 */
class sageEventQueue {
protected:
   std::deque<sageEvent*> eventQueue;

   pthread_mutex_t *queueLock;
   pthread_cond_t *notEmpty;

   bool empty;

public:
   sageEventQueue();

   sageEvent* getEvent();  // get event from the queue
   void appendEvent(sageEvent* event);
   void appendEvent(int type, char *msg = NULL, void *param = NULL);
   void appendEvent(int type, int info, void *param = NULL);
   void prependEvent(sageEvent* event);

   bool isEmpty()  { return (eventQueue.size() == 0); }
   ~sageEventQueue();
};

#endif