Ticket #4242: myth_IOMultiplierV4_r19570.diff

libs/libmythtv/ThreadedFileWriter.cpp

@@ -27 +27 @@
 #define LOC_ERR QString("TFW, Error: ")
 
 const uint ThreadedFileWriter::TFW_DEF_BUF_SIZE   = 2*1024*1024;
-const uint ThreadedFileWriter::TFW_MAX_WRITE_SIZE = TFW_DEF_BUF_SIZE / 4;
-const uint ThreadedFileWriter::TFW_MIN_WRITE_SIZE = TFW_DEF_BUF_SIZE / 32;
+const uint ThreadedFileWriter::TFW_MAX_WRITE_SIZE = TFW_DEF_BUF_SIZE / 
+                                                    (128 / (2<<(5-1)));
+const uint ThreadedFileWriter::TFW_MIN_WRITE_SIZE = TFW_DEF_BUF_SIZE /
+                                                    (1024 / (2<<(5-1)));
 
 /** \class ThreadedFileWriter
  *  \brief This class supports the writing of recordings to disk.
@@ -118 +120 @@
  *  \brief Creates a threaded file writer.
  */
 ThreadedFileWriter::ThreadedFileWriter(const QString &fname,
-                                       int pflags, mode_t pmode) :
+                                       int pflags, mode_t pmode,
+                                       uint io_mult) :
     // file stuff
     filename(fname),                     flags(pflags),
     mode(pmode),                         fd(-1),
@@ -130 +133 @@
     rpos(0),                             wpos(0),
     written(0),
     // buffer
+    io_multiplier(io_mult),
     buf(NULL),                           tfw_buf_size(0)
 {
     filename.detach();
@@ -163 +167 @@
         bzero(buf, TFW_DEF_BUF_SIZE + 64);
 
         tfw_buf_size = TFW_DEF_BUF_SIZE;
-        tfw_min_write_size = TFW_MIN_WRITE_SIZE;
+
+        tfw_min_write_size = TFW_DEF_BUF_SIZE / (1024 / (2<<(io_multiplier - 1)));
+        tfw_max_write_size = TFW_DEF_BUF_SIZE / (128 / (2<<(io_multiplier - 1)));
+
+        VERBOSE(VB_RECORD, LOC + QString("Using io multiplier %1, "
+                                          "min/max = %2/%3")
+                                                     .arg(io_multiplier)
+                                                     .arg(tfw_min_write_size)
+                                                     .arg(tfw_max_write_size));
+
         pthread_create(&writer, NULL, boot_writer, this);
         pthread_create(&syncer, NULL, boot_syncer, this);
         return true;
@@ -427 +440 @@
            buffer is valid, and we try to write all of it at once which
            takes a long time. During this time, the other thread fills up
            the 10% that was free... */
-        size = (size > TFW_MAX_WRITE_SIZE) ? TFW_MAX_WRITE_SIZE : size;
+        size = (size > tfw_max_write_size) ? tfw_max_write_size : size;
 
         bool write_ok;
         if (ignore_writes)

libs/libmythtv/dbcheck.cpp

@@ -18 +18 @@
 #define MINIMUM_DBMS_VERSION 5,0,15
 
 /// This is the DB schema version expected by the running MythTV instance.
-const QString currentDatabaseVersion = "1228";
+const QString currentDatabaseVersion = "1229";
 
 static bool UpdateDBVersionNumber(const QString &newnumber);
 static bool performActualUpdate(
@@ -937 +937 @@
             return false;
     }
 
-
     if (dbver == "1050")
     {
         const char *updates[] = {
@@ -4396 +4395 @@
             return false;
     }
 
+    if (dbver == "1228")
+    {
+        const char *updates[] = {
+"ALTER TABLE storagegroup ADD COLUMN io_multiplier TINYINT(1) NULL;",
+NULL
+};
+        if (!performActualUpdate(updates, "1229", dbver))
+            return false;
+    }
+
     return true;
 }
 

libs/libmythtv/RingBuffer.cpp

@@ -44 +44 @@
 
 const uint RingBuffer::kBufferSize = 3 * 1024 * 1024;
 
-#define CHUNK 32768 /* readblocksize increments */
+#define DEF_CHUNK 32768 /* default readblocksize increments */
 
 #define PNG_MIN_SIZE   20 /* header plus one empty chunk */
 #define NUV_MIN_SIZE  204 /* header size? */
@@ -106 +106 @@
  */
 RingBuffer::RingBuffer(const QString &lfilename,
                        bool write, bool readahead,
-                       uint read_retries)
+                       uint read_retries, uint io_multiplier)
     : filename(lfilename),
       tfw(NULL),                fd2(-1),
       writemode(false),
