home *** CD-ROM | disk | FTP | other *** search
/ Fresh Fish 7 / FreshFishVol7.bin / bbs / gnu / aplusplus-1.01-src.lha / GNU / src / amiga / APlusPlus-1.01 / libsource / TimerC.cxx < prev    next >
C/C++ Source or Header  |  1994-04-23  |  3KB  |  133 lines
  1. /******************************************************************************
  2.  **
  3.  **    C++ Class Library for the Amiga© system software.
  4.  **
  5.  **    Copyright (C) 1994 by Armin Vogt  **  EMail: armin@uni-paderborn.de
  6.  **    All Rights Reserved.
  7.  **
  8.  **    $Source: apphome:APlusPlus/RCS/libsource/TimerC.cxx,v $
  9.  **    $Revision: 1.3 $
  10.  **    $Date: 1994/04/23 21:02:52 $
  11.  **    $Author: Armin_Vogt $
  12.  **
  13.  ******************************************************************************/
  14.  
  15.  
  16. extern "C" {
  17. #ifdef __GNUG__
  18. #include <inline/timer.h>
  19. #endif
  20.  
  21. #ifdef __SASC
  22. #include <proto/timer.h>
  23. #endif
  24. }
  25.  
  26. #include <APlusPlus/devices/TimerC.h>
  27. #include <string.h>
  28.  
  29.  
  30. volatile static char rcs_id[] = "$Id: TimerC.cxx,v 1.3 1994/04/23 21:02:52 Armin_Vogt Exp Armin_Vogt $";
  31.  
  32.  
  33. TimerC::TimerC(UWORD unit,struct MsgPort *replyPort)
  34. {
  35.    set(0,0);
  36.    create(unit,replyPort);
  37. }
  38.  
  39. TimerC::~TimerC()
  40. { 
  41.     dispose(); 
  42. }
  43.  
  44. BOOL TimerC::create(UWORD unit,struct MsgPort *replyPort)
  45.    /* create a timer object to a msgport.
  46.    */
  47. {
  48.    memset((APTR)&timerIO,0,sizeof(timerequest));
  49.    timerIO.tr_node.io_Message.mn_ReplyPort = replyPort;
  50.  
  51.       if ( !(OpenDevice((UBYTE*)TIMERNAME,(ULONG)unit,(struct IORequest*)&timerIO,(ULONG)0L)) )
  52.       {
  53.          timerIO.tr_node.io_Command = TR_ADDREQUEST;
  54.          timerIO.tr_time = time;   // copy time values to Timer IORequest.
  55.          sent = FALSE;
  56.          setID(TIMER_CLASS);
  57.  
  58.          return TRUE;
  59.       }
  60.       else _ierror(TIMER_OPENDEVICE_FAILED);
  61.  
  62.    return FALSE;
  63. }
  64.  
  65. void TimerC::dispose()
  66.    /* Dispose of the timerequest, no matter if it is sent or in the replyport's message queue.
  67.    */
  68. {
  69.    if (Ok())
  70.    {
  71.       abort();  // make sure the Timer is no longer in use.
  72.       CloseDevice((struct IORequest*)&timerIO);
  73.       setID(APPOBJECT_INVALID);
  74.    }
  75. }
  76.  
  77. BOOL TimerC::start(ULONG secs,ULONG micros)
  78. {
  79.    if (Ok())
  80.       if (sent==FALSE)
  81.       {
  82.          if (secs || micros)  set(secs,micros);
  83.  
  84.          timerIO.tr_time = time;    // copy time values to Timer IORequest.
  85.          SendIO((struct IORequest*)&timerIO);
  86.             sent = TRUE;
  87.          return TRUE;
  88.       }
  89.  
  90.    return FALSE;
  91. }
  92.  
  93. void TimerC::abort()
  94.    /* Abort a started Timer. If the Timer has not been started yet, nothing will happen.
  95.       After execution the Timer is ready to be started again.
  96.    */
  97. {
  98.    if (Ok())
  99.       if (sent==TRUE)
  100.       {
  101.          AbortIO((struct IORequest*)&timerIO);  // tell timer device to send back request if not done.
  102.          WaitIO((struct IORequest*)&timerIO);   // wait for arrival, then remove from message queue.
  103.          sent = FALSE;
  104.       }
  105. }
  106.  
  107. BOOL TimerC::reuse()
  108.    /* Make a Timer that has returned from the Timer.device useable for subsequent start().
  109.         Usually call reuse() after having received and identified a timer reply message.
  110.       An already sent Timer that has not been replied yet will fail being reused and return FALSE.
  111.       To reuse an already sent Timer without waiting for it any longer use abort().
  112.    */
  113. {
  114.    if (Ok())
  115.       if (sent == FALSE)   // timer is not in use.
  116.          return TRUE;
  117.       else
  118.          if (CheckIO((struct IORequest*)&timerIO))  // request already replied ?
  119.          {
  120.                 // the replied request is assumed be removed from the port queue via getMsg().
  121.             sent = FALSE;
  122.             return TRUE;
  123.          }
  124.  
  125.    return FALSE;
  126. }
  127.  
  128. void TimerC::changeReplyPort(UWORD unit,struct MsgPort *newReplyPort)
  129. {
  130.    dispose();
  131.    create(unit,newReplyPort);
  132. }
  133.