Changeset 7300c37 in mainline for uspace/srv/hw/netif/dp8390/dp8390.c

Timestamp:

2011-01-11T01:33:13Z (14 years ago)

Author:

Martin Decky <martin@…>

Branches:

lfn, master, serial, ticket/834-toolchain-update, topic/msim-upgrade, topic/simplify-dev-export

Children:

8136102

Parents:

4fc2b3b

Message:

fetching of frames from the network card is still single-threaded, but sending the frames to NIL uses parallelism

File:

• uspace/srv/hw/netif/dp8390/dp8390.c (modified) (9 diffs)

uspace/srv/hw/netif/dp8390/dp8390.c

@@ -54 +54 @@
 #include <errno.h>
 #include <libarch/ddi.h>
-#include <netif_skel.h>
 #include <net/packet.h>
-#include <nil_interface.h>
 #include <packet_client.h>
 #include "dp8390.h"
@@ -344 +342 @@
         
         /* Step 10: */
-        pio_write_8(ne2k->port + DP_CR, CR_DM_ABORT | CR_STA);
+        pio_write_8(ne2k->port + DP_CR, CR_PS_P0 | CR_DM_ABORT | CR_STA);
         
         /* Step 11: */
@@ -449 +447 @@
 }
 
-static void ne2k_receive_frame(ne2k_t *ne2k, uint8_t page, size_t length,
-    int nil_phone, device_id_t device_id)
-{
-        packet_t *packet = netif_packet_get_1(length);
-        if (!packet)
-                return;
-        
-        void *buf = packet_suffix(packet, length);
+static frame_t *ne2k_receive_frame(ne2k_t *ne2k, uint8_t page, size_t length)
+{
+        frame_t *frame = (frame_t *) malloc(sizeof(frame_t));
+        if (frame == NULL)
+                return NULL;
+        
+        link_initialize(&frame->link);
+        
+        frame->packet = netif_packet_get_1(length);
+        if (frame->packet == NULL) {
+                free(frame);
+                return NULL;
+        }
+        
+        void *buf = packet_suffix(frame->packet, length);
         bzero(buf, length);
         uint8_t last = page + length / DP_PAGE;
@@ -473 +478 @@
         
         ne2k->stats.receive_packets++;
-        nil_received_msg(nil_phone, device_id, packet, SERVICE_NONE);
-}
-
-static void ne2k_receive(ne2k_t *ne2k, int nil_phone, device_id_t device_id)
-{
+        return frame;
+}
+
+static link_t *ne2k_receive(ne2k_t *ne2k)
+{
+        /*
+         * Allocate memory for the list of received frames.
+         * If the allocation fails here we still receive the
+         * frames from the network, but they will be lost.
+         */
+        link_t *frames = (link_t *) malloc(sizeof(link_t));
+        if (frames != NULL)
+                list_initialize(frames);
+        
         while (true) {
                 uint8_t boundary = pio_read_8(ne2k->port + DP_BNRY) + 1;
@@ -526 +540 @@
                         ne2k->overruns++;
                         next = current;
-                } else if ((header.status & RSR_PRX) && (ne2k->up))
-                        ne2k_receive_frame(ne2k, boundary, length, nil_phone, device_id);
+                } else if ((header.status & RSR_PRX) && (ne2k->up)) {
+                        frame_t *frame = ne2k_receive_frame(ne2k, boundary, length);
+                        if ((frame != NULL) && (frames != NULL))
+                                list_append(&frame->link, frames);
+                }
                 
                 /*
@@ -542 +559 @@
                 pio_write_8(ne2k->port + DP_BNRY, next);
         }
-}
-
-void ne2k_interrupt(ne2k_t *ne2k, uint8_t isr, int nil_phone, device_id_t device_id)
-{
+        
+        return frames;
+}
+
+link_t *ne2k_interrupt(ne2k_t *ne2k, uint8_t isr, uint8_t tsr)
+{
+        /* List of received frames */
+        link_t *frames = NULL;
+        
         if (isr & (ISR_PTX | ISR_TXE)) {
                 if (isr & ISR_TXE)
                         ne2k->stats.send_errors++;
                 else {
-                        uint8_t tsr = pio_read_8(ne2k->port + DP_TSR);
-                        
                         if (tsr & TSR_PTX)
                                 ne2k->stats.send_packets++;
@@ -598 +618 @@
         }
         
-        if (isr & ISR_PRX)
-                ne2k_receive(ne2k, nil_phone, device_id);
-        
         if (isr & ISR_RXE)
                 ne2k->stats.receive_errors++;
@@ -613 +630 @@
         }
         
+        if (isr & ISR_PRX)
+                frames = ne2k_receive(ne2k);
+        
         if (isr & ISR_RST) {
                 /*
@@ -624 +644 @@
         pio_write_8(ne2k->port + DP_IMR,
             IMR_PRXE | IMR_PTXE | IMR_RXEE | IMR_TXEE | IMR_OVWE | IMR_CNTE);
+        
+        return frames;
 }