@@ -121 +121 @@
       readsallowed(false),      wantseek(false), setswitchtonext(false),
       rawbitrate(4000),         playspeed(1.0f),
       fill_threshold(65536),    fill_min(-1),
-      readblocksize(CHUNK),     wanttoread(0),
+      readblocksize(DEF_CHUNK), wanttoread(0),
       numfailures(0),           commserror(false),
       dvdPriv(NULL),            oldfile(false),
       livetvchain(NULL),        ignoreliveeof(false),
@@ -130 +130 @@
     filename.detach();
     pthread_rwlock_init(&rwlock, NULL);
 
+    if ((io_multiplier > 5) || (io_multiplier < 2))
+    {
+        VERBOSE(VB_IMPORTANT, LOC + QString("Read/Write multiplier value of %1 is "
+                                  "out of range, setting to the default value %2.")
+                         .arg(io_multiplier).arg(StorageGroup::DEF_IO_MULTIPLIER));
+        io_multiplier = StorageGroup::DEF_IO_MULTIPLIER;
+    }
+
     if (write)
     {
         tfw = new ThreadedFileWriter(
-            filename, O_WRONLY|O_TRUNC|O_CREAT|O_LARGEFILE, 0644);
+            filename, O_WRONLY|O_TRUNC|O_CREAT|O_LARGEFILE, 0644,
+            io_multiplier);
 
         if (!tfw->Open())
         {
@@ -144 +153 @@
         return;
     }
 
+    read_chunk_size = (2<<(io_multiplier - 1)) * 1024;
+    max_read_size = 640 / (32 / (2<<(io_multiplier - 1))) * 1024;
+
+    VERBOSE(VB_GENERAL, LOC + QString("Using io multiplier %1, chunk/max = "
+                                                                     "%2/%3")
+                                                          .arg(io_multiplier)
+                                                          .arg(read_chunk_size)
+                                                          .arg(max_read_size));
+
     if (read_retries != (uint)-1)
         OpenFile(filename, read_retries);
 }
@@ -564 +582 @@
 
     wantseek       = false;
     readsallowed   = false;
-    readblocksize  = CHUNK;
+    readblocksize  = read_chunk_size;
 
     // loop without sleeping if the buffered data is less than this
-    fill_threshold = CHUNK * 2;
+    fill_threshold = read_chunk_size * 2;
     fill_min       = 1;
 
 #ifdef USING_FRONTEND
