[PD-cvs] SF.net SVN: pure-data: [10146] trunk/externals/mrpeach/osc/pipelist.c

[mrpeach at users.sourceforge.net]

Revision: 10146
          http://pure-data.svn.sourceforge.net/pure-data/?rev=10146&view=rev
Author:   mrpeach
Date:     2008-07-06 13:04:13 -0700 (Sun, 06 Jul 2008)

Log Message:
-----------
The anything method works now...

Modified Paths:
--------------
    trunk/externals/mrpeach/osc/pipelist.c

Modified: trunk/externals/mrpeach/osc/pipelist.c
===================================================================
--- trunk/externals/mrpeach/osc/pipelist.c	2008-07-06 19:58:57 UTC (rev 10145)
+++ trunk/externals/mrpeach/osc/pipelist.c	2008-07-06 20:04:13 UTC (rev 10146)
@@ -1,4 +1,5 @@
 /* pipelist.c 20070711 Martin Peach based on pipe from x_time.c */
+/* 20080706 added anything method for meta-messages */
 #include "m_pd.h" 
 /* -------------------------- pipe -------------------------- */
 
@@ -24,7 +25,9 @@
 static void *pipelist_new(t_symbol *s, int argc, t_atom *argv);
 static void pipelist_hang_free(t_hang *h);
 static void pipelist_hang_tick(t_hang *h);
+static void pipelist_any_hang_tick(t_hang *h);
 static void pipelist_list(t_pipelist *x, t_symbol *s, int ac, t_atom *av);
+static void pipelist_anything(t_pipelist *x, t_symbol *s, int ac, t_atom *av);
 static void pipelist_flush(t_pipelist *x);
 static void pipelist_clear(t_pipelist *x);
 void pipelist_setup(void);
@@ -82,6 +85,27 @@
     pipelist_hang_free(h);
 }
 
+static void pipelist_any_hang_tick(t_hang *h)
+{
+    t_pipelist  *x = h->h_owner;
+    t_hang      *h2, *h3;
+
+    /* excise h from the linked list of hangs */
+    if (x->x_hang == h) x->x_hang = h->h_next;
+    else for (h2 = x->x_hang; ((h3 = h2->h_next)!=NULL); h2 = h3)
+    {
+        if (h3 == h)
+        {
+            h2->h_next = h3->h_next;
+            break;
+        }
+    }
+    /* output h's atoms */
+    outlet_anything(x->x_pipelistout, h->h_atoms[0].a_w.w_symbol, h->h_n-1, &h->h_atoms[1]);
+    /* free h */
+    pipelist_hang_free(h);
+}
+
 static void pipelist_list(t_pipelist *x, t_symbol *s, int ac, t_atom *av)
 {
     if (x->x_deltime > 0)
@@ -102,7 +126,29 @@
         clock_delay(h->h_clock, (x->x_deltime >= 0 ? x->x_deltime : 0));
     }
     /* otherwise just pass the list straight through  */
-    /*else outlet_list(x->x_pipelistout, &s_list, ac, av);*/
+    else outlet_list(x->x_pipelistout, &s_list, ac, av);
+}
+
+static void pipelist_anything(t_pipelist *x, t_symbol *s, int ac, t_atom *av)
+{
+    if (x->x_deltime > 0)
+    { /* if delay is real, save the list for output in delay milliseconds */
+        t_hang *h;
+        int i;
+
+        h = (t_hang *)getbytes(sizeof(t_hang));
+        h->h_n = ac+1;
+        h->h_atoms = (t_atom *)getbytes(h->h_n*sizeof(t_atom));
+        SETSYMBOL(&h->h_atoms[0], s);
+        for (i = 1; i < h->h_n; ++i)
+            h->h_atoms[i] = av[i-1];
+        h->h_next = x->x_hang;
+        x->x_hang = h;
+        h->h_owner = x;
+        h->h_clock = clock_new(h, (t_method)pipelist_any_hang_tick);
+        clock_delay(h->h_clock, (x->x_deltime >= 0 ? x->x_deltime : 0));
+    }
+    /* otherwise just pass it straight through  */
     else outlet_anything(x->x_pipelistout, s, ac, av);
 }
 
@@ -127,7 +173,7 @@
         (t_newmethod)pipelist_new, (t_method)pipelist_clear,
         sizeof(t_pipelist), 0, A_GIMME, 0);
     class_addlist(pipelist_class, pipelist_list);
-    class_addanything(pipelist_class, pipelist_list);
+    class_addanything(pipelist_class, pipelist_anything);
     class_addmethod(pipelist_class, (t_method)pipelist_flush, gensym("flush"), 0);
     class_addmethod(pipelist_class, (t_method)pipelist_clear, gensym("clear"), 0);
 }


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.