/[svn]/linuxsampler/trunk/src/linuxsampler.cpp
ViewVC logotype

Contents of /linuxsampler/trunk/src/linuxsampler.cpp

Parent Directory Parent Directory | Revision Log Revision Log


Revision 1297 - (show annotations) (download)
Thu Aug 16 15:55:21 2007 UTC (16 years, 7 months ago) by iliev
File size: 14755 byte(s)
* bugfix: the active stream/voice count statistic was incorrect

1 /***************************************************************************
2 * *
3 * LinuxSampler - modular, streaming capable sampler *
4 * *
5 * Copyright (C) 2003-2004 by Benno Senoner and Christian Schoenebeck *
6 * Copyright (C) 2005-2007 Christian Schoenebeck *
7 * *
8 * This program is free software; you can redistribute it and/or modify *
9 * it under the terms of the GNU General Public License as published by *
10 * the Free Software Foundation; either version 2 of the License, or *
11 * (at your option) any later version. *
12 * *
13 * This program is distributed in the hope that it will be useful, *
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of *
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
16 * GNU General Public License for more details. *
17 * *
18 * You should have received a copy of the GNU General Public License *
19 * along with this program; if not, write to the Free Software *
20 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, *
21 * MA 02111-1307 USA *
22 ***************************************************************************/
23
24 #include <getopt.h>
25 #include <signal.h>
26
27 #include "Sampler.h"
28 #include "engines/EngineFactory.h"
29 #include "engines/InstrumentEditorFactory.h"
30 #include "drivers/midi/MidiInputDeviceFactory.h"
31 #include "drivers/audio/AudioOutputDeviceFactory.h"
32 #include "engines/gig/Profiler.h"
33 #include "network/lscpserver.h"
34 #include "common/stacktrace.h"
35 #include "common/Features.h"
36
37 using namespace LinuxSampler;
38
39 Sampler* pSampler = NULL;
40 LSCPServer* pLSCPServer = NULL;
41 pthread_t main_thread;
42 pid_t main_pid;
43 bool bPrintStatistics = false;
44 bool profile = false;
45 bool tune = true;
46 unsigned long int lscp_addr;
47 unsigned short int lscp_port;
48
49 void parse_options(int argc, char **argv);
50 void signal_handler(int signal);
51 void kill_app();
52
53 int main(int argc, char **argv) {
54
55 // initialize the stack trace mechanism with our binary file
56 StackTraceInit(argv[0], -1);
57
58 main_pid = getpid();
59 main_thread = pthread_self();
60
61 // setting signal handler for catching SIGINT (thus e.g. <CTRL><C>)
62 signal(SIGINT, signal_handler);
63
64 // register signal handler for all unusual signals
65 // (we will print the stack trace and exit)
66 struct sigaction sact;
67 sigemptyset(&sact.sa_mask);
68 sact.sa_flags = 0;
69 sact.sa_handler = signal_handler;
70 sigaction(SIGSEGV, &sact, NULL);
71 sigaction(SIGBUS, &sact, NULL);
72 sigaction(SIGILL, &sact, NULL);
73 sigaction(SIGFPE, &sact, NULL);
74 sigaction(SIGUSR1, &sact, NULL);
75 sigaction(SIGUSR2, &sact, NULL);
76
77 lscp_addr = htonl(LSCP_ADDR);
78 lscp_port = htons(LSCP_PORT);
79
80 // parse and assign command line options
81 parse_options(argc, argv);
82
83 dmsg(1,("LinuxSampler %s\n", VERSION));
84 dmsg(1,("Copyright (C) 2003,2004 by Benno Senoner and Christian Schoenebeck\n"));
85 dmsg(1,("Copyright (C) 2005-2007 Christian Schoenebeck\n"));
86
87 if (tune) {
88 // detect and print system / CPU specific features
89 Features::detect();
90 dmsg(1,("Detected features: %s\n", Features::featuresAsString().c_str()));
91 // prevent slow denormal FPU modes
92 Features::enableDenormalsAreZeroMode();
93 }
94
95 // create LinuxSampler instance
96 dmsg(1,("Creating Sampler..."));
97 pSampler = new Sampler;
98 dmsg(1,("OK\n"));
99
100 dmsg(1,("Registered sampler engines: %s\n", EngineFactory::AvailableEngineTypesAsString().c_str()));
101 dmsg(1,("Registered MIDI input drivers: %s\n", MidiInputDeviceFactory::AvailableDriversAsString().c_str()));
102 dmsg(1,("Registered audio output drivers: %s\n", AudioOutputDeviceFactory::AvailableDriversAsString().c_str()));
103 dmsg(1,("Registered instrument editors: %s\n", InstrumentEditorFactory::AvailableEditorsAsString().c_str()));
104
105 // start LSCP network server
106 struct in_addr addr;
107 addr.s_addr = lscp_addr;
108 dmsg(1,("Starting LSCP network server (%s:%d)...", inet_ntoa(addr), ntohs(lscp_port)));
109 pLSCPServer = new LSCPServer(pSampler, lscp_addr, lscp_port);
110 pLSCPServer->StartThread();
111 pLSCPServer->WaitUntilInitialized();
112 dmsg(1,("OK\n"));
113
114 if (profile)
115 {
116 dmsg(1,("Calibrating profiler..."));
117 LinuxSampler::gig::Profiler::Calibrate();
118 LinuxSampler::gig::Profiler::Reset();
119 LinuxSampler::gig::Profiler::enable();
120 dmsg(1,("OK\n"));
121 }
122
123 printf("LinuxSampler initialization completed. :-)\n\n");
124
125 std::list<LSCPEvent::event_t> rtEvents;
126 rtEvents.push_back(LSCPEvent::event_voice_count);
127 rtEvents.push_back(LSCPEvent::event_stream_count);
128 rtEvents.push_back(LSCPEvent::event_buffer_fill);
129 rtEvents.push_back(LSCPEvent::event_total_voice_count);
130
131 while (true) {
132 if (bPrintStatistics) {
133 const std::set<Engine*>& engines = EngineFactory::EngineInstances();
134 std::set<Engine*>::iterator itEngine = engines.begin();
135 for (int i = 0; itEngine != engines.end(); itEngine++, i++) {
136 Engine* pEngine = *itEngine;
137 printf("Engine %d) Voices: %3.3d (Max: %3.3d) Streams: %3.3d (Max: %3.3d)\n", i,
138 pEngine->VoiceCount(), pEngine->VoiceCountMax(),
139 pEngine->DiskStreamCount(), pEngine->DiskStreamCountMax()
140 );
141 fflush(stdout);
142 }
143 }
144
145 sleep(1);
146 if (profile)
147 {
148 unsigned int samplingFreq = 48000; //FIXME: hardcoded for now
149 unsigned int bv = LinuxSampler::gig::Profiler::GetBogoVoices(samplingFreq);
150 if (bv != 0)
151 {
152 printf(" BogoVoices: %i \r", bv);
153 fflush(stdout);
154 }
155 }
156
157 if (LSCPServer::EventSubscribers(rtEvents))
158 {
159 LSCPServer::LockRTNotify();
160 std::map<uint,SamplerChannel*> channels = pSampler->GetSamplerChannels();
161 std::map<uint,SamplerChannel*>::iterator iter = channels.begin();
162 for (; iter != channels.end(); iter++) {
163 SamplerChannel* pSamplerChannel = iter->second;
164 EngineChannel* pEngineChannel = pSamplerChannel->GetEngineChannel();
165 if (!pEngineChannel) continue;
166 Engine* pEngine = pEngineChannel->GetEngine();
167 if (!pEngine) continue;
168 pSampler->fireVoiceCountChanged(iter->first, pEngineChannel->GetVoiceCount());
169 pSampler->fireStreamCountChanged(iter->first, pEngineChannel->GetDiskStreamCount());
170 pSampler->fireBufferFillChanged(iter->first, pEngine->DiskStreamBufferFillPercentage());
171 pSampler->fireTotalVoiceCountChanged(pSampler->GetVoiceCount());
172 }
173 LSCPServer::UnlockRTNotify();
174 }
175
176 }
177
178 return EXIT_SUCCESS;
179 }
180
181 void signal_handler(int iSignal) {
182 switch (iSignal) {
183 case SIGINT: {
184 if (pthread_equal(pthread_self(), main_thread)) {
185 if (pLSCPServer) pLSCPServer->StopThread();
186 // the delete order here is important: the Sampler
187 // destructor sends notifications to the lscpserver
188 if (pSampler) delete pSampler;
189 if (pLSCPServer) delete pLSCPServer;
190 #if HAVE_SQLITE3
191 InstrumentsDb::Destroy();
192 #endif
193 printf("LinuxSampler stopped due to SIGINT.\n");
194 exit(EXIT_SUCCESS);
195 }
196 return;
197 }
198 case SIGSEGV:
199 std::cerr << ">>> FATAL ERROR: Segmentation fault (SIGSEGV) occured! <<<\n" << std::flush;
200 break;
201 case SIGBUS:
202 std::cerr << ">>> FATAL ERROR: Access to undefined portion of a memory object (SIGBUS) occured! <<<\n" << std::flush;
203 break;
204 case SIGILL:
205 std::cerr << ">>> FATAL ERROR: Illegal instruction (SIGILL) occured! <<<\n" << std::flush;
206 break;
207 case SIGFPE:
208 std::cerr << ">>> FATAL ERROR: Erroneous arithmetic operation (SIGFPE) occured! <<<\n" << std::flush;
209 break;
210 case SIGUSR1:
211 std::cerr << ">>> User defined signal 1 (SIGUSR1) received <<<\n" << std::flush;
212 break;
213 case SIGUSR2:
214 std::cerr << ">>> User defined signal 2 (SIGUSR2) received <<<\n" << std::flush;
215 break;
216 default: { // this should never happen, as we register for the signals we want
217 std::cerr << ">>> FATAL ERROR: Unknown signal received! <<<\n" << std::flush;
218 break;
219 }
220 }
221 signal(iSignal, SIG_DFL); // Reinstall default handler to prevent race conditions
222 std::cerr << "Showing stack trace...\n" << std::flush;
223 StackTrace();
224 sleep(2);
225 std::cerr << "Killing LinuxSampler...\n" << std::flush;
226 kill_app(); // Use abort() if we want to generate a core dump.
227 }
228
229 void kill_app() {
230 kill(main_pid, SIGKILL);
231 }
232
233 void parse_options(int argc, char **argv) {
234 int res;
235 int option_index = 0;
236 static struct option long_options[] =
237 {
238 {"help",0,0,0},
239 {"version",0,0,0},
240 {"profile",0,0,0},
241 {"no-tune",0,0,0},
242 {"statistics",0,0,0},
243 {"instruments-db-location",1,0,0},
244 {"create-instruments-db",1,0,0},
245 {"lscp-addr",1,0,0},
246 {"lscp-port",1,0,0},
247 {0,0,0,0}
248 };
249
250 while (true) {
251 /*
252 Stephane Letz : letz@grame.fr
253 getopt_long_only does not exist on OSX : replaced by getopt_long for now.
254 */
255 res = getopt_long(argc, argv, "", long_options, &option_index);
256 if(res == -1) break;
257 if (res == 0) {
258 switch(option_index) {
259 case 0: // --help
260 printf("usage: linuxsampler [OPTIONS]\n\n");
261 printf("--help prints this message\n");
262 printf("--version prints version information\n");
263 printf("--profile profile synthesis algorithms\n");
264 printf("--no-tune disable assembly optimization\n");
265 printf("--statistics periodically prints statistics\n");
266 printf("--lscp-addr set LSCP address (default: any)\n");
267 printf("--lscp-port set LSCP port (default: 8888)\n");
268 printf("--create-instruments-db creates an instruments DB\n");
269 printf("--instruments-db-location specifies the instruments DB file\n");
270 exit(EXIT_SUCCESS);
271 break;
272 case 1: // --version
273 printf("LinuxSampler %s\n", VERSION);
274 exit(EXIT_SUCCESS);
275 break;
276 case 2: // --profile
277 profile = true;
278 break;
279 case 3: // --no-tune
280 tune = false;
281 break;
282 case 4: // --statistics
283 bPrintStatistics = true;
284 break;
285 case 5: // --instruments-db-location
286 #if HAVE_SQLITE3
287 try {
288 if (optarg) {
289 struct stat statBuf;
290 int res = stat(optarg, &statBuf);
291
292 if (res) {
293 std::stringstream ss;
294 ss << "Fail to stat `" << optarg << "`: " << strerror(errno);
295 throw Exception(ss.str());
296 }
297
298 if (!S_ISREG(statBuf.st_mode)) {
299 std::stringstream ss;
300 ss << "`" << optarg << "` is not a regular file";
301 throw Exception(ss.str());
302 }
303
304 InstrumentsDb::GetInstrumentsDb()->SetDbFile(String(optarg));
305 }
306 } catch(Exception e) {
307 std::cerr << e.Message() << std::endl << std::endl;
308 return;
309 }
310
311 return;
312 #else
313 std::cerr << "LinuxSampler was not build with ";
314 std::cerr << "instruments database support." <<std::endl;
315 return;
316 #endif
317 case 6: // --create-instruments-db
318 #if HAVE_SQLITE3
319 try {
320 if (optarg) {
321 std::cout << "Creating instruments database..." << std::endl;
322 InstrumentsDb::CreateInstrumentsDb(String(optarg));
323 InstrumentsDb::Destroy();
324 std::cout << "Done" << std::endl;
325 }
326 } catch(Exception e) {
327 std::cerr << e.Message() << std::endl;
328 exit(EXIT_FAILURE);
329 return;
330 }
331
332 exit(EXIT_SUCCESS);
333 return;
334 #else
335 std::cerr << "Failed to create the database. LinuxSampler was ";
336 std::cerr << "not build with instruments database support." <<std::endl;
337 exit(EXIT_FAILURE);
338 return;
339 #endif
340 case 7: // --lscp-addr
341 struct in_addr addr;
342 if (inet_aton(optarg, &addr) == 0)
343 printf("WARNING: Failed to parse lscp-addr argument, ignoring!\n");
344 else
345 lscp_addr = addr.s_addr;
346 break;
347 case 8: // --lscp-port
348 long unsigned int port = 0;
349 if ((sscanf(optarg, "%u", &port) != 1) || (port == 0) || (port > 65535))
350 printf("WARNING: Failed to parse lscp-port argument, ignoring!\n");
351 else
352 lscp_port = htons(port);
353 break;
354 }
355 }
356 }
357 }

  ViewVC Help
Powered by ViewVC