usb-firewall-fork/Upstream/Src/upstream_msc.c

/*
 * upstream_msc.c
 *
 *  Created on: 4/07/2015
 *      Author: Robert Fisk
 */


#include "upstream_interface_def.h"
#include "upstream_msc.h"
#include "upstream_spi.h"
#include "upstream_statemachine.h"
#include "stm32f4xx_hal.h"


//Stuff we need to save for our callbacks to use:
UpstreamMSCCallbackTypeDef 				TestReadyCallback;
UpstreamMSCCallbackUintPacketTypeDef	GetCapacityCallback;
UpstreamMSCCallbackPacketTypeDef		GetStreamDataCallback;
uint32_t								ByteCount;
UpstreamPacketTypeDef*					ReadStreamPacket;
uint8_t									ReadStreamBusy;


static void Upstream_MSC_TestReadyReplyCallback(UpstreamPacketTypeDef* replyPacket);
static void Upstream_MSC_GetCapacityReplyCallback(UpstreamPacketTypeDef* replyPacket);
static void Upstream_MSC_GetStreamDataPacketCallback(UpstreamPacketTypeDef* replyPacket);
static void Upstream_MSC_BeginWriteReplyCallback(UpstreamPacketTypeDef* replyPacket);



HAL_StatusTypeDef Upstream_MSC_TestReady(UpstreamMSCCallbackTypeDef callback)
{
	UpstreamPacketTypeDef* freePacket;

	if (Upstream_StateMachine_CheckClassOperationOk() != HAL_OK)
	{
		return HAL_ERROR;
	}
	
	TestReadyCallback = callback;
	freePacket = Upstream_GetFreePacketImmediately();
	if (freePacket == NULL)
	{
		return HAL_ERROR;
	}

	freePacket->Length16 = UPSTREAM_PACKET_HEADER_LEN_16;
	freePacket->CommandClass = COMMAND_CLASS_MASS_STORAGE;
	freePacket->Command = COMMAND_MSC_TEST_UNIT_READY;
	if (Upstream_TransmitPacket(freePacket) == HAL_OK)
	{
		return Upstream_ReceivePacket(Upstream_MSC_TestReadyReplyCallback);
	}
	//else:
	return HAL_ERROR;
}


void Upstream_MSC_TestReadyReplyCallback(UpstreamPacketTypeDef* replyPacket)
{
	if (Upstream_StateMachine_CheckClassOperationOk() != HAL_OK)
	{
		return;
	}

	if (replyPacket == NULL)
	{
		TestReadyCallback(HAL_ERROR);
		return;
	}

	if ((replyPacket->Length16 != (UPSTREAM_PACKET_HEADER_LEN_16 + 1)) ||
		(replyPacket->Data[0] != HAL_OK))
	{
		Upstream_ReleasePacket(replyPacket);
		TestReadyCallback(HAL_ERROR);
		return;
	}

	Upstream_ReleasePacket(replyPacket);
	TestReadyCallback(HAL_OK);
}



HAL_StatusTypeDef Upstream_MSC_GetCapacity(UpstreamMSCCallbackUintPacketTypeDef callback)
{
	UpstreamPacketTypeDef* freePacket;

	if (Upstream_StateMachine_CheckClassOperationOk() != HAL_OK)
	{
		return HAL_ERROR;
	}

	GetCapacityCallback = callback;
	freePacket = Upstream_GetFreePacketImmediately();
	if (freePacket == NULL)
	{
		return HAL_ERROR;
	}

	freePacket->Length16 = UPSTREAM_PACKET_HEADER_LEN_16;
	freePacket->CommandClass = COMMAND_CLASS_MASS_STORAGE;
	freePacket->Command = COMMAND_MSC_GET_CAPACITY;
	if (Upstream_TransmitPacket(freePacket) == HAL_OK)
	{
		return Upstream_ReceivePacket(Upstream_MSC_GetCapacityReplyCallback);
	}
	//else:
	return HAL_ERROR;
}


