bci2000.org BBS

Code: Select all

One more thing, in data acquisition module tutorial, example scenario is that my A/D card comes with C-style software interface declared in its header file with several functions that configure the card, start acquisition, store data, stream data and so on. But what should I do if my A/D card doesn’t come with it?

Code: Select all

// MyADC.h:
#include "BufferedADC.h"
#include "SerialStream.h"
class MyADC : public BufferedADC
{
...
 private:
  bool ConnectToAD( SerialStream& ) const;

  SerialStream mPort;
...
};

// MyADC.cpp
...
#include <windows.h>
...

void
MyADC::OnPreflight( ... ) const
{
  ...
  SerialStream port;
  if( !ConnectToAD( port ) )
    bcierr << "Cannot connect to AD on port " << Parameter( "COMport" ) << endl;
  ...
}

void
MyADC::OnInitialize( ... )
{
  ...
  ConnectToAD( mPort );
  ...
}

void
MyADC::OnStartAcquisition()
{
  mPort << "SENDDATA\n" << flush;
}

void
MyADC::OnAcquireData( GenericSignal& Output )
{
#if DATA_SENT_AS_SPACE_SEPARATED_ASCII_NUMBERS
  double value;
  for( int ch = 0; ch < Output.Channels(); ++ch )
    for( int sample = 0; sample < Output.Elements(); ++sample )
    {
      mPort >> ws >> value;
      Output( ch, sample ) = value;
    }
#elseif DATA_SENT_AS_BINARY_FLOATS_IN_LITTLE_ENDIAN_FORMAT
  float32_t value;
  union { float32_t* f; uint32_t* i; } valuePtr = { &value };
  for( int ch = 0; ch < Output.Channels(); ++ch )
    for( int sample = 0; sample < Output.Elements(); ++sample )
    {
      mPort.read( valuePtr.i, sizeof( *valuePtr.i ) );
      Output( ch, sample ) = *valuePtr.f;
    }
#endif
}

bool
MyADC::ConnectToAD( SerialStream& outStream ) const
{
  outStream.clear();
  outStream.close();
  string comport = Parameter( "COMport" );
  COMMCONFIG config = { sizeof( COMMCONFIG ), 1 };
  config.dwProviderSubtype = PST_RS232;
  ::BuildCommDCB( "baud=1200 parity=N data=8 stop=1", &config.dcb );
  bool success = ::SetDefaultCommConfig( comport.c_str(), &config, sizeof( config ) );
  if( success )
  {
    outStream.open( comport.c_str() );
    success = outStream.is_open();
  }
  if( success )
  { 
    outStream << "GETVERSION\n" << flush;
    string response;
    success = getline( outStream, response, '\n' );
  }
  if( success )
    bcidbg << "Connected to AD, version is " << response << endl;
  return success;
}

Code: Select all

...
  enum { Start = 0x01, Stop = 0x02, GetVersion = 0x03, ... };
...
  mPort.put( GetVersion ).flush();
  uint8_t version = mPort.get();
...
  mPort.put( Start ).flush();
...
  mPort.put( Stop ).flush();
...

Code: Select all

#include "PCHIncludes.h"
#pragma hdrstop

#include<iostream>
#include "PolyBuffADC.h"
#include "BCIError.h"

#include "SerialStream.h"
#include "ThreadUtils.h" // for SleepFor()

using namespace std;


RegisterFilter( PolyBuffADC, 1 );

PolyBuffADC::PolyBuffADC():
mSourceCh(0),
     mSampleBlockSize(0),
     mSamplingRate(0)
{

 BEGIN_PARAMETER_DEFINITIONS

    "Source:Signal%20Properties int SourceCh= 1 "
       "// number of digitized and stored channels",

    "Source:Signal%20Properties int SampleBlockSize= 32 "
       "// number of samples transmitted at a time",

    "Source:Signal%20Properties float SamplingRate= 512Hz "
       "// sample rate",
		
	 "Source string COMport= COM3"
      "// COMport for PolyAmp",
	
 END_PARAMETER_DEFINITIONS


 BEGIN_STATE_DEFINITIONS

 "Running 1 0 0 0"
   
 END_STATE_DEFINITIONS

}

PolyBuffADC::~PolyBuffADC()
{
	OnHalt();
}

void
PolyBuffADC::OnHalt()
{

}

