Changeset 734 for trunk/libffado/src/libstreaming

Timestamp:

11/28/07 05:03:31 (15 years ago)

Author:

ppalmers

Message:

merge ppalmers-streaming branch

Files:

• trunk/libffado/src/libstreaming/amdtp (copied) (copied from branches/ppalmers-streaming/src/libstreaming/amdtp)
• trunk/libffado/src/libstreaming/AmdtpPort.cpp (deleted)
• trunk/libffado/src/libstreaming/AmdtpPort.h (deleted)
• trunk/libffado/src/libstreaming/AmdtpPortInfo.cpp (deleted)
• trunk/libffado/src/libstreaming/AmdtpPortInfo.h (deleted)
• trunk/libffado/src/libstreaming/AmdtpSlaveStreamProcessor.cpp (deleted)
• trunk/libffado/src/libstreaming/AmdtpSlaveStreamProcessor.h (deleted)
• trunk/libffado/src/libstreaming/AmdtpStreamProcessor.cpp (deleted)
• trunk/libffado/src/libstreaming/AmdtpStreamProcessor.h (deleted)
• trunk/libffado/src/libstreaming/cip.c (deleted)
• trunk/libffado/src/libstreaming/cip.h (deleted)
• trunk/libffado/src/libstreaming/cycletimer.h (deleted)
• trunk/libffado/src/libstreaming/generic (copied) (copied from branches/ppalmers-streaming/src/libstreaming/generic)
• trunk/libffado/src/libstreaming/IsoHandler.cpp (deleted)
• trunk/libffado/src/libstreaming/IsoHandler.h (deleted)
• trunk/libffado/src/libstreaming/IsoHandlerManager.cpp (deleted)
• trunk/libffado/src/libstreaming/IsoHandlerManager.h (deleted)
• trunk/libffado/src/libstreaming/IsoStream.cpp (deleted)
• trunk/libffado/src/libstreaming/IsoStream.h (deleted)
• trunk/libffado/src/libstreaming/motu (copied) (copied from branches/ppalmers-streaming/src/libstreaming/motu)
• trunk/libffado/src/libstreaming/MotuPort.cpp (deleted)
• trunk/libffado/src/libstreaming/MotuPort.h (deleted)
• trunk/libffado/src/libstreaming/MotuPortInfo.cpp (deleted)
• trunk/libffado/src/libstreaming/MotuPortInfo.h (deleted)
• trunk/libffado/src/libstreaming/MotuStreamProcessor.cpp (deleted)
• trunk/libffado/src/libstreaming/MotuStreamProcessor.h (deleted)
• trunk/libffado/src/libstreaming/Port.cpp (deleted)
• trunk/libffado/src/libstreaming/Port.h (deleted)
• trunk/libffado/src/libstreaming/PortManager.cpp (deleted)
• trunk/libffado/src/libstreaming/PortManager.h (deleted)
• trunk/libffado/src/libstreaming/StreamProcessor.cpp (deleted)
• trunk/libffado/src/libstreaming/StreamProcessor.h (deleted)
• trunk/libffado/src/libstreaming/StreamProcessorManager.cpp (modified) (24 diffs)
• trunk/libffado/src/libstreaming/StreamProcessorManager.h (modified) (7 diffs)
• trunk/libffado/src/libstreaming/util (copied) (copied from branches/ppalmers-streaming/src/libstreaming/util)

trunk/libffado/src/libstreaming/StreamProcessorManager.cpp

