Emulation/StrikeBox
1
0
Fork 0
mirror of https://github.com/StrikerX3/StrikeBox.git synced 2024-06-23 14:53:22 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix large packet data transfers

Browse source
This commit is contained in:
StrikerX3 2018-12-10 13:53:42 -02:00
parent b68e17b1e9
commit b465a540dd
1 changed files with 44 additions and 34 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

78
src/core/vixen/hw/ata/cmds/proto_packet.cpp
View file

@ -103,27 +103,32 @@ void PacketProtocolCommand::Execute() {
void PacketProtocolCommand::ReadData(uint8_t *value, uint32_t size) {
// Host is reading the data requested by the Packet command
uint32_t pos = 0;
// Read from buffer
uint32_t sizeRead = m_packetCmdState.dataBuffer.Read(value, size);
do {
// Read from buffer
uint32_t sizeRead = m_packetCmdState.dataBuffer.Read(value + pos, size - pos);
pos += sizeRead;
// Done reading the packet data?
if (m_packetCmdState.dataBuffer.IsReadFinished()) {
m_regs.status |= StBusy;
m_regs.status &= ~StDataRequest;
// Done reading the packet data?
if (m_packetCmdState.dataBuffer.IsReadFinished()) {
m_regs.status |= StBusy;
m_regs.status &= ~StDataRequest;
// Done transferring all the data needed by the packet?
if (m_command->IsTransferFinished()) {
HandleProtocolTail(false);
return;
// Done transferring all the data needed by the packet?
if (m_command->IsTransferFinished()) {
HandleProtocolTail(false);
return;
}
// Read more data
if (!m_command->Execute()) {
HandleProtocolTail(true);
return;
}
}
// Read more data
if (!m_command->Execute()) {
HandleProtocolTail(true);
return;
}
}
} while (pos < size);
}
void PacketProtocolCommand::WriteData(uint8_t *value, uint32_t size) {
@ -141,26 +146,31 @@ void PacketProtocolCommand::WriteData(uint8_t *value, uint32_t size) {
else {
// Writing the data requested by the Packet command
// Write to buffer
uint32_t sizeWritten = m_packetCmdState.dataBuffer.Write(value, size);
uint32_t pos = 0;
// Done writing the packet data?
if (m_packetCmdState.dataBuffer.IsWriteFinished()) {
m_regs.status |= StBusy;
m_regs.status &= ~StDataRequest;
do {
// Write to buffer
uint32_t sizeWritten = m_packetCmdState.dataBuffer.Write(value, size);
pos += sizeWritten;
// Execute command with the current buffer
if (!m_command->Execute()) {
HandleProtocolTail(true);
return;
// Done writing the packet data?
if (m_packetCmdState.dataBuffer.IsWriteFinished()) {
m_regs.status |= StBusy;
m_regs.status &= ~StDataRequest;
// Execute command with the current buffer
if (!m_command->Execute()) {
HandleProtocolTail(true);
return;
}
// Done transferring all the data needed by the packet?
if (m_command->IsTransferFinished()) {
HandleProtocolTail(false);
return;
}
}
// Done transferring all the data needed by the packet?
if (m_command->IsTransferFinished()) {
HandleProtocolTail(false);
return;
}
}
} while (pos < size);
}
}