chiark - git - mdw - disorder/blob - disobedience/log.c

   1 /*
   2  * This file is part of DisOrder.
   3  * Copyright (C) 2006, 2007 Richard Kettlewell
   4  *
   5  * This program is free software; you can redistribute it and/or modify
   6  * it under the terms of the GNU General Public License as published by
   7  * the Free Software Foundation; either version 2 of the License, or
   8  * (at your option) any later version.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU General Public License
  16  * along with this program; if not, write to the Free Software
  17  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
  18  * USA
  19  */
  20 /** @file disobedience/log.c
  21  * @brief State monitoring
  22  *
  23  * Disobedience relies on the server to tell when essentially anything changes,
  24  * even if it initiated the change itself.  It uses the @c log command to
  25  * achieve this.
  26  */
  27
  28 #include "disobedience.h"
  29
  30 /* State monitoring -------------------------------------------------------- */
  31
  32 static void log_connected(void *v);
  33 static void log_completed(void *v, const char *track);
  34 static void log_failed(void *v, const char *track, const char *status);
  35 static void log_moved(void *v, const char *user);
  36 static void log_playing(void *v, const char *track, const char *user);
  37 static void log_queue(void *v, struct queue_entry *q);
  38 static void log_recent_added(void *v, struct queue_entry *q);
  39 static void log_recent_removed(void *v, const char *id);
  40 static void log_removed(void *v, const char *id, const char *user);
  41 static void log_scratched(void *v, const char *track, const char *user);
  42 static void log_state(void *v, unsigned long state);
  43 static void log_volume(void *v, int l, int r);
  44
  45 /** @brief Callbacks for server state monitoring */
  46 const disorder_eclient_log_callbacks log_callbacks = {
  47   log_connected,
  48   log_completed,
  49   log_failed,
  50   log_moved,
  51   log_playing,
  52   log_queue,
  53   log_recent_added,
  54   log_recent_removed,
  55   log_removed,
  56   log_scratched,
  57   log_state,
  58   log_volume
  59 };
  60
  61 /** @brief State monitor
  62  *
  63  * We keep a linked list of everything that is interested in state changes.
  64  */
  65 struct monitor {
  66   /** @brief Next monitor */
  67   struct monitor *next;
  68
  69   /** @brief State bits of interest */
  70   unsigned long mask;
  71
  72   /** @brief Function to call if any of @c mask change */
  73   monitor_callback *callback;
  74
  75   /** @brief User data for callback */
  76   void *u;
  77 };
  78
  79 /** @brief List of monitors */
  80 static struct monitor *monitors;
  81
  82 /** @brief Update everything */
  83 void all_update(void) {
  84   playing_update();
  85   queue_update();
  86   recent_update();
  87   volume_update();
  88 }
  89
  90 /** @brief Called when the client connects
  91  *
  92  * Depending on server and network state the TCP connection to the server may
  93  * go up or down many times during the lifetime of Disobedience.  This function
  94  * is called whenever it connects.
  95  *
  96  * The intent is to use the monitor logic to achieve this in future.
  97  */
  98 static void log_connected(void attribute((unused)) *v) {
  99   /* Don't know what we might have missed while disconnected so update
 100    * everything.  We get this at startup too and this is how we do the initial
 101    * state fetch. */
 102   all_update();
 103 }
 104
 105 /** @brief Called when the current track finishes playing */
 106 static void log_completed(void attribute((unused)) *v,
 107                           const char attribute((unused)) *track) {
 108   playing = 0;
 109   playing_update();
 110 }
 111
 112 /** @brief Called when the current track fails */
 113 static void log_failed(void attribute((unused)) *v,
 114                        const char attribute((unused)) *track,
 115                        const char attribute((unused)) *status) {
 116   playing = 0;
 117   playing_update();
 118 }
 119
 120 /** @brief Called when some track is moved within the queue */
 121 static void log_moved(void attribute((unused)) *v,
 122                       const char attribute((unused)) *user) {
 123   queue_update();
 124 }
 125
 126 static void log_playing(void attribute((unused)) *v,
 127                         const char attribute((unused)) *track,
 128                         const char attribute((unused)) *user) {
 129   playing = 1;
 130   playing_update();
 131   /* we get a log_removed() anyway so we don't need to update_queue() from
 132    * here */
 133 }
 134
 135 /** @brief Called when a track is added to the queue */
 136 static void log_queue(void attribute((unused)) *v,
 137                       struct queue_entry attribute((unused)) *q) {
 138   queue_update();
 139 }
 140
 141 /** @brief Called when a track is added to the recently-played list */
 142 static void log_recent_added(void attribute((unused)) *v,
 143                              struct queue_entry attribute((unused)) *q) {
 144   recent_update();
 145 }
 146
 147 /** @brief Called when a track is removed from the recently-played list
 148  *
 149  * We do nothing here - log_recent_added() suffices.
 150  */
 151 static void log_recent_removed(void attribute((unused)) *v,
 152                                const char attribute((unused)) *id) {
 153   /* nothing - log_recent_added() will trigger the relevant update */
 154 }
 155
 156 /** @brief Called when a track is removed from the queue */
 157 static void log_removed(void attribute((unused)) *v,
 158                         const char attribute((unused)) *id,
 159                         const char attribute((unused)) *user) {
 160   queue_update();
 161 }
 162
 163 /** @brief Called when the current track is scratched */
 164 static void log_scratched(void attribute((unused)) *v,
 165                           const char attribute((unused)) *track,
 166                           const char attribute((unused)) *user) {
 167   playing = 0;
 168   playing_update();
 169 }
 170
 171 /** @brief Called when a state change occurs */
 172 static void log_state(void attribute((unused)) *v,
 173                       unsigned long state) {
 174   const struct monitor *m;
 175   unsigned long changes = state ^ last_state;
 176   static int first = 1;
 177
 178   if(first) {
 179     changes = -1UL;
 180     first = 0;
 181   }
 182   D(("log_state old=%s new=%s changed=%s",
 183      disorder_eclient_interpret_state(last_state),
 184      disorder_eclient_interpret_state(state),
 185      disorder_eclient_interpret_state(changes)));
 186   last_state = state;
 187   /* Tell anything that cares about the state change */
 188   for(m = monitors; m; m = m->next) {
 189     if(changes & m->mask)
 190       m->callback(m->u);
 191   }
 192   /* If the track is paused or resume then the currently playing track is
 193    * refetched so that we can continue to correctly calculate the played so-far
 194    * field */
 195   playing_update();
 196 }
 197
 198 /** @brief Called when volume changes */
 199 static void log_volume(void attribute((unused)) *v,
 200                        int l, int r) {
 201   if(volume_l != l || volume_r != r) {
 202     volume_l = l;
 203     volume_r = r;
 204     volume_update();
 205   }
 206 }
 207
 208 /** @brief Add a monitor to the list */
 209 void register_monitor(monitor_callback *callback,
 210                       void *u,
 211                       unsigned long mask) {
 212   struct monitor *m = xmalloc(sizeof *m);
 213
 214   m->next = monitors;
 215   m->mask = mask;
 216   m->callback = callback;
 217   m->u = u;
 218   monitors = m;
 219 }
 220
 221 /*
 222 Local Variables:
 223 c-basic-offset:2
 224 comment-column:40
 225 fill-column:79
 226 indent-tabs-mode:nil
 227 End:
 228 */