Hello,

skaller wrote:
> On Thu, 2007-10-11 at 01:00 +1000, skaller wrote:
>> On Wed, 2007-10-10 at 11:08 +0100, Hugo Ferreira wrote:
>>> Hello,
>>> Apologies for being so obtuse but I cannot to see how this solves my
>>> problem. 
>>> let exp = a |> b |> c
> 
>> A function is a slave, it is *called* with its argument.
>> you cant *read* the arguments.
> 
> BTW: what you want is something like this 'concept demo'
> I hacked up in Felix (notes below).
> 
> 	a -> b -> c -> d ->+
> 	^                  |
> 	|                  |
> 	+--------<---------+
> 

Basically yes. Closer to this though:

 	a -> b -> c -> d ->+-> e -> f
 	^                  |
 	|                  |
 	+--------<---------+


The solution below is basically the same suggestion I got (in Ocaml)
from someone else. I guess this is the way to go then.

Regards,
Hugo F.


> ////////////////////////////////////////////////////
> // generate events 1 to limit
> proc a
> (
>   limit:ischannel[int], 
>   chout: oschannel[int]
> ) 
> {
>   var event:int; var n:int;
>   forever {
>     read(&n,limit);
>     forall event in 1 upto n do
>       write(chout,event);
>     done;
>   };
> }
> 
> // double it
> proc b(chin: ischannel[int], chout: oschannel[int]) {
>   int event;
>   forever {
>     read(&event,chin);
>     write(chout,event*2);
>   };
> }
> 
> // add 1
> proc c(chin: ischannel[int], chout: oschannel[int]) {
>   int event;
>   forever {
>     read(&event,chin);
>     write(chout,event+1);
>   };
> }
> 
> proc d
> (
>   chin:ischannel[int], 
>   limit: oschannel[int]
> ) 
> {
>   int count; int i; int event;
>   var total = 10;
>   while (total < 1000) {
>     println$ "subtotal " + str total;
>     n := total;
>     write(limit,total);
>     forall i in 1 upto n do
>       read(&event, chin);
>       //println$ f"Event %d = %d" (i,event);
>       total += event;
>     done;
>   };
>   println$ "total=" + str total;
> }
> 
> proc pipeline() {
>   bin,aout := mk_ioschannel_pair[int]();
>   cin,bout := mk_ioschannel_pair[int]();
>   din,cout := mk_ioschannel_pair[int]();
>   limin,limout := mk_ioschannel_pair[int]();
>   spawn_fthread { a(limin, aout); };
>   spawn_fthread { b(bin, bout); };
>   spawn_fthread { c(cin, cout); };
>   spawn_fthread { d(din, limout); };
> }
> 
> pipeline();
> ///////////////////////////////////////
> $ f fl
> subtotal 10
> subtotal 130
> total=17290
> ////////////////////////////////////////
> 
> Here we create procedures a,b,c,d which are templates
> for "chips" with input and output "pins".
> 
> In the pipeline() procedure we create wires with named ends for input
> and output, and plug them into instances of the 'chips'
> to create a 'circuit'. (This is crude but it works and is 
> fully general).
> 
> In the pipeline the input state of 'a' is the 'limit' value,
> which is written by 'd'. When 'd' gets the result sum, if it is
> too small it writes the sum as the new limit back to the
> chip 'a'.
> 
>