2 * gfio - gui front end for fio - the flexible io tester
4 * Copyright (C) 2012 Stephen M. Cameron <stephenmcameron@gmail.com>
5 * Copyright (C) 2012 Jens Axboe <axboe@kernel.dk>
7 * The license below covers all files distributed with fio unless otherwise
8 * noted in the file itself.
10 * This program is free software; you can redistribute it and/or modify
11 * it under the terms of the GNU General Public License version 2 as
12 * published by the Free Software Foundation.
14 * This program is distributed in the hope that it will be useful,
15 * but WITHOUT ANY WARRANTY; without even the implied warranty of
16 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
17 * GNU General Public License for more details.
19 * You should have received a copy of the GNU General Public License
20 * along with this program; if not, write to the Free Software
21 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
40 static int gfio_server_running;
41 static unsigned int gfio_graph_limit = 100;
43 GdkColor gfio_color_white;
44 GdkColor gfio_color_lightyellow;
45 const char *gfio_graph_font = GRAPH_DEFAULT_FONT;
47 typedef void (*clickfunction)(GtkWidget *widget, gpointer data);
49 static void connect_clicked(GtkWidget *widget, gpointer data);
50 static void start_job_clicked(GtkWidget *widget, gpointer data);
51 static void send_clicked(GtkWidget *widget, gpointer data);
53 static struct button_spec {
54 const char *buttontext;
56 const char *tooltiptext[2];
57 const int start_sensitive;
58 } buttonspeclist[] = {
60 .buttontext = "Connect",
62 .tooltiptext = { "Disconnect from host", "Connect to host" },
68 .tooltiptext = { "Send job description to host", NULL },
72 .buttontext = "Start Job",
73 .f = start_job_clicked,
74 .tooltiptext = { "Start the current job on the server", NULL },
79 static void setup_iops_graph(struct gfio_graphs *gg)
83 g = graph_new(DRAWING_AREA_XDIM / 2.0, DRAWING_AREA_YDIM, gfio_graph_font);
84 graph_title(g, "IOPS (IOs/sec)");
85 graph_x_title(g, "Time (secs)");
86 gg->read_iops = graph_add_label(g, "Read IOPS");
87 gg->write_iops = graph_add_label(g, "Write IOPS");
88 gg->trim_iops = graph_add_label(g, "Trim IOPS");
89 graph_set_color(g, gg->read_iops, GFIO_READ_R, GFIO_READ_G, GFIO_READ_B);
90 graph_set_color(g, gg->write_iops, GFIO_WRITE_R, GFIO_WRITE_G, GFIO_WRITE_B);
91 graph_set_color(g, gg->trim_iops, GFIO_TRIM_R, GFIO_TRIM_G, GFIO_TRIM_B);
92 line_graph_set_data_count_limit(g, gfio_graph_limit);
93 graph_add_extra_space(g, 0.0, 0.0, 0.0, 0.0);
94 graph_set_graph_all_zeroes(g, 0);
98 static void setup_bandwidth_graph(struct gfio_graphs *gg)
102 g = graph_new(DRAWING_AREA_XDIM / 2.0, DRAWING_AREA_YDIM, gfio_graph_font);
103 graph_title(g, "Bandwidth (bytes/sec)");
104 graph_x_title(g, "Time (secs)");
105 gg->read_bw = graph_add_label(g, "Read Bandwidth");
106 gg->write_bw = graph_add_label(g, "Write Bandwidth");
107 gg->trim_bw = graph_add_label(g, "Trim Bandwidth");
108 graph_set_color(g, gg->read_bw, GFIO_READ_R, GFIO_READ_G, GFIO_READ_B);
109 graph_set_color(g, gg->write_bw, GFIO_WRITE_R, GFIO_WRITE_G, GFIO_WRITE_B);
110 graph_set_color(g, gg->trim_bw, GFIO_TRIM_R, GFIO_TRIM_G, GFIO_TRIM_B);
111 graph_set_base_offset(g, 1);
112 line_graph_set_data_count_limit(g, 100);
113 graph_add_extra_space(g, 0.0, 0.0, 0.0, 0.0);
114 graph_set_graph_all_zeroes(g, 0);
115 gg->bandwidth_graph = g;
118 static void setup_graphs(struct gfio_graphs *g)
121 setup_bandwidth_graph(g);
124 void clear_ge_ui_info(struct gui_entry *ge)
126 gtk_label_set_text(GTK_LABEL(ge->probe.hostname), "");
127 gtk_label_set_text(GTK_LABEL(ge->probe.os), "");
128 gtk_label_set_text(GTK_LABEL(ge->probe.arch), "");
129 gtk_label_set_text(GTK_LABEL(ge->probe.fio_ver), "");
131 /* should we empty it... */
132 gtk_entry_set_text(GTK_ENTRY(ge->eta.name), "");
134 multitext_update_entry(&ge->eta.iotype, 0, "");
135 multitext_update_entry(&ge->eta.bs, 0, "");
136 multitext_update_entry(&ge->eta.ioengine, 0, "");
137 multitext_update_entry(&ge->eta.iodepth, 0, "");
138 gtk_entry_set_text(GTK_ENTRY(ge->eta.jobs), "");
139 gtk_entry_set_text(GTK_ENTRY(ge->eta.files), "");
140 gtk_entry_set_text(GTK_ENTRY(ge->eta.read_bw), "");
141 gtk_entry_set_text(GTK_ENTRY(ge->eta.read_iops), "");
142 gtk_entry_set_text(GTK_ENTRY(ge->eta.write_bw), "");
143 gtk_entry_set_text(GTK_ENTRY(ge->eta.write_iops), "");
146 static void set_menu_entry_text(struct gui *ui, const char *path,
151 w = gtk_ui_manager_get_widget(ui->uimanager, path);
153 gtk_menu_item_set_label(GTK_MENU_ITEM(w), text);
155 fprintf(stderr, "gfio: can't find path %s\n", path);
159 static void set_menu_entry_visible(struct gui *ui, const char *path, int show)
163 w = gtk_ui_manager_get_widget(ui->uimanager, path);
165 gtk_widget_set_sensitive(w, show);
167 fprintf(stderr, "gfio: can't find path %s\n", path);
170 static void set_job_menu_visible(struct gui *ui, int visible)
172 set_menu_entry_visible(ui, "/MainMenu/JobMenu", visible);
175 static void set_view_results_visible(struct gui *ui, int visible)
177 set_menu_entry_visible(ui, "/MainMenu/ViewMenu/Results", visible);
180 static const char *get_button_tooltip(struct button_spec *s, int sensitive)
182 if (s->tooltiptext[sensitive])
183 return s->tooltiptext[sensitive];
185 return s->tooltiptext[0];
188 static GtkWidget *add_button(GtkWidget *buttonbox,
189 struct button_spec *buttonspec, gpointer data)
191 GtkWidget *button = gtk_button_new_with_label(buttonspec->buttontext);
192 gboolean sens = buttonspec->start_sensitive;
194 g_signal_connect(button, "clicked", G_CALLBACK(buttonspec->f), data);
195 gtk_box_pack_start(GTK_BOX(buttonbox), button, FALSE, FALSE, 3);
197 sens = buttonspec->start_sensitive;
198 gtk_widget_set_tooltip_text(button, get_button_tooltip(buttonspec, sens));
199 gtk_widget_set_sensitive(button, sens);
204 static void add_buttons(struct gui_entry *ge, struct button_spec *buttonlist,
209 for (i = 0; i < nbuttons; i++)
210 ge->button[i] = add_button(ge->buttonbox, &buttonlist[i], ge);
214 * Update sensitivity of job buttons and job menu items, based on the
215 * state of the client.
217 static void update_button_states(struct gui *ui, struct gui_entry *ge)
219 unsigned int connect_state, send_state, start_state, edit_state;
220 const char *connect_str = NULL;
224 gfio_report_error(ge, "Bad client state: %u\n", ge->state);
225 /* fall through to new state */
229 connect_str = "Connect";
233 case GE_STATE_CONNECTED:
236 connect_str = "Disconnect";
240 case GE_STATE_JOB_SENT:
243 connect_str = "Disconnect";
247 case GE_STATE_JOB_STARTED:
250 connect_str = "Disconnect";
254 case GE_STATE_JOB_RUNNING:
257 connect_str = "Disconnect";
261 case GE_STATE_JOB_DONE:
264 connect_str = "Connect";
270 gtk_widget_set_sensitive(ge->button[GFIO_BUTTON_CONNECT], connect_state);
271 gtk_widget_set_sensitive(ge->button[GFIO_BUTTON_SEND], send_state);
272 gtk_widget_set_sensitive(ge->button[GFIO_BUTTON_START], start_state);
273 gtk_button_set_label(GTK_BUTTON(ge->button[GFIO_BUTTON_CONNECT]), connect_str);
274 gtk_widget_set_tooltip_text(ge->button[GFIO_BUTTON_CONNECT], get_button_tooltip(&buttonspeclist[GFIO_BUTTON_CONNECT], connect_state));
276 set_menu_entry_visible(ui, "/MainMenu/JobMenu/Connect", connect_state);
277 set_menu_entry_text(ui, "/MainMenu/JobMenu/Connect", connect_str);
279 set_menu_entry_visible(ui, "/MainMenu/JobMenu/Edit job", edit_state);
280 set_menu_entry_visible(ui, "/MainMenu/JobMenu/Send job", send_state);
281 set_menu_entry_visible(ui, "/MainMenu/JobMenu/Start job", start_state);
283 if (ge->client && ge->client->nr_results)
284 set_view_results_visible(ui, 1);
286 set_view_results_visible(ui, 0);
289 void gfio_set_state(struct gui_entry *ge, unsigned int state)
292 update_button_states(ge->ui, ge);
295 static void gfio_ui_setup_log(struct gui *ui)
297 GtkTreeSelection *selection;
299 GtkWidget *tree_view;
301 model = gtk_list_store_new(4, G_TYPE_STRING, G_TYPE_STRING, G_TYPE_STRING, G_TYPE_STRING);
303 tree_view = gtk_tree_view_new_with_model(GTK_TREE_MODEL(model));
304 gtk_widget_set_can_focus(tree_view, FALSE);
306 selection = gtk_tree_view_get_selection(GTK_TREE_VIEW(tree_view));
307 gtk_tree_selection_set_mode(GTK_TREE_SELECTION(selection), GTK_SELECTION_BROWSE);
308 g_object_set(G_OBJECT(tree_view), "headers-visible", TRUE,
309 "enable-grid-lines", GTK_TREE_VIEW_GRID_LINES_BOTH, NULL);
311 tree_view_column(tree_view, 0, "Time", ALIGN_RIGHT | UNSORTABLE);
312 tree_view_column(tree_view, 1, "Host", ALIGN_RIGHT | UNSORTABLE);
313 tree_view_column(tree_view, 2, "Level", ALIGN_RIGHT | UNSORTABLE);
314 tree_view_column(tree_view, 3, "Text", ALIGN_LEFT | UNSORTABLE);
316 ui->log_model = model;
317 ui->log_tree = tree_view;
320 static gint on_config_drawing_area(GtkWidget *w, GdkEventConfigure *event,
323 guint width = gtk_widget_get_allocated_width(w);
324 guint height = gtk_widget_get_allocated_height(w);
325 struct gfio_graphs *g = data;
327 graph_set_size(g->iops_graph, width / 2.0, height);
328 graph_set_position(g->iops_graph, width / 2.0, 0.0);
329 graph_set_size(g->bandwidth_graph, width / 2.0, height);
330 graph_set_position(g->bandwidth_graph, 0, 0);
334 static void draw_graph(struct graph *g, cairo_t *cr)
336 line_graph_draw(g, cr);
340 static gboolean graph_tooltip(GtkWidget *w, gint x, gint y,
341 gboolean keyboard_mode, GtkTooltip *tooltip,
344 struct gfio_graphs *g = data;
345 const char *text = NULL;
347 if (graph_contains_xy(g->iops_graph, x, y))
348 text = graph_find_tooltip(g->iops_graph, x, y);
349 else if (graph_contains_xy(g->bandwidth_graph, x, y))
350 text = graph_find_tooltip(g->bandwidth_graph, x, y);
353 gtk_tooltip_set_text(tooltip, text);
360 static int on_expose_drawing_area(GtkWidget *w, GdkEvent *event, gpointer p)
362 struct gfio_graphs *g = p;
365 cr = gdk_cairo_create(gtk_widget_get_window(w));
367 if (graph_has_tooltips(g->iops_graph) ||
368 graph_has_tooltips(g->bandwidth_graph)) {
369 g_object_set(w, "has-tooltip", TRUE, NULL);
370 g_signal_connect(w, "query-tooltip", G_CALLBACK(graph_tooltip), g);
373 cairo_set_source_rgb(cr, 0, 0, 0);
374 draw_graph(g->iops_graph, cr);
375 draw_graph(g->bandwidth_graph, cr);
382 * FIXME: need more handling here
384 static void ge_destroy(struct gui_entry *ge)
386 struct gfio_client *gc = ge->client;
390 if (ge->state >= GE_STATE_CONNECTED)
391 fio_client_terminate(gc->client);
393 fio_put_client(gc->client);
398 g_hash_table_remove(ge->ui->ge_hash, &ge->page_num);
405 static void ge_widget_destroy(GtkWidget *w, gpointer data)
407 struct gui_entry *ge = (struct gui_entry *) data;
412 static void gfio_quit(struct gui *ui)
417 static void quit_clicked(__attribute__((unused)) GtkWidget *widget,
420 struct gui *ui = (struct gui *) data;
425 static void *job_thread(void *arg)
427 struct gui *ui = arg;
429 ui->handler_running = 1;
430 fio_handle_clients(&gfio_client_ops);
431 ui->handler_running = 0;
435 static int send_job_file(struct gui_entry *ge)
437 struct gfio_client *gc = ge->client;
441 * Prune old options, we are expecting the return options
442 * when the job file is parsed remotely and returned to us.
444 while (!flist_empty(&gc->o_list)) {
445 struct gfio_client_options *gco;
447 gco = flist_entry(gc->o_list.next, struct gfio_client_options, list);
448 flist_del(&gco->list);
452 ret = fio_client_send_ini(gc->client, ge->job_file);
456 gfio_report_error(ge, "Failed to send file %s: %s\n", ge->job_file, strerror(-ret));
460 static void *server_thread(void *arg)
463 gfio_server_running = 1;
464 fio_start_server(NULL);
465 gfio_server_running = 0;
469 static void gfio_start_server(struct gui *ui)
471 if (!gfio_server_running) {
472 gfio_server_running = 1;
473 pthread_create(&ui->server_t, NULL, server_thread, NULL);
474 pthread_detach(ui->server_t);
478 static void start_job_clicked(__attribute__((unused)) GtkWidget *widget,
481 struct gui_entry *ge = data;
482 struct gfio_client *gc = ge->client;
485 fio_start_client(gc->client);
488 static void file_open(GtkWidget *w, gpointer data);
490 struct connection_widgets
497 static void hostname_cb(GtkEntry *entry, gpointer data)
499 struct connection_widgets *cw = data;
500 int uses_net = 0, is_localhost = 0;
505 * Check whether to display the 'auto start backend' box
506 * or not. Show it if we are a localhost and using network,
509 ctext = gtk_combo_box_text_get_active_text(GTK_COMBO_BOX_TEXT(cw->combo));
510 if (!ctext || !strncmp(ctext, "IPv4", 4) || !strncmp(ctext, "IPv6", 4))
515 text = gtk_entry_get_text(GTK_ENTRY(cw->hentry));
516 if (!strcmp(text, "127.0.0.1") || !strcmp(text, "localhost") ||
517 !strcmp(text, "::1") || !strcmp(text, "ip6-localhost") ||
518 !strcmp(text, "ip6-loopback"))
522 if (!uses_net || is_localhost) {
523 gtk_toggle_button_set_active(GTK_TOGGLE_BUTTON(cw->button), 1);
524 gtk_widget_set_sensitive(cw->button, 1);
526 gtk_toggle_button_set_active(GTK_TOGGLE_BUTTON(cw->button), 0);
527 gtk_widget_set_sensitive(cw->button, 0);
531 static int get_connection_details(struct gui_entry *ge)
533 GtkWidget *dialog, *box, *vbox, *hbox, *frame, *pentry;
534 struct connection_widgets cw;
535 struct gui *ui = ge->ui;
541 dialog = gtk_dialog_new_with_buttons("Connection details",
542 GTK_WINDOW(ui->window),
543 GTK_DIALOG_DESTROY_WITH_PARENT,
544 GTK_STOCK_OK, GTK_RESPONSE_ACCEPT,
545 GTK_STOCK_CANCEL, GTK_RESPONSE_REJECT, NULL);
547 frame = gtk_frame_new("Hostname / socket name");
548 vbox = gtk_dialog_get_content_area(GTK_DIALOG(dialog));
549 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
551 box = gtk_vbox_new(FALSE, 6);
552 gtk_container_add(GTK_CONTAINER(frame), box);
554 hbox = gtk_hbox_new(TRUE, 10);
555 gtk_box_pack_start(GTK_BOX(box), hbox, FALSE, FALSE, 0);
556 cw.hentry = gtk_entry_new();
557 gtk_entry_set_text(GTK_ENTRY(cw.hentry), "localhost");
558 gtk_box_pack_start(GTK_BOX(hbox), cw.hentry, TRUE, TRUE, 0);
560 frame = gtk_frame_new("Port");
561 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
562 box = gtk_vbox_new(FALSE, 10);
563 gtk_container_add(GTK_CONTAINER(frame), box);
565 hbox = gtk_hbox_new(TRUE, 4);
566 gtk_box_pack_start(GTK_BOX(box), hbox, FALSE, FALSE, 0);
567 pentry = create_spinbutton(hbox, 1, 65535, FIO_NET_PORT);
569 frame = gtk_frame_new("Type");
570 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
571 box = gtk_vbox_new(FALSE, 10);
572 gtk_container_add(GTK_CONTAINER(frame), box);
574 hbox = gtk_hbox_new(TRUE, 4);
575 gtk_box_pack_start(GTK_BOX(box), hbox, FALSE, FALSE, 0);
577 cw.combo = gtk_combo_box_text_new();
578 gtk_combo_box_text_append_text(GTK_COMBO_BOX_TEXT(cw.combo), "IPv4");
579 gtk_combo_box_text_append_text(GTK_COMBO_BOX_TEXT(cw.combo), "IPv6");
580 gtk_combo_box_text_append_text(GTK_COMBO_BOX_TEXT(cw.combo), "local socket");
581 gtk_combo_box_set_active(GTK_COMBO_BOX(cw.combo), 0);
583 gtk_container_add(GTK_CONTAINER(hbox), cw.combo);
585 frame = gtk_frame_new("Options");
586 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
587 box = gtk_vbox_new(FALSE, 10);
588 gtk_container_add(GTK_CONTAINER(frame), box);
590 hbox = gtk_hbox_new(TRUE, 4);
591 gtk_box_pack_start(GTK_BOX(box), hbox, FALSE, FALSE, 0);
593 cw.button = gtk_check_button_new_with_label("Auto-spawn fio backend");
594 gtk_toggle_button_set_active(GTK_TOGGLE_BUTTON(cw.button), 1);
595 gtk_widget_set_tooltip_text(cw.button, "When running fio locally, it is necessary to have the backend running on the same system. If this is checked, gfio will start the backend automatically for you if it isn't already running.");
596 gtk_box_pack_start(GTK_BOX(hbox), cw.button, FALSE, FALSE, 6);
599 * Connect edit signal, so we can show/not-show the auto start button
601 g_signal_connect(G_OBJECT(cw.hentry), "changed", G_CALLBACK(hostname_cb), &cw);
602 g_signal_connect(G_OBJECT(cw.combo), "changed", G_CALLBACK(hostname_cb), &cw);
604 gtk_widget_show_all(dialog);
606 if (gtk_dialog_run(GTK_DIALOG(dialog)) != GTK_RESPONSE_ACCEPT) {
607 gtk_widget_destroy(dialog);
611 ge->host = strdup(gtk_entry_get_text(GTK_ENTRY(cw.hentry)));
612 ge->port = gtk_spin_button_get_value_as_int(GTK_SPIN_BUTTON(pentry));
614 typeentry = gtk_combo_box_text_get_active_text(GTK_COMBO_BOX_TEXT(cw.combo));
615 if (!typeentry || !strncmp(typeentry, "IPv4", 4))
616 ge->type = Fio_client_ipv4;
617 else if (!strncmp(typeentry, "IPv6", 4))
618 ge->type = Fio_client_ipv6;
620 ge->type = Fio_client_socket;
623 ge->server_start = gtk_toggle_button_get_active(GTK_TOGGLE_BUTTON(cw.button));
625 gtk_widget_destroy(dialog);
629 static void gfio_set_client(struct gfio_client *gc, struct fio_client *client)
631 gc->client = fio_get_client(client);
632 client->client_data = gc;
635 static void gfio_client_added(struct gui_entry *ge, struct fio_client *client)
637 struct gfio_client_options *gco;
638 struct gfio_client *gc;
640 gc = calloc(1, sizeof(*gc));
641 INIT_FLIST_HEAD(&gc->o_list);
644 gfio_set_client(gc, client);
647 * Just add a default set of options, need to consider how best
650 gco = calloc(1, sizeof(*gco));
651 INIT_FLIST_HEAD(&gco->list);
652 options_default_fill(&gco->o);
653 flist_add_tail(&gco->list, &gc->o_list);
657 static void gfio_clear_graph_data(struct gfio_graphs *g)
659 graph_clear_values(g->iops_graph);
660 graph_clear_values(g->bandwidth_graph);
663 static void connect_clicked(GtkWidget *widget, gpointer data)
665 struct gui_entry *ge = data;
666 struct gfio_client *gc = ge->client;
668 if (ge->state == GE_STATE_NEW) {
672 file_open(widget, ge->ui);
679 struct fio_client *client;
681 if (get_connection_details(ge)) {
682 gfio_report_error(ge, "Failed to get connection details\n");
686 client = fio_client_add_explicit(&gfio_client_ops, ge->host, ge->type, ge->port);
688 gfio_report_error(ge, "Failed to add client %s\n", ge->host);
693 gfio_set_client(gc, client);
696 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(ge->thread_status_pb), "No jobs running");
697 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(ge->thread_status_pb), 0.0);
698 ret = fio_client_connect(gc->client);
700 if (!ge->ui->handler_running)
701 pthread_create(&ge->ui->t, NULL, job_thread, ge->ui);
702 gfio_set_state(ge, GE_STATE_CONNECTED);
703 gfio_clear_graph_data(&ge->graphs);
705 gfio_report_error(ge, "Failed to connect to %s: %s\n", ge->client->client->hostname, strerror(-ret));
708 fio_client_terminate(gc->client);
709 gfio_set_state(ge, GE_STATE_NEW);
710 clear_ge_ui_info(ge);
714 static void send_clicked(GtkWidget *widget, gpointer data)
716 struct gui_entry *ge = data;
718 if (send_job_file(ge))
719 gtk_widget_set_sensitive(ge->button[GFIO_BUTTON_START], 1);
722 static GtkWidget *new_client_page(struct gui_entry *ge);
724 static struct gui_entry *alloc_new_gui_entry(struct gui *ui)
726 struct gui_entry *ge;
728 ge = malloc(sizeof(*ge));
729 memset(ge, 0, sizeof(*ge));
730 ge->state = GE_STATE_NEW;
735 static struct gui_entry *get_new_ge_with_tab(struct gui *ui, const char *name)
737 struct gui_entry *ge;
739 ge = alloc_new_gui_entry(ui);
741 ge->vbox = new_client_page(ge);
742 g_signal_connect(ge->vbox, "destroy", G_CALLBACK(ge_widget_destroy), ge);
744 ge->page_label = gtk_label_new(name);
745 ge->page_num = gtk_notebook_append_page(GTK_NOTEBOOK(ui->notebook), ge->vbox, ge->page_label);
747 g_hash_table_insert(ui->ge_hash, &ge->page_num, ge);
749 gtk_widget_show_all(ui->window);
753 static void file_new(GtkWidget *w, gpointer data)
755 struct gui *ui = (struct gui *) data;
756 struct gui_entry *ge;
758 ge = get_new_ge_with_tab(ui, "Untitled");
759 gtk_notebook_set_current_page(GTK_NOTEBOOK(ui->notebook), ge->page_num);
763 * Return the 'ge' corresponding to the tab. If the active tab is the
764 * main tab, open a new tab.
766 static struct gui_entry *get_ge_from_page(struct gui *ui, gint cur_page,
772 return get_new_ge_with_tab(ui, "Untitled");
778 return g_hash_table_lookup(ui->ge_hash, &cur_page);
781 static struct gui_entry *get_ge_from_cur_tab(struct gui *ui)
786 * Main tab is tab 0, so any current page other than 0 holds
789 cur_page = gtk_notebook_get_current_page(GTK_NOTEBOOK(ui->notebook));
791 return get_ge_from_page(ui, cur_page, NULL);
796 static void file_close(GtkWidget *w, gpointer data)
798 struct gui *ui = (struct gui *) data;
799 struct gui_entry *ge;
802 * Can't close the main tab
804 ge = get_ge_from_cur_tab(ui);
806 gtk_widget_destroy(ge->vbox);
810 if (g_hash_table_size(ui->ge_hash)) {
811 gfio_report_info(ui, "Error", "The main page view cannot be closed\n");
818 static void file_add_recent(struct gui *ui, const gchar *uri)
822 memset(&grd, 0, sizeof(grd));
823 grd.display_name = strdup("gfio");
824 grd.description = strdup("Fio job file");
825 grd.mime_type = strdup(GFIO_MIME);
826 grd.app_name = strdup(g_get_application_name());
827 grd.app_exec = strdup("gfio %f/%u");
829 gtk_recent_manager_add_full(ui->recentmanager, uri, &grd);
832 static gchar *get_filename_from_uri(const gchar *uri)
834 if (strncmp(uri, "file://", 7))
837 return strdup(uri + 7);
840 static int do_file_open(struct gui_entry *ge, const gchar *uri)
842 struct fio_client *client;
844 assert(!ge->job_file);
846 ge->job_file = get_filename_from_uri(uri);
848 client = fio_client_add_explicit(&gfio_client_ops, ge->host, ge->type, ge->port);
850 char *label = strdup(uri);
853 gtk_label_set_text(GTK_LABEL(ge->page_label), basename(label));
856 gfio_client_added(ge, client);
857 file_add_recent(ge->ui, uri);
861 gfio_report_error(ge, "Failed to add client %s\n", ge->host);
869 static int do_file_open_with_tab(struct gui *ui, const gchar *uri)
871 struct gui_entry *ge;
873 int ret, ge_is_new = 0;
876 * Creates new tab if current tab is the main window, or the
877 * current tab already has a client.
879 cur_page = gtk_notebook_get_current_page(GTK_NOTEBOOK(ui->notebook));
880 ge = get_ge_from_page(ui, cur_page, &ge_is_new);
882 ge = get_new_ge_with_tab(ui, "Untitled");
886 gtk_notebook_set_current_page(GTK_NOTEBOOK(ui->notebook), ge->page_num);
888 if (get_connection_details(ge)) {
890 gtk_widget_destroy(ge->vbox);
895 ret = do_file_open(ge, uri);
898 if (ge->server_start)
899 gfio_start_server(ui);
902 gtk_widget_destroy(ge->vbox);
908 static void recent_open(GtkAction *action, gpointer data)
910 struct gui *ui = (struct gui *) data;
914 info = g_object_get_data(G_OBJECT(action), "gtk-recent-info");
915 uri = gtk_recent_info_get_uri(info);
917 do_file_open_with_tab(ui, uri);
920 static void file_open(GtkWidget *w, gpointer data)
922 struct gui *ui = data;
924 GtkFileFilter *filter;
927 dialog = gtk_file_chooser_dialog_new("Open File",
928 GTK_WINDOW(ui->window),
929 GTK_FILE_CHOOSER_ACTION_OPEN,
930 GTK_STOCK_CANCEL, GTK_RESPONSE_CANCEL,
931 GTK_STOCK_OPEN, GTK_RESPONSE_ACCEPT,
933 gtk_file_chooser_set_select_multiple(GTK_FILE_CHOOSER(dialog), FALSE);
935 filter = gtk_file_filter_new();
936 gtk_file_filter_add_pattern(filter, "*.fio");
937 gtk_file_filter_add_pattern(filter, "*.job");
938 gtk_file_filter_add_pattern(filter, "*.ini");
939 gtk_file_filter_add_mime_type(filter, GFIO_MIME);
940 gtk_file_filter_set_name(filter, "Fio job file");
941 gtk_file_chooser_set_filter(GTK_FILE_CHOOSER(dialog), filter);
943 if (gtk_dialog_run(GTK_DIALOG(dialog)) != GTK_RESPONSE_ACCEPT) {
944 gtk_widget_destroy(dialog);
948 filename = gtk_file_chooser_get_filename(GTK_FILE_CHOOSER(dialog));
950 gtk_widget_destroy(dialog);
952 do_file_open_with_tab(ui, filename);
956 static void file_save(GtkWidget *w, gpointer data)
958 struct gui *ui = data;
961 dialog = gtk_file_chooser_dialog_new("Save File",
962 GTK_WINDOW(ui->window),
963 GTK_FILE_CHOOSER_ACTION_SAVE,
964 GTK_STOCK_CANCEL, GTK_RESPONSE_CANCEL,
965 GTK_STOCK_SAVE, GTK_RESPONSE_ACCEPT,
968 gtk_file_chooser_set_do_overwrite_confirmation(GTK_FILE_CHOOSER(dialog), TRUE);
969 gtk_file_chooser_set_current_name(GTK_FILE_CHOOSER(dialog), "Untitled document");
971 if (gtk_dialog_run(GTK_DIALOG(dialog)) == GTK_RESPONSE_ACCEPT) {
974 filename = gtk_file_chooser_get_filename(GTK_FILE_CHOOSER(dialog));
975 // save_job_file(filename);
978 gtk_widget_destroy(dialog);
981 static void view_log_destroy(GtkWidget *w, gpointer data)
983 struct gui *ui = (struct gui *) data;
985 g_object_ref(G_OBJECT(ui->log_tree));
986 gtk_container_remove(GTK_CONTAINER(w), ui->log_tree);
987 gtk_widget_destroy(w);
991 void gfio_view_log(struct gui *ui)
993 GtkWidget *win, *scroll, *vbox, *box;
998 ui->log_view = win = gtk_window_new(GTK_WINDOW_TOPLEVEL);
999 gtk_window_set_title(GTK_WINDOW(win), "Log");
1000 gtk_window_set_default_size(GTK_WINDOW(win), 700, 500);
1002 scroll = gtk_scrolled_window_new(NULL, NULL);
1004 gtk_container_set_border_width(GTK_CONTAINER(scroll), 5);
1006 gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(scroll), GTK_POLICY_AUTOMATIC, GTK_POLICY_AUTOMATIC);
1008 box = gtk_hbox_new(TRUE, 0);
1009 gtk_box_pack_start(GTK_BOX(box), ui->log_tree, TRUE, TRUE, 0);
1010 g_signal_connect(box, "destroy", G_CALLBACK(view_log_destroy), ui);
1011 gtk_scrolled_window_add_with_viewport(GTK_SCROLLED_WINDOW(scroll), box);
1013 vbox = gtk_vbox_new(TRUE, 5);
1014 gtk_box_pack_start(GTK_BOX(vbox), scroll, TRUE, TRUE, 0);
1016 gtk_container_add(GTK_CONTAINER(win), vbox);
1017 gtk_widget_show_all(win);
1020 static void view_log(GtkWidget *w, gpointer data)
1022 struct gui *ui = (struct gui *) data;
1027 static void connect_job_entry(GtkWidget *w, gpointer data)
1029 struct gui *ui = (struct gui *) data;
1030 struct gui_entry *ge;
1032 ge = get_ge_from_cur_tab(ui);
1034 connect_clicked(w, ge);
1037 static void send_job_entry(GtkWidget *w, gpointer data)
1039 struct gui *ui = (struct gui *) data;
1040 struct gui_entry *ge;
1042 ge = get_ge_from_cur_tab(ui);
1044 send_clicked(w, ge);
1047 static void edit_job_entry(GtkWidget *w, gpointer data)
1049 struct gui *ui = (struct gui *) data;
1050 struct gui_entry *ge;
1052 ge = get_ge_from_cur_tab(ui);
1053 if (ge && ge->client)
1054 gopt_get_options_window(ui->window, ge->client);
1057 static void start_job_entry(GtkWidget *w, gpointer data)
1059 struct gui *ui = (struct gui *) data;
1060 struct gui_entry *ge;
1062 ge = get_ge_from_cur_tab(ui);
1064 start_job_clicked(w, ge);
1067 static void view_results(GtkWidget *w, gpointer data)
1069 struct gui *ui = (struct gui *) data;
1070 struct gfio_client *gc;
1071 struct gui_entry *ge;
1073 ge = get_ge_from_cur_tab(ui);
1077 if (ge->results_window)
1081 if (gc && gc->nr_results)
1082 gfio_display_end_results(gc);
1085 static void __update_graph_settings(struct gfio_graphs *g)
1087 line_graph_set_data_count_limit(g->iops_graph, gfio_graph_limit);
1088 graph_set_font(g->iops_graph, gfio_graph_font);
1089 line_graph_set_data_count_limit(g->bandwidth_graph, gfio_graph_limit);
1090 graph_set_font(g->bandwidth_graph, gfio_graph_font);
1093 static void ge_update_settings_fn(gpointer key, gpointer value, gpointer data)
1095 struct gui_entry *ge = (struct gui_entry *) value;
1098 __update_graph_settings(&ge->graphs);
1100 ev = gdk_event_new(GDK_EXPOSE);
1101 g_signal_emit_by_name(G_OBJECT(ge->graphs.drawing_area), GFIO_DRAW_EVENT, GTK_WIDGET(ge->graphs.drawing_area), ev, &ge->graphs);
1105 static void update_graph_limits(void)
1107 struct gui *ui = &main_ui;
1110 __update_graph_settings(&ui->graphs);
1112 ev = gdk_event_new(GDK_EXPOSE);
1113 g_signal_emit_by_name(G_OBJECT(ui->graphs.drawing_area), GFIO_DRAW_EVENT, GTK_WIDGET(ui->graphs.drawing_area), ev, &ui->graphs);
1116 g_hash_table_foreach(ui->ge_hash, ge_update_settings_fn, NULL);
1119 static void preferences(GtkWidget *w, gpointer data)
1121 GtkWidget *dialog, *frame, *box, **buttons, *vbox, *font;
1122 GtkWidget *hbox, *spin, *entry, *spin_int;
1123 struct gui *ui = (struct gui *) data;
1126 dialog = gtk_dialog_new_with_buttons("Preferences",
1127 GTK_WINDOW(ui->window),
1128 GTK_DIALOG_DESTROY_WITH_PARENT,
1129 GTK_STOCK_OK, GTK_RESPONSE_ACCEPT,
1130 GTK_STOCK_CANCEL, GTK_RESPONSE_REJECT,
1133 frame = gtk_frame_new("Graphing");
1134 vbox = gtk_dialog_get_content_area(GTK_DIALOG(dialog));
1135 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
1136 vbox = gtk_vbox_new(FALSE, 6);
1137 gtk_container_add(GTK_CONTAINER(frame), vbox);
1139 hbox = gtk_hbox_new(FALSE, 5);
1140 gtk_box_pack_start(GTK_BOX(vbox), hbox, FALSE, FALSE, 5);
1141 entry = gtk_label_new("Font face to use for graph labels");
1142 gtk_box_pack_start(GTK_BOX(hbox), entry, TRUE, TRUE, 5);
1144 font = gtk_font_button_new_with_font(gfio_graph_font);
1145 gtk_box_pack_start(GTK_BOX(hbox), font, FALSE, FALSE, 5);
1147 box = gtk_vbox_new(FALSE, 6);
1148 gtk_box_pack_start(GTK_BOX(vbox), box, FALSE, FALSE, 5);
1150 hbox = gtk_hbox_new(FALSE, 5);
1151 gtk_box_pack_start(GTK_BOX(box), hbox, TRUE, TRUE, 5);
1152 entry = gtk_label_new("Maximum number of data points in graph (seconds)");
1153 gtk_box_pack_start(GTK_BOX(hbox), entry, FALSE, FALSE, 5);
1155 spin = create_spinbutton(hbox, 10, 1000000, gfio_graph_limit);
1157 box = gtk_vbox_new(FALSE, 6);
1158 gtk_box_pack_start(GTK_BOX(vbox), box, FALSE, FALSE, 5);
1160 hbox = gtk_hbox_new(FALSE, 5);
1161 gtk_box_pack_start(GTK_BOX(box), hbox, TRUE, TRUE, 5);
1162 entry = gtk_label_new("Client ETA request interval (msec)");
1163 gtk_box_pack_start(GTK_BOX(hbox), entry, FALSE, FALSE, 5);
1165 spin_int = create_spinbutton(hbox, 100, 100000, gfio_client_ops.eta_msec);
1166 frame = gtk_frame_new("Debug logging");
1167 vbox = gtk_dialog_get_content_area(GTK_DIALOG(dialog));
1168 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
1169 vbox = gtk_vbox_new(FALSE, 6);
1170 gtk_container_add(GTK_CONTAINER(frame), vbox);
1172 box = gtk_hbox_new(FALSE, 6);
1173 gtk_container_add(GTK_CONTAINER(vbox), box);
1175 buttons = malloc(sizeof(GtkWidget *) * FD_DEBUG_MAX);
1177 for (i = 0; i < FD_DEBUG_MAX; i++) {
1179 box = gtk_hbox_new(FALSE, 6);
1180 gtk_container_add(GTK_CONTAINER(vbox), box);
1184 buttons[i] = gtk_check_button_new_with_label(debug_levels[i].name);
1185 gtk_widget_set_tooltip_text(buttons[i], debug_levels[i].help);
1186 gtk_box_pack_start(GTK_BOX(box), buttons[i], FALSE, FALSE, 6);
1189 gtk_widget_show_all(dialog);
1191 if (gtk_dialog_run(GTK_DIALOG(dialog)) != GTK_RESPONSE_ACCEPT) {
1192 gtk_widget_destroy(dialog);
1196 for (i = 0; i < FD_DEBUG_MAX; i++) {
1199 set = gtk_toggle_button_get_active(GTK_TOGGLE_BUTTON(buttons[i]));
1201 fio_debug |= (1UL << i);
1204 gfio_graph_font = strdup(gtk_font_button_get_font_name(GTK_FONT_BUTTON(font)));
1205 gfio_graph_limit = gtk_spin_button_get_value_as_int(GTK_SPIN_BUTTON(spin));
1206 update_graph_limits();
1207 gfio_client_ops.eta_msec = gtk_spin_button_get_value_as_int(GTK_SPIN_BUTTON(spin_int));
1209 gtk_widget_destroy(dialog);
1212 static void about_dialog(GtkWidget *w, gpointer data)
1214 const char *authors[] = {
1215 "Jens Axboe <axboe@kernel.dk>",
1216 "Stephen Carmeron <stephenmcameron@gmail.com>",
1219 const char *license[] = {
1220 "Fio is free software; you can redistribute it and/or modify "
1221 "it under the terms of the GNU General Public License as published by "
1222 "the Free Software Foundation; either version 2 of the License, or "
1223 "(at your option) any later version.\n",
1224 "Fio is distributed in the hope that it will be useful, "
1225 "but WITHOUT ANY WARRANTY; without even the implied warranty of "
1226 "MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the "
1227 "GNU General Public License for more details.\n",
1228 "You should have received a copy of the GNU General Public License "
1229 "along with Fio; if not, write to the Free Software Foundation, Inc., "
1230 "51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA\n"
1232 char *license_trans;
1234 license_trans = g_strconcat(license[0], "\n", license[1], "\n",
1235 license[2], "\n", NULL);
1237 gtk_show_about_dialog(NULL,
1238 "program-name", "gfio",
1239 "comments", "Gtk2 UI for fio",
1240 "license", license_trans,
1241 "website", "http://git.kernel.dk/?p=fio.git;a=summary",
1243 "version", fio_version_string,
1244 "copyright", "© 2012 Jens Axboe <axboe@kernel.dk>",
1245 "logo-icon-name", "fio",
1247 "wrap-license", TRUE,
1250 g_free(license_trans);
1253 static GtkActionEntry menu_items[] = {
1254 { "FileMenuAction", GTK_STOCK_FILE, "File", NULL, NULL, NULL},
1255 { "ViewMenuAction", GTK_STOCK_FILE, "View", NULL, NULL, NULL},
1256 { "JobMenuAction", GTK_STOCK_FILE, "Job", NULL, NULL, NULL},
1257 { "HelpMenuAction", GTK_STOCK_HELP, "Help", NULL, NULL, NULL},
1258 { "NewFile", GTK_STOCK_NEW, "New", "<Control>N", NULL, G_CALLBACK(file_new) },
1259 { "CloseFile", GTK_STOCK_CLOSE, "Close", "<Control>W", NULL, G_CALLBACK(file_close) },
1260 { "OpenFile", GTK_STOCK_OPEN, NULL, "<Control>O", NULL, G_CALLBACK(file_open) },
1261 { "SaveFile", GTK_STOCK_SAVE, NULL, "<Control>S", NULL, G_CALLBACK(file_save) },
1262 { "Preferences", GTK_STOCK_PREFERENCES, NULL, "<Control>p", NULL, G_CALLBACK(preferences) },
1263 { "ViewLog", NULL, "Log", "<Control>l", NULL, G_CALLBACK(view_log) },
1264 { "ViewResults", NULL, "Results", "<Control>R", NULL, G_CALLBACK(view_results) },
1265 { "ConnectJob", NULL, "Connect", "<Control>D", NULL, G_CALLBACK(connect_job_entry) },
1266 { "EditJob", NULL, "Edit job", "<Control>E", NULL, G_CALLBACK(edit_job_entry) },
1267 { "SendJob", NULL, "Send job", "<Control>X", NULL, G_CALLBACK(send_job_entry) },
1268 { "StartJob", NULL, "Start job", "<Control>L", NULL, G_CALLBACK(start_job_entry) },
1269 { "Quit", GTK_STOCK_QUIT, NULL, "<Control>Q", NULL, G_CALLBACK(quit_clicked) },
1270 { "About", GTK_STOCK_ABOUT, NULL, NULL, NULL, G_CALLBACK(about_dialog) },
1272 static gint nmenu_items = sizeof(menu_items) / sizeof(menu_items[0]);
1274 static const gchar *ui_string = " \
1276 <menubar name=\"MainMenu\"> \
1277 <menu name=\"FileMenu\" action=\"FileMenuAction\"> \
1278 <menuitem name=\"New\" action=\"NewFile\" /> \
1279 <menuitem name=\"Open\" action=\"OpenFile\" /> \
1280 <menuitem name=\"Close\" action=\"CloseFile\" /> \
1281 <separator name=\"Separator1\"/> \
1282 <menuitem name=\"Save\" action=\"SaveFile\" /> \
1283 <separator name=\"Separator2\"/> \
1284 <menuitem name=\"Preferences\" action=\"Preferences\" /> \
1285 <separator name=\"Separator3\"/> \
1286 <placeholder name=\"FileRecentFiles\"/> \
1287 <separator name=\"Separator4\"/> \
1288 <menuitem name=\"Quit\" action=\"Quit\" /> \
1290 <menu name=\"JobMenu\" action=\"JobMenuAction\"> \
1291 <menuitem name=\"Connect\" action=\"ConnectJob\" /> \
1292 <separator name=\"Separator5\"/> \
1293 <menuitem name=\"Edit job\" action=\"EditJob\" /> \
1294 <menuitem name=\"Send job\" action=\"SendJob\" /> \
1295 <separator name=\"Separator6\"/> \
1296 <menuitem name=\"Start job\" action=\"StartJob\" /> \
1298 <menu name=\"ViewMenu\" action=\"ViewMenuAction\"> \
1299 <menuitem name=\"Results\" action=\"ViewResults\" /> \
1300 <separator name=\"Separator7\"/> \
1301 <menuitem name=\"Log\" action=\"ViewLog\" /> \
1303 <menu name=\"Help\" action=\"HelpMenuAction\"> \
1304 <menuitem name=\"About\" action=\"About\" /> \
1310 static GtkWidget *get_menubar_menu(GtkWidget *window, GtkUIManager *ui_manager,
1313 GtkActionGroup *action_group;
1316 action_group = gtk_action_group_new("Menu");
1317 gtk_action_group_add_actions(action_group, menu_items, nmenu_items, ui);
1319 gtk_ui_manager_insert_action_group(ui_manager, action_group, 0);
1320 gtk_ui_manager_add_ui_from_string(GTK_UI_MANAGER(ui_manager), ui_string, -1, &error);
1322 gtk_window_add_accel_group(GTK_WINDOW(window), gtk_ui_manager_get_accel_group(ui_manager));
1324 return gtk_ui_manager_get_widget(ui_manager, "/MainMenu");
1327 void gfio_ui_setup(GtkSettings *settings, GtkWidget *menubar,
1328 GtkWidget *vbox, GtkUIManager *ui_manager)
1330 gtk_box_pack_start(GTK_BOX(vbox), menubar, FALSE, FALSE, 0);
1333 static void combo_entry_changed(GtkComboBox *box, gpointer data)
1335 struct gui_entry *ge = (struct gui_entry *) data;
1338 index = gtk_combo_box_get_active(box);
1340 multitext_set_entry(&ge->eta.iotype, index);
1341 multitext_set_entry(&ge->eta.bs, index);
1342 multitext_set_entry(&ge->eta.ioengine, index);
1343 multitext_set_entry(&ge->eta.iodepth, index);
1346 static void combo_entry_destroy(GtkWidget *widget, gpointer data)
1348 struct gui_entry *ge = (struct gui_entry *) data;
1350 multitext_free(&ge->eta.iotype);
1351 multitext_free(&ge->eta.bs);
1352 multitext_free(&ge->eta.ioengine);
1353 multitext_free(&ge->eta.iodepth);
1356 static GtkWidget *new_client_page(struct gui_entry *ge)
1358 GtkWidget *main_vbox, *probe, *probe_frame, *probe_box;
1359 GtkWidget *scrolled_window, *bottom_align, *top_align, *top_vbox;
1361 main_vbox = gtk_vbox_new(FALSE, 3);
1363 top_align = gtk_alignment_new(0, 0, 1, 0);
1364 top_vbox = gtk_vbox_new(FALSE, 3);
1365 gtk_container_add(GTK_CONTAINER(top_align), top_vbox);
1366 gtk_box_pack_start(GTK_BOX(main_vbox), top_align, FALSE, FALSE, 0);
1368 probe = gtk_frame_new("Job");
1369 gtk_box_pack_start(GTK_BOX(main_vbox), probe, FALSE, FALSE, 3);
1370 probe_frame = gtk_vbox_new(FALSE, 3);
1371 gtk_container_add(GTK_CONTAINER(probe), probe_frame);
1373 probe_box = gtk_hbox_new(FALSE, 3);
1374 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, FALSE, FALSE, 3);
1375 ge->probe.hostname = new_info_label_in_frame(probe_box, "Host");
1376 ge->probe.os = new_info_label_in_frame(probe_box, "OS");
1377 ge->probe.arch = new_info_label_in_frame(probe_box, "Architecture");
1378 ge->probe.fio_ver = new_info_label_in_frame(probe_box, "Fio version");
1380 probe_box = gtk_hbox_new(FALSE, 3);
1381 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, FALSE, FALSE, 3);
1383 ge->eta.names = new_combo_entry_in_frame(probe_box, "Jobs");
1384 g_signal_connect(ge->eta.names, "changed", G_CALLBACK(combo_entry_changed), ge);
1385 g_signal_connect(ge->eta.names, "destroy", G_CALLBACK(combo_entry_destroy), ge);
1386 ge->eta.iotype.entry = new_info_entry_in_frame(probe_box, "IO");
1387 ge->eta.bs.entry = new_info_entry_in_frame(probe_box, "Blocksize (Read/Write)");
1388 ge->eta.ioengine.entry = new_info_entry_in_frame(probe_box, "IO Engine");
1389 ge->eta.iodepth.entry = new_info_entry_in_frame(probe_box, "IO Depth");
1390 ge->eta.jobs = new_info_entry_in_frame(probe_box, "Jobs");
1391 ge->eta.files = new_info_entry_in_frame(probe_box, "Open files");
1393 probe_box = gtk_hbox_new(FALSE, 3);
1394 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, FALSE, FALSE, 3);
1395 ge->eta.read_bw = new_info_entry_in_frame_rgb(probe_box, "Read BW", GFIO_READ_R, GFIO_READ_G, GFIO_READ_B);
1396 ge->eta.read_iops = new_info_entry_in_frame_rgb(probe_box, "IOPS", GFIO_READ_R, GFIO_READ_G, GFIO_READ_B);
1397 ge->eta.write_bw = new_info_entry_in_frame_rgb(probe_box, "Write BW", GFIO_WRITE_R, GFIO_WRITE_G, GFIO_WRITE_B);
1398 ge->eta.write_iops = new_info_entry_in_frame_rgb(probe_box, "IOPS", GFIO_WRITE_R, GFIO_WRITE_G, GFIO_WRITE_B);
1399 ge->eta.trim_bw = new_info_entry_in_frame_rgb(probe_box, "Trim BW", GFIO_TRIM_R, GFIO_TRIM_G, GFIO_TRIM_B);
1400 ge->eta.trim_iops = new_info_entry_in_frame_rgb(probe_box, "IOPS", GFIO_TRIM_R, GFIO_TRIM_G, GFIO_TRIM_B);
1403 * Only add this if we have a commit rate
1406 probe_box = gtk_hbox_new(FALSE, 3);
1407 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, TRUE, FALSE, 3);
1409 ge->eta.cr_bw = new_info_label_in_frame(probe_box, "Commit BW");
1410 ge->eta.cr_iops = new_info_label_in_frame(probe_box, "Commit IOPS");
1412 ge->eta.cw_bw = new_info_label_in_frame(probe_box, "Commit BW");
1413 ge->eta.cw_iops = new_info_label_in_frame(probe_box, "Commit IOPS");
1417 * Set up a drawing area and IOPS and bandwidth graphs
1419 ge->graphs.drawing_area = gtk_drawing_area_new();
1420 gtk_widget_set_size_request(GTK_WIDGET(ge->graphs.drawing_area),
1421 DRAWING_AREA_XDIM, DRAWING_AREA_YDIM);
1422 gtk_widget_modify_bg(ge->graphs.drawing_area, GTK_STATE_NORMAL, &gfio_color_lightyellow);
1423 g_signal_connect(G_OBJECT(ge->graphs.drawing_area), GFIO_DRAW_EVENT,
1424 G_CALLBACK(on_expose_drawing_area), &ge->graphs);
1425 g_signal_connect(G_OBJECT(ge->graphs.drawing_area), "configure_event",
1426 G_CALLBACK(on_config_drawing_area), &ge->graphs);
1427 scrolled_window = gtk_scrolled_window_new(NULL, NULL);
1428 gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(scrolled_window),
1429 GTK_POLICY_AUTOMATIC, GTK_POLICY_AUTOMATIC);
1430 gtk_scrolled_window_add_with_viewport(GTK_SCROLLED_WINDOW(scrolled_window),
1431 ge->graphs.drawing_area);
1432 gtk_box_pack_start(GTK_BOX(main_vbox), scrolled_window, TRUE, TRUE, 0);
1434 setup_graphs(&ge->graphs);
1437 * Set up alignments for widgets at the bottom of ui,
1438 * align bottom left, expand horizontally but not vertically
1440 bottom_align = gtk_alignment_new(0, 1, 1, 0);
1441 ge->buttonbox = gtk_hbox_new(FALSE, 0);
1442 gtk_container_add(GTK_CONTAINER(bottom_align), ge->buttonbox);
1443 gtk_box_pack_start(GTK_BOX(main_vbox), bottom_align, FALSE, FALSE, 0);
1445 add_buttons(ge, buttonspeclist, ARRAY_SIZE(buttonspeclist));
1448 * Set up thread status progress bar
1450 ge->thread_status_pb = gtk_progress_bar_new();
1451 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(ge->thread_status_pb), 0.0);
1452 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(ge->thread_status_pb), "No connections");
1453 gtk_container_add(GTK_CONTAINER(ge->buttonbox), ge->thread_status_pb);
1459 static GtkWidget *new_main_page(struct gui *ui)
1461 GtkWidget *main_vbox, *probe, *probe_frame, *probe_box;
1462 GtkWidget *scrolled_window, *bottom_align, *top_align, *top_vbox;
1464 main_vbox = gtk_vbox_new(FALSE, 3);
1467 * Set up alignments for widgets at the top of ui,
1468 * align top left, expand horizontally but not vertically
1470 top_align = gtk_alignment_new(0, 0, 1, 0);
1471 top_vbox = gtk_vbox_new(FALSE, 0);
1472 gtk_container_add(GTK_CONTAINER(top_align), top_vbox);
1473 gtk_box_pack_start(GTK_BOX(main_vbox), top_align, FALSE, FALSE, 0);
1475 probe = gtk_frame_new("Run statistics");
1476 gtk_box_pack_start(GTK_BOX(main_vbox), probe, FALSE, FALSE, 3);
1477 probe_frame = gtk_vbox_new(FALSE, 3);
1478 gtk_container_add(GTK_CONTAINER(probe), probe_frame);
1480 probe_box = gtk_hbox_new(FALSE, 3);
1481 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, FALSE, FALSE, 3);
1482 ui->eta.jobs = new_info_entry_in_frame(probe_box, "Running");
1483 ui->eta.read_bw = new_info_entry_in_frame_rgb(probe_box, "Read BW", GFIO_READ_R, GFIO_READ_G, GFIO_READ_B);
1484 ui->eta.read_iops = new_info_entry_in_frame_rgb(probe_box, "IOPS", GFIO_READ_R, GFIO_READ_G, GFIO_READ_B);
1485 ui->eta.write_bw = new_info_entry_in_frame_rgb(probe_box, "Write BW", GFIO_WRITE_R, GFIO_WRITE_G, GFIO_WRITE_B);
1486 ui->eta.write_iops = new_info_entry_in_frame_rgb(probe_box, "IOPS", GFIO_WRITE_R, GFIO_WRITE_G, GFIO_WRITE_B);
1487 ui->eta.trim_bw = new_info_entry_in_frame_rgb(probe_box, "Trim BW", GFIO_TRIM_R, GFIO_TRIM_G, GFIO_TRIM_B);
1488 ui->eta.trim_iops = new_info_entry_in_frame_rgb(probe_box, "IOPS", GFIO_TRIM_R, GFIO_TRIM_G, GFIO_TRIM_B);
1491 * Only add this if we have a commit rate
1494 probe_box = gtk_hbox_new(FALSE, 3);
1495 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, TRUE, FALSE, 3);
1497 ui->eta.cr_bw = new_info_label_in_frame(probe_box, "Commit BW");
1498 ui->eta.cr_iops = new_info_label_in_frame(probe_box, "Commit IOPS");
1500 ui->eta.cw_bw = new_info_label_in_frame(probe_box, "Commit BW");
1501 ui->eta.cw_iops = new_info_label_in_frame(probe_box, "Commit IOPS");
1505 * Set up a drawing area and IOPS and bandwidth graphs
1507 ui->graphs.drawing_area = gtk_drawing_area_new();
1508 gtk_widget_set_size_request(GTK_WIDGET(ui->graphs.drawing_area),
1509 DRAWING_AREA_XDIM, DRAWING_AREA_YDIM);
1510 gtk_widget_modify_bg(ui->graphs.drawing_area, GTK_STATE_NORMAL, &gfio_color_lightyellow);
1511 g_signal_connect(G_OBJECT(ui->graphs.drawing_area), GFIO_DRAW_EVENT,
1512 G_CALLBACK(on_expose_drawing_area), &ui->graphs);
1513 g_signal_connect(G_OBJECT(ui->graphs.drawing_area), "configure_event",
1514 G_CALLBACK(on_config_drawing_area), &ui->graphs);
1515 scrolled_window = gtk_scrolled_window_new(NULL, NULL);
1516 gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(scrolled_window),
1517 GTK_POLICY_AUTOMATIC, GTK_POLICY_AUTOMATIC);
1518 gtk_scrolled_window_add_with_viewport(GTK_SCROLLED_WINDOW(scrolled_window),
1519 ui->graphs.drawing_area);
1520 gtk_box_pack_start(GTK_BOX(main_vbox), scrolled_window,
1523 setup_graphs(&ui->graphs);
1526 * Set up alignments for widgets at the bottom of ui,
1527 * align bottom left, expand horizontally but not vertically
1529 bottom_align = gtk_alignment_new(0, 1, 1, 0);
1530 ui->buttonbox = gtk_hbox_new(FALSE, 0);
1531 gtk_container_add(GTK_CONTAINER(bottom_align), ui->buttonbox);
1532 gtk_box_pack_start(GTK_BOX(main_vbox), bottom_align, FALSE, FALSE, 0);
1535 * Set up thread status progress bar
1537 ui->thread_status_pb = gtk_progress_bar_new();
1538 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(ui->thread_status_pb), 0.0);
1539 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(ui->thread_status_pb), "No connections");
1540 gtk_container_add(GTK_CONTAINER(ui->buttonbox), ui->thread_status_pb);
1545 static gboolean notebook_switch_page(GtkNotebook *notebook, GtkWidget *widget,
1546 guint page, gpointer data)
1549 struct gui *ui = (struct gui *) data;
1550 struct gui_entry *ge;
1553 set_job_menu_visible(ui, 0);
1554 set_view_results_visible(ui, 0);
1558 set_job_menu_visible(ui, 1);
1559 ge = get_ge_from_page(ui, page, NULL);
1561 update_button_states(ui, ge);
1566 static gint compare_recent_items(GtkRecentInfo *a, GtkRecentInfo *b)
1568 time_t time_a = gtk_recent_info_get_visited(a);
1569 time_t time_b = gtk_recent_info_get_visited(b);
1571 return time_b - time_a;
1574 static void add_recent_file_items(struct gui *ui)
1576 const gchar *gfio = g_get_application_name();
1577 GList *items, *item;
1580 if (ui->recent_ui_id) {
1581 gtk_ui_manager_remove_ui(ui->uimanager, ui->recent_ui_id);
1582 gtk_ui_manager_ensure_update(ui->uimanager);
1584 ui->recent_ui_id = gtk_ui_manager_new_merge_id(ui->uimanager);
1586 if (ui->actiongroup) {
1587 gtk_ui_manager_remove_action_group(ui->uimanager, ui->actiongroup);
1588 g_object_unref(ui->actiongroup);
1590 ui->actiongroup = gtk_action_group_new("RecentFileActions");
1592 gtk_ui_manager_insert_action_group(ui->uimanager, ui->actiongroup, -1);
1594 items = gtk_recent_manager_get_items(ui->recentmanager);
1595 items = g_list_sort(items, (GCompareFunc) compare_recent_items);
1597 for (item = items; item && item->data; item = g_list_next(item)) {
1598 GtkRecentInfo *info = (GtkRecentInfo *) item->data;
1603 if (!gtk_recent_info_has_application(info, gfio))
1607 * We only support local files for now
1609 if (!gtk_recent_info_is_local(info) || !gtk_recent_info_exists(info))
1612 action_name = g_strdup_printf("RecentFile%u", i++);
1613 label = gtk_recent_info_get_display_name(info);
1615 action = g_object_new(GTK_TYPE_ACTION,
1616 "name", action_name,
1617 "label", label, NULL);
1619 g_object_set_data_full(G_OBJECT(action), "gtk-recent-info",
1620 gtk_recent_info_ref(info),
1621 (GDestroyNotify) gtk_recent_info_unref);
1624 g_signal_connect(action, "activate", G_CALLBACK(recent_open), ui);
1626 gtk_action_group_add_action(ui->actiongroup, action);
1627 g_object_unref(action);
1629 gtk_ui_manager_add_ui(ui->uimanager, ui->recent_ui_id,
1630 "/MainMenu/FileMenu/FileRecentFiles",
1632 GTK_UI_MANAGER_MENUITEM, FALSE);
1634 g_free(action_name);
1640 g_list_foreach(items, (GFunc) gtk_recent_info_unref, NULL);
1644 static void drag_and_drop_received(GtkWidget *widget, GdkDragContext *ctx,
1645 gint x, gint y, GtkSelectionData *seldata,
1646 guint info, guint time, gpointer *data)
1648 struct gui *ui = (struct gui *) data;
1652 source = gtk_drag_get_source_widget(ctx);
1653 if (source && widget == gtk_widget_get_toplevel(source)) {
1654 gtk_drag_finish(ctx, FALSE, FALSE, time);
1658 uris = gtk_selection_data_get_uris(seldata);
1660 gtk_drag_finish(ctx, FALSE, FALSE, time);
1665 do_file_open_with_tab(ui, uris[0]);
1667 gtk_drag_finish(ctx, TRUE, FALSE, time);
1671 static void init_ui(int *argc, char **argv[], struct gui *ui)
1673 GtkSettings *settings;
1676 /* Magical g*thread incantation, you just need this thread stuff.
1677 * Without it, the update that happens in gfio_update_thread_status
1678 * doesn't really happen in a timely fashion, you need expose events
1680 #if !GTK_CHECK_VERSION(2, 24, 0)
1681 if (!g_thread_supported())
1682 g_thread_init(NULL);
1687 gtk_init(argc, argv);
1688 settings = gtk_settings_get_default();
1689 gtk_settings_set_long_property(settings, "gtk_tooltip_timeout", 10, "gfio setting");
1691 gdk_color_parse("#fffff4", &gfio_color_lightyellow);
1692 gdk_color_parse("white", &gfio_color_white);
1694 ui->window = gtk_window_new(GTK_WINDOW_TOPLEVEL);
1695 gtk_window_set_title(GTK_WINDOW(ui->window), "fio");
1696 gtk_window_set_default_size(GTK_WINDOW(ui->window), 1024, 768);
1698 g_signal_connect(ui->window, "delete-event", G_CALLBACK(quit_clicked), ui);
1699 g_signal_connect(ui->window, "destroy", G_CALLBACK(quit_clicked), ui);
1701 ui->vbox = gtk_vbox_new(FALSE, 0);
1702 gtk_container_add(GTK_CONTAINER(ui->window), ui->vbox);
1704 ui->uimanager = gtk_ui_manager_new();
1705 ui->menu = get_menubar_menu(ui->window, ui->uimanager, ui);
1706 gfio_ui_setup(settings, ui->menu, ui->vbox, ui->uimanager);
1708 ui->recentmanager = gtk_recent_manager_get_default();
1709 add_recent_file_items(ui);
1711 ui->notebook = gtk_notebook_new();
1712 g_signal_connect(ui->notebook, "switch-page", G_CALLBACK(notebook_switch_page), ui);
1713 gtk_notebook_set_scrollable(GTK_NOTEBOOK(ui->notebook), 1);
1714 gtk_notebook_popup_enable(GTK_NOTEBOOK(ui->notebook));
1715 gtk_container_add(GTK_CONTAINER(ui->vbox), ui->notebook);
1717 vbox = new_main_page(ui);
1718 gtk_drag_dest_set(GTK_WIDGET(ui->window), GTK_DEST_DEFAULT_ALL, NULL, 1, GDK_ACTION_COPY);
1719 gtk_drag_dest_add_uri_targets(GTK_WIDGET(ui->window));
1720 g_signal_connect(ui->window, "drag-data-received", G_CALLBACK(drag_and_drop_received), ui);
1722 gtk_notebook_append_page(GTK_NOTEBOOK(ui->notebook), vbox, gtk_label_new("Main"));
1724 gfio_ui_setup_log(ui);
1726 gtk_widget_show_all(ui->window);
1729 int main(int argc, char *argv[], char *envp[])
1731 if (initialize_fio(envp))
1733 if (fio_init_options())
1738 memset(&main_ui, 0, sizeof(main_ui));
1739 main_ui.ge_hash = g_hash_table_new(g_int_hash, g_int_equal);
1741 init_ui(&argc, &argv, &main_ui);
1743 gdk_threads_enter();
1745 gdk_threads_leave();
1747 g_hash_table_destroy(main_ui.ge_hash);