void Upstream_MSC_GetCapacityReplyCallback(UpstreamPacketTypeDef* replyPacket)
{
	uint32_t uint1;
	uint32_t uint2;

	if (Upstream_StateMachine_CheckClassOperationOk() != HAL_OK)
	{
		return;
	}

	if (replyPacket == NULL)
	{
		GetCapacityCallback(NULL, 0, 0);
		return;
	}

	if (replyPacket->Length16 != (UPSTREAM_PACKET_HEADER_LEN_16 + (8 / 2)))
	{
		GetCapacityCallback(NULL, 0, 0);
		return;
	}

	uint1 = *(uint32_t*)&(replyPacket->Data[0]);
	uint2 = *(uint32_t*)&(replyPacket->Data[4]);
	GetCapacityCallback(replyPacket, uint1, uint2);		//usb_msc_scsi will use this packet, so don't release now
}



HAL_StatusTypeDef Upstream_MSC_BeginRead(UpstreamMSCCallbackTypeDef callback,
										 uint64_t readBlockStart,
										 uint32_t readBlockCount,
										 uint32_t readByteCount)
{
	UpstreamPacketTypeDef* freePacket;

	if (Upstream_StateMachine_CheckClassOperationOk() != HAL_OK)
	{
		return HAL_ERROR;
	}

	ReadStreamPacket = NULL;			//Prepare for GetStreamDataPacket's use
	ReadStreamBusy = 0;
	ByteCount = readByteCount;

	TestReadyCallback = callback;
	freePacket = Upstream_GetFreePacketImmediately();
	if (freePacket == NULL)
	{
		return HAL_ERROR;
	}

	freePacket->Length16 = UPSTREAM_PACKET_HEADER_LEN_16 + ((4 * 3) / 2);
	freePacket->CommandClass = COMMAND_CLASS_MASS_STORAGE;
	freePacket->Command = COMMAND_MSC_BEGIN_READ;
	*(uint64_t*)&(freePacket->Data[0]) = readBlockStart;
	*(uint32_t*)&(freePacket->Data[8]) = readBlockCount;

	if (Upstream_TransmitPacket(freePacket) == HAL_OK)
	{
		return Upstream_ReceivePacket(Upstream_MSC_TestReadyReplyCallback);	//Re-use TestReadyReplyCallback because it does exactly what we want!
	}
	//else:
	return HAL_ERROR;
}



HAL_StatusTypeDef Upstream_MSC_GetStreamDataPacket(UpstreamMSCCallbackPacketTypeDef callback)
{
	if (Upstream_StateMachine_CheckClassOperationOk() != HAL_OK)
	{
		return HAL_ERROR;
	}
	GetStreamDataCallback = callback;

	if (ReadStreamBusy != 0)
	{
		return HAL_OK;
	}
	ReadStreamBusy = 1;

	if (ReadStreamPacket && GetStreamDataCallback)		//Do we have a stored packet and an address to send it?
	{
		Upstream_MSC_GetStreamDataPacketCallback(ReadStreamPacket);	//Send it now!
		ReadStreamPacket = NULL;
		return HAL_OK;				//Our callback will call us again, so we don't need to get a packet in this case.
	}
	return Upstream_ReceivePacket(Upstream_MSC_GetStreamDataPacketCallback);
}


