Changeset 196 for fm_server/trunk/src/fm_input_cdj.c

Timestamp:

01/16/08 13:40:36 (4 years ago)

Author:

ath

Message:

Fixes for FmElement's new API.

Files:

• fm_server/trunk/src/fm_input_cdj.c (modified) (6 diffs)

fm_server/trunk/src/fm_input_cdj.c

@@ -64 +64 @@
 FmInputState fm_input_cdj_get_state     (FmInput        *input);
 static void fm_input_cdj_update_bpm     (FmInputCDJ     *input_cdj);
-static void fm_input_cdj_become_sync_master (FmElement  *element);
+static void fm_input_cdj_become_sync_master (FmElement  *element,
+                                         FmSync         *sync);
 static void fm_input_cdj_get_buffer     (FmElement      *element,
-                                         FmBuffer       *buffer);
+                                         FmBuffer       *buffer,
+                                         FmSync         *sync);
 static void fm_input_cdj_input_state_changed_cb (FmInput *input,
                                          FmInputState   state,
@@ -277 +279 @@
 
 static void
-fm_input_cdj_become_sync_master         (FmElement      *element)
-{
-#define BPM 120
+fm_input_cdj_become_sync_master         (FmElement      *element,
+                                         FmSync         *sync)
+{
         g_print ("FmInputCDJ has become sync master!\n");
 
-        FmSync *sync = fm_element_pipeline_get_sync_info (element);
-
-        sync->bpm = BPM;
+        sync->in_use = TRUE;
+
+        sync->bpm = 120.0;
         sync->beat_per_bar = 4;
 }
@@ -291 +293 @@
 static void
 fm_input_cdj_get_buffer                 (FmElement      *element,
-                                         FmBuffer       *buffer)
+                                         FmBuffer       *buffer,
+                                         FmSync         *sync)
 {
         FmInputCDJ *input_cdj = FM_INPUT_CDJ (element);
@@ -300 +303 @@
 
         
-        fm_element_get_buffer (FM_ELEMENT (input_cdj->rate), buffer);
+//      fm_element_get_buffer (FM_ELEMENT (input_cdj->rate), buffer, sync);
+        fm_element_get_buffer (FM_ELEMENT (input_cdj->input), buffer, sync);
+//      g_print ("went %lld nsec ahead\n", (long long int) FM_BUFFER_DURATION (buffer));
 
         //g_print ("Used %d samples\n", fm_effect_rate_input_frames_used (input_cdj->rate));
 
-//      if (fm_element_is_sync_master (element))
-//              fm_sync_master_played_samples (sync, fm_effect_rate_input_frames_used (input_cdj->rate));
+
+
+        if (fm_element_is_sync_master (element)) {
+                if (FM_BUFFER_DISCONT (buffer)) {
+                        g_print ("**************************************************************************************************\n");
+                        g_print ("DISCONT buffer! new pos %llu\n", (long long unsigned int) FM_BUFFER_TIMESTAMP (buffer));
+                        fm_sync_set (sync, 0, FM_BUFFER_TIMESTAMP (buffer));
+                        FM_BUFFER_DISCONT (buffer) = FALSE;
+                } else {
+                        fm_sync_master_played_ns (sync, FM_BUFFER_DURATION (buffer));
+                        fm_sync_update_cycle (sync);
+                }
+
+                if (FM_BUFFER_DURATION (buffer) > 0)
+                        fm_sync_show_pos (sync);
+        }
 }
 
@@ -453 +472 @@
                                          gint           value)
 {
-#define SAMPLES_FOR_UNIT 10000
+#define NSECS_FOR_UNIT (1000L * 1000 * 100)
 
         g_print ("A seek button pressed while ");
@@ -465 +484 @@
         g_return_if_fail (value != 0);
 
-        glong offset = value * SAMPLES_FOR_UNIT;
+        gint64 offset = value * NSECS_FOR_UNIT;
         fm_input_gst_seek_relative (input_cdj->input, offset);
 }