@@ -637 +655 @@
 void RingBuffer::ResetReadAhead(long long newinternal)
 {
     readAheadLock.lock();
-    readblocksize = CHUNK;
+    readblocksize = read_chunk_size;
     rbrpos = 0;
     rbwpos = 0;
     internalreadpos = newinternal;
@@ -762 +780 @@
 
     struct timeval lastread, now;
     gettimeofday(&lastread, NULL);
-    const int KB640 = 640*1024;
     int readtimeavg = 300;
     int readinterval;
 
     pausereadthread = false;
 
-    readAheadBuffer = new char[kBufferSize + KB640];
+    readAheadBuffer = new char[kBufferSize + max_read_size];
 
     pthread_rwlock_wrlock(&rwlock);
     ResetReadAhead(0);
@@ -822 +839 @@
 
             readtimeavg = (readtimeavg * 9 + readinterval) / 10;
 
-            if (readtimeavg < 200 && readblocksize < KB640)
+            if (readtimeavg < 200 && readblocksize < max_read_size)
             {
-                readblocksize += CHUNK;
+                readblocksize += read_chunk_size;
                 //VERBOSE(VB_PLAYBACK,
                 //    QString("Avg read interval was %1 msec. %2K block size")
                 //            .arg(readtimeavg).arg(readblocksize/1024));
                 readtimeavg = 300;
             }
-            else if (readtimeavg > 400 && readblocksize > CHUNK)
+            else if (readtimeavg > 400 && readblocksize > read_chunk_size)
             {
-                readblocksize -= CHUNK;
+                readblocksize -= read_chunk_size;
                 //VERBOSE(VB_PLAYBACK,
                 //    QString("Avg read interval was %1 msec. %2K block size")
                 //            .arg(readtimeavg).arg(readblocksize/1024));

libs/libmythtv/tv_play.cpp

@@ -47 +47 @@
 #include "datadirect.h"
 #include "sourceutil.h"
 #include "cardutil.h"
+#include "storagegroup.h"
 #include "channelutil.h"
 #include "util-osx-cocoa.h"
 #include "libmythdb/compat.h"
@@ -1668 +1669 @@
             QString playbackURL = ctx->playingInfo->GetPlaybackURL();
             ctx->UnlockPlayingInfo(__FILE__, __LINE__);
 
+            StorageGroup sgroup(ctx->playingInfo->storagegroup,
+                                ctx->playingInfo->hostname);
+
+            QString dirname =
+              sgroup.FindRecordingDir(ctx->playingInfo->GetRecordBasename());
+
+            uint io_multiplier = sgroup.ioMultiplier(dirname);
+
             bool opennow = (ctx->tvchain->GetCardType(-1) != "DUMMY");
 
             VERBOSE(VB_IMPORTANT, QString("We have a playbackURL(%1) & "
@@ -1675 +1684 @@
                     .arg(playbackURL).arg(ctx->tvchain->GetCardType(-1)));
 
             ctx->SetRingBuffer(new RingBuffer(playbackURL, false, true,
-                                      opennow ? 12 : (uint)-1));
+                                      opennow ? 12 : (uint)-1,
+                                      io_multiplier));
             ctx->buffer->SetLiveMode(ctx->tvchain);
         }
 
@@ -1740 +1750 @@
                               desiredNextState != kState_WatchingRecording);
         ctx->UnlockPlayingInfo(__FILE__, __LINE__);
         
