src/network/lscpinstrumentloader.cpp

/***************************************************************************
 *                                                                         *
 *   Copyright (C) 2005 Christian Schoenebeck                              *
 *                                                                         *
 *   This library 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.                                   *
 *                                                                         *
 *   This library is distributed in the hope that it will be useful,       *
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
 *   GNU General Public License for more details.                          *
 *                                                                         *
 *   You should have received a copy of the GNU General Public License     *
 *   along with this library; if not, write to the Free Software           *
 *   Foundation, Inc., 59 Temple Place, Suite 330, Boston,                 *
 *   MA  02111-1307  USA                                                   *
 ***************************************************************************/

#include "lscpinstrumentloader.h"

LSCPInstrumentLoader::LSCPInstrumentLoader() : Thread(false, 0, -4) {
    pQueue = new RingBuffer<command_t>(INSTRUMENT_LOADER_QUEUE_SIZE);
}

LSCPInstrumentLoader::~LSCPInstrumentLoader() {
    if (pQueue) delete pQueue;
}

/**
 * @brief Order loading of a new instrument.
 * The request will go into a queue waiting to be processed by the loader
 * thread. This method will immediately return and the instrument will be
 * loaded in the background.
 *
 * @param Filename - file name of the instrument
 * @param uiInstrumentIndex - index of the instrument within the file
 * @param pEngine - engine on which the instrument should be loaded
 */
void LSCPInstrumentLoader::StartNewLoad(String Filename, uint uiInstrumentIndex, Engine* pEngine) {
    command_t cmd;
    cmd.Filename          = Filename;
    cmd.uiInstrumentIndex = uiInstrumentIndex;
    cmd.pEngine           = pEngine;
    pQueue->push(&cmd);
    StartThread(); // ensure the thread is running
}

// Entry point for the InstrumentLoader Thread.
int LSCPInstrumentLoader::Main() {
    while (pQueue->read_space()) {
        command_t cmd;
        pQueue->pop(&cmd);
        try {
            cmd.pEngine->LoadInstrument(cmd.Filename.c_str(), cmd.uiInstrumentIndex);
        }
        catch (LinuxSamplerException e) {
            e.PrintMessage();
        }
        // Always re-enable the engine.
        cmd.pEngine->Enable();
    }

    // nothing left to do
    StopThread();
}
1	schoenebeck	385	/***************************************************************************
2			* *
3			* Copyright (C) 2005 Christian Schoenebeck *
4			* *
5			* This library is free software; you can redistribute it and/or modify *
6			* it under the terms of the GNU General Public License as published by *
7			* the Free Software Foundation; either version 2 of the License, or *
8			* (at your option) any later version. *
9			* *
10			* This library is distributed in the hope that it will be useful, *
11			* but WITHOUT ANY WARRANTY; without even the implied warranty of *
12			* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
13			* GNU General Public License for more details. *
14			* *
15			* You should have received a copy of the GNU General Public License *
16			* along with this library; if not, write to the Free Software *
17			* Foundation, Inc., 59 Temple Place, Suite 330, Boston, *
18			* MA 02111-1307 USA *
19			***************************************************************************/
20
21			#include "lscpinstrumentloader.h"
22
23			LSCPInstrumentLoader::LSCPInstrumentLoader() : Thread(false, 0, -4) {
24			pQueue = new RingBuffer<command_t>(INSTRUMENT_LOADER_QUEUE_SIZE);
25			}
26
27			LSCPInstrumentLoader::~LSCPInstrumentLoader() {
28			if (pQueue) delete pQueue;
29			}
30
31			/**
32			* @brief Order loading of a new instrument.
33			* The request will go into a queue waiting to be processed by the loader
34			* thread. This method will immediately return and the instrument will be
35			* loaded in the background.
36			*
37			* @param Filename - file name of the instrument
38			* @param uiInstrumentIndex - index of the instrument within the file
39			* @param pEngine - engine on which the instrument should be loaded
40			*/
41			void LSCPInstrumentLoader::StartNewLoad(String Filename, uint uiInstrumentIndex, Engine* pEngine) {
42			command_t cmd;
43			cmd.Filename = Filename;
44			cmd.uiInstrumentIndex = uiInstrumentIndex;
45			cmd.pEngine = pEngine;
46			pQueue->push(&cmd);
47			StartThread(); // ensure the thread is running
48			}
49
50			// Entry point for the InstrumentLoader Thread.
51			int LSCPInstrumentLoader::Main() {
52			while (pQueue->read_space()) {
53			command_t cmd;
54			pQueue->pop(&cmd);
55			try {
56			cmd.pEngine->LoadInstrument(cmd.Filename.c_str(), cmd.uiInstrumentIndex);
57			}
58			catch (LinuxSamplerException e) {
59			e.PrintMessage();
60			}
61			// Always re-enable the engine.
62			cmd.pEngine->Enable();
63			}
64
65			// nothing left to do
66			StopThread();
67			}