X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=goptions.c;h=5b5c89ead6995b68c5a40f9bdf7893e372d8ee8b;hp=cf25d2d9659fa41cb8685fe096e97730f9be45c0;hb=ebadc0ce34c11b3e0130d5602b18f4ed0e638386;hpb=8b3a476e6897370b0d7ed05de559cc49235b7a61 diff --git a/goptions.c b/goptions.c index cf25d2d9..5b5c89ea 100644 --- a/goptions.c +++ b/goptions.c @@ -9,6 +9,7 @@ #include "fio.h" #include "gfio.h" #include "ghelpers.h" +#include "gerror.h" #include "parse.h" struct gopt { @@ -17,6 +18,7 @@ struct gopt { unsigned int opt_type; gulong sig_handler; struct gopt_job_view *gjv; + struct flist_head changed_list; }; struct gopt_combo { @@ -26,7 +28,7 @@ struct gopt_combo { struct gopt_int { struct gopt gopt; - unsigned int lastval; + unsigned long long lastval; GtkWidget *spin; }; @@ -59,16 +61,32 @@ struct gopt_str_multi { GtkWidget *checks[PARSE_MAX_VP]; }; +enum { + GOPT_COMBO_INT = 1, + GOPT_COMBO_STR, + GOPT_INT, + GOPT_BOOL, + GOPT_STR, + GOPT_STR_VAL, + GOPT_RANGE, + GOPT_STR_MULTI, +}; + struct gopt_frame_widget { GtkWidget *vbox[2]; unsigned int nr; }; struct gopt_job_view { - struct flist_head list; struct gopt_frame_widget g_widgets[__FIO_OPT_G_NR]; - GtkWidget *widgets[FIO_MAX_OPTS]; GtkWidget *vboxes[__FIO_OPT_C_NR]; + struct gopt *gopts[FIO_MAX_OPTS]; + GtkWidget *dialog; + GtkWidget *job_combo; + struct gfio_client *client; + struct flist_head changed_list; + struct thread_options *o; + int in_job_switch; }; static GNode *gopt_dep_tree; @@ -110,7 +128,8 @@ static GtkWidget *gopt_get_group_frame(struct gopt_job_view *gjv, /* * Mark children as invisible, if needed. */ -static void gopt_set_children_visible(struct fio_option *parent, +static void gopt_set_children_visible(struct gopt_job_view *gjv, + struct fio_option *parent, gboolean visible) { GNode *child, *node; @@ -123,21 +142,65 @@ static void gopt_set_children_visible(struct fio_option *parent, while (child) { struct fio_option *o = child->data; struct gopt *g = o->gui_data; - struct gopt_job_view *gjv = g->gjv; + GtkWidget *widget = g->box; /* * Recurse into child, if it also has children */ if (g_node_n_children(child)) - gopt_set_children_visible(o, visible); - - if (gjv->widgets[g->opt_index]) - gtk_widget_set_sensitive(gjv->widgets[g->opt_index], visible); + gopt_set_children_visible(gjv, o, visible); + gtk_widget_set_sensitive(widget, visible); child = g_node_next_sibling(child); } } +static void gopt_mark_index(struct gopt_job_view *gjv, struct gopt *gopt, + unsigned int idx, int type) +{ + INIT_FLIST_HEAD(&gopt->changed_list); + + assert(!gjv->gopts[idx]); + gopt->opt_index = idx; + gopt->opt_type = type; + gopt->gjv = gjv; + gjv->gopts[idx] = gopt; +} + +static void gopt_dialog_update_apply_button(struct gopt_job_view *gjv) +{ + GtkDialog *dialog = GTK_DIALOG(gjv->dialog); + gboolean set; + + set = !flist_empty(&gjv->changed_list); + gtk_dialog_set_response_sensitive(dialog, GTK_RESPONSE_APPLY, set); + + if (set) { + gtk_widget_set_sensitive(gjv->job_combo, 0); + gtk_widget_set_tooltip_text(gjv->job_combo, "Apply option changes before switching to a new job"); + } else { + gtk_widget_set_sensitive(gjv->job_combo, 1); + gtk_widget_set_tooltip_text(gjv->job_combo, "Change current job"); + } +} + +static void gopt_changed(struct gopt *gopt) +{ + struct gopt_job_view *gjv = gopt->gjv; + + if (gjv->in_job_switch) + return; + + /* + * Add to changed list. This also prevents the option from being + * freed when the widget is destroyed. + */ + if (flist_empty(&gopt->changed_list)) { + flist_add_tail(&gopt->changed_list, &gjv->changed_list); + gopt_dialog_update_apply_button(gjv); + } +} + static void gopt_str_changed(GtkEntry *entry, gpointer data) { struct gopt_str *s = (struct gopt_str *) data; @@ -145,18 +208,12 @@ static void gopt_str_changed(GtkEntry *entry, gpointer data) const gchar *text; int set; + gopt_changed(&s->gopt); + text = gtk_entry_get_text(GTK_ENTRY(s->entry)); set = strcmp(text, "") != 0; - gopt_set_children_visible(o, set); -} -static void gopt_mark_index(struct gopt_job_view *gjv, struct gopt *gopt, - unsigned int idx) -{ - assert(!gjv->widgets[idx]); - gopt->opt_index = idx; - gopt->gjv = gjv; - gjv->widgets[idx] = gopt->box; + gopt_set_children_visible(s->gopt.gjv, o, set); } static void gopt_str_destroy(GtkWidget *w, gpointer data) @@ -167,6 +224,12 @@ static void gopt_str_destroy(GtkWidget *w, gpointer data) gtk_widget_destroy(w); } +static void gopt_str_store_set_val(struct gopt_str *s, const char *text) +{ + if (text) + gtk_entry_set_text(GTK_ENTRY(s->entry), text); +} + static struct gopt *gopt_new_str_store(struct gopt_job_view *gjv, struct fio_option *o, const char *text, unsigned int idx) @@ -174,8 +237,7 @@ static struct gopt *gopt_new_str_store(struct gopt_job_view *gjv, struct gopt_str *s; GtkWidget *label; - s = malloc(sizeof(*s)); - memset(s, 0, sizeof(*s)); + s = calloc(1, sizeof(*s)); s->gopt.box = gtk_hbox_new(FALSE, 3); if (!o->lname) @@ -184,16 +246,16 @@ static struct gopt *gopt_new_str_store(struct gopt_job_view *gjv, label = gtk_label_new(o->lname); s->entry = gtk_entry_new(); - gopt_mark_index(gjv, &s->gopt, idx); - if (text) - gtk_entry_set_text(GTK_ENTRY(s->entry), text); - gtk_entry_set_editable(GTK_ENTRY(s->entry), 1); + gopt_mark_index(gjv, &s->gopt, idx, GOPT_STR); + gtk_editable_set_editable(GTK_EDITABLE(s->entry), 1); - if (o->def) - gtk_entry_set_text(GTK_ENTRY(s->entry), o->def); + if (text) + gopt_str_store_set_val(s, text); + else if (o->def) + gopt_str_store_set_val(s, o->def); - s->gopt.sig_handler = g_signal_connect(GTK_OBJECT(s->entry), "changed", G_CALLBACK(gopt_str_changed), s); - g_signal_connect(GTK_OBJECT(s->entry), "destroy", G_CALLBACK(gopt_str_destroy), s); + s->gopt.sig_handler = g_signal_connect(G_OBJECT(s->entry), "changed", G_CALLBACK(gopt_str_changed), s); + g_signal_connect(G_OBJECT(s->entry), "destroy", G_CALLBACK(gopt_str_destroy), s); gtk_box_pack_start(GTK_BOX(s->gopt.box), s->entry, FALSE, FALSE, 0); gtk_box_pack_start(GTK_BOX(s->gopt.box), label, FALSE, FALSE, 0); @@ -206,8 +268,11 @@ static void gopt_combo_changed(GtkComboBox *box, gpointer data) struct fio_option *o = &fio_options[c->gopt.opt_index]; unsigned int index; + gopt_changed(&c->gopt); + index = gtk_combo_box_get_active(GTK_COMBO_BOX(c->combo)); - gopt_set_children_visible(o, index); + + gopt_set_children_visible(c->gopt.gjv, o, index); } static void gopt_combo_destroy(GtkWidget *w, gpointer data) @@ -220,13 +285,12 @@ static void gopt_combo_destroy(GtkWidget *w, gpointer data) static struct gopt_combo *__gopt_new_combo(struct gopt_job_view *gjv, struct fio_option *o, - unsigned int idx) + unsigned int idx, int type) { struct gopt_combo *c; GtkWidget *label; - c = malloc(sizeof(*c)); - memset(c, 0, sizeof(*c)); + c = calloc(1, sizeof(*c)); c->gopt.box = gtk_hbox_new(FALSE, 3); if (!o->lname) @@ -234,9 +298,9 @@ static struct gopt_combo *__gopt_new_combo(struct gopt_job_view *gjv, else label = gtk_label_new(o->lname); - c->combo = gtk_combo_box_new_text(); - gopt_mark_index(gjv, &c->gopt, idx); - g_signal_connect(GTK_OBJECT(c->combo), "destroy", G_CALLBACK(gopt_combo_destroy), c); + c->combo = gtk_combo_box_text_new(); + gopt_mark_index(gjv, &c->gopt, idx, type); + g_signal_connect(G_OBJECT(c->combo), "destroy", G_CALLBACK(gopt_combo_destroy), c); gtk_box_pack_start(GTK_BOX(c->gopt.box), c->combo, FALSE, FALSE, 0); gtk_box_pack_start(GTK_BOX(c->gopt.box), label, FALSE, FALSE, 0); @@ -244,6 +308,24 @@ static struct gopt_combo *__gopt_new_combo(struct gopt_job_view *gjv, return c; } +static void gopt_combo_str_set_val(struct gopt_combo *c, const char *text) +{ + struct fio_option *o = &fio_options[c->gopt.opt_index]; + struct value_pair *vp; + int i; + + i = 0; + vp = &o->posval[0]; + while (vp->ival) { + if (!strcmp(vp->ival, text)) { + gtk_combo_box_set_active(GTK_COMBO_BOX(c->combo), i); + break; + } + vp++; + i++; + } +} + static struct gopt *gopt_new_combo_str(struct gopt_job_view *gjv, struct fio_option *o, const char *text, unsigned int idx) @@ -252,25 +334,43 @@ static struct gopt *gopt_new_combo_str(struct gopt_job_view *gjv, struct value_pair *vp; int i, active = 0; - c = __gopt_new_combo(gjv, o, idx); + c = __gopt_new_combo(gjv, o, idx, GOPT_COMBO_STR); i = 0; vp = &o->posval[0]; while (vp->ival) { - gtk_combo_box_append_text(GTK_COMBO_BOX(c->combo), vp->ival); + gtk_combo_box_text_append_text(GTK_COMBO_BOX_TEXT(c->combo), vp->ival); if (o->def && !strcmp(vp->ival, o->def)) active = i; - if (text && !strcmp(vp->ival, text)) - active = i; vp++; i++; } gtk_combo_box_set_active(GTK_COMBO_BOX(c->combo), active); - c->gopt.sig_handler = g_signal_connect(GTK_OBJECT(c->combo), "changed", G_CALLBACK(gopt_combo_changed), c); + if (text) + gopt_combo_str_set_val(c, text); + c->gopt.sig_handler = g_signal_connect(G_OBJECT(c->combo), "changed", G_CALLBACK(gopt_combo_changed), c); return &c->gopt; } +static void gopt_combo_int_set_val(struct gopt_combo *c, unsigned int ip) +{ + struct fio_option *o = &fio_options[c->gopt.opt_index]; + struct value_pair *vp; + int i; + + i = 0; + vp = &o->posval[0]; + while (vp->ival) { + if (vp->oval == ip) { + gtk_combo_box_set_active(GTK_COMBO_BOX(c->combo), i); + break; + } + vp++; + i++; + } +} + static struct gopt *gopt_new_combo_int(struct gopt_job_view *gjv, struct fio_option *o, unsigned int *ip, unsigned int idx) @@ -279,12 +379,12 @@ static struct gopt *gopt_new_combo_int(struct gopt_job_view *gjv, struct value_pair *vp; int i, active = 0; - c = __gopt_new_combo(gjv, o, idx); + c = __gopt_new_combo(gjv, o, idx, GOPT_COMBO_INT); i = 0; vp = &o->posval[0]; while (vp->ival) { - gtk_combo_box_append_text(GTK_COMBO_BOX(c->combo), vp->ival); + gtk_combo_box_text_append_text(GTK_COMBO_BOX_TEXT(c->combo), vp->ival); if (ip && vp->oval == *ip) active = i; vp++; @@ -292,10 +392,31 @@ static struct gopt *gopt_new_combo_int(struct gopt_job_view *gjv, } gtk_combo_box_set_active(GTK_COMBO_BOX(c->combo), active); - c->gopt.sig_handler = g_signal_connect(GTK_OBJECT(c->combo), "changed", G_CALLBACK(gopt_combo_changed), c); + if (ip) + gopt_combo_int_set_val(c, *ip); + c->gopt.sig_handler = g_signal_connect(G_OBJECT(c->combo), "changed", G_CALLBACK(gopt_combo_changed), c); return &c->gopt; } +static void gopt_str_multi_toggled(GtkToggleButton *button, gpointer data) +{ + struct gopt_str_multi *m = (struct gopt_str_multi *) data; + + gopt_changed(&m->gopt); +} + +static void gopt_str_multi_destroy(GtkWidget *w, gpointer data) +{ + struct gopt_str_multi *m = (struct gopt_str_multi *) data; + + free(m); + gtk_widget_destroy(w); +} + +static void gopt_str_multi_set_val(struct gopt_str_multi *m, int val) +{ +} + static struct gopt *gopt_new_str_multi(struct gopt_job_view *gjv, struct fio_option *o, unsigned int idx) { @@ -304,10 +425,9 @@ static struct gopt *gopt_new_str_multi(struct gopt_job_view *gjv, GtkWidget *frame, *hbox; int i; - m = malloc(sizeof(*m)); - memset(m, 0, sizeof(*m)); + m = calloc(1, sizeof(*m)); m->gopt.box = gtk_hbox_new(FALSE, 3); - gopt_mark_index(gjv, &m->gopt, idx); + gopt_mark_index(gjv, &m->gopt, idx, GOPT_STR_MULTI); if (!o->lname) frame = gtk_frame_new(o->name); @@ -324,9 +444,13 @@ static struct gopt *gopt_new_str_multi(struct gopt_job_view *gjv, m->checks[i] = gtk_check_button_new_with_label(vp->ival); gtk_widget_set_tooltip_text(m->checks[i], vp->help); gtk_box_pack_start(GTK_BOX(hbox), m->checks[i], FALSE, FALSE, 3); + g_signal_connect(G_OBJECT(m->checks[i]), "toggled", G_CALLBACK(gopt_str_multi_toggled), m); vp++; + i++; } + gopt_str_multi_set_val(m, 0); + g_signal_connect(G_OBJECT(m->gopt.box), "destroy", G_CALLBACK(gopt_str_multi_destroy), m); return &m->gopt; } @@ -337,6 +461,8 @@ static void gopt_int_changed(GtkSpinButton *spin, gpointer data) GtkAdjustment *adj; int value, delta; + gopt_changed(&i->gopt); + adj = gtk_spin_button_get_adjustment(spin); value = gtk_adjustment_get_value(adj); delta = value - i->lastval; @@ -365,6 +491,12 @@ static void gopt_int_destroy(GtkWidget *w, gpointer data) gtk_widget_destroy(w); } +static void gopt_int_set_val(struct gopt_int *i, unsigned long long p) +{ + gtk_spin_button_set_value(GTK_SPIN_BUTTON(i->spin), p); + i->lastval = p; +} + static struct gopt_int *__gopt_new_int(struct gopt_job_view *gjv, struct fio_option *o, unsigned long long *p, unsigned int idx) @@ -374,8 +506,7 @@ static struct gopt_int *__gopt_new_int(struct gopt_job_view *gjv, guint maxval, interval; GtkWidget *label; - i = malloc(sizeof(*i)); - memset(i, 0, sizeof(*i)); + i = calloc(1, sizeof(*i)); i->gopt.box = gtk_hbox_new(FALSE, 3); if (!o->lname) label = gtk_label_new(o->name); @@ -392,7 +523,7 @@ static struct gopt_int *__gopt_new_int(struct gopt_job_view *gjv, else if (o->def) { long long val; - check_str_bytes(o->def, &val, NULL); + check_str_bytes(o->def, &val, o); defval = val; } @@ -401,10 +532,12 @@ static struct gopt_int *__gopt_new_int(struct gopt_job_view *gjv, interval = o->interval; i->spin = gtk_spin_button_new_with_range(o->minval, maxval, interval); - gopt_mark_index(gjv, &i->gopt, idx); + gopt_mark_index(gjv, &i->gopt, idx, GOPT_INT); gtk_spin_button_set_update_policy(GTK_SPIN_BUTTON(i->spin), GTK_UPDATE_IF_VALID); - gtk_spin_button_set_value(GTK_SPIN_BUTTON(i->spin), defval); - i->lastval = defval; + if (p) + gopt_int_set_val(i, *p); + else + gopt_int_set_val(i, defval); i->gopt.sig_handler = g_signal_connect(G_OBJECT(i->spin), "value-changed", G_CALLBACK(gopt_int_changed), i); g_signal_connect(G_OBJECT(i->spin), "destroy", G_CALLBACK(gopt_int_destroy), i); @@ -446,6 +579,8 @@ static void gopt_bool_toggled(GtkToggleButton *button, gpointer data) struct fio_option *o = &fio_options[b->gopt.opt_index]; gboolean set; + gopt_changed(&b->gopt); + set = gtk_toggle_button_get_active(GTK_TOGGLE_BUTTON(b->check)); if (o->inv_opt) { @@ -459,7 +594,7 @@ static void gopt_bool_toggled(GtkToggleButton *button, gpointer data) g_signal_handler_unblock(G_OBJECT(b_inv->check), b_inv->gopt.sig_handler); } - gopt_set_children_visible(o, set); + gopt_set_children_visible(b->gopt.gjv, o, set); } static void gopt_bool_destroy(GtkWidget *w, gpointer data) @@ -470,6 +605,11 @@ static void gopt_bool_destroy(GtkWidget *w, gpointer data) gtk_widget_destroy(w); } +static void gopt_bool_set_val(struct gopt_bool *b, unsigned int val) +{ + gtk_toggle_button_set_active(GTK_TOGGLE_BUTTON(b->check), val); +} + static struct gopt *gopt_new_bool(struct gopt_job_view *gjv, struct fio_option *o, unsigned int *val, unsigned int idx) @@ -478,8 +618,7 @@ static struct gopt *gopt_new_bool(struct gopt_job_view *gjv, GtkWidget *label; int defstate = 0; - b = malloc(sizeof(*b)); - memset(b, 0, sizeof(*b)); + b = calloc(1, sizeof(*b)); b->gopt.box = gtk_hbox_new(FALSE, 3); if (!o->lname) label = gtk_label_new(o->name); @@ -487,16 +626,17 @@ static struct gopt *gopt_new_bool(struct gopt_job_view *gjv, label = gtk_label_new(o->lname); b->check = gtk_check_button_new(); - gopt_mark_index(gjv, &b->gopt, idx); - if (val) - defstate = *val; - else if (o->def && !strcmp(o->def, "1")) + gopt_mark_index(gjv, &b->gopt, idx, GOPT_BOOL); + if (o->def && !strcmp(o->def, "1")) defstate = 1; if (o->neg) defstate = !defstate; - gtk_toggle_button_set_active(GTK_TOGGLE_BUTTON(b->check), defstate); + if (val) + gopt_bool_set_val(b, *val); + else + gtk_toggle_button_set_active(GTK_TOGGLE_BUTTON(b->check), defstate); b->gopt.sig_handler = g_signal_connect(G_OBJECT(b->check), "toggled", G_CALLBACK(gopt_bool_toggled), b); g_signal_connect(G_OBJECT(b->check), "destroy", G_CALLBACK(gopt_bool_destroy), b); @@ -516,6 +656,8 @@ static void range_value_changed(GtkSpinButton *spin, gpointer data) int changed = -1, i; gint val, mval; + gopt_changed(&r->gopt); + for (i = 0; i < GOPT_RANGE_SPIN; i++) { if (GTK_SPIN_BUTTON(r->spins[i]) == spin) { changed = i; @@ -553,20 +695,28 @@ static void gopt_range_destroy(GtkWidget *w, gpointer data) gtk_widget_destroy(w); } +static void gopt_int_range_set_val(struct gopt_range *r, unsigned int *vals) +{ + int i; + + for (i = 0; i < GOPT_RANGE_SPIN; i++) + gtk_spin_button_set_value(GTK_SPIN_BUTTON(r->spins[i]), vals[i]); +} + static struct gopt *gopt_new_int_range(struct gopt_job_view *gjv, struct fio_option *o, unsigned int **ip, unsigned int idx) { struct gopt_range *r; - gint maxval, defval; GtkWidget *label; guint interval; + unsigned int defvals[GOPT_RANGE_SPIN]; + gint maxval; int i; - r = malloc(sizeof(*r)); - memset(r, 0, sizeof(*r)); + r = calloc(1, sizeof(*r)); r->gopt.box = gtk_hbox_new(FALSE, 3); - gopt_mark_index(gjv, &r->gopt, idx); + gopt_mark_index(gjv, &r->gopt, idx, GOPT_RANGE); if (!o->lname) label = gtk_label_new(o->name); else @@ -576,12 +726,13 @@ static struct gopt *gopt_new_int_range(struct gopt_job_view *gjv, if (!maxval) maxval = INT_MAX; - defval = 0; + memset(defvals, 0, sizeof(defvals)); if (o->def) { long long val; - check_str_bytes(o->def, &val, NULL); - defval = val; + check_str_bytes(o->def, &val, o); + for (i = 0; i < GOPT_RANGE_SPIN; i++) + defvals[i] = val; } interval = 1.0; @@ -591,15 +742,17 @@ static struct gopt *gopt_new_int_range(struct gopt_job_view *gjv, for (i = 0; i < GOPT_RANGE_SPIN; i++) { r->spins[i] = gtk_spin_button_new_with_range(o->minval, maxval, interval); gtk_spin_button_set_update_policy(GTK_SPIN_BUTTON(r->spins[i]), GTK_UPDATE_IF_VALID); - if (ip) - gtk_spin_button_set_value(GTK_SPIN_BUTTON(r->spins[i]), *ip[i]); - else - gtk_spin_button_set_value(GTK_SPIN_BUTTON(r->spins[i]), defval); - gtk_box_pack_start(GTK_BOX(r->gopt.box), r->spins[i], FALSE, FALSE, 0); - g_signal_connect(G_OBJECT(r->spins[i]), "value-changed", G_CALLBACK(range_value_changed), r); } + if (ip) + gopt_int_range_set_val(r, *ip); + else + gopt_int_range_set_val(r, defvals); + + for (i = 0; i < GOPT_RANGE_SPIN; i++) + g_signal_connect(G_OBJECT(r->spins[i]), "value-changed", G_CALLBACK(range_value_changed), r); + gtk_box_pack_start(GTK_BOX(r->gopt.box), label, FALSE, FALSE, 0); g_signal_connect(G_OBJECT(r->gopt.box), "destroy", G_CALLBACK(gopt_range_destroy), r); return &r->gopt; @@ -644,6 +797,29 @@ static void gopt_str_val_spin_wrapped(GtkSpinButton *spin, gpointer data) } } +static void gopt_str_val_changed(GtkSpinButton *spin, gpointer data) +{ + struct gopt_str_val *g = (struct gopt_str_val *) data; + + gopt_changed(&g->gopt); +} + +static void gopt_str_val_set_val(struct gopt_str_val *g, unsigned long long val) +{ + int i = 0; + + do { + if (!val || (val % 1024)) + break; + + i++; + val /= 1024; + } while (1); + + gtk_spin_button_set_value(GTK_SPIN_BUTTON(g->spin), val); + gtk_combo_box_set_active(GTK_COMBO_BOX(g->combo), i); +} + static struct gopt *gopt_new_str_val(struct gopt_job_view *gjv, struct fio_option *o, unsigned long long *p, unsigned int idx) @@ -653,14 +829,13 @@ static struct gopt *gopt_new_str_val(struct gopt_job_view *gjv, GtkWidget *label; int i; - g = malloc(sizeof(*g)); - memset(g, 0, sizeof(*g)); + g = calloc(1, sizeof(*g)); g->gopt.box = gtk_hbox_new(FALSE, 3); if (!o->lname) label = gtk_label_new(o->name); else label = gtk_label_new(o->lname); - gopt_mark_index(gjv, &g->gopt, idx); + gopt_mark_index(gjv, &g->gopt, idx, GOPT_STR_VAL); g->spin = gtk_spin_button_new_with_range(0.0, 1023.0, 1.0); gtk_spin_button_set_update_policy(GTK_SPIN_BUTTON(g->spin), GTK_UPDATE_IF_VALID); @@ -668,11 +843,12 @@ static struct gopt *gopt_new_str_val(struct gopt_job_view *gjv, gtk_spin_button_set_wrap(GTK_SPIN_BUTTON(g->spin), 1); gtk_box_pack_start(GTK_BOX(g->gopt.box), g->spin, FALSE, FALSE, 0); g_signal_connect(G_OBJECT(g->spin), "wrapped", G_CALLBACK(gopt_str_val_spin_wrapped), g); + g_signal_connect(G_OBJECT(g->spin), "changed", G_CALLBACK(gopt_str_val_changed), g); - g->combo = gtk_combo_box_new_text(); + g->combo = gtk_combo_box_text_new(); i = 0; while (strlen(postfix[i])) { - gtk_combo_box_append_text(GTK_COMBO_BOX(g->combo), postfix[i]); + gtk_combo_box_text_append_text(GTK_COMBO_BOX_TEXT(g->combo), postfix[i]); i++; } g->maxindex = i - 1; @@ -680,10 +856,153 @@ static struct gopt *gopt_new_str_val(struct gopt_job_view *gjv, gtk_box_pack_start(GTK_BOX(g->gopt.box), g->combo, FALSE, FALSE, 0); gtk_box_pack_start(GTK_BOX(g->gopt.box), label, FALSE, FALSE, 3); + if (p) + gopt_str_val_set_val(g, *p); + + g_signal_connect(G_OBJECT(g->combo), "changed", G_CALLBACK(gopt_str_val_changed), g); + g_signal_connect(G_OBJECT(g->gopt.box), "destroy", G_CALLBACK(gopt_str_val_destroy), g); return &g->gopt; } +static void gopt_set_option(struct gopt_job_view *gjv, struct fio_option *o, + struct gopt *gopt, struct thread_options *to) +{ + switch (o->type) { + case FIO_OPT_STR_VAL: { + unsigned long long *ullp = NULL; + struct gopt_str_val *g; + + if (o->off1) + ullp = td_var(to, o, o->off1); + + g = container_of(gopt, struct gopt_str_val, gopt); + if (ullp) + gopt_str_val_set_val(g, *ullp); + break; + } + case FIO_OPT_STR_VAL_TIME: { + unsigned long long *ullp = NULL; + struct gopt_int *i; + + if (o->off1) + ullp = td_var(to, o, o->off1); + + i = container_of(gopt, struct gopt_int, gopt); + if (ullp) + gopt_int_set_val(i, *ullp); + break; + } + case FIO_OPT_INT: + if (o->posval[0].ival) { + unsigned int *ip = NULL; + struct gopt_combo *c; + + if (o->off1) + ip = td_var(to, o, o->off1); + + c = container_of(gopt, struct gopt_combo, gopt); + if (ip) + gopt_combo_int_set_val(c, *ip); + } else { + unsigned int *ip = NULL; + struct gopt_int *i; + + if (o->off1) + ip = td_var(to, o, o->off1); + + i = container_of(gopt, struct gopt_int, gopt); + if (ip) + gopt_int_set_val(i, *ip); + } + break; + case FIO_OPT_STR_SET: + case FIO_OPT_BOOL: { + unsigned int *ip = NULL; + struct gopt_bool *b; + + if (o->off1) + ip = td_var(to, o, o->off1); + + b = container_of(gopt, struct gopt_bool, gopt); + if (ip) + gopt_bool_set_val(b, *ip); + break; + } + case FIO_OPT_STR: { + if (o->posval[0].ival) { + unsigned int *ip = NULL; + struct gopt_combo *c; + + if (o->off1) + ip = td_var(to, o, o->off1); + + c = container_of(gopt, struct gopt_combo, gopt); + if (ip) + gopt_combo_int_set_val(c, *ip); + } else { + struct gopt_str *s; + char *text = NULL; + + if (o->off1) { + char **p = td_var(to, o, o->off1); + + text = *p; + } + + s = container_of(gopt, struct gopt_str, gopt); + gopt_str_store_set_val(s, text); + } + + break; + } + case FIO_OPT_STR_STORE: { + struct gopt_combo *c; + char *text = NULL; + + if (o->off1) { + char **p = td_var(to, o, o->off1); + text = *p; + } + + if (!o->posval[0].ival) { + struct gopt_str *s; + + s = container_of(gopt, struct gopt_str, gopt); + gopt_str_store_set_val(s, text); + break; + } + + c = container_of(gopt, struct gopt_combo, gopt); + if (text) + gopt_combo_str_set_val(c, text); + break; + } + case FIO_OPT_STR_MULTI: + /* HANDLE ME */ + break; + case FIO_OPT_RANGE: { + struct gopt_range *r; + unsigned int *ip[4] = { td_var(to, o, o->off1), + td_var(to, o, o->off2), + td_var(to, o, o->off3), + td_var(to, o, o->off4) }; + + r = container_of(gopt, struct gopt_range, gopt); + gopt_int_range_set_val(r, *ip); + break; + } + /* still need to handle this one */ + case FIO_OPT_FLOAT_LIST: + break; + case FIO_OPT_DEPRECATED: + break; + default: + printf("ignore type %u\n", o->type); + break; + } +} + static void gopt_add_option(struct gopt_job_view *gjv, GtkWidget *hbox, struct fio_option *o, unsigned int opt_index, struct thread_options *to) @@ -695,7 +1014,7 @@ static void gopt_add_option(struct gopt_job_view *gjv, GtkWidget *hbox, unsigned long long *ullp = NULL; if (o->off1) - ullp = td_var(to, o->off1); + ullp = td_var(to, o, o->off1); go = gopt_new_str_val(gjv, o, ullp, opt_index); break; @@ -704,26 +1023,34 @@ static void gopt_add_option(struct gopt_job_view *gjv, GtkWidget *hbox, unsigned long long *ullp = NULL; if (o->off1) - ullp = td_var(to, o->off1); + ullp = td_var(to, o, o->off1); go = gopt_new_ullong(gjv, o, ullp, opt_index); break; } - case FIO_OPT_INT: { - unsigned int *ip = NULL; + case FIO_OPT_INT: + if (o->posval[0].ival) { + unsigned int *ip = NULL; - if (o->off1) - ip = td_var(to, o->off1); + if (o->off1) + ip = td_var(to, o, o->off1); - go = gopt_new_int(gjv, o, ip, opt_index); - break; + go = gopt_new_combo_int(gjv, o, ip, opt_index); + } else { + unsigned int *ip = NULL; + + if (o->off1) + ip = td_var(to, o, o->off1); + + go = gopt_new_int(gjv, o, ip, opt_index); } + break; case FIO_OPT_STR_SET: case FIO_OPT_BOOL: { unsigned int *ip = NULL; if (o->off1) - ip = td_var(to, o->off1); + ip = td_var(to, o, o->off1); go = gopt_new_bool(gjv, o, ip, opt_index); break; @@ -733,7 +1060,7 @@ static void gopt_add_option(struct gopt_job_view *gjv, GtkWidget *hbox, unsigned int *ip = NULL; if (o->off1) - ip = td_var(to, o->off1); + ip = td_var(to, o, o->off1); go = gopt_new_combo_int(gjv, o, ip, opt_index); } else { @@ -747,7 +1074,7 @@ static void gopt_add_option(struct gopt_job_view *gjv, GtkWidget *hbox, char *text = NULL; if (o->off1) { - char **p = td_var(to, o->off1); + char **p = td_var(to, o, o->off1); text = *p; } @@ -763,10 +1090,10 @@ static void gopt_add_option(struct gopt_job_view *gjv, GtkWidget *hbox, go = gopt_new_str_multi(gjv, o, opt_index); break; case FIO_OPT_RANGE: { - unsigned int *ip[4] = { td_var(to, o->off1), - td_var(to, o->off2), - td_var(to, o->off3), - td_var(to, o->off4) }; + unsigned int *ip[4] = { td_var(to, o, o->off1), + td_var(to, o, o->off2), + td_var(to, o, o->off3), + td_var(to, o, o->off4) }; go = gopt_new_int_range(gjv, o, ip, opt_index); break; @@ -787,7 +1114,6 @@ static void gopt_add_option(struct gopt_job_view *gjv, GtkWidget *hbox, if (o->help) gtk_widget_set_tooltip_text(go->box, o->help); - go->opt_type = o->type; o->gui_data = go; dest = gopt_get_group_frame(gjv, hbox, o->group); @@ -822,6 +1148,19 @@ static void gopt_add_options(struct gopt_job_view *gjv, } } +static void gopt_set_options(struct gopt_job_view *gjv, + struct thread_options *to) +{ + int i; + + for (i = 0; fio_options[i].name; i++) { + struct fio_option *o = &fio_options[i]; + struct gopt *gopt = gjv->gopts[i]; + + gopt_set_option(gjv, o, gopt, to); + } +} + static GtkWidget *gopt_add_tab(GtkWidget *notebook, const char *name) { GtkWidget *box, *vbox, *scroll; @@ -860,35 +1199,357 @@ static void gopt_add_group_tabs(GtkWidget *notebook, struct gopt_job_view *gjv) } while (1); } -void gopt_get_options_window(GtkWidget *window, struct gfio_client *gc) +static void gopt_handle_str_multi_changed(struct gopt_job_view *gjv, + struct gopt_str_multi *m, + struct fio_option *o) { - GtkWidget *dialog, *notebook, *topnotebook, *vbox; - struct gfio_client_options *gco; - struct thread_options *o; + unsigned int *ip = td_var(gjv->o, o, o->off1); + struct value_pair *vp; + gboolean set; + guint val = 0; + int i; + + i = 0; + vp = &o->posval[0]; + while (vp->ival) { + if (!m->checks[i]) + break; + set = gtk_toggle_button_get_active(GTK_TOGGLE_BUTTON(m->checks[i])); + if (set) { + if (vp->orval) + val |= vp->oval; + else + val = vp->oval; + } + i++; + vp++; + } + + if (o->off1) + *ip = val; +} + +static void gopt_handle_range_changed(struct gopt_job_view *gjv, + struct gopt_range *r, + struct fio_option *o) +{ + unsigned int *ip[4] = { td_var(gjv->o, o, o->off1), + td_var(gjv->o, o, o->off2), + td_var(gjv->o, o, o->off3), + td_var(gjv->o, o, o->off4) }; + gint val; + int i; + + for (i = 0; i < GOPT_RANGE_SPIN; i++) { + val = gtk_spin_button_get_value_as_int(GTK_SPIN_BUTTON(r->spins[i])); + *ip[i] = val; + } +} + +static void gopt_handle_str_val_changed(struct gopt_job_view *gjv, + struct gopt_str_val *s, + struct fio_option *o) +{ + unsigned long long *ullp = td_var(gjv->o, o, o->off1); + GtkAdjustment *adj; + gint index; + + if (!ullp) + return; + + /* + * Numerical value + */ + adj = gtk_spin_button_get_adjustment(GTK_SPIN_BUTTON(s->spin)); + *ullp = gtk_adjustment_get_value(adj); + + /* + * Multiplier + */ + index = gtk_combo_box_get_active(GTK_COMBO_BOX(s->combo)); + while (index--) + *ullp *= 1024ULL; +} + +static void gopt_handle_str_changed(struct gopt_job_view *gjv, + struct gopt_str *s, struct fio_option *o) +{ + char **p = td_var(gjv->o, o, o->off1); + + if (*p) + free(*p); + + *p = strdup(gtk_entry_get_text(GTK_ENTRY(s->entry))); +} + +static void gopt_handle_bool_changed(struct gopt_job_view *gjv, + struct gopt_bool *b, struct fio_option *o) +{ + unsigned int *ip = td_var(gjv->o, o, o->off1); + gboolean set; + + set = gtk_toggle_button_get_active(GTK_TOGGLE_BUTTON(b->check)); + *ip = set; +} + +static void gopt_handle_int_changed(struct gopt_job_view *gjv, + struct gopt_int *i, struct fio_option *o) +{ + unsigned int *ip = td_var(gjv->o, o, o->off1); + GtkAdjustment *adj; + guint val; + + adj = gtk_spin_button_get_adjustment(GTK_SPIN_BUTTON(i->spin)); + val = gtk_adjustment_get_value(adj); + *ip = val; +} + +static void gopt_handle_combo_str_changed(struct gopt_job_view *gjv, + struct gopt_combo *c, + struct fio_option *o) +{ + char **p = td_var(gjv->o, o, o->off1); + + if (*p) + free(*p); + + *p = strdup(gtk_combo_box_text_get_active_text(GTK_COMBO_BOX_TEXT(c->combo))); +} + +static void gopt_handle_combo_int_changed(struct gopt_job_view *gjv, + struct gopt_combo *c, + struct fio_option *o) +{ + unsigned int *ip = td_var(gjv->o, o, o->off1); + gint index; + + index = gtk_combo_box_get_active(GTK_COMBO_BOX(c->combo)); + *ip = o->posval[index].oval; +} + +static void gopt_handle_changed(struct gopt *gopt) +{ + struct fio_option *o = &fio_options[gopt->opt_index]; + struct gopt_job_view *gjv = gopt->gjv; + + switch (gopt->opt_type) { + case GOPT_COMBO_INT: { + struct gopt_combo *c; + + c = container_of(gopt, struct gopt_combo, gopt); + gopt_handle_combo_int_changed(gjv, c, o); + break; + } + case GOPT_COMBO_STR: { + struct gopt_combo *c; + + c = container_of(gopt, struct gopt_combo, gopt); + gopt_handle_combo_str_changed(gjv, c, o); + break; + } + case GOPT_INT: { + struct gopt_int *i; + + i = container_of(gopt, struct gopt_int, gopt); + gopt_handle_int_changed(gjv, i, o); + break; + } + case GOPT_BOOL: { + struct gopt_bool *b; + + b = container_of(gopt, struct gopt_bool, gopt); + gopt_handle_bool_changed(gjv, b, o); + break; + } + case GOPT_STR: { + struct gopt_str *s; + + s = container_of(gopt, struct gopt_str, gopt); + gopt_handle_str_changed(gjv, s, o); + break; + } + case GOPT_STR_VAL: { + struct gopt_str_val *s; + + s = container_of(gopt, struct gopt_str_val, gopt); + gopt_handle_str_val_changed(gjv, s, o); + break; + } + case GOPT_RANGE: { + struct gopt_range *r; + + r = container_of(gopt, struct gopt_range, gopt); + gopt_handle_range_changed(gjv, r, o); + break; + } + case GOPT_STR_MULTI: { + struct gopt_str_multi *m; + + m = container_of(gopt, struct gopt_str_multi, gopt); + gopt_handle_str_multi_changed(gjv, m, o); + break; + } + default: + log_err("gfio: bad option type: %d\n", gopt->opt_type); + break; + } +} + +static void gopt_report_update_status(struct gopt_job_view *gjv) +{ + struct gfio_client *gc = gjv->client; + char tmp[80]; + + sprintf(tmp, "\nCompleted with error: %d\n", gc->update_job_status); + gfio_report_info(gc->ge->ui, "Update job", tmp); +} + +static int gopt_handle_changed_options(struct gopt_job_view *gjv) +{ + struct gfio_client *gc = gjv->client; struct flist_head *entry; - struct gopt_job_view *gjv; - FLIST_HEAD(gjv_list); + uint64_t waitid = 0; + struct gopt *gopt; + int ret; + + flist_for_each(entry, &gjv->changed_list) { + gopt = flist_entry(entry, struct gopt, changed_list); + gopt_handle_changed(gopt); + } + + gc->update_job_status = 0; + gc->update_job_done = 0; + + ret = fio_client_update_options(gc->client, gjv->o, &waitid); + if (ret) + goto done; + + ret = fio_client_wait_for_reply(gc->client, waitid); + if (ret) + goto done; + + assert(gc->update_job_done); + if (gc->update_job_status) + goto done; + + while (!flist_empty(&gjv->changed_list)) { + gopt = flist_entry(gjv->changed_list.next, struct gopt, changed_list); + flist_del_init(&gopt->changed_list); + } + +done: + gopt_dialog_update_apply_button(gjv); + return ret; +} + +static gint gopt_dialog_cancel(gint response) +{ + switch (response) { + case GTK_RESPONSE_NONE: + case GTK_RESPONSE_REJECT: + case GTK_RESPONSE_DELETE_EVENT: + case GTK_RESPONSE_CANCEL: + case GTK_RESPONSE_NO: + return 1; + default: + return 0; + } +} + +static gint gopt_dialog_done(gint response) +{ + switch (response) { + case GTK_RESPONSE_ACCEPT: + case GTK_RESPONSE_OK: + case GTK_RESPONSE_YES: + return 1; + default: + return 0; + } +} + +static void gopt_handle_option_dialog(struct gopt_job_view *gjv) +{ + gint response; + + do { + response = gtk_dialog_run(GTK_DIALOG(gjv->dialog)); + + if (gopt_dialog_cancel(response) || + gopt_dialog_done(response)) + break; + + /* + * Apply + */ + gopt_handle_changed_options(gjv); + gopt_report_update_status(gjv); + } while (1); + + if (gopt_dialog_cancel(response)) + return; + + gopt_handle_changed_options(gjv); +} + +static void gopt_job_changed(GtkComboBox *box, gpointer data) +{ + struct gopt_job_view *gjv = (struct gopt_job_view *) data; + struct gfio_client_options *gco = NULL; + struct gfio_client *gc = gjv->client; + struct flist_head *entry; + gchar *job; /* - * Just choose the first item, we need to make each options - * entry the main notebook, with the below options view as - * a sub-notebook + * The switch act should be sensitized appropriately, so that we + * never get here with modified options. */ - assert(!flist_empty(&gc->o_list)); + if (!flist_empty(&gjv->changed_list)) { + gfio_report_info(gc->ge->ui, "Internal Error", "Modified options on job switch.\nThat should not be possible!\n"); + return; + } + + job = gtk_combo_box_text_get_active_text(GTK_COMBO_BOX_TEXT(gjv->job_combo)); + flist_for_each(entry, &gc->o_list) { + const char *name; + + gco = flist_entry(entry, struct gfio_client_options, list); + name = gco->o.name; + if (!name || !strlen(name)) + name = "Default job"; + + if (!strcmp(name, job)) + break; + + gco = NULL; + } + + if (!gco) { + gfio_report_info(gc->ge->ui, "Internal Error", "Could not find job description.\nThat should not be possible!\n"); + return; + } + + gjv->in_job_switch = 1; + gopt_set_options(gjv, &gco->o); + gjv->in_job_switch = 0; +} + +void gopt_get_options_window(GtkWidget *window, struct gfio_client *gc) +{ + GtkWidget *dialog, *notebook, *vbox, *topvbox, *combo; + struct gfio_client_options *gco; + struct flist_head *entry; + struct gopt_job_view *gjv; dialog = gtk_dialog_new_with_buttons("Fio options", GTK_WINDOW(window), GTK_DIALOG_DESTROY_WITH_PARENT, GTK_STOCK_OK, GTK_RESPONSE_ACCEPT, + GTK_STOCK_APPLY, GTK_RESPONSE_APPLY, GTK_STOCK_CANCEL, GTK_RESPONSE_REJECT, NULL); - gtk_widget_set_size_request(GTK_WIDGET(dialog), 1024, 768); - - topnotebook = gtk_notebook_new(); - gtk_notebook_set_scrollable(GTK_NOTEBOOK(topnotebook), 1); - gtk_notebook_popup_enable(GTK_NOTEBOOK(topnotebook)); - gtk_box_pack_start(GTK_BOX(GTK_DIALOG(dialog)->vbox), topnotebook, TRUE, TRUE, 5); - + combo = gtk_combo_box_text_new(); flist_for_each(entry, &gc->o_list) { + struct thread_options *o; const char *name; gco = flist_entry(entry, struct gfio_client_options, list); @@ -897,31 +1558,42 @@ void gopt_get_options_window(GtkWidget *window, struct gfio_client *gc) if (!name || !strlen(name)) name = "Default job"; - vbox = gopt_add_tab(topnotebook, name); + gtk_combo_box_text_append_text(GTK_COMBO_BOX_TEXT(combo), name); + } + gtk_combo_box_set_active(GTK_COMBO_BOX(combo), 0); - notebook = gtk_notebook_new(); - gtk_notebook_set_scrollable(GTK_NOTEBOOK(notebook), 1); - gtk_notebook_popup_enable(GTK_NOTEBOOK(notebook)); - gtk_box_pack_start(GTK_BOX(vbox), notebook, TRUE, TRUE, 5); + gtk_widget_set_size_request(GTK_WIDGET(dialog), 1024, 768); - gjv = calloc(1, sizeof(*gjv)); - INIT_FLIST_HEAD(&gjv->list); - flist_add_tail(&gjv->list, &gjv_list); - gopt_add_group_tabs(notebook, gjv); - gopt_add_options(gjv, o); - } + topvbox = gtk_dialog_get_content_area(GTK_DIALOG(dialog)); + gtk_box_pack_start(GTK_BOX(topvbox), combo, FALSE, FALSE, 5); + + vbox = gtk_vbox_new(TRUE, 5); + gtk_box_pack_start(GTK_BOX(topvbox), vbox, TRUE, TRUE, 5); + + notebook = gtk_notebook_new(); + gtk_notebook_set_scrollable(GTK_NOTEBOOK(notebook), 1); + gtk_notebook_popup_enable(GTK_NOTEBOOK(notebook)); + gtk_box_pack_start(GTK_BOX(vbox), notebook, TRUE, TRUE, 5); + + gjv = calloc(1, sizeof(*gjv)); + INIT_FLIST_HEAD(&gjv->changed_list); + gco = flist_entry(gc->o_list.next, struct gfio_client_options, list); + gjv->o = &gco->o; + gjv->dialog = dialog; + gjv->client = gc; + gjv->job_combo = combo; + gopt_add_group_tabs(notebook, gjv); + gopt_add_options(gjv, &gco->o); + gopt_dialog_update_apply_button(gjv); + + g_signal_connect(G_OBJECT(combo), "changed", G_CALLBACK(gopt_job_changed), gjv); gtk_widget_show_all(dialog); - gtk_dialog_run(GTK_DIALOG(dialog)); + gopt_handle_option_dialog(gjv); gtk_widget_destroy(dialog); - - while (!flist_empty(&gjv_list)) { - gjv = flist_entry(gjv_list.next, struct gopt_job_view, list); - flist_del(&gjv->list); - free(gjv); - } + free(gjv); } /*