- Timestamp:
- 01/05/08 12:14:12 (16 years ago)
- Files:
-
- branches/api-cleanup/src/libstreaming/generic/PortManager.cpp (modified) (1 diff)
- branches/api-cleanup/src/libstreaming/generic/StreamProcessor.cpp (modified) (2 diffs)
- branches/api-cleanup/src/libutil/TimestampedBuffer.cpp (modified) (1 diff)
- branches/api-cleanup/src/libutil/TimestampedBuffer.h (modified) (2 diffs)
- branches/api-cleanup/tests/test-timestampedbuffer.cpp (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
branches/api-cleanup/src/libstreaming/generic/PortManager.cpp
r811 r813 36 36 37 37 PortManager::PortManager() { 38 39 38 } 40 39 branches/api-cleanup/src/libstreaming/generic/StreamProcessor.cpp
r811 r813 88 88 debugOutput(DEBUG_LEVEL_VERBOSE,"Could not unregister stream processor with the Iso manager\n"); 89 89 } 90 // make the threads leave the wait condition 91 POST_SEMAPHORE; 90 92 sem_destroy(&m_signal_semaphore); 91 92 // FIXME: how do we ensure that nobody is using us?93 93 94 94 if (m_data_buffer) delete m_data_buffer; … … 1277 1277 case ePS_Created: 1278 1278 assert(m_data_buffer); 1279 // object just created1280 result = m_data_buffer->init();1281 1279 1282 1280 // prepare the framerate estimate branches/api-cleanup/src/libutil/TimestampedBuffer.cpp
r807 r813 275 275 unsigned int TimestampedBuffer::getBufferSpace() { 276 276 return ffado_ringbuffer_write_space(m_event_buffer)/(m_bytes_per_frame); 277 }278 279 /**280 * \brief Initializes the TimestampedBuffer281 *282 * Initializes the TimestampedBuffer, should be called before anything else283 * is done.284 *285 * @return true if successful286 */287 bool TimestampedBuffer::init() {288 return true;289 277 } 290 278 branches/api-cleanup/src/libutil/TimestampedBuffer.h
r807 r813 89 89 virtual ~TimestampedBuffer(); 90 90 91 /**92 * @brief waits for the availability of frames (blocking)93 * @param nframes number of frames94 *95 * @return true if frames are available, false if not (e.g. signal occurred)96 */97 bool waitForFrames(unsigned int nframes);98 99 /**100 * @brief waits for the availability of frames (blocking)101 *102 * waits for one update period of frames103 *104 * @return true if frames are available, false if not (e.g. signal occurred)105 */106 bool waitForFrames();107 108 /**109 * @brief waits for the availability of frames (non-blocking)110 * @param nframes number of frames111 *112 * @return true if frames are available, false if not113 */114 bool tryWaitForFrames(unsigned int nframes);115 116 /**117 * @brief waits for the availability of frames (non-blocking)118 *119 * waits for one update period of frames120 *121 * @return true if frames are available, false if not122 */123 bool tryWaitForFrames();124 125 91 bool writeDummyFrame(); 126 92 bool dropFrames ( unsigned int nbframes ); … … 134 100 bool blockProcessReadFrames ( unsigned int nbframes ); 135 101 136 bool init();137 102 bool prepare(); 138 103 bool clearBuffer(); branches/api-cleanup/tests/test-timestampedbuffer.cpp
r783 r813 282 282 t->setVerboseLevel(arguments.verbose); 283 283 284 t->init();285 286 284 // Setup the buffer 287 285 t->setBufferSize(arguments.buffersize);