# HG changeset patch
# User Florian Pose <fp@igh-essen.com>
# Date 1255622501 -7200
# Node ID 91ae9c95dd2eb9267370151db463e1525724778a
# Parent  26ac1c6111007a0f25b75f6d131971ef0edb015b
Implemented poll(); receiving on generic device also works.

diff -r 26ac1c611100 -r 91ae9c95dd2e devices/generic.c
--- a/devices/generic.c	Thu Oct 15 17:38:53 2009 +0200
+++ b/devices/generic.c	Thu Oct 15 18:01:41 2009 +0200
@@ -75,6 +75,7 @@
 int ec_gen_device_open(ec_gen_device_t *);
 int ec_gen_device_stop(ec_gen_device_t *);
 int ec_gen_device_start_xmit(ec_gen_device_t *, struct sk_buff *);
+void ec_gen_device_poll(ec_gen_device_t *);
 
 /*****************************************************************************/
 
@@ -107,6 +108,8 @@
 
 void ec_gen_poll(struct net_device *dev)
 {
+    ec_gen_device_t *gendev = *((ec_gen_device_t **) netdev_priv(dev));
+    ec_gen_device_poll(gendev);
 }
 
 /*****************************************************************************/
@@ -271,6 +274,35 @@
 
 /*****************************************************************************/
 
+/** Polls the device.
+ */
+void ec_gen_device_poll(
+        ec_gen_device_t *dev
+        )
+{
+    struct msghdr msg;
+    struct kvec iov;
+    char buf[2000]; // FIXME
+    int ret, budget = 10; // FIXME
+
+    iov.iov_base = buf;
+    iov.iov_len = 2000;
+    memset(&msg, 0, sizeof(msg));
+
+    do {
+        ret = kernel_recvmsg(dev->socket, &msg, &iov, 1, iov.iov_len,
+                MSG_DONTWAIT);
+        if (ret > 0) {
+            ecdev_receive(dev->ecdev, buf, ret);
+        } else if (ret < 0) {
+            break;
+        }
+        budget--;
+    } while (budget);
+}
+
+/*****************************************************************************/
+
 /** Offer device.
  */
 int offer_device(