X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=mysql_selector.c;h=cdb36dd2d0a3d50a008c3579b8e2a733e69e8a04;hp=9f5a14f39854831faa238e8cb3d6363cb8d4f93d;hb=58ad3169dc1a4999ef3250753f980f168bd2f29e;hpb=9f10e6742ffc2ac5e4bf6224e1ff882074c7ca45 diff --git a/mysql_selector.c b/mysql_selector.c index 9f5a14f3..cdb36dd2 100644 --- a/mysql_selector.c +++ b/mysql_selector.c @@ -38,7 +38,6 @@ extern struct misc_meta_data *mmd; static void *mysql_ptr = NULL; - static int com_cam(int, int, char **); static int com_cdb(int, int, char **); static int com_cs(int, int, char **); @@ -810,7 +809,7 @@ static int com_verb(int fd, int argc, char *argv[]) if (argc < 1) return -E_MYSQL_SYNTAX; - result = get_result(argv[1]); + result = get_result(argv[1]); if (!result) /* return success, because it's ok to have no results */ return 1; @@ -837,7 +836,7 @@ static void *get_all_attributes(void) mysql_free_result(result); return NULL; } - mysql_data_seek(result, 4); /* skip Lastplayed, Numplayed... */ + mysql_data_seek(result, 4); /* skip Lastplayed, Numplayed... */ return result; } @@ -871,9 +870,9 @@ static int com_hist(int fd, int argc, char *argv[]) { q = make_message("select name, to_days(now()) - to_days(lastplayed) from " "data%s%s%s order by lastplayed", (argc < 1)? "" : " where ", - (argc < 1)? "" : argv[1], + (argc < 1)? "" : argv[1], (argc < 1)? "" : " = '1'"); - result = get_result(q); + result = get_result(q); free(q); if (!result) return -E_NORESULT; @@ -951,7 +950,7 @@ static int com_mbox(int fd, int argc, char *argv[]) } mysql_free_result(result); ret = -E_NORESULT; - result = get_result(query); + result = get_result(query); if (!result) goto out; ret = -E_EMPTY_RESULT; @@ -998,7 +997,7 @@ static char *get_atts(char *name, int verbose) num_fields = mysql_num_fields(result); if (num_fields < 5) goto out; - mysql_data_seek(result2, 4); /* skip Lastplayed, Numplayed... */ + mysql_data_seek(result2, 4); /* skip Lastplayed, Numplayed... */ row = mysql_fetch_row(result); ret = -E_NOROW; if (!row) @@ -1010,11 +1009,11 @@ static char *get_atts(char *name, int verbose) goto out; if (atts && (verbose || is_set)) atts = para_strcat(atts, verbose? "," : " "); - if (is_set || verbose) + if (is_set || verbose) atts = para_strcat(atts, row2[0]); if (verbose) atts = para_strcat(atts, is_set? "=\"1\"" : "=\"0\""); - } + } ret = 1; out: if (result2) @@ -1048,7 +1047,7 @@ static char *get_meta(char *name, int verbose) goto out; q = make_message(verbose? verbose_fmt : fmt, ebn); free(ebn); - result = get_result(q); + result = get_result(q); free(q); if (!result) goto out; @@ -1187,7 +1186,7 @@ static char *get_query(char *streamname, char *filename, int with_path) free(tmp2); continue; } - if (!strcmp(command, "score:")) + if (!score && !strcmp(command, "score:")) score = s_a_r_list(macro_list, arg); } if (!score) { @@ -1207,10 +1206,10 @@ static char *get_query(char *streamname, char *filename, int with_path) goto write_query; } select_clause = para_strdup(with_path? - "select concat(dir.dir, '/', dir.name) from data, dir " - "where dir.name = data.name " - : - "select name from data where name is not NULL"); + "select concat(dir.dir, '/', dir.name) from data, dir " + "where dir.name = data.name " + : + "select name from data where name is not NULL"); order = make_message("order by -(%s)", score); free(score); if (accept_opts && deny_opts) { @@ -1248,7 +1247,7 @@ out: * This is called from server and from some commands. Name must not be NULL * Never returns NULL. */ -static char *get_dbinfo(char *name) +static char *get_selector_info(char *name) { char *meta = NULL, *atts = NULL, *info, *dir = NULL, *query, *stream = NULL; void *result = NULL; @@ -1696,7 +1695,7 @@ static int com_ls(int fd, int argc, char *argv[]) argv[1]); else q = para_strdup("select name from data"); - result = get_result(q); + result = get_result(q); free(q); if (!result) return -E_NORESULT; @@ -1761,7 +1760,7 @@ static int get_numplayed(char *name) char *buf = make_message(fmt, name); int ret = -E_NORESULT; - result = get_result(buf); + result = get_result(buf); free(buf); if (!result) goto out; @@ -1814,7 +1813,7 @@ static void update_mmd(char *info) static void update_audio_file_server_handler(char *name) { char *info; - info = get_dbinfo(name); + info = get_selector_info(name); update_mmd(info); free(info); update_audio_file(name); @@ -1827,14 +1826,14 @@ static int com_us(__unused int fd, int argc, char *argv[]) return update_audio_file(argv[1]); } -static void refresh_mmd_dbinfo(void) +static void refresh_selector_info(void) { char *name = get_current_audio_file(); char *info; if (!name) return; - info = get_dbinfo(name); + info = get_selector_info(name); free(name); mmd_lock(); update_mmd(info); @@ -1880,7 +1879,7 @@ static int com_ps(__unused int fd, int argc, char *argv[]) else i = match < num_rows - 1? match + 1 : 0; ret = -E_NOROW; - mysql_data_seek(result, i); + mysql_data_seek(result, i); row = mysql_fetch_row(result); if (!row || !row[0]) goto out; @@ -1901,7 +1900,7 @@ static int com_ps(__unused int fd, int argc, char *argv[]) "'current_stream'", row[0]); ret = real_query(query); free(query); - refresh_mmd_dbinfo(); + refresh_selector_info(); out: free(stream); if (result) @@ -2009,7 +2008,7 @@ static int com_cs(int fd, int argc, char *argv[]) ret = change_stream(argv[1]); if (ret < 0) goto out; - refresh_mmd_dbinfo(); + refresh_selector_info(); } if (csp) { mmd_lock(); @@ -2148,7 +2147,7 @@ no_more_atts: for (; argv[i] && ret >= 0; i++) ret = update_atts(fd, argv[i], atts); } - refresh_mmd_dbinfo(); + refresh_selector_info(); out: return ret; }