laiyp/lib_xua
1
0
Fork 0
forked from PAWPAW-Mirror/lib_xua
Code Pull Requests Activity

Merge remote-tracking branch 'origin/IAP2_DEV'

Browse Source
This commit is contained in:
Ross Owen
2014-02-10 14:43:23 +00:00
parent bf1a7373d1 34640a49d4
commit cc0ddbf026
1 changed files with 57 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files

99
module_usb_audio/usb_buffer/usb_buffer.xc
View File

@@ -170,6 +170,7 @@ void buffer(register chanend c_aud_out, register chanend c_aud_in, chanend c_aud
int iap_data_remaining_to_device = 0; int iap_data_remaining_to_device = 0;
int iap_data_collected_from_device = 0; int iap_data_collected_from_device = 0;
int iap_expected_data_length = 0; int iap_expected_data_length = 0;
int iap_draining_chan = 0;
#endif #endif
@@ -555,7 +556,8 @@ void buffer(register chanend c_aud_out, register chanend c_aud_in, chanend c_aud
else if(tmp==-1) else if(tmp==-1)
{ {
XUD_ResetEndpoint(ep_iap_from_host, null); XUD_ResetEndpoint(ep_iap_from_host, null);
iap_send_reset(c_iap); // What if this happen in the middle of a send/ack? iap_send_reset(c_iap);
iap_draining_chan = 1; // Drain c_iap until a reset is sent back
iap_data_collected_from_device = 0; iap_data_collected_from_device = 0;
iap_data_remaining_to_device = -1; iap_data_remaining_to_device = -1;
iap_expected_data_length = 0; iap_expected_data_length = 0;
@@ -644,58 +646,71 @@ void buffer(register chanend c_aud_out, register chanend c_aud_in, chanend c_aud
/* Received word from iap thread - Check for ACK or Data */ /* Received word from iap thread - Check for ACK or Data */
case iap_get_ack_or_reset_or_data(c_iap, is_ack_iap, is_reset, datum_iap): case iap_get_ack_or_reset_or_data(c_iap, is_ack_iap, is_reset, datum_iap):
if (is_ack_iap) if (iap_draining_chan)
{ {
/* An ack from the iap/uart thread means it has accepted some data we sent it /* As we're draining the iAP channel now, ignore ACKs and data */
* we are okay to send another word */ if (is_reset)
if (iap_data_remaining_to_device == 0)
{ {
/* We have read an entire packet - Mark ready to receive another */ // The iAP core has returned a reset token, so we can stop draining the iAP channel now
XUD_SetReady_Out(ep_iap_from_host, iap_from_host_buffer); iap_draining_chan = 0;
}
else
{
/* Read another byte from the fifo and output it to iap thread */
datum_iap = iap_from_host_buffer[iap_from_host_rdptr];
outuint(c_iap, datum_iap);
iap_from_host_rdptr += 1;
iap_data_remaining_to_device -= 1;
} }
} }
else else
{ {
if (iap_expected_data_length == 0) if (is_ack_iap)
{ {
/* Expect a length from iAP core */ /* An ack from the iap/uart thread means it has accepted some data we sent it
iap_send_ack(c_iap); * we are okay to send another word */
iap_expected_data_length = datum_iap; if (iap_data_remaining_to_device == 0)
{
/* We have read an entire packet - Mark ready to receive another */
XUD_SetReady_Out(ep_iap_from_host, iap_from_host_buffer);
}
else
{
/* Read another byte from the fifo and output it to iap thread */
datum_iap = iap_from_host_buffer[iap_from_host_rdptr];
outuint(c_iap, datum_iap);
iap_from_host_rdptr += 1;
iap_data_remaining_to_device -= 1;
}
} }
else else if (!is_reset)
{ {
if (iap_data_collected_from_device < IAP_USB_BUFFER_TO_HOST_SIZE) if (iap_expected_data_length == 0)
{ {
/* There is room in the collecting buffer for the data.. */ /* Expect a length from iAP core */
iap_to_host_buffer[iap_data_collected_from_device] = datum_iap;
iap_data_collected_from_device += 1;
}
else
{
// Too many events from device - drop
}
/* Once we have the whole message, sent it to host */
/* Note we don't ack the last byte yet... */
if (iap_data_collected_from_device == iap_expected_data_length)
{
XUD_SetReady_In(ep_iap_to_host_int, gc_zero_buffer, 0);
XUD_SetReady_In(ep_iap_to_host, iap_to_host_buffer, iap_data_collected_from_device);
iap_data_collected_from_device = 0;
iap_expected_data_length = 0;
}
else
{
/* The iap/uart thread has sent us some data - handshake back */
iap_send_ack(c_iap); iap_send_ack(c_iap);
iap_expected_data_length = datum_iap;
}
else
{
if (iap_data_collected_from_device < IAP_USB_BUFFER_TO_HOST_SIZE)
{
/* There is room in the collecting buffer for the data.. */
iap_to_host_buffer[iap_data_collected_from_device] = datum_iap;
iap_data_collected_from_device += 1;
}
else
{
// Too many events from device - drop
}
/* Once we have the whole message, sent it to host */
/* Note we don't ack the last byte yet... */
if (iap_data_collected_from_device == iap_expected_data_length)
{
XUD_SetReady_In(ep_iap_to_host_int, gc_zero_buffer, 0);
XUD_SetReady_In(ep_iap_to_host, iap_to_host_buffer, iap_data_collected_from_device);
printintln(iap_data_collected_from_device);
iap_data_collected_from_device = 0;
iap_expected_data_length = 0;
}
else
{
/* The iap/uart thread has sent us some data - handshake back */
iap_send_ack(c_iap);
}
} }
} }
} }