* [Qemu-devel] [5553] ETRAX-FS: Process outgoing DMA channels until EOL.
@ 2008-10-27 20:44 Edgar E. Iglesias
0 siblings, 0 replies; only message in thread
From: Edgar E. Iglesias @ 2008-10-27 20:44 UTC (permalink / raw)
To: qemu-devel
Revision: 5553
http://svn.sv.gnu.org/viewvc/?view=rev&root=qemu&revision=5553
Author: edgar_igl
Date: 2008-10-27 20:44:27 +0000 (Mon, 27 Oct 2008)
Log Message:
-----------
ETRAX-FS: Process outgoing DMA channels until EOL.
For outgoing DMA channels, keep processing descriptors until hitting end
of list.
Signed-off-by: Edgar E. Iglesias <edgar.iglesias@gmail.com>
Modified Paths:
--------------
trunk/hw/etraxfs_dma.c
Modified: trunk/hw/etraxfs_dma.c
===================================================================
--- trunk/hw/etraxfs_dma.c 2008-10-27 20:24:59 UTC (rev 5552)
+++ trunk/hw/etraxfs_dma.c 2008-10-27 20:44:27 UTC (rev 5553)
@@ -393,72 +393,74 @@
uint32_t saved_data_buf;
unsigned char buf[2 * 1024];
- if (ctrl->channels[c].eol == 1)
- return;
+ while (ctrl->channels[c].eol != 1) {
+ saved_data_buf = channel_reg(ctrl, c, RW_SAVED_DATA_BUF);
- saved_data_buf = channel_reg(ctrl, c, RW_SAVED_DATA_BUF);
+ D(printf("ch=%d buf=%x after=%x saved_data_buf=%x\n",
+ c,
+ (uint32_t)ctrl->channels[c].current_d.buf,
+ (uint32_t)ctrl->channels[c].current_d.after,
+ saved_data_buf));
- D(printf("ch=%d buf=%x after=%x saved_data_buf=%x\n",
- c,
- (uint32_t)ctrl->channels[c].current_d.buf,
- (uint32_t)ctrl->channels[c].current_d.after,
- saved_data_buf));
+ len = (uint32_t)ctrl->channels[c].current_d.after;
+ len -= saved_data_buf;
- len = (uint32_t)(unsigned long) ctrl->channels[c].current_d.after;
- len -= saved_data_buf;
+ if (len > sizeof buf)
+ len = sizeof buf;
+ cpu_physical_memory_read (saved_data_buf, buf, len);
- if (len > sizeof buf)
- len = sizeof buf;
- cpu_physical_memory_read (saved_data_buf, buf, len);
+ D(printf("channel %d pushes %x %u bytes\n", c,
+ saved_data_buf, len));
- D(printf("channel %d pushes %x %u bytes\n", c,
- saved_data_buf, len));
+ if (ctrl->channels[c].client->client.push)
+ ctrl->channels[c].client->client.push(
+ ctrl->channels[c].client->client.opaque,
+ buf, len);
+ else
+ printf("WARNING: DMA ch%d dataloss,"
+ " no attached client.\n", c);
- if (ctrl->channels[c].client->client.push)
- ctrl->channels[c].client->client.push(
- ctrl->channels[c].client->client.opaque, buf, len);
- else
- printf("WARNING: DMA ch%d dataloss, no attached client.\n", c);
+ saved_data_buf += len;
- saved_data_buf += len;
+ if (saved_data_buf ==
+ (uint32_t)ctrl->channels[c].current_d.after) {
+ /* Done. Step to next. */
+ if (ctrl->channels[c].current_d.out_eop) {
+ /* TODO: signal eop to the client. */
+ D(printf("signal eop\n"));
+ }
+ if (ctrl->channels[c].current_d.intr) {
+ /* TODO: signal eop to the client. */
+ /* data intr. */
+ D(printf("signal intr\n"));
+ ctrl->channels[c].regs[R_INTR] |= (1 << 2);
+ channel_update_irq(ctrl, c);
+ }
+ if (ctrl->channels[c].current_d.eol) {
+ D(printf("channel %d EOL\n", c));
+ ctrl->channels[c].eol = 1;
- if (saved_data_buf ==
- (uint32_t)(unsigned long)ctrl->channels[c].current_d.after) {
- /* Done. Step to next. */
- if (ctrl->channels[c].current_d.out_eop) {
- /* TODO: signal eop to the client. */
- D(printf("signal eop\n"));
- }
- if (ctrl->channels[c].current_d.intr) {
- /* TODO: signal eop to the client. */
- /* data intr. */
- D(printf("signal intr\n"));
- ctrl->channels[c].regs[R_INTR] |= (1 << 2);
- channel_update_irq(ctrl, c);
- }
- if (ctrl->channels[c].current_d.eol) {
- D(printf("channel %d EOL\n", c));
- ctrl->channels[c].eol = 1;
+ /* Mark the context as disabled. */
+ ctrl->channels[c].current_c.dis = 1;
+ channel_store_c(ctrl, c);
- /* Mark the context as disabled. */
- ctrl->channels[c].current_c.dis = 1;
- channel_store_c(ctrl, c);
+ channel_stop(ctrl, c);
+ } else {
+ ctrl->channels[c].regs[RW_SAVED_DATA] =
+ (uint32_t)ctrl->channels[c].current_d.next;
+ /* Load new descriptor. */
+ channel_load_d(ctrl, c);
+ saved_data_buf = (uint32_t)(unsigned long)
+ ctrl->channels[c].current_d.buf;
+ }
- channel_stop(ctrl, c);
- } else {
- ctrl->channels[c].regs[RW_SAVED_DATA] =
- (uint32_t)(unsigned long) ctrl->channels[c].current_d.next;
- /* Load new descriptor. */
- channel_load_d(ctrl, c);
- saved_data_buf = (uint32_t)(unsigned long)
- ctrl->channels[c].current_d.buf;
+ channel_store_d(ctrl, c);
+ ctrl->channels[c].regs[RW_SAVED_DATA_BUF] =
+ saved_data_buf;
+ D(dump_d(c, &ctrl->channels[c].current_d));
}
-
- channel_store_d(ctrl, c);
ctrl->channels[c].regs[RW_SAVED_DATA_BUF] = saved_data_buf;
- D(dump_d(c, &ctrl->channels[c].current_d));
}
- ctrl->channels[c].regs[RW_SAVED_DATA_BUF] = saved_data_buf;
}
static int channel_in_process(struct fs_dma_ctrl *ctrl, int c,
@@ -471,7 +473,7 @@
return 0;
saved_data_buf = channel_reg(ctrl, c, RW_SAVED_DATA_BUF);
- len = (uint32_t)(unsigned long) ctrl->channels[c].current_d.after;
+ len = (uint32_t)ctrl->channels[c].current_d.after;
len -= saved_data_buf;
if (len > buflen)
@@ -481,7 +483,7 @@
saved_data_buf += len;
if (saved_data_buf ==
- (uint32_t)(unsigned long)ctrl->channels[c].current_d.after
+ (uint32_t)ctrl->channels[c].current_d.after
|| eop) {
uint32_t r_intr = ctrl->channels[c].regs[R_INTR];
@@ -518,10 +520,10 @@
channel_stop(ctrl, c);
} else {
ctrl->channels[c].regs[RW_SAVED_DATA] =
- (uint32_t)(unsigned long) ctrl->channels[c].current_d.next;
+ (uint32_t)ctrl->channels[c].current_d.next;
/* Load new descriptor. */
channel_load_d(ctrl, c);
- saved_data_buf = (uint32_t)(unsigned long)
+ saved_data_buf = (uint32_t)
ctrl->channels[c].current_d.buf;
}
}
^ permalink raw reply [flat|nested] only message in thread
only message in thread, other threads:[~2008-10-27 20:44 UTC | newest]
Thread overview: (only message) (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2008-10-27 20:44 [Qemu-devel] [5553] ETRAX-FS: Process outgoing DMA channels until EOL Edgar E. Iglesias
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).