-        ctx->SetRingBuffer(new RingBuffer(playbackURL, false));
+        StorageGroup sgroup(ctx->playingInfo->storagegroup,
+                            ctx->playingInfo->hostname);
+
+        QString dirname =
+          sgroup.FindRecordingDir(ctx->playingInfo->GetRecordBasename());
+
+        uint io_multiplier = sgroup.ioMultiplier(dirname);
+        ctx->SetRingBuffer(new RingBuffer(playbackURL, false, true, 12, io_multiplier));
         
         if (ctx->buffer && ctx->buffer->IsOpen())
         {
@@ -6023 +6040 @@
         {
             ctx->LockPlayingInfo(__FILE__, __LINE__);
             QString playbackURL = ctx->playingInfo->GetPlaybackURL();
-            ctx->SetRingBuffer(new RingBuffer(playbackURL, false));
+            StorageGroup sgroup(ctx->playingInfo->storagegroup,
+                                ctx->playingInfo->hostname);
+
+            QString dirname =
+              sgroup.FindRecordingDir(ctx->playingInfo->GetRecordBasename());
+            uint io_multiplier = sgroup.ioMultiplier(dirname);
+            ctx->SetRingBuffer(new RingBuffer(playbackURL, false,
+                                              true, 12, io_multiplier));
             ctx->tvchain->SetProgram(*ctx->playingInfo);
             ctx->buffer->SetLiveMode(ctx->tvchain);
             ctx->UnlockPlayingInfo(__FILE__, __LINE__);

libs/libmythtv/RingBuffer.h

@@ -13 +13 @@
 }
 
 #include "mythexp.h"
+#include "storagegroup.h"
 
 class RemoteFile;
 class RemoteEncoder;
@@ -24 +25 @@
 {
   public:
     RingBuffer(const QString &lfilename, bool write,
-               bool usereadahead = true, uint read_retries = 12/*6*/);
+               bool usereadahead = true, uint read_retries = 12/*6*/,
+               uint io_multiplier = StorageGroup::DEF_IO_MULTIPLIER);
    ~RingBuffer();
 
     // Sets
@@ -126 +128 @@
     long long readpos;
     long long writepos;
 
+    uint read_chunk_size;
+    uint max_read_size;
+
     bool stopreads;
 
     mutable pthread_rwlock_t rwlock;
@@ -154 +159 @@
     float          playspeed;
     int            fill_threshold;
     int            fill_min;
-    int            readblocksize;
+    uint           readblocksize;
 
     QWaitCondition pauseWait;
 

libs/libmythtv/tv_rec.cpp

@@ -13 +13 @@
 // Qt headers
 #include <qapplication.h>
 #include <qsqldatabase.h>
+#include <qfileinfo.h>
+#include <qdir.h>
 
 // MythTV headers
 #include "mythconfig.h"
@@ -4003 +4005 @@
 
     if (lastTuningRequest.flags & kFlagRecording)
     {
-        SetRingBuffer(new RingBuffer(rec->GetFileName(), true));
+        StorageGroup sgroup(rec->storagegroup, gContext->GetHostName());
+        QString filename = rec->GetFileName();
+        QFileInfo fi(filename);
+        uint io_multiplier = sgroup.ioMultiplier(fi.absolutePath());
+
+        SetRingBuffer(new RingBuffer(filename, true, true, 12,
+                                     io_multiplier));
         if (!ringBuffer->IsOpen())
         {
             VERBOSE(VB_IMPORTANT, LOC_ERR +
                     QString("RingBuffer '%1' not open...")
-                    .arg(rec->GetFileName()));
+                    .arg(filename));
             SetRingBuffer(NULL);
             ClearFlags(kFlagPendingActions);
             goto err_ret;
@@ -4373 +4381 @@
     MythEvent me(QString("QUERY_NEXT_LIVETV_DIR %1").arg(cardid));
     gContext->dispatch(me);
 
+    StorageGroup sgroup(prog->storagegroup, gContext->GetHostName());
+
     if (WaitForNextLiveTVDir())
     {
         QMutexLocker lock(&nextLiveTVDirLock);
         prog->pathname = nextLiveTVDir;
     }
     else
-    {
-        StorageGroup sgroup("LiveTV", gContext->GetHostName());
         prog->pathname = sgroup.FindNextDirMostFree();
-    }
 
     StartedRecording(prog);
 
-    *rb = new RingBuffer(prog->GetFileName(), true);
+    QString filename = prog->GetFileName();
+    QFileInfo fi(filename);
+    uint io_multiplier = sgroup.ioMultiplier(fi.absolutePath());
+
+    *rb = new RingBuffer(filename, true, true, 12, io_multiplier);
     if (!(*rb)->IsOpen())
     {
         VERBOSE(VB_IMPORTANT, LOC_ERR +
                 QString("RingBuffer '%1' not open...")
-                .arg(prog->GetFileName()));
+                .arg(filename));
 
         delete *rb;
         delete prog;

libs/libmythtv/ThreadedFileWriter.h

@@ -7 +7 @@
 #include <qwaitcondition.h>
 #include <qstring.h>
 
+#include "storagegroup.h"
+
 class ThreadedFileWriter
 {
   public:
-    ThreadedFileWriter(const QString &fname, int flags, mode_t mode);
+    ThreadedFileWriter(const QString &fname, int flags, mode_t mode,
+                       uint io_mult = StorageGroup::DEF_IO_MULTIPLIER);
     ~ThreadedFileWriter();
 
     bool Open(void);
@@ -43 +46 @@
     int             flags;
     mode_t          mode;
     int             fd;
+    uint            io_multiplier;
 
     // state
     bool            no_writes;
@@ -51 +55 @@
     bool            in_dtor;
     bool            ignore_writes;
     long long       tfw_min_write_size;
+    long long       tfw_max_write_size;
 
     // buffer position state
     uint            rpos;    ///< points to end of data written to disk

libs/libmyth/storagegroup.h

@@ -2 +2 @@
 #define _STORAGEGROUP_H
 
 #include <QStringList>
+#include <qmap.h>
 
 #include "libmyth/settings.h"
 #include "libmyth/mythwidgets.h"
 
+class MPUBLIC DirectoryPathSetting : public LineEditSetting,
+                                     public GlobalDBStorage
+{
+  public:
+    DirectoryPathSetting(const QString &name, QString &dir) :
+        LineEditSetting(this, true), GlobalDBStorage(this, name), m_dir(dir)
+    {
+        setLabel(QObject::tr("Directory Path"));
+        QString help = QObject::tr("Specify the path to add to this "
+                                   "storage group.");
+        setHelpText(help);
+    }
+
+    virtual void load(void)
+    {
+        setValue(m_dir);
+    }
+
+    virtual void save(void)
+    {
+        m_dir = getValue();
+    }
+
+  private:
+    QString &m_dir;
+};
+
+class MPUBLIC ioMultiplierSetting : public SpinBoxSetting,
+                                    public GlobalDBStorage
+{
+  public:
+    ioMultiplierSetting(const QString &name, uint &io_multiplier) :
+        SpinBoxSetting(this, 2, 5, 1), GlobalDBStorage(this, name),
+        m_io_multiplier(io_multiplier)
+    {
+        setLabel(QObject::tr("Read/Write Buffer"));
+        QString help = QObject::tr("Specify the amount of buffering to "
+                                   "use for this directory. Default 5. "
+                                   "Use caution when adjusting this.");
+        setHelpText(help);
+    }
+
+    virtual void load(void)
+    {
+        setValue(m_io_multiplier);
+    }
+
+    virtual void save(void)
+    {
+        m_io_multiplier = getValue().toUInt();
+    }
+
+  private:
+    uint &m_io_multiplier;
+};
+
+class DirectoryConfig : public QObject, public ConfigurationWizard
+{
+  public:
+    DirectoryConfig(QString &dir, uint &io_multiplier);
+};
+
 class MPUBLIC StorageGroup: public ConfigurationWizard
 {
   public:
@@ -32 +95 @@
 
     static QStringList getRecordingsGroups(void);
 
+    uint ioMultiplier(QString dirname);
+
+    static const uint DEF_IO_MULTIPLIER = 5;
+
   private:
     QString      m_groupname;
     QString      m_hostname;
     QStringList  m_dirlist;
+    uint         io_multiplier;
 };
 
 class MPUBLIC StorageGroupEditor :
@@ -56 +124 @@
     void doDelete(void);
 
   protected:
+    void editDirectory(QString &dir, uint &io_multiplier);
+
     QString         m_group;
     ListBoxSetting *listbox;
     QString         lastValue;
+    QMap<QString, uint> multiplier_map;
 };
 
 class MPUBLIC StorageGroupListEditor :

libs/libmyth/storagegroup.cpp

@@ -20 +20 @@
     << "DB Backups"
     ;
 
+DirectoryConfig::DirectoryConfig(QString &dir, uint &io_multiplier)
+{
+    ConfigurationGroup* group = new VerticalConfigurationGroup(false, false);
+
+    if (dir.isEmpty())
+        group->setLabel(QObject::tr("Add new directory"));
+    else
+        group->setLabel(QObject::tr("Settings for directory: ") + dir);
+
+    group->addChild(new DirectoryPathSetting("directoryEdit", dir));
+    group->addChild(new ioMultiplierSetting("multiplierEdit", io_multiplier));
+
+    addChild(group);
+}
+
+
 /****************************************************************************/
 
 /** \brief StorageGroup constructor.
@@ -327 +343 @@
     return groups;
 }
 
+uint StorageGroup::ioMultiplier(QString dirname)
+{
+    if (dirname.isEmpty() || m_groupname.isEmpty() || m_hostname.isEmpty())
+        return StorageGroup::DEF_IO_MULTIPLIER;
+
+    QString dirname_t = dirname;
+
+    if (dirname.endsWith("/"))
+        dirname_t.chop(1);
+    else
+        dirname_t.append("/");
+
+    uint io_multiplier;
+    MSqlQuery query(MSqlQuery::InitCon());
+
+    query.prepare("SELECT io_multiplier FROM storagegroup "
+                  "WHERE groupname = :GROUP "
+                  "AND hostname = :HOSTNAME "
+                  "AND (dirname = :DIRNAME  "
+                  "OR dirname = :DIRNAME_T);");
+    query.bindValue(":GROUP", m_groupname);
+    query.bindValue(":HOSTNAME", m_hostname);
+    query.bindValue(":DIRNAME", dirname);
+    query.bindValue(":DIRNAME_T", dirname_t);
+
+    if (!query.exec() || !query.isActive())
+        MythDB::DBError("StorageGroup::ioMultiplier()", query);
+    else if (!query.next())
+    {
+        VERBOSE(VB_FILE, LOC + QString("Unable to find storage group %1 "
+                                       "for hostname %2, using default "
+                                       "io_multiplier of %3.")
+                                     .arg(m_groupname).arg(m_hostname)
+                                     .arg(StorageGroup::DEF_IO_MULTIPLIER));
+
+        return StorageGroup::DEF_IO_MULTIPLIER;
+    }
+
+    io_multiplier = query.value(0).toUInt();
+
+    if (!io_multiplier)
+        io_multiplier = StorageGroup::DEF_IO_MULTIPLIER;
+
+    return io_multiplier;
+}
+
 /****************************************************************************/
 typedef enum {
     SGPopup_OK = 0,
@@ -401 +463 @@
 
     if (name == "__CREATE_NEW_STORAGE_DIRECTORY__")
     {
+        uint m_io_multiplier = StorageGroup::DEF_IO_MULTIPLIER;
         name = "";
-        SGPopupResult result = StorageGroupPopup::showPopup(
-            gContext->GetMainWindow(), 
-            tr("Add Storage Group Directory"),
-            tr("Enter directory name or press SELECT to enter text via the "
-               "On Screen Keyboard"), name);
-        if (result == SGPopup_CANCEL)
+            
+        DirectoryConfig config(name, m_io_multiplier);
+        
+        if (config.exec() != MythDialog::Accepted)
             return;
 
         if (name.isEmpty())
@@ -417 +478 @@
             name.append("/");
 
         MSqlQuery query(MSqlQuery::InitCon());
-        query.prepare("INSERT INTO storagegroup (groupname, hostname, dirname) "
-                      "VALUES (:NAME, :HOSTNAME, :DIRNAME);");
+        query.prepare("INSERT INTO storagegroup (groupname, hostname, "
+                      "dirname, io_multiplier) "
+                      "VALUES (:NAME, :HOSTNAME, :DIRNAME, :IO_MULTIPLIER);");
         query.bindValue(":NAME", m_group);
         query.bindValue(":DIRNAME", name);
+        query.bindValue(":IO_MULTIPLIER", m_io_multiplier);
         query.bindValue(":HOSTNAME", gContext->GetHostName());
         if (!query.exec())
             MythDB::DBError("StorageGroupEditor::open", query);
         else
             lastValue = name;
     } else {
-        SGPopupResult result = StorageGroupPopup::showPopup(
-            gContext->GetMainWindow(), 
-            tr("Edit Storage Group Directory"),
-            tr("Enter directory name or press SELECT to enter text via the "
-               "On Screen Keyboard"), name);
-        if (result == SGPopup_CANCEL)
+        uint m_io_multiplier = multiplier_map[name];
+        
+        if (!m_io_multiplier)
+            m_io_multiplier = StorageGroup::DEF_IO_MULTIPLIER;
+        
+        DirectoryConfig config(name, m_io_multiplier);
+        
+        if (config.exec() != MythDialog::Accepted)
             return;
 
         if (name.right(1) != "/")
@@ -450 +515 @@
         if (!query.exec())
             MythDB::DBError("StorageGroupEditor::open", query);
 
-        query.prepare("INSERT INTO storagegroup (groupname, hostname, dirname) "
-                      "VALUES (:NAME, :HOSTNAME, :DIRNAME);");
+        query.prepare("INSERT INTO storagegroup (groupname, hostname, "
+                      "dirname, io_multiplier) "
+                      "VALUES (:NAME, :HOSTNAME, :DIRNAME, :IO_MULTIPLIER);");
         query.bindValue(":NAME", m_group);
         query.bindValue(":DIRNAME", name);
+        query.bindValue(":IO_MULTIPLIER", m_io_multiplier);
         query.bindValue(":HOSTNAME", gContext->GetHostName());
         if (!query.exec())
             MythDB::DBError("StorageGroupEditor::open", query);
@@ -502 +569 @@
 void StorageGroupEditor::Load(void)
 {
     listbox->clearSelections();
+    multiplier_map.clear();
 
     MSqlQuery query(MSqlQuery::InitCon());
-    query.prepare("SELECT dirname, id FROM storagegroup "
+    query.prepare("SELECT dirname, io_multiplier, id FROM storagegroup "
                   "WHERE groupname = :NAME AND hostname = :HOSTNAME "
                   "ORDER BY id;");
     query.bindValue(":NAME", m_group);
@@ -522 +590 @@
                 first = false;
             }
             listbox->addSelection(query.value(0).toString());
+            multiplier_map[query.value(0).toString()] = query.value(1).toUInt();
         }
     }
 
@@ -548 +617 @@
     return dialog;
 }
 
+
 /****************************************************************************/
 
 StorageGroupListEditor::StorageGroupListEditor(void) :

programs/mythbackend/mainserver.h

@@ -150 +150 @@
     FileTransfer *getFileTransferByID(int id);
     FileTransfer *getFileTransferBySock(MythSocket *socket);
 
-    QString LocalFilePath(const QUrl &url);
+    QString LocalFilePath(const QUrl &url, uint &io_multiplier);
 
     static void *SpawnDeleteThread(void *param);
     void DoDeleteThread(const DeleteStruct *ds);

programs/mythbackend/filetransfer.cpp

@@ -8 +8 @@
 #include "mythsocket.h"
 
 FileTransfer::FileTransfer(QString &filename, MythSocket *remote,
-                           bool usereadahead, int retries) :
+                           bool usereadahead, int retries, uint io_mult) :
     readthreadlive(true), readsLocked(false),
-    rbuffer(new RingBuffer(filename, false, usereadahead, retries)),
+    rbuffer(new RingBuffer(filename, false, usereadahead, retries, io_mult)),
     sock(remote), ateof(false), lock(QMutex::NonRecursive),
     refLock(QMutex::NonRecursive), refCount(0)
 {
 }
 
-FileTransfer::FileTransfer(QString &filename, MythSocket *remote) :
+FileTransfer::FileTransfer(QString &filename, MythSocket *remote,
+                           uint io_mult) :
     readthreadlive(true), readsLocked(false),
-    rbuffer(new RingBuffer(filename, false)),
+    rbuffer(new RingBuffer(filename, false, true, 12, io_mult)),
     sock(remote), ateof(false), lock(QMutex::NonRecursive),
     refLock(QMutex::NonRecursive), refCount(0)
 {

programs/mythbackend/mainserver.cpp

@@ -1054 +1054 @@
         VERBOSE(VB_IMPORTANT, QString("adding: %1 as a remote file transfer")
                                .arg(commands[2]));
         QUrl qurl = slist[1];
-        QString filename = LocalFilePath(qurl);
+        uint io_multiplier = 0;
 
+        QString filename = LocalFilePath(qurl, io_multiplier);
+
         FileTransfer *ft = NULL;
         bool usereadahead = true;
         int retries = -1;
@@ -1066 +1068 @@
         }
 
         if (retries >= 0)
-            ft = new FileTransfer(filename, socket, usereadahead, retries);
+            ft = new FileTransfer(filename, socket, usereadahead, retries,
+                                  io_multiplier);
         else
-            ft = new FileTransfer(filename, socket);
+            ft = new FileTransfer(filename, socket, io_multiplier);
 
         sockListLock.lock();
         fileTransferList.push_back(ft);
@@ -4349 +4352 @@
         QApplication::exit(m_exitCode);
 }
 
