device.cpp

#include "device.h"

#include <iostream>
#include <cstring>

using namespace Chaos;

void Device::init(const char* filename, int bytesPerFrame) {
	file = fopen( filename, "r" );

	if( file == NULL ) {
		std::cerr << "Couldn't open " << filename << std::endl;
	}
	
	this->bytesPerFrame = bytesPerFrame;
	this->buffer = new char[bytesPerFrame];
}

Device::~Device() {
	stop();
	WaitForInternalThreadToExit();
	fclose( file );
	
	if( buffer != NULL) {
		delete [] buffer;
	}
}

void Device::addObserver(DeviceObserver* observer) {
	this->observer = observer;
}

void Device::doAction() {
//	printf("Read: " );
	for (int i = 0; i < bytesPerFrame; i++) {
		buffer[i] = fgetc( file );
//		printf("%d ", (int)buffer[i]);
	}
//	printf("\n");
	
	DeviceEvent event;
	
	interpret( buffer, &event );
	
	if (observer != NULL &&
		event.time != -1) {
		observer->newDeviceEvent( &event );
	}
}