Changeset 5624:ec1593cc8525 in roaraudio for roard

Timestamp:

08/18/12 02:04:07 (12 years ago)

Author:

phi

Branch:

default

Phase:

public

Message:

Added support for RePlayGain? (RPG) control (See: #300)

Location:

roard

Files:

• codecfilter_flac.c (modified) (2 diffs)
• codecfilter_vorbis.c (modified) (2 diffs)
• include/roard.h (modified) (1 diff)
• include/streams.h (modified) (2 diffs)
• req.c (modified) (4 diffs)
• roard.c (modified) (1 diff)
• streams.c (modified) (2 diffs)

roard/codecfilter_flac.c

@@ -116 +116 @@
  const FLAC__StreamMetadata_VorbisComment * vc;
  FLAC__uint32 i;
+ struct roar_stream_rpg rpg;
  const char * key, * value;
  char keycopy[ROAR_META_MAX_NAMELEN];
  int type;
- float rpg_track = 0, rpg_album = 0;
+ float rpg_track = 0, rpg_album = 0, rpg_final = 0;
 
  if ( metadata->type == FLAC__METADATA_TYPE_VORBIS_COMMENT ) {
@@ -171 +172 @@
   }
 
- if ( rpg_album ) {
-  self->ss->mixer.rpg_div = 2718;  // = int(exp(1)*1000)
-  self->ss->mixer.rpg_mul = (float)rpg_album*2718;
- } else if ( rpg_track ) {
-  self->ss->mixer.rpg_div = 2718;
-  self->ss->mixer.rpg_mul = (float)rpg_track*2718;
+ if ( streams_get_rpg(ROAR_STREAM(self->ss)->id, &rpg) != -1 ) {
+  rpg_final = 0;
+
+  switch (rpg.mode) {
+   case ROAR_RPGMODE_NONE: rpg_final =  0.; break;
+   case ROAR_RPGMODE_USER: rpg_final = -1.; break;
+   case ROAR_RPGMODE_ALBUM: rpg_final = rpg_album; break;
+   case ROAR_RPGMODE_TRACK: rpg_final = rpg_track; break;
+   case ROAR_RPGMODE_ALBUMTRACK: rpg_final = rpg_album ? rpg_album : rpg_track; break;
+   case ROAR_RPGMODE_TRACKALBUM: rpg_final = rpg_track ? rpg_track : rpg_album; break;
+  }
+
+  if ( rpg_final > 0 ) {
+   self->ss->mixer.rpg_div = 2718;
+   self->ss->mixer.rpg_mul = (float)rpg_final*2718;
+  } else if ( !rpg_final ) {
+   self->ss->mixer.rpg_div = 1;
+   self->ss->mixer.rpg_mul = 1;
+  }
  }
 

roard/codecfilter_vorbis.c

@@ -305 +305 @@
  char key[ROAR_META_MAX_NAMELEN] = {0}, value[LIBROAR_BUFFER_MSGDATA] = {0};
  struct roar_stream * s = ROAR_STREAM(self->stream);
+ struct roar_stream_rpg rpg;
  int type;
  int j, h = 0;
- float rpg_track = 0, rpg_album = 0;
+ float rpg_track = 0, rpg_album = 0, rpg_final;
  int meta_ok;
 
@@ -373 +374 @@
  }
 
- if ( rpg_album ) {
-  self->stream->mixer.rpg_div = 2718;  // = int(exp(1)*1000)
-  self->stream->mixer.rpg_mul = (float)rpg_album*2718;
- } else if ( rpg_track ) {
-  self->stream->mixer.rpg_div = 2718;
-  self->stream->mixer.rpg_mul = (float)rpg_track*2718;
+ if ( streams_get_rpg(ROAR_STREAM(self->stream)->id, &rpg) != -1 ) {
+  rpg_final = 0;
+
+  switch (rpg.mode) {
+   case ROAR_RPGMODE_NONE: rpg_final =  0.; break;
+   case ROAR_RPGMODE_USER: rpg_final = -1.; break;
+   case ROAR_RPGMODE_ALBUM: rpg_final = rpg_album; break;
+   case ROAR_RPGMODE_TRACK: rpg_final = rpg_track; break;
+   case ROAR_RPGMODE_ALBUMTRACK: rpg_final = rpg_album ? rpg_album : rpg_track; break;
+   case ROAR_RPGMODE_TRACKALBUM: rpg_final = rpg_track ? rpg_track : rpg_album; break;
+  }
+
+  if ( rpg_final > 0 ) {
+   self->stream->mixer.rpg_div = 2718;
+   self->stream->mixer.rpg_mul = (float)rpg_final*2718;
+  } else if ( !rpg_final ) {
+   self->stream->mixer.rpg_div = 1;
+   self->stream->mixer.rpg_mul = 1;
+  }
  }
 

roard/include/roard.h

@@ -196 +196 @@
  uint32_t flags;
  struct {
-  uint32_t flags;
+  uint32_t                   flags;
   struct roar_mixer_settings mixer;
   int                        mixer_channels;
+  int                        rpgmode;
  } streams[ROAR_DIR_DIRIDS];
  char * location;

roard/include/streams.h

@@ -116 +116 @@
  size_t single_sink_c;
  size_t single_sink_self_c;
+ int rpgmode;
 } * g_streams[ROAR_STREAMS_MAX];
 
@@ -177 +178 @@
 int streams_set_map      (int id, char * map, size_t len);
 
+int streams_get_rpg      (int id, struct roar_stream_rpg * rpg);
+int streams_set_rpg      (int id, const struct roar_stream_rpg * rpg);
+
 int streams_ltm_ctl      (int id, int mt, int window, int cmd);
 int streams_ltm_calc     (int id, struct roar_audio_info * info, void * data, size_t len);

roard/req.c

@@ -1118 +1118 @@
  struct roar_audio_info * audio_info;
  struct roar_stream_ltm * ltm;
+ struct roar_stream_rpg   rpg;
  uint16_t * d  = (uint16_t *) mes->data;
  int64_t * d64 = ( int64_t *) mes->data;
@@ -1348 +1349 @@
    break;
 
+  case ROAR_STREAM_PARA_RPG:
+    if ( streams_get_rpg(mes->stream, &rpg) == -1 ) {
+     return -1;
+    }
+
+    mes->datalen = 2*5;
+
+    d[2] = rpg.mode;
+    d[3] = rpg.mul;
+    d[4] = rpg.div;
+
+    for (i = 0; i < mes->datalen/2; i++) {
+     d[i] = ROAR_HOST2NET16(d[i]);
+    }
+   break;
+
   default:
     ROAR_WARN("req_on_get_stream_para(*): unsupported command: %i", d[1]);
@@ -1360 +1377 @@
 int req_on_set_stream_para (int client, struct roar_message * mes, char ** data, uint32_t flags[2]) {
  struct roar_stream_server * ss;
+ struct roar_stream_rpg rpg;
  uint16_t * d = (uint16_t *) mes->data;
  uint32_t tmp, tmp2, flagstore;
@@ -1470 +1488 @@
     }
    break;
+  case ROAR_STREAM_PARA_RPG:
+    if ( mes->datalen != (5 * 2) )
+     return -1;
+
+    for (i = 2; i < mes->datalen/2; i++) {
+     d[i] = ROAR_NET2HOST16(d[i]);
+    }
+
+    rpg.mode = d[2];
+    rpg.mul  = d[3];
+    rpg.div  = d[4];
+
+    if ( streams_set_rpg(mes->stream, &rpg) == -1 )
+     return -1;
+   break;
   default:
     ROAR_WARN("req_on_set_stream_para(*): unsupported command version: %i, %i", d[0], d[1]);

roard/roard.c

@@ -523 +523 @@
   g_config->streams[i].mixer.scale    = 65535;
   g_config->streams[i].mixer.mixer[0] = g_config->streams[i].mixer.scale;
+  g_config->streams[i].rpgmode        = ROAR_RPGMODE_ALBUMTRACK;
  }
 

