# HG changeset patch # User samer # Date 1327445110 0 # Node ID 11e8c4e65a033e8cb48709147873c2e0ba3695ae # Parent a0213fab5674b9f042206cd4a22d5f7bf270b81f Removed printing from qutils, added some to recorder. diff -r a0213fab5674 -r 11e8c4e65a03 README --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/README Tue Jan 24 22:45:10 2012 +0000 @@ -0,0 +1,18 @@ +---+ Reactive + + This package provides a simple continuation-based framework for reactive programming + in Prolog. Most of the documentation is in reactive.pl. qutils.pl provides some + basic facilities for dealing with message queues in a time and space constrained + manner. recorder.pl provides a general mechanism for logging all events passing + into a reactive system. + +---++++ Dependencies: + +Packages: + * plcore + * plrand + * reactive + * plmidi + * plosc + + diff -r a0213fab5674 -r 11e8c4e65a03 qutils.pl --- a/qutils.pl Mon Jan 23 17:38:47 2012 +0000 +++ b/qutils.pl Tue Jan 24 22:45:10 2012 +0000 @@ -18,7 +18,7 @@ get_message_or_timeout(inf,Msg) :- !, thread_get_message(Msg). get_message_or_timeout(Deadline,Msg) :- get_time(Now), - ( Now>=Deadline -> Msg=timeout, writeln(elapsed) + ( Now>=Deadline -> Msg=timeout %, writeln(elapsed) ; thread_self(Thread), setup_call_cleanup( alarm_at(Deadline, thread_send_message(Thread,timeout), Id), diff -r a0213fab5674 -r 11e8c4e65a03 recorder.pl --- a/recorder.pl Mon Jan 23 17:38:47 2012 +0000 +++ b/recorder.pl Tue Jan 24 22:45:10 2012 +0000 @@ -24,6 +24,7 @@ retractall(event(_,_)), retractall(start_time(_)), assert(start_time(Now)), + format('recording events for ~w.\n',[Client]), call(Client,C1), recorder_cont(C1,Proc).