[Xenomai-git] Alexis Berlemont : analogy: [fake] validate the looping feature

[GIT version control]

Module: xenomai-abe
Branch: experimental
Commit: 4beb5b3fc5b2072af46c54a99765a3ce339ee9cf
URL:    
http://git.xenomai.org/?p=xenomai-abe.git;a=commit;h=4beb5b3fc5b2072af46c54a99765a3ce339ee9cf

Author: Alexis Berlemont <alexis.berlem...@gmail.com>
Date:   Fri Jan 14 20:53:36 2011 +0100

analogy: [fake] validate the looping feature

Two subdevices have been added: an asynchronous output subdevice
(idx=2) and an asynchronous input subdevice (idx=3). All the values
sent from userspace to the output subdevice is redirected into the
input subdevice.

---

 ksrc/drivers/analogy/testing/fake.c |   22 ++++++++++++++++------
 1 files changed, 16 insertions(+), 6 deletions(-)

diff --git a/ksrc/drivers/analogy/testing/fake.c 
b/ksrc/drivers/analogy/testing/fake.c
index 7e4d5ed..911826a 100644
--- a/ksrc/drivers/analogy/testing/fake.c
+++ b/ksrc/drivers/analogy/testing/fake.c
@@ -175,6 +175,9 @@ int ao_pull_values(a4l_subd_t *subd)
        /* Let's have a look at how many samples are available */
        priv->count = a4l_buf_count(subd) < TRANSFER_SIZE ? 
                a4l_buf_count(subd) : TRANSFER_SIZE;
+       
+       if (!priv->count)
+               return 0;
 
        err = a4l_buf_get(subd, priv->buffer, priv->count);
        if (err < 0) {
@@ -183,6 +186,9 @@ int ao_pull_values(a4l_subd_t *subd)
                        "ao_get_values: a4l_buf_get failed (err=%d)\n", err);
        }
 
+       if (priv->count)
+               a4l_buf_evt(subd, 0);
+
        return err;
 }
 
@@ -195,11 +201,15 @@ int ai2_push_values(a4l_subd_t *subd)
 
        if (priv->count) {
                err = a4l_buf_put(subd, priv->buffer, priv->count);
-               a4l_err(subd->dev, 
-                       "ao_redirect_values: "
-                       "a4l_buf_get failed (err=%d)\n", err);
+               if (err < 0)
+                       a4l_err(subd->dev, 
+                               "ai2_push_values: "
+                               "a4l_buf_put failed (err=%d)\n", err);
        }
 
+       if (priv->count)
+               a4l_buf_evt(subd, 0);
+
        return err;
 }
 
@@ -329,7 +339,7 @@ int ai2_cmd(a4l_subd_t *subd, a4l_cmd_t *cmd)
 {
        struct fake_priv *priv = (struct fake_priv *)subd->dev->priv;
 
-       a4l_info(subd->dev, "ao_cmd: (subd=%d)\n", subd->idx);  
+       a4l_info(subd->dev, "ai2_cmd: (subd=%d)\n", subd->idx);  
        RTDM_EXECUTE_ATOMICALLY(priv->ai2_running = 1);
        return 0;
 }
@@ -338,13 +348,12 @@ int ai2_cancel(a4l_subd_t *subd)
 {
        struct fake_priv *priv = (struct fake_priv *)subd->dev->priv;
 
-       a4l_info(subd->dev, "ao_cancel: (subd=%d)\n", subd->idx);
+       a4l_info(subd->dev, "ai2_cancel: (subd=%d)\n", subd->idx);
        RTDM_EXECUTE_ATOMICALLY(priv->ai2_running = 0);
        return 0;
 }
 
 
-
 /* --- Synchronous AI functions --- */
 
 static int ai_insn_read(a4l_subd_t *subd, a4l_kinsn_t *insn)
@@ -416,6 +425,7 @@ void setup_ao_subd(a4l_subd_t *subd)
        subd->chan_desc = &analog_chandesc;
        subd->do_cmd = ao_cmd;
        subd->cancel = ao_cancel;
+       subd->trigger = ao_trigger;
        subd->cmd_mask = &ao_cmd_mask;
 }
 


_______________________________________________
Xenomai-git mailing list
Xenomai-git@gna.org
https://mail.gna.org/listinfo/xenomai-git