FryingPan/framework/Generic/Timer.cpp

   1 /*
   2  * Amiga Generic Set - set of libraries and includes to ease sw development for all Amiga platforms
   3  * Copyright (C) 2001-2011 Tomasz Wiszkowski Tomasz.Wiszkowski at gmail.com.
   4  *
   5  * This library is free software; you can redistribute it and/or
   6  * modify it under the terms of the GNU Lesser General Public
   7  * License as published by the Free Software Foundation; either
   8  * version 2.1 of the License, or (at your option) any later version.
   9  *
  10  * This library is distributed in the hope that it will be useful,
  11  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * Lesser General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU Lesser General Public
  16  * License along with this library; if not, write to the Free Software
  17  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301  USA
  18  */
  19
  20 #include "Timer.h"
  21 #include <libclass/exec.h>
  22 #include <devices/timer.h>
  23 #include <exec/ports.h>
  24 #include "LibrarySpool.h"
  25
  26 using namespace GenNS;
  27
  28 Timer::Timer()
  29 {
  30    issued = 0;
  31    port = Exec->CreateMsgPort();
  32    treq = (timerequest*)Exec->CreateIORequest(port, sizeof(timerequest));
  33    Exec->OpenDevice("timer.device", UNIT_VBLANK, (IORequest*)treq, 0);
  34 }
  35
  36 Timer::~Timer()
  37 {
  38    AbortRequest();
  39    WaitRequest();
  40    Exec->CloseDevice((IORequest*)treq);
  41    Exec->DeleteIORequest((IORequest*)treq);
  42    Exec->DeleteMsgPort(port);
  43 }
  44
  45 void Timer::WaitRequest()
  46 {
  47
  48    if (issued != 0)
  49    {
  50       Exec->WaitPort(port);
  51       treq = (timerequest*)Exec->GetMsg(port);
  52       issued = 0;
  53    }
  54 }
  55
  56 void Timer::AbortRequest()
  57 {
  58    if (issued != 0)
  59    {
  60       Exec->AbortIO((IORequest*)treq);
  61       WaitRequest();
  62    }
  63 }
  64
  65 void Timer::AddRequest(unsigned long duration)  // milliseconds ?
  66 {
  67    /*
  68     * don't initiate another request unless this one is finished.
  69     */
  70    if (issued != 0)
  71    {
  72       struct timerequest *tr = (struct timerequest*)Exec->GetMsg(port);
  73       if (tr == 0)
  74          return;
  75
  76       treq = tr;
  77       issued = 0;
  78    }
  79    treq->tr_node.io_Command = TR_ADDREQUEST;
  80    treq->tr_time.tv_secs  = (duration/1000);
  81    treq->tr_time.tv_micro = (duration % 1000) * 1000;
  82    Exec->SendIO((IORequest*)treq);
  83    issued = 1;
  84 }
  85
  86 unsigned long Timer::GetSignals(void)
  87 {
  88    return 1<<port->mp_SigBit;
  89 }