lily/grob-pq-engraver.cc

   1 /*
   2   grob-pq-engraver.cc -- implement Grob_pq_engraver
   3
   4   source file of the GNU LilyPond music typesetter
   5
   6   (c) 2001--2007  Han-Wen Nienhuys <hanwen@xs4all.nl>
   7 */
   8
   9 #include "context.hh"
  10 #include "engraver.hh"
  11 #include "grob.hh"
  12 #include "warn.hh"
  13
  14 struct Grob_pq_entry
  15 {
  16   Grob *grob_;
  17   Moment end_;
  18 };
  19
  20 bool
  21 operator< (Grob_pq_entry const &a, Grob_pq_entry const &b)
  22 {
  23   return a.end_ < b.end_;
  24 }
  25
  26 class Grob_pq_engraver : public Engraver
  27 {
  28 public:
  29   TRANSLATOR_DECLARATIONS (Grob_pq_engraver);
  30 protected:
  31   virtual void initialize ();
  32   DECLARE_ACKNOWLEDGER (grob);
  33   void start_translation_timestep ();
  34   void stop_translation_timestep ();
  35   void process_acknowledged ();
  36
  37   vector<Grob_pq_entry> started_now_;
  38 };
  39
  40 Grob_pq_engraver::Grob_pq_engraver ()
  41 {
  42 }
  43
  44 void
  45 Grob_pq_engraver::initialize ()
  46 {
  47   context ()->set_property ("busyGrobs", SCM_EOL);
  48 }
  49
  50 LY_DEFINE (ly_grob_pq_less_p, "ly:grob-pq<?",
  51            2, 0, 0, (SCM a, SCM b),
  52            "Compare 2 grob priority queue entries. Internal")
  53 {
  54   if (Moment::compare (*unsmob_moment (scm_car (a)),
  55                        *unsmob_moment (scm_car (b))) < 0)
  56     return SCM_BOOL_T;
  57   else
  58     return SCM_BOOL_F;
  59 }
  60
  61 void
  62 Grob_pq_engraver::acknowledge_grob (Grob_info gi)
  63 {
  64   Stream_event *ev = gi.event_cause ();
  65
  66   if (ev
  67       && !gi.grob ()->internal_has_interface (ly_symbol2scm ("multi-measure-interface")))
  68     {
  69       Moment n = now_mom ();
  70       Moment l = get_event_length (ev, n);
  71
  72       if (!l.to_bool ())
  73         return;
  74
  75       Moment end = n + l;
  76
  77       Grob_pq_entry e;
  78       e.grob_ = gi.grob ();
  79       e.end_ = end;
  80
  81       started_now_.push_back (e);
  82     }
  83 }
  84
  85 void
  86 Grob_pq_engraver::process_acknowledged ()
  87 {
  88   vector_sort (started_now_, less<Grob_pq_entry> ());
  89   SCM lst = SCM_EOL;
  90   SCM *tail = &lst;
  91   for (vsize i = 0; i < started_now_.size (); i++)
  92     {
  93       *tail = scm_acons (started_now_[i].end_.smobbed_copy (),
  94                          started_now_[i].grob_->self_scm (),
  95                          SCM_EOL);
  96       tail = SCM_CDRLOC (*tail);
  97     }
  98
  99   SCM busy = get_property ("busyGrobs");
 100   busy = scm_merge_x (lst, busy, ly_grob_pq_less_p_proc);
 101   context ()->set_property ("busyGrobs", busy);
 102
 103   started_now_.clear ();
 104 }
 105
 106 void
 107 Grob_pq_engraver::stop_translation_timestep ()
 108 {
 109   Moment now = now_mom ();
 110   SCM start_busy = get_property ("busyGrobs");
 111   SCM busy = start_busy;
 112   while (scm_is_pair (busy) && *unsmob_moment (scm_caar (busy)) == now)
 113     busy = scm_cdr (busy);
 114
 115 }
 116
 117 void
 118 Grob_pq_engraver::start_translation_timestep ()
 119 {
 120   Moment now = now_mom ();
 121
 122   SCM start_busy = get_property ("busyGrobs");
 123   SCM busy = start_busy;
 124   while (scm_is_pair (busy) && *unsmob_moment (scm_caar (busy)) < now)
 125     {
 126       /*
 127         The grob-pq-engraver is not water tight, and stuff like
 128         tupletSpannerDuration confuses it.
 129       */
 130       busy = scm_cdr (busy);
 131     }
 132
 133   if (start_busy != busy)
 134     context ()->set_property ("busyGrobs", busy);
 135 }
 136
 137 #include "translator.icc"
 138 ADD_ACKNOWLEDGER (Grob_pq_engraver, grob);
 139 ADD_TRANSLATOR (Grob_pq_engraver,
 140
 141                 /* doc */ "Administrate when certain grobs (eg. note heads) stop playing",
 142                 /* create */ "",
 143                 /* read */ "busyGrobs",
 144                 /* write */ "busyGrobs");