Changeset 706
- Timestamp:
- 11/04/07 05:15:42 (16 years ago)
- Files:
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
branches/ppalmers-streaming/src/libstreaming/generic/StreamProcessor.cpp
r705 r706 34 34 35 35 IMPL_DEBUG_MODULE( StreamProcessor, StreamProcessor, DEBUG_LEVEL_VERBOSE ); 36 IMPL_DEBUG_MODULE( ReceiveStreamProcessor, ReceiveStreamProcessor, DEBUG_LEVEL_VERBOSE );37 IMPL_DEBUG_MODULE( TransmitStreamProcessor, TransmitStreamProcessor, DEBUG_LEVEL_VERBOSE );38 36 39 37 StreamProcessor::StreamProcessor(enum IsoStream::EStreamType type, int port, int framerate) … … 84 82 m_data_buffer->dumpInfo(); 85 83 86 //m_PeriodStat.dumpInfo();87 //m_PacketStat.dumpInfo();88 //m_WakeupStat.dumpInfo();84 m_PeriodStat.dumpInfo(); 85 m_PacketStat.dumpInfo(); 86 m_WakeupStat.dumpInfo(); 89 87 90 88 } … … 298 296 } 299 297 300 ReceiveStreamProcessor::ReceiveStreamProcessor(int port, int framerate)301 : StreamProcessor(IsoStream::EST_Receive, port, framerate) {302 303 }304 305 ReceiveStreamProcessor::~ReceiveStreamProcessor() {306 307 }308 309 void ReceiveStreamProcessor::setVerboseLevel(int l) {310 setDebugLevel(l);311 StreamProcessor::setVerboseLevel(l);312 313 }314 315 298 uint64_t ReceiveStreamProcessor::getTimeAtPeriod() { 316 299 ffado_timestamp_t next_period_boundary=m_data_buffer->getTimestampFromHead(m_period); … … 334 317 } 335 318 336 TransmitStreamProcessor::TransmitStreamProcessor( int port, int framerate)337 : StreamProcessor(IsoStream::EST_Transmit, port, framerate) {338 339 }340 341 TransmitStreamProcessor::~TransmitStreamProcessor() {342 343 }344 345 void TransmitStreamProcessor::setVerboseLevel(int l) {346 setDebugLevel(l);347 StreamProcessor::setVerboseLevel(l);348 349 }350 351 319 uint64_t TransmitStreamProcessor::getTimeAtPeriod() { 352 320 ffado_timestamp_t next_period_boundary=m_data_buffer->getTimestampFromTail((m_nb_buffers-1) * m_period); branches/ppalmers-streaming/src/libstreaming/generic/StreamProcessor.h
r705 r706 242 242 243 243 public: 244 ReceiveStreamProcessor(int port, int framerate) ;245 246 virtual ~ReceiveStreamProcessor() ;244 ReceiveStreamProcessor(int port, int framerate) 245 : StreamProcessor(IsoStream::EST_Receive, port, framerate) {}; 246 virtual ~ReceiveStreamProcessor(){}; 247 247 248 248 … … 260 260 unsigned char channel, unsigned char tag, unsigned char sy, 261 261 unsigned int cycle, unsigned int dropped) = 0; 262 virtual void setVerboseLevel(int l);263 262 264 263 uint64_t getTimeAtPeriod(); … … 267 266 protected: 268 267 bool processWriteBlock(char *data, unsigned int nevents, unsigned int offset) {return true;}; 269 270 DECLARE_DEBUG_MODULE;271 272 268 }; 273 269 … … 279 275 280 276 public: 281 TransmitStreamProcessor(int port, int framerate) ;282 283 virtual ~TransmitStreamProcessor() ;277 TransmitStreamProcessor(int port, int framerate) 278 : StreamProcessor(IsoStream::EST_Transmit, port, framerate) {}; 279 virtual ~TransmitStreamProcessor() {}; 284 280 285 281 virtual enum EProcessorType getType() {return E_Transmit;}; … … 292 288 virtual bool getFramesDry(unsigned int nbframes, int64_t ts) {return false;}; 293 289 294 virtual void setVerboseLevel(int l);295 296 290 uint64_t getTimeAtPeriod(); 297 291 bool canClientTransferFrames(unsigned int nframes); … … 299 293 protected: 300 294 bool processReadBlock(char *data, unsigned int nevents, unsigned int offset) {return true;}; 301 302 DECLARE_DEBUG_MODULE;303 304 305 295 }; 306 296