diff options
Diffstat (limited to 'tderadio3/plugins/streaming/streaming.cpp')
| -rw-r--r-- | tderadio3/plugins/streaming/streaming.cpp | 526 |
1 files changed, 0 insertions, 526 deletions
diff --git a/tderadio3/plugins/streaming/streaming.cpp b/tderadio3/plugins/streaming/streaming.cpp deleted file mode 100644 index fcbc0cb..0000000 --- a/tderadio3/plugins/streaming/streaming.cpp +++ /dev/null @@ -1,526 +0,0 @@ -/*************************************************************************** - streaming.cpp - description - ------------------- - begin : Sun Sept 3 2006 - copyright : (C) 2006 by Martin Witte - email : witte@kawo1.rwth-aachen.de - ***************************************************************************/ - -/*************************************************************************** - * * - * This program is free software; you can redistribute it and/or modify * - * it under the terms of the GNU General Public License as published by * - * the Free Software Foundation; either version 2 of the License, or * - * (at your option) any later version. * - * * - ***************************************************************************/ - -#include "streaming.h" - -#include "../../src/include/aboutwidget.h" -#include "../../src/include/utils.h" -#include <tdelocale.h> -#include <tdeaboutdata.h> -#include <kurl.h> -#include <tdelocale.h> - -#include "streaming-job.h" -#include "streaming-configuration.h" - -/////////////////////////////////////////////////////////////////////// -//// plugin library functions - -PLUGIN_LIBRARY_FUNCTIONS(StreamingDevice, "tderadio-streaming", i18n("Streaming Support")); - -///////////////////////////////////////////////////////////////////////////// - - - - -StreamingDevice::StreamingDevice(const TQString &name) - : TQObject(NULL, NULL), - PluginBase(name, i18n("TDERadio Streaming Plugin")) -{ - m_CaptureChannels.setAutoDelete(true); - m_PlaybackChannels.setAutoDelete(true); -} - - -StreamingDevice::~StreamingDevice() -{ - resetPlaybackStreams(); - resetCaptureStreams(); -} - - -bool StreamingDevice::connectI(Interface *i) -{ - bool a = PluginBase::connectI(i); - bool b = ISoundStreamClient::connectI(i); - return a || b; -} - - -bool StreamingDevice::disconnectI(Interface *i) -{ - bool a = PluginBase::disconnectI(i); - bool b = ISoundStreamClient::disconnectI(i); - return a || b; -} - -void StreamingDevice::noticeConnectedI (ISoundStreamServer *s, bool pointer_valid) -{ - ISoundStreamClient::noticeConnectedI(s, pointer_valid); - if (s && pointer_valid) { - s->register4_sendReleasePlayback(this); - s->register4_sendReleaseCapture(this); - s->register4_sendStartPlayback(this); - s->register4_sendPausePlayback(this); - s->register4_sendStopPlayback(this); - s->register4_queryIsPlaybackRunning(this); - s->register4_sendStartCaptureWithFormat(this); - s->register4_sendStopCapture(this); - s->register4_queryIsCaptureRunning(this); - s->register4_notifySoundStreamClosed(this); - s->register4_notifySoundStreamRedirected(this); - s->register4_notifySoundStreamData(this); - s->register4_notifyReadyForPlaybackData(this); - } -} - -// PluginBase - -void StreamingDevice::saveState (TDEConfig *c) const -{ - c->setGroup(TQString("streaming-") + PluginBase::name()); - c->writeEntry("soundstreamclient-id", m_SoundStreamClientID); - - c->writeEntry("playback-channels", m_PlaybackChannelList.size()); - for (unsigned int i = 0; i < m_PlaybackChannelList.size(); ++i) { - TQString s = m_PlaybackChannelList[i]; - const StreamingJob *j = m_PlaybackChannels[s]; - - const SoundFormat &sf = j->getSoundFormat(); - KURL url = j->getURL(); - size_t buffer_size = j->getBufferSize(); - - sf.saveConfig("playback-channel-" + TQString::number(i), c); - c->writeEntry("playback-channel-" + TQString::number(i) + "-url", url.url()); - c->writeEntry("playback-channel-" + TQString::number(i) + "-buffer-size", buffer_size); - } - - c->writeEntry("capture-channels", m_CaptureChannelList.size()); - for (unsigned int i = 0; i < m_CaptureChannelList.size(); ++i) { - TQString s = m_CaptureChannelList[i]; - const StreamingJob *j = m_CaptureChannels[s]; - - const SoundFormat &sf = j->getSoundFormat(); - KURL url = j->getURL(); - size_t buffer_size = j->getBufferSize(); - - sf.saveConfig("capture-channel-" + TQString::number(i), c); - c->writeEntry("capture-channel-" + TQString::number(i) + "-url", url.url()); - c->writeEntry("capture-channel-" + TQString::number(i) + "-buffer-size", buffer_size); - } -} - -void StreamingDevice::restoreState (TDEConfig *c) -{ - c->setGroup(TQString("streaming-") + PluginBase::name()); - setSoundStreamClientID(c->readEntry("soundstreamclient-id", getSoundStreamClientID())); - - resetPlaybackStreams(false); - resetCaptureStreams(false); - - int n = c->readNumEntry("playback-channels", 0); - for (int i = 0; i < n; ++i) { - SoundFormat sf; - sf.restoreConfig("playback-channel-" + TQString::number(i), c); - TQString url = c->readEntry("playback-channel-" + TQString::number(i) + "-url", TQString()); - size_t buffer_size = c->readNum64Entry("playback-channel-" + TQString::number(i) + "-buffer-size", 32*1024); - - if (!url.isNull()) { - addPlaybackStream(url, sf, buffer_size, i == n-1); - } - } - - n = c->readNumEntry("capture-channels", 0); - for (int i = 0; i < n; ++i) { - SoundFormat sf; - sf.restoreConfig("capture-channel-" + TQString::number(i), c); - TQString url = c->readEntry("capture-channel-" + TQString::number(i) + "-url", TQString()); - size_t buffer_size = c->readNum64Entry("capture-channel-" + TQString::number(i) + "-buffer-size", 32*1024); - - if (!url.isNull()) { - addCaptureStream(url, sf, buffer_size, i == n-1); - } - } - - if (!m_CaptureChannelList.size()) { - addCaptureStream("/dev/video24", SoundFormat(48000, 2, 16, true, BYTE_ORDER, "raw"), 65536); - } - - emit sigUpdateConfig(); -} - - -ConfigPageInfo StreamingDevice::createConfigurationPage() -{ - StreamingConfiguration *conf = new StreamingConfiguration(NULL, this); - TQObject::connect(this, TQT_SIGNAL(sigUpdateConfig()), conf, TQT_SLOT(slotUpdateConfig())); - return ConfigPageInfo (conf, - i18n("Streaming"), - i18n("Streaming Device Options"), - "tderadio_streaming"); -} - - -AboutPageInfo StreamingDevice::createAboutPage() -{ - return AboutPageInfo(); -} - - - -bool StreamingDevice::preparePlayback(SoundStreamID id, const TQString &channel, bool /*active_mode*/, bool start_immediately) -{ - if (id.isValid() && m_PlaybackChannels.find(channel)) { - m_AllPlaybackStreams.insert(id, channel); - if (start_immediately) - startPlayback(id); - return true; - } - return false; -} - - -bool StreamingDevice::prepareCapture(SoundStreamID id, const TQString &channel) -{ - logDebug("StreamingDevice::prepareCapture"); - if (id.isValid() && m_CaptureChannels.find(channel)) { - m_AllCaptureStreams.insert(id, channel); - return true; - } - return false; -} - -bool StreamingDevice::releasePlayback(SoundStreamID id) -{ - if (id.isValid() && m_AllPlaybackStreams.contains(id)) { - stopPlayback(id); - if (!m_EnabledPlaybackStreams.contains(id)) - m_AllPlaybackStreams.remove(id); - return true; - } - return false; -} - -bool StreamingDevice::releaseCapture(SoundStreamID id) -{ - logDebug("StreamingDevice::releaseCapture"); - if (id.isValid() && m_AllCaptureStreams.contains(id)) { - stopCapture(id); - if (!m_EnabledCaptureStreams.contains(id)) - m_AllCaptureStreams.remove(id); - return true; - } - return false; -} - -bool StreamingDevice::supportsPlayback() const -{ - return m_PlaybackChannels.size() > 0; -} - - -bool StreamingDevice::supportsCapture() const -{ - return m_CaptureChannels.size() > 0; -} - - -bool StreamingDevice::startPlayback(SoundStreamID id) -{ - if (id.isValid() && m_AllPlaybackStreams.contains(id)) { - m_EnabledPlaybackStreams.insert(id, m_AllPlaybackStreams[id]); - StreamingJob &x = *m_PlaybackChannels.find(m_AllPlaybackStreams[id]); - x.startPlayback(); - return true; - } else { - return false; - } -} - - -bool StreamingDevice::pausePlayback(SoundStreamID /*id*/) -{ - //return stopPlayback(id); - return false; -} - - -bool StreamingDevice::stopPlayback(SoundStreamID id) -{ - if (id.isValid() && m_EnabledPlaybackStreams.contains(id)) { - StreamingJob &x = *m_PlaybackChannels.find(m_AllPlaybackStreams[id]); - if (x.stopPlayback()) { - m_EnabledPlaybackStreams.remove(id); - } - return true; - } else { - return false; - } -} - - -bool StreamingDevice::isPlaybackRunning(SoundStreamID id, bool &b) const -{ - if (id.isValid() && m_EnabledPlaybackStreams.contains(id)) { - b = true; - return true; - } else { - return false; - } -} - -bool StreamingDevice::startCaptureWithFormat(SoundStreamID id, - const SoundFormat &proposed_format, - SoundFormat &real_format, - bool force_format) -{ - logDebug("StreamingDevice::startCaptureWithFormat"); - if (id.isValid() && m_AllCaptureStreams.contains(id)) { - m_EnabledCaptureStreams.insert(id, m_AllCaptureStreams[id]); - StreamingJob &x = *m_CaptureChannels.find(m_AllCaptureStreams[id]); - x.startCapture(proposed_format, real_format, force_format); - return true; - } else { - return false; - } -} - - -bool StreamingDevice::stopCapture(SoundStreamID id) -{ - if (id.isValid() && m_EnabledCaptureStreams.contains(id)) { - StreamingJob &x = *m_CaptureChannels.find(m_AllCaptureStreams[id]); - if (x.stopCapture()) { - m_EnabledCaptureStreams.remove(id); - } - return true; - } else { - return false; - } -} - - -bool StreamingDevice::isCaptureRunning(SoundStreamID id, bool &b, SoundFormat &sf) const -{ - if (id.isValid() && m_EnabledCaptureStreams.contains(id)) { - StreamingJob &x = *m_CaptureChannels.find(m_AllCaptureStreams[id]); - sf = x.getSoundFormat(); - b = true; - return true; - } else { - return false; - } -} - - -bool StreamingDevice::noticeSoundStreamClosed(SoundStreamID id) -{ - bool found = (stopCapture(id) && releaseCapture(id)) || - (stopPlayback(id) && releasePlayback(id)); - return found; -} - - -bool StreamingDevice::noticeSoundStreamRedirected(SoundStreamID oldID, SoundStreamID newID) -{ - bool found = false; - if (newID != oldID) { - if (m_AllPlaybackStreams.contains(oldID)) { - m_AllPlaybackStreams.insert(newID, m_AllPlaybackStreams[oldID]); - m_AllPlaybackStreams.remove(oldID); - found = true; - } - if (m_EnabledPlaybackStreams.contains(oldID)) { - m_EnabledPlaybackStreams.insert(newID, m_EnabledPlaybackStreams[oldID]); - m_EnabledPlaybackStreams.remove(oldID); - found = true; - } - if (m_AllCaptureStreams.contains(oldID)) { - m_AllCaptureStreams.insert(newID, m_AllCaptureStreams[oldID]); - m_AllCaptureStreams.remove(oldID); - found = true; - } - if (m_EnabledCaptureStreams.contains(oldID)) { - m_EnabledCaptureStreams.insert(newID, m_EnabledCaptureStreams[oldID]); - m_EnabledCaptureStreams.remove(oldID); - found = true; - } - } - return found; -} - - -bool StreamingDevice::noticeSoundStreamData(SoundStreamID id, - const SoundFormat &/*format*/, - const char *data, size_t size, size_t &consumed_size, - const SoundMetaData &/*md*/ - ) -{ - if (id.isValid() && m_EnabledPlaybackStreams.contains(id)) { - StreamingJob &x = *m_CaptureChannels.find(m_AllCaptureStreams[id]); - x.playData(data, size, consumed_size); - return true; - } - else { - return false; - } -} - -bool StreamingDevice::noticeReadyForPlaybackData(SoundStreamID id, size_t free_size) -{ - if (!id.isValid() || !m_AllCaptureStreams.contains(id)) - return false; - StreamingJob &x = *m_CaptureChannels.find(m_AllCaptureStreams[id]); - - while (x.hasRecordedData() && free_size > 0) { - const char *buffer = NULL; - size_t size = SIZE_T_DONT_CARE; - size_t consumed_size = SIZE_T_DONT_CARE; - SoundMetaData meta_data(0,0,0, i18n("internal stream, not stored (%1)").arg(m_AllCaptureStreams[id])); - x.lockData(buffer, size, meta_data); // get pointer to data and meta-data content - if (size > free_size) - size = free_size; - notifySoundStreamData(id, x.getSoundFormat(), buffer, size, consumed_size, meta_data); - if (consumed_size == SIZE_T_DONT_CARE) - consumed_size = size; - x.removeData(consumed_size); - free_size -= consumed_size; - if (consumed_size < size) { - logWarning(i18n("StreamingDevice %1::notifySoundStreamData: Playback Clients skipped %2 bytes").arg(name()).arg(size-consumed_size)); - break; - } - } - return true; -} - - - -const TQStringList &StreamingDevice::getPlaybackChannels() const -{ - return m_PlaybackChannelList; -} - - -const TQStringList &StreamingDevice::getCaptureChannels() const -{ - return m_CaptureChannelList; -} - - -TQString StreamingDevice::getSoundStreamClientDescription() const -{ - return i18n("Streaming Device %1").arg(PluginBase::name()); -} - - -void StreamingDevice::logStreamError(const KURL &url, const TQString &s) -{ - logError(i18n("Streaming Device %1, %2: %3").arg(name()).arg(url.url()).arg(s)); -} - -void StreamingDevice::logStreamWarning(const KURL &url, const TQString &s) -{ - logWarning(i18n("Streaming Device %1, %2: %3").arg(name()).arg(url.url()).arg(s)); -} - - -bool StreamingDevice::getPlaybackStreamOptions(const TQString &channel, TQString &url, SoundFormat &sf, size_t &buffer_size) const -{ - if (m_PlaybackChannels.find(channel)) { - const StreamingJob *j = m_PlaybackChannels[channel]; - url = j->getURL(); - sf = j->getSoundFormat(); - buffer_size = j->getBufferSize(); - return true; - } - return false; -} - - -bool StreamingDevice::getCaptureStreamOptions(const TQString &channel, TQString &url, SoundFormat &sf, size_t &buffer_size) const -{ - if (m_CaptureChannels.find(channel)) { - const StreamingJob *j = m_CaptureChannels[channel]; - url = j->getURL(); - sf = j->getSoundFormat(); - buffer_size = j->getBufferSize(); - return true; - } - return false; -} - -void StreamingDevice::resetPlaybackStreams(bool notification_enabled) -{ - while (m_EnabledPlaybackStreams.begin() != m_EnabledPlaybackStreams.end()) { - sendStopPlayback(m_EnabledPlaybackStreams.begin().key()); - } - while (m_AllPlaybackStreams.begin() != m_AllPlaybackStreams.end()) { - releasePlayback(m_AllPlaybackStreams.begin().key()); - } - m_PlaybackChannelList.clear(); - m_PlaybackChannels.clear(); - if (notification_enabled) { - notifyPlaybackChannelsChanged(m_SoundStreamClientID, m_PlaybackChannelList); - } -} - - -void StreamingDevice::resetCaptureStreams(bool notification_enabled) -{ - while (m_EnabledCaptureStreams.begin() != m_EnabledCaptureStreams.end()) { - sendStopCapture(m_EnabledCaptureStreams.begin().key()); - } - while (m_AllCaptureStreams.begin() != m_AllCaptureStreams.end()) { - releaseCapture(m_AllCaptureStreams.begin().key()); - } - m_CaptureChannelList.clear(); - m_CaptureChannels.clear(); - if (notification_enabled) { - notifyCaptureChannelsChanged(m_SoundStreamClientID, m_CaptureChannelList); - } -} - - -void StreamingDevice::addPlaybackStream(const TQString &url, const SoundFormat &sf, size_t buffer_size, bool notification_enabled) -{ - StreamingJob *x = new StreamingJob(url, sf, buffer_size); - connect(x, TQT_SIGNAL(logStreamError(const KURL &, const TQString &)), - this, TQT_SLOT (logStreamError(const KURL &, const TQString &))); - - m_PlaybackChannelList.append(url); - m_PlaybackChannels.insert(url, x); - if (notification_enabled) { - notifyPlaybackChannelsChanged(m_SoundStreamClientID, m_PlaybackChannelList); - } -} - - -void StreamingDevice::addCaptureStream (const TQString &url, const SoundFormat &sf, size_t buffer_size, bool notification_enabled) -{ - StreamingJob *x = new StreamingJob(url, sf, buffer_size); - connect(x, TQT_SIGNAL(logStreamError(const KURL &, const TQString &)), - this, TQT_SLOT (logStreamError(const KURL &, const TQString &))); - - m_CaptureChannelList.append(url); - m_CaptureChannels.insert(url, x); - if (notification_enabled) { - notifyCaptureChannelsChanged(m_SoundStreamClientID, m_CaptureChannelList); - } -} - - -#include "streaming.moc" |