-QString MainServer::LocalFilePath(const QUrl &url)
+QString MainServer::LocalFilePath(const QUrl &url, uint &io_multiplier)
 {
     QString lpath = url.path();
 
+    io_multiplier = StorageGroup::DEF_IO_MULTIPLIER;
+
     if (lpath.section('/', -2, -2) == "channels")
     {
         // This must be an icon request. Check channel.icon to be safe.
@@ -4386 +4391 @@
         ProgramInfo *pginfo = ProgramInfo::GetProgramFromBasename(fpath);
         if (pginfo)
         {
+            StorageGroup sgroup(pginfo->storagegroup, gContext->GetHostName());
+            QString dirname =
+              sgroup.FindRecordingDir(pginfo->GetRecordBasename());
+            io_multiplier = sgroup.ioMultiplier(dirname);
             QString pburl = GetPlaybackURL(pginfo);
             if (pburl.left(1) == "/")
             {
@@ -4410 +4419 @@
             lpath = QFileInfo(lpath).fileName();
             StorageGroup sgroup;
             QString tmpFile = sgroup.FindRecordingFile(lpath);
+            QFileInfo fi(tmpFile);
+            io_multiplier = sgroup.ioMultiplier(fi.absolutePath());
             if (!tmpFile.isEmpty())
             {
                 lpath = tmpFile;

programs/mythbackend/filetransfer.h

@@ -13 +13 @@
 #include <qmutex.h>
 #include <qwaitcondition.h>
 
+#include "storagegroup.h"
+
 class RingBuffer;
 class MythSocket;
 
@@ -21 +23 @@
     friend class QObject; // quiet OSX gcc warning
 
   public:
-    FileTransfer(QString &filename, MythSocket *remote);
     FileTransfer(QString &filename, MythSocket *remote,
-                 bool usereadahead, int retries);
+                 uint io_mult = StorageGroup::DEF_IO_MULTIPLIER);
+    FileTransfer(QString &filename, MythSocket *remote, bool usereadahead,
+                 int retries, uint io_mult = StorageGroup::DEF_IO_MULTIPLIER);
 
     MythSocket *getSocket() { return sock; }