/* DeaDBeeF - ultimate music player for GNU/Linux systems with X11 Copyright (C) 2009-2010 Alexey Yakovenko 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 the Free Software Foundation; either version 2 of the License, or (at your option) any later version. This program 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 program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. */ #include #include #include #include #include //#include #include #ifndef __linux__ #define _POSIX_C_SOURCE #endif #include #ifdef HAVE_CONFIG_H # include #endif #include "plugins.h" #include "md5/md5.h" #include "messagepump.h" #include "threading.h" #include "playlist.h" #include "volume.h" #include "streamer.h" #include "playback.h" #include "common.h" #include "conf.h" #include "junklib.h" #include "vfs.h" #define trace(...) { fprintf(stderr, __VA_ARGS__); } //#define trace(fmt,...) #ifndef PATH_MAX #define PATH_MAX 1024 /* max # of characters in a path name */ #endif //#define DISABLE_VERSIONCHECK 1 static uintptr_t mutex; // deadbeef api static DB_functions_t deadbeef_api = { // FIXME: set to 1.0 after api freeze .vmajor = 0, .vminor = 0, .ev_subscribe = plug_ev_subscribe, .ev_unsubscribe = plug_ev_unsubscribe, .md5 = plug_md5, .md5_to_str = plug_md5_to_str, .md5_init = (void (*)(DB_md5_t *s))md5_init, .md5_append = (void (*)(DB_md5_t *s, const uint8_t *daya, int nbytes))md5_append, .md5_finish = (void (*)(DB_md5_t *s, uint8_t digest[16]))md5_finish, .get_output = plug_get_output, .playback_next = plug_playback_next, .playback_prev = plug_playback_prev, .playback_pause = plug_playback_pause, .playback_stop = plug_playback_stop, .playback_play = plug_playback_play, .playback_random = plug_playback_random, .playback_get_pos = plug_playback_get_pos, .playback_set_pos = plug_playback_set_pos, // streamer access .streamer_get_playing_track = (DB_playItem_t *(*) (void))streamer_get_playing_track, .streamer_get_streaming_track = (DB_playItem_t *(*) (void))streamer_get_streaming_track, .streamer_get_playpos = streamer_get_playpos, .streamer_seek = streamer_set_seek, .streamer_ok_to_read = streamer_ok_to_read, .streamer_reset = streamer_reset, .streamer_read = streamer_read, .streamer_set_bitrate = streamer_set_bitrate, .streamer_get_apx_bitrate = streamer_get_apx_bitrate, .streamer_get_current_fileinfo = streamer_get_current_fileinfo, .streamer_get_current_playlist = streamer_get_current_playlist, // process control .get_config_dir = plug_get_config_dir, .quit = plug_quit, // threading .thread_start = thread_start, .thread_start_low_priority = thread_start_low_priority, .thread_join = thread_join, .mutex_create = mutex_create, .mutex_create_nonrecursive = mutex_create_nonrecursive, .mutex_free = mutex_free, .mutex_lock = mutex_lock, .mutex_unlock = mutex_unlock, .cond_create = cond_create, .cond_free = cond_free, .cond_wait = cond_wait, .cond_signal = cond_signal, .cond_broadcast = cond_broadcast, // playlist management .plt_get_count = plt_get_count, .plt_get_head = (DB_playItem_t * (*) (int plt))plt_get_head, .plt_get_sel_count = plt_get_sel_count, .plt_add = plt_add, .plt_remove = plt_remove, .plt_free = plt_free, .plt_set_curr = plt_set_curr, .plt_get_curr = plt_get_curr, .plt_get_title = plt_get_title, .plt_set_title = plt_set_title, .plt_move = plt_move, // playlist access .pl_lock = pl_lock, .pl_unlock = pl_unlock, .plt_lock = plt_lock, .plt_unlock = plt_unlock, .pl_item_alloc = (DB_playItem_t* (*)(void))pl_item_alloc, .pl_item_ref = (void (*)(DB_playItem_t *))pl_item_ref, .pl_item_unref = (void (*)(DB_playItem_t *))pl_item_unref, .pl_item_copy = (void (*)(DB_playItem_t *, DB_playItem_t *))pl_item_copy, .pl_add_file = (int (*) (const char *, int (*cb)(DB_playItem_t *it, void *data), void *))pl_add_file, .pl_add_dir = (int (*) (const char *dirname, int (*cb)(DB_playItem_t *it, void *data), void *user_data))pl_add_dir, .pl_insert_item = (DB_playItem_t *(*) (DB_playItem_t *after, DB_playItem_t *it))pl_insert_item, .pl_insert_dir = (DB_playItem_t *(*) (DB_playItem_t *after, const char *dirname, int *pabort, int (*cb)(DB_playItem_t *it, void *data), void *user_data))pl_insert_dir, .pl_insert_file = (DB_playItem_t *(*) (DB_playItem_t *after, const char *fname, int *pabort, int (*cb)(DB_playItem_t *it, void *data), void *user_data))pl_insert_file, .pl_get_idx_of = (int (*) (DB_playItem_t *it))pl_get_idx_of, .pl_get_for_idx = (DB_playItem_t * (*)(int))pl_get_for_idx, .pl_get_for_idx_and_iter = (DB_playItem_t * (*) (int idx, int iter))pl_get_for_idx_and_iter, .pl_set_item_duration = (void (*) (DB_playItem_t *it, float duration))pl_set_item_duration, .pl_get_item_duration = (float (*) (DB_playItem_t *it))pl_get_item_duration, .pl_get_item_flags = (uint32_t (*) (DB_playItem_t *it))pl_get_item_flags, .pl_set_item_flags = (void (*) (DB_playItem_t *it, uint32_t flags))pl_set_item_flags, .pl_sort = pl_sort, .pl_items_copy_junk = (void (*)(DB_playItem_t *from, DB_playItem_t *first, DB_playItem_t *last))pl_items_copy_junk, .pl_get_totaltime = pl_get_totaltime, .pl_getcount = pl_getcount, .pl_delete_selected = pl_delete_selected, .pl_set_cursor = pl_set_cursor, .pl_get_cursor = pl_get_cursor, .pl_set_selected = (void (*) (DB_playItem_t *, int))pl_set_selected, .pl_is_selected = (int (*) (DB_playItem_t *))pl_is_selected, .pl_clear = pl_clear, .pl_load = pl_load, .pl_save = pl_save, .pl_save_current = pl_save_current, .pl_save_all = pl_save_all, .pl_select_all = pl_select_all, .pl_crop_selected = pl_crop_selected, .pl_getselcount = pl_getselcount, .pl_get_first = (DB_playItem_t *(*) (int))pl_get_first, .pl_get_last = (DB_playItem_t *(*) (int))pl_get_last, .pl_get_next = (DB_playItem_t *(*) (DB_playItem_t *, int))pl_get_next, .pl_get_prev = (DB_playItem_t *(*) (DB_playItem_t *, int))pl_get_prev, .pl_format_title = (int (*) (DB_playItem_t *it, int idx, char *s, int size, int id, const char *fmt))pl_format_title, .pl_move_items = (void (*) (int iter, DB_playItem_t *drop_before, uint32_t *indexes, int count))pl_move_items, .pl_copy_items = (void (*) (int iter, int plt_from, DB_playItem_t *before, uint32_t *indices, int cnt))pl_copy_items, .pl_search_reset = pl_search_reset, .pl_search_process = pl_search_process, // metainfo .pl_add_meta = (void (*) (DB_playItem_t *, const char *, const char *))pl_add_meta, .pl_append_meta = (void (*) (DB_playItem_t *, const char *, const char *))pl_append_meta, .pl_find_meta = (const char *(*) (DB_playItem_t *, const char *))pl_find_meta, .pl_replace_meta = (void (*) (DB_playItem_t *, const char *, const char *))pl_replace_meta, .pl_delete_all_meta = (void (*) (DB_playItem_t *it))pl_delete_all_meta, .pl_get_metadata = (DB_metaInfo_t *(*)(DB_playItem_t *it))pl_get_metadata, // cuesheet support .pl_insert_cue_from_buffer = (DB_playItem_t *(*) (DB_playItem_t *after, DB_playItem_t *origin, const uint8_t *buffer, int buffersize, int numsamples, int samplerate))pl_insert_cue_from_buffer, .pl_insert_cue = (DB_playItem_t *(*)(DB_playItem_t *after, DB_playItem_t *origin, int numsamples, int samplerate))pl_insert_cue, // playqueue support .pl_playqueue_push = (int (*) (DB_playItem_t *))pl_playqueue_push, .pl_playqueue_clear = pl_playqueue_clear, .pl_playqueue_pop = pl_playqueue_pop, .pl_playqueue_remove = (void (*) (DB_playItem_t *))pl_playqueue_remove, .pl_playqueue_test = (int (*) (DB_playItem_t *))pl_playqueue_test, // volume control .volume_set_db = plug_volume_set_db, .volume_get_db = volume_get_db, .volume_set_amp = plug_volume_set_amp, .volume_get_amp = volume_get_amp, .volume_get_min_db = volume_get_min_db, // junk reading .junk_id3v1_read = (int (*)(DB_playItem_t *it, DB_FILE *fp))junk_id3v1_read, .junk_id3v1_find = junk_id3v1_find, .junk_id3v1_write = (int (*) (FILE *, DB_playItem_t *))junk_id3v1_write, .junk_id3v2_find = junk_id3v2_find, .junk_id3v2_read = (int (*)(DB_playItem_t *it, DB_FILE *fp))junk_id3v2_read, .junk_id3v2_read_full = (int (*)(DB_playItem_t *, DB_id3v2_tag_t *tag, DB_FILE *fp))junk_id3v2_read_full, .junk_id3v2_convert_24_to_23 = junk_id3v2_convert_24_to_23, .junk_id3v2_convert_23_to_24 = junk_id3v2_convert_23_to_24, .junk_id3v2_convert_22_to_24 = junk_id3v2_convert_22_to_24, .junk_id3v2_free = junk_id3v2_free, .junk_id3v2_write = junk_id3v2_write, .junk_id3v2_remove_frames = junk_id3v2_remove_frames, .junk_id3v2_add_text_frame = junk_id3v2_add_text_frame, .junk_apev2_read = (int (*)(DB_playItem_t *it, DB_FILE *fp))junk_apev2_read, .junk_apev2_read_full = (int (*) (DB_playItem_t *it, DB_apev2_tag_t *tag_store, DB_FILE *fp))junk_apev2_read_full, .junk_apev2_find = junk_apev2_find, .junk_apev2_remove_frames = junk_apev2_remove_frames, .junk_apev2_add_text_frame = junk_apev2_add_text_frame, .junk_apev2_free = junk_apev2_free, .junk_apev2_write = junk_apev2_write, .junk_get_leading_size = junk_get_leading_size, .junk_get_leading_size_stdio = junk_get_leading_size_stdio, .junk_detect_charset = junk_detect_charset, .junk_recode = junk_recode, .junk_iconv = junk_iconv, .junk_rewrite_tags = (int (*) (DB_playItem_t *it, uint32_t flags, int id3v2_version, const char *id3v1_encoding))junk_rewrite_tags, // vfs .fopen = vfs_fopen, .fclose = vfs_fclose, .fread = vfs_fread, .fseek = vfs_fseek, .ftell = vfs_ftell, .rewind = vfs_rewind, .fgetlength = vfs_fgetlength, .fget_content_type = vfs_get_content_type, .fget_content_name = vfs_get_content_name, .fget_content_genre = vfs_get_content_genre, // message passing .sendmessage = messagepump_push, // configuration access .conf_get_str = conf_get_str, .conf_get_float = conf_get_float, .conf_get_int = conf_get_int, .conf_set_str = conf_set_str, .conf_set_int = conf_set_int, .conf_set_float = conf_set_float, .conf_find = conf_find, .conf_remove_items = conf_remove_items, .conf_save = conf_save, // plugin communication .plug_get_decoder_list = plug_get_decoder_list, .plug_get_output_list = plug_get_output_list, .plug_get_dsp_list = plug_get_dsp_list, .plug_get_list = plug_get_list, .plug_activate = plug_activate, .plug_get_decoder_id = plug_get_decoder_id, .plug_remove_decoder_id = plug_remove_decoder_id, .plug_get_for_id = plug_get_for_id, // misc utilities .is_local_file = plug_is_local_file, }; DB_functions_t *deadbeef = &deadbeef_api; const char * plug_get_config_dir (void) { return dbconfdir; } void plug_volume_set_db (float db) { volume_set_db (db); plug_trigger_event_volumechanged (); } void plug_volume_set_amp (float amp) { volume_set_amp (amp); plug_trigger_event_volumechanged (); } #define MAX_PLUGINS 100 DB_plugin_t *g_plugins[MAX_PLUGINS+1]; DB_decoder_t *g_decoder_plugins[MAX_DECODER_PLUGINS+1]; #define MAX_VFS_PLUGINS 10 DB_vfs_t *g_vfs_plugins[MAX_VFS_PLUGINS+1]; #define MAX_DSP_PLUGINS 10 DB_dsp_t *g_dsp_plugins[MAX_DSP_PLUGINS+1]; #define MAX_OUTPUT_PLUGINS 10 DB_output_t *g_output_plugins[MAX_OUTPUT_PLUGINS+1]; DB_output_t *output_plugin = NULL; void plug_md5 (uint8_t sig[16], const char *in, int len) { md5_state_t st; md5_init (&st); md5_append (&st, in, len); md5_finish (&st, sig); } void plug_md5_to_str (char *str, const uint8_t sig[16]) { int i = 0; static const char hex[] = "0123456789abcdef"; for (i = 0; i < 16; i++) { *str++ = hex[(sig[i]&0xf0)>>4]; *str++ = hex[sig[i]&0xf]; } *str = 0; } // event handlers typedef struct { DB_plugin_t *plugin; DB_callback_t callback; uintptr_t data; } evhandler_t; #define MAX_HANDLERS 100 static evhandler_t handlers[DB_EV_MAX][MAX_HANDLERS]; // plugin control structures typedef struct plugin_s { void *handle; DB_plugin_t *plugin; struct plugin_s *next; } plugin_t; plugin_t *plugins; void plug_ev_subscribe (DB_plugin_t *plugin, int ev, DB_callback_t callback, uintptr_t data) { assert (ev < DB_EV_MAX && ev >= 0); int i; mutex_lock (mutex); for (i = 0; i < MAX_HANDLERS; i++) { if (!handlers[ev][i].plugin) { handlers[ev][i].plugin = plugin; handlers[ev][i].callback = callback; handlers[ev][i].data = data; break; } } mutex_unlock (mutex); if (i == MAX_HANDLERS) { fprintf (stderr, "failed to subscribe plugin %s to event %d (too many event handlers)\n", plugin->name, ev); } } void plug_ev_unsubscribe (DB_plugin_t *plugin, int ev, DB_callback_t callback, uintptr_t data) { assert (ev < DB_EV_MAX && ev >= 0); mutex_lock (mutex); for (int i = 0; i < MAX_HANDLERS; i++) { if (handlers[ev][i].plugin == plugin) { handlers[ev][i].plugin = NULL; handlers[ev][i].callback = NULL; handlers[ev][i].data = 0; break; } } mutex_unlock (mutex); } void plug_playback_next (void) { messagepump_push (M_NEXTSONG, 0, 0, 0); } void plug_playback_prev (void) { messagepump_push (M_PREVSONG, 0, 0, 0); } void plug_playback_pause (void) { messagepump_push (M_PAUSESONG, 0, 0, 0); } void plug_playback_stop (void) { messagepump_push (M_STOPSONG, 0, 0, 0); } void plug_playback_play (void) { messagepump_push (M_PLAYSONG, 0, 0, 0); } void plug_playback_random (void) { messagepump_push (M_PLAYRANDOM, 0, 0, 0); } float plug_playback_get_pos (void) { playItem_t *trk = streamer_get_playing_track (); if (!trk || trk->_duration <= 0) { if (trk) { pl_item_unref (trk); } return 0; } if (trk) { pl_item_unref (trk); } return streamer_get_playpos () * 100 / trk->_duration; } void plug_playback_set_pos (float pos) { playItem_t *trk = streamer_get_playing_track (); if (!trk || trk->_duration <= 0) { if (trk) { pl_item_unref (trk); } return; } float t = pos * trk->_duration / 100.f; if (trk) { pl_item_unref (trk); } streamer_set_seek (t); } void plug_quit (void) { // FIXME progress_abort (); messagepump_push (M_TERMINATE, 0, 0, 0); } /////// non-api functions (plugin support) void plug_event_call (DB_event_t *ev) { if (!mutex) { trace ("plug: event passed before plugin initialization\n"); } ev->time = time (NULL); // printf ("plug_event_call enter %d\n", ev->event); mutex_lock (mutex); for (int i = 0; i < MAX_HANDLERS; i++) { if (handlers[ev->event][i].plugin && !handlers[ev->event][i].plugin->inactive) { handlers[ev->event][i].callback (ev, handlers[ev->event][i].data); } } // if (ev->event == DB_EV_PLAYLISTSWITCH) { // printf ("DB_EV_PLAYLISTSWITCH %d %d\n", plt_get_curr (), conf_get_int ("playlist.current", 0)); // pl_save_current (); // } mutex_unlock (mutex); // printf ("plug_event_call leave %d\n", ev->event); } void plug_trigger_event (int ev, uintptr_t param) { DB_event_t *event; playItem_t *pltrack = NULL; switch (ev) { case DB_EV_SONGSTARTED: case DB_EV_SONGFINISHED: { DB_event_track_t *pev = alloca (sizeof (DB_event_track_t)); pev->index = -1; pltrack = streamer_get_playing_track (); pev->track = DB_PLAYITEM (pltrack); event = DB_EVENT (pev); } break; case DB_EV_TRACKDELETED: { DB_event_track_t *pev = alloca (sizeof (DB_event_track_t)); pev->index = -1; // FIXME pev->track = DB_PLAYITEM (param); event = DB_EVENT (pev); } break; default: event = alloca (sizeof (DB_event_t)); } event->event = ev; plug_event_call (event); if (pltrack) { pl_item_unref (pltrack); } } void plug_trigger_event_trackchange (int from, int to) { DB_event_trackchange_t event; event.ev.event = DB_EV_SONGCHANGED; event.from = from; event.to = to; plug_event_call (DB_EVENT (&event)); } void plug_trigger_event_trackinfochanged (int trk) { DB_event_track_t event; event.ev.event = DB_EV_TRACKINFOCHANGED; event.index = trk; playItem_t *track = pl_get_for_idx (trk); event.track = DB_PLAYITEM (track); plug_event_call (DB_EVENT (&event)); if (track) { pl_item_unref (track); } } void plug_trigger_event_paused (int paused) { DB_event_state_t event; event.ev.event = DB_EV_PAUSED; event.state = paused; plug_event_call (DB_EVENT (&event)); } void plug_trigger_event_playlistchanged (void) { DB_event_t event; event.event = DB_EV_PLAYLISTCHANGED; plug_event_call (DB_EVENT (&event)); } void plug_trigger_event_volumechanged (void) { DB_event_t event; event.event = DB_EV_VOLUMECHANGED; plug_event_call (DB_EVENT (&event)); } int plug_init_plugin (DB_plugin_t* (*loadfunc)(DB_functions_t *), void *handle) { DB_plugin_t *plugin_api = loadfunc (&deadbeef_api); if (!plugin_api) { return -1; } #if !DISABLE_VERSIONCHECK if (plugin_api->api_vmajor != 0 || plugin_api->api_vminor != 0) { // version check enabled if (plugin_api->api_vmajor != DB_API_VERSION_MAJOR || plugin_api->api_vminor != DB_API_VERSION_MINOR) { fprintf (stderr, "\033[0;31mWARNING: plugin \"%s\" wants API v%d.%d (got %d.%d), will not be loaded\033[0;m\n", plugin_api->name, plugin_api->api_vmajor, plugin_api->api_vminor, DB_API_VERSION_MAJOR, DB_API_VERSION_MINOR); return -1; } } else { fprintf (stderr, "\033[0;31mWARNING: plugin \"%s\" has disabled version check. do not distribute!\033[0;m\n", plugin_api->name); } #endif plugin_t *plug = malloc (sizeof (plugin_t)); memset (plug, 0, sizeof (plugin_t)); plug->plugin = plugin_api; plug->handle = handle; plug->next = plugins; plugins = plug; return 0; } void plug_load_all (void) { #if DISABLE_VERSIONCHECK fprintf (stderr, "\033[0;31mDISABLE_VERSIONCHECK=1! do not distribute!\033[0;m\n"); #endif const char *conf_blacklist_plugins = conf_get_str ("blacklist_plugins", ""); trace ("plug: mutex_create\n"); mutex = mutex_create (); const char *dirname = LIBDIR "/deadbeef"; struct dirent **namelist = NULL; char *xdg_local_home = getenv ("XDG_LOCAL_HOME"); char xdg_plugin_dir[1024]; if (xdg_local_home) { strcpy (xdg_plugin_dir, xdg_local_home); } else { char *homedir = getenv ("HOME"); if (!homedir) { fprintf (stderr, "plug_load_all: warning: unable to find home directory\n"); xdg_plugin_dir[0] = 0; } else { int written = snprintf (xdg_plugin_dir, sizeof (xdg_plugin_dir), "%s/.local/lib/deadbeef", homedir); if (written > sizeof (xdg_plugin_dir)) { fprintf (stderr, "warning: XDG_LOCAL_HOME value is too long: %s. Ignoring.", xdg_local_home); xdg_plugin_dir[0] = 0; } } } const char *plugins_dirs[] = { dirname, xdg_plugin_dir, NULL }; int k = 0, n; while (plugins_dirs[k]) { const char *plugdir = plugins_dirs[k++]; if (!(*plugdir)) { continue; } fprintf (stderr, "loading plugins from %s\n", plugdir); namelist = NULL; n = scandir (plugdir, &namelist, NULL, alphasort); if (n < 0) { if (namelist) { free (namelist); } break; } else { int i; for (i = 0; i < n; i++) { // no hidden files while (namelist[i]->d_name[0] != '.') { int l = strlen (namelist[i]->d_name); if (l < 3) { break; } if (strcasecmp (&namelist[i]->d_name[l-3], ".so")) { break; } char d_name[256]; memcpy (d_name, namelist[i]->d_name, l+1); // no blacklisted const uint8_t *p = conf_blacklist_plugins; while (*p) { const uint8_t *e = p; while (*e && *e > 0x20) { e++; } if (l-3 == e-p) { if (!strncmp (p, d_name, e-p)) { p = NULL; break; } } p = e; while (*p && *p <= 0x20) { p++; } } if (!p) { fprintf (stderr, "plugin %s is blacklisted in config file\n", d_name); break; } char fullname[PATH_MAX]; snprintf (fullname, PATH_MAX, "%s/%s", plugdir, d_name); fprintf (stderr, "loading plugin %s\n", d_name); void *handle = dlopen (fullname, RTLD_NOW); if (!handle) { fprintf (stderr, "dlopen error: %s\n", dlerror ()); break; } d_name[l-3] = 0; fprintf (stderr, "module name is %s\n", d_name); strcat (d_name, "_load"); DB_plugin_t *(*plug_load)(DB_functions_t *api) = dlsym (handle, d_name); if (!plug_load) { fprintf (stderr, "dlsym error: %s\n", dlerror ()); dlclose (handle); break; } if (plug_init_plugin (plug_load, handle) < 0) { d_name[l-3] = 0; fprintf (stderr, "plugin %s is incompatible with current version of deadbeef, please upgrade the plugin\n", d_name); dlclose (handle); break; } break; } free (namelist[i]); } free (namelist); } } // load all compiled-in modules #define PLUG(n) extern DB_plugin_t * n##_load (DB_functions_t *api); #include "moduleconf.h" #undef PLUG #define PLUG(n) plug_init_plugin (n##_load, NULL); #include "moduleconf.h" #undef PLUG plugin_t *plug; // categorize plugins int numplugins = 0; int numdecoders = 0; int numvfs = 0; int numoutput = 0; int numdsp = 0; for (plug = plugins; plug; plug = plug->next) { g_plugins[numplugins++] = plug->plugin; if (plug->plugin->type == DB_PLUGIN_DECODER) { fprintf (stderr, "found decoder plugin %s\n", plug->plugin->name); if (numdecoders >= MAX_DECODER_PLUGINS) { break; } g_decoder_plugins[numdecoders++] = (DB_decoder_t *)plug->plugin; } else if (plug->plugin->type == DB_PLUGIN_VFS) { fprintf (stderr, "found vfs plugin %s\n", plug->plugin->name); if (numvfs >= MAX_VFS_PLUGINS) { break; } g_vfs_plugins[numvfs++] = (DB_vfs_t *)plug->plugin; } else if (plug->plugin->type == DB_PLUGIN_OUTPUT) { fprintf (stderr, "found output plugin %s\n", plug->plugin->name); if (numoutput >= MAX_OUTPUT_PLUGINS) { break; } g_output_plugins[numoutput++] = (DB_output_t *)plug->plugin; } else if (plug->plugin->type == DB_PLUGIN_DSP) { fprintf (stderr, "found dsp plugin %s\n", plug->plugin->name); if (numdsp >= MAX_DSP_PLUGINS) { break; } g_dsp_plugins[numdsp++] = (DB_dsp_t *)plug->plugin; } } // start plugins for (plug = plugins; plug; plug = plug->next) { if (plug->plugin->start) { if (plug->plugin->start () < 0) { plug->plugin->inactive = 1; } } } // fprintf (stderr, "numplugins: %d, numdecoders: %d, numvfs: %d\n", numplugins, numdecoders, numvfs); g_plugins[numplugins] = NULL; g_decoder_plugins[numdecoders] = NULL; g_vfs_plugins[numvfs] = NULL; g_output_plugins[numoutput] = NULL; // select output plugin if (plug_select_output () < 0) { fprintf (stderr, "failed to find output plugin!\n"); exit (-1); } } void plug_unload_all (void) { fprintf (stderr, "plug_unload_all\n"); plugin_t *p; for (p = plugins; p; p = p->next) { if (p->plugin->stop) { fprintf (stderr, "stopping %s...\n", p->plugin->name); fflush (stderr); p->plugin->stop (); } } fprintf (stderr, "stopped all plugins\n"); while (plugins) { plugin_t *next = plugins->next; if (plugins->handle) { dlclose (plugins->handle); } free (plugins); plugins = next; } mutex_free (mutex); fprintf (stderr, "all plugins had been unloaded\n"); } struct DB_decoder_s ** plug_get_decoder_list (void) { return g_decoder_plugins; } struct DB_output_s ** plug_get_output_list (void) { return g_output_plugins; } struct DB_vfs_s ** plug_get_vfs_list (void) { return g_vfs_plugins; } struct DB_dsp_s ** plug_get_dsp_list (void) { return g_dsp_plugins; } struct DB_plugin_s ** plug_get_list (void) { return g_plugins; } int plug_activate (DB_plugin_t *plug, int activate) { if (plug->inactive && !activate) { return -1; } if (!plug->inactive && activate) { return -1; } if (activate) { if (plug->start) { if (!plug->start ()) { plug->inactive = 0; } else { fprintf (stderr, "failed to start plugin %s\n", plug->name); return -1; } return 0; } else { return -1; } } else { if (plug->stop) { if (!plug->stop ()) { plug->inactive = 1; } else { fprintf (stderr, "failed to stop plugin %s\n", plug->name); return -1; } return 0; } else { return -1; } } } DB_output_t * plug_get_output (void) { return output_plugin; } int plug_select_output (void) { const char *outplugname = conf_get_str ("output_plugin", "ALSA output plugin"); for (int i = 0; g_output_plugins[i]; i++) { DB_output_t *p = g_output_plugins[i]; if (!strcmp (p->plugin.name, outplugname)) { fprintf (stderr, "selected output plugin: %s\n", outplugname); output_plugin = p; break; } } if (!output_plugin) { output_plugin = g_output_plugins[0]; if (output_plugin) { fprintf (stderr, "selected output plugin: %s\n", output_plugin->plugin.name); conf_set_str ("output_plugin", output_plugin->plugin.name); } } if (!output_plugin) { return -1; } plug_trigger_event (DB_EV_OUTPUTCHANGED, 0); return 0; } void plug_reinit_sound (void) { int state = p_get_state (); p_free (); DB_output_t *prev = plug_get_output (); if (plug_select_output () < 0) { const char *outplugname = conf_get_str ("output_plugin", "ALSA output plugin"); fprintf (stderr, "failed to select output plugin %s\nreverted to %s\n", outplugname, prev->plugin.name); output_plugin = prev; } streamer_reset (1); if (p_init () < 0) { streamer_set_nextsong (-2, 0); return; } if (state != OUTPUT_STATE_PAUSED && state != OUTPUT_STATE_STOPPED) { if (p_play () < 0) { fprintf (stderr, "failed to reinit sound output\n"); streamer_set_nextsong (-2, 0); } } } // list of all unique decoder ids used in current session static char *decoder_ids[MAX_DECODER_PLUGINS]; const char * plug_get_decoder_id (const char *id) { int i; char **lastnull = NULL; for (i = 0; i < MAX_DECODER_PLUGINS; i++) { if (decoder_ids[i] && !strcmp (id, decoder_ids[i])) { return decoder_ids[i]; } else if (!lastnull && !decoder_ids[i]) { lastnull = &decoder_ids[i]; } } if (!lastnull) { return NULL; } char *newid = strdup (id); *lastnull = newid; return newid; } void plug_remove_decoder_id (const char *id) { int i; for (i = 0; i < MAX_DECODER_PLUGINS; i++) { if (decoder_ids[i] && !strcmp (decoder_ids[i], id)) { free (decoder_ids[i]); decoder_ids[i] = NULL; } } } void plug_free_decoder_ids (void) { int i; for (i = 0; i < MAX_DECODER_PLUGINS; i++) { if (decoder_ids[i]) { free (decoder_ids[i]); decoder_ids[i] = NULL; } } } DB_decoder_t * plug_get_decoder_for_id (const char *id) { DB_decoder_t **plugins = plug_get_decoder_list (); for (int c = 0; plugins[c]; c++) { if (!strcmp (id, plugins[c]->plugin.id)) { return plugins[c]; } } return NULL; } DB_plugin_t * plug_get_for_id (const char *id) { DB_plugin_t **plugins = plug_get_list (); for (int c = 0; plugins[c]; c++) { if (plugins[c]->id && !strcmp (id, plugins[c]->id)) { return plugins[c]; } } return NULL; } int plug_is_local_file (const char *fname) { if (!strncasecmp (fname, "file://", 7)) { return 1; } for (; *fname; fname++) { if (!strncmp (fname, "://", 3)) { return 0; } } return 1; }