(type a_id_type (enumerated "art1" "art2")) (type e_kind (enumerated "e1" "e2")) (type list_size (range 0 2)) (type i_range (range 1 3)) (constant number_of_artists 2) (constant number_of_events 2) (task a1 ( (entry start_artist) (entry notify_client_event (by-value event e_kind)) (entry terminate_artist) (variable notify_event e_kind) (entry terminate_artist-end)) ( (accept start_artist) (call dispatcher register_event "art1" "e1") (call dispatcher register_event "art1" "e2") (call artist_manager a1_registered) (loop (select (when t (accept notify_client_event ( (assign notify_event event)))) (when t (accept terminate_artist ( (call dispatcher unregister_event "art1" "e1") (call dispatcher unregister_event "art1" "e2") (accept terminate_artist-end))) ((exit))))))) (task a2 ( (entry start_artist) (entry notify_client_event (by-value event e_kind)) (entry terminate_artist) (variable notify_event e_kind) (entry terminate_artist-end)) ( (accept start_artist) (call dispatcher register_event "art2" "e1") (call artist_manager a2_registered) (loop (select (when t (accept notify_client_event ( (assign notify_event event)))) (when t (accept terminate_artist ( (call dispatcher unregister_event "art2" "e1") (accept terminate_artist-end))) ((exit))))))) (task adt_wrapper ( (entry start_wrapper)) ( (accept start_wrapper) (loop (call dispatcher notify_artists (choose e_kind)) (call dispatcher notify_artists-end)))) (task artist_manager ( (entry start_manager) (entry a1_registered) (entry a2_registered) (entry start_manager-end)) ( (accept start_manager ( (call a1 start_artist) (call a2 start_artist) (accept a1_registered) (accept a2_registered) (accept start_manager-end))) (while (choose (boolean)) ( (null))) (call a1 terminate_artist) (call a1 terminate_artist-end) (call a2 terminate_artist) (call a2 terminate_artist-end))) (task client_init () ( (call artist_manager start_manager) (call artist_manager start_manager-end) (call adt_wrapper start_wrapper))) (task dispatcher ( (entry register_event (by-value a_id a_id_type) (by-value event_kind e_kind)) (entry unregister_event (by-value a_id a_id_type) (by-value event_kind e_kind)) (entry notify_artists (by-value event e_kind)) (variable e1_lst (array (range 1 number_of_artists) a_id_type)) (variable e2_lst (array (range 1 number_of_artists) a_id_type)) (variable e1_sz list_size 0) (variable e2_sz list_size 0) (variable i i_range) (entry notify_artists-end)) ( (loop (select (when t (accept register_event ( (case event_kind ("e1" ( (assign i 1) (loop (if (> i e1_sz) ( (assign e1_sz (+ e1_sz 1)) (assign (index e1_lst i) a_id) ((exit)))) (if (= (index e1_lst i) a_id) ( ((exit)))) (assign i (+ i 1))))) ("e2" ( (assign i 1) (loop (if (> i e2_sz) ( (assign e2_sz (+ e2_sz 1)) (assign (index e2_lst i) a_id) ((exit)))) (if (= (index e2_lst i) a_id) ( ((exit)))) (assign i (+ i 1))))))))) (when t (accept unregister_event ( (case event_kind ("e1" ( (if (= e1_sz 0) ( (null)) ( (assign i 1) (while (<= i e1_sz) ( (if (= (index e1_lst i) a_id) ( (while (< i e1_sz) ( (assign (index e1_lst i) (index e1_lst (+ i 1))) (assign i (+ i 1)))) (assign e1_sz (- e1_sz 1)))) (assign i (+ i 1)))))))) ("e2" ( (if (= e2_sz 0) ( (null)) ( (assign i 1) (while (<= i e2_sz) ( (if (= (index e2_lst i) a_id) ( (while (< i e2_sz) ( (assign (index e2_lst i) (index e2_lst (+ i 1))) (assign i (+ i 1)))) (assign e2_sz (- e2_sz 1)))) (assign i (+ i 1)))))))))))) (when t (accept notify_artists ( (case event ("e1" ( (for i 1 e1_sz ( (case (index e1_lst i) ("art1" ( (call a1 notify_client_event "e1"))) ("art2" ( (call a2 notify_client_event "e1")))))))) ("e2" ( (for i 1 e2_sz ( (case (index e2_lst i) ("art1" ( (call a1 notify_client_event "e2"))) ("art2" ( (call a2 notify_client_event "e2"))))))))) (accept notify_artists-end)))) (when t (terminate))))))
Back to SEDL Source for Chiron Original Dispatcher (2 artists, 2 events)