roard/streams.c

@@ -234 +234 @@
    s->mixerstream =  NULL;
 #endif
+
+   s->rpgmode = ROAR_RPGMODE_DEFAULT;
 
    //roardsp_fchain_init(&(s->fc));
@@ -1508 +1510 @@
 }
 
+int streams_get_rpg      (int id, struct roar_stream_rpg * rpg) {
+ _CHECK_SID(id);
+
+ if ( rpg == NULL ) {
+  roar_err_set(ROAR_ERROR_FAULT);
+  return -1;
+ }
+
+ rpg->mode = g_streams[id]->rpgmode;
+ rpg->mul  = g_streams[id]->mixer.rpg_mul;
+ rpg->div  = g_streams[id]->mixer.rpg_div;
+
+ if ( rpg->mode == ROAR_RPGMODE_DEFAULT )
+  rpg->mode = g_config->streams[ROAR_STREAM(g_streams[id])->dir].rpgmode;
+
+ return 0;
+}
+
+int streams_set_rpg      (int id, const struct roar_stream_rpg * rpg) {
+ int mode;
+
+ _CHECK_SID(id);
+
+ if ( rpg == NULL ) {
+  roar_err_set(ROAR_ERROR_FAULT);
+  return -1;
+ }
+
+ // test if we have a valid value at all.
+ if ( rpg->mode > ROAR_RPGMODE_TRACKALBUM || rpg->mode < ROAR_RPGMODE_DEFAULT ) {
+  roar_err_set(ROAR_ERROR_RANGE);
+  return -1;
+ }
+
+ mode = g_streams[id]->rpgmode = rpg->mode;
+
+ if ( mode == ROAR_RPGMODE_DEFAULT )
+  mode = g_config->streams[ROAR_STREAM(g_streams[id])->dir].rpgmode;
+
+ switch (mode) {
+  case ROAR_RPGMODE_NONE:
+    g_streams[id]->mixer.rpg_mul = 1;
+    g_streams[id]->mixer.rpg_div = 1;
+   break;
+  case ROAR_RPGMODE_USER:
+    g_streams[id]->mixer.rpg_mul = rpg->mul;
+    g_streams[id]->mixer.rpg_div = rpg->div;
+   break;
+ }
+
+ return 0;
+}
+
+
 int streams_ltm_ctl      (int id, int mt, int window, int cmd) {
  struct roar_stream_server * ss;