X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~mdw/git/disorder/blobdiff_plain/4eb1f430bde3b517e045cc7ed68194ff9dbdda4a..93ca72f2d7a75e383f6b7b2460cee8b1c4ae2cfe:/disobedience/disobedience.c diff --git a/disobedience/disobedience.c b/disobedience/disobedience.c index 2b21b61..291d955 100644 --- a/disobedience/disobedience.c +++ b/disobedience/disobedience.c @@ -30,8 +30,6 @@ /* Apologies for the numerous de-consting casts, but GLib et al do not seem to * have heard of const. */ -#include "style.h" /* generated style */ - /* Variables --------------------------------------------------------------- */ /** @brief Event loop */ @@ -49,6 +47,9 @@ GtkWidget *tabs; /** @brief Main client */ disorder_eclient *client; +/** @brief Log client */ +disorder_eclient *logclient; + /** @brief Last reported state * * This is updated by log_state(). @@ -69,15 +70,30 @@ int volume_r; double goesupto = 10; /* volume upper bound */ -/** @brief Break up choose tab by initial letter */ -int choosealpha; - /** @brief True if a NOP is in flight */ static int nop_in_flight; +/** @brief True if an rtp-address command is in flight */ +static int rtp_address_in_flight; + /** @brief Global tooltip group */ GtkTooltips *tips; +/** @brief True if RTP play is available + * + * This is a bit of a bodge... + */ +int rtp_supported; + +/** @brief True if RTP play is enabled */ +int rtp_is_running; + +/** @brief Linked list of functions to call when we reset login parameters */ +static struct reset_callback_node { + struct reset_callback_node *next; + reset_callback *callback; +} *resets; + /* Window creation --------------------------------------------------------- */ /* Note that all the client operations kicked off from here will only complete @@ -120,6 +136,12 @@ static GtkWidget *report_box(void) { /** @brief Create and populate the main tab group */ static GtkWidget *notebook(void) { tabs = gtk_notebook_new(); + /* The current tab is _NORMAL, the rest are _ACTIVE, which is bizarre but + * produces not too dreadful appearance */ + gtk_widget_modify_bg(tabs, GTK_STATE_NORMAL, &tool_bg); + gtk_widget_modify_bg(tabs, GTK_STATE_ACTIVE, &tool_active); + gtk_widget_modify_fg(tabs, GTK_STATE_NORMAL, &tool_fg); + gtk_widget_modify_fg(tabs, GTK_STATE_ACTIVE, &tool_fg); g_signal_connect(tabs, "switch-page", G_CALLBACK(tab_switched), 0); gtk_notebook_append_page(GTK_NOTEBOOK(tabs), queue_widget(), gtk_label_new("Queue")); @@ -164,7 +186,7 @@ static void make_toplevel_window(void) { FALSE, /* expand */ FALSE, /* fill */ 0); - gtk_widget_set_name(toplevel, "disobedience"); + gtk_widget_modify_bg(toplevel, GTK_STATE_NORMAL, &tool_bg); } #if MDEBUG @@ -310,9 +332,44 @@ static gboolean maybe_send_nop(gpointer attribute((unused)) data) { nop_in_flight = 1; disorder_eclient_nop(client, nop_completed, 0); } + if(rtp_supported) { + const int old_state = rtp_is_running; + rtp_is_running = rtp_running(); + if(old_state != rtp_is_running) + control_monitor(0); + } return TRUE; /* keep call me please */ } +/** @brief Called when a rtp-address command succeeds */ +static void got_rtp_address(void attribute((unused)) *v, + int attribute((unused)) nvec, + char attribute((unused)) **vec) { + rtp_address_in_flight = 0; + rtp_supported = 1; + rtp_is_running = rtp_running(); + control_monitor(0); +} + +/** @brief Called when a rtp-address command fails */ +static void no_rtp_address(struct callbackdata attribute((unused)) *cbd, + int attribute((unused)) code, + const char attribute((unused)) *msg) { + rtp_address_in_flight = 0; + rtp_supported = 0; + rtp_is_running = 0; + control_monitor(0); +} + +/** @brief Called to check whether RTP play is available */ +static void check_rtp_address(void) { + if(!rtp_address_in_flight) { + struct callbackdata *const cbd = xmalloc(sizeof *cbd); + cbd->onerror = no_rtp_address; + disorder_eclient_rtp_address(client, got_rtp_address, cbd); + } +} + /* main -------------------------------------------------------------------- */ static const struct option options[] = { @@ -320,7 +377,6 @@ static const struct option options[] = { { "version", no_argument, 0, 'V' }, { "config", required_argument, 0, 'c' }, { "tufnel", no_argument, 0, 't' }, - { "choosealpha", no_argument, 0, 'C' }, { "debug", no_argument, 0, 'd' }, { 0, 0, 0, 0 } }; @@ -349,9 +405,31 @@ static void version(void) { exit(0); } +/* reset state */ +void reset(void) { + struct reset_callback_node *r; + + /* reset the clients */ + disorder_eclient_close(client); + disorder_eclient_close(logclient); + rtp_supported = 0; + for(r = resets; r; r = r->next) + r->callback(); + /* Might be a new server so re-check */ + check_rtp_address(); +} + +/** @brief Register a reset callback */ +void register_reset(reset_callback *callback) { + struct reset_callback_node *const r = xmalloc(sizeof *r); + + r->next = resets; + r->callback = callback; + resets = r; +} + int main(int argc, char **argv) { int n; - disorder_eclient *logclient; mem_init(); /* garbage-collect PCRE's memory */ @@ -363,19 +441,18 @@ int main(int argc, char **argv) { #endif if(!setlocale(LC_CTYPE, "")) fatal(errno, "error calling setlocale"); gtk_init(&argc, &argv); - gtk_rc_parse_string(style); - while((n = getopt_long(argc, argv, "hVc:dtH", options, 0)) >= 0) { + while((n = getopt_long(argc, argv, "hVc:dtHC", options, 0)) >= 0) { switch(n) { case 'h': help(); case 'V': version(); case 'c': configfile = optarg; break; case 'd': debugging = 1; break; case 't': goesupto = 11; break; - case 'C': choosealpha = 1; break; /* not well tested any more */ default: fatal(0, "invalid option"); } } signal(SIGPIPE, SIG_IGN); + load_appearance(); /* create the event loop */ D(("create main loop")); mainloop = g_main_loop_new(0, 0); @@ -406,8 +483,11 @@ int main(int argc, char **argv) { maybe_send_nop, 0/*data*/, 0/*notify*/); + register_reset(properties_reset); /* Start monitoring the log */ disorder_eclient_log(logclient, &log_callbacks, 0); + /* See if RTP play supported */ + check_rtp_address(); D(("enter main loop")); MTAG("misc"); g_main_loop_run(mainloop);