void
PolyBuffADC::OnPreflight( SignalProperties& Output ) const
{
  // The user has pressed "Set Config" and we need to sanity-check everything.
  // For example, check that all necessary parameters and states are accessible:

	/*Local Variables: */
  int sourceCh = Parameter( "SourceCh" ),
  sampleBlockSize = Parameter( "SampleBlockSize" ),
  samplingRate = static_cast<int>( Parameter( "SamplingRate" ).InHertz() );	//not sure bout this one
	
	// Check that the user is asking for one channel
	//after, we are going to change it to 8 channels.
  if( sourceCh != 1 )
	bcierr << "PolyBuff only has one electrode for now.  Set SourceCh=1." << endl;
  if( samplingRate != 512 )
     bcierr << "PolyBuff has a sampling rate of 512Hz.  Set SamplingRate to 512." << endl;
  if( Parameter( "SampleBlockSize" ) >64 )
    bcierr << "Sample Block Size shouldnt be bigger than 64" << endl;


	string COMportParam = Parameter( "COMport" );
  if( COMportParam.empty() )
  {
    bcierr << "No COM port specified for device" << endl;
    return;
  }

	serialstream port;
	if( !ConnectToAD( port ) )
		bcierr << "Cannot connect to AD on port " << Parameter( "COMport" ) << endl;


  int numberOfChannels = Parameter( "SourceCh" );					//same as sourceCh from above
  int samplesPerBlock  = Parameter( "SampleBlockSize" );	//same as sampleBlockSize from above
  SignalType sigType = SignalType::float32;  // could also parameterize this
  Output = SignalProperties( numberOfChannels, samplesPerBlock, sigType );

}

bool PolyBuffADC::ConnectToAD(serialstream& outStream) const{
  outStream.clear();
  outStream.close();
  string comport = Parameter( "COMport" );
  COMMCONFIG config = { sizeof( COMMCONFIG ), 1 };
  config.dwProviderSubType = PST_RS232;
  ::BuildCommDCB( "baud=1200 parity=N data=8 stop=1", &config.dcb );
  bool success = ::SetDefaultCommConfig( comport.c_str(), &config, sizeof( config ) );
  if( success )
  {
		bcierr << "if 1" << endl;   //added if for debuging

    outStream.open( comport.c_str() );
    success = outStream.is_open();
  }
	string response;
  if( success )
  {
		bcierr << "if 2" << endl;   //added if for debuging
		outStream << "GETVERSION\n" << flush;
    success = getline( outStream, response, '\n' );
  }
  if( success )
		bcierr << "if 3" << endl;   //added if for debuging, never enters here
		bcidbg << "Connected to AD, version is " << response << endl;
  return success;
}

void
PolyBuffADC::OnInitialize( const SignalProperties& Output )
{
  mSourceCh = Parameter( "SourceCh" );
  mSampleBlockSize = Parameter( "SampleBlockSize" );
  mSamplingRate = Parameter( "SamplingRate" );

  serialstream mPort;
  ConnectToAD( mPort );
  mLastTime = PrecisionTime::Now();
}

void 
PolyBuffADC::OnStartAcquisition()
{
  mPort << "SENDDATA\n" << flush;
}

void
PolyBuffADC::DoAcquire( GenericSignal& Output )
{
	double value;
  for( int ch = 0; ch < Output.Channels(); ++ch )
    for( int sample = 0; sample < Output.Elements(); ++sample )
    {
      mPort >> ws >> value;
      Output( ch, sample ) = value;
    }



  /*given by default: */
  // For now, we output flat lines:
  for( int ch = 0; ch < Output.Channels(); ch++ )
    for( int el = 0; el < Output.Elements(); el++ )
      Output( ch, el ) = 0.0f;

  // Here is a wait loop to ensure that we do not deliver the signal faster than real-time
  // (In your final implementation, you should remove this: the hardware will play this role then.)
  while( PrecisionTime::UnsignedDiff( PrecisionTime::Now(), mLastTime ) < mMsecPerBlock ) ThreadUtils::SleepFor(1);
  mLastTime = PrecisionTime::Now();
}

void
PolyBuffADC::StartRun()
{
  // The user has just pressed "Start" (or "Resume")
  bciout << "Hello World!" << endl;

  mLastTime = PrecisionTime::Now();
}

void
PolyBuffADC::StopRun()
{
  // The Running state has been set to 0, either because the user has pressed "Suspend",
  // because the run has reached its natural end.
  bciout << "Goodbye World." << endl;
}

void
PolyBuffADC::OnStopAcquisition()
{
  // This method will always be called before OnHalt is called.
}