source: trunk/src/winmm/os2timer.cpp@ 667

/* $Id: os2timer.cpp,v 1.6 1999-08-24 16:12:04 phaller Exp $ */

/*
 * OS/2 Timer class
 *
 * Copyright 1998 Sander van Leeuwen (sandervl@xs4all.nl)
 *
 * Project Odin Software License can be found in LICENSE.TXT
 *
 */


/****************************************************************************
 * Includes                                                                 *
 ****************************************************************************/

#define INCL_DOSPROCESS
#define INCL_DOSDATETIME
#define INCL_DOSSEMAPHORES
#include <os2wrap.h>      //Odin32 OS/2 api wrappers
#include <process.h>
#include "win32type.h"
#include "wintimer.h"
#include "os2timer.h"
#include "misc.h"



/****************************************************************************
 * Structures                                                               *
 ****************************************************************************/

#if 0
//@@@PH started new implementation
typedef struct _MMTIMEREVENT
{
  struct _MMTIMEREVENT* prev;
  struct _MMTIMEREVENT* next;

  DWORD           id;                    // event id
  DWORD           timeScheduled;         // system time to fire event
  DWORD           timePeriod;            // period if periodic event
  TID             tidCaller;             // thread ID of caller thread
  DWORD           dwUser;                // user supplied value
  LPTIMERCALLBACK lpCallback;            // address to call
  DWORD           dwFlags;               // event flags
} MMTIMEREVENT, *PMMTIMEREVENT, *LPTIMEREVENT;

typedef struct _MMTIMERRESOLUTION
{
  struct _MMTIMERRESOLUTION* prev;
  struct _MMTIMERRESOLUTION* next;

  DWORD  dwResolution;                   // requested resolution for block
} MMTIMERRESOLUTION, *PMMTIMERRESOLUTION, *LPMMTIMERRESOLUTION;

/*
  enterResolutionScope
  leaveResolutionScope

  addEvent
  removeEvent
  rescheduleEvent
  callbackCaller
*/
#endif

/****************************************************************************
 * Local Prototypes                                                         *
 ****************************************************************************/

static void _Optlink TimerHlpHandler(void *);




/******************************************************************************/
/******************************************************************************/
OS2Timer::OS2Timer() : TimerSem(0), TimerHandle(0), TimerThreadID(0),
                       clientCallback(NULL), TimerStatus(Stopped), fFatal(FALSE)
{
 OS2Timer *timer = OS2Timer::timers;

  if(timer != NULL) {
    while(timer->next != NULL) {
        timer = timer->next;
    }
    timer->next = this;
  }
  else  timers      = this;

  TimerThreadID = _beginthread(TimerHlpHandler, NULL, 0x4000, (void *)this);
  DosSleep(100);
}
/******************************************************************************/
/******************************************************************************/
OS2Timer::~OS2Timer()
{
 OS2Timer *timer = OS2Timer::timers;

  KillTimer();

  if(timer != this) {
    while(timer->next != this) {
        timer = timer->next;
    }
    timer->next = this->next;
  }
  else  timers = timer->next;
}
/******************************************************************************/
/******************************************************************************/
BOOL OS2Timer::StartTimer(int period, int resolution, LPTIMECALLBACK lptc,
                          int dwUser, int fuEvent)
{
 APIRET rc;

  if(TimerThreadID == -1) {
    return(FALSE);
  }
  if(TimerStatus == Stopped) {
    clientCallback = lptc;
    userData       = dwUser;
        if(fuEvent == TIME_PERIODIC)
            rc = DosStartTimer(period, (HSEM)TimerSem, &TimerHandle);
    else    rc = DosAsyncTimer(period, (HSEM)TimerSem, &TimerHandle);
    if(rc) {
#ifdef DEBUG
        if(fuEvent == TIME_PERIODIC)
            WriteLog("DosStartTimer failed %d\n", rc);
        else    WriteLog("DosAsyncTimer failed %d\n", rc);
#endif
        return(FALSE);
    }
        TimerStatus = Running;
  }
  else  return(FALSE);  //already running (must use timeKillEvent first)
  return(TRUE);
}
/******************************************************************************/
/******************************************************************************/
void OS2Timer::StopTimer()
{
  if(TimerStatus == Running) {
        DosStopTimer(TimerHandle);
        TimerStatus = Stopped;
  }
}
/******************************************************************************/
/******************************************************************************/
void OS2Timer::KillTimer()
{
  fFatal = TRUE;
  DosStopTimer(TimerHandle);
  if(DosPostEventSem(TimerSem)) {//something went wrong
        DosKillThread(TimerThreadID);
        DosCloseEventSem(TimerSem);
  }
  TimerStatus = InActive;
}
/******************************************************************************/
//******************************************************************************
void OS2Timer::TimerHandler()
{
 ULONG   Count = 0;
 APIRET  rc = 0;       /* Return code  */

#ifdef DEBUG
    WriteLog("TimerHandler thread created\n");
#endif
    rc = DosSetPriority (PRTYS_THREAD,        /* Change a single thread */
                         PRTYC_TIMECRITICAL,  /* Time critical class    */
                         0L,                  /* Increase by 15         */
                         0L);                 /* Assume current thread  */

    rc = DosCreateEventSem(NULL, &TimerSem, DC_SEM_SHARED, 0);

    if(rc != 0)
        _endthread();

#ifdef DEBUG
    WriteLog("Semaphore created\n");
#endif
    TimerStatus = Stopped;

    while(!fFatal) {
        DosWaitEventSem(TimerSem, SEM_INDEFINITE_WAIT);
        DosResetEventSem(TimerSem, &Count);
        if(!fFatal) {
#ifdef DEBUG
////        WriteLog("T");
#endif
        // @@@PH: we're calling the client with PRTYC_TIMECRITICAL !!!
        //        It'd be much nicer to call with original priority!
        // @@@PH: plus the original thread is supposed to stop while the
        //        time event is scheduled (DosSuspendThread()) ? It's
        //        much like raising a signal (SIGALARM)
        clientCallback((UINT)this, 0, userData, 0, 0);
    }
    }
    DosCloseEventSem(TimerSem);
}
//******************************************************************************
//******************************************************************************
static void _Optlink TimerHlpHandler(void *timer)
{
  ((OS2Timer *)timer)->TimerHandler();

  _endthread();
}
//******************************************************************************
//******************************************************************************
OS2Timer *OS2Timer::timers      = NULL;
int       OS2Timer::timerPeriod = 0;