@@ -23 +23 @@
-
-#include "StreamProcessorManager.h"
-
-
+
+
+
+
-#include <errno.h>
-#include <assert.h>
-
-
-
-
+
-
-#define RUNNING_TIMEOUT_MSEC 4000
@@ -36 +35 @@
-#define ENABLE_TIMEOUT_MSEC 4000
-
-
-
+
+
+
+
+
+
-
-namespace Streaming {
-
-NORMAL
-
-
+VERBOSE
+
+framerate, unsigned int 
-    : m_is_slave( false )
-    , m_SyncSource(NULL)
-    , m_nb_buffers(nb_buffers)
-    , m_period(period)
+    , m_nominal_framerate ( framerate )
-    , m_xruns(0)
-    , m_isoManager(0)
@@ -57 +61 @@
-StreamProcessorManager::~StreamProcessorManager() {
-    if (m_isoManager) delete m_isoManager;
-
-}
-
@@ -77 +80 @@
-    assert(m_isoManager);
-
-==StreamProcessor::E
+ == StreamProcessor::ePT
-        processor->setVerboseLevel(getDebugLevel()); // inherit debug level
-
-        m_ReceiveProcessors.push_back(processor);
-
-        processor->setManager(this);
-
-        return true;
-    }
-
-==StreamProcessor::E
+ == StreamProcessor::ePT
-        processor->setVerboseLevel(getDebugLevel()); // inherit debug level
-
-        m_TransmitProcessors.push_back(processor);
-
-        processor->setManager(this);
-
-        return true;
-    }
-
-    debugFatal("Unsupported processor type!\n");
-
-    return false;
-}
@@ -107 +105 @@
-    assert(processor);
-
-E
+ePT
-
-        for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
-
-++it ) {
-
+  
+  ++it )
+
-            if ( *it == processor ) {
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
-                }
-
-
-
-
+
+
+
+
+
+
-        for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
-
-++it ) {
-
+  
+  ++it )
+
-            if ( *it == processor ) {
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
-                }
+                return true;
+            }
-        }
-    }
-
-    debugFatal("Processor (%p) not found!\n",processor);
-
-    return false; //not found
-
-}
-
-bool StreamProcessorManager::setSyncSource(StreamProcessor *s) {
-    debugOutput( DEBUG_LEVEL_VERBOSE, "Setting sync source to (%p)\n", s);
-
-    m_SyncSource=s;
-    return true;
-}
-
-StreamProcessor *StreamProcessorManager::getSyncSource() {
-    return m_SyncSource;
-}
-
@@ -172 +153 @@
-{
-    debugOutput( DEBUG_LEVEL_VERBOSE, "enter...\n");
-
-
-
+
-    if(!m_isoManager) {
-        debugFatal("Could not create IsoHandlerManager\n");
-        return false;
-    }
-
-    // propagate the debug level
-    m_isoManager->setVerboseLevel(getDebugLevel());
+    
+    // try to queue up 75% of the frames in the transmit buffer
+    unsigned int nb_frames = (getNbBuffers() - 1) * getPeriodSize() * 1000 / 2000;
+    m_isoManager->setTransmitBufferNbFrames(nb_frames);
-
-    if(!m_isoManager->init()) {
@@ -189 +170 @@
-
-    m_xrun_happened=false;
-
-    return true;
-}
@@ -207 +187 @@
-    }
-
+    // FIXME: put into separate method
+    for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
+          it != m_ReceiveProcessors.end();
+          ++it )
+    {
+        if(m_SyncSource == NULL) {
+            debugWarning(" => Sync Source is %p.\n", *it);
+            m_SyncSource = *it;
+        }
+    }
+    for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
+          it != m_TransmitProcessors.end();
+          ++it )
+    {
+        if(m_SyncSource == NULL) {
+            debugWarning(" => Sync Source is %p.\n", *it);
+            m_SyncSource = *it;
+        }
+    }
+
+    // now do the actual preparation of the SP's
+    debugOutput( DEBUG_LEVEL_VERBOSE, "Prepare Receive processors...\n");
-    for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
-        it != m_ReceiveProcessors.end();
-        ++it ) {
-            if(m_SyncSource == NULL) {
-                debugWarning(" => Sync Source is %p.\n", *it);
-                m_SyncSource = *it;
-            }
-    }
-
-    for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
-        it != m_TransmitProcessors.end();
-        ++it ) {
-            if(m_SyncSource == NULL) {
-                debugWarning(" => Sync Source is %p.\n", *it);
-                m_SyncSource = *it;
-            }
-    }
-
-    // now do the actual preparation
-    debugOutput( DEBUG_LEVEL_VERBOSE, "Prepare Receive processors...\n");
-    for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
-        it != m_ReceiveProcessors.end();
-        ++it ) {
-
-        if(!(*it)->setSyncSource(m_SyncSource)) {
-            debugFatal(  " could not set sync source (%p)...\n",(*it));
-            return false;
-        }
-
-        if(!(*it)->setOption("slaveMode", m_is_slave)) {
@@ -245 +222 @@
-        }
-    }
-
-    debugOutput( DEBUG_LEVEL_VERBOSE, "Prepare Transmit processors...\n");
-    for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
-        it != m_TransmitProcessors.end();
-        ++it ) {
-        if(!(*it)->setSyncSource(m_SyncSource)) {
-            debugFatal(  " could not set sync source (%p)...\n",(*it));
-            return false;
-        }
-        if(!(*it)->setOption("slaveMode", m_is_slave)) {
-            debugOutput(DEBUG_LEVEL_VERBOSE, " note: could not set slaveMode option for (%p)...\n",(*it));
@@ -269 +241 @@
-        return false;
-    }
-
-    return true;
-}
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-        for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
-                it != m_ReceiveProcessors.end();
-                ++it ) {
-
-
-
+
+
-        for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
-                it != m_TransmitProcessors.end();
-                ++it ) {
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
-        for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
-                it != m_ReceiveProcessors.end();
-                ++it ) {
-
-
-
-
-
-
-
+
+
+
-        for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
-                it != m_TransmitProcessors.end();
-                ++it ) {
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-    debugOutput( DEBUG_LEVEL_VERBOSE, " StreamProcessor streams running...\n");
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-    return true;
-}
@@ -405 +533 @@
-    debugOutput( DEBUG_LEVEL_VERBOSE, " Receive processors...\n");
-    for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
-    debugOutput( DEBUG_LEVEL_VERBOSE, " Transmit processors...\n");
-    for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
-
-    debugOutput( DEBUG_LEVEL_VERBOSE, "Preparing IsoHandlerManager...\n");
@@ -437 +558 @@
-    }
-
-    debugOutput( DEBUG_LEVEL_VERBOSE, "Disabling StreamProcessors...\n");
-        if (!disableStreamProcessors()) {
-        debugFatal("Could not disable StreamProcessors...\n");
-        return false;
-    }
-
-    debugOutput( DEBUG_LEVEL_VERBOSE, "Starting IsoHandlers...\n");
-    if (!m_isoManager->startHandlers(-1)) {
@@ -449 +564 @@
-    }
-
+    // put all SP's into dry-running state
+    if (!startDryRunning()) {
+        debugFatal("Could not put SP's in dry-running state\n");
+        return false;
+    }
+
-    // start all SP's synchonized
-    if (!syncStartAll()) {
@@ -461 +582 @@
-
-    return true;
-
-}
-
@@ -468 +588 @@
-    assert(m_isoManager);
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-        for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
-            it != m_ReceiveProcessors.end();
-            ++it ) {
-
-
-
+
+
-        for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
-            it != m_TransmitProcessors.end();
-            ++it ) {
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-
-    debugOutput( DEBUG_LEVEL_VERBOSE, "Stopping handlers...\n");
@@ -503 +680 @@
-    debugOutput( DEBUG_LEVEL_VERBOSE, " Receive processors...\n");
-    for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
-    debugOutput( DEBUG_LEVEL_VERBOSE, " Transmit processors...\n");
-    for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
-    return true;
-}
@@ -733 +709 @@
-
-    debugOutput( DEBUG_LEVEL_VERBOSE, "Handling Xrun ...\n");
+
+    dumpInfo();
-
-    /*
@@ -743 +721 @@
-     * 3) Re-enable the SP's
-     */
-
-
-
+
+
+
+
-        return false;
-    }
@@ -771 +750 @@
-bool StreamProcessorManager::waitForPeriod() {
-    int time_till_next_period;
-=
+ = 
-
-    debugOutput( DEBUG_LEVEL_VERY_VERBOSE, "enter...\n");
@@ -799 +778 @@
-            xrun_occurred |= (*it)->xrunOccurred();
-        }
+        if(xrun_occurred) break;
-
-        // check if we were waked up too soon
-
-
-
-
-
-
-
-
+
+
-
-    // we save the 'ideal' time of the transfer at this point,
@@ -816 +790 @@
-    // NOTE: before waitForPeriod() is called again, both the transmit
-    //       and the receive processors should have done their transfer.
-=
+ = 
-    debugOutput( DEBUG_LEVEL_VERY_VERBOSE, "transfer at %llu ticks...\n",
-        m_time_of_transfer);
+
+    // normally we can transfer frames at this time, but in some cases this is not true
+    // e.g. when there are not enough frames in the receive buffer.
+    // however this doesn't have to be a problem, since we can wait some more until we
+    // have enough frames. There is only a problem once the ISO xmit doesn't have packets
+    // to transmit, or if the receive buffer overflows. These conditions are signaled by
+    // the iso threads
+    // check if xruns occurred on the Iso side.
+    // also check if xruns will occur should we transfer() now
+    #ifdef DEBUG
+    int waited = 0;
+    #endif
+    bool ready_for_transfer = false;
+    xrun_occurred = false;
+    while (!ready_for_transfer && !xrun_occurred) {
+        ready_for_transfer = true;
+        for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
+            it != m_ReceiveProcessors.end();
+            ++it ) {
+            ready_for_transfer &= ((*it)->canClientTransferFrames(m_period));
+            xrun_occurred |= (*it)->xrunOccurred();
+        }
+        for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
+            it != m_TransmitProcessors.end();
+            ++it ) {
+            ready_for_transfer &= ((*it)->canClientTransferFrames(m_period));
+            xrun_occurred |= (*it)->xrunOccurred();
+        }
+        if (!ready_for_transfer) {
+            usleep(125); // MAGIC: one cycle sleep...
+
+            // in order to avoid this in the future, we increase the sync delay of the sync source SP
+            int d = m_SyncSource->getSyncDelay() + TICKS_PER_CYCLE;
+            m_SyncSource->setSyncDelay(d);
+
+            #ifdef DEBUG
+            waited++;
+            #endif
+        }
+    } // we are either ready or an xrun occurred
+
+    #ifdef DEBUG
+    if(waited > 0) {
+        debugOutput(DEBUG_LEVEL_VERBOSE, "Waited %d x 125us due to SP not ready for transfer\n", waited);
+    }
+    #endif
+
+    // this is to notify the client of the delay that we introduced by waiting
+    m_delayed_usecs = - m_SyncSource->getTimeUntilNextPeriodSignalUsecs();
+    debugOutput( DEBUG_LEVEL_VERY_VERBOSE, "delayed for %d usecs...\n", m_delayed_usecs);
-
-#ifdef DEBUG
@@ -833 +857 @@
-    }
-    debugOutput( DEBUG_LEVEL_VERY_VERBOSE, "XF at %011llu ticks, RBF=%d, XBF=%d, SUM=%d...\n",
-
-
-
-
-
+
-
-    // check if xruns occurred on the Iso side.
-    // also check if xruns will occur should we transfer() now
-
-    for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
-          it != m_ReceiveProcessors.end();
-          ++it ) {
-
-
-
-
-
-
-
+
-        if ((*it)->xrunOccurred()) {
-
+side 
-            (*it)->dumpInfo();
-        }
-        if (!((*it)->canClientTransferFrames(m_period))) {
-
+side 
-            (*it)->dumpInfo();
-        }
-#endif
-
-    }
-    for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
-          it != m_TransmitProcessors.end();
-          ++it ) {
-        // a xrun has occurred on the Iso side
-        xrun_occurred |= (*it)->xrunOccurred();
-
-        // if this is true, a xrun will occur
-        xrun_occurred |= !((*it)->canClientTransferFrames(m_period));
-
-#ifdef DEBUG
-        if ((*it)->xrunOccurred()) {
-
+side 
-        }
-        if (!((*it)->canClientTransferFrames(m_period))) {
-
-
+
+
+
-#endif
-    }
-
-    m_nbperiods++;
-
-    // now we can signal the client that we are (should be) ready
-    return !xrun_occurred;
@@ -896 +899 @@
- */
-bool StreamProcessorManager::transfer() {
-
-
-
-
-
-
-
+
+
+
+
+
-}
-
@@ -913 +914 @@
- * @return true if successful, false otherwise (indicates xrun).
- */
-
-
-
-
+
+
+
+
+
+
+
+
-    // a static cast could make sure that there is no performance
-    // penalty for the virtual functions (to be checked)
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
-        for ( StreamProcessorVectorIterator it = m_ReceiveProcessors.begin();
-                it != m_ReceiveProcessors.end();
-                ++it ) {
-
-
-
+
+
-                            m_period, m_time_of_transfer,*it);
-
-
-
+
+
-        }
-    } else {
+        // FIXME: in the SPM it would be nice to have system time instead of
+        //        1394 time
+        float rate = m_SyncSource->getTicksPerFrame();
+        int64_t one_ringbuffer_in_ticks=(int64_t)(((float)(m_nb_buffers * m_period)) * rate);
+
+        // the data we are putting into the buffer is intended to be transmitted
+        // one ringbuffer size after it has been received
+        int64_t transmit_timestamp = addTicks(m_time_of_transfer, one_ringbuffer_in_ticks);
+
-        for ( StreamProcessorVectorIterator it = m_TransmitProcessors.begin();
-                it != m_TransmitProcessors.end();
-                ++it ) {
-
-
-
-
-
-
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-}
-

trunk/libffado/src/libstreaming/StreamProcessorManager.h

@@ -25 +25 @@
-#define __FFADO_STREAMPROCESSORMANAGER__
-
+#include "generic/Port.h"
+#include "generic/StreamProcessor.h"
+#include "util/IsoHandlerManager.h"
+
-#include "debugmodule/debugmodule.h"
-#include "libutil/Thread.h"
-#include "libutil/OptionContainer.h"
-#include <semaphore.h>
-#include "Port.h"
-#include "StreamProcessor.h"
-#include "IsoHandlerManager.h"
-
-#include <vector>
+#include <semaphore.h>
-
-namespace Streaming {
@@ -52 +53 @@
-public:
-
-
+rate, unsigned int 
-    virtual ~StreamProcessorManager();
-
@@ -61 +62 @@
-    bool stop();
-
+    bool startDryRunning();
-    bool syncStartAll();
-
@@ -67 +69 @@
-    bool unregisterProcessor(StreamProcessor *processor); ///< stop managing a streamprocessor
-
-    bool enableStreamProcessors(uint64_t time_to_enable_at); /// enable registered StreamProcessors
-    bool disableStreamProcessors(); /// disable registered StreamProcessors
-
-    void setPeriodSize(unsigned int period);
-    void setPeriodSize(unsigned int period, unsigned int nb_buffers);
-
+unsigned 
-
-    void setNbBuffers(unsigned int nb_buffers);
@@ -82 +81 @@
-
-    // the client-side functions
+    bool waitForPeriod();
+    bool transfer();
+    bool transfer(enum StreamProcessor::eProcessorType);
+private:
+    bool transferSilence();
+    bool transferSilence(enum StreamProcessor::eProcessorType);
-
-
-
-
-
-
+
+
-    int getDelayedUsecs() {return m_delayed_usecs;};
-    bool xrunOccurred();
-    int getXrunCount() {return m_xruns;};
+
+    unsigned int getNominalRate() {return m_nominal_framerate;};
+    uint64_t getTimeOfLastTransfer() { return m_time_of_transfer;};
-
-private:
@@ -116 +121 @@
-public:
-    bool setSyncSource(StreamProcessor *s);
-
+
+
-
-protected:
@@ -132 +138 @@
-    unsigned int m_nb_buffers;
-    unsigned int m_period;
+    unsigned int m_nominal_framerate;
-    unsigned int m_xruns;
-