diff -r b7b49303d0c0 -r 762d760dcfdf qtms/src/qtmsstream.cpp --- 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 (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 - (qsource)->GetSource(tmssource); - break; - case QTMS_SOURCE_MODEM: - status = static_cast - (qsource)->GetSource(tmssource); - break; - case QTMS_SOURCE_MIC: - status = static_cast - (qsource)->GetSource(tmssource); - break; - default: - break; - } - if (status == QTMS_RESULT_SUCCESS && tmssource) - { + switch (qsrctype) { + case QTMS_SOURCE_CLIENT: + status = static_cast (qsource)->GetSource(tmssource); + break; + case QTMS_SOURCE_MODEM: + status = static_cast (qsource)->GetSource(tmssource); + break; + case QTMS_SOURCE_MIC: + status = static_cast (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 - (qsource)->GetSource(tmssource); - break; - case QTMS_SOURCE_MODEM: - status = static_cast - (qsource)->GetSource(tmssource); - break; - case QTMS_SOURCE_MIC: - status = static_cast - (qsource)->GetSource(tmssource); - break; - default: - break; - } - if (status == QTMS_RESULT_SUCCESS && tmssource) - { + switch (qsrctype) { + case QTMS_SOURCE_CLIENT: + status = static_cast (qsource)->GetSource(tmssource); + break; + case QTMS_SOURCE_MODEM: + status = static_cast (qsource)->GetSource(tmssource); + break; + case QTMS_SOURCE_MIC: + status = static_cast (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 - (qsink)->GetSink(tmssink); - break; - case QTMS_SINK_MODEM: - status = static_cast - (qsink)->GetSink(tmssink); - break; - case QTMS_SINK_SPEAKER: - status = static_cast - (qsink)->GetSink(tmssink); - break; - default: - break; - } - if (status == QTMS_RESULT_SUCCESS && tmssink) - { + switch (qsinktype) { + case QTMS_SINK_CLIENT: + status = static_cast (qsink)->GetSink(tmssink); + break; + case QTMS_SINK_MODEM: + status = static_cast (qsink)->GetSink(tmssink); + break; + case QTMS_SINK_SPEAKER: + status = static_cast (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 - (qsink)->GetSink(tmssink); - break; - case QTMS_SINK_MODEM: - status = static_cast - (qsink)->GetSink(tmssink); - break; - case QTMS_SINK_SPEAKER: - status = static_cast - (qsink)->GetSink(tmssink); - break; - default: - break; - } - if (status == QTMS_RESULT_SUCCESS && tmssink) - { + switch (qsinktype) { + case QTMS_SINK_CLIENT: + status = static_cast (qsink)->GetSink(tmssink); + break; + case QTMS_SINK_MODEM: + status = static_cast (qsink)->GetSink(tmssink); + break; + case QTMS_SINK_SPEAKER: + status = static_cast (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 - (qformat)->GetFormat(tmsformat); - break; - case QTMS_FORMAT_AMR: - status = static_cast - (qformat)->GetFormat(tmsformat); - break; - case QTMS_FORMAT_G711: - status = static_cast - (qformat)->GetFormat(tmsformat); - break; - case QTMS_FORMAT_G729: - status = static_cast - (qformat)->GetFormat(tmsformat); - break; - case QTMS_FORMAT_ILBC: - status = static_cast - (qformat)->GetFormat(tmsformat); - break; - default: - break; - } + switch (fmttype) { + case QTMS_FORMAT_PCM: + status = static_cast (qformat)->GetFormat(tmsformat); + break; + case QTMS_FORMAT_AMR: + status = static_cast (qformat)->GetFormat(tmsformat); + break; + case QTMS_FORMAT_G711: + status = static_cast (qformat)->GetFormat(tmsformat); + break; + case QTMS_FORMAT_G729: + status = static_cast (qformat)->GetFormat(tmsformat); + break; + case QTMS_FORMAT_ILBC: + status = static_cast (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 - (qformat)->GetFormat(tmsformat); - break; - case QTMS_FORMAT_AMR: - status = static_cast - (qformat)->GetFormat(tmsformat); - break; - case QTMS_FORMAT_G711: - status = static_cast - (qformat)->GetFormat(tmsformat); - break; - case QTMS_FORMAT_G729: - status = static_cast - (qformat)->GetFormat(tmsformat); - break; - case QTMS_FORMAT_ILBC: - status = static_cast - (qformat)->GetFormat(tmsformat); - break; - default: - break; - } + switch (fmttype) { + case QTMS_FORMAT_PCM: + status = static_cast (qformat)->GetFormat(tmsformat); + break; + case QTMS_FORMAT_AMR: + status = static_cast (qformat)->GetFormat(tmsformat); + break; + case QTMS_FORMAT_G711: + status = static_cast (qformat)->GetFormat(tmsformat); + break; + case QTMS_FORMAT_G729: + status = static_cast (qformat)->GetFormat(tmsformat); + break; + case QTMS_FORMAT_ILBC: + status = static_cast (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 - (qeffect)->GetEffect(tmseffect); - break; - case QTMS_EFFECT_GAIN: - status = static_cast - (qeffect)->GetEffect(tmseffect); - break; - default: - break; - } + switch (effecttype) { + case QTMS_EFFECT_VOLUME: + status = static_cast (qeffect)->GetEffect(tmseffect); + break; + case QTMS_EFFECT_GAIN: + status = static_cast (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 - (qeffect)->GetEffect(tmseffect); - break; - case QTMS_EFFECT_GAIN: - status = static_cast - (qeffect)->GetEffect(tmseffect); - break; - default: - break; - } + switch (effecttype) { + case QTMS_EFFECT_VOLUME: + status = static_cast (qeffect)->GetEffect(tmseffect); + break; + case QTMS_EFFECT_GAIN: + status = static_cast (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(); - } } +}