Changeset 395 for branches/streaming-rework/src/libstreaming/StreamProcessorManager.cpp

Timestamp:

02/16/07 02:35:25 (16 years ago)

Author:

pieterpalmers

Message:

debugmodule.cpp:
- removed path from the source file name when printing debug messages

IsoStream?.cpp, StreamProcessor?.cpp:
- debug message modifications

StreamProcessorManager?.cpp:
- removed obsolete debug code

AmdtpStreamProcessor?.cpp:
- debug message modifications
- removed DLL that calculates framerate, as it is also calculated in the

TimestampedBuffer?

- converted code to use the new offset feature of the TimestampedBuffer?
- converted code to use the new frame timestamp calculation feature

of the TimestampedBuffer?

- first try at xmit sync code (unfinished)
- fixed 'unable to start' bug in receive SP

bebob_avdevice.cpp:
- added some #ifdef code to test with xmit SP's only (temporary)

TimestampedBuffer?.cpp:
- add offset feature
- add abitrary frame timestamp calculation

Files:

• branches/streaming-rework/src/libstreaming/StreamProcessorManager.cpp (modified) (4 diffs)

branches/streaming-rework/src/libstreaming/StreamProcessorManager.cpp

@@ -905 +905 @@
-                it != m_ReceiveProcessors.end();
-                ++it ) {
-            
-            //#ifdef DEBUG
-            #if 0
-            {
-                uint64_t ts_tail=0;
-                uint64_t fc_tail=0;
-                
-                uint64_t ts_head=0;
-                uint64_t fc_head=0;
-                
-                int cnt=0;
-                
-                (*it)->getBufferHeadTimestamp(&ts_head,&fc_head);
-                (*it)->getBufferTailTimestamp(&ts_tail,&fc_tail);
-                
-                while((fc_head != fc_tail) && (cnt++ < 10)) {
-                    (*it)->getBufferHeadTimestamp(&ts_head,&fc_head);
-                    (*it)->getBufferTailTimestamp(&ts_tail,&fc_tail);
-                }
-                
-                debugOutput(DEBUG_LEVEL_VERBOSE,"R => HEAD: TS=%11llu, FC=%5llu | TAIL: TS=%11llu, FC=%5llu, %d\n",
-                    ts_head, fc_head, ts_tail, fc_tail, cnt);
-            }
-            #endif
-    
-            if(!(*it)->getFrames(m_period)) {
-                    debugOutput(DEBUG_LEVEL_VERBOSE,"could not getFrames(%u, %11llu) from stream processor (%p)",
@@ -935 +911 @@
-                    return false; // buffer underrun
-            }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
-        }
-    } else {
@@ -965 +917 @@
-                it != m_TransmitProcessors.end();
-                ++it ) {
-                
-            //#ifdef DEBUG
-            #if 0
-            {
-                uint64_t ts_tail=0;
-                uint64_t fc_tail=0;
-                
-                uint64_t ts_head=0;
-                uint64_t fc_head=0;
-                
-                int cnt=0;
-                
-                (*it)->getBufferHeadTimestamp(&ts_head,&fc_head);
-                (*it)->getBufferTailTimestamp(&ts_tail,&fc_tail);
-                
-                while((fc_head != fc_tail) && (cnt++ < 10)) {
-                    (*it)->getBufferHeadTimestamp(&ts_head,&fc_head);
-                    (*it)->getBufferTailTimestamp(&ts_tail,&fc_tail);
-                }
-                
-                debugOutput(DEBUG_LEVEL_VERBOSE,"T => HEAD: TS=%11llu, FC=%5llu | TAIL: TS=%11llu, FC=%5llu, %d\n",
-                    ts_head, fc_head, ts_tail, fc_tail, cnt);
-            }
-            #endif
-                
-            if(!(*it)->putFrames(m_period, (int64_t)m_time_of_transfer)) {
@@ -995 +923 @@
-                return false; // buffer overrun
-            }
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
-
+
-        }
-    }