--- a/qtms/src/qtmsstream.cpp Fri Jul 23 17:48:16 2010 -0500
+++ b/qtms/src/qtmsstream.cpp Fri Aug 06 17:13:32 2010 -0500
@@ -42,370 +42,316 @@
QTMSStream::QTMSStream(void) :
iStream(NULL)
- {
- }
+{
+}
QTMSStream::~QTMSStream()
- {
+{
//delete iStream;
//delete (static_cast<QTMSStreamImpl*> (iStream));
- }
+}
gint QTMSStream::AddSource(QTMSSource* qsource)
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream && qsource)
- {
+ if (iStream && qsource) {
QTMSSourceType qsrctype;
TMSSource* tmssource(NULL);
qsource->GetType(qsrctype);
- switch (qsrctype)
- {
- case QTMS_SOURCE_CLIENT:
- status = static_cast<QTMSClientSourceImpl*>
- (qsource)->GetSource(tmssource);
- break;
- case QTMS_SOURCE_MODEM:
- status = static_cast<QTMSModemSourceImpl*>
- (qsource)->GetSource(tmssource);
- break;
- case QTMS_SOURCE_MIC:
- status = static_cast<QTMSMicSourceImpl*>
- (qsource)->GetSource(tmssource);
- break;
- default:
- break;
- }
- if (status == QTMS_RESULT_SUCCESS && tmssource)
- {
+ switch (qsrctype) {
+ case QTMS_SOURCE_CLIENT:
+ status = static_cast<QTMSClientSourceImpl*> (qsource)->GetSource(tmssource);
+ break;
+ case QTMS_SOURCE_MODEM:
+ status = static_cast<QTMSModemSourceImpl*> (qsource)->GetSource(tmssource);
+ break;
+ case QTMS_SOURCE_MIC:
+ status = static_cast<QTMSMicSourceImpl*> (qsource)->GetSource(tmssource);
+ break;
+ default:
+ break;
+ }
+ if (status == QTMS_RESULT_SUCCESS && tmssource) {
status = iStream->AddSource(tmssource);
- }
}
+ }
return status;
- }
+}
gint QTMSStream::RemoveSource(QTMSSource* qsource)
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream && qsource)
- {
+ if (iStream && qsource) {
QTMSSourceType qsrctype;
TMSSource* tmssource(NULL);
qsource->GetType(qsrctype);
- switch (qsrctype)
- {
- case QTMS_SOURCE_CLIENT:
- status = static_cast<QTMSClientSourceImpl*>
- (qsource)->GetSource(tmssource);
- break;
- case QTMS_SOURCE_MODEM:
- status = static_cast<QTMSModemSourceImpl*>
- (qsource)->GetSource(tmssource);
- break;
- case QTMS_SOURCE_MIC:
- status = static_cast<QTMSMicSourceImpl*>
- (qsource)->GetSource(tmssource);
- break;
- default:
- break;
- }
- if (status == QTMS_RESULT_SUCCESS && tmssource)
- {
+ switch (qsrctype) {
+ case QTMS_SOURCE_CLIENT:
+ status = static_cast<QTMSClientSourceImpl*> (qsource)->GetSource(tmssource);
+ break;
+ case QTMS_SOURCE_MODEM:
+ status = static_cast<QTMSModemSourceImpl*> (qsource)->GetSource(tmssource);
+ break;
+ case QTMS_SOURCE_MIC:
+ status = static_cast<QTMSMicSourceImpl*> (qsource)->GetSource(tmssource);
+ break;
+ default:
+ break;
+ }
+ if (status == QTMS_RESULT_SUCCESS && tmssource) {
status = iStream->RemoveSource(tmssource);
- }
}
+ }
return status;
- }
+}
gint QTMSStream::AddSink(QTMSSink* qsink)
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream && qsink)
- {
+ if (iStream && qsink) {
QTMSSinkType qsinktype;
TMSSink* tmssink(NULL);
qsink->GetType(qsinktype);
- switch (qsinktype)
- {
- case QTMS_SINK_CLIENT:
- status = static_cast<QTMSClientSinkImpl*>
- (qsink)->GetSink(tmssink);
- break;
- case QTMS_SINK_MODEM:
- status = static_cast<QTMSModemSinkImpl*>
- (qsink)->GetSink(tmssink);
- break;
- case QTMS_SINK_SPEAKER:
- status = static_cast<QTMSSpeakerSinkImpl*>
- (qsink)->GetSink(tmssink);
- break;
- default:
- break;
- }
- if (status == QTMS_RESULT_SUCCESS && tmssink)
- {
+ switch (qsinktype) {
+ case QTMS_SINK_CLIENT:
+ status = static_cast<QTMSClientSinkImpl*> (qsink)->GetSink(tmssink);
+ break;
+ case QTMS_SINK_MODEM:
+ status = static_cast<QTMSModemSinkImpl*> (qsink)->GetSink(tmssink);
+ break;
+ case QTMS_SINK_SPEAKER:
+ status = static_cast<QTMSSpeakerSinkImpl*> (qsink)->GetSink(tmssink);
+ break;
+ default:
+ break;
+ }
+ if (status == QTMS_RESULT_SUCCESS && tmssink) {
status = iStream->AddSink(tmssink);
- }
}
+ }
return status;
- }
+}
gint QTMSStream::RemoveSink(QTMSSink* qsink)
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream && qsink)
- {
+ if (iStream && qsink) {
QTMSSinkType qsinktype;
TMSSink* tmssink(NULL);
qsink->GetType(qsinktype);
- switch (qsinktype)
- {
- case QTMS_SINK_CLIENT:
- status = static_cast<QTMSClientSinkImpl*>
- (qsink)->GetSink(tmssink);
- break;
- case QTMS_SINK_MODEM:
- status = static_cast<QTMSModemSinkImpl*>
- (qsink)->GetSink(tmssink);
- break;
- case QTMS_SINK_SPEAKER:
- status = static_cast<QTMSSpeakerSinkImpl*>
- (qsink)->GetSink(tmssink);
- break;
- default:
- break;
- }
- if (status == QTMS_RESULT_SUCCESS && tmssink)
- {
+ switch (qsinktype) {
+ case QTMS_SINK_CLIENT:
+ status = static_cast<QTMSClientSinkImpl*> (qsink)->GetSink(tmssink);
+ break;
+ case QTMS_SINK_MODEM:
+ status = static_cast<QTMSModemSinkImpl*> (qsink)->GetSink(tmssink);
+ break;
+ case QTMS_SINK_SPEAKER:
+ status = static_cast<QTMSSpeakerSinkImpl*> (qsink)->GetSink(tmssink);
+ break;
+ default:
+ break;
+ }
+ if (status == QTMS_RESULT_SUCCESS && tmssink) {
status = iStream->RemoveSink(tmssink);
- }
}
+ }
return status;
- }
+}
gint QTMSStream::SetFormat(QTMSFormat* qformat)
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream && qformat)
- {
+ if (iStream && qformat) {
QTMSFormatType fmttype;
TMSFormat* tmsformat(NULL);
qformat->GetType(fmttype);
- switch (fmttype)
- {
- case QTMS_FORMAT_PCM:
- status = static_cast<QTMSPCMFormatImpl*>
- (qformat)->GetFormat(tmsformat);
- break;
- case QTMS_FORMAT_AMR:
- status = static_cast<QTMSAMRFormatImpl*>
- (qformat)->GetFormat(tmsformat);
- break;
- case QTMS_FORMAT_G711:
- status = static_cast<QTMSG711FormatImpl*>
- (qformat)->GetFormat(tmsformat);
- break;
- case QTMS_FORMAT_G729:
- status = static_cast<QTMSG729FormatImpl*>
- (qformat)->GetFormat(tmsformat);
- break;
- case QTMS_FORMAT_ILBC:
- status = static_cast<QTMSILBCFormatImpl*>
- (qformat)->GetFormat(tmsformat);
- break;
- default:
- break;
- }
+ switch (fmttype) {
+ case QTMS_FORMAT_PCM:
+ status = static_cast<QTMSPCMFormatImpl*> (qformat)->GetFormat(tmsformat);
+ break;
+ case QTMS_FORMAT_AMR:
+ status = static_cast<QTMSAMRFormatImpl*> (qformat)->GetFormat(tmsformat);
+ break;
+ case QTMS_FORMAT_G711:
+ status = static_cast<QTMSG711FormatImpl*> (qformat)->GetFormat(tmsformat);
+ break;
+ case QTMS_FORMAT_G729:
+ status = static_cast<QTMSG729FormatImpl*> (qformat)->GetFormat(tmsformat);
+ break;
+ case QTMS_FORMAT_ILBC:
+ status = static_cast<QTMSILBCFormatImpl*> (qformat)->GetFormat(tmsformat);
+ break;
+ default:
+ break;
+ }
status = iStream->SetFormat(tmsformat);
- }
+ }
return status;
- }
+}
gint QTMSStream::ResetFormat(QTMSFormat* qformat)
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream && qformat)
- {
+ if (iStream && qformat) {
QTMSFormatType fmttype;
TMSFormat* tmsformat(NULL);
qformat->GetType(fmttype);
- switch (fmttype)
- {
- case QTMS_FORMAT_PCM:
- status = static_cast<QTMSPCMFormatImpl*>
- (qformat)->GetFormat(tmsformat);
- break;
- case QTMS_FORMAT_AMR:
- status = static_cast<QTMSAMRFormatImpl*>
- (qformat)->GetFormat(tmsformat);
- break;
- case QTMS_FORMAT_G711:
- status = static_cast<QTMSG711FormatImpl*>
- (qformat)->GetFormat(tmsformat);
- break;
- case QTMS_FORMAT_G729:
- status = static_cast<QTMSG729FormatImpl*>
- (qformat)->GetFormat(tmsformat);
- break;
- case QTMS_FORMAT_ILBC:
- status = static_cast<QTMSILBCFormatImpl*>
- (qformat)->GetFormat(tmsformat);
- break;
- default:
- break;
- }
+ switch (fmttype) {
+ case QTMS_FORMAT_PCM:
+ status = static_cast<QTMSPCMFormatImpl*> (qformat)->GetFormat(tmsformat);
+ break;
+ case QTMS_FORMAT_AMR:
+ status = static_cast<QTMSAMRFormatImpl*> (qformat)->GetFormat(tmsformat);
+ break;
+ case QTMS_FORMAT_G711:
+ status = static_cast<QTMSG711FormatImpl*> (qformat)->GetFormat(tmsformat);
+ break;
+ case QTMS_FORMAT_G729:
+ status = static_cast<QTMSG729FormatImpl*> (qformat)->GetFormat(tmsformat);
+ break;
+ case QTMS_FORMAT_ILBC:
+ status = static_cast<QTMSILBCFormatImpl*> (qformat)->GetFormat(tmsformat);
+ break;
+ default:
+ break;
+ }
status = iStream->ResetFormat(tmsformat);
- }
+ }
return status;
- }
+}
gint QTMSStream::AddEffect(QTMSEffect* qeffect)
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream && qeffect)
- {
+ if (iStream && qeffect) {
QTMSEffectType effecttype;
TMSEffect* tmseffect(NULL);
qeffect->GetType(effecttype);
- switch (effecttype)
- {
- case QTMS_EFFECT_VOLUME:
- status = static_cast<QTMSVolumeEffectImpl*>
- (qeffect)->GetEffect(tmseffect);
- break;
- case QTMS_EFFECT_GAIN:
- status = static_cast<QTMSGainEffectImpl*>
- (qeffect)->GetEffect(tmseffect);
- break;
- default:
- break;
- }
+ switch (effecttype) {
+ case QTMS_EFFECT_VOLUME:
+ status = static_cast<QTMSVolumeEffectImpl*> (qeffect)->GetEffect(tmseffect);
+ break;
+ case QTMS_EFFECT_GAIN:
+ status = static_cast<QTMSGainEffectImpl*> (qeffect)->GetEffect(tmseffect);
+ break;
+ default:
+ break;
+ }
status = iStream->AddEffect(tmseffect);
- }
+ }
return status;
- }
+}
gint QTMSStream::RemoveEffect(QTMSEffect* qeffect)
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream && qeffect)
- {
+ if (iStream && qeffect) {
QTMSEffectType effecttype;
TMSEffect* tmseffect(NULL);
qeffect->GetType(effecttype);
- switch (effecttype)
- {
- case QTMS_EFFECT_VOLUME:
- status = static_cast<QTMSVolumeEffectImpl*>
- (qeffect)->GetEffect(tmseffect);
- break;
- case QTMS_EFFECT_GAIN:
- status = static_cast<QTMSGainEffectImpl*>
- (qeffect)->GetEffect(tmseffect);
- break;
- default:
- break;
- }
+ switch (effecttype) {
+ case QTMS_EFFECT_VOLUME:
+ status = static_cast<QTMSVolumeEffectImpl*> (qeffect)->GetEffect(tmseffect);
+ break;
+ case QTMS_EFFECT_GAIN:
+ status = static_cast<QTMSGainEffectImpl*> (qeffect)->GetEffect(tmseffect);
+ break;
+ default:
+ break;
+ }
status = iStream->RemoveEffect(tmseffect);
- }
+ }
return status;
- }
+}
gint QTMSStream::GetState()
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream)
- {
+ if (iStream) {
status = iStream->GetState();
- }
+ }
return status;
- }
+}
gint QTMSStream::GetStreamType()
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream)
- {
+ if (iStream) {
status = iStream->GetStreamType();
- }
+ }
return status;
- }
+}
gint QTMSStream::GetStreamId()
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream)
- {
+ if (iStream) {
status = iStream->GetStreamId();
- }
+ }
return status;
- }
+}
gint QTMSStream::Init(gint retrytime)
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream)
- {
+ if (iStream) {
status = iStream->Init(retrytime);
- }
+ }
return status;
- }
+}
gint QTMSStream::Pause()
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream)
- {
+ if (iStream) {
status = iStream->Pause();
- }
+ }
return status;
- }
+}
gint QTMSStream::Start(gint retrytime)
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream)
- {
+ if (iStream) {
status = iStream->Start(retrytime);
- }
+ }
return status;
- }
+}
gint QTMSStream::Stop()
- {
+{
gint status(QTMS_RESULT_UNINITIALIZED_OBJECT);
- if (iStream)
- {
+ if (iStream) {
status = iStream->Stop();
- }
+ }
return status;
- }
+}
void QTMSStream::Deinit()
- {
- if (iStream)
- {
+{
+ if (iStream) {
iStream->Deinit();
- }
}
+}