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	/***************************************************************************
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	}