Standardize folder structure.

Signed-off-by: Michele Calgaro <michele.calgaro@yahoo.it>

1 files changed, 455 insertions, 0 deletions

diff --git a/plugins/timeshifter/timeshifter.cpp b/plugins/timeshifter/timeshifter.cpp
new file mode 100644
index 0000000..146e530
--- /dev/null
+++ b/plugins/timeshifter/timeshifter.cpp
@@ -0,0 +1,455 @@
+/***************************************************************************
+                          timeshifter.cpp  -  description
+                             -------------------
+    begin                : Mon May 16 13:39:31 CEST 2005
+    copyright            : (C) 2005 by Ernst 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.                                   *
+ *                                                                         *
+ ***************************************************************************/
+
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+
+#include <tdelocale.h>
+#include <linux/soundcard.h>
+
+#include "../../src/include/utils.h"
+#include "timeshifter.h"
+#include "timeshifter-configuration.h"
+
+///////////////////////////////////////////////////////////////////////
+
+PLUGIN_LIBRARY_FUNCTIONS(TimeShifter, "tderadio-timeshifter", i18n("TimeShift Support"));
+
+///////////////////////////////////////////////////////////////////////
+
+TimeShifter::TimeShifter (const TQString &name)
+    : PluginBase(name, i18n("TimeShifter Plugin")),
+      m_TempFileName("/tmp/tderadio-timeshifter-tempfile"),
+      m_TempFileMaxSize(256*1024*1024),
+      m_PlaybackMixerID(TQString()),
+      m_PlaybackMixerChannel("PCM"),
+      m_orgVolume(0.0),
+      m_PlaybackMetaData(0,0,0),
+      m_PlaybackDataLeftInBuffer(0),
+      m_RingBuffer(m_TempFileName, m_TempFileMaxSize)
+{
+}
+
+
+TimeShifter::~TimeShifter ()
+{
+}
+
+
+bool TimeShifter::connectI (Interface *i)
+{
+    bool a = PluginBase::connectI(i);
+    bool b = ISoundStreamClient::connectI(i);
+    return a || b;
+}
+
+
+bool TimeShifter::disconnectI (Interface *i)
+{
+    bool a = PluginBase::disconnectI(i);
+    bool b = ISoundStreamClient::disconnectI(i);
+    return a || b;
+}
+
+
+void TimeShifter::noticeConnectedI (ISoundStreamServer *s, bool pointer_valid)
+{
+    ISoundStreamClient::noticeConnectedI(s, pointer_valid);
+    if (s && pointer_valid) {
+        s->register4_notifySoundStreamClosed(this);
+        s->register4_sendStartPlayback(this);
+        s->register4_sendStopPlayback(this);
+        s->register4_sendPausePlayback(this);
+        s->register4_notifySoundStreamData(this);
+        s->register4_notifyReadyForPlaybackData(this);
+        s->register4_querySoundStreamDescription(this);
+        s->register4_sendStartCaptureWithFormat(this);
+        s->register4_sendStopCapture(this);
+    }
+}
+
+
+void   TimeShifter::saveState    (TDEConfig *config) const
+{
+    config->setGroup(TQString("timeshifter-") + name());
+
+    config->writeEntry("temp-file-name",         m_TempFileName);
+    config->writeEntry("max-file-size",          m_TempFileMaxSize / 1024 / 1024);
+
+    config->writeEntry("PlaybackMixerID",      m_PlaybackMixerID);
+    config->writeEntry("PlaybackMixerChannel", m_PlaybackMixerChannel);
+}
+
+
+void   TimeShifter::restoreState (TDEConfig *config)
+{
+    config->setGroup(TQString("timeshifter-") + name());
+
+    TQString  fname =               config->readEntry("temp-file-name", "/tmp/tderadio-timeshifter-tempfile");
+    TQ_UINT64 fsize = 1024 * 1024 * config->readNumEntry("max-file-size",  256);
+
+    TQString mixerID = config->readEntry ("PlaybackMixerID", TQString());
+    TQString channel = config->readEntry ("PlaybackMixerChannel", "PCM");
+
+    setPlaybackMixer(mixerID, channel);
+    setTempFile(fname, fsize);
+
+    emit sigUpdateConfig();
+}
+
+
+ConfigPageInfo  TimeShifter::createConfigurationPage()
+{
+    TimeShifterConfiguration *conf = new TimeShifterConfiguration(NULL, this);
+    TQObject::connect(this, TQT_SIGNAL(sigUpdateConfig()), conf, TQT_SLOT(slotUpdateConfig()));
+    return ConfigPageInfo (conf,
+                           i18n("Timeshifter"),
+                           i18n("Timeshifter Options"),
+                           "tderadio_pause");
+}
+
+AboutPageInfo   TimeShifter::createAboutPage()
+{
+    return AboutPageInfo();
+}
+
+
+bool TimeShifter::noticeSoundStreamClosed(SoundStreamID id)
+{
+    return stopPlayback(id);
+}
+
+bool TimeShifter::startPlayback(SoundStreamID id)
+{
+    if (id == m_OrgStreamID) {
+        m_StreamPaused = false;
+        return true;
+    }
+    return false;
+}
+
+bool TimeShifter::stopPlayback(SoundStreamID id)
+{
+    if (id == m_NewStreamID) {
+
+        return sendStopPlayback(m_OrgStreamID);
+
+    } else if (id == m_OrgStreamID) {
+
+        SoundStreamID tmp_newID = m_NewStreamID;
+        SoundStreamID tmp_orgID = m_OrgStreamID;
+
+        m_OrgStreamID.invalidate();
+        m_NewStreamID.invalidate();
+
+        sendStopCapture(tmp_newID);
+        closeSoundStream(tmp_newID);
+        stopPlayback(tmp_newID);
+        m_RingBuffer.clear();
+        m_PlaybackMetaData = SoundMetaData(0,0,0);
+        m_PlaybackDataLeftInBuffer = 0;
+        return  true;
+    }
+    return false;
+}
+
+
+bool TimeShifter::pausePlayback(SoundStreamID id)
+{
+    if (!m_OrgStreamID.isValid()) {
+        SoundStreamID orgid = id;
+        SoundStreamID newid = createNewSoundStream(orgid, false);
+        m_OrgStreamID  = orgid;
+        m_NewStreamID  = newid;
+        notifySoundStreamCreated(newid);
+        notifySoundStreamRedirected(orgid, newid);
+        queryPlaybackVolume(newid, m_orgVolume);
+        sendMute(newid);
+        sendPlaybackVolume(newid, 0);
+
+        m_NewStreamID.invalidate();
+        sendStopPlayback(newid);
+        m_NewStreamID = newid;
+
+        m_StreamPaused = true;
+
+        m_RingBuffer.clear();
+        m_PlaybackMetaData = SoundMetaData(0,0,0);
+        m_PlaybackDataLeftInBuffer = 0;
+
+        sendStartCaptureWithFormat(m_NewStreamID, m_SoundFormat, m_realSoundFormat);
+
+        ISoundStreamClient *playback_mixer = searchPlaybackMixer();
+        if (playback_mixer) {
+            playback_mixer->preparePlayback(m_OrgStreamID, m_PlaybackMixerChannel, /*active*/true, /*startimmediately*/ true);
+            m_PlaybackMixerID = playback_mixer->getSoundStreamClientID();
+        }
+
+        return true;
+
+    } else if (id == m_OrgStreamID) {
+        m_StreamPaused = !m_StreamPaused;
+        if (!m_StreamPaused) {
+//            sendStartPlayback(m_OrgStreamID);
+            sendUnmute(m_OrgStreamID);
+            sendPlaybackVolume(m_OrgStreamID, m_orgVolume);
+        } else {
+            queryPlaybackVolume(m_OrgStreamID, m_orgVolume);
+        }
+        return true;
+    }
+    return false;
+}
+
+
+size_t TimeShifter::writeMetaDataToBuffer(const SoundMetaData &md, char *buffer, size_t buffer_size)
+{
+    TQ_UINT64 pos     = md.position();
+    time_t   abs     = md.absoluteTimestamp();
+    time_t   rel     = md.relativeTimestamp();
+    size_t   url_len = md.url().url().length() + 1;
+    size_t   req_size = sizeof(req_size) + sizeof(pos) + sizeof(abs) + sizeof(rel) + sizeof(url_len) + url_len;
+    if (req_size <= buffer_size) {
+        *(size_t*)buffer = req_size;
+        buffer += sizeof(req_size);
+        *(TQ_UINT64*)buffer = pos;
+        buffer += sizeof(pos);
+        *(time_t*)buffer = abs;
+        buffer += sizeof(abs);
+        *(time_t*)buffer = rel;
+        buffer += sizeof(rel);
+        *(size_t*)buffer = url_len;
+        buffer += sizeof(url_len);
+        memcpy(buffer, md.url().url().ascii(), url_len);
+        buffer += url_len;
+        return req_size;
+    } else if (buffer_size >= sizeof(req_size)) {
+        *(size_t*)buffer = sizeof(req_size);
+        return sizeof(req_size);
+    } else {
+        return 0;
+    }
+}
+
+size_t TimeShifter::readMetaDataFromBuffer(SoundMetaData &md, const char *buffer, size_t buffer_size)
+{
+    size_t   req_size = 0;
+    TQ_UINT64 pos = 0;
+    time_t   abs = 0;
+    time_t   rel = 0;
+    size_t   url_len = 0;
+    KURL     url;
+    if (buffer_size >= sizeof(req_size)) {
+        req_size = *(size_t*)buffer;
+        buffer += sizeof(req_size);
+        if (req_size > sizeof(req_size)) {
+            pos = *(TQ_UINT64*)buffer;
+            buffer += sizeof(TQ_UINT64);
+            abs = *(time_t*)buffer;
+            buffer += sizeof(abs);
+            rel = *(time_t*)buffer;
+            buffer += sizeof(rel);
+            url_len = *(size_t*)buffer;
+            buffer += sizeof(url_len);
+            url = buffer;
+            buffer += url_len;
+        }
+    }
+    md = SoundMetaData(pos, rel, abs, url);
+    return req_size;
+}
+
+
+bool TimeShifter::noticeSoundStreamData(SoundStreamID id, const SoundFormat &/*sf*/, const char *data, size_t size, size_t &consumed_size, const SoundMetaData &md)
+{
+    if (id == m_NewStreamID) {
+        char buffer_meta[1024];
+        size_t meta_buffer_size = writeMetaDataToBuffer(md, buffer_meta, 1024);
+        size_t packet_size = meta_buffer_size + sizeof(size) + size;
+        if (packet_size > m_RingBuffer.getMaxSize())
+            return false;
+        TQ_INT64 diff = m_RingBuffer.getFreeSize() - packet_size;
+        while (diff < 0) {
+            skipPacketInRingBuffer();
+            diff = m_RingBuffer.getFreeSize() - packet_size;
+        }
+        m_RingBuffer.addData(buffer_meta, meta_buffer_size);
+        m_RingBuffer.addData((const char*)&size, sizeof(size));
+        m_RingBuffer.addData(data, size);
+        consumed_size = (consumed_size == SIZE_T_DONT_CARE) ? size : min(consumed_size, size);
+        return true;
+    }
+    return false;
+}
+
+
+void TimeShifter::skipPacketInRingBuffer()
+{
+    if (m_PlaybackDataLeftInBuffer > 0) {
+        m_RingBuffer.removeData(m_PlaybackDataLeftInBuffer);
+    } else {
+        size_t meta_size = 0;
+        m_RingBuffer.takeData((char*)&meta_size, sizeof(meta_size));
+        m_RingBuffer.removeData(meta_size - sizeof(meta_size));
+        size_t packet_size = 0;
+        m_RingBuffer.takeData((char*)&packet_size, sizeof(packet_size));
+        m_RingBuffer.removeData(packet_size - sizeof(packet_size));
+    }
+}
+
+
+bool TimeShifter::noticeReadyForPlaybackData(SoundStreamID id, size_t free_size)
+{
+    if (id == m_OrgStreamID && !m_StreamPaused) {
+
+        while (!m_RingBuffer.error() && m_RingBuffer.getFillSize() > 0 && free_size > 0) {
+            if (m_PlaybackDataLeftInBuffer == 0) {
+                char meta_buffer[1024];
+                size_t &meta_size = *(size_t*)meta_buffer;
+                meta_size = 0;
+                m_RingBuffer.takeData(meta_buffer, sizeof(meta_size));
+                if (meta_size && meta_size <= 1024) {
+                    m_RingBuffer.takeData(meta_buffer + sizeof(meta_size), meta_size - sizeof(meta_size));
+                    readMetaDataFromBuffer(m_PlaybackMetaData, meta_buffer, meta_size);
+                } else {
+                    m_RingBuffer.removeData(meta_size - sizeof(meta_size));
+                }
+
+                m_PlaybackDataLeftInBuffer = 0;
+                m_RingBuffer.takeData((char*)&m_PlaybackDataLeftInBuffer, sizeof(m_PlaybackDataLeftInBuffer));
+            }
+
+            const size_t buffer_size = 65536;
+            char buffer[buffer_size];
+
+            while (!m_RingBuffer.error() && m_PlaybackDataLeftInBuffer > 0 && free_size > 0) {
+                size_t s = m_PlaybackDataLeftInBuffer < free_size ? m_PlaybackDataLeftInBuffer : free_size;
+
+                if (s > buffer_size)
+                    s = buffer_size;
+                s = m_RingBuffer.takeData(buffer, s);
+
+                size_t consumed_size = SIZE_T_DONT_CARE;
+                notifySoundStreamData(m_OrgStreamID, m_realSoundFormat, buffer, s, consumed_size, m_PlaybackMetaData);
+                if (consumed_size == SIZE_T_DONT_CARE)
+                    consumed_size = s;
+
+                free_size                  -= consumed_size;
+                m_PlaybackDataLeftInBuffer -= consumed_size;
+                if (consumed_size < s) {
+                    logError(i18n("TimeShifter::notifySoundStreamData: clients skipped %1 bytes. Data Lost").arg(s - consumed_size));
+                    free_size = 0; // break condition for outer loop
+                    break;
+                }
+            }
+        }
+        return true;
+    }
+    return false;
+}
+
+
+
+ISoundStreamClient *TimeShifter::searchPlaybackMixer()
+{
+    ISoundStreamClient *playback_mixer = getSoundStreamClientWithID(m_PlaybackMixerID);
+
+    // some simple sort of autodetection if one mixer isn't present any more
+    if (!playback_mixer) {
+        TQPtrList<ISoundStreamClient> playback_mixers = queryPlaybackMixers();
+        if (!playback_mixers.isEmpty())
+            playback_mixer = playback_mixers.first();
+    }
+    return playback_mixer;
+}
+
+
+bool  TimeShifter::setPlaybackMixer(const TQString &soundStreamClientID, const TQString &ch)
+{
+    m_PlaybackMixerID = soundStreamClientID;
+    m_PlaybackMixerChannel = ch;
+
+    ISoundStreamClient *playback_mixer = searchPlaybackMixer();
+
+    float  oldVolume;
+    if (m_OrgStreamID.isValid()) {
+        queryPlaybackVolume(m_OrgStreamID, oldVolume);
+        sendStopPlayback(m_OrgStreamID);
+        sendReleasePlayback(m_OrgStreamID);
+    }
+
+    if (playback_mixer)
+        playback_mixer->preparePlayback(m_OrgStreamID, m_PlaybackMixerChannel, /*active*/true, /*start_imm*/false);
+
+    if (m_OrgStreamID.isValid()) {
+        sendStartPlayback(m_OrgStreamID);
+        sendPlaybackVolume(m_OrgStreamID, oldVolume);
+    }
+
+    return true;
+}
+
+
+void TimeShifter::setTempFile(const TQString &filename, TQ_UINT64 s)
+{
+    m_RingBuffer.clear();
+    m_RingBuffer.resize(m_TempFileName = filename, m_TempFileMaxSize = s);
+    m_PlaybackMetaData = SoundMetaData(0,0,0, i18n("internal stream, not stored"));
+    m_PlaybackDataLeftInBuffer = 0;
+}
+
+bool TimeShifter::getSoundStreamDescription(SoundStreamID id, TQString &descr) const
+{
+    if (id == m_NewStreamID) {
+        descr = name();
+        return true;
+    }
+    else {
+        return false;
+    }
+}
+
+bool TimeShifter::startCaptureWithFormat(
+    SoundStreamID      id,
+    const SoundFormat &proposed_format,
+    SoundFormat       &real_format,
+    bool               force_format
+)
+{
+    if (id == m_OrgStreamID) {
+        if (force_format && m_realSoundFormat != proposed_format) {
+            sendStopCapture(m_NewStreamID);
+            sendStartCaptureWithFormat(m_NewStreamID, proposed_format, m_realSoundFormat);
+        }
+        real_format = m_realSoundFormat;
+        return true;
+    } else {
+        return false;
+    }
+}
+
+bool TimeShifter::stopCapture(SoundStreamID id)
+{
+    if (id == m_OrgStreamID) {
+        return true;
+    } else {
+        return false;
+    }
+}
+
+#include "timeshifter.moc"