diff options
Diffstat (limited to 'common/JackServerGlobals.cpp')
| -rw-r--r-- | common/JackServerGlobals.cpp | 507 |
1 files changed, 254 insertions, 253 deletions
diff --git a/common/JackServerGlobals.cpp b/common/JackServerGlobals.cpp index 99b962fd..f4dda14b 100644 --- a/common/JackServerGlobals.cpp +++ b/common/JackServerGlobals.cpp @@ -1,5 +1,5 @@ /* -Copyright (C) 2005 Grame +Copyright (C) 2005 Grame 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 @@ -17,7 +17,7 @@ Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */ -#ifdef WIN32 +#ifdef WIN32 #pragma warning (disable : 4786) #endif @@ -28,7 +28,7 @@ Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. #include <getopt.h> #ifndef WIN32 - #include <dirent.h> +#include <dirent.h> #endif static char* server_name = NULL; @@ -39,19 +39,19 @@ namespace Jack unsigned int JackServerGlobals::fClientCount = 0; JackServer* JackServerGlobals::fServer = NULL; -int JackServerGlobals::Start(const char* server_name, - jack_driver_desc_t* driver_desc, - JSList* driver_params, - int sync, - int temporary, - int time_out_ms, - int rt, - int priority, - int loopback, - int verbose) +int JackServerGlobals::Start(const char* server_name, + jack_driver_desc_t* driver_desc, + JSList* driver_params, + int sync, + int temporary, + int time_out_ms, + int rt, + int priority, + int loopback, + int verbose) { JackLog("Jackdmp: sync = %ld timeout = %ld rt = %ld priority = %ld verbose = %ld \n", sync, time_out_ms, rt, priority, verbose); - fServer = new JackServer(sync, temporary, time_out_ms, rt, priority, loopback, verbose, server_name); + fServer = new JackServer(sync, temporary, time_out_ms, rt, priority, loopback, verbose, server_name); int res = fServer->Open(driver_desc, driver_params); return (res < 0) ? res : fServer->Start(); } @@ -75,253 +75,254 @@ int JackServerGlobals::Delete() bool JackServerGlobals::Init() { - if (fClientCount++ == 0) { - + if (fClientCount++ == 0) { + JackLog("JackServerGlobals Init\n"); - int realtime = 0; - int client_timeout = 0; /* msecs; if zero, use period size. */ - int realtime_priority = 10; - int verbose_aux = 0; - int do_mlock = 1; - unsigned int port_max = 128; - int loopback = 0; - int do_unlock = 0; - int temporary = 0; - - jack_driver_desc_t* driver_desc; - const char *options = "-ad:P:uvshVRL:STFl:t:mn:p:"; - static struct option long_options[] = { - { "driver", 1, 0, 'd'}, - { "verbose", 0, 0, 'v' }, - { "help", 0, 0, 'h' }, - { "port-max", 1, 0, 'p' }, - { "no-mlock", 0, 0, 'm' }, - { "name", 0, 0, 'n' }, - { "unlock", 0, 0, 'u' }, - { "realtime", 0, 0, 'R' }, - { "loopback", 0, 0, 'L' }, - { "realtime-priority", 1, 0, 'P' }, - { "timeout", 1, 0, 't' }, - { "temporary", 0, 0, 'T' }, - { "version", 0, 0, 'V' }, - { "silent", 0, 0, 's' }, - { "sync", 0, 0, 'S' }, - { 0, 0, 0, 0 } - }; - int opt = 0; - int option_index = 0; - int seen_driver = 0; - char *driver_name = NULL; - char **driver_args = NULL; - JSList* driver_params; - int driver_nargs = 1; - JSList* drivers = NULL; - int show_version = 0; - int sync = 0; - int rc, i; - int ret; - - FILE* fp = 0; - char filename[255]; - char buffer[255]; - int argc = 0; - char* argv[32]; - - snprintf(filename, 255, "%s/.jackdrc", getenv("HOME")); - fp = fopen(filename, "r"); - - if (!fp) { - fp = fopen("/etc/jackdrc", "r"); - } - // if still not found, check old config name for backwards compatability - if (!fp) { - fp = fopen("/etc/jackd.conf", "r"); - } - - argc = 0; - if (fp) { - ret = fscanf(fp, "%s", buffer); - while (ret != 0 && ret != EOF) { - argv[argc] = (char*)malloc(64); - strcpy(argv[argc], buffer); - ret = fscanf(fp, "%s", buffer); - argc++; - } - fclose(fp); - } - - /* - For testing - int argc = 15; - char* argv[] = {"jackdmp", "-R", "-v", "-d", "coreaudio", "-p", "512", "-d", "~:Aggregate:0", "-r", "48000", "-i", "2", "-o", "2" }; - */ - - opterr = 0; - optind = 1; // Important : to reset argv parsing - - while (!seen_driver && - (opt = getopt_long(argc, argv, options, long_options, &option_index)) != EOF) { - - switch (opt) { - - case 'd': - seen_driver = 1; - driver_name = optarg; - break; - - case 'v': - verbose_aux = 1; - break; - - case 'S': - sync = 1; - break; - - case 'n': - server_name = optarg; - break; - - case 'm': - do_mlock = 0; - break; - - case 'p': - port_max = (unsigned int)atol(optarg); - break; - - case 'P': - realtime_priority = atoi(optarg); - break; - - case 'R': - realtime = 1; - break; - - case 'L': - loopback = atoi(optarg); - break; - - case 'T': - temporary = 1; - break; - - case 't': - client_timeout = atoi(optarg); - break; - - case 'u': - do_unlock = 1; - break; - - case 'V': - show_version = 1; - break; - - default: - fprintf(stderr, "unknown option character %c\n", optopt); - break; - } - } - - drivers = jack_drivers_load(drivers); - if (!drivers) { - fprintf(stderr, "jackdmp: no drivers found; exiting\n"); - goto error; - } - - driver_desc = jack_find_driver_descriptor(drivers, driver_name); - if (!driver_desc) { - fprintf(stderr, "jackdmp: unknown driver '%s'\n", driver_name); - goto error; - } - - if (optind < argc) { - driver_nargs = 1 + argc - optind; - } else { - driver_nargs = 1; - } - - if (driver_nargs == 0) { - fprintf(stderr, "No driver specified ... hmm. JACK won't do" - " anything when run like this.\n"); - goto error; - } - - driver_args = (char**)malloc(sizeof(char*) * driver_nargs); - driver_args[0] = driver_name; - - for (i = 1; i < driver_nargs; i++) { - driver_args[i] = argv[optind++]; - } - - if (jack_parse_driver_params(driver_desc, driver_nargs, driver_args, &driver_params)) { - goto error; - } - - #ifndef WIN32 - if (server_name == NULL) - server_name = (char*)JackTools::DefaultServerName(); - #endif - - rc = jack_register_server(server_name, false); - switch (rc) { - case EEXIST: - fprintf(stderr, "`%s' server already active\n", server_name); - goto error; - case ENOSPC: - fprintf(stderr, "too many servers already active\n"); - goto error; - case ENOMEM: - fprintf(stderr, "no access to shm registry\n"); - goto error; - default: - if (jack_verbose) - fprintf(stderr, "server `%s' registered\n", server_name); - } - - /* clean up shared memory and files from any previous instance of this server name */ - jack_cleanup_shm(); - #ifndef WIN32 - JackTools::CleanupFiles(server_name); - #endif - - if (!realtime && client_timeout == 0) - client_timeout = 500; /* 0.5 sec; usable when non realtime. */ - - for (i = 0; i < argc; i++) { - free(argv[i]); - } - - int res = Start(server_name, driver_desc, driver_params, sync, temporary, client_timeout, realtime, realtime_priority, loopback, verbose_aux); - if (res < 0) { - jack_error("Cannot start server... exit"); - Delete(); - jack_cleanup_shm(); - #ifndef WIN32 - JackTools::CleanupFiles(server_name); - #endif - jack_unregister_server(server_name); - goto error; - } - } - - return true; - + int realtime = 0; + int client_timeout = 0; /* msecs; if zero, use period size. */ + int realtime_priority = 10; + int verbose_aux = 0; + int do_mlock = 1; + unsigned int port_max = 128; + int loopback = 0; + int do_unlock = 0; + int temporary = 0; + + jack_driver_desc_t* driver_desc; + const char *options = "-ad:P:uvshVRL:STFl:t:mn:p:"; + static struct option long_options[] = { + { "driver", 1, 0, 'd' + }, + { "verbose", 0, 0, 'v' }, + { "help", 0, 0, 'h' }, + { "port-max", 1, 0, 'p' }, + { "no-mlock", 0, 0, 'm' }, + { "name", 0, 0, 'n' }, + { "unlock", 0, 0, 'u' }, + { "realtime", 0, 0, 'R' }, + { "loopback", 0, 0, 'L' }, + { "realtime-priority", 1, 0, 'P' }, + { "timeout", 1, 0, 't' }, + { "temporary", 0, 0, 'T' }, + { "version", 0, 0, 'V' }, + { "silent", 0, 0, 's' }, + { "sync", 0, 0, 'S' }, + { 0, 0, 0, 0 } + }; + int opt = 0; + int option_index = 0; + int seen_driver = 0; + char *driver_name = NULL; + char **driver_args = NULL; + JSList* driver_params; + int driver_nargs = 1; + JSList* drivers = NULL; + int show_version = 0; + int sync = 0; + int rc, i; + int ret; + + FILE* fp = 0; + char filename[255]; + char buffer[255]; + int argc = 0; + char* argv[32]; + + snprintf(filename, 255, "%s/.jackdrc", getenv("HOME")); + fp = fopen(filename, "r"); + + if (!fp) { + fp = fopen("/etc/jackdrc", "r"); + } + // if still not found, check old config name for backwards compatability + if (!fp) { + fp = fopen("/etc/jackd.conf", "r"); + } + + argc = 0; + if (fp) { + ret = fscanf(fp, "%s", buffer); + while (ret != 0 && ret != EOF) { + argv[argc] = (char*)malloc(64); + strcpy(argv[argc], buffer); + ret = fscanf(fp, "%s", buffer); + argc++; + } + fclose(fp); + } + + /* + For testing + int argc = 15; + char* argv[] = {"jackdmp", "-R", "-v", "-d", "coreaudio", "-p", "512", "-d", "~:Aggregate:0", "-r", "48000", "-i", "2", "-o", "2" }; + */ + + opterr = 0; + optind = 1; // Important : to reset argv parsing + + while (!seen_driver && + (opt = getopt_long(argc, argv, options, long_options, &option_index)) != EOF) { + + switch (opt) { + + case 'd': + seen_driver = 1; + driver_name = optarg; + break; + + case 'v': + verbose_aux = 1; + break; + + case 'S': + sync = 1; + break; + + case 'n': + server_name = optarg; + break; + + case 'm': + do_mlock = 0; + break; + + case 'p': + port_max = (unsigned int)atol(optarg); + break; + + case 'P': + realtime_priority = atoi(optarg); + break; + + case 'R': + realtime = 1; + break; + + case 'L': + loopback = atoi(optarg); + break; + + case 'T': + temporary = 1; + break; + + case 't': + client_timeout = atoi(optarg); + break; + + case 'u': + do_unlock = 1; + break; + + case 'V': + show_version = 1; + break; + + default: + fprintf(stderr, "unknown option character %c\n", optopt); + break; + } + } + + drivers = jack_drivers_load(drivers); + if (!drivers) { + fprintf(stderr, "jackdmp: no drivers found; exiting\n"); + goto error; + } + + driver_desc = jack_find_driver_descriptor(drivers, driver_name); + if (!driver_desc) { + fprintf(stderr, "jackdmp: unknown driver '%s'\n", driver_name); + goto error; + } + + if (optind < argc) { + driver_nargs = 1 + argc - optind; + } else { + driver_nargs = 1; + } + + if (driver_nargs == 0) { + fprintf(stderr, "No driver specified ... hmm. JACK won't do" + " anything when run like this.\n"); + goto error; + } + + driver_args = (char**)malloc(sizeof(char*) * driver_nargs); + driver_args[0] = driver_name; + + for (i = 1; i < driver_nargs; i++) { + driver_args[i] = argv[optind++]; + } + + if (jack_parse_driver_params(driver_desc, driver_nargs, driver_args, &driver_params)) { + goto error; + } + +#ifndef WIN32 + if (server_name == NULL) + server_name = (char*)JackTools::DefaultServerName(); +#endif + + rc = jack_register_server(server_name, false); + switch (rc) { + case EEXIST: + fprintf(stderr, "`%s' server already active\n", server_name); + goto error; + case ENOSPC: + fprintf(stderr, "too many servers already active\n"); + goto error; + case ENOMEM: + fprintf(stderr, "no access to shm registry\n"); + goto error; + default: + if (jack_verbose) + fprintf(stderr, "server `%s' registered\n", server_name); + } + + /* clean up shared memory and files from any previous instance of this server name */ + jack_cleanup_shm(); +#ifndef WIN32 + JackTools::CleanupFiles(server_name); +#endif + + if (!realtime && client_timeout == 0) + client_timeout = 500; /* 0.5 sec; usable when non realtime. */ + + for (i = 0; i < argc; i++) { + free(argv[i]); + } + + int res = Start(server_name, driver_desc, driver_params, sync, temporary, client_timeout, realtime, realtime_priority, loopback, verbose_aux); + if (res < 0) { + jack_error("Cannot start server... exit"); + Delete(); + jack_cleanup_shm(); +#ifndef WIN32 + JackTools::CleanupFiles(server_name); +#endif + jack_unregister_server(server_name); + goto error; + } + } + + return true; + error: - fClientCount--; - return false; + fClientCount--; + return false; } void JackServerGlobals::Destroy() { if (--fClientCount == 0) { JackLog("JackServerGlobals Destroy\n"); - Stop(); - jack_cleanup_shm(); - #ifndef WIN32 - JackTools::CleanupFiles(server_name); - #endif - jack_unregister_server(server_name); + Stop(); + jack_cleanup_shm(); +#ifndef WIN32 + JackTools::CleanupFiles(server_name); +#endif + jack_unregister_server(server_name); } } |