comparison data/fft/FFTDataServer.cpp @ 193:bf1f256864de

* A start to a panner widget to go with thumbwheels

 #include "base/StorageAdviser.h"
 #include "base/Profiler.h"
 
 
 #define DEBUG_FFT_SERVER 1
-//#define DEBUG_FFT_SERVER_FILL 1
+#define DEBUG_FFT_SERVER_FILL 1
 
 #ifdef DEBUG_FFT_SERVER_FILL
 #ifndef DEBUG_FFT_SERVER
 #define DEBUG_FFT_SERVER 1
 #endif

     m_fftInput(0),
     m_exiting(false),
     m_suspended(true), //!!! or false?
     m_fillThread(0)
 {
+#ifdef DEBUG_FFT_SERVER
+    std::cerr << "FFTDataServer(" << this << " [" << (void *)QThread::currentThreadId() << "])::FFTDataServer" << std::endl;
+#endif
+
     size_t start = m_model->getStartFrame();
     size_t end = m_model->getEndFrame();
 
     m_width = (end - start) / m_windowIncrement + 1;
     m_height = m_fftSize / 2;

 }
 
 FFTDataServer::~FFTDataServer()
 {
 #ifdef DEBUG_FFT_SERVER
-    std::cerr << "FFTDataServer(" << this << ")::~FFTDataServer()" << std::endl;
+    std::cerr << "FFTDataServer(" << this << " [" << (void *)QThread::currentThreadId() << "])::~FFTDataServer()" << std::endl;
 #endif
 
     m_suspended = false;
     m_exiting = true;
     m_condition.wakeAll();

 }
 
 void
 FFTDataServer::deleteProcessingData()
 {
+#ifdef DEBUG_FFT_SERVER
+    std::cerr << "FFTDataServer(" << this << " [" << (void *)QThread::currentThreadId() << "]): deleteProcessingData" << std::endl;
+#endif
     if (m_fftInput) {
         fftwf_destroy_plan(m_fftPlan);
         fftwf_free(m_fftInput);
         fftwf_free(m_fftOutput);
         fftwf_free(m_workbuffer);

 
 void
 FFTDataServer::suspend()
 {
 #ifdef DEBUG_FFT_SERVER
-    std::cerr << "FFTDataServer(" << this << "): suspend" << std::endl;
+    std::cerr << "FFTDataServer(" << this << " [" << (void *)QThread::currentThreadId() << "]): suspend" << std::endl;
 #endif
     Profiler profiler("FFTDataServer::suspend", false);
 
     QMutexLocker locker(&m_writeMutex);
     m_suspended = true;

 
 void
 FFTDataServer::suspendWrites()
 {
 #ifdef DEBUG_FFT_SERVER
-    std::cerr << "FFTDataServer(" << this << "): suspendWrites" << std::endl;
+    std::cerr << "FFTDataServer(" << this << " [" << (void *)QThread::currentThreadId() << "]): suspendWrites" << std::endl;
 #endif
     Profiler profiler("FFTDataServer::suspendWrites", false);
 
     m_suspended = true;
 }
 
 void
 FFTDataServer::resume()
 {
 #ifdef DEBUG_FFT_SERVER
-    std::cerr << "FFTDataServer(" << this << "): resume" << std::endl;
+    std::cerr << "FFTDataServer(" << this << " [" << (void *)QThread::currentThreadId() << "]): resume" << std::endl;
 #endif
     Profiler profiler("FFTDataServer::resume", false);
 
     m_suspended = false;
     if (m_fillThread) {

 
 FFTCache *
 FFTDataServer::getCacheAux(size_t c)
 {
     Profiler profiler("FFTDataServer::getCacheAux", false);
+#ifdef DEBUG_FFT_SERVER
+    std::cerr << "FFTDataServer(" << this << " [" << (void *)QThread::currentThreadId() << "])::getCacheAux" << std::endl;
+#endif
 
     QMutexLocker locker(&m_writeMutex);
 
     if (m_lastUsedCache == -1) {
         m_fillThread->start();

 	for (size_t i = 0; i < pfx; ++i) {
 	    m_fftInput[off + i] = 0.0;
 	}
     }
 
+    std::cerr << "FFTDataServer::fillColumn: requesting frames "
+              << startFrame + pfx << " -> " << endFrame << " ( = "
+              << endFrame - (startFrame + pfx) << ") at index "
+              << off + pfx << " in buffer of size " << m_fftSize
+              << " with window size " << m_windowSize 
+              << " from channel " << m_channel << std::endl;
+
     size_t got = m_model->getValues(m_channel, startFrame + pfx,
 				    endFrame, m_fftInput + off + pfx);
 
     while (got + pfx < m_windowSize) {
 	m_fftInput[off + got + pfx] = 0.0;

 
             if (m_server.m_exiting) return;
 
             while (m_server.m_suspended) {
 #ifdef DEBUG_FFT_SERVER
-                std::cerr << "FFTDataServer(" << this << "): suspended, waiting..." << std::endl;
+                std::cerr << "FFTDataServer(" << this << " [" << (void *)QThread::currentThreadId() << "]): suspended, waiting..." << std::endl;
 #endif
                 m_server.m_writeMutex.lock();
                 m_server.m_condition.wait(&m_server.m_writeMutex, 10000);
                 m_server.m_writeMutex.unlock();
 #ifdef DEBUG_FFT_SERVER
-                std::cerr << "FFTDataServer(" << this << "): waited" << std::endl;
+                std::cerr << "FFTDataServer(" << this << " [" << (void *)QThread::currentThreadId() << "]): waited" << std::endl;
 #endif
                 if (m_server.m_exiting) return;
             }
 
             if (++counter == updateAt) {

 
         if (m_server.m_exiting) return;
 
         while (m_server.m_suspended) {
 #ifdef DEBUG_FFT_SERVER
-            std::cerr << "FFTDataServer(" << this << "): suspended, waiting..." << std::endl;
+            std::cerr << "FFTDataServer(" << this << " [" << (void *)QThread::currentThreadId() << "]): suspended, waiting..." << std::endl;
 #endif
             m_server.m_writeMutex.lock();
             m_server.m_condition.wait(&m_server.m_writeMutex, 10000);
             m_server.m_writeMutex.unlock();
             if (m_server.m_exiting) return;