Search  

---

C:/temp/src/j2k/QNX4/Test/Writer.cpp

Go to the documentation of this file.

#ifndef __J2K__QNX__Writer_CPP__
#define __J2K__QNX__Writer_CPP__

#include <j2k/Fred/QNX/Writer.hpp>
#include <j2k/Fred/QNX/Extern.hpp>

Writer::Writer() 
{
  // Initialize and setup the Serial Port
  kb_fd  = open( LOCAL_KEYBOARD, O_RDWR );  // Local Keyboard
  mdm_fd = open( ELAN104_SERIAL, O_RDWR );  // QNX-2 Elan104 Board

  kb_proxy  = qnx_proxy_attach( 0, 0, 0, -1 );
  mdm_proxy = qnx_proxy_attach( 0, 0, 0, -1 );

  dev_mode( kb_fd,  0, _DEV_MODES );
  dev_mode( mdm_fd, 0, _DEV_MODES );

  // Clear, then arm the proxies for future events

  dev_state( kb_fd,  0,        _DEV_EVENT_INPUT );
  dev_arm(   kb_fd,  kb_proxy,  _DEV_EVENT_INPUT );
      
  dev_state( mdm_fd, 0,        _DEV_EVENT_INPUT );
  dev_arm(   mdm_fd, mdm_proxy, _DEV_EVENT_INPUT );
}

void Writer::Run() 
{
  int temp = 0;
  for(;;) { 
    // Wait for either keyboard or modem to send an input.
    printf("Writer Receive(...)\n\r");
    rpid = Receive( 0, 0, 0 );
    printf("Writer Received it! [%d]\n\r", rpid );

    // Waiting for an event, then check the Process ID,
    // Read the message and send it back to the other machine.
    printf( "Writer2!\n\r" );

    if ( rpid == kb_proxy ) {
      printf("Keyboard\n\r");
      state = dev_state( kb_fd, 0, _DEV_EVENT_INPUT );

      // If there is an Input from Keyboard Console
      // then Read it and Send it Back to the Modem
   
      if ( state & _DEV_EVENT_INPUT ) {
        n = read( kb_fd, &buf, sizeof( buf ) );

        b1->Write( (int)( buf[0] ) );
        dev_arm( kb_fd, kb_proxy, _DEV_EVENT_INPUT );
      } 

    } else if ( rpid == r1->Pid() ) {

      printf("Writer Reply back\n\r");
      msg.type = MSG_NONE;
      Reply( pid, &msg, sizeof( msg ) );
    }

    printf("End of Writer [%d]\n\r", rpid );

  }

  printf("Writer Thread finished!\n\r");
}

void Writer::Track( int TrackID, int dir )
{
  int value = 0;

  if ( TrackID < 1  ||  TrackID > 4 ) { return; }

  TrackID--;
  value = ( TrackID << 1 );
  if ( dir ) { value++; }

  value = ( 1 << value );
  b1->Write( 0, value );
}

#endif

---