Changeset 419 for branches/streaming-rework/src
- Timestamp:
- 02/25/07 04:28:00 (16 years ago)
- Files:
-
- branches/streaming-rework/src/bebob/bebob_avdevice.cpp (modified) (17 diffs)
- branches/streaming-rework/src/bebob/bebob_avdevice.h (modified) (3 diffs)
- branches/streaming-rework/src/bounce/bounce_avdevice.cpp (modified) (12 diffs)
- branches/streaming-rework/src/bounce/bounce_avdevice.h (modified) (2 diffs)
- branches/streaming-rework/src/devicemanager.cpp (modified) (1 diff)
- branches/streaming-rework/src/devicemanager.h (modified) (2 diffs)
- branches/streaming-rework/src/dice/dice_avdevice.cpp (modified) (1 diff)
- branches/streaming-rework/src/dice/dice_avdevice.h (modified) (2 diffs)
- branches/streaming-rework/src/freebob_streaming.cpp (modified) (1 diff)
- branches/streaming-rework/src/iavdevice.h (modified) (3 diffs)
- branches/streaming-rework/src/libstreaming/AmdtpPort.cpp (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/AmdtpPort.h (modified) (2 diffs)
- branches/streaming-rework/src/libstreaming/AmdtpPortInfo.cpp (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/AmdtpPortInfo.h (modified) (2 diffs)
- branches/streaming-rework/src/libstreaming/AmdtpStreamProcessor.cpp (modified) (2 diffs)
- branches/streaming-rework/src/libstreaming/AmdtpStreamProcessor.h (modified) (2 diffs)
- branches/streaming-rework/src/libstreaming/IsoHandler.cpp (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/IsoHandler.h (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/IsoHandlerManager.cpp (modified) (3 diffs)
- branches/streaming-rework/src/libstreaming/IsoHandlerManager.h (modified) (3 diffs)
- branches/streaming-rework/src/libstreaming/IsoStream.cpp (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/IsoStream.h (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/MotuPort.cpp (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/MotuPort.h (modified) (2 diffs)
- branches/streaming-rework/src/libstreaming/MotuPortInfo.cpp (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/MotuPortInfo.h (modified) (2 diffs)
- branches/streaming-rework/src/libstreaming/MotuStreamProcessor.cpp (modified) (2 diffs)
- branches/streaming-rework/src/libstreaming/MotuStreamProcessor.h (modified) (2 diffs)
- branches/streaming-rework/src/libstreaming/Port.cpp (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/Port.h (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/PortManager.cpp (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/PortManager.h (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/StreamProcessor.cpp (modified) (2 diffs)
- branches/streaming-rework/src/libstreaming/StreamProcessor.h (modified) (3 diffs)
- branches/streaming-rework/src/libstreaming/StreamProcessorManager.cpp (modified) (1 diff)
- branches/streaming-rework/src/libstreaming/StreamProcessorManager.h (modified) (1 diff)
- branches/streaming-rework/src/libutil/DelayLockedLoop.cpp (modified) (1 diff)
- branches/streaming-rework/src/libutil/DelayLockedLoop.h (modified) (1 diff)
- branches/streaming-rework/src/libutil/OptionContainer.cpp (modified) (2 diffs)
- branches/streaming-rework/src/libutil/OptionContainer.h (modified) (2 diffs)
- branches/streaming-rework/src/libutil/PacketBuffer.cpp (modified) (1 diff)
- branches/streaming-rework/src/libutil/PacketBuffer.h (modified) (1 diff)
- branches/streaming-rework/src/libutil/PosixThread.cpp (modified) (1 diff)
- branches/streaming-rework/src/libutil/PosixThread.h (modified) (1 diff)
- branches/streaming-rework/src/libutil/StreamStatistics.cpp (modified) (1 diff)
- branches/streaming-rework/src/libutil/StreamStatistics.h (modified) (1 diff)
- branches/streaming-rework/src/libutil/SystemTimeSource.cpp (modified) (2 diffs)
- branches/streaming-rework/src/libutil/SystemTimeSource.h (modified) (2 diffs)
- branches/streaming-rework/src/libutil/test-dll.cpp (modified) (1 diff)
- branches/streaming-rework/src/libutil/Thread.h (modified) (1 diff)
- branches/streaming-rework/src/libutil/TimeSource.cpp (modified) (2 diffs)
- branches/streaming-rework/src/libutil/TimeSource.h (modified) (2 diffs)
- branches/streaming-rework/src/libutil/TimestampedBuffer.cpp (modified) (2 diffs)
- branches/streaming-rework/src/libutil/TimestampedBuffer.h (modified) (2 diffs)
- branches/streaming-rework/src/libutil/unittests.cpp (modified) (1 diff)
- branches/streaming-rework/src/metrichalo/mh_avdevice.cpp (modified) (2 diffs)
- branches/streaming-rework/src/metrichalo/mh_avdevice.h (modified) (1 diff)
- branches/streaming-rework/src/motu/motu_avdevice.cpp (modified) (16 diffs)
- branches/streaming-rework/src/motu/motu_avdevice.h (modified) (2 diffs)
- branches/streaming-rework/src/rme/rme_avdevice.cpp (modified) (1 diff)
- branches/streaming-rework/src/rme/rme_avdevice.h (modified) (1 diff)
Legend:
- Unmodified
- Added
- Removed
- Modified
- Copied
- Moved
branches/streaming-rework/src/bebob/bebob_avdevice.cpp
r418 r419 80 80 debugOutput( DEBUG_LEVEL_VERBOSE, "Created BeBoB::AvDevice (NodeID %d)\n", 81 81 nodeId ); 82 addOption( FreebobUtil::OptionContainer::Option("snoopMode",false));83 addOption( FreebobUtil::OptionContainer::Option("id",std::string("dev?")));82 addOption(Util::OptionContainer::Option("snoopMode",false)); 83 addOption(Util::OptionContainer::Option("id",std::string("dev?"))); 84 84 } 85 85 … … 93 93 , m_nodeId ( -1 ) 94 94 { 95 addOption( FreebobUtil::OptionContainer::Option("snoopMode",false));96 addOption( FreebobUtil::OptionContainer::Option("id",std::string("dev?")));95 addOption(Util::OptionContainer::Option("snoopMode",false)); 96 addOption(Util::OptionContainer::Option("id",std::string("dev?"))); 97 97 } 98 98 … … 990 990 991 991 // create & add streamprocessors 992 FreebobStreaming::StreamProcessor *p;992 Streaming::StreamProcessor *p; 993 993 994 p=new FreebobStreaming::AmdtpReceiveStreamProcessor(994 p=new Streaming::AmdtpReceiveStreamProcessor( 995 995 m_p1394Service->getPort(), 996 996 samplerate, … … 1004 1004 1005 1005 if (!addPlugToProcessor(*outputPlug,p, 1006 FreebobStreaming::Port::E_Capture)) {1006 Streaming::Port::E_Capture)) { 1007 1007 debugFatal("Could not add plug to processor!\n"); 1008 1008 delete p; … … 1015 1015 if (snoopMode) { 1016 1016 // we are snooping, so this is receive too. 1017 p=new FreebobStreaming::AmdtpReceiveStreamProcessor(1017 p=new Streaming::AmdtpReceiveStreamProcessor( 1018 1018 m_p1394Service->getPort(), 1019 1019 samplerate, 1020 1020 inputPlug->getNrOfChannels()); 1021 1021 } else { 1022 p=new FreebobStreaming::AmdtpTransmitStreamProcessor(1022 p=new Streaming::AmdtpTransmitStreamProcessor( 1023 1023 m_p1394Service->getPort(), 1024 1024 samplerate, … … 1035 1035 if (snoopMode) { 1036 1036 if (!addPlugToProcessor(*inputPlug,p, 1037 FreebobStreaming::Port::E_Capture)) {1037 Streaming::Port::E_Capture)) { 1038 1038 debugFatal("Could not add plug to processor!\n"); 1039 1039 return false; … … 1042 1042 } else { 1043 1043 if (!addPlugToProcessor(*inputPlug,p, 1044 FreebobStreaming::Port::E_Playback)) {1044 Streaming::Port::E_Playback)) { 1045 1045 debugFatal("Could not add plug to processor!\n"); 1046 1046 return false; … … 1055 1055 AvDevice::addPlugToProcessor( 1056 1056 AvPlug& plug, 1057 FreebobStreaming::StreamProcessor *processor,1058 FreebobStreaming::AmdtpAudioPort::E_Direction direction) {1057 Streaming::StreamProcessor *processor, 1058 Streaming::AmdtpAudioPort::E_Direction direction) { 1059 1059 1060 1060 std::string id=std::string("dev?"); … … 1080 1080 portname << id << "_" << channelInfo->m_name; 1081 1081 1082 FreebobStreaming::Port *p=NULL;1082 Streaming::Port *p=NULL; 1083 1083 switch(clusterInfo->m_portType) { 1084 1084 case ExtendedPlugInfoClusterInfoSpecificData::ePT_Speaker: … … 1087 1087 case ExtendedPlugInfoClusterInfoSpecificData::ePT_Line: 1088 1088 case ExtendedPlugInfoClusterInfoSpecificData::ePT_Analog: 1089 p=new FreebobStreaming::AmdtpAudioPort(1089 p=new Streaming::AmdtpAudioPort( 1090 1090 portname.str(), 1091 1091 direction, … … 1095 1095 channelInfo->m_streamPosition - 1, 1096 1096 channelInfo->m_location, 1097 FreebobStreaming::AmdtpPortInfo::E_MBLA1097 Streaming::AmdtpPortInfo::E_MBLA 1098 1098 ); 1099 1099 break; 1100 1100 1101 1101 case ExtendedPlugInfoClusterInfoSpecificData::ePT_MIDI: 1102 p=new FreebobStreaming::AmdtpMidiPort(1102 p=new Streaming::AmdtpMidiPort( 1103 1103 portname.str(), 1104 1104 direction, … … 1108 1108 channelInfo->m_streamPosition - 1, 1109 1109 channelInfo->m_location, 1110 FreebobStreaming::AmdtpPortInfo::E_Midi1110 Streaming::AmdtpPortInfo::E_Midi 1111 1111 ); 1112 1112 … … 1142 1142 } 1143 1143 1144 FreebobStreaming::StreamProcessor *1144 Streaming::StreamProcessor * 1145 1145 AvDevice::getStreamProcessorByIndex(int i) { 1146 1146 … … 1160 1160 if (i<(int)m_receiveProcessors.size()) { 1161 1161 int n=i; 1162 FreebobStreaming::StreamProcessor *p=m_receiveProcessors.at(n);1162 Streaming::StreamProcessor *p=m_receiveProcessors.at(n); 1163 1163 1164 1164 iso_channel=m_p1394Service->allocateIsoChannelCMP( … … 1176 1176 } else if (i<(int)m_receiveProcessors.size() + (int)m_transmitProcessors.size()) { 1177 1177 int n=i-m_receiveProcessors.size(); 1178 FreebobStreaming::StreamProcessor *p=m_transmitProcessors.at(n);1178 Streaming::StreamProcessor *p=m_transmitProcessors.at(n); 1179 1179 1180 1180 iso_channel=m_p1394Service->allocateIsoChannelCMP( … … 1199 1199 if (i<(int)m_receiveProcessors.size()) { 1200 1200 int n=i; 1201 FreebobStreaming::StreamProcessor *p=m_receiveProcessors.at(n);1201 Streaming::StreamProcessor *p=m_receiveProcessors.at(n); 1202 1202 1203 1203 // deallocate ISO channel … … 1212 1212 } else if (i<(int)m_receiveProcessors.size() + (int)m_transmitProcessors.size()) { 1213 1213 int n=i-m_receiveProcessors.size(); 1214 FreebobStreaming::StreamProcessor *p=m_transmitProcessors.at(n);1214 Streaming::StreamProcessor *p=m_transmitProcessors.at(n); 1215 1215 1216 1216 // deallocate ISO channel branches/streaming-rework/src/bebob/bebob_avdevice.h
r416 r419 71 71 72 72 virtual int getStreamCount(); 73 virtual FreebobStreaming::StreamProcessor *getStreamProcessorByIndex(int i);73 virtual Streaming::StreamProcessor *getStreamProcessorByIndex(int i); 74 74 75 75 virtual bool prepare(); … … 149 149 AvPlug::EAvPlugType type); 150 150 151 bool addPlugToProcessor( AvPlug& plug, FreebobStreaming::StreamProcessor *processor,152 FreebobStreaming::AmdtpAudioPort::E_Direction direction);151 bool addPlugToProcessor( AvPlug& plug, Streaming::StreamProcessor *processor, 152 Streaming::AmdtpAudioPort::E_Direction direction); 153 153 154 154 bool setSamplingFrequencyPlug( AvPlug& plug, … … 184 184 185 185 // streaming stuff 186 typedef std::vector< FreebobStreaming::StreamProcessor * > StreamProcessorVector;186 typedef std::vector< Streaming::StreamProcessor * > StreamProcessorVector; 187 187 StreamProcessorVector m_receiveProcessors; 188 188 StreamProcessorVector m_transmitProcessors; branches/streaming-rework/src/bounce/bounce_avdevice.cpp
r416 r419 67 67 debugOutput( DEBUG_LEVEL_VERBOSE, "Created Bounce::BounceDevice (NodeID %d)\n", 68 68 nodeId ); 69 addOption( FreebobUtil::OptionContainer::Option("snoopMode",false));70 addOption( FreebobUtil::OptionContainer::Option("id",std::string("dev?")));69 addOption(Util::OptionContainer::Option("snoopMode",false)); 70 addOption(Util::OptionContainer::Option("id",std::string("dev?"))); 71 71 } 72 72 … … 228 228 bool 229 229 BounceDevice::addPortsToProcessor( 230 FreebobStreaming::StreamProcessor *processor,231 FreebobStreaming::Port::E_Direction direction) {230 Streaming::StreamProcessor *processor, 231 Streaming::Port::E_Direction direction) { 232 232 233 233 debugOutput(DEBUG_LEVEL_VERBOSE,"Adding ports to processor\n"); … … 241 241 for (i=0;i<BOUNCE_NR_OF_CHANNELS;i++) { 242 242 char *buff; 243 asprintf(&buff,"%s%s_Port%d",id.c_str(),direction== FreebobStreaming::AmdtpAudioPort::E_Playback?"p":"c",i);244 245 FreebobStreaming::Port *p=NULL;246 p=new FreebobStreaming::AmdtpAudioPort(243 asprintf(&buff,"%s%s_Port%d",id.c_str(),direction==Streaming::AmdtpAudioPort::E_Playback?"p":"c",i); 244 245 Streaming::Port *p=NULL; 246 p=new Streaming::AmdtpAudioPort( 247 247 buff, 248 248 direction, … … 252 252 i, 253 253 0, 254 FreebobStreaming::AmdtpPortInfo::E_MBLA254 Streaming::AmdtpPortInfo::E_MBLA 255 255 ); 256 256 … … 285 285 286 286 // create & add streamprocessors 287 FreebobStreaming::StreamProcessor *p;288 289 p=new FreebobStreaming::AmdtpReceiveStreamProcessor(287 Streaming::StreamProcessor *p; 288 289 p=new Streaming::AmdtpReceiveStreamProcessor( 290 290 m_p1394Service->getPort(), 291 291 m_samplerate, … … 299 299 300 300 if (!addPortsToProcessor(p, 301 FreebobStreaming::Port::E_Capture)) {301 Streaming::Port::E_Capture)) { 302 302 debugFatal("Could not add plug to processor!\n"); 303 303 delete p; … … 310 310 if (snoopMode) { 311 311 // we are snooping, so this is receive too. 312 p=new FreebobStreaming::AmdtpReceiveStreamProcessor(312 p=new Streaming::AmdtpReceiveStreamProcessor( 313 313 m_p1394Service->getPort(), 314 314 m_samplerate, 315 315 BOUNCE_NR_OF_CHANNELS); 316 316 } else { 317 p=new FreebobStreaming::AmdtpTransmitStreamProcessor(317 p=new Streaming::AmdtpTransmitStreamProcessor( 318 318 m_p1394Service->getPort(), 319 319 m_samplerate, … … 330 330 if (snoopMode) { 331 331 if (!addPortsToProcessor(p, 332 FreebobStreaming::Port::E_Capture)) {332 Streaming::Port::E_Capture)) { 333 333 debugFatal("Could not add plug to processor!\n"); 334 334 delete p; … … 338 338 } else { 339 339 if (!addPortsToProcessor(p, 340 FreebobStreaming::Port::E_Playback)) {340 Streaming::Port::E_Playback)) { 341 341 debugFatal("Could not add plug to processor!\n"); 342 342 delete p; … … 354 354 } 355 355 356 FreebobStreaming::StreamProcessor *356 Streaming::StreamProcessor * 357 357 BounceDevice::getStreamProcessorByIndex(int i) { 358 358 if (i<(int)m_receiveProcessors.size()) { … … 369 369 if (i<(int)m_receiveProcessors.size()) { 370 370 int n=i; 371 FreebobStreaming::StreamProcessor *p=m_receiveProcessors.at(n);371 Streaming::StreamProcessor *p=m_receiveProcessors.at(n); 372 372 373 373 // allocate ISO channel … … 407 407 } else if (i<(int)m_receiveProcessors.size() + (int)m_transmitProcessors.size()) { 408 408 int n=i-m_receiveProcessors.size(); 409 FreebobStreaming::StreamProcessor *p=m_transmitProcessors.at(n);409 Streaming::StreamProcessor *p=m_transmitProcessors.at(n); 410 410 411 411 // allocate ISO channel branches/streaming-rework/src/bounce/bounce_avdevice.h
r416 r419 83 83 virtual int getStreamCount(); 84 84 85 virtual FreebobStreaming::StreamProcessor *getStreamProcessorByIndex(int i);85 virtual Streaming::StreamProcessor *getStreamProcessorByIndex(int i); 86 86 87 87 bool startStreamByIndex(int i); … … 104 104 105 105 // streaming stuff 106 typedef std::vector< FreebobStreaming::StreamProcessor * > StreamProcessorVector;106 typedef std::vector< Streaming::StreamProcessor * > StreamProcessorVector; 107 107 StreamProcessorVector m_receiveProcessors; 108 108 StreamProcessorVector m_transmitProcessors; 109 109 110 110 bool addPortsToProcessor( 111 FreebobStreaming::StreamProcessor *processor,112 FreebobStreaming::Port::E_Direction direction);111 Streaming::StreamProcessor *processor, 112 Streaming::Port::E_Direction direction); 113 113 114 114 DECLARE_DEBUG_MODULE; branches/streaming-rework/src/devicemanager.cpp
r413 r419 297 297 * @return StreamProcessor that is sync source 298 298 */ 299 FreebobStreaming::StreamProcessor *299 Streaming::StreamProcessor * 300 300 DeviceManager::getSyncSource() { 301 301 IAvDevice* device = getAvDeviceByIndex(0); branches/streaming-rework/src/devicemanager.h
r407 r419 32 32 class Ieee1394Service; 33 33 class IAvDevice; 34 namespace FreebobStreaming {34 namespace Streaming { 35 35 class StreamProcessor; 36 36 } … … 65 65 bool loadCache( Glib::ustring fileName ); 66 66 67 FreebobStreaming::StreamProcessor *getSyncSource();67 Streaming::StreamProcessor *getSyncSource(); 68 68 69 69 protected: branches/streaming-rework/src/dice/dice_avdevice.cpp
r415 r419 176 176 } 177 177 178 FreebobStreaming::StreamProcessor *178 Streaming::StreamProcessor * 179 179 DiceAvDevice::getStreamProcessorByIndex(int i) { 180 180 branches/streaming-rework/src/dice/dice_avdevice.h
r415 r419 65 65 66 66 int getStreamCount(); 67 FreebobStreaming::StreamProcessor *getStreamProcessorByIndex(int i);67 Streaming::StreamProcessor *getStreamProcessorByIndex(int i); 68 68 69 69 bool prepare(); … … 89 89 signed int m_iso_recv_channel, m_iso_send_channel; 90 90 91 FreebobStreaming::AmdtpReceiveStreamProcessor *m_receiveProcessor;92 FreebobStreaming::AmdtpTransmitStreamProcessor *m_transmitProcessor;91 Streaming::AmdtpReceiveStreamProcessor *m_receiveProcessor; 92 Streaming::AmdtpTransmitStreamProcessor *m_transmitProcessor; 93 93 94 94 private: branches/streaming-rework/src/freebob_streaming.cpp
r415 r419 50 50 DECLARE_GLOBAL_DEBUG_MODULE; 51 51 52 using namespace FreebobStreaming;52 using namespace Streaming; 53 53 54 54 struct _freebob_device branches/streaming-rework/src/iavdevice.h
r416 r419 29 29 class Ieee1394Service; 30 30 31 namespace FreebobStreaming {31 namespace Streaming { 32 32 class StreamProcessor; 33 33 } … … 39 39 40 40 */ 41 class IAvDevice : public FreebobUtil::OptionContainer {41 class IAvDevice : public Util::OptionContainer { 42 42 public: 43 43 virtual ~IAvDevice() {} … … 188 188 * @return a StreamProcessor object if successful, NULL otherwise 189 189 */ 190 virtual FreebobStreaming::StreamProcessor *getStreamProcessorByIndex(int i) = 0;190 virtual Streaming::StreamProcessor *getStreamProcessorByIndex(int i) = 0; 191 191 192 192 /** branches/streaming-rework/src/libstreaming/AmdtpPort.cpp
r407 r419 29 29 #include <assert.h> 30 30 31 namespace FreebobStreaming {31 namespace Streaming { 32 32 33 } // end of namespace FreebobStreaming33 } // end of namespace Streaming branches/streaming-rework/src/libstreaming/AmdtpPort.h
r415 r419 37 37 #include "AmdtpPortInfo.h" 38 38 39 namespace FreebobStreaming {39 namespace Streaming { 40 40 41 41 /*! … … 94 94 }; 95 95 96 } // end of namespace FreebobStreaming96 } // end of namespace Streaming 97 97 98 98 #endif /* __FREEBOB_AMDTPPORT__ */ branches/streaming-rework/src/libstreaming/AmdtpPortInfo.cpp
r407 r419 30 30 31 31 32 namespace FreebobStreaming {32 namespace Streaming { 33 33 34 34 35 } // end of namespace FreebobStreaming35 } // end of namespace Streaming branches/streaming-rework/src/libstreaming/AmdtpPortInfo.h
r415 r419 32 32 #include <string> 33 33 34 namespace FreebobStreaming {34 namespace Streaming { 35 35 /*! 36 36 \brief Class containing the stream information for an AMDTP channel … … 78 78 }; 79 79 80 } // end of namespace FreebobStreaming80 } // end of namespace Streaming 81 81 82 82 #endif /* __FREEBOB_AMDTPPORTINFO__ */ branches/streaming-rework/src/libstreaming/AmdtpStreamProcessor.cpp
r411 r419 40 40 #define TRANSMIT_ADVANCE_CYCLES 1U 41 41 42 namespace FreebobStreaming {42 namespace Streaming { 43 43 44 44 IMPL_DEBUG_MODULE( AmdtpTransmitStreamProcessor, AmdtpTransmitStreamProcessor, DEBUG_LEVEL_NORMAL ); … … 1401 1401 } 1402 1402 1403 } // end of namespace FreebobStreaming1403 } // end of namespace Streaming branches/streaming-rework/src/libstreaming/AmdtpStreamProcessor.h
r415 r419 55 55 #define IEC61883_AM824_LABEL_MIDI_3X 0x83 56 56 57 namespace FreebobStreaming {57 namespace Streaming { 58 58 59 59 class Port; … … 229 229 230 230 231 } // end of namespace FreebobStreaming231 } // end of namespace Streaming 232 232 233 233 #endif /* __FREEBOB_AMDTPSTREAMPROCESSOR__ */ branches/streaming-rework/src/libstreaming/IsoHandler.cpp
r398 r419 51 51 52 52 53 namespace FreebobStreaming53 namespace Streaming 54 54 { 55 55 branches/streaming-rework/src/libstreaming/IsoHandler.h
r398 r419 35 35 36 36 enum raw1394_iso_disposition ; 37 namespace FreebobStreaming37 namespace Streaming 38 38 { 39 39 branches/streaming-rework/src/libstreaming/IsoHandlerManager.cpp
r398 r419 38 38 #define PACKETS_PER_INTERRUPT 4U 39 39 40 namespace FreebobStreaming40 namespace Streaming 41 41 { 42 42 … … 72 72 if (prio>98) prio=98; 73 73 74 m_isoManagerThread=new FreebobUtil::PosixThread(74 m_isoManagerThread=new Util::PosixThread( 75 75 this, 76 76 m_realtime, prio, … … 723 723 } 724 724 725 } // end of namespace FreebobStreaming726 725 } // end of namespace Streaming 726 branches/streaming-rework/src/libstreaming/IsoHandlerManager.h
r398 r419 40 40 #define USLEEP_AFTER_UPDATE 100 41 41 #define MAX_UPDATE_TRIES 10 42 namespace FreebobUtil {42 namespace Util { 43 43 class PosixThread; 44 44 } 45 45 46 namespace FreebobStreaming46 namespace Streaming 47 47 { 48 48 … … 69 69 */ 70 70 71 class IsoHandlerManager : public FreebobUtil::RunnableInterface71 class IsoHandlerManager : public Util::RunnableInterface 72 72 { 73 73 friend class StreamProcessorManager; … … 151 151 bool m_realtime; 152 152 unsigned int m_priority; 153 FreebobUtil::PosixThread *m_isoManagerThread;153 Util::PosixThread *m_isoManagerThread; 154 154 155 155 branches/streaming-rework/src/libstreaming/IsoStream.cpp
r395 r419 30 30 #include <assert.h> 31 31 32 namespace FreebobStreaming32 namespace Streaming 33 33 { 34 34 branches/streaming-rework/src/libstreaming/IsoStream.h
r390 r419 33 33 #include "IsoHandler.h" 34 34 35 namespace FreebobStreaming35 namespace Streaming 36 36 { 37 37 branches/streaming-rework/src/libstreaming/MotuPort.cpp
r407 r419 30 30 #include <assert.h> 31 31 32 namespace FreebobStreaming {32 namespace Streaming { 33 33 34 } // end of namespace FreebobStreaming34 } // end of namespace Streaming branches/streaming-rework/src/libstreaming/MotuPort.h
r407 r419 37 37 #include "MotuPortInfo.h" 38 38 39 namespace FreebobStreaming {39 namespace Streaming { 40 40 41 41 /*! … … 114 114 }; 115 115 116 } // end of namespace FreebobStreaming116 } // end of namespace Streaming 117 117 118 118 #endif /* __FREEBOB_MOTUPORT__ */ branches/streaming-rework/src/libstreaming/MotuPortInfo.cpp
r407 r419 29 29 #include <assert.h> 30 30 31 namespace FreebobStreaming {31 namespace Streaming { 32 32 33 33 34 } // end of namespace FreebobStreaming34 } // end of namespace Streaming branches/streaming-rework/src/libstreaming/MotuPortInfo.h
r407 r419 32 32 #include <string> 33 33 34 namespace FreebobStreaming {34 namespace Streaming { 35 35 /*! 36 36 \brief Class containing the stream information for a Motu channel … … 87 87 }; 88 88 89 } // end of namespace FreebobStreaming89 } // end of namespace Streaming 90 90 91 91 #endif /* __FREEBOB_MOTUPORTINFO__ */ branches/streaming-rework/src/libstreaming/MotuStreamProcessor.cpp
r411 r419 42 42 #define TRANSMIT_ADVANCE_CYCLES 1U 43 43 44 namespace FreebobStreaming {44 namespace Streaming { 45 45 46 46 IMPL_DEBUG_MODULE( MotuTransmitStreamProcessor, MotuTransmitStreamProcessor, DEBUG_LEVEL_NORMAL ); … … 1390 1390 } 1391 1391 1392 } // end of namespace FreebobStreaming1392 } // end of namespace Streaming branches/streaming-rework/src/libstreaming/MotuStreamProcessor.h
r407 r419 36 36 #include "../libutil/DelayLockedLoop.h" 37 37 38 namespace FreebobStreaming {38 namespace Streaming { 39 39 40 40 class MotuAudioPort; … … 177 177 }; 178 178 179 } // end of namespace FreebobStreaming179 } // end of namespace Streaming 180 180 181 181 #endif /* __FREEBOB_MOTUSTREAMPROCESSOR__ */ branches/streaming-rework/src/libstreaming/Port.cpp
r386 r419 32 32 33 33 34 namespace FreebobStreaming {34 namespace Streaming { 35 35 36 36 IMPL_DEBUG_MODULE( Port, Port, DEBUG_LEVEL_NORMAL ); branches/streaming-rework/src/libstreaming/Port.h
r386 r419 35 35 #include "libutil/ringbuffer.h" 36 36 37 namespace FreebobStreaming {37 namespace Streaming { 38 38 39 39 /*! branches/streaming-rework/src/libstreaming/PortManager.cpp
r227 r419 32 32 33 33 34 namespace FreebobStreaming {34 namespace Streaming { 35 35 36 36 IMPL_DEBUG_MODULE( PortManager, PortManager, DEBUG_LEVEL_NORMAL ); branches/streaming-rework/src/libstreaming/PortManager.h
r227 r419 34 34 #include <vector> 35 35 36 namespace FreebobStreaming {36 namespace Streaming { 37 37 38 38 class Port; branches/streaming-rework/src/libstreaming/StreamProcessor.cpp
r411 r419 35 35 #include <assert.h> 36 36 37 namespace FreebobStreaming {37 namespace Streaming { 38 38 39 39 IMPL_DEBUG_MODULE( StreamProcessor, StreamProcessor, DEBUG_LEVEL_VERBOSE ); … … 58 58 { 59 59 // create the timestamped buffer and register ourselves as its client 60 m_data_buffer=new FreebobUtil::TimestampedBuffer(this);60 m_data_buffer=new Util::TimestampedBuffer(this); 61 61 62 62 } branches/streaming-rework/src/libstreaming/StreamProcessor.h
r411 r419 40 40 #include "libutil/TimestampedBuffer.h" 41 41 42 namespace FreebobStreaming {42 namespace Streaming { 43 43 44 44 class StreamProcessorManager; … … 54 54 class StreamProcessor : public IsoStream, 55 55 public PortManager, 56 public FreebobUtil::TimestampedBufferClient {56 public Util::TimestampedBufferClient { 57 57 58 58 friend class StreamProcessorManager; … … 110 110 111 111 public: 112 FreebobUtil::TimestampedBuffer *m_data_buffer;112 Util::TimestampedBuffer *m_data_buffer; 113 113 114 114 protected: branches/streaming-rework/src/libstreaming/StreamProcessorManager.cpp
r411 r419 43 43 #define ENABLE_DELAY_CYCLES 2000 44 44 45 namespace FreebobStreaming {45 namespace Streaming { 46 46 47 47 IMPL_DEBUG_MODULE( StreamProcessorManager, StreamProcessorManager, DEBUG_LEVEL_NORMAL ); branches/streaming-rework/src/libstreaming/StreamProcessorManager.h
r398 r419 38 38 #include <vector> 39 39 40 namespace FreebobStreaming {40 namespace Streaming { 41 41 42 42 class StreamProcessor; branches/streaming-rework/src/libutil/DelayLockedLoop.cpp
r277 r419 29 29 #include "DelayLockedLoop.h" 30 30 31 namespace FreebobUtil {31 namespace Util { 32 32 33 33 /** branches/streaming-rework/src/libutil/DelayLockedLoop.h
r253 r419 29 29 #define __FREEBOB_DELAYLOCKEDLOOP__ 30 30 31 namespace FreebobUtil {31 namespace Util { 32 32 33 33 class DelayLockedLoop { branches/streaming-rework/src/libutil/OptionContainer.cpp
r418 r419 32 32 #include <sstream> 33 33 34 namespace FreebobUtil {34 namespace Util { 35 35 36 36 IMPL_DEBUG_MODULE( OptionContainer, OptionContainer, DEBUG_LEVEL_NORMAL ); … … 464 464 465 465 466 } // end of namespace FreebobUtil466 } // end of namespace Util branches/streaming-rework/src/libutil/OptionContainer.h
r418 r419 33 33 #include <string> 34 34 35 namespace FreebobUtil {35 namespace Util { 36 36 37 37 class OptionContainer { … … 174 174 }; 175 175 176 } // end of namespace FreebobUtil176 } // end of namespace Util 177 177 178 178 #endif /* __FREEBOB_OPTIONCONTAINER__ */ branches/streaming-rework/src/libutil/PacketBuffer.cpp
r386 r419 31 31 32 32 33 namespace FreebobStreaming {33 namespace Streaming { 34 34 35 35 IMPL_DEBUG_MODULE( PacketBuffer, PacketBuffer, DEBUG_LEVEL_VERBOSE ); branches/streaming-rework/src/libutil/PacketBuffer.h
r386 r419 33 33 #include "libutil/ringbuffer.h" 34 34 35 namespace FreebobStreaming {35 namespace Streaming { 36 36 37 37 class PacketBuffer { branches/streaming-rework/src/libutil/PosixThread.cpp
r275 r419 30 30 #include <assert.h> 31 31 32 namespace FreebobUtil32 namespace Util 33 33 { 34 34 branches/streaming-rework/src/libutil/PosixThread.h
r254 r419 31 31 #include <pthread.h> 32 32 33 namespace FreebobUtil33 namespace Util 34 34 { 35 35 branches/streaming-rework/src/libutil/StreamStatistics.cpp
r386 r419 30 30 #include <stdio.h> 31 31 32 namespace FreebobStreaming {32 namespace Streaming { 33 33 34 34 StreamStatistics::StreamStatistics() branches/streaming-rework/src/libutil/StreamStatistics.h
r386 r419 32 32 #include <string> 33 33 34 namespace FreebobStreaming {34 namespace Streaming { 35 35 36 36 class StreamStatistics { branches/streaming-rework/src/libutil/SystemTimeSource.cpp
r384 r419 30 30 #include "Time.h" 31 31 32 namespace FreebobUtil {32 namespace Util { 33 33 34 34 IMPL_DEBUG_MODULE( SystemTimeSource, SystemTimeSource, DEBUG_LEVEL_NORMAL ); … … 54 54 } 55 55 56 } // end of namespace FreebobUtil56 } // end of namespace Util branches/streaming-rework/src/libutil/SystemTimeSource.h
r384 r419 32 32 #include "TimeSource.h" 33 33 34 namespace FreebobUtil {34 namespace Util { 35 35 36 36 class SystemTimeSource 37 : public FreebobUtil::TimeSource37 : public Util::TimeSource 38 38 { 39 39 … … 54 54 }; 55 55 56 } // end of namespace FreebobUtil56 } // end of namespace Util 57 57 58 58 #endif /* __FREEBOB_SYSTEMTIMESOURCE__ */ branches/streaming-rework/src/libutil/test-dll.cpp
r253 r419 29 29 #include <stdio.h> 30 30 31 using namespace FreebobUtil;31 using namespace Util; 32 32 33 33 int main() { branches/streaming-rework/src/libutil/Thread.h
r266 r419 33 33 #include <pthread.h> 34 34 35 namespace FreebobUtil35 namespace Util 36 36 { 37 37 branches/streaming-rework/src/libutil/TimeSource.cpp
r384 r419 36 36 #include "libutil/Time.h" 37 37 38 namespace FreebobUtil {38 namespace Util { 39 39 40 40 IMPL_DEBUG_MODULE( TimeSource, TimeSource, DEBUG_LEVEL_NORMAL ); … … 321 321 } 322 322 323 } // end of namespace FreebobUtil323 } // end of namespace Util branches/streaming-rework/src/libutil/TimeSource.h
r384 r419 35 35 typedef uint64_t freebob_microsecs_t; 36 36 37 namespace FreebobUtil {37 namespace Util { 38 38 39 39 class TimeSource; … … 96 96 }; 97 97 98 } // end of namespace FreebobUtil98 } // end of namespace Util 99 99 100 100 #endif /* __FREEBOB_TIMESOURCE__ */ branches/streaming-rework/src/libutil/TimestampedBuffer.cpp
r411 r419 33 33 #include "assert.h" 34 34 35 namespace FreebobUtil {35 namespace Util { 36 36 37 37 IMPL_DEBUG_MODULE( TimestampedBuffer, TimestampedBuffer, DEBUG_LEVEL_VERBOSE ); … … 867 867 } 868 868 869 } // end of namespace FreebobUtil869 } // end of namespace Util branches/streaming-rework/src/libutil/TimestampedBuffer.h
r407 r419 32 32 #include "libutil/ringbuffer.h" 33 33 34 namespace FreebobUtil {34 namespace Util { 35 35 36 36 class TimestampedBufferClient; … … 195 195 }; 196 196 197 } // end of namespace FreebobUtil197 } // end of namespace Util 198 198 199 199 #endif /* __FREEBOB_TIMESTAMPEDBUFFER__ */ branches/streaming-rework/src/libutil/unittests.cpp
r416 r419 27 27 28 28 using namespace Util; 29 using namespace FreebobUtil;30 29 31 30 /////////////////////////////////////// branches/streaming-rework/src/metrichalo/mh_avdevice.cpp
r416 r419 64 64 debugOutput( DEBUG_LEVEL_VERBOSE, "Created MetricHalo::MHAvDevice (NodeID %d)\n", 65 65 nodeId ); 66 addOption( FreebobUtil::OptionContainer::Option("id",std::string("dev?")));66 addOption(Util::OptionContainer::Option("id",std::string("dev?"))); 67 67 68 68 } … … 182 182 } 183 183 184 FreebobStreaming::StreamProcessor *184 Streaming::StreamProcessor * 185 185 MHAvDevice::getStreamProcessorByIndex(int i) { 186 186 branches/streaming-rework/src/metrichalo/mh_avdevice.h
r416 r419 66 66 67 67 virtual int getStreamCount(); 68 virtual FreebobStreaming::StreamProcessor *getStreamProcessorByIndex(int i);68 virtual Streaming::StreamProcessor *getStreamProcessorByIndex(int i); 69 69 70 70 virtual bool prepare(); branches/streaming-rework/src/motu/motu_avdevice.cpp
r416 r419 389 389 } 390 390 391 m_receiveProcessor=new FreebobStreaming::MotuReceiveStreamProcessor(391 m_receiveProcessor=new Streaming::MotuReceiveStreamProcessor( 392 392 m_p1394Service->getPort(), samp_freq, event_size_in); 393 393 … … 404 404 405 405 char *buff; 406 FreebobStreaming::Port *p=NULL;406 Streaming::Port *p=NULL; 407 407 408 408 // retrieve the ID … … 413 413 414 414 // Add audio capture ports 415 if (!addDirPorts( FreebobStreaming::Port::E_Capture, samp_freq, optical_in_mode)) {415 if (!addDirPorts(Streaming::Port::E_Capture, samp_freq, optical_in_mode)) { 416 416 return false; 417 417 } … … 421 421 // event data. 422 422 asprintf(&buff,"%s_cap_MIDI0",id.c_str()); 423 p = new FreebobStreaming::MotuMidiPort(buff,424 FreebobStreaming::Port::E_Capture, 4);423 p = new Streaming::MotuMidiPort(buff, 424 Streaming::Port::E_Capture, 4); 425 425 if (!p) { 426 426 debugOutput(DEBUG_LEVEL_VERBOSE, "Skipped port %s\n", buff); … … 438 438 // example of adding an control port: 439 439 // asprintf(&buff,"%s_cap_%s",id.c_str(),"myportnamehere"); 440 // p=new FreebobStreaming::MotuControlPort(440 // p=new Streaming::MotuControlPort( 441 441 // buff, 442 // FreebobStreaming::Port::E_Capture,442 // Streaming::Port::E_Capture, 443 443 // 0 // you can add all other port specific stuff you 444 444 // // need to pass by extending MotuXXXPort and MotuPortInfo … … 459 459 460 460 // Do the same for the transmit processor 461 m_transmitProcessor=new FreebobStreaming::MotuTransmitStreamProcessor(461 m_transmitProcessor=new Streaming::MotuTransmitStreamProcessor( 462 462 m_p1394Service->getPort(), getSamplingFrequency(), event_size_out); 463 463 … … 473 473 474 474 // Add audio playback ports 475 if (!addDirPorts( FreebobStreaming::Port::E_Playback, samp_freq, optical_out_mode)) {475 if (!addDirPorts(Streaming::Port::E_Playback, samp_freq, optical_out_mode)) { 476 476 return false; 477 477 } … … 481 481 // of the event data. 482 482 asprintf(&buff,"%s_pbk_MIDI0",id.c_str()); 483 p = new FreebobStreaming::MotuMidiPort(buff,484 FreebobStreaming::Port::E_Capture, 4);483 p = new Streaming::MotuMidiPort(buff, 484 Streaming::Port::E_Capture, 4); 485 485 if (!p) { 486 486 debugOutput(DEBUG_LEVEL_VERBOSE, "Skipped port %s\n", buff); … … 499 499 // asprintf(&buff,"%s_pbk_%s",id.c_str(),"myportnamehere"); 500 500 // 501 // p=new FreebobStreaming::MotuControlPort(501 // p=new Streaming::MotuControlPort( 502 502 // buff, 503 // FreebobStreaming::Port::E_Playback,503 // Streaming::Port::E_Playback, 504 504 // 0 // you can add all other port specific stuff you 505 505 // // need to pass by extending MotuXXXPort and MotuPortInfo … … 526 526 } 527 527 528 FreebobStreaming::StreamProcessor *528 Streaming::StreamProcessor * 529 529 MotuDevice::getStreamProcessorByIndex(int i) { 530 530 switch (i) { … … 730 730 /* ======================================================================= */ 731 731 732 bool MotuDevice::addPort( FreebobStreaming::StreamProcessor *s_processor,733 char *name, enum FreebobStreaming::Port::E_Direction direction,732 bool MotuDevice::addPort(Streaming::StreamProcessor *s_processor, 733 char *name, enum Streaming::Port::E_Direction direction, 734 734 int position, int size) { 735 735 /* … … 739 739 * prior to exit. 740 740 */ 741 FreebobStreaming::Port *p=NULL;742 743 p = new FreebobStreaming::MotuAudioPort(name, direction, position, size);741 Streaming::Port *p=NULL; 742 743 p = new Streaming::MotuAudioPort(name, direction, position, size); 744 744 745 745 if (!p) { … … 761 761 762 762 bool MotuDevice::addDirPorts( 763 enum FreebobStreaming::Port::E_Direction direction,763 enum Streaming::Port::E_Direction direction, 764 764 unsigned int sample_rate, unsigned int optical_mode) { 765 765 /* … … 771 771 * create all ports and just disable those which are not active. 772 772 */ 773 const char *mode_str = direction== FreebobStreaming::Port::E_Capture?"cap":"pbk";774 const char *aux_str = direction== FreebobStreaming::Port::E_Capture?"Mix1":"Phones";775 FreebobStreaming::StreamProcessor *s_processor;773 const char *mode_str = direction==Streaming::Port::E_Capture?"cap":"pbk"; 774 const char *aux_str = direction==Streaming::Port::E_Capture?"Mix1":"Phones"; 775 Streaming::StreamProcessor *s_processor; 776 776 unsigned int i, ofs; 777 777 char *buff; … … 783 783 } 784 784 785 if (direction == FreebobStreaming::Port::E_Capture) {785 if (direction == Streaming::Port::E_Capture) { 786 786 s_processor = m_receiveProcessor; 787 787 } else { … … 819 819 asprintf(&buff,"%s_%s_AES/EBU%d", id.c_str(), mode_str, i+1); 820 820 } else { 821 if (direction == FreebobStreaming::Port::E_Capture)821 if (direction == Streaming::Port::E_Capture) 822 822 asprintf(&buff,"%s_%s_Mic%d", id.c_str(), mode_str, i+1); 823 823 else branches/streaming-rework/src/motu/motu_avdevice.h
r416 r419 113 113 114 114 virtual int getStreamCount(); 115 virtual FreebobStreaming::StreamProcessor *getStreamProcessorByIndex(int i);115 virtual Streaming::StreamProcessor *getStreamProcessorByIndex(int i); 116 116 117 117 virtual bool prepare(); … … 140 140 signed int m_bandwidth; 141 141 142 FreebobStreaming::MotuReceiveStreamProcessor *m_receiveProcessor;143 FreebobStreaming::MotuTransmitStreamProcessor *m_transmitProcessor;142 Streaming::MotuReceiveStreamProcessor *m_receiveProcessor; 143 Streaming::MotuTransmitStreamProcessor *m_transmitProcessor; 144 144 145 145 private: 146 bool addPort( FreebobStreaming::StreamProcessor *s_processor,146 bool addPort(Streaming::StreamProcessor *s_processor, 147 147 char *name, 148 enum FreebobStreaming::Port::E_Direction direction,148 enum Streaming::Port::E_Direction direction, 149 149 int position, int size); 150 150 bool addDirPorts( 151 enum FreebobStreaming::Port::E_Direction direction,151 enum Streaming::Port::E_Direction direction, 152 152 unsigned int sample_rate, unsigned int optical_mode); 153 153 branches/streaming-rework/src/rme/rme_avdevice.cpp
r416 r419 189 189 } 190 190 191 FreebobStreaming::StreamProcessor *191 Streaming::StreamProcessor * 192 192 RmeDevice::getStreamProcessorByIndex(int i) { 193 193 return NULL; branches/streaming-rework/src/rme/rme_avdevice.h
r416 r419 67 67 68 68 virtual int getStreamCount(); 69 virtual FreebobStreaming::StreamProcessor *getStreamProcessorByIndex(int i);69 virtual Streaming::StreamProcessor *getStreamProcessorByIndex(int i); 70 70 71 71 virtual bool prepare();