Search  

---

C:/temp/src/j2k/nto/TimerPulse.cpp

Go to the documentation of this file.

#ifndef __J2K__TimerPulse_CPP__
#define __J2K__TimerPulse_CPP__

#include <j2k/nto/TimerPulse.hpp>
#include <j2k/nto/fixprio.hpp>

// Setup a timer, to be started later.
TimerPulse::TimerPulse( ULONG nsec, ULONG sec )  
 : pulse_id( TimerSignalEvent ), chid( ~0 )
{
  memset( &event, 0, sizeof( event ) );

  // Set priority to max, so we don't get disrupted 
  // by anything else then interrupts

  printf( "Creating channel for TimerPulse \n" );

  // Create a channel to receive the timer event
  chid = ChannelCreate( 0 );
  assert( chid != -1 );

  // Setup timer and timer event
  event.sigev_notify     = SIGEV_PULSE;
  event.sigev_coid       = ConnectAttach( ND_LOCAL_NODE, 0, chid, 0, 0 );
  event.sigev_priority   = getprio( 0 ); // fixprio( 20 );
  event.sigev_code       = 1023;
  event.sigev_value.sival_ptr = (void*)pulse_id;

  assert( event.sigev_coid != -1 );

  // Create the timer, binding it to the event

  if ( timer_create( CLOCK_REALTIME, &event, &timer_id ) == -1 )
  {
    MC_OnError( errno, Error, "while creating a timer." )
    perror( "Can't create timer.\n" );
    exit( 1 );
  }
  
  memset( &t, 0, sizeof( t ) );

  set( nsec, sec );

}

void TimerPulse::set( ULONG nsec, ULONG sec )
{
  // Change timer request to alter behavior
  t.it_value.tv_sec         = sec;
  t.it_value.tv_nsec        = nsec;
  t.it_interval.tv_sec      = sec;
  t.it_interval.tv_nsec     = nsec;

  // Start the timer
  if ( timer_settime( timer_id, 0, &t, NULL ) == -1 )
  {
    MC_OnError( errno, Error, "Can't start timer." )
    perror( "Can't start timer\n" );
    exit( 1 );
  }
}

void TimerPulse::run() 
{
  // Start the timer
  if ( timer_settime( timer_id, 0, &t, NULL ) == -1 )
  {
    MC_OnError( errno, Error, "Can't start timer." )
    perror( "Can't start timer\n" );
    exit( 1 );
  }

  for(;;) 
  {
    // Wait for pulse
    if ( MsgReceivePulse( chid, &pulse, sizeof( pulse ), NULL ) ) 
    {
     MC_OnError( errno, Error, "Invalid pulse received by TimerPulse.\n" )
    }
    tick( pulse_id );
  }
} 

#endif

---