void Upstream_MSC_GetStreamDataPacketCallback(UpstreamPacketTypeDef* replyPacket)
{
	uint16_t dataLength8;

	ReadStreamBusy = 0;

	if (Upstream_StateMachine_CheckClassOperationOk() != HAL_OK)
	{
		return;
	}

	if (GetStreamDataCallback == NULL)
	{
		ReadStreamPacket = replyPacket;		//We used up our callback already, so save this one for later.
		return;
	}

	if (replyPacket == NULL)
	{
		GetStreamDataCallback(NULL, 0);
		return;
	}

	dataLength8 = (replyPacket->Length16 - UPSTREAM_PACKET_HEADER_LEN_16) * 2;

	if (((replyPacket->CommandClass & COMMAND_CLASS_DATA_FLAG) == 0) ||		//Any 'command' reply (as opposed to 'data' reply) is an automatic fail here
		 (replyPacket->Length16 <= UPSTREAM_PACKET_HEADER_LEN_16) ||			//Should be at least one data byte in the reply.
		 (dataLength8 > ByteCount))											//No more data than expected transfer length
	{
		GetStreamDataCallback(NULL, 0);
		return;
	}

	ByteCount -= dataLength8;
	GetStreamDataCallback(replyPacket, dataLength8);	//usb_msc_scsi will use this packet, so don't release now
	if (ByteCount > 0)
	{
		Upstream_MSC_GetStreamDataPacket(NULL);			//Try to get the next packet now, before USB asks for it
	}
}



HAL_StatusTypeDef Upstream_MSC_BeginWrite(UpstreamMSCCallbackTypeDef callback,
										  uint64_t readBlockStart,
										  uint32_t readBlockCount)
{
	UpstreamPacketTypeDef* freePacket;

	if (Upstream_StateMachine_CheckClassOperationOk() != HAL_OK)
	{
		return HAL_ERROR;
	}

	TestReadyCallback = callback;
	freePacket = Upstream_GetFreePacketImmediately();
	if (freePacket == NULL)
	{
		return HAL_ERROR;
	}

	freePacket->Length16 = UPSTREAM_PACKET_HEADER_LEN_16 + ((4 * 3) / 2);
	freePacket->CommandClass = COMMAND_CLASS_MASS_STORAGE;
	freePacket->Command = COMMAND_MSC_BEGIN_WRITE;
	*(uint64_t*)&(freePacket->Data[0]) = readBlockStart;
	*(uint32_t*)&(freePacket->Data[8]) = readBlockCount;

	if (Upstream_TransmitPacket(freePacket) == HAL_OK)
	{
		return Upstream_ReceivePacket(Upstream_MSC_BeginWriteReplyCallback);
	}
	//else:
	return HAL_ERROR;
}


void Upstream_MSC_BeginWriteReplyCallback(UpstreamPacketTypeDef* replyPacket)
{
	uint8_t tempResult;

	if (Upstream_StateMachine_CheckClassOperationOk() != HAL_OK)
	{
		return;
	}

	if (replyPacket == NULL)
	{
		TestReadyCallback(HAL_ERROR);
		return;
	}

	if ((replyPacket->Length16 != (UPSTREAM_PACKET_HEADER_LEN_16 + 1)) ||
		((replyPacket->Data[0] != HAL_OK) && (replyPacket->Data[0] != HAL_BUSY)))
	{
		Upstream_ReleasePacket(replyPacket);
		TestReadyCallback(HAL_ERROR);
		return;
	}

	tempResult = replyPacket->Data[0];
	Upstream_ReleasePacket(replyPacket);
	TestReadyCallback(tempResult);
}



HAL_StatusTypeDef Upstream_MSC_PutStreamDataPacket(UpstreamPacketTypeDef* packetToSend,
												   uint32_t dataLength8)
{
	if (Upstream_StateMachine_CheckClassOperationOk() != HAL_OK)
	{
		return HAL_ERROR;
	}

	if ((dataLength8 % 2) != 0)
	{
		return HAL_ERROR;
	}

	packetToSend->Length16 = (dataLength8 / 2) + UPSTREAM_PACKET_HEADER_LEN_16;
	packetToSend->CommandClass = COMMAND_CLASS_MASS_STORAGE | COMMAND_CLASS_DATA_FLAG;
	packetToSend->Command = COMMAND_MSC_BEGIN_WRITE;
	return Upstream_TransmitPacket(packetToSend);
}