/*
	PIP - Platform Independent Primitives
	PIIODevice that pass write to read
	Ivan Pelipenko peri4ko@yandex.ru

	This program is free software: you can redistribute it and/or modify
	it under the terms of the GNU Lesser General Public License as published by
	the Free Software Foundation, either version 3 of the License, or
	(at your option) any later version.

	This program is distributed in the hope that it will be useful,
	but WITHOUT ANY WARRANTY; without even the implied warranty of
	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
	GNU Lesser General Public License for more details.

	You should have received a copy of the GNU Lesser General Public License
	along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/

#include "pitransparentdevice.h"


/*! \class PITransparentDevice
 * \brief PIIODevice that pass write to read
 * 
 * \section  PITransparentDevice_sec0 Synopsis
 * This class pass all data from \a write() function to \a read().
 * %PITransparentDevice contains internal queue and works in
 * packets mode. If you write 3 different  packets into this device,
 * read will return this 3 packets.
 */

REGISTER_DEVICE(PITransparentDevice)


PITransparentDevice::PITransparentDevice() {
}


int PITransparentDevice::readDevice(void * read_to, int max_size) {
	if (!canRead()) return -1;
	que_mutex.lock();
	if (que.isEmpty()) {
		que_mutex.unlock();
		return 0;
	}
	PIByteArray ba = que.dequeue();
	que_mutex.unlock();
	int ret = piMini(max_size, ba.size_s());
	memcpy(read_to, ba.data(), ret);
	return ret;
}


int PITransparentDevice::writeDevice(const void * data, int max_size) {
	if (!canWrite()) return -1;
	que_mutex.lock();
	que.enqueue(PIByteArray(data, max_size));
	que_mutex.unlock();
	return max_size;
}


bool PITransparentDevice::openDevice() {
	return true;
}


bool PITransparentDevice::closeDevice() {
	que_mutex.lock();
	que.clear();
	que_mutex.unlock();
	return true;
}