blob: d0418a4585212939d7a5bee68b227dfceb0fe509 [file] [log] [blame]
Stephen M. Cameronff1f3282012-02-24 08:17:30 +01001/*
2 * gfio - gui front end for fio - the flexible io tester
3 *
4 * Copyright (C) 2012 Stephen M. Cameron <stephenmcameron@gmail.com>
Jens Axboec0187f32012-03-06 15:39:15 +01005 * Copyright (C) 2012 Jens Axboe <axboe@kernel.dk>
Stephen M. Cameronff1f3282012-02-24 08:17:30 +01006 *
7 * The license below covers all files distributed with fio unless otherwise
8 * noted in the file itself.
9 *
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.
13 *
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.
18 *
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
22 *
23 */
Stephen M. Cameron8232e282012-02-24 08:17:31 +010024#include <locale.h>
Stephen M. Cameron60f6b332012-02-24 08:17:32 +010025#include <malloc.h>
Jens Axboe6b79c802012-03-08 10:51:36 +010026#include <string.h>
Stephen M. Cameron8232e282012-02-24 08:17:31 +010027
Stephen M. Cameron5b7573a2012-02-24 08:17:31 +010028#include <glib.h>
Jens Axboe2fd3bb02012-03-07 08:07:39 +010029#include <cairo.h>
Stephen M. Cameronff1f3282012-02-24 08:17:30 +010030#include <gtk/gtk.h>
31
Stephen M. Cameron8232e282012-02-24 08:17:31 +010032#include "fio.h"
Jens Axboe2fd3bb02012-03-07 08:07:39 +010033#include "graph.h"
Stephen M. Cameron8232e282012-02-24 08:17:31 +010034
Jens Axboe38634cb2012-03-13 12:26:41 +010035#define GFIO_MIME "text/fio"
36
Jens Axboe63a130b2012-03-06 20:08:59 +010037static int gfio_server_running;
Jens Axboef3e84402012-03-07 13:14:32 +010038static const char *gfio_graph_font;
Jens Axboe8577f4f2012-03-09 19:28:27 +010039static unsigned int gfio_graph_limit = 100;
Jens Axboe63a130b2012-03-06 20:08:59 +010040
Jens Axboe6b79c802012-03-08 10:51:36 +010041static void view_log(GtkWidget *w, gpointer data);
Jens Axboe3e47bd22012-02-29 13:45:02 +010042
Stephen M. Cameronf3074002012-02-24 08:17:30 +010043#define ARRAYSIZE(x) (sizeof((x)) / (sizeof((x)[0])))
44
45typedef void (*clickfunction)(GtkWidget *widget, gpointer data);
46
Jens Axboe3e47bd22012-02-29 13:45:02 +010047static void connect_clicked(GtkWidget *widget, gpointer data);
Stephen M. Cameronf3074002012-02-24 08:17:30 +010048static void start_job_clicked(GtkWidget *widget, gpointer data);
Jens Axboeb9d2f302012-03-08 20:36:28 +010049static void send_clicked(GtkWidget *widget, gpointer data);
Stephen M. Cameronf3074002012-02-24 08:17:30 +010050
51static struct button_spec {
52 const char *buttontext;
53 clickfunction f;
54 const char *tooltiptext;
Jens Axboe3e47bd22012-02-29 13:45:02 +010055 const int start_insensitive;
Stephen M. Cameronf3074002012-02-24 08:17:30 +010056} buttonspeclist[] = {
Jens Axboe3e47bd22012-02-29 13:45:02 +010057#define CONNECT_BUTTON 0
Jens Axboeb9d2f302012-03-08 20:36:28 +010058#define SEND_BUTTON 1
59#define START_JOB_BUTTON 2
Jens Axboe3e47bd22012-02-29 13:45:02 +010060 { "Connect", connect_clicked, "Connect to host", 0 },
Jens Axboeb9d2f302012-03-08 20:36:28 +010061 { "Send", send_clicked, "Send job description to host", 1 },
62 { "Start Job", start_job_clicked,
Jens Axboe2f99deb2012-03-09 14:37:29 +010063 "Start the current job on the server", 1 },
Stephen M. Cameronf3074002012-02-24 08:17:30 +010064};
65
Jens Axboe843ad232012-02-29 11:44:53 +010066struct probe_widget {
67 GtkWidget *hostname;
68 GtkWidget *os;
69 GtkWidget *arch;
70 GtkWidget *fio_ver;
71};
72
Jens Axboec80b74b2012-03-12 10:23:28 +010073struct multitext_widget {
74 GtkWidget *entry;
75 char **text;
76 unsigned int cur_text;
77 unsigned int max_text;
78};
79
Jens Axboe3e47bd22012-02-29 13:45:02 +010080struct eta_widget {
Jens Axboe3863d1a2012-03-09 17:39:05 +010081 GtkWidget *names;
Jens Axboec80b74b2012-03-12 10:23:28 +010082 struct multitext_widget iotype;
83 struct multitext_widget ioengine;
84 struct multitext_widget iodepth;
Jens Axboe3e47bd22012-02-29 13:45:02 +010085 GtkWidget *jobs;
86 GtkWidget *files;
87 GtkWidget *read_bw;
88 GtkWidget *read_iops;
89 GtkWidget *cr_bw;
90 GtkWidget *cr_iops;
91 GtkWidget *write_bw;
92 GtkWidget *write_iops;
93 GtkWidget *cw_bw;
94 GtkWidget *cw_iops;
95};
96
Jens Axboe2f99deb2012-03-09 14:37:29 +010097struct gfio_graphs {
98#define DRAWING_AREA_XDIM 1000
99#define DRAWING_AREA_YDIM 400
100 GtkWidget *drawing_area;
Jens Axboe2f99deb2012-03-09 14:37:29 +0100101 struct graph *iops_graph;
102 struct graph *bandwidth_graph;
103};
104
105/*
106 * Main window widgets and data
107 */
Stephen M. Cameronff1f3282012-02-24 08:17:30 +0100108struct gui {
Jens Axboe02421e62012-03-12 12:05:50 +0100109 GtkUIManager *uimanager;
Jens Axboe38634cb2012-03-13 12:26:41 +0100110 GtkRecentManager *recentmanager;
111 GtkActionGroup *actiongroup;
112 guint recent_ui_id;
Jens Axboe02421e62012-03-12 12:05:50 +0100113 GtkWidget *menu;
Stephen M. Cameronff1f3282012-02-24 08:17:30 +0100114 GtkWidget *window;
Stephen M. Cameron5b7573a2012-02-24 08:17:31 +0100115 GtkWidget *vbox;
Stephen M. Cameron04cc6b72012-02-24 08:17:31 +0100116 GtkWidget *thread_status_pb;
Stephen M. Cameronf3074002012-02-24 08:17:30 +0100117 GtkWidget *buttonbox;
Jens Axboe2f99deb2012-03-09 14:37:29 +0100118 GtkWidget *notebook;
119 GtkWidget *error_info_bar;
120 GtkWidget *error_label;
121 GtkListStore *log_model;
122 GtkWidget *log_tree;
123 GtkWidget *log_view;
124 struct gfio_graphs graphs;
125 struct probe_widget probe;
126 struct eta_widget eta;
127 pthread_t server_t;
128
Jens Axboea9eccde2012-03-09 14:59:42 +0100129 pthread_t t;
130 int handler_running;
131
Jens Axboe2f99deb2012-03-09 14:37:29 +0100132 struct flist_head list;
133} main_ui;
134
Jens Axboe85dd01e2012-03-12 14:33:16 +0100135enum {
136 GE_STATE_NEW = 1,
137 GE_STATE_CONNECTED,
138 GE_STATE_JOB_SENT,
139 GE_STATE_JOB_STARTED,
140 GE_STATE_JOB_RUNNING,
141 GE_STATE_JOB_DONE,
142};
143
Jens Axboe2f99deb2012-03-09 14:37:29 +0100144/*
145 * Notebook entry
146 */
147struct gui_entry {
148 struct flist_head list;
149 struct gui *ui;
150
151 GtkWidget *vbox;
Jens Axboec80b74b2012-03-12 10:23:28 +0100152 GtkWidget *job_notebook;
Jens Axboe2f99deb2012-03-09 14:37:29 +0100153 GtkWidget *thread_status_pb;
154 GtkWidget *buttonbox;
Stephen M. Cameronf3074002012-02-24 08:17:30 +0100155 GtkWidget *button[ARRAYSIZE(buttonspeclist)];
Jens Axboe2f99deb2012-03-09 14:37:29 +0100156 GtkWidget *notebook;
Jens Axboe0420ba62012-02-29 11:16:52 +0100157 GtkWidget *error_info_bar;
158 GtkWidget *error_label;
Jens Axboef9d40b42012-03-06 09:52:49 +0100159 GtkWidget *results_notebook;
160 GtkWidget *results_window;
Jens Axboe9b260bd2012-03-06 11:02:52 +0100161 GtkListStore *log_model;
162 GtkWidget *log_tree;
Jens Axboe4cbe7212012-03-06 13:36:17 +0100163 GtkWidget *log_view;
Jens Axboe2f99deb2012-03-09 14:37:29 +0100164 struct gfio_graphs graphs;
Jens Axboe843ad232012-02-29 11:44:53 +0100165 struct probe_widget probe;
Jens Axboe3e47bd22012-02-29 13:45:02 +0100166 struct eta_widget eta;
Jens Axboe2f99deb2012-03-09 14:37:29 +0100167 GtkWidget *page_label;
168 gint page_num;
Jens Axboe85dd01e2012-03-12 14:33:16 +0100169 unsigned int state;
Jens Axboe0420ba62012-02-29 11:16:52 +0100170
Jens Axboeb9d2f302012-03-08 20:36:28 +0100171 struct gfio_client *client;
Jens Axboe0420ba62012-02-29 11:16:52 +0100172 int nr_job_files;
173 char **job_files;
Jens Axboe2f99deb2012-03-09 14:37:29 +0100174};
Stephen M. Cameronff1f3282012-02-24 08:17:30 +0100175
Jens Axboee0681f32012-03-06 12:14:42 +0100176struct gfio_client {
Jens Axboe2f99deb2012-03-09 14:37:29 +0100177 struct gui_entry *ge;
Jens Axboeb9d2f302012-03-08 20:36:28 +0100178 struct fio_client *client;
Jens Axboee0681f32012-03-06 12:14:42 +0100179 GtkWidget *results_widget;
180 GtkWidget *disk_util_frame;
Jens Axboe6b79c802012-03-08 10:51:36 +0100181 GtkWidget *err_entry;
Jens Axboedcaeb602012-03-08 19:45:37 +0100182 unsigned int job_added;
183 struct thread_options o;
Jens Axboee0681f32012-03-06 12:14:42 +0100184};
185
Jens Axboe9988ca72012-03-09 15:14:06 +0100186static void gfio_update_thread_status(struct gui_entry *ge, char *status_message, double perc);
187static void gfio_update_thread_status_all(char *status_message, double perc);
Jens Axboec7249262012-03-09 17:11:04 +0100188void report_error(GError *error);
Jens Axboe9988ca72012-03-09 15:14:06 +0100189
Stephen M. Cameronf0af9f82012-03-11 11:35:50 +0100190static void iops_graph_y_axis_unit_change(struct graph *g, int power_of_ten)
191{
192 switch (power_of_ten) {
193 case 9: graph_y_title(g, "Billions of IOs / sec");
194 break;
195 case 6: graph_y_title(g, "Millions of IOs / sec");
196 break;
197 case 3: graph_y_title(g, "Thousands of IOs / sec");
198 break;
199 case 0:
200 default: graph_y_title(g, "IOs / sec");
201 break;
202 }
203}
204
Jens Axboe2f99deb2012-03-09 14:37:29 +0100205static struct graph *setup_iops_graph(void)
Jens Axboe2fd3bb02012-03-07 08:07:39 +0100206{
Jens Axboe2f99deb2012-03-09 14:37:29 +0100207 struct graph *g;
208
209 g = graph_new(DRAWING_AREA_XDIM / 2.0, DRAWING_AREA_YDIM, gfio_graph_font);
210 graph_title(g, "IOPS");
211 graph_x_title(g, "Time (secs)");
212 graph_y_title(g, "IOs / sec");
213 graph_add_label(g, "Read IOPS");
214 graph_add_label(g, "Write IOPS");
215 graph_set_color(g, "Read IOPS", 0.13, 0.54, 0.13);
216 graph_set_color(g, "Write IOPS", 1.0, 0.0, 0.0);
Jens Axboe8577f4f2012-03-09 19:28:27 +0100217 line_graph_set_data_count_limit(g, gfio_graph_limit);
Stephen M. Cameronf0af9f82012-03-11 11:35:50 +0100218 graph_y_axis_unit_change_notify(g, iops_graph_y_axis_unit_change);
Stephen M. Camerondef0ac22012-03-12 07:32:57 +0100219 graph_add_extra_space(g, 0.005, 0.005, 0.03, 0.03);
Jens Axboe2f99deb2012-03-09 14:37:29 +0100220 return g;
Jens Axboe2fd3bb02012-03-07 08:07:39 +0100221}
222
Stephen M. Cameronf0af9f82012-03-11 11:35:50 +0100223static void bandwidth_graph_y_axis_unit_change(struct graph *g, int power_of_ten)
224{
225 switch (power_of_ten) {
226 case 9: graph_y_title(g, "Petabytes / sec");
227 break;
228 case 6: graph_y_title(g, "Gigabytes / sec");
229 break;
230 case 3: graph_y_title(g, "Megabytes / sec");
231 break;
232 case 0:
233 default: graph_y_title(g, "Kilobytes / sec");
234 break;
235 }
236}
237
Jens Axboe2f99deb2012-03-09 14:37:29 +0100238static struct graph *setup_bandwidth_graph(void)
Jens Axboe2fd3bb02012-03-07 08:07:39 +0100239{
Jens Axboe2f99deb2012-03-09 14:37:29 +0100240 struct graph *g;
241
242 g = graph_new(DRAWING_AREA_XDIM / 2.0, DRAWING_AREA_YDIM, gfio_graph_font);
243 graph_title(g, "Bandwidth");
244 graph_x_title(g, "Time (secs)");
245 graph_y_title(g, "Kbytes / sec");
246 graph_add_label(g, "Read Bandwidth");
247 graph_add_label(g, "Write Bandwidth");
248 graph_set_color(g, "Read Bandwidth", 0.13, 0.54, 0.13);
249 graph_set_color(g, "Write Bandwidth", 1.0, 0.0, 0.0);
250 line_graph_set_data_count_limit(g, 100);
Stephen M. Cameronf0af9f82012-03-11 11:35:50 +0100251 graph_y_axis_unit_change_notify(g, bandwidth_graph_y_axis_unit_change);
Stephen M. Camerondef0ac22012-03-12 07:32:57 +0100252 graph_add_extra_space(g, 0.005, 0.005, 0.03, 0.03);
253
Jens Axboe2f99deb2012-03-09 14:37:29 +0100254 return g;
Jens Axboe2fd3bb02012-03-07 08:07:39 +0100255}
256
Jens Axboe2f99deb2012-03-09 14:37:29 +0100257static void setup_graphs(struct gfio_graphs *g)
Jens Axboe8663ea62012-03-02 14:04:30 +0100258{
Jens Axboe2f99deb2012-03-09 14:37:29 +0100259 g->iops_graph = setup_iops_graph();
260 g->bandwidth_graph = setup_bandwidth_graph();
261}
262
Jens Axboec80b74b2012-03-12 10:23:28 +0100263static void multitext_add_entry(struct multitext_widget *mt, const char *text)
264{
265 mt->text = realloc(mt->text, (mt->max_text + 1) * sizeof(char *));
266 mt->text[mt->max_text] = strdup(text);
267 mt->max_text++;
268}
269
270static void multitext_set_entry(struct multitext_widget *mt, unsigned int index)
271{
272 if (index >= mt->max_text)
273 return;
Jens Axboeda185432012-03-12 11:05:46 +0100274 if (!mt->text || !mt->text[index])
Jens Axboec80b74b2012-03-12 10:23:28 +0100275 return;
276
277 mt->cur_text = index;
278 gtk_entry_set_text(GTK_ENTRY(mt->entry), mt->text[index]);
279}
280
281static void multitext_update_entry(struct multitext_widget *mt,
282 unsigned int index, const char *text)
283{
Jens Axboeda185432012-03-12 11:05:46 +0100284 if (!mt->text)
285 return;
286
Jens Axboec80b74b2012-03-12 10:23:28 +0100287 if (mt->text[index])
288 free(mt->text[index]);
289
290 mt->text[index] = strdup(text);
291 if (mt->cur_text == index)
292 gtk_entry_set_text(GTK_ENTRY(mt->entry), mt->text[index]);
293}
294
295static void multitext_free(struct multitext_widget *mt)
296{
297 int i;
298
299 gtk_entry_set_text(GTK_ENTRY(mt->entry), "");
300
301 for (i = 0; i < mt->max_text; i++) {
302 if (mt->text[i])
303 free(mt->text[i]);
304 }
305
306 free(mt->text);
307 mt->cur_text = -1;
308 mt->max_text = 0;
309}
310
Jens Axboe2f99deb2012-03-09 14:37:29 +0100311static void clear_ge_ui_info(struct gui_entry *ge)
312{
313 gtk_label_set_text(GTK_LABEL(ge->probe.hostname), "");
314 gtk_label_set_text(GTK_LABEL(ge->probe.os), "");
315 gtk_label_set_text(GTK_LABEL(ge->probe.arch), "");
316 gtk_label_set_text(GTK_LABEL(ge->probe.fio_ver), "");
Jens Axboe3863d1a2012-03-09 17:39:05 +0100317#if 0
318 /* should we empty it... */
Jens Axboe2f99deb2012-03-09 14:37:29 +0100319 gtk_entry_set_text(GTK_ENTRY(ge->eta.name), "");
Jens Axboe3863d1a2012-03-09 17:39:05 +0100320#endif
Jens Axboec80b74b2012-03-12 10:23:28 +0100321 multitext_update_entry(&ge->eta.iotype, 0, "");
322 multitext_update_entry(&ge->eta.ioengine, 0, "");
323 multitext_update_entry(&ge->eta.iodepth, 0, "");
Jens Axboe2f99deb2012-03-09 14:37:29 +0100324 gtk_entry_set_text(GTK_ENTRY(ge->eta.jobs), "");
325 gtk_entry_set_text(GTK_ENTRY(ge->eta.files), "");
326 gtk_entry_set_text(GTK_ENTRY(ge->eta.read_bw), "");
327 gtk_entry_set_text(GTK_ENTRY(ge->eta.read_iops), "");
328 gtk_entry_set_text(GTK_ENTRY(ge->eta.write_bw), "");
329 gtk_entry_set_text(GTK_ENTRY(ge->eta.write_iops), "");
Jens Axboe8663ea62012-03-02 14:04:30 +0100330}
331
Jens Axboe3863d1a2012-03-09 17:39:05 +0100332static GtkWidget *new_combo_entry_in_frame(GtkWidget *box, const char *label)
333{
334 GtkWidget *entry, *frame;
335
336 frame = gtk_frame_new(label);
337 entry = gtk_combo_box_new_text();
338 gtk_box_pack_start(GTK_BOX(box), frame, TRUE, TRUE, 3);
339 gtk_container_add(GTK_CONTAINER(frame), entry);
340
341 return entry;
342}
343
Jens Axboe3650a3c2012-03-05 14:09:03 +0100344static GtkWidget *new_info_entry_in_frame(GtkWidget *box, const char *label)
345{
346 GtkWidget *entry, *frame;
347
348 frame = gtk_frame_new(label);
349 entry = gtk_entry_new();
Jens Axboe1c1e4a52012-03-05 14:37:38 +0100350 gtk_entry_set_editable(GTK_ENTRY(entry), 0);
Jens Axboe3650a3c2012-03-05 14:09:03 +0100351 gtk_box_pack_start(GTK_BOX(box), frame, TRUE, TRUE, 3);
352 gtk_container_add(GTK_CONTAINER(frame), entry);
353
354 return entry;
355}
356
357static GtkWidget *new_info_label_in_frame(GtkWidget *box, const char *label)
358{
359 GtkWidget *label_widget;
360 GtkWidget *frame;
361
362 frame = gtk_frame_new(label);
363 label_widget = gtk_label_new(NULL);
364 gtk_box_pack_start(GTK_BOX(box), frame, TRUE, TRUE, 3);
365 gtk_container_add(GTK_CONTAINER(frame), label_widget);
366
367 return label_widget;
368}
369
370static GtkWidget *create_spinbutton(GtkWidget *hbox, double min, double max, double defval)
371{
372 GtkWidget *button, *box;
373
374 box = gtk_hbox_new(FALSE, 3);
375 gtk_container_add(GTK_CONTAINER(hbox), box);
376
377 button = gtk_spin_button_new_with_range(min, max, 1.0);
378 gtk_box_pack_start(GTK_BOX(box), button, TRUE, TRUE, 0);
379
380 gtk_spin_button_set_update_policy(GTK_SPIN_BUTTON(button), GTK_UPDATE_IF_VALID);
381 gtk_spin_button_set_value(GTK_SPIN_BUTTON(button), defval);
382
383 return button;
384}
385
Jens Axboe3650a3c2012-03-05 14:09:03 +0100386static void label_set_int_value(GtkWidget *entry, unsigned int val)
387{
388 char tmp[80];
389
390 sprintf(tmp, "%u", val);
391 gtk_label_set_text(GTK_LABEL(entry), tmp);
392}
393
394static void entry_set_int_value(GtkWidget *entry, unsigned int val)
395{
396 char tmp[80];
397
398 sprintf(tmp, "%u", val);
399 gtk_entry_set_text(GTK_ENTRY(entry), tmp);
400}
401
Jens Axboe16ce5ad2012-03-12 11:56:09 +0100402static void show_info_dialog(struct gui *ui, const char *title,
403 const char *message)
404{
405 GtkWidget *dialog, *content, *label;
406
407 dialog = gtk_dialog_new_with_buttons(title, GTK_WINDOW(ui->window),
408 GTK_DIALOG_MODAL | GTK_DIALOG_DESTROY_WITH_PARENT,
409 GTK_STOCK_OK, GTK_RESPONSE_OK, NULL);
410
411 content = gtk_dialog_get_content_area(GTK_DIALOG(dialog));
412 label = gtk_label_new(message);
413 gtk_container_add(GTK_CONTAINER(content), label);
414 gtk_widget_show_all(dialog);
415 gtk_dialog_set_default_response(GTK_DIALOG(dialog), GTK_RESPONSE_ACCEPT);
416 gtk_dialog_run(GTK_DIALOG(dialog));
417 gtk_widget_destroy(dialog);
418}
419
Jens Axboe85dd01e2012-03-12 14:33:16 +0100420/*
421 * Update sensitivity of job buttons and job menu items, based on the
422 * state of the client.
423 */
424static void update_button_states(struct gui *ui, struct gui_entry *ge)
425{
426 unsigned int connect_state, send_state, start_state, edit_state;
427 const char *connect_str = NULL;
428 GtkWidget *w;
429
430 switch (ge->state) {
431 default: {
432 char tmp[80];
433
434 sprintf(tmp, "Bad client state: %u\n", ge->state);
435 show_info_dialog(ui, "Error", tmp);
436 /* fall through to new state */
437 }
438
439 case GE_STATE_NEW:
440 connect_state = 1;
441 edit_state = 0;
442 connect_str = "Connect";
443 send_state = 0;
444 start_state = 0;
445 break;
446 case GE_STATE_CONNECTED:
447 connect_state = 1;
448 edit_state = 0;
449 connect_str = "Disconnect";
450 send_state = 1;
451 start_state = 0;
452 break;
453 case GE_STATE_JOB_SENT:
454 connect_state = 1;
455 edit_state = 0;
456 connect_str = "Disconnect";
457 send_state = 0;
458 start_state = 1;
459 break;
460 case GE_STATE_JOB_STARTED:
461 connect_state = 1;
462 edit_state = 1;
463 connect_str = "Disconnect";
464 send_state = 0;
465 start_state = 1;
466 break;
467 case GE_STATE_JOB_RUNNING:
468 connect_state = 1;
469 edit_state = 0;
470 connect_str = "Disconnect";
471 send_state = 0;
472 start_state = 0;
473 break;
474 case GE_STATE_JOB_DONE:
475 connect_state = 1;
476 edit_state = 0;
477 connect_str = "Connect";
478 send_state = 0;
479 start_state = 0;
480 break;
481 }
482
483 gtk_widget_set_sensitive(ge->button[CONNECT_BUTTON], connect_state);
484 gtk_widget_set_sensitive(ge->button[SEND_BUTTON], send_state);
485 gtk_widget_set_sensitive(ge->button[START_JOB_BUTTON], start_state);
486 gtk_button_set_label(GTK_BUTTON(ge->button[CONNECT_BUTTON]), connect_str);
487
488 /*
489 * So the below doesn't work at all, how to set those menu items
490 * invisibible...
491 */
492 w = gtk_ui_manager_get_widget(ui->uimanager, "/MainMenu/JobMenu/Connect");
Jens Axboe21ba9042012-03-13 10:58:59 +0100493 gtk_widget_set_sensitive(w, connect_state);
494 gtk_menu_item_set_label(GTK_MENU_ITEM(w), connect_str);
Jens Axboe85dd01e2012-03-12 14:33:16 +0100495
Stephen M. Cameron63f81ed2012-03-13 08:08:32 +0100496 w = gtk_ui_manager_get_widget(ui->uimanager, "/MainMenu/JobMenu/Edit job");
Jens Axboe21ba9042012-03-13 10:58:59 +0100497 gtk_widget_set_sensitive(w, edit_state);
Jens Axboe85dd01e2012-03-12 14:33:16 +0100498
Stephen M. Cameron63f81ed2012-03-13 08:08:32 +0100499 w = gtk_ui_manager_get_widget(ui->uimanager, "/MainMenu/JobMenu/Send job");
Jens Axboe21ba9042012-03-13 10:58:59 +0100500 gtk_widget_set_sensitive(w, send_state);
Jens Axboe85dd01e2012-03-12 14:33:16 +0100501
Stephen M. Cameron63f81ed2012-03-13 08:08:32 +0100502 w = gtk_ui_manager_get_widget(ui->uimanager, "/MainMenu/JobMenu/Start job");
Jens Axboe21ba9042012-03-13 10:58:59 +0100503 gtk_widget_set_sensitive(w, start_state);
Jens Axboe85dd01e2012-03-12 14:33:16 +0100504}
505
506static void gfio_set_state(struct gui_entry *ge, unsigned int state)
507{
508 ge->state = state;
509 update_button_states(ge->ui, ge);
510}
511
Jens Axboea2697902012-03-05 16:43:49 +0100512#define ALIGN_LEFT 1
513#define ALIGN_RIGHT 2
514#define INVISIBLE 4
515#define UNSORTABLE 8
516
517GtkTreeViewColumn *tree_view_column(GtkWidget *tree_view, int index, const char *title, unsigned int flags)
518{
519 GtkCellRenderer *renderer;
520 GtkTreeViewColumn *col;
521 double xalign = 0.0; /* left as default */
522 PangoAlignment align;
523 gboolean visible;
524
525 align = (flags & ALIGN_LEFT) ? PANGO_ALIGN_LEFT :
526 (flags & ALIGN_RIGHT) ? PANGO_ALIGN_RIGHT :
527 PANGO_ALIGN_CENTER;
528 visible = !(flags & INVISIBLE);
529
530 renderer = gtk_cell_renderer_text_new();
531 col = gtk_tree_view_column_new();
532
533 gtk_tree_view_column_set_title(col, title);
534 if (!(flags & UNSORTABLE))
535 gtk_tree_view_column_set_sort_column_id(col, index);
536 gtk_tree_view_column_set_resizable(col, TRUE);
537 gtk_tree_view_column_pack_start(col, renderer, TRUE);
538 gtk_tree_view_column_add_attribute(col, renderer, "text", index);
539 gtk_object_set(GTK_OBJECT(renderer), "alignment", align, NULL);
540 switch (align) {
541 case PANGO_ALIGN_LEFT:
542 xalign = 0.0;
543 break;
544 case PANGO_ALIGN_CENTER:
545 xalign = 0.5;
546 break;
547 case PANGO_ALIGN_RIGHT:
548 xalign = 1.0;
549 break;
550 }
551 gtk_cell_renderer_set_alignment(GTK_CELL_RENDERER(renderer), xalign, 0.5);
552 gtk_tree_view_column_set_visible(col, visible);
553 gtk_tree_view_append_column(GTK_TREE_VIEW(tree_view), col);
554 return col;
555}
556
Jens Axboe9b260bd2012-03-06 11:02:52 +0100557static void gfio_ui_setup_log(struct gui *ui)
558{
559 GtkTreeSelection *selection;
560 GtkListStore *model;
561 GtkWidget *tree_view;
562
563 model = gtk_list_store_new(4, G_TYPE_STRING, G_TYPE_STRING, G_TYPE_INT, G_TYPE_STRING);
564
565 tree_view = gtk_tree_view_new_with_model(GTK_TREE_MODEL(model));
566 gtk_widget_set_can_focus(tree_view, FALSE);
567
568 selection = gtk_tree_view_get_selection(GTK_TREE_VIEW(tree_view));
569 gtk_tree_selection_set_mode(GTK_TREE_SELECTION(selection), GTK_SELECTION_BROWSE);
Jens Axboe661f7412012-03-06 13:55:45 +0100570 g_object_set(G_OBJECT(tree_view), "headers-visible", TRUE,
571 "enable-grid-lines", GTK_TREE_VIEW_GRID_LINES_BOTH, NULL);
Jens Axboe9b260bd2012-03-06 11:02:52 +0100572
573 tree_view_column(tree_view, 0, "Time", ALIGN_RIGHT | UNSORTABLE);
574 tree_view_column(tree_view, 1, "Host", ALIGN_RIGHT | UNSORTABLE);
575 tree_view_column(tree_view, 2, "Level", ALIGN_RIGHT | UNSORTABLE);
Jens Axboef095d562012-03-06 13:49:12 +0100576 tree_view_column(tree_view, 3, "Text", ALIGN_LEFT | UNSORTABLE);
Jens Axboe9b260bd2012-03-06 11:02:52 +0100577
578 ui->log_model = model;
579 ui->log_tree = tree_view;
580}
581
Jens Axboea2697902012-03-05 16:43:49 +0100582static GtkWidget *gfio_output_clat_percentiles(unsigned int *ovals,
583 fio_fp64_t *plist,
584 unsigned int len,
585 const char *base,
586 unsigned int scale)
587{
588 GType types[FIO_IO_U_LIST_MAX_LEN];
589 GtkWidget *tree_view;
590 GtkTreeSelection *selection;
591 GtkListStore *model;
592 GtkTreeIter iter;
593 int i;
594
595 for (i = 0; i < len; i++)
596 types[i] = G_TYPE_INT;
597
598 model = gtk_list_store_newv(len, types);
599
600 tree_view = gtk_tree_view_new_with_model(GTK_TREE_MODEL(model));
601 gtk_widget_set_can_focus(tree_view, FALSE);
602
Jens Axboe661f7412012-03-06 13:55:45 +0100603 g_object_set(G_OBJECT(tree_view), "headers-visible", TRUE,
604 "enable-grid-lines", GTK_TREE_VIEW_GRID_LINES_BOTH, NULL);
605
Jens Axboea2697902012-03-05 16:43:49 +0100606 selection = gtk_tree_view_get_selection(GTK_TREE_VIEW(tree_view));
607 gtk_tree_selection_set_mode(GTK_TREE_SELECTION(selection), GTK_SELECTION_BROWSE);
608
609 for (i = 0; i < len; i++) {
610 char fbuf[8];
611
612 sprintf(fbuf, "%2.2f%%", plist[i].u.f);
613 tree_view_column(tree_view, i, fbuf, ALIGN_RIGHT | UNSORTABLE);
614 }
615
616 gtk_list_store_append(model, &iter);
617
Jens Axboee0681f32012-03-06 12:14:42 +0100618 for (i = 0; i < len; i++) {
619 if (scale)
620 ovals[i] = (ovals[i] + 999) / 1000;
Jens Axboea2697902012-03-05 16:43:49 +0100621 gtk_list_store_set(model, &iter, i, ovals[i], -1);
Jens Axboee0681f32012-03-06 12:14:42 +0100622 }
Jens Axboea2697902012-03-05 16:43:49 +0100623
624 return tree_view;
625}
626
627static void gfio_show_clat_percentiles(GtkWidget *vbox, struct thread_stat *ts,
628 int ddir)
629{
630 unsigned int *io_u_plat = ts->io_u_plat[ddir];
631 unsigned long nr = ts->clat_stat[ddir].samples;
632 fio_fp64_t *plist = ts->percentile_list;
633 unsigned int *ovals, len, minv, maxv, scale_down;
634 const char *base;
635 GtkWidget *tree_view, *frame, *hbox;
636 char tmp[64];
637
638 len = calc_clat_percentiles(io_u_plat, nr, plist, &ovals, &maxv, &minv);
639 if (!len)
640 goto out;
641
642 /*
643 * We default to usecs, but if the value range is such that we
644 * should scale down to msecs, do that.
645 */
646 if (minv > 2000 && maxv > 99999) {
647 scale_down = 1;
648 base = "msec";
649 } else {
650 scale_down = 0;
651 base = "usec";
652 }
653
654 tree_view = gfio_output_clat_percentiles(ovals, plist, len, base, scale_down);
655
656 sprintf(tmp, "Completion percentiles (%s)", base);
657 frame = gtk_frame_new(tmp);
658 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
659
660 hbox = gtk_hbox_new(FALSE, 3);
661 gtk_container_add(GTK_CONTAINER(frame), hbox);
662
663 gtk_box_pack_start(GTK_BOX(hbox), tree_view, TRUE, FALSE, 3);
664out:
665 if (ovals)
666 free(ovals);
667}
668
Jens Axboe3650a3c2012-03-05 14:09:03 +0100669static void gfio_show_lat(GtkWidget *vbox, const char *name, unsigned long min,
670 unsigned long max, double mean, double dev)
671{
672 const char *base = "(usec)";
Jens Axboe1c1e4a52012-03-05 14:37:38 +0100673 GtkWidget *hbox, *label, *frame;
Jens Axboe3650a3c2012-03-05 14:09:03 +0100674 char *minp, *maxp;
675 char tmp[64];
676
677 if (!usec_to_msec(&min, &max, &mean, &dev))
678 base = "(msec)";
679
680 minp = num2str(min, 6, 1, 0);
681 maxp = num2str(max, 6, 1, 0);
682
Jens Axboe3650a3c2012-03-05 14:09:03 +0100683 sprintf(tmp, "%s %s", name, base);
684 frame = gtk_frame_new(tmp);
685 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
686
Jens Axboe3650a3c2012-03-05 14:09:03 +0100687 hbox = gtk_hbox_new(FALSE, 3);
Jens Axboe1c1e4a52012-03-05 14:37:38 +0100688 gtk_container_add(GTK_CONTAINER(frame), hbox);
Jens Axboe3650a3c2012-03-05 14:09:03 +0100689
690 label = new_info_label_in_frame(hbox, "Minimum");
691 gtk_label_set_text(GTK_LABEL(label), minp);
692 label = new_info_label_in_frame(hbox, "Maximum");
693 gtk_label_set_text(GTK_LABEL(label), maxp);
694 label = new_info_label_in_frame(hbox, "Average");
695 sprintf(tmp, "%5.02f", mean);
696 gtk_label_set_text(GTK_LABEL(label), tmp);
697 label = new_info_label_in_frame(hbox, "Standard deviation");
698 sprintf(tmp, "%5.02f", dev);
699 gtk_label_set_text(GTK_LABEL(label), tmp);
700
701 free(minp);
702 free(maxp);
703
704}
705
Jens Axboeca850992012-03-05 20:04:43 +0100706#define GFIO_CLAT 1
707#define GFIO_SLAT 2
708#define GFIO_LAT 4
709
Jens Axboe3650a3c2012-03-05 14:09:03 +0100710static void gfio_show_ddir_status(GtkWidget *mbox, struct group_run_stats *rs,
711 struct thread_stat *ts, int ddir)
712{
713 const char *ddir_label[2] = { "Read", "Write" };
Jens Axboe0b761302012-03-05 20:44:11 +0100714 GtkWidget *frame, *label, *box, *vbox, *main_vbox;
Jens Axboee0681f32012-03-06 12:14:42 +0100715 unsigned long min[3], max[3], runt;
Jens Axboe3650a3c2012-03-05 14:09:03 +0100716 unsigned long long bw, iops;
Jens Axboeca850992012-03-05 20:04:43 +0100717 unsigned int flags = 0;
Jens Axboee0681f32012-03-06 12:14:42 +0100718 double mean[3], dev[3];
Jens Axboe3650a3c2012-03-05 14:09:03 +0100719 char *io_p, *bw_p, *iops_p;
720 int i2p;
721
722 if (!ts->runtime[ddir])
723 return;
724
725 i2p = is_power_of_2(rs->kb_base);
726 runt = ts->runtime[ddir];
727
728 bw = (1000 * ts->io_bytes[ddir]) / runt;
729 io_p = num2str(ts->io_bytes[ddir], 6, 1, i2p);
730 bw_p = num2str(bw, 6, 1, i2p);
731
732 iops = (1000 * (uint64_t)ts->total_io_u[ddir]) / runt;
733 iops_p = num2str(iops, 6, 1, 0);
734
735 box = gtk_hbox_new(FALSE, 3);
736 gtk_box_pack_start(GTK_BOX(mbox), box, TRUE, FALSE, 3);
737
738 frame = gtk_frame_new(ddir_label[ddir]);
739 gtk_box_pack_start(GTK_BOX(box), frame, FALSE, FALSE, 5);
740
Jens Axboe0b761302012-03-05 20:44:11 +0100741 main_vbox = gtk_vbox_new(FALSE, 3);
742 gtk_container_add(GTK_CONTAINER(frame), main_vbox);
Jens Axboe3650a3c2012-03-05 14:09:03 +0100743
744 box = gtk_hbox_new(FALSE, 3);
Jens Axboe0b761302012-03-05 20:44:11 +0100745 gtk_box_pack_start(GTK_BOX(main_vbox), box, TRUE, FALSE, 3);
Jens Axboe3650a3c2012-03-05 14:09:03 +0100746
747 label = new_info_label_in_frame(box, "IO");
748 gtk_label_set_text(GTK_LABEL(label), io_p);
749 label = new_info_label_in_frame(box, "Bandwidth");
750 gtk_label_set_text(GTK_LABEL(label), bw_p);
751 label = new_info_label_in_frame(box, "IOPS");
752 gtk_label_set_text(GTK_LABEL(label), iops_p);
753 label = new_info_label_in_frame(box, "Runtime (msec)");
754 label_set_int_value(label, ts->runtime[ddir]);
755
Jens Axboee0681f32012-03-06 12:14:42 +0100756 if (calc_lat(&ts->bw_stat[ddir], &min[0], &max[0], &mean[0], &dev[0])) {
Jens Axboeca850992012-03-05 20:04:43 +0100757 double p_of_agg = 100.0;
758 const char *bw_str = "KB";
759 char tmp[32];
760
761 if (rs->agg[ddir]) {
Jens Axboee0681f32012-03-06 12:14:42 +0100762 p_of_agg = mean[0] * 100 / (double) rs->agg[ddir];
Jens Axboeca850992012-03-05 20:04:43 +0100763 if (p_of_agg > 100.0)
764 p_of_agg = 100.0;
765 }
766
Jens Axboee0681f32012-03-06 12:14:42 +0100767 if (mean[0] > 999999.9) {
768 min[0] /= 1000.0;
769 max[0] /= 1000.0;
770 mean[0] /= 1000.0;
771 dev[0] /= 1000.0;
Jens Axboeca850992012-03-05 20:04:43 +0100772 bw_str = "MB";
773 }
774
Jens Axboe0b761302012-03-05 20:44:11 +0100775 sprintf(tmp, "Bandwidth (%s)", bw_str);
776 frame = gtk_frame_new(tmp);
777 gtk_box_pack_start(GTK_BOX(main_vbox), frame, FALSE, FALSE, 5);
Jens Axboeca850992012-03-05 20:04:43 +0100778
Jens Axboe0b761302012-03-05 20:44:11 +0100779 box = gtk_hbox_new(FALSE, 3);
780 gtk_container_add(GTK_CONTAINER(frame), box);
Jens Axboeca850992012-03-05 20:04:43 +0100781
Jens Axboe0b761302012-03-05 20:44:11 +0100782 label = new_info_label_in_frame(box, "Minimum");
Jens Axboee0681f32012-03-06 12:14:42 +0100783 label_set_int_value(label, min[0]);
Jens Axboe0b761302012-03-05 20:44:11 +0100784 label = new_info_label_in_frame(box, "Maximum");
Jens Axboee0681f32012-03-06 12:14:42 +0100785 label_set_int_value(label, max[0]);
Jens Axboe0b761302012-03-05 20:44:11 +0100786 label = new_info_label_in_frame(box, "Percentage of jobs");
Jens Axboeca850992012-03-05 20:04:43 +0100787 sprintf(tmp, "%3.2f%%", p_of_agg);
788 gtk_label_set_text(GTK_LABEL(label), tmp);
Jens Axboe0b761302012-03-05 20:44:11 +0100789 label = new_info_label_in_frame(box, "Average");
Jens Axboee0681f32012-03-06 12:14:42 +0100790 sprintf(tmp, "%5.02f", mean[0]);
Jens Axboeca850992012-03-05 20:04:43 +0100791 gtk_label_set_text(GTK_LABEL(label), tmp);
Jens Axboe0b761302012-03-05 20:44:11 +0100792 label = new_info_label_in_frame(box, "Standard deviation");
Jens Axboee0681f32012-03-06 12:14:42 +0100793 sprintf(tmp, "%5.02f", dev[0]);
Jens Axboeca850992012-03-05 20:04:43 +0100794 gtk_label_set_text(GTK_LABEL(label), tmp);
795 }
796
Jens Axboee0681f32012-03-06 12:14:42 +0100797 if (calc_lat(&ts->slat_stat[ddir], &min[0], &max[0], &mean[0], &dev[0]))
Jens Axboe2b089892012-03-06 08:09:17 +0100798 flags |= GFIO_SLAT;
Jens Axboee0681f32012-03-06 12:14:42 +0100799 if (calc_lat(&ts->clat_stat[ddir], &min[1], &max[1], &mean[1], &dev[1]))
Jens Axboe2b089892012-03-06 08:09:17 +0100800 flags |= GFIO_CLAT;
Jens Axboee0681f32012-03-06 12:14:42 +0100801 if (calc_lat(&ts->lat_stat[ddir], &min[2], &max[2], &mean[2], &dev[2]))
Jens Axboe2b089892012-03-06 08:09:17 +0100802 flags |= GFIO_LAT;
803
804 if (flags) {
805 frame = gtk_frame_new("Latency");
806 gtk_box_pack_start(GTK_BOX(main_vbox), frame, FALSE, FALSE, 5);
807
808 vbox = gtk_vbox_new(FALSE, 3);
809 gtk_container_add(GTK_CONTAINER(frame), vbox);
810
811 if (flags & GFIO_SLAT)
Jens Axboee0681f32012-03-06 12:14:42 +0100812 gfio_show_lat(vbox, "Submission latency", min[0], max[0], mean[0], dev[0]);
Jens Axboe2b089892012-03-06 08:09:17 +0100813 if (flags & GFIO_CLAT)
Jens Axboee0681f32012-03-06 12:14:42 +0100814 gfio_show_lat(vbox, "Completion latency", min[1], max[1], mean[1], dev[1]);
Jens Axboe2b089892012-03-06 08:09:17 +0100815 if (flags & GFIO_LAT)
Jens Axboee0681f32012-03-06 12:14:42 +0100816 gfio_show_lat(vbox, "Total latency", min[2], max[2], mean[2], dev[2]);
Jens Axboe2b089892012-03-06 08:09:17 +0100817 }
818
819 if (ts->clat_percentiles)
820 gfio_show_clat_percentiles(main_vbox, ts, ddir);
821
822
Jens Axboe3650a3c2012-03-05 14:09:03 +0100823 free(io_p);
824 free(bw_p);
825 free(iops_p);
826}
827
Jens Axboee5bd1342012-03-05 21:38:12 +0100828static GtkWidget *gfio_output_lat_buckets(double *lat, unsigned int num,
829 const char **labels)
830{
831 GtkWidget *tree_view;
832 GtkTreeSelection *selection;
833 GtkListStore *model;
834 GtkTreeIter iter;
835 GType *types;
836 int i, skipped;
837
838 /*
839 * Check if all are empty, in which case don't bother
840 */
841 for (i = 0, skipped = 0; i < num; i++)
842 if (lat[i] <= 0.0)
843 skipped++;
844
845 if (skipped == num)
846 return NULL;
847
848 types = malloc(num * sizeof(GType));
849
850 for (i = 0; i < num; i++)
851 types[i] = G_TYPE_STRING;
852
853 model = gtk_list_store_newv(num, types);
854 free(types);
855 types = NULL;
856
857 tree_view = gtk_tree_view_new_with_model(GTK_TREE_MODEL(model));
858 gtk_widget_set_can_focus(tree_view, FALSE);
859
Jens Axboe661f7412012-03-06 13:55:45 +0100860 g_object_set(G_OBJECT(tree_view), "headers-visible", TRUE,
861 "enable-grid-lines", GTK_TREE_VIEW_GRID_LINES_BOTH, NULL);
862
Jens Axboee5bd1342012-03-05 21:38:12 +0100863 selection = gtk_tree_view_get_selection(GTK_TREE_VIEW(tree_view));
864 gtk_tree_selection_set_mode(GTK_TREE_SELECTION(selection), GTK_SELECTION_BROWSE);
865
866 for (i = 0; i < num; i++)
867 tree_view_column(tree_view, i, labels[i], ALIGN_RIGHT | UNSORTABLE);
868
869 gtk_list_store_append(model, &iter);
870
871 for (i = 0; i < num; i++) {
872 char fbuf[32];
873
874 if (lat[i] <= 0.0)
875 sprintf(fbuf, "0.00");
876 else
877 sprintf(fbuf, "%3.2f%%", lat[i]);
878
879 gtk_list_store_set(model, &iter, i, fbuf, -1);
880 }
881
882 return tree_view;
883}
884
885static void gfio_show_latency_buckets(GtkWidget *vbox, struct thread_stat *ts)
886{
887 GtkWidget *box, *frame, *tree_view;
888 double io_u_lat_u[FIO_IO_U_LAT_U_NR];
889 double io_u_lat_m[FIO_IO_U_LAT_M_NR];
890 const char *uranges[] = { "2", "4", "10", "20", "50", "100",
891 "250", "500", "750", "1000", };
892 const char *mranges[] = { "2", "4", "10", "20", "50", "100",
893 "250", "500", "750", "1000", "2000",
894 ">= 2000", };
895
896 stat_calc_lat_u(ts, io_u_lat_u);
897 stat_calc_lat_m(ts, io_u_lat_m);
898
899 tree_view = gfio_output_lat_buckets(io_u_lat_u, FIO_IO_U_LAT_U_NR, uranges);
900 if (tree_view) {
901 frame = gtk_frame_new("Latency buckets (usec)");
902 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
903
904 box = gtk_hbox_new(FALSE, 3);
905 gtk_container_add(GTK_CONTAINER(frame), box);
906 gtk_box_pack_start(GTK_BOX(box), tree_view, TRUE, FALSE, 3);
907 }
908
909 tree_view = gfio_output_lat_buckets(io_u_lat_m, FIO_IO_U_LAT_M_NR, mranges);
910 if (tree_view) {
911 frame = gtk_frame_new("Latency buckets (msec)");
912 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
913
914 box = gtk_hbox_new(FALSE, 3);
915 gtk_container_add(GTK_CONTAINER(frame), box);
916 gtk_box_pack_start(GTK_BOX(box), tree_view, TRUE, FALSE, 3);
917 }
918}
919
Jens Axboe2e331012012-03-05 22:07:54 +0100920static void gfio_show_cpu_usage(GtkWidget *vbox, struct thread_stat *ts)
921{
922 GtkWidget *box, *frame, *entry;
923 double usr_cpu, sys_cpu;
924 unsigned long runtime;
925 char tmp[32];
926
927 runtime = ts->total_run_time;
928 if (runtime) {
929 double runt = (double) runtime;
930
931 usr_cpu = (double) ts->usr_time * 100 / runt;
932 sys_cpu = (double) ts->sys_time * 100 / runt;
933 } else {
934 usr_cpu = 0;
935 sys_cpu = 0;
936 }
937
938 frame = gtk_frame_new("OS resources");
939 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
940
941 box = gtk_hbox_new(FALSE, 3);
942 gtk_container_add(GTK_CONTAINER(frame), box);
943
944 entry = new_info_entry_in_frame(box, "User CPU");
945 sprintf(tmp, "%3.2f%%", usr_cpu);
946 gtk_entry_set_text(GTK_ENTRY(entry), tmp);
947 entry = new_info_entry_in_frame(box, "System CPU");
948 sprintf(tmp, "%3.2f%%", sys_cpu);
949 gtk_entry_set_text(GTK_ENTRY(entry), tmp);
950 entry = new_info_entry_in_frame(box, "Context switches");
951 entry_set_int_value(entry, ts->ctx);
952 entry = new_info_entry_in_frame(box, "Major faults");
953 entry_set_int_value(entry, ts->majf);
954 entry = new_info_entry_in_frame(box, "Minor faults");
955 entry_set_int_value(entry, ts->minf);
956}
Jens Axboe19998db2012-03-06 09:17:59 +0100957static void gfio_add_sc_depths_tree(GtkListStore *model,
958 struct thread_stat *ts, unsigned int len,
959 int submit)
960{
961 double io_u_dist[FIO_IO_U_MAP_NR];
962 GtkTreeIter iter;
963 /* Bits 0, and 3-8 */
964 const int add_mask = 0x1f9;
965 int i, j;
966
967 if (submit)
968 stat_calc_dist(ts->io_u_submit, ts->total_submit, io_u_dist);
969 else
970 stat_calc_dist(ts->io_u_complete, ts->total_complete, io_u_dist);
971
972 gtk_list_store_append(model, &iter);
973
974 gtk_list_store_set(model, &iter, 0, submit ? "Submit" : "Complete", -1);
975
976 for (i = 1, j = 0; i < len; i++) {
977 char fbuf[32];
978
979 if (!(add_mask & (1UL << (i - 1))))
980 sprintf(fbuf, "0.0%%");
981 else {
982 sprintf(fbuf, "%3.1f%%", io_u_dist[j]);
983 j++;
984 }
985
986 gtk_list_store_set(model, &iter, i, fbuf, -1);
987 }
988
989}
990
991static void gfio_add_total_depths_tree(GtkListStore *model,
992 struct thread_stat *ts, unsigned int len)
993{
994 double io_u_dist[FIO_IO_U_MAP_NR];
995 GtkTreeIter iter;
996 /* Bits 1-6, and 8 */
997 const int add_mask = 0x17e;
998 int i, j;
999
1000 stat_calc_dist(ts->io_u_map, ts_total_io_u(ts), io_u_dist);
1001
1002 gtk_list_store_append(model, &iter);
1003
1004 gtk_list_store_set(model, &iter, 0, "Total", -1);
1005
1006 for (i = 1, j = 0; i < len; i++) {
1007 char fbuf[32];
1008
1009 if (!(add_mask & (1UL << (i - 1))))
1010 sprintf(fbuf, "0.0%%");
1011 else {
1012 sprintf(fbuf, "%3.1f%%", io_u_dist[j]);
1013 j++;
1014 }
1015
1016 gtk_list_store_set(model, &iter, i, fbuf, -1);
1017 }
1018
1019}
Jens Axboe2e331012012-03-05 22:07:54 +01001020
1021static void gfio_show_io_depths(GtkWidget *vbox, struct thread_stat *ts)
1022{
Jens Axboe2e331012012-03-05 22:07:54 +01001023 GtkWidget *frame, *box, *tree_view;
1024 GtkTreeSelection *selection;
1025 GtkListStore *model;
Jens Axboe2e331012012-03-05 22:07:54 +01001026 GType types[FIO_IO_U_MAP_NR + 1];
1027 int i;
Jens Axboe19998db2012-03-06 09:17:59 +01001028#define NR_LABELS 10
1029 const char *labels[NR_LABELS] = { "Depth", "0", "1", "2", "4", "8", "16", "32", "64", ">= 64" };
Jens Axboe2e331012012-03-05 22:07:54 +01001030
1031 frame = gtk_frame_new("IO depths");
1032 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
1033
1034 box = gtk_hbox_new(FALSE, 3);
1035 gtk_container_add(GTK_CONTAINER(frame), box);
1036
Jens Axboe19998db2012-03-06 09:17:59 +01001037 for (i = 0; i < NR_LABELS; i++)
Jens Axboe2e331012012-03-05 22:07:54 +01001038 types[i] = G_TYPE_STRING;
1039
Jens Axboe19998db2012-03-06 09:17:59 +01001040 model = gtk_list_store_newv(NR_LABELS, types);
Jens Axboe2e331012012-03-05 22:07:54 +01001041
1042 tree_view = gtk_tree_view_new_with_model(GTK_TREE_MODEL(model));
1043 gtk_widget_set_can_focus(tree_view, FALSE);
1044
Jens Axboe661f7412012-03-06 13:55:45 +01001045 g_object_set(G_OBJECT(tree_view), "headers-visible", TRUE,
1046 "enable-grid-lines", GTK_TREE_VIEW_GRID_LINES_BOTH, NULL);
1047
Jens Axboe2e331012012-03-05 22:07:54 +01001048 selection = gtk_tree_view_get_selection(GTK_TREE_VIEW(tree_view));
1049 gtk_tree_selection_set_mode(GTK_TREE_SELECTION(selection), GTK_SELECTION_BROWSE);
1050
Jens Axboe19998db2012-03-06 09:17:59 +01001051 for (i = 0; i < NR_LABELS; i++)
Jens Axboe2e331012012-03-05 22:07:54 +01001052 tree_view_column(tree_view, i, labels[i], ALIGN_RIGHT | UNSORTABLE);
1053
Jens Axboe19998db2012-03-06 09:17:59 +01001054 gfio_add_total_depths_tree(model, ts, NR_LABELS);
1055 gfio_add_sc_depths_tree(model, ts, NR_LABELS, 1);
1056 gfio_add_sc_depths_tree(model, ts, NR_LABELS, 0);
Jens Axboe2e331012012-03-05 22:07:54 +01001057
1058 gtk_box_pack_start(GTK_BOX(box), tree_view, TRUE, FALSE, 3);
1059}
1060
Jens Axboef9d40b42012-03-06 09:52:49 +01001061static gboolean results_window_delete(GtkWidget *w, gpointer data)
1062{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001063 struct gui_entry *ge = (struct gui_entry *) data;
Jens Axboef9d40b42012-03-06 09:52:49 +01001064
1065 gtk_widget_destroy(w);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001066 ge->results_window = NULL;
1067 ge->results_notebook = NULL;
Jens Axboef9d40b42012-03-06 09:52:49 +01001068 return TRUE;
1069}
1070
Jens Axboe2f99deb2012-03-09 14:37:29 +01001071static GtkWidget *get_results_window(struct gui_entry *ge)
Jens Axboef9d40b42012-03-06 09:52:49 +01001072{
1073 GtkWidget *win, *notebook;
1074
Jens Axboe2f99deb2012-03-09 14:37:29 +01001075 if (ge->results_window)
1076 return ge->results_notebook;
Jens Axboef9d40b42012-03-06 09:52:49 +01001077
1078 win = gtk_window_new(GTK_WINDOW_TOPLEVEL);
1079 gtk_window_set_title(GTK_WINDOW(win), "Results");
Jens Axboeb01329d2012-03-07 20:31:28 +01001080 gtk_window_set_default_size(GTK_WINDOW(win), 1024, 768);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001081 g_signal_connect(win, "delete-event", G_CALLBACK(results_window_delete), ge);
1082 g_signal_connect(win, "destroy", G_CALLBACK(results_window_delete), ge);
Jens Axboef9d40b42012-03-06 09:52:49 +01001083
1084 notebook = gtk_notebook_new();
Jens Axboe0aa928c2012-03-09 17:24:07 +01001085 gtk_notebook_set_scrollable(GTK_NOTEBOOK(notebook), 1);
1086 gtk_notebook_popup_enable(GTK_NOTEBOOK(notebook));
Jens Axboef9d40b42012-03-06 09:52:49 +01001087 gtk_container_add(GTK_CONTAINER(win), notebook);
1088
Jens Axboe2f99deb2012-03-09 14:37:29 +01001089 ge->results_window = win;
1090 ge->results_notebook = notebook;
1091 return ge->results_notebook;
Jens Axboef9d40b42012-03-06 09:52:49 +01001092}
1093
Jens Axboe3650a3c2012-03-05 14:09:03 +01001094static void gfio_display_ts(struct fio_client *client, struct thread_stat *ts,
1095 struct group_run_stats *rs)
1096{
Jens Axboeb01329d2012-03-07 20:31:28 +01001097 GtkWidget *res_win, *box, *vbox, *entry, *scroll;
Jens Axboee0681f32012-03-06 12:14:42 +01001098 struct gfio_client *gc = client->client_data;
Jens Axboe3650a3c2012-03-05 14:09:03 +01001099
1100 gdk_threads_enter();
1101
Jens Axboe2f99deb2012-03-09 14:37:29 +01001102 res_win = get_results_window(gc->ge);
Jens Axboe3650a3c2012-03-05 14:09:03 +01001103
Jens Axboeb01329d2012-03-07 20:31:28 +01001104 scroll = gtk_scrolled_window_new(NULL, NULL);
1105 gtk_container_set_border_width(GTK_CONTAINER(scroll), 5);
1106 gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(scroll), GTK_POLICY_AUTOMATIC, GTK_POLICY_AUTOMATIC);
1107
Jens Axboe3650a3c2012-03-05 14:09:03 +01001108 vbox = gtk_vbox_new(FALSE, 3);
Jens Axboe3650a3c2012-03-05 14:09:03 +01001109
Jens Axboeb01329d2012-03-07 20:31:28 +01001110 box = gtk_hbox_new(FALSE, 0);
1111 gtk_box_pack_start(GTK_BOX(vbox), box, TRUE, FALSE, 5);
Jens Axboe3650a3c2012-03-05 14:09:03 +01001112
Jens Axboeb01329d2012-03-07 20:31:28 +01001113 gtk_scrolled_window_add_with_viewport(GTK_SCROLLED_WINDOW(scroll), vbox);
1114
1115 gtk_notebook_append_page(GTK_NOTEBOOK(res_win), scroll, gtk_label_new(ts->name));
Jens Axboef9d40b42012-03-06 09:52:49 +01001116
Jens Axboee0681f32012-03-06 12:14:42 +01001117 gc->results_widget = vbox;
1118
Jens Axboe3650a3c2012-03-05 14:09:03 +01001119 entry = new_info_entry_in_frame(box, "Name");
1120 gtk_entry_set_text(GTK_ENTRY(entry), ts->name);
1121 if (strlen(ts->description)) {
1122 entry = new_info_entry_in_frame(box, "Description");
1123 gtk_entry_set_text(GTK_ENTRY(entry), ts->description);
1124 }
1125 entry = new_info_entry_in_frame(box, "Group ID");
1126 entry_set_int_value(entry, ts->groupid);
1127 entry = new_info_entry_in_frame(box, "Jobs");
1128 entry_set_int_value(entry, ts->members);
Jens Axboe6b79c802012-03-08 10:51:36 +01001129 gc->err_entry = entry = new_info_entry_in_frame(box, "Error");
Jens Axboe3650a3c2012-03-05 14:09:03 +01001130 entry_set_int_value(entry, ts->error);
1131 entry = new_info_entry_in_frame(box, "PID");
1132 entry_set_int_value(entry, ts->pid);
1133
1134 if (ts->io_bytes[DDIR_READ])
1135 gfio_show_ddir_status(vbox, rs, ts, DDIR_READ);
1136 if (ts->io_bytes[DDIR_WRITE])
1137 gfio_show_ddir_status(vbox, rs, ts, DDIR_WRITE);
1138
Jens Axboee5bd1342012-03-05 21:38:12 +01001139 gfio_show_latency_buckets(vbox, ts);
Jens Axboe2e331012012-03-05 22:07:54 +01001140 gfio_show_cpu_usage(vbox, ts);
1141 gfio_show_io_depths(vbox, ts);
Jens Axboee5bd1342012-03-05 21:38:12 +01001142
Jens Axboe2f99deb2012-03-09 14:37:29 +01001143 gtk_widget_show_all(gc->ge->results_window);
Jens Axboe3650a3c2012-03-05 14:09:03 +01001144 gdk_threads_leave();
1145}
1146
Jens Axboe084d1c62012-03-03 20:28:07 +01001147static void gfio_text_op(struct fio_client *client, struct fio_net_cmd *cmd)
Stephen M. Camerona1820202012-02-24 08:17:31 +01001148{
Jens Axboe9b260bd2012-03-06 11:02:52 +01001149 struct cmd_text_pdu *p = (struct cmd_text_pdu *) cmd->payload;
Jens Axboe2f99deb2012-03-09 14:37:29 +01001150 struct gui *ui = &main_ui;
Jens Axboe9b260bd2012-03-06 11:02:52 +01001151 GtkTreeIter iter;
1152 struct tm *tm;
1153 time_t sec;
1154 char tmp[64], timebuf[80];
Stephen M. Cameron736f2df2012-02-24 08:17:32 +01001155
Jens Axboe9b260bd2012-03-06 11:02:52 +01001156 sec = p->log_sec;
1157 tm = localtime(&sec);
1158 strftime(tmp, sizeof(tmp), "%Y-%m-%d %H:%M:%S", tm);
1159 sprintf(timebuf, "%s.%03ld", tmp, p->log_usec / 1000);
1160
Stephen M. Cameron736f2df2012-02-24 08:17:32 +01001161 gdk_threads_enter();
Jens Axboe9b260bd2012-03-06 11:02:52 +01001162
Jens Axboe2f99deb2012-03-09 14:37:29 +01001163 gtk_list_store_append(ui->log_model, &iter);
1164 gtk_list_store_set(ui->log_model, &iter, 0, timebuf, -1);
1165 gtk_list_store_set(ui->log_model, &iter, 1, client->hostname, -1);
1166 gtk_list_store_set(ui->log_model, &iter, 2, p->level, -1);
1167 gtk_list_store_set(ui->log_model, &iter, 3, p->buf, -1);
Jens Axboe9b260bd2012-03-06 11:02:52 +01001168
Jens Axboe6b79c802012-03-08 10:51:36 +01001169 if (p->level == FIO_LOG_ERR)
Jens Axboe2f99deb2012-03-09 14:37:29 +01001170 view_log(NULL, (gpointer) ui);
Jens Axboe6b79c802012-03-08 10:51:36 +01001171
Stephen M. Cameron736f2df2012-02-24 08:17:32 +01001172 gdk_threads_leave();
Stephen M. Camerona1820202012-02-24 08:17:31 +01001173}
1174
1175static void gfio_disk_util_op(struct fio_client *client, struct fio_net_cmd *cmd)
1176{
Jens Axboee0681f32012-03-06 12:14:42 +01001177 struct cmd_du_pdu *p = (struct cmd_du_pdu *) cmd->payload;
1178 struct gfio_client *gc = client->client_data;
1179 GtkWidget *box, *frame, *entry, *vbox;
Jens Axboe604cfe32012-03-07 19:51:36 +01001180 double util;
1181 char tmp[16];
Jens Axboee0681f32012-03-06 12:14:42 +01001182
Jens Axboe0050e5f2012-03-06 09:23:27 +01001183 gdk_threads_enter();
Jens Axboee0681f32012-03-06 12:14:42 +01001184
Jens Axboe45dcb2e2012-03-07 16:16:50 +01001185 if (!gc->results_widget)
Jens Axboee0681f32012-03-06 12:14:42 +01001186 goto out;
Jens Axboee0681f32012-03-06 12:14:42 +01001187
1188 if (!gc->disk_util_frame) {
1189 gc->disk_util_frame = gtk_frame_new("Disk utilization");
1190 gtk_box_pack_start(GTK_BOX(gc->results_widget), gc->disk_util_frame, FALSE, FALSE, 5);
1191 }
1192
1193 vbox = gtk_vbox_new(FALSE, 3);
1194 gtk_container_add(GTK_CONTAINER(gc->disk_util_frame), vbox);
1195
1196 frame = gtk_frame_new((char *) p->dus.name);
1197 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 2);
1198
1199 box = gtk_vbox_new(FALSE, 3);
1200 gtk_container_add(GTK_CONTAINER(frame), box);
1201
1202 frame = gtk_frame_new("Read");
1203 gtk_box_pack_start(GTK_BOX(box), frame, FALSE, FALSE, 2);
1204 vbox = gtk_hbox_new(TRUE, 3);
1205 gtk_container_add(GTK_CONTAINER(frame), vbox);
1206 entry = new_info_entry_in_frame(vbox, "IOs");
1207 entry_set_int_value(entry, p->dus.ios[0]);
1208 entry = new_info_entry_in_frame(vbox, "Merges");
1209 entry_set_int_value(entry, p->dus.merges[0]);
1210 entry = new_info_entry_in_frame(vbox, "Sectors");
1211 entry_set_int_value(entry, p->dus.sectors[0]);
1212 entry = new_info_entry_in_frame(vbox, "Ticks");
1213 entry_set_int_value(entry, p->dus.ticks[0]);
1214
1215 frame = gtk_frame_new("Write");
1216 gtk_box_pack_start(GTK_BOX(box), frame, FALSE, FALSE, 2);
1217 vbox = gtk_hbox_new(TRUE, 3);
1218 gtk_container_add(GTK_CONTAINER(frame), vbox);
1219 entry = new_info_entry_in_frame(vbox, "IOs");
1220 entry_set_int_value(entry, p->dus.ios[1]);
1221 entry = new_info_entry_in_frame(vbox, "Merges");
1222 entry_set_int_value(entry, p->dus.merges[1]);
1223 entry = new_info_entry_in_frame(vbox, "Sectors");
1224 entry_set_int_value(entry, p->dus.sectors[1]);
1225 entry = new_info_entry_in_frame(vbox, "Ticks");
1226 entry_set_int_value(entry, p->dus.ticks[1]);
1227
1228 frame = gtk_frame_new("Shared");
1229 gtk_box_pack_start(GTK_BOX(box), frame, FALSE, FALSE, 2);
1230 vbox = gtk_hbox_new(TRUE, 3);
1231 gtk_container_add(GTK_CONTAINER(frame), vbox);
1232 entry = new_info_entry_in_frame(vbox, "IO ticks");
1233 entry_set_int_value(entry, p->dus.io_ticks);
1234 entry = new_info_entry_in_frame(vbox, "Time in queue");
1235 entry_set_int_value(entry, p->dus.time_in_queue);
1236
Jens Axboe604cfe32012-03-07 19:51:36 +01001237 util = 0.0;
1238 if (p->dus.msec)
1239 util = (double) 100 * p->dus.io_ticks / (double) p->dus.msec;
1240 if (util > 100.0)
1241 util = 100.0;
1242
1243 sprintf(tmp, "%3.2f%%", util);
1244 entry = new_info_entry_in_frame(vbox, "Disk utilization");
1245 gtk_entry_set_text(GTK_ENTRY(entry), tmp);
1246
Jens Axboee0681f32012-03-06 12:14:42 +01001247 gtk_widget_show_all(gc->results_widget);
1248out:
Jens Axboe0050e5f2012-03-06 09:23:27 +01001249 gdk_threads_leave();
Stephen M. Camerona1820202012-02-24 08:17:31 +01001250}
1251
Jens Axboe3650a3c2012-03-05 14:09:03 +01001252extern int sum_stat_clients;
1253extern struct thread_stat client_ts;
1254extern struct group_run_stats client_gs;
1255
1256static int sum_stat_nr;
1257
Jens Axboe89e5fad2012-03-05 09:21:12 +01001258static void gfio_thread_status_op(struct fio_client *client,
1259 struct fio_net_cmd *cmd)
Stephen M. Camerona1820202012-02-24 08:17:31 +01001260{
Jens Axboe3650a3c2012-03-05 14:09:03 +01001261 struct cmd_ts_pdu *p = (struct cmd_ts_pdu *) cmd->payload;
1262
1263 gfio_display_ts(client, &p->ts, &p->rs);
1264
1265 if (sum_stat_clients == 1)
1266 return;
1267
1268 sum_thread_stats(&client_ts, &p->ts, sum_stat_nr);
1269 sum_group_stats(&client_gs, &p->rs);
1270
1271 client_ts.members++;
1272 client_ts.groupid = p->ts.groupid;
1273
1274 if (++sum_stat_nr == sum_stat_clients) {
1275 strcpy(client_ts.name, "All clients");
1276 gfio_display_ts(client, &client_ts, &client_gs);
1277 }
Stephen M. Camerona1820202012-02-24 08:17:31 +01001278}
1279
Jens Axboe89e5fad2012-03-05 09:21:12 +01001280static void gfio_group_stats_op(struct fio_client *client,
1281 struct fio_net_cmd *cmd)
Stephen M. Camerona1820202012-02-24 08:17:31 +01001282{
Jens Axboe98ceabd2012-03-09 08:53:28 +01001283 /* We're ignoring group stats for now */
Stephen M. Camerona1820202012-02-24 08:17:31 +01001284}
1285
Jens Axboe2f99deb2012-03-09 14:37:29 +01001286static gint on_config_drawing_area(GtkWidget *w, GdkEventConfigure *event,
1287 gpointer data)
Stephen M. Cameron3ea48b82012-03-07 19:40:58 +01001288{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001289 struct gfio_graphs *g = data;
1290
Stephen M. Cameron57f9d282012-03-11 11:36:51 +01001291 graph_set_size(g->iops_graph, w->allocation.width / 2.0, w->allocation.height);
1292 graph_set_position(g->iops_graph, w->allocation.width / 2.0, 0.0);
1293 graph_set_size(g->bandwidth_graph, w->allocation.width / 2.0, w->allocation.height);
1294 graph_set_position(g->bandwidth_graph, 0, 0);
Stephen M. Cameron3ea48b82012-03-07 19:40:58 +01001295 return TRUE;
1296}
1297
Stephen M. Cameron57f9d282012-03-11 11:36:51 +01001298static void draw_graph(struct graph *g, cairo_t *cr)
1299{
1300 line_graph_draw(g, cr);
1301 cairo_stroke(cr);
1302}
1303
Jens Axboe93e2db22012-03-13 09:45:22 +01001304static gboolean graph_tooltip(GtkWidget *w, gint x, gint y,
1305 gboolean keyboard_mode, GtkTooltip *tooltip,
1306 gpointer data)
1307{
1308 struct gfio_graphs *g = data;
1309 const char *text = NULL;
1310
1311 if (graph_contains_xy(g->iops_graph, x, y))
1312 text = graph_find_tooltip(g->iops_graph, x, y);
1313 else if (graph_contains_xy(g->bandwidth_graph, x, y))
1314 text = graph_find_tooltip(g->bandwidth_graph, x, y);
1315
1316 if (text) {
1317 gtk_tooltip_set_text(tooltip, text);
1318 return TRUE;
1319 }
1320
1321 return FALSE;
1322}
1323
Jens Axboe2fd3bb02012-03-07 08:07:39 +01001324static int on_expose_drawing_area(GtkWidget *w, GdkEvent *event, gpointer p)
1325{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001326 struct gfio_graphs *g = p;
Jens Axboe2fd3bb02012-03-07 08:07:39 +01001327 cairo_t *cr;
1328
1329 cr = gdk_cairo_create(w->window);
Jens Axboe93e2db22012-03-13 09:45:22 +01001330
1331 if (graph_has_tooltips(g->iops_graph) ||
1332 graph_has_tooltips(g->bandwidth_graph)) {
1333 g_object_set(w, "has-tooltip", TRUE, NULL);
1334 g_signal_connect(w, "query-tooltip", G_CALLBACK(graph_tooltip), g);
1335 }
1336
Jens Axboe2fd3bb02012-03-07 08:07:39 +01001337 cairo_set_source_rgb(cr, 0, 0, 0);
Stephen M. Cameron57f9d282012-03-11 11:36:51 +01001338 draw_graph(g->iops_graph, cr);
1339 draw_graph(g->bandwidth_graph, cr);
Jens Axboe2fd3bb02012-03-07 08:07:39 +01001340 cairo_destroy(cr);
1341
1342 return FALSE;
1343}
1344
Jens Axboe2f99deb2012-03-09 14:37:29 +01001345/*
1346 * Client specific ETA
1347 */
1348static void gfio_update_client_eta(struct fio_client *client, struct jobs_eta *je)
Jens Axboe3e47bd22012-02-29 13:45:02 +01001349{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001350 struct gfio_client *gc = client->client_data;
1351 struct gui_entry *ge = gc->ge;
Jens Axboe3e47bd22012-02-29 13:45:02 +01001352 static int eta_good;
1353 char eta_str[128];
1354 char output[256];
1355 char tmp[32];
1356 double perc = 0.0;
1357 int i2p = 0;
1358
Jens Axboe0050e5f2012-03-06 09:23:27 +01001359 gdk_threads_enter();
1360
Jens Axboe3e47bd22012-02-29 13:45:02 +01001361 eta_str[0] = '\0';
1362 output[0] = '\0';
1363
1364 if (je->eta_sec != INT_MAX && je->elapsed_sec) {
1365 perc = (double) je->elapsed_sec / (double) (je->elapsed_sec + je->eta_sec);
1366 eta_to_str(eta_str, je->eta_sec);
1367 }
1368
1369 sprintf(tmp, "%u", je->nr_running);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001370 gtk_entry_set_text(GTK_ENTRY(ge->eta.jobs), tmp);
Jens Axboe3e47bd22012-02-29 13:45:02 +01001371 sprintf(tmp, "%u", je->files_open);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001372 gtk_entry_set_text(GTK_ENTRY(ge->eta.files), tmp);
Jens Axboe3e47bd22012-02-29 13:45:02 +01001373
1374#if 0
1375 if (je->m_rate[0] || je->m_rate[1] || je->t_rate[0] || je->t_rate[1]) {
1376 if (je->m_rate || je->t_rate) {
1377 char *tr, *mr;
1378
1379 mr = num2str(je->m_rate, 4, 0, i2p);
1380 tr = num2str(je->t_rate, 4, 0, i2p);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001381 gtk_entry_set_text(GTK_ENTRY(ge->eta);
Jens Axboe3e47bd22012-02-29 13:45:02 +01001382 p += sprintf(p, ", CR=%s/%s KB/s", tr, mr);
1383 free(tr);
1384 free(mr);
1385 } else if (je->m_iops || je->t_iops)
1386 p += sprintf(p, ", CR=%d/%d IOPS", je->t_iops, je->m_iops);
Jens Axboeebbd89c2012-03-02 11:21:13 +01001387
Jens Axboe2f99deb2012-03-09 14:37:29 +01001388 gtk_entry_set_text(GTK_ENTRY(ge->eta.cr_bw), "---");
1389 gtk_entry_set_text(GTK_ENTRY(ge->eta.cr_iops), "---");
1390 gtk_entry_set_text(GTK_ENTRY(ge->eta.cw_bw), "---");
1391 gtk_entry_set_text(GTK_ENTRY(ge->eta.cw_iops), "---");
Jens Axboe3e47bd22012-02-29 13:45:02 +01001392#endif
1393
1394 if (je->eta_sec != INT_MAX && je->nr_running) {
1395 char *iops_str[2];
1396 char *rate_str[2];
1397
1398 if ((!je->eta_sec && !eta_good) || je->nr_ramp == je->nr_running)
1399 strcpy(output, "-.-% done");
1400 else {
1401 eta_good = 1;
1402 perc *= 100.0;
1403 sprintf(output, "%3.1f%% done", perc);
1404 }
1405
1406 rate_str[0] = num2str(je->rate[0], 5, 10, i2p);
1407 rate_str[1] = num2str(je->rate[1], 5, 10, i2p);
1408
1409 iops_str[0] = num2str(je->iops[0], 4, 1, 0);
1410 iops_str[1] = num2str(je->iops[1], 4, 1, 0);
1411
Jens Axboe2f99deb2012-03-09 14:37:29 +01001412 gtk_entry_set_text(GTK_ENTRY(ge->eta.read_bw), rate_str[0]);
1413 gtk_entry_set_text(GTK_ENTRY(ge->eta.read_iops), iops_str[0]);
1414 gtk_entry_set_text(GTK_ENTRY(ge->eta.write_bw), rate_str[1]);
1415 gtk_entry_set_text(GTK_ENTRY(ge->eta.write_iops), iops_str[1]);
Jens Axboe3e47bd22012-02-29 13:45:02 +01001416
Jens Axboe93e2db22012-03-13 09:45:22 +01001417 graph_add_xy_data(ge->graphs.iops_graph, "Read IOPS", je->elapsed_sec, je->iops[0], iops_str[0]);
1418 graph_add_xy_data(ge->graphs.iops_graph, "Write IOPS", je->elapsed_sec, je->iops[1], iops_str[1]);
1419 graph_add_xy_data(ge->graphs.bandwidth_graph, "Read Bandwidth", je->elapsed_sec, je->rate[0], rate_str[0]);
1420 graph_add_xy_data(ge->graphs.bandwidth_graph, "Write Bandwidth", je->elapsed_sec, je->rate[1], rate_str[1]);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001421
1422 free(rate_str[0]);
1423 free(rate_str[1]);
1424 free(iops_str[0]);
1425 free(iops_str[1]);
1426 }
1427
1428 if (eta_str[0]) {
1429 char *dst = output + strlen(output);
1430
1431 sprintf(dst, " - %s", eta_str);
1432 }
1433
Jens Axboe9988ca72012-03-09 15:14:06 +01001434 gfio_update_thread_status(ge, output, perc);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001435 gdk_threads_leave();
1436}
1437
1438/*
1439 * Update ETA in main window for all clients
1440 */
1441static void gfio_update_all_eta(struct jobs_eta *je)
1442{
1443 struct gui *ui = &main_ui;
1444 static int eta_good;
1445 char eta_str[128];
1446 char output[256];
1447 double perc = 0.0;
1448 int i2p = 0;
1449
1450 gdk_threads_enter();
1451
1452 eta_str[0] = '\0';
1453 output[0] = '\0';
1454
1455 if (je->eta_sec != INT_MAX && je->elapsed_sec) {
1456 perc = (double) je->elapsed_sec / (double) (je->elapsed_sec + je->eta_sec);
1457 eta_to_str(eta_str, je->eta_sec);
1458 }
1459
1460#if 0
1461 if (je->m_rate[0] || je->m_rate[1] || je->t_rate[0] || je->t_rate[1]) {
1462 if (je->m_rate || je->t_rate) {
1463 char *tr, *mr;
1464
1465 mr = num2str(je->m_rate, 4, 0, i2p);
1466 tr = num2str(je->t_rate, 4, 0, i2p);
1467 gtk_entry_set_text(GTK_ENTRY(ui->eta);
1468 p += sprintf(p, ", CR=%s/%s KB/s", tr, mr);
1469 free(tr);
1470 free(mr);
1471 } else if (je->m_iops || je->t_iops)
1472 p += sprintf(p, ", CR=%d/%d IOPS", je->t_iops, je->m_iops);
1473
1474 gtk_entry_set_text(GTK_ENTRY(ui->eta.cr_bw), "---");
1475 gtk_entry_set_text(GTK_ENTRY(ui->eta.cr_iops), "---");
1476 gtk_entry_set_text(GTK_ENTRY(ui->eta.cw_bw), "---");
1477 gtk_entry_set_text(GTK_ENTRY(ui->eta.cw_iops), "---");
1478#endif
1479
Jens Axboe3863d1a2012-03-09 17:39:05 +01001480 entry_set_int_value(ui->eta.jobs, je->nr_running);
1481
Jens Axboe2f99deb2012-03-09 14:37:29 +01001482 if (je->eta_sec != INT_MAX && je->nr_running) {
1483 char *iops_str[2];
1484 char *rate_str[2];
1485
1486 if ((!je->eta_sec && !eta_good) || je->nr_ramp == je->nr_running)
1487 strcpy(output, "-.-% done");
1488 else {
1489 eta_good = 1;
1490 perc *= 100.0;
1491 sprintf(output, "%3.1f%% done", perc);
1492 }
1493
1494 rate_str[0] = num2str(je->rate[0], 5, 10, i2p);
1495 rate_str[1] = num2str(je->rate[1], 5, 10, i2p);
1496
1497 iops_str[0] = num2str(je->iops[0], 4, 1, 0);
1498 iops_str[1] = num2str(je->iops[1], 4, 1, 0);
1499
1500 gtk_entry_set_text(GTK_ENTRY(ui->eta.read_bw), rate_str[0]);
1501 gtk_entry_set_text(GTK_ENTRY(ui->eta.read_iops), iops_str[0]);
1502 gtk_entry_set_text(GTK_ENTRY(ui->eta.write_bw), rate_str[1]);
1503 gtk_entry_set_text(GTK_ENTRY(ui->eta.write_iops), iops_str[1]);
1504
Jens Axboe93e2db22012-03-13 09:45:22 +01001505 graph_add_xy_data(ui->graphs.iops_graph, "Read IOPS", je->elapsed_sec, je->iops[0], iops_str[0]);
1506 graph_add_xy_data(ui->graphs.iops_graph, "Write IOPS", je->elapsed_sec, je->iops[1], iops_str[1]);
1507 graph_add_xy_data(ui->graphs.bandwidth_graph, "Read Bandwidth", je->elapsed_sec, je->rate[0], rate_str[0]);
1508 graph_add_xy_data(ui->graphs.bandwidth_graph, "Write Bandwidth", je->elapsed_sec, je->rate[1], rate_str[1]);
Jens Axboe2fd3bb02012-03-07 08:07:39 +01001509
Jens Axboe3e47bd22012-02-29 13:45:02 +01001510 free(rate_str[0]);
1511 free(rate_str[1]);
1512 free(iops_str[0]);
1513 free(iops_str[1]);
1514 }
1515
1516 if (eta_str[0]) {
1517 char *dst = output + strlen(output);
1518
1519 sprintf(dst, " - %s", eta_str);
1520 }
1521
Jens Axboe9988ca72012-03-09 15:14:06 +01001522 gfio_update_thread_status_all(output, perc);
Jens Axboe0050e5f2012-03-06 09:23:27 +01001523 gdk_threads_leave();
Jens Axboe3e47bd22012-02-29 13:45:02 +01001524}
1525
Stephen M. Camerona1820202012-02-24 08:17:31 +01001526static void gfio_probe_op(struct fio_client *client, struct fio_net_cmd *cmd)
1527{
Jens Axboe843ad232012-02-29 11:44:53 +01001528 struct cmd_probe_pdu *probe = (struct cmd_probe_pdu *) cmd->payload;
Jens Axboe88f6e7a2012-03-06 12:55:29 +01001529 struct gfio_client *gc = client->client_data;
Jens Axboe2f99deb2012-03-09 14:37:29 +01001530 struct gui_entry *ge = gc->ge;
Jens Axboe843ad232012-02-29 11:44:53 +01001531 const char *os, *arch;
1532 char buf[64];
1533
1534 os = fio_get_os_string(probe->os);
1535 if (!os)
1536 os = "unknown";
1537
1538 arch = fio_get_arch_string(probe->arch);
1539 if (!arch)
1540 os = "unknown";
1541
1542 if (!client->name)
1543 client->name = strdup((char *) probe->hostname);
1544
Jens Axboe0050e5f2012-03-06 09:23:27 +01001545 gdk_threads_enter();
1546
Jens Axboe2f99deb2012-03-09 14:37:29 +01001547 gtk_label_set_text(GTK_LABEL(ge->probe.hostname), (char *) probe->hostname);
1548 gtk_label_set_text(GTK_LABEL(ge->probe.os), os);
1549 gtk_label_set_text(GTK_LABEL(ge->probe.arch), arch);
Jens Axboe843ad232012-02-29 11:44:53 +01001550 sprintf(buf, "%u.%u.%u", probe->fio_major, probe->fio_minor, probe->fio_patch);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001551 gtk_label_set_text(GTK_LABEL(ge->probe.fio_ver), buf);
Jens Axboe88f6e7a2012-03-06 12:55:29 +01001552
Jens Axboe85dd01e2012-03-12 14:33:16 +01001553 gfio_set_state(ge, GE_STATE_CONNECTED);
Jens Axboe0050e5f2012-03-06 09:23:27 +01001554
1555 gdk_threads_leave();
Stephen M. Camerona1820202012-02-24 08:17:31 +01001556}
1557
Jens Axboe9988ca72012-03-09 15:14:06 +01001558static void gfio_update_thread_status(struct gui_entry *ge,
1559 char *status_message, double perc)
1560{
1561 static char message[100];
1562 const char *m = message;
1563
1564 strncpy(message, status_message, sizeof(message) - 1);
1565 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(ge->thread_status_pb), m);
1566 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(ge->thread_status_pb), perc / 100.0);
1567 gtk_widget_queue_draw(main_ui.window);
1568}
1569
1570static void gfio_update_thread_status_all(char *status_message, double perc)
Stephen M. Cameron5b7573a2012-02-24 08:17:31 +01001571{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001572 struct gui *ui = &main_ui;
Stephen M. Cameron5b7573a2012-02-24 08:17:31 +01001573 static char message[100];
1574 const char *m = message;
1575
1576 strncpy(message, status_message, sizeof(message) - 1);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001577 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(ui->thread_status_pb), m);
1578 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(ui->thread_status_pb), perc / 100.0);
1579 gtk_widget_queue_draw(ui->window);
Stephen M. Cameron5b7573a2012-02-24 08:17:31 +01001580}
1581
Jens Axboe3ec62ec2012-03-01 12:01:29 +01001582static void gfio_quit_op(struct fio_client *client)
1583{
Jens Axboee0681f32012-03-06 12:14:42 +01001584 struct gfio_client *gc = client->client_data;
Jens Axboe3ec62ec2012-03-01 12:01:29 +01001585
Jens Axboe0050e5f2012-03-06 09:23:27 +01001586 gdk_threads_enter();
Jens Axboe85dd01e2012-03-12 14:33:16 +01001587 gfio_set_state(gc->ge, GE_STATE_NEW);
Jens Axboe0050e5f2012-03-06 09:23:27 +01001588 gdk_threads_leave();
Jens Axboe3ec62ec2012-03-01 12:01:29 +01001589}
1590
Jens Axboe807f9972012-03-02 10:25:24 +01001591static void gfio_add_job_op(struct fio_client *client, struct fio_net_cmd *cmd)
1592{
1593 struct cmd_add_job_pdu *p = (struct cmd_add_job_pdu *) cmd->payload;
Jens Axboee0681f32012-03-06 12:14:42 +01001594 struct gfio_client *gc = client->client_data;
Jens Axboedcaeb602012-03-08 19:45:37 +01001595 struct thread_options *o = &gc->o;
Jens Axboe2f99deb2012-03-09 14:37:29 +01001596 struct gui_entry *ge = gc->ge;
Jens Axboe807f9972012-03-02 10:25:24 +01001597 char tmp[8];
Jens Axboe807f9972012-03-02 10:25:24 +01001598
Jens Axboedcaeb602012-03-08 19:45:37 +01001599 convert_thread_options_to_cpu(o, &p->top);
Jens Axboe807f9972012-03-02 10:25:24 +01001600
Jens Axboe0050e5f2012-03-06 09:23:27 +01001601 gdk_threads_enter();
1602
Jens Axboe2f99deb2012-03-09 14:37:29 +01001603 gtk_label_set_text(GTK_LABEL(ge->page_label), (gchar *) o->name);
1604
Jens Axboe3863d1a2012-03-09 17:39:05 +01001605 gtk_combo_box_append_text(GTK_COMBO_BOX(ge->eta.names), (gchar *) o->name);
1606 gtk_combo_box_set_active(GTK_COMBO_BOX(ge->eta.names), 0);
1607
Jens Axboec80b74b2012-03-12 10:23:28 +01001608 multitext_add_entry(&ge->eta.iotype, ddir_str(o->td_ddir));
1609 multitext_add_entry(&ge->eta.ioengine, (const char *) o->ioengine);
Jens Axboe807f9972012-03-02 10:25:24 +01001610
Jens Axboedcaeb602012-03-08 19:45:37 +01001611 sprintf(tmp, "%u", o->iodepth);
Jens Axboec80b74b2012-03-12 10:23:28 +01001612 multitext_add_entry(&ge->eta.iodepth, tmp);
1613
1614 multitext_set_entry(&ge->eta.iotype, 0);
1615 multitext_set_entry(&ge->eta.ioengine, 0);
1616 multitext_set_entry(&ge->eta.iodepth, 0);
Jens Axboe0050e5f2012-03-06 09:23:27 +01001617
Jens Axboedcaeb602012-03-08 19:45:37 +01001618 gc->job_added++;
1619
Jens Axboe85dd01e2012-03-12 14:33:16 +01001620 gfio_set_state(ge, GE_STATE_JOB_SENT);
1621
Jens Axboe0050e5f2012-03-06 09:23:27 +01001622 gdk_threads_leave();
Jens Axboe807f9972012-03-02 10:25:24 +01001623}
1624
Jens Axboeed727a42012-03-02 12:14:40 +01001625static void gfio_client_timed_out(struct fio_client *client)
1626{
Jens Axboee0681f32012-03-06 12:14:42 +01001627 struct gfio_client *gc = client->client_data;
Jens Axboeed727a42012-03-02 12:14:40 +01001628 char buf[256];
1629
1630 gdk_threads_enter();
1631
Jens Axboe85dd01e2012-03-12 14:33:16 +01001632 gfio_set_state(gc->ge, GE_STATE_NEW);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001633 clear_ge_ui_info(gc->ge);
Jens Axboeed727a42012-03-02 12:14:40 +01001634
1635 sprintf(buf, "Client %s: timeout talking to server.\n", client->hostname);
Jens Axboe16ce5ad2012-03-12 11:56:09 +01001636 show_info_dialog(gc->ge->ui, "Network timeout", buf);
Jens Axboeed727a42012-03-02 12:14:40 +01001637
1638 gdk_threads_leave();
1639}
1640
Jens Axboe6b79c802012-03-08 10:51:36 +01001641static void gfio_client_stop(struct fio_client *client, struct fio_net_cmd *cmd)
1642{
1643 struct gfio_client *gc = client->client_data;
1644
1645 gdk_threads_enter();
1646
Jens Axboe85dd01e2012-03-12 14:33:16 +01001647 gfio_set_state(gc->ge, GE_STATE_JOB_DONE);
Jens Axboe6b79c802012-03-08 10:51:36 +01001648
1649 if (gc->err_entry)
1650 entry_set_int_value(gc->err_entry, client->error);
1651
1652 gdk_threads_leave();
1653}
1654
Jens Axboe85dd01e2012-03-12 14:33:16 +01001655static void gfio_client_start(struct fio_client *client, struct fio_net_cmd *cmd)
1656{
1657 struct gfio_client *gc = client->client_data;
1658
1659 gdk_threads_enter();
1660 gfio_set_state(gc->ge, GE_STATE_JOB_STARTED);
1661 gdk_threads_leave();
1662}
1663
1664static void gfio_client_job_start(struct fio_client *client, struct fio_net_cmd *cmd)
1665{
1666 struct gfio_client *gc = client->client_data;
1667
1668 gdk_threads_enter();
1669 gfio_set_state(gc->ge, GE_STATE_JOB_RUNNING);
1670 gdk_threads_leave();
1671}
1672
Stephen M. Camerona1820202012-02-24 08:17:31 +01001673struct client_ops gfio_client_ops = {
Jens Axboe0420ba62012-02-29 11:16:52 +01001674 .text_op = gfio_text_op,
1675 .disk_util = gfio_disk_util_op,
1676 .thread_status = gfio_thread_status_op,
1677 .group_stats = gfio_group_stats_op,
Jens Axboe2f99deb2012-03-09 14:37:29 +01001678 .jobs_eta = gfio_update_client_eta,
1679 .eta = gfio_update_all_eta,
Jens Axboe0420ba62012-02-29 11:16:52 +01001680 .probe = gfio_probe_op,
Jens Axboe3ec62ec2012-03-01 12:01:29 +01001681 .quit = gfio_quit_op,
Jens Axboe807f9972012-03-02 10:25:24 +01001682 .add_job = gfio_add_job_op,
Jens Axboeed727a42012-03-02 12:14:40 +01001683 .timed_out = gfio_client_timed_out,
Jens Axboe6b79c802012-03-08 10:51:36 +01001684 .stop = gfio_client_stop,
Jens Axboe85dd01e2012-03-12 14:33:16 +01001685 .start = gfio_client_start,
1686 .job_start = gfio_client_job_start,
Jens Axboe6433ee02012-03-09 20:10:51 +01001687 .eta_msec = FIO_CLIENT_DEF_ETA_MSEC,
Jens Axboe3ec62ec2012-03-01 12:01:29 +01001688 .stay_connected = 1,
Stephen M. Camerona1820202012-02-24 08:17:31 +01001689};
1690
Stephen M. Cameronff1f3282012-02-24 08:17:30 +01001691static void quit_clicked(__attribute__((unused)) GtkWidget *widget,
1692 __attribute__((unused)) gpointer data)
1693{
1694 gtk_main_quit();
1695}
1696
Stephen M. Cameron25927252012-02-24 08:17:31 +01001697static void *job_thread(void *arg)
Stephen M. Cameronf3074002012-02-24 08:17:30 +01001698{
Jens Axboea9eccde2012-03-09 14:59:42 +01001699 struct gui *ui = arg;
1700
1701 ui->handler_running = 1;
Stephen M. Cameron25927252012-02-24 08:17:31 +01001702 fio_handle_clients(&gfio_client_ops);
Jens Axboea9eccde2012-03-09 14:59:42 +01001703 ui->handler_running = 0;
Stephen M. Cameron25927252012-02-24 08:17:31 +01001704 return NULL;
1705}
1706
Jens Axboe2f99deb2012-03-09 14:37:29 +01001707static int send_job_files(struct gui_entry *ge)
Stephen M. Cameron60f6b332012-02-24 08:17:32 +01001708{
Jens Axboe9988ca72012-03-09 15:14:06 +01001709 struct gfio_client *gc = ge->client;
Jens Axboe441013b2012-03-01 08:01:52 +01001710 int i, ret = 0;
Stephen M. Cameron60f6b332012-02-24 08:17:32 +01001711
Jens Axboe2f99deb2012-03-09 14:37:29 +01001712 for (i = 0; i < ge->nr_job_files; i++) {
Jens Axboe9988ca72012-03-09 15:14:06 +01001713 ret = fio_client_send_ini(gc->client, ge->job_files[i]);
Jens Axboec7249262012-03-09 17:11:04 +01001714 if (ret < 0) {
1715 GError *error;
1716
1717 error = g_error_new(g_quark_from_string("fio"), 1, "Failed to send file %s: %s\n", ge->job_files[i], strerror(-ret));
1718 report_error(error);
1719 g_error_free(error);
1720 break;
1721 } else if (ret)
Jens Axboe441013b2012-03-01 08:01:52 +01001722 break;
1723
Jens Axboe2f99deb2012-03-09 14:37:29 +01001724 free(ge->job_files[i]);
1725 ge->job_files[i] = NULL;
Jens Axboe441013b2012-03-01 08:01:52 +01001726 }
Jens Axboe2f99deb2012-03-09 14:37:29 +01001727 while (i < ge->nr_job_files) {
1728 free(ge->job_files[i]);
1729 ge->job_files[i] = NULL;
Jens Axboe441013b2012-03-01 08:01:52 +01001730 i++;
Jens Axboe0420ba62012-02-29 11:16:52 +01001731 }
1732
Jens Axboe2c77d832012-03-13 19:02:04 +01001733 free(ge->job_files);
1734 ge->job_files = NULL;
Jens Axboe3af45202012-03-13 09:59:53 +01001735 ge->nr_job_files = 0;
Jens Axboe441013b2012-03-01 08:01:52 +01001736 return ret;
Stephen M. Cameron60f6b332012-02-24 08:17:32 +01001737}
1738
Jens Axboe63a130b2012-03-06 20:08:59 +01001739static void *server_thread(void *arg)
1740{
1741 is_backend = 1;
1742 gfio_server_running = 1;
1743 fio_start_server(NULL);
1744 gfio_server_running = 0;
1745 return NULL;
1746}
1747
Jens Axboe2f99deb2012-03-09 14:37:29 +01001748static void gfio_start_server(void)
Jens Axboe63a130b2012-03-06 20:08:59 +01001749{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001750 struct gui *ui = &main_ui;
1751
Jens Axboe63a130b2012-03-06 20:08:59 +01001752 if (!gfio_server_running) {
1753 gfio_server_running = 1;
1754 pthread_create(&ui->server_t, NULL, server_thread, NULL);
Jens Axboee34f6ad2012-03-06 20:47:15 +01001755 pthread_detach(ui->server_t);
Jens Axboe63a130b2012-03-06 20:08:59 +01001756 }
1757}
1758
Stephen M. Cameron25927252012-02-24 08:17:31 +01001759static void start_job_clicked(__attribute__((unused)) GtkWidget *widget,
1760 gpointer data)
1761{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001762 struct gui_entry *ge = data;
1763 struct gfio_client *gc = ge->client;
Stephen M. Cameron25927252012-02-24 08:17:31 +01001764
Jens Axboe78cb2fe2012-03-12 23:05:29 +01001765 if (gc)
1766 fio_start_client(gc->client);
Stephen M. Cameronf3074002012-02-24 08:17:30 +01001767}
1768
Jens Axboedf06f222012-03-02 13:32:04 +01001769static void file_open(GtkWidget *w, gpointer data);
1770
1771static void connect_clicked(GtkWidget *widget, gpointer data)
Jens Axboe3e47bd22012-02-29 13:45:02 +01001772{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001773 struct gui_entry *ge = data;
1774 struct gfio_client *gc = ge->client;
Jens Axboe3ec62ec2012-03-01 12:01:29 +01001775
Jens Axboe85dd01e2012-03-12 14:33:16 +01001776 if (ge->state == GE_STATE_NEW) {
Jens Axboec7249262012-03-09 17:11:04 +01001777 int ret;
1778
Jens Axboe2f99deb2012-03-09 14:37:29 +01001779 if (!ge->nr_job_files)
Jens Axboecf4b0442012-03-12 15:09:42 +01001780 file_open(widget, ge->ui);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001781 if (!ge->nr_job_files)
1782 return;
1783
1784 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(ge->thread_status_pb), "No jobs running");
1785 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(ge->thread_status_pb), 0.0);
Jens Axboec7249262012-03-09 17:11:04 +01001786 ret = fio_client_connect(gc->client);
1787 if (!ret) {
Jens Axboea9eccde2012-03-09 14:59:42 +01001788 if (!ge->ui->handler_running)
1789 pthread_create(&ge->ui->t, NULL, job_thread, ge->ui);
Jens Axboe85dd01e2012-03-12 14:33:16 +01001790 gfio_set_state(ge, GE_STATE_CONNECTED);
Jens Axboec7249262012-03-09 17:11:04 +01001791 } else {
1792 GError *error;
1793
1794 error = g_error_new(g_quark_from_string("fio"), 1, "Failed to connect to %s: %s\n", ge->client->client->hostname, strerror(-ret));
1795 report_error(error);
1796 g_error_free(error);
Jens Axboe69406b92012-03-06 14:00:42 +01001797 }
Jens Axboedf06f222012-03-02 13:32:04 +01001798 } else {
Jens Axboe2f99deb2012-03-09 14:37:29 +01001799 fio_client_terminate(gc->client);
Jens Axboe85dd01e2012-03-12 14:33:16 +01001800 gfio_set_state(ge, GE_STATE_NEW);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001801 clear_ge_ui_info(ge);
Jens Axboedf06f222012-03-02 13:32:04 +01001802 }
Jens Axboe3e47bd22012-02-29 13:45:02 +01001803}
1804
Jens Axboeb9d2f302012-03-08 20:36:28 +01001805static void send_clicked(GtkWidget *widget, gpointer data)
1806{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001807 struct gui_entry *ge = data;
Jens Axboeb9d2f302012-03-08 20:36:28 +01001808
Jens Axboe2f99deb2012-03-09 14:37:29 +01001809 if (send_job_files(ge)) {
Jens Axboec7249262012-03-09 17:11:04 +01001810 GError *error;
1811
1812 error = g_error_new(g_quark_from_string("fio"), 1, "Failed to send one or more job files for client %s", ge->client->client->hostname);
1813 report_error(error);
1814 g_error_free(error);
1815
Jens Axboe2f99deb2012-03-09 14:37:29 +01001816 gtk_widget_set_sensitive(ge->button[START_JOB_BUTTON], 1);
Jens Axboeb9d2f302012-03-08 20:36:28 +01001817 }
Jens Axboeb9d2f302012-03-08 20:36:28 +01001818}
1819
Jens Axboe2f99deb2012-03-09 14:37:29 +01001820static GtkWidget *add_button(GtkWidget *buttonbox,
1821 struct button_spec *buttonspec, gpointer data)
Stephen M. Cameronf3074002012-02-24 08:17:30 +01001822{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001823 GtkWidget *button = gtk_button_new_with_label(buttonspec->buttontext);
1824
1825 g_signal_connect(button, "clicked", G_CALLBACK(buttonspec->f), data);
1826 gtk_box_pack_start(GTK_BOX(buttonbox), button, FALSE, FALSE, 3);
1827 gtk_widget_set_tooltip_text(button, buttonspec->tooltiptext);
1828 gtk_widget_set_sensitive(button, !buttonspec->start_insensitive);
1829
1830 return button;
Stephen M. Cameronf3074002012-02-24 08:17:30 +01001831}
1832
Jens Axboe2f99deb2012-03-09 14:37:29 +01001833static void add_buttons(struct gui_entry *ge, struct button_spec *buttonlist,
1834 int nbuttons)
Stephen M. Cameronf3074002012-02-24 08:17:30 +01001835{
1836 int i;
1837
Stephen M. Cameronf3074002012-02-24 08:17:30 +01001838 for (i = 0; i < nbuttons; i++)
Jens Axboe2f99deb2012-03-09 14:37:29 +01001839 ge->button[i] = add_button(ge->buttonbox, &buttonlist[i], ge);
Stephen M. Cameronf3074002012-02-24 08:17:30 +01001840}
1841
Jens Axboe0420ba62012-02-29 11:16:52 +01001842static void on_info_bar_response(GtkWidget *widget, gint response,
1843 gpointer data)
1844{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001845 struct gui *ui = &main_ui;
1846
Jens Axboe0420ba62012-02-29 11:16:52 +01001847 if (response == GTK_RESPONSE_OK) {
1848 gtk_widget_destroy(widget);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001849 ui->error_info_bar = NULL;
Jens Axboe0420ba62012-02-29 11:16:52 +01001850 }
1851}
1852
Jens Axboedf06f222012-03-02 13:32:04 +01001853void report_error(GError *error)
Jens Axboe0420ba62012-02-29 11:16:52 +01001854{
Jens Axboe2f99deb2012-03-09 14:37:29 +01001855 struct gui *ui = &main_ui;
1856
1857 if (ui->error_info_bar == NULL) {
1858 ui->error_info_bar = gtk_info_bar_new_with_buttons(GTK_STOCK_OK,
Jens Axboe0420ba62012-02-29 11:16:52 +01001859 GTK_RESPONSE_OK,
1860 NULL);
Jens Axboe2f99deb2012-03-09 14:37:29 +01001861 g_signal_connect(ui->error_info_bar, "response", G_CALLBACK(on_info_bar_response), NULL);
1862 gtk_info_bar_set_message_type(GTK_INFO_BAR(ui->error_info_bar),
Jens Axboe0420ba62012-02-29 11:16:52 +01001863 GTK_MESSAGE_ERROR);
1864
Jens Axboe2f99deb2012-03-09 14:37:29 +01001865 ui->error_label = gtk_label_new(error->message);
1866 GtkWidget *container = gtk_info_bar_get_content_area(GTK_INFO_BAR(ui->error_info_bar));
1867 gtk_container_add(GTK_CONTAINER(container), ui->error_label);
Jens Axboe0420ba62012-02-29 11:16:52 +01001868
Jens Axboe2f99deb2012-03-09 14:37:29 +01001869 gtk_box_pack_start(GTK_BOX(ui->vbox), ui->error_info_bar, FALSE, FALSE, 0);
1870 gtk_widget_show_all(ui->vbox);
Jens Axboe0420ba62012-02-29 11:16:52 +01001871 } else {
1872 char buffer[256];
1873 snprintf(buffer, sizeof(buffer), "Failed to open file.");
Jens Axboe2f99deb2012-03-09 14:37:29 +01001874 gtk_label_set(GTK_LABEL(ui->error_label), buffer);
Jens Axboe0420ba62012-02-29 11:16:52 +01001875 }
1876}
1877
Jens Axboe62bc9372012-03-07 11:45:07 +01001878struct connection_widgets
1879{
1880 GtkWidget *hentry;
1881 GtkWidget *combo;
1882 GtkWidget *button;
1883};
1884
1885static void hostname_cb(GtkEntry *entry, gpointer data)
1886{
1887 struct connection_widgets *cw = data;
1888 int uses_net = 0, is_localhost = 0;
1889 const gchar *text;
1890 gchar *ctext;
1891
1892 /*
1893 * Check whether to display the 'auto start backend' box
1894 * or not. Show it if we are a localhost and using network,
1895 * or using a socket.
1896 */
1897 ctext = gtk_combo_box_get_active_text(GTK_COMBO_BOX(cw->combo));
1898 if (!ctext || !strncmp(ctext, "IPv4", 4) || !strncmp(ctext, "IPv6", 4))
1899 uses_net = 1;
1900 g_free(ctext);
1901
1902 if (uses_net) {
1903 text = gtk_entry_get_text(GTK_ENTRY(cw->hentry));
1904 if (!strcmp(text, "127.0.0.1") || !strcmp(text, "localhost") ||
1905 !strcmp(text, "::1") || !strcmp(text, "ip6-localhost") ||
1906 !strcmp(text, "ip6-loopback"))
1907 is_localhost = 1;
1908 }
1909
1910 if (!uses_net || is_localhost) {
1911 gtk_toggle_button_set_active(GTK_TOGGLE_BUTTON(cw->button), 1);
1912 gtk_widget_set_sensitive(cw->button, 1);
1913 } else {
1914 gtk_toggle_button_set_active(GTK_TOGGLE_BUTTON(cw->button), 0);
1915 gtk_widget_set_sensitive(cw->button, 0);
1916 }
1917}
1918
Jens Axboeb9f3c7e2012-03-02 14:27:17 +01001919static int get_connection_details(char **host, int *port, int *type,
1920 int *server_start)
Jens Axboea7a42ce2012-03-02 13:12:04 +01001921{
Jens Axboe62bc9372012-03-07 11:45:07 +01001922 GtkWidget *dialog, *box, *vbox, *hbox, *frame, *pentry;
1923 struct connection_widgets cw;
Jens Axboea7a42ce2012-03-02 13:12:04 +01001924 char *typeentry;
1925
1926 dialog = gtk_dialog_new_with_buttons("Connection details",
Jens Axboe2f99deb2012-03-09 14:37:29 +01001927 GTK_WINDOW(main_ui.window),
Jens Axboea7a42ce2012-03-02 13:12:04 +01001928 GTK_DIALOG_DESTROY_WITH_PARENT,
1929 GTK_STOCK_OK, GTK_RESPONSE_ACCEPT,
1930 GTK_STOCK_CANCEL, GTK_RESPONSE_REJECT, NULL);
1931
1932 frame = gtk_frame_new("Hostname / socket name");
Jens Axboef1299092012-03-07 20:00:02 +01001933 /* gtk_dialog_get_content_area() is 2.14 and newer */
1934 vbox = GTK_DIALOG(dialog)->vbox;
Jens Axboea7a42ce2012-03-02 13:12:04 +01001935 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
1936
1937 box = gtk_vbox_new(FALSE, 6);
1938 gtk_container_add(GTK_CONTAINER(frame), box);
1939
1940 hbox = gtk_hbox_new(TRUE, 10);
1941 gtk_box_pack_start(GTK_BOX(box), hbox, FALSE, FALSE, 0);
Jens Axboe62bc9372012-03-07 11:45:07 +01001942 cw.hentry = gtk_entry_new();
1943 gtk_entry_set_text(GTK_ENTRY(cw.hentry), "localhost");
1944 gtk_box_pack_start(GTK_BOX(hbox), cw.hentry, TRUE, TRUE, 0);
Jens Axboea7a42ce2012-03-02 13:12:04 +01001945
1946 frame = gtk_frame_new("Port");
1947 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
1948 box = gtk_vbox_new(FALSE, 10);
1949 gtk_container_add(GTK_CONTAINER(frame), box);
1950
1951 hbox = gtk_hbox_new(TRUE, 4);
1952 gtk_box_pack_start(GTK_BOX(box), hbox, FALSE, FALSE, 0);
1953 pentry = create_spinbutton(hbox, 1, 65535, FIO_NET_PORT);
1954
1955 frame = gtk_frame_new("Type");
1956 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
1957 box = gtk_vbox_new(FALSE, 10);
1958 gtk_container_add(GTK_CONTAINER(frame), box);
1959
1960 hbox = gtk_hbox_new(TRUE, 4);
1961 gtk_box_pack_start(GTK_BOX(box), hbox, FALSE, FALSE, 0);
1962
Jens Axboe62bc9372012-03-07 11:45:07 +01001963 cw.combo = gtk_combo_box_new_text();
1964 gtk_combo_box_append_text(GTK_COMBO_BOX(cw.combo), "IPv4");
1965 gtk_combo_box_append_text(GTK_COMBO_BOX(cw.combo), "IPv6");
1966 gtk_combo_box_append_text(GTK_COMBO_BOX(cw.combo), "local socket");
1967 gtk_combo_box_set_active(GTK_COMBO_BOX(cw.combo), 0);
Jens Axboea7a42ce2012-03-02 13:12:04 +01001968
Jens Axboe62bc9372012-03-07 11:45:07 +01001969 gtk_container_add(GTK_CONTAINER(hbox), cw.combo);
Jens Axboea7a42ce2012-03-02 13:12:04 +01001970
Jens Axboeb9f3c7e2012-03-02 14:27:17 +01001971 frame = gtk_frame_new("Options");
1972 gtk_box_pack_start(GTK_BOX(vbox), frame, FALSE, FALSE, 5);
1973 box = gtk_vbox_new(FALSE, 10);
1974 gtk_container_add(GTK_CONTAINER(frame), box);
1975
1976 hbox = gtk_hbox_new(TRUE, 4);
1977 gtk_box_pack_start(GTK_BOX(box), hbox, FALSE, FALSE, 0);
1978
Jens Axboe62bc9372012-03-07 11:45:07 +01001979 cw.button = gtk_check_button_new_with_label("Auto-spawn fio backend");
1980 gtk_toggle_button_set_active(GTK_TOGGLE_BUTTON(cw.button), 1);
1981 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.");
1982 gtk_box_pack_start(GTK_BOX(hbox), cw.button, FALSE, FALSE, 6);
1983
1984 /*
1985 * Connect edit signal, so we can show/not-show the auto start button
1986 */
1987 g_signal_connect(GTK_OBJECT(cw.hentry), "changed", G_CALLBACK(hostname_cb), &cw);
1988 g_signal_connect(GTK_OBJECT(cw.combo), "changed", G_CALLBACK(hostname_cb), &cw);
Jens Axboeb9f3c7e2012-03-02 14:27:17 +01001989
Jens Axboea7a42ce2012-03-02 13:12:04 +01001990 gtk_widget_show_all(dialog);
1991
1992 if (gtk_dialog_run(GTK_DIALOG(dialog)) != GTK_RESPONSE_ACCEPT) {
1993 gtk_widget_destroy(dialog);
1994 return 1;
1995 }
1996
Jens Axboe62bc9372012-03-07 11:45:07 +01001997 *host = strdup(gtk_entry_get_text(GTK_ENTRY(cw.hentry)));
Jens Axboea7a42ce2012-03-02 13:12:04 +01001998 *port = gtk_spin_button_get_value_as_int(GTK_SPIN_BUTTON(pentry));
1999
Jens Axboe62bc9372012-03-07 11:45:07 +01002000 typeentry = gtk_combo_box_get_active_text(GTK_COMBO_BOX(cw.combo));
Jens Axboea7a42ce2012-03-02 13:12:04 +01002001 if (!typeentry || !strncmp(typeentry, "IPv4", 4))
2002 *type = Fio_client_ipv4;
2003 else if (!strncmp(typeentry, "IPv6", 4))
2004 *type = Fio_client_ipv6;
2005 else
2006 *type = Fio_client_socket;
2007 g_free(typeentry);
2008
Jens Axboe62bc9372012-03-07 11:45:07 +01002009 *server_start = gtk_toggle_button_get_active(GTK_TOGGLE_BUTTON(cw.button));
Jens Axboeb9f3c7e2012-03-02 14:27:17 +01002010
Jens Axboea7a42ce2012-03-02 13:12:04 +01002011 gtk_widget_destroy(dialog);
2012 return 0;
2013}
2014
Jens Axboe2f99deb2012-03-09 14:37:29 +01002015static void gfio_client_added(struct gui_entry *ge, struct fio_client *client)
Jens Axboee0681f32012-03-06 12:14:42 +01002016{
2017 struct gfio_client *gc;
2018
2019 gc = malloc(sizeof(*gc));
2020 memset(gc, 0, sizeof(*gc));
Jens Axboe2f99deb2012-03-09 14:37:29 +01002021 gc->ge = ge;
Jens Axboe343cb4a2012-03-09 17:16:51 +01002022 gc->client = fio_get_client(client);
Jens Axboeb9d2f302012-03-08 20:36:28 +01002023
Jens Axboe2f99deb2012-03-09 14:37:29 +01002024 ge->client = gc;
Jens Axboee0681f32012-03-06 12:14:42 +01002025
2026 client->client_data = gc;
2027}
2028
Jens Axboe2f99deb2012-03-09 14:37:29 +01002029static GtkWidget *new_client_page(struct gui_entry *ge);
2030
2031static struct gui_entry *alloc_new_gui_entry(struct gui *ui)
2032{
2033 struct gui_entry *ge;
2034
2035 ge = malloc(sizeof(*ge));
2036 memset(ge, 0, sizeof(*ge));
Jens Axboe85dd01e2012-03-12 14:33:16 +01002037 ge->state = GE_STATE_NEW;
Jens Axboe2f99deb2012-03-09 14:37:29 +01002038 INIT_FLIST_HEAD(&ge->list);
2039 flist_add_tail(&ge->list, &ui->list);
2040 ge->ui = ui;
2041 return ge;
2042}
2043
2044/*
2045 * FIXME: need more handling here
2046 */
2047static void ge_destroy(GtkWidget *w, gpointer data)
2048{
2049 struct gui_entry *ge = data;
Jens Axboe343cb4a2012-03-09 17:16:51 +01002050 struct gfio_client *gc = ge->client;
2051
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002052 if (gc && gc->client) {
Jens Axboe85dd01e2012-03-12 14:33:16 +01002053 if (ge->state >= GE_STATE_CONNECTED)
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002054 fio_client_terminate(gc->client);
2055
Jens Axboe343cb4a2012-03-09 17:16:51 +01002056 fio_put_client(gc->client);
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002057 }
Jens Axboe2f99deb2012-03-09 14:37:29 +01002058
2059 flist_del(&ge->list);
2060 free(ge);
2061}
2062
2063static struct gui_entry *get_new_ge_with_tab(const char *name)
2064{
2065 struct gui_entry *ge;
2066
2067 ge = alloc_new_gui_entry(&main_ui);
2068
2069 ge->vbox = new_client_page(ge);
2070 g_signal_connect(ge->vbox, "destroy", G_CALLBACK(ge_destroy), ge);
2071
2072 ge->page_label = gtk_label_new(name);
2073 ge->page_num = gtk_notebook_append_page(GTK_NOTEBOOK(main_ui.notebook), ge->vbox, ge->page_label);
2074
2075 gtk_widget_show_all(main_ui.window);
2076 return ge;
2077}
2078
2079static void file_new(GtkWidget *w, gpointer data)
2080{
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002081 struct gui *ui = (struct gui *) data;
2082 struct gui_entry *ge;
2083
2084 ge = get_new_ge_with_tab("Untitled");
2085 gtk_notebook_set_current_page(GTK_NOTEBOOK(ui->notebook), ge->page_num);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002086}
2087
2088/*
2089 * Return the 'ge' corresponding to the tab. If the active tab is the
2090 * main tab, open a new tab.
2091 */
Jens Axboe38634cb2012-03-13 12:26:41 +01002092static struct gui_entry *get_ge_from_page(gint cur_page, int *created)
Jens Axboe2f99deb2012-03-09 14:37:29 +01002093{
2094 struct flist_head *entry;
2095 struct gui_entry *ge;
2096
Jens Axboe38634cb2012-03-13 12:26:41 +01002097 if (!cur_page) {
2098 if (created)
2099 *created = 1;
Jens Axboe2f99deb2012-03-09 14:37:29 +01002100 return get_new_ge_with_tab("Untitled");
Jens Axboe38634cb2012-03-13 12:26:41 +01002101 }
2102
2103 if (created)
2104 *created = 0;
Jens Axboe2f99deb2012-03-09 14:37:29 +01002105
2106 flist_for_each(entry, &main_ui.list) {
2107 ge = flist_entry(entry, struct gui_entry, list);
2108 if (ge->page_num == cur_page)
2109 return ge;
2110 }
2111
2112 return NULL;
2113}
2114
Jens Axboe85dd01e2012-03-12 14:33:16 +01002115static struct gui_entry *get_ge_from_cur_tab(struct gui *ui)
2116{
2117 gint cur_page;
2118
2119 /*
2120 * Main tab is tab 0, so any current page other than 0 holds
2121 * a ge entry.
2122 */
2123 cur_page = gtk_notebook_get_current_page(GTK_NOTEBOOK(ui->notebook));
2124 if (cur_page)
Jens Axboe38634cb2012-03-13 12:26:41 +01002125 return get_ge_from_page(cur_page, NULL);
Jens Axboe85dd01e2012-03-12 14:33:16 +01002126
2127 return NULL;
2128}
2129
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002130static void file_close(GtkWidget *w, gpointer data)
2131{
2132 struct gui *ui = (struct gui *) data;
Jens Axboe85dd01e2012-03-12 14:33:16 +01002133 struct gui_entry *ge;
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002134
2135 /*
2136 * Can't close the main tab
2137 */
Jens Axboe85dd01e2012-03-12 14:33:16 +01002138 ge = get_ge_from_cur_tab(ui);
2139 if (ge) {
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002140 gtk_widget_destroy(ge->vbox);
2141 return;
2142 }
2143
Jens Axboef5c67262012-03-13 08:20:41 +01002144 if (!flist_empty(&ui->list)) {
2145 show_info_dialog(ui, "Error", "The main page view cannot be closed\n");
2146 return;
2147 }
2148
2149 gtk_main_quit();
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002150}
2151
Jens Axboe38634cb2012-03-13 12:26:41 +01002152static void file_add_recent(struct gui *ui, const gchar *uri)
2153{
Jens Axboea217ba72012-03-13 20:29:39 +01002154 GtkRecentData grd;
2155
2156 memset(&grd, 0, sizeof(grd));
2157 grd.display_name = strdup("gfio");
2158 grd.description = strdup("Fio job file");
2159 grd.mime_type = strdup(GFIO_MIME);
2160 grd.app_name = strdup(g_get_application_name());
2161 grd.app_exec = strdup("gfio %f/%u");
2162
2163 gtk_recent_manager_add_full(ui->recentmanager, uri, &grd);
Jens Axboe38634cb2012-03-13 12:26:41 +01002164}
2165
2166static gchar *get_filename_from_uri(const gchar *uri)
2167{
2168 if (strncmp(uri, "file://", 7))
2169 return strdup(uri);
2170
2171 return strdup(uri + 7);
2172}
2173
2174static int do_file_open(struct gui_entry *ge, const gchar *uri, char *host,
2175 int type, int port)
2176{
2177 struct fio_client *client;
2178 gchar *filename;
2179
2180 filename = get_filename_from_uri(uri);
2181
2182 ge->job_files = realloc(ge->job_files, (ge->nr_job_files + 1) * sizeof(char *));
2183 ge->job_files[ge->nr_job_files] = strdup(filename);
2184 ge->nr_job_files++;
2185
2186 client = fio_client_add_explicit(&gfio_client_ops, host, type, port);
2187 if (!client) {
2188 GError *error;
2189
2190 error = g_error_new(g_quark_from_string("fio"), 1,
2191 "Failed to add client %s", host);
2192 report_error(error);
2193 g_error_free(error);
2194 return 1;
2195 }
2196
2197 gfio_client_added(ge, client);
2198 file_add_recent(ge->ui, uri);
2199 return 0;
2200}
2201
Jens Axboea6790902012-03-13 15:16:11 +01002202static int do_file_open_with_tab(struct gui *ui, const gchar *uri)
Jens Axboe0420ba62012-02-29 11:16:52 +01002203{
Jens Axboea6790902012-03-13 15:16:11 +01002204 int port, type, server_start;
Jens Axboe2f99deb2012-03-09 14:37:29 +01002205 struct gui_entry *ge;
2206 gint cur_page;
Jens Axboe38634cb2012-03-13 12:26:41 +01002207 char *host;
Jens Axboea6790902012-03-13 15:16:11 +01002208 int ret, ge_is_new = 0;
Jens Axboe2f99deb2012-03-09 14:37:29 +01002209
2210 /*
2211 * Creates new tab if current tab is the main window, or the
2212 * current tab already has a client.
2213 */
2214 cur_page = gtk_notebook_get_current_page(GTK_NOTEBOOK(ui->notebook));
Jens Axboe38634cb2012-03-13 12:26:41 +01002215 ge = get_ge_from_page(cur_page, &ge_is_new);
2216 if (ge->client) {
Jens Axboe2f99deb2012-03-09 14:37:29 +01002217 ge = get_new_ge_with_tab("Untitled");
Jens Axboe38634cb2012-03-13 12:26:41 +01002218 ge_is_new = 1;
2219 }
Jens Axboe2f99deb2012-03-09 14:37:29 +01002220
2221 gtk_notebook_set_current_page(GTK_NOTEBOOK(ui->notebook), ge->page_num);
Jens Axboe0420ba62012-02-29 11:16:52 +01002222
Jens Axboea6790902012-03-13 15:16:11 +01002223 if (get_connection_details(&host, &port, &type, &server_start)) {
2224 if (ge_is_new)
2225 gtk_widget_destroy(ge->vbox);
2226
2227 return 1;
2228 }
2229
2230 ret = do_file_open(ge, uri, host, type, port);
2231
2232 free(host);
2233
2234 if (!ret) {
2235 if (server_start)
2236 gfio_start_server();
2237 } else {
2238 if (ge_is_new)
2239 gtk_widget_destroy(ge->vbox);
2240 }
2241
2242 return ret;
2243}
2244
2245static void recent_open(GtkAction *action, gpointer data)
2246{
2247 struct gui *ui = (struct gui *) data;
2248 GtkRecentInfo *info;
2249 const gchar *uri;
2250
2251 info = g_object_get_data(G_OBJECT(action), "gtk-recent-info");
2252 uri = gtk_recent_info_get_uri(info);
2253
2254 do_file_open_with_tab(ui, uri);
2255}
2256
2257static void file_open(GtkWidget *w, gpointer data)
2258{
2259 struct gui *ui = data;
2260 GtkWidget *dialog;
2261 GSList *filenames, *fn_glist;
2262 GtkFileFilter *filter;
2263
Jens Axboe0420ba62012-02-29 11:16:52 +01002264 dialog = gtk_file_chooser_dialog_new("Open File",
Jens Axboe63a130b2012-03-06 20:08:59 +01002265 GTK_WINDOW(ui->window),
Jens Axboe0420ba62012-02-29 11:16:52 +01002266 GTK_FILE_CHOOSER_ACTION_OPEN,
2267 GTK_STOCK_CANCEL, GTK_RESPONSE_CANCEL,
2268 GTK_STOCK_OPEN, GTK_RESPONSE_ACCEPT,
2269 NULL);
2270 gtk_file_chooser_set_select_multiple(GTK_FILE_CHOOSER(dialog), TRUE);
2271
2272 filter = gtk_file_filter_new();
2273 gtk_file_filter_add_pattern(filter, "*.fio");
2274 gtk_file_filter_add_pattern(filter, "*.job");
Jens Axboe2d262992012-03-07 08:19:30 +01002275 gtk_file_filter_add_pattern(filter, "*.ini");
Jens Axboe38634cb2012-03-13 12:26:41 +01002276 gtk_file_filter_add_mime_type(filter, GFIO_MIME);
Jens Axboe0420ba62012-02-29 11:16:52 +01002277 gtk_file_filter_set_name(filter, "Fio job file");
2278 gtk_file_chooser_set_filter(GTK_FILE_CHOOSER(dialog), filter);
2279
2280 if (gtk_dialog_run(GTK_DIALOG(dialog)) != GTK_RESPONSE_ACCEPT) {
2281 gtk_widget_destroy(dialog);
2282 return;
2283 }
2284
2285 fn_glist = gtk_file_chooser_get_filenames(GTK_FILE_CHOOSER(dialog));
Jens Axboea7a42ce2012-03-02 13:12:04 +01002286
2287 gtk_widget_destroy(dialog);
2288
Jens Axboe0420ba62012-02-29 11:16:52 +01002289 filenames = fn_glist;
2290 while (filenames != NULL) {
Jens Axboea6790902012-03-13 15:16:11 +01002291 if (do_file_open_with_tab(ui, filenames->data))
2292 break;
Jens Axboe0420ba62012-02-29 11:16:52 +01002293 filenames = g_slist_next(filenames);
2294 }
Jens Axboe63a130b2012-03-06 20:08:59 +01002295
Jens Axboe0420ba62012-02-29 11:16:52 +01002296 g_slist_free(fn_glist);
Jens Axboe0420ba62012-02-29 11:16:52 +01002297}
2298
2299static void file_save(GtkWidget *w, gpointer data)
2300{
Jens Axboe63a130b2012-03-06 20:08:59 +01002301 struct gui *ui = data;
Jens Axboe0420ba62012-02-29 11:16:52 +01002302 GtkWidget *dialog;
2303
2304 dialog = gtk_file_chooser_dialog_new("Save File",
Jens Axboe63a130b2012-03-06 20:08:59 +01002305 GTK_WINDOW(ui->window),
Jens Axboe0420ba62012-02-29 11:16:52 +01002306 GTK_FILE_CHOOSER_ACTION_SAVE,
2307 GTK_STOCK_CANCEL, GTK_RESPONSE_CANCEL,
2308 GTK_STOCK_SAVE, GTK_RESPONSE_ACCEPT,
2309 NULL);
2310
2311 gtk_file_chooser_set_do_overwrite_confirmation(GTK_FILE_CHOOSER(dialog), TRUE);
2312 gtk_file_chooser_set_current_name(GTK_FILE_CHOOSER(dialog), "Untitled document");
2313
2314 if (gtk_dialog_run(GTK_DIALOG(dialog)) == GTK_RESPONSE_ACCEPT) {
2315 char *filename;
2316
2317 filename = gtk_file_chooser_get_filename(GTK_FILE_CHOOSER(dialog));
2318 // save_job_file(filename);
2319 g_free(filename);
2320 }
2321 gtk_widget_destroy(dialog);
2322}
2323
Jens Axboe9b260bd2012-03-06 11:02:52 +01002324static void view_log_destroy(GtkWidget *w, gpointer data)
2325{
2326 struct gui *ui = (struct gui *) data;
2327
2328 gtk_widget_ref(ui->log_tree);
2329 gtk_container_remove(GTK_CONTAINER(w), ui->log_tree);
2330 gtk_widget_destroy(w);
Jens Axboe4cbe7212012-03-06 13:36:17 +01002331 ui->log_view = NULL;
Jens Axboe9b260bd2012-03-06 11:02:52 +01002332}
2333
2334static void view_log(GtkWidget *w, gpointer data)
2335{
Jens Axboe4cbe7212012-03-06 13:36:17 +01002336 GtkWidget *win, *scroll, *vbox, *box;
2337 struct gui *ui = (struct gui *) data;
Jens Axboe9b260bd2012-03-06 11:02:52 +01002338
Jens Axboe4cbe7212012-03-06 13:36:17 +01002339 if (ui->log_view)
2340 return;
2341
2342 ui->log_view = win = gtk_window_new(GTK_WINDOW_TOPLEVEL);
Jens Axboe9b260bd2012-03-06 11:02:52 +01002343 gtk_window_set_title(GTK_WINDOW(win), "Log");
Jens Axboe4cbe7212012-03-06 13:36:17 +01002344 gtk_window_set_default_size(GTK_WINDOW(win), 700, 500);
Jens Axboe9b260bd2012-03-06 11:02:52 +01002345
Jens Axboe4cbe7212012-03-06 13:36:17 +01002346 scroll = gtk_scrolled_window_new(NULL, NULL);
Jens Axboe9b260bd2012-03-06 11:02:52 +01002347
Jens Axboe4cbe7212012-03-06 13:36:17 +01002348 gtk_container_set_border_width(GTK_CONTAINER(scroll), 5);
2349
2350 gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(scroll), GTK_POLICY_AUTOMATIC, GTK_POLICY_AUTOMATIC);
2351
2352 box = gtk_hbox_new(TRUE, 0);
2353 gtk_box_pack_start_defaults(GTK_BOX(box), ui->log_tree);
2354 g_signal_connect(box, "destroy", G_CALLBACK(view_log_destroy), ui);
2355 gtk_scrolled_window_add_with_viewport(GTK_SCROLLED_WINDOW(scroll), box);
2356
2357 vbox = gtk_vbox_new(TRUE, 5);
2358 gtk_box_pack_start_defaults(GTK_BOX(vbox), scroll);
2359
2360 gtk_container_add(GTK_CONTAINER(win), vbox);
Jens Axboe9b260bd2012-03-06 11:02:52 +01002361 gtk_widget_show_all(win);
2362}
2363
Jens Axboe85dd01e2012-03-12 14:33:16 +01002364static void connect_job_entry(GtkWidget *w, gpointer data)
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002365{
Jens Axboe85dd01e2012-03-12 14:33:16 +01002366 struct gui *ui = (struct gui *) data;
2367 struct gui_entry *ge;
2368
2369 ge = get_ge_from_cur_tab(ui);
2370 if (ge)
2371 connect_clicked(w, ge);
2372}
2373
2374static void send_job_entry(GtkWidget *w, gpointer data)
2375{
2376 struct gui *ui = (struct gui *) data;
2377 struct gui_entry *ge;
2378
2379 ge = get_ge_from_cur_tab(ui);
2380 if (ge)
2381 send_clicked(w, ge);
2382
2383}
2384
2385static void edit_job_entry(GtkWidget *w, gpointer data)
2386{
2387}
2388
2389static void start_job_entry(GtkWidget *w, gpointer data)
2390{
2391 struct gui *ui = (struct gui *) data;
2392 struct gui_entry *ge;
2393
2394 ge = get_ge_from_cur_tab(ui);
2395 if (ge)
2396 start_job_clicked(w, ge);
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002397}
2398
Jens Axboe8577f4f2012-03-09 19:28:27 +01002399static void __update_graph_limits(struct gfio_graphs *g)
2400{
2401 line_graph_set_data_count_limit(g->iops_graph, gfio_graph_limit);
2402 line_graph_set_data_count_limit(g->bandwidth_graph, gfio_graph_limit);
2403}
2404
2405static void update_graph_limits(void)
2406{
2407 struct flist_head *entry;
2408 struct gui_entry *ge;
2409
2410 __update_graph_limits(&main_ui.graphs);
2411
2412 flist_for_each(entry, &main_ui.list) {
2413 ge = flist_entry(entry, struct gui_entry, list);
2414 __update_graph_limits(&ge->graphs);
2415 }
2416}
2417
Jens Axboe46974a72012-03-02 19:34:13 +01002418static void preferences(GtkWidget *w, gpointer data)
2419{
Jens Axboef3e84402012-03-07 13:14:32 +01002420 GtkWidget *dialog, *frame, *box, **buttons, *vbox, *font;
Jens Axboe1cf6bca2012-03-09 20:20:17 +01002421 GtkWidget *hbox, *spin, *entry, *spin_int;
Jens Axboe46974a72012-03-02 19:34:13 +01002422 int i;
2423
2424 dialog = gtk_dialog_new_with_buttons("Preferences",
Jens Axboe2f99deb2012-03-09 14:37:29 +01002425 GTK_WINDOW(main_ui.window),
Jens Axboe46974a72012-03-02 19:34:13 +01002426 GTK_DIALOG_DESTROY_WITH_PARENT,
2427 GTK_STOCK_OK, GTK_RESPONSE_ACCEPT,
2428 GTK_STOCK_CANCEL, GTK_RESPONSE_REJECT,
2429 NULL);
2430
Jens Axboe8577f4f2012-03-09 19:28:27 +01002431 frame = gtk_frame_new("Graphing");
Jens Axboef3e84402012-03-07 13:14:32 +01002432 gtk_box_pack_start(GTK_BOX(GTK_DIALOG(dialog)->vbox), frame, FALSE, FALSE, 5);
2433 vbox = gtk_vbox_new(FALSE, 6);
2434 gtk_container_add(GTK_CONTAINER(frame), vbox);
2435
Jens Axboe1cf6bca2012-03-09 20:20:17 +01002436 hbox = gtk_hbox_new(FALSE, 5);
2437 gtk_box_pack_start(GTK_BOX(vbox), hbox, FALSE, FALSE, 5);
2438 entry = gtk_label_new("Font face to use for graph labels");
2439 gtk_box_pack_start(GTK_BOX(hbox), entry, TRUE, TRUE, 5);
2440
Jens Axboef3e84402012-03-07 13:14:32 +01002441 font = gtk_font_button_new();
Jens Axboe1cf6bca2012-03-09 20:20:17 +01002442 gtk_box_pack_start(GTK_BOX(hbox), font, FALSE, FALSE, 5);
Jens Axboef3e84402012-03-07 13:14:32 +01002443
Jens Axboe8577f4f2012-03-09 19:28:27 +01002444 box = gtk_vbox_new(FALSE, 6);
2445 gtk_box_pack_start(GTK_BOX(vbox), box, FALSE, FALSE, 5);
2446
2447 hbox = gtk_hbox_new(FALSE, 5);
Jens Axboe1cf6bca2012-03-09 20:20:17 +01002448 gtk_box_pack_start(GTK_BOX(box), hbox, TRUE, TRUE, 5);
Jens Axboe8577f4f2012-03-09 19:28:27 +01002449 entry = gtk_label_new("Maximum number of data points in graph (seconds)");
2450 gtk_box_pack_start(GTK_BOX(hbox), entry, FALSE, FALSE, 5);
2451
Jens Axboec05d9052012-03-11 13:05:35 +01002452 spin = create_spinbutton(hbox, 10, 1000000, gfio_graph_limit);
Jens Axboe8577f4f2012-03-09 19:28:27 +01002453
Jens Axboe1cf6bca2012-03-09 20:20:17 +01002454 box = gtk_vbox_new(FALSE, 6);
2455 gtk_box_pack_start(GTK_BOX(vbox), box, FALSE, FALSE, 5);
2456
2457 hbox = gtk_hbox_new(FALSE, 5);
2458 gtk_box_pack_start(GTK_BOX(box), hbox, TRUE, TRUE, 5);
2459 entry = gtk_label_new("Client ETA request interval (msec)");
2460 gtk_box_pack_start(GTK_BOX(hbox), entry, FALSE, FALSE, 5);
2461
2462 spin_int = create_spinbutton(hbox, 100, 100000, gfio_client_ops.eta_msec);
Jens Axboea31d9fa2012-03-09 20:23:05 +01002463 frame = gtk_frame_new("Debug logging");
2464 gtk_box_pack_start(GTK_BOX(GTK_DIALOG(dialog)->vbox), frame, FALSE, FALSE, 5);
2465 vbox = gtk_vbox_new(FALSE, 6);
2466 gtk_container_add(GTK_CONTAINER(frame), vbox);
2467
2468 box = gtk_hbox_new(FALSE, 6);
2469 gtk_container_add(GTK_CONTAINER(vbox), box);
2470
2471 buttons = malloc(sizeof(GtkWidget *) * FD_DEBUG_MAX);
2472
2473 for (i = 0; i < FD_DEBUG_MAX; i++) {
2474 if (i == 7) {
2475 box = gtk_hbox_new(FALSE, 6);
2476 gtk_container_add(GTK_CONTAINER(vbox), box);
2477 }
2478
2479
2480 buttons[i] = gtk_check_button_new_with_label(debug_levels[i].name);
2481 gtk_widget_set_tooltip_text(buttons[i], debug_levels[i].help);
2482 gtk_box_pack_start(GTK_BOX(box), buttons[i], FALSE, FALSE, 6);
2483 }
2484
Jens Axboe46974a72012-03-02 19:34:13 +01002485 gtk_widget_show_all(dialog);
2486
2487 if (gtk_dialog_run(GTK_DIALOG(dialog)) != GTK_RESPONSE_ACCEPT) {
2488 gtk_widget_destroy(dialog);
2489 return;
2490 }
2491
2492 for (i = 0; i < FD_DEBUG_MAX; i++) {
2493 int set;
2494
2495 set = gtk_toggle_button_get_active(GTK_TOGGLE_BUTTON(buttons[i]));
2496 if (set)
2497 fio_debug |= (1UL << i);
2498 }
2499
Jens Axboef3e84402012-03-07 13:14:32 +01002500 gfio_graph_font = strdup(gtk_font_button_get_font_name(GTK_FONT_BUTTON(font)));
Jens Axboe8577f4f2012-03-09 19:28:27 +01002501 gfio_graph_limit = gtk_spin_button_get_value_as_int(GTK_SPIN_BUTTON(spin));
2502 update_graph_limits();
Jens Axboe1cf6bca2012-03-09 20:20:17 +01002503 gfio_client_ops.eta_msec = gtk_spin_button_get_value_as_int(GTK_SPIN_BUTTON(spin_int));
Jens Axboe8577f4f2012-03-09 19:28:27 +01002504
Jens Axboe46974a72012-03-02 19:34:13 +01002505 gtk_widget_destroy(dialog);
2506}
2507
Jens Axboe0420ba62012-02-29 11:16:52 +01002508static void about_dialog(GtkWidget *w, gpointer data)
2509{
Jens Axboe81e4ea62012-03-07 14:18:28 +01002510 const char *authors[] = {
2511 "Jens Axboe <axboe@kernel.dk>",
2512 "Stephen Carmeron <stephenmcameron@gmail.com>",
2513 NULL
2514 };
Jens Axboe84a72ed2012-03-07 14:24:57 +01002515 const char *license[] = {
2516 "Fio is free software; you can redistribute it and/or modify "
2517 "it under the terms of the GNU General Public License as published by "
2518 "the Free Software Foundation; either version 2 of the License, or "
2519 "(at your option) any later version.\n",
2520 "Fio is distributed in the hope that it will be useful, "
2521 "but WITHOUT ANY WARRANTY; without even the implied warranty of "
2522 "MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the "
2523 "GNU General Public License for more details.\n",
2524 "You should have received a copy of the GNU General Public License "
2525 "along with Fio; if not, write to the Free Software Foundation, Inc., "
2526 "51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA\n"
2527 };
2528 char *license_trans;
2529
2530 license_trans = g_strconcat(license[0], "\n", license[1], "\n",
2531 license[2], "\n", NULL);
Jens Axboe81e4ea62012-03-07 14:18:28 +01002532
Jens Axboe0420ba62012-02-29 11:16:52 +01002533 gtk_show_about_dialog(NULL,
2534 "program-name", "gfio",
2535 "comments", "Gtk2 UI for fio",
Jens Axboe84a72ed2012-03-07 14:24:57 +01002536 "license", license_trans,
Jens Axboe81e4ea62012-03-07 14:18:28 +01002537 "website", "http://git.kernel.dk/?p=fio.git;a=summary",
2538 "authors", authors,
Jens Axboe0420ba62012-02-29 11:16:52 +01002539 "version", fio_version_string,
Jens Axboe81e4ea62012-03-07 14:18:28 +01002540 "copyright", "© 2012 Jens Axboe <axboe@kernel.dk>",
Jens Axboe0420ba62012-02-29 11:16:52 +01002541 "logo-icon-name", "fio",
2542 /* Must be last: */
Jens Axboe81e4ea62012-03-07 14:18:28 +01002543 "wrap-license", TRUE,
Jens Axboe0420ba62012-02-29 11:16:52 +01002544 NULL);
Jens Axboe84a72ed2012-03-07 14:24:57 +01002545
Jens Axboe2f99deb2012-03-09 14:37:29 +01002546 g_free(license_trans);
Jens Axboe0420ba62012-02-29 11:16:52 +01002547}
2548
2549static GtkActionEntry menu_items[] = {
Jens Axboe46974a72012-03-02 19:34:13 +01002550 { "FileMenuAction", GTK_STOCK_FILE, "File", NULL, NULL, NULL},
Jens Axboe9b260bd2012-03-06 11:02:52 +01002551 { "ViewMenuAction", GTK_STOCK_FILE, "View", NULL, NULL, NULL},
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002552 { "JobMenuAction", GTK_STOCK_FILE, "Job", NULL, NULL, NULL},
Jens Axboe46974a72012-03-02 19:34:13 +01002553 { "HelpMenuAction", GTK_STOCK_HELP, "Help", NULL, NULL, NULL},
Jens Axboe2f99deb2012-03-09 14:37:29 +01002554 { "NewFile", GTK_STOCK_NEW, "New", "<Control>N", NULL, G_CALLBACK(file_new) },
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002555 { "CloseFile", GTK_STOCK_CLOSE, "Close", "<Control>W", NULL, G_CALLBACK(file_close) },
Jens Axboe46974a72012-03-02 19:34:13 +01002556 { "OpenFile", GTK_STOCK_OPEN, NULL, "<Control>O", NULL, G_CALLBACK(file_open) },
2557 { "SaveFile", GTK_STOCK_SAVE, NULL, "<Control>S", NULL, G_CALLBACK(file_save) },
2558 { "Preferences", GTK_STOCK_PREFERENCES, NULL, "<Control>p", NULL, G_CALLBACK(preferences) },
Jens Axboe9b260bd2012-03-06 11:02:52 +01002559 { "ViewLog", NULL, "Log", "<Control>l", NULL, G_CALLBACK(view_log) },
Jens Axboe85dd01e2012-03-12 14:33:16 +01002560 { "ConnectJob", NULL, "Connect", "<Control>E", NULL, G_CALLBACK(connect_job_entry) },
2561 { "EditJob", NULL, "Edit job", "<Control>E", NULL, G_CALLBACK(edit_job_entry) },
2562 { "SendJob", NULL, "Send job", "<Control>X", NULL, G_CALLBACK(send_job_entry) },
2563 { "StartJob", NULL, "Start job", "<Control>L", NULL, G_CALLBACK(start_job_entry) },
Jens Axboe46974a72012-03-02 19:34:13 +01002564 { "Quit", GTK_STOCK_QUIT, NULL, "<Control>Q", NULL, G_CALLBACK(quit_clicked) },
2565 { "About", GTK_STOCK_ABOUT, NULL, NULL, NULL, G_CALLBACK(about_dialog) },
Jens Axboe0420ba62012-02-29 11:16:52 +01002566};
Jens Axboe3e47bd22012-02-29 13:45:02 +01002567static gint nmenu_items = sizeof(menu_items) / sizeof(menu_items[0]);
Jens Axboe0420ba62012-02-29 11:16:52 +01002568
2569static const gchar *ui_string = " \
2570 <ui> \
2571 <menubar name=\"MainMenu\"> \
2572 <menu name=\"FileMenu\" action=\"FileMenuAction\"> \
Jens Axboe2f99deb2012-03-09 14:37:29 +01002573 <menuitem name=\"New\" action=\"NewFile\" /> \
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002574 <menuitem name=\"Close\" action=\"CloseFile\" /> \
Jens Axboe2f99deb2012-03-09 14:37:29 +01002575 <separator name=\"Separator1\"/> \
Jens Axboe0420ba62012-02-29 11:16:52 +01002576 <menuitem name=\"Open\" action=\"OpenFile\" /> \
2577 <menuitem name=\"Save\" action=\"SaveFile\" /> \
Jens Axboe46974a72012-03-02 19:34:13 +01002578 <separator name=\"Separator2\"/> \
Jens Axboe2f99deb2012-03-09 14:37:29 +01002579 <menuitem name=\"Preferences\" action=\"Preferences\" /> \
2580 <separator name=\"Separator3\"/> \
Jens Axboe261f21d2012-03-12 14:58:22 +01002581 <placeholder name=\"FileRecentFiles\"/> \
2582 <separator name=\"Separator4\"/> \
Jens Axboe0420ba62012-02-29 11:16:52 +01002583 <menuitem name=\"Quit\" action=\"Quit\" /> \
2584 </menu> \
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002585 <menu name=\"JobMenu\" action=\"JobMenuAction\"> \
Jens Axboe85dd01e2012-03-12 14:33:16 +01002586 <menuitem name=\"Connect\" action=\"ConnectJob\" /> \
Jens Axboe261f21d2012-03-12 14:58:22 +01002587 <separator name=\"Separator5\"/> \
Jens Axboe85dd01e2012-03-12 14:33:16 +01002588 <menuitem name=\"Edit job\" action=\"EditJob\" /> \
2589 <menuitem name=\"Send job\" action=\"SendJob\" /> \
Jens Axboe261f21d2012-03-12 14:58:22 +01002590 <separator name=\"Separator6\"/> \
Jens Axboe85dd01e2012-03-12 14:33:16 +01002591 <menuitem name=\"Start job\" action=\"StartJob\" /> \
Jens Axboe16ce5ad2012-03-12 11:56:09 +01002592 </menu>\
Jens Axboe9b260bd2012-03-06 11:02:52 +01002593 <menu name=\"ViewMenu\" action=\"ViewMenuAction\"> \
2594 <menuitem name=\"Log\" action=\"ViewLog\" /> \
2595 </menu>\
Jens Axboe0420ba62012-02-29 11:16:52 +01002596 <menu name=\"Help\" action=\"HelpMenuAction\"> \
2597 <menuitem name=\"About\" action=\"About\" /> \
2598 </menu> \
2599 </menubar> \
2600 </ui> \
2601";
2602
Jens Axboe02421e62012-03-12 12:05:50 +01002603static void set_job_menu_visible(struct gui *ui, int visible)
2604{
2605 GtkWidget *job;
2606
2607 job = gtk_ui_manager_get_widget(ui->uimanager, "/MainMenu/JobMenu");
2608 gtk_widget_set_sensitive(job, visible);
2609}
2610
Jens Axboe4cbe7212012-03-06 13:36:17 +01002611static GtkWidget *get_menubar_menu(GtkWidget *window, GtkUIManager *ui_manager,
2612 struct gui *ui)
Jens Axboe0420ba62012-02-29 11:16:52 +01002613{
2614 GtkActionGroup *action_group = gtk_action_group_new("Menu");
2615 GError *error = 0;
2616
2617 action_group = gtk_action_group_new("Menu");
Jens Axboe4cbe7212012-03-06 13:36:17 +01002618 gtk_action_group_add_actions(action_group, menu_items, nmenu_items, ui);
Jens Axboe0420ba62012-02-29 11:16:52 +01002619
2620 gtk_ui_manager_insert_action_group(ui_manager, action_group, 0);
2621 gtk_ui_manager_add_ui_from_string(GTK_UI_MANAGER(ui_manager), ui_string, -1, &error);
2622
2623 gtk_window_add_accel_group(GTK_WINDOW(window), gtk_ui_manager_get_accel_group(ui_manager));
Jens Axboe02421e62012-03-12 12:05:50 +01002624
Jens Axboe0420ba62012-02-29 11:16:52 +01002625 return gtk_ui_manager_get_widget(ui_manager, "/MainMenu");
2626}
2627
2628void gfio_ui_setup(GtkSettings *settings, GtkWidget *menubar,
2629 GtkWidget *vbox, GtkUIManager *ui_manager)
2630{
2631 gtk_box_pack_start(GTK_BOX(vbox), menubar, FALSE, FALSE, 0);
2632}
2633
Jens Axboec80b74b2012-03-12 10:23:28 +01002634static void combo_entry_changed(GtkComboBox *box, gpointer data)
2635{
2636 struct gui_entry *ge = (struct gui_entry *) data;
2637 gint index;
2638
2639 index = gtk_combo_box_get_active(box);
2640
2641 multitext_set_entry(&ge->eta.iotype, index);
2642 multitext_set_entry(&ge->eta.ioengine, index);
2643 multitext_set_entry(&ge->eta.iodepth, index);
2644}
2645
2646static void combo_entry_destroy(GtkWidget *widget, gpointer data)
2647{
2648 struct gui_entry *ge = (struct gui_entry *) data;
2649
2650 multitext_free(&ge->eta.iotype);
2651 multitext_free(&ge->eta.ioengine);
2652 multitext_free(&ge->eta.iodepth);
2653}
2654
Jens Axboe2f99deb2012-03-09 14:37:29 +01002655static GtkWidget *new_client_page(struct gui_entry *ge)
Stephen M. Cameronff1f3282012-02-24 08:17:30 +01002656{
Jens Axboe2f99deb2012-03-09 14:37:29 +01002657 GtkWidget *main_vbox, *probe, *probe_frame, *probe_box;
Jens Axboe65476332012-03-13 10:37:04 +01002658 GtkWidget *scrolled_window, *bottom_align, *top_align, *top_vbox;
Stephen M. Cameronaaa71f62012-03-07 14:47:03 +01002659 GdkColor white;
Jens Axboe0420ba62012-02-29 11:16:52 +01002660
Jens Axboe2f99deb2012-03-09 14:37:29 +01002661 main_vbox = gtk_vbox_new(FALSE, 3);
Stephen M. Cameron45032dd2012-02-24 08:17:31 +01002662
Jens Axboe65476332012-03-13 10:37:04 +01002663 top_align = gtk_alignment_new(0, 0, 1, 0);
2664 top_vbox = gtk_vbox_new(FALSE, 3);
2665 gtk_container_add(GTK_CONTAINER(top_align), top_vbox);
2666 gtk_box_pack_start(GTK_BOX(main_vbox), top_align, FALSE, FALSE, 0);
Stephen M. Cameronc36f98d2012-02-24 08:17:32 +01002667
Jens Axboe3e47bd22012-02-29 13:45:02 +01002668 probe = gtk_frame_new("Job");
Jens Axboe2f99deb2012-03-09 14:37:29 +01002669 gtk_box_pack_start(GTK_BOX(main_vbox), probe, FALSE, FALSE, 3);
Jens Axboe843ad232012-02-29 11:44:53 +01002670 probe_frame = gtk_vbox_new(FALSE, 3);
2671 gtk_container_add(GTK_CONTAINER(probe), probe_frame);
2672
2673 probe_box = gtk_hbox_new(FALSE, 3);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002674 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, FALSE, FALSE, 3);
2675 ge->probe.hostname = new_info_label_in_frame(probe_box, "Host");
2676 ge->probe.os = new_info_label_in_frame(probe_box, "OS");
2677 ge->probe.arch = new_info_label_in_frame(probe_box, "Architecture");
2678 ge->probe.fio_ver = new_info_label_in_frame(probe_box, "Fio version");
Jens Axboe843ad232012-02-29 11:44:53 +01002679
Jens Axboe3e47bd22012-02-29 13:45:02 +01002680 probe_box = gtk_hbox_new(FALSE, 3);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002681 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, FALSE, FALSE, 3);
2682
Jens Axboe3863d1a2012-03-09 17:39:05 +01002683 ge->eta.names = new_combo_entry_in_frame(probe_box, "Jobs");
Jens Axboec80b74b2012-03-12 10:23:28 +01002684 g_signal_connect(ge->eta.names, "changed", G_CALLBACK(combo_entry_changed), ge);
2685 g_signal_connect(ge->eta.names, "destroy", G_CALLBACK(combo_entry_destroy), ge);
2686 ge->eta.iotype.entry = new_info_entry_in_frame(probe_box, "IO");
2687 ge->eta.ioengine.entry = new_info_entry_in_frame(probe_box, "IO Engine");
2688 ge->eta.iodepth.entry = new_info_entry_in_frame(probe_box, "IO Depth");
Jens Axboe2f99deb2012-03-09 14:37:29 +01002689 ge->eta.jobs = new_info_entry_in_frame(probe_box, "Jobs");
2690 ge->eta.files = new_info_entry_in_frame(probe_box, "Open files");
2691
2692 probe_box = gtk_hbox_new(FALSE, 3);
2693 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, FALSE, FALSE, 3);
2694 ge->eta.read_bw = new_info_entry_in_frame(probe_box, "Read BW");
2695 ge->eta.read_iops = new_info_entry_in_frame(probe_box, "IOPS");
2696 ge->eta.write_bw = new_info_entry_in_frame(probe_box, "Write BW");
2697 ge->eta.write_iops = new_info_entry_in_frame(probe_box, "IOPS");
2698
2699 /*
2700 * Only add this if we have a commit rate
2701 */
2702#if 0
2703 probe_box = gtk_hbox_new(FALSE, 3);
Jens Axboe3e47bd22012-02-29 13:45:02 +01002704 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, TRUE, FALSE, 3);
Jens Axboe807f9972012-03-02 10:25:24 +01002705
Jens Axboe2f99deb2012-03-09 14:37:29 +01002706 ge->eta.cr_bw = new_info_label_in_frame(probe_box, "Commit BW");
2707 ge->eta.cr_iops = new_info_label_in_frame(probe_box, "Commit IOPS");
2708
2709 ge->eta.cw_bw = new_info_label_in_frame(probe_box, "Commit BW");
2710 ge->eta.cw_iops = new_info_label_in_frame(probe_box, "Commit IOPS");
2711#endif
2712
2713 /*
2714 * Set up a drawing area and IOPS and bandwidth graphs
2715 */
2716 gdk_color_parse("white", &white);
2717 ge->graphs.drawing_area = gtk_drawing_area_new();
Jens Axboe2f99deb2012-03-09 14:37:29 +01002718 gtk_widget_set_size_request(GTK_WIDGET(ge->graphs.drawing_area),
Stephen M. Cameron57f9d282012-03-11 11:36:51 +01002719 DRAWING_AREA_XDIM, DRAWING_AREA_YDIM);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002720 gtk_widget_modify_bg(ge->graphs.drawing_area, GTK_STATE_NORMAL, &white);
2721 g_signal_connect(G_OBJECT(ge->graphs.drawing_area), "expose_event",
2722 G_CALLBACK(on_expose_drawing_area), &ge->graphs);
2723 g_signal_connect(G_OBJECT(ge->graphs.drawing_area), "configure_event",
2724 G_CALLBACK(on_config_drawing_area), &ge->graphs);
Jens Axboe65476332012-03-13 10:37:04 +01002725 scrolled_window = gtk_scrolled_window_new(NULL, NULL);
2726 gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(scrolled_window),
Jens Axboe2f99deb2012-03-09 14:37:29 +01002727 GTK_POLICY_AUTOMATIC, GTK_POLICY_AUTOMATIC);
Jens Axboe65476332012-03-13 10:37:04 +01002728 gtk_scrolled_window_add_with_viewport(GTK_SCROLLED_WINDOW(scrolled_window),
Jens Axboe2f99deb2012-03-09 14:37:29 +01002729 ge->graphs.drawing_area);
Jens Axboe65476332012-03-13 10:37:04 +01002730 gtk_box_pack_start(GTK_BOX(main_vbox), scrolled_window, TRUE, TRUE, 0);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002731
2732 setup_graphs(&ge->graphs);
2733
2734 /*
2735 * Set up alignments for widgets at the bottom of ui,
2736 * align bottom left, expand horizontally but not vertically
2737 */
Jens Axboe65476332012-03-13 10:37:04 +01002738 bottom_align = gtk_alignment_new(0, 1, 1, 0);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002739 ge->buttonbox = gtk_hbox_new(FALSE, 0);
Jens Axboe65476332012-03-13 10:37:04 +01002740 gtk_container_add(GTK_CONTAINER(bottom_align), ge->buttonbox);
2741 gtk_box_pack_start(GTK_BOX(main_vbox), bottom_align, FALSE, FALSE, 0);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002742
2743 add_buttons(ge, buttonspeclist, ARRAYSIZE(buttonspeclist));
2744
2745 /*
2746 * Set up thread status progress bar
2747 */
2748 ge->thread_status_pb = gtk_progress_bar_new();
2749 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(ge->thread_status_pb), 0.0);
2750 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(ge->thread_status_pb), "No connections");
2751 gtk_container_add(GTK_CONTAINER(ge->buttonbox), ge->thread_status_pb);
2752
2753
2754 return main_vbox;
2755}
2756
2757static GtkWidget *new_main_page(struct gui *ui)
2758{
2759 GtkWidget *main_vbox, *probe, *probe_frame, *probe_box;
Jens Axboe65476332012-03-13 10:37:04 +01002760 GtkWidget *scrolled_window, *bottom_align, *top_align, *top_vbox;
Jens Axboe2f99deb2012-03-09 14:37:29 +01002761 GdkColor white;
2762
2763 main_vbox = gtk_vbox_new(FALSE, 3);
2764
2765 /*
2766 * Set up alignments for widgets at the top of ui,
2767 * align top left, expand horizontally but not vertically
2768 */
Jens Axboe65476332012-03-13 10:37:04 +01002769 top_align = gtk_alignment_new(0, 0, 1, 0);
2770 top_vbox = gtk_vbox_new(FALSE, 0);
2771 gtk_container_add(GTK_CONTAINER(top_align), top_vbox);
2772 gtk_box_pack_start(GTK_BOX(main_vbox), top_align, FALSE, FALSE, 0);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002773
2774 probe = gtk_frame_new("Run statistics");
2775 gtk_box_pack_start(GTK_BOX(main_vbox), probe, FALSE, FALSE, 3);
2776 probe_frame = gtk_vbox_new(FALSE, 3);
2777 gtk_container_add(GTK_CONTAINER(probe), probe_frame);
Jens Axboe3e47bd22012-02-29 13:45:02 +01002778
2779 probe_box = gtk_hbox_new(FALSE, 3);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002780 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, FALSE, FALSE, 3);
Jens Axboe3863d1a2012-03-09 17:39:05 +01002781 ui->eta.jobs = new_info_entry_in_frame(probe_box, "Running");
Jens Axboeca850992012-03-05 20:04:43 +01002782 ui->eta.read_bw = new_info_entry_in_frame(probe_box, "Read BW");
2783 ui->eta.read_iops = new_info_entry_in_frame(probe_box, "IOPS");
2784 ui->eta.write_bw = new_info_entry_in_frame(probe_box, "Write BW");
2785 ui->eta.write_iops = new_info_entry_in_frame(probe_box, "IOPS");
Jens Axboe807f9972012-03-02 10:25:24 +01002786
2787 /*
2788 * Only add this if we have a commit rate
2789 */
2790#if 0
2791 probe_box = gtk_hbox_new(FALSE, 3);
2792 gtk_box_pack_start(GTK_BOX(probe_frame), probe_box, TRUE, FALSE, 3);
2793
Jens Axboe3e47bd22012-02-29 13:45:02 +01002794 ui->eta.cr_bw = new_info_label_in_frame(probe_box, "Commit BW");
2795 ui->eta.cr_iops = new_info_label_in_frame(probe_box, "Commit IOPS");
2796
Jens Axboe3e47bd22012-02-29 13:45:02 +01002797 ui->eta.cw_bw = new_info_label_in_frame(probe_box, "Commit BW");
2798 ui->eta.cw_iops = new_info_label_in_frame(probe_box, "Commit IOPS");
Jens Axboe807f9972012-03-02 10:25:24 +01002799#endif
Jens Axboe3e47bd22012-02-29 13:45:02 +01002800
Stephen M. Cameron45032dd2012-02-24 08:17:31 +01002801 /*
Jens Axboe2fd3bb02012-03-07 08:07:39 +01002802 * Set up a drawing area and IOPS and bandwidth graphs
Stephen M. Cameron736f2df2012-02-24 08:17:32 +01002803 */
Stephen M. Cameronaaa71f62012-03-07 14:47:03 +01002804 gdk_color_parse("white", &white);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002805 ui->graphs.drawing_area = gtk_drawing_area_new();
Jens Axboe2f99deb2012-03-09 14:37:29 +01002806 gtk_widget_set_size_request(GTK_WIDGET(ui->graphs.drawing_area),
Stephen M. Cameron57f9d282012-03-11 11:36:51 +01002807 DRAWING_AREA_XDIM, DRAWING_AREA_YDIM);
Jens Axboe2f99deb2012-03-09 14:37:29 +01002808 gtk_widget_modify_bg(ui->graphs.drawing_area, GTK_STATE_NORMAL, &white);
2809 g_signal_connect(G_OBJECT(ui->graphs.drawing_area), "expose_event",
2810 G_CALLBACK(on_expose_drawing_area), &ui->graphs);
2811 g_signal_connect(G_OBJECT(ui->graphs.drawing_area), "configure_event",
2812 G_CALLBACK(on_config_drawing_area), &ui->graphs);
Jens Axboe65476332012-03-13 10:37:04 +01002813 scrolled_window = gtk_scrolled_window_new(NULL, NULL);
2814 gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(scrolled_window),
Stephen M. Cameron736f2df2012-02-24 08:17:32 +01002815 GTK_POLICY_AUTOMATIC, GTK_POLICY_AUTOMATIC);
Jens Axboe65476332012-03-13 10:37:04 +01002816 gtk_scrolled_window_add_with_viewport(GTK_SCROLLED_WINDOW(scrolled_window),
Jens Axboe2f99deb2012-03-09 14:37:29 +01002817 ui->graphs.drawing_area);
Jens Axboe65476332012-03-13 10:37:04 +01002818 gtk_box_pack_start(GTK_BOX(main_vbox), scrolled_window,
Stephen M. Camerone1645342012-02-24 08:17:32 +01002819 TRUE, TRUE, 0);
Stephen M. Cameron736f2df2012-02-24 08:17:32 +01002820
Jens Axboe2f99deb2012-03-09 14:37:29 +01002821 setup_graphs(&ui->graphs);
Jens Axboe2fd3bb02012-03-07 08:07:39 +01002822
Stephen M. Cameronc36f98d2012-02-24 08:17:32 +01002823 /*
2824 * Set up alignments for widgets at the bottom of ui,
2825 * align bottom left, expand horizontally but not vertically
2826 */
Jens Axboe65476332012-03-13 10:37:04 +01002827 bottom_align = gtk_alignment_new(0, 1, 1, 0);
Stephen M. Cameronc36f98d2012-02-24 08:17:32 +01002828 ui->buttonbox = gtk_hbox_new(FALSE, 0);
Jens Axboe65476332012-03-13 10:37:04 +01002829 gtk_container_add(GTK_CONTAINER(bottom_align), ui->buttonbox);
2830 gtk_box_pack_start(GTK_BOX(main_vbox), bottom_align, FALSE, FALSE, 0);
Stephen M. Cameronc36f98d2012-02-24 08:17:32 +01002831
Jens Axboe3ec62ec2012-03-01 12:01:29 +01002832 /*
2833 * Set up thread status progress bar
2834 */
2835 ui->thread_status_pb = gtk_progress_bar_new();
2836 gtk_progress_bar_set_fraction(GTK_PROGRESS_BAR(ui->thread_status_pb), 0.0);
Jens Axboe8663ea62012-03-02 14:04:30 +01002837 gtk_progress_bar_set_text(GTK_PROGRESS_BAR(ui->thread_status_pb), "No connections");
Jens Axboe3ec62ec2012-03-01 12:01:29 +01002838 gtk_container_add(GTK_CONTAINER(ui->buttonbox), ui->thread_status_pb);
2839
Jens Axboe2f99deb2012-03-09 14:37:29 +01002840 return main_vbox;
2841}
2842
2843static gboolean notebook_switch_page(GtkNotebook *notebook, GtkWidget *widget,
2844 guint page, gpointer data)
2845
2846{
Jens Axboe02421e62012-03-12 12:05:50 +01002847 struct gui *ui = (struct gui *) data;
Jens Axboe85dd01e2012-03-12 14:33:16 +01002848 struct gui_entry *ge;
Jens Axboe02421e62012-03-12 12:05:50 +01002849
Jens Axboe85dd01e2012-03-12 14:33:16 +01002850 if (!page) {
2851 set_job_menu_visible(ui, 0);
2852 return TRUE;
2853 }
2854
2855 set_job_menu_visible(ui, 1);
Jens Axboe38634cb2012-03-13 12:26:41 +01002856 ge = get_ge_from_page(page, NULL);
Jens Axboe85dd01e2012-03-12 14:33:16 +01002857 if (ge)
2858 update_button_states(ui, ge);
2859
Jens Axboe2f99deb2012-03-09 14:37:29 +01002860 return TRUE;
2861}
2862
Jens Axboe38634cb2012-03-13 12:26:41 +01002863static gint compare_recent_items(GtkRecentInfo *a, GtkRecentInfo *b)
2864{
2865 time_t time_a = gtk_recent_info_get_visited(a);
2866 time_t time_b = gtk_recent_info_get_visited(b);
2867
2868 return time_b - time_a;
2869}
2870
2871static void add_recent_file_items(struct gui *ui)
2872{
2873 const gchar *gfio = g_get_application_name();
2874 GList *items, *item;
2875 int i = 0;
2876
2877 if (ui->recent_ui_id) {
2878 gtk_ui_manager_remove_ui(ui->uimanager, ui->recent_ui_id);
2879 gtk_ui_manager_ensure_update(ui->uimanager);
2880 }
2881 ui->recent_ui_id = gtk_ui_manager_new_merge_id(ui->uimanager);
2882
2883 if (ui->actiongroup) {
2884 gtk_ui_manager_remove_action_group(ui->uimanager, ui->actiongroup);
2885 g_object_unref(ui->actiongroup);
2886 }
2887 ui->actiongroup = gtk_action_group_new("RecentFileActions");
2888
2889 gtk_ui_manager_insert_action_group(ui->uimanager, ui->actiongroup, -1);
2890
2891 items = gtk_recent_manager_get_items(ui->recentmanager);
2892 items = g_list_sort(items, (GCompareFunc) compare_recent_items);
2893
2894 for (item = items; item && item->data; item = g_list_next(item)) {
2895 GtkRecentInfo *info = (GtkRecentInfo *) item->data;
2896 gchar *action_name;
2897 const gchar *label;
2898 GtkAction *action;
2899
2900 if (!gtk_recent_info_has_application(info, gfio))
2901 continue;
2902
2903 /*
2904 * We only support local files for now
2905 */
2906 if (!gtk_recent_info_is_local(info) || !gtk_recent_info_exists(info))
2907 continue;
2908
2909 action_name = g_strdup_printf("RecentFile%u", i++);
2910 label = gtk_recent_info_get_display_name(info);
2911
2912 action = g_object_new(GTK_TYPE_ACTION,
2913 "name", action_name,
2914 "label", label, NULL);
2915
2916 g_object_set_data_full(G_OBJECT(action), "gtk-recent-info",
2917 gtk_recent_info_ref(info),
2918 (GDestroyNotify) gtk_recent_info_unref);
2919
2920
2921 g_signal_connect(action, "activate", G_CALLBACK(recent_open), ui);
2922
2923 gtk_action_group_add_action(ui->actiongroup, action);
2924 g_object_unref(action);
2925
2926 gtk_ui_manager_add_ui(ui->uimanager, ui->recent_ui_id,
2927 "/MainMenu/FileMenu/FileRecentFiles",
2928 label, action_name,
2929 GTK_UI_MANAGER_MENUITEM, FALSE);
2930
2931 g_free(action_name);
2932
2933 if (i == 8)
2934 break;
2935 }
2936
2937 g_list_foreach(items, (GFunc) gtk_recent_info_unref, NULL);
2938 g_list_free(items);
2939}
2940
Jens Axboea6790902012-03-13 15:16:11 +01002941static void drag_and_drop_received(GtkWidget *widget, GdkDragContext *ctx,
2942 gint x, gint y, GtkSelectionData *data,
2943 guint info, guint time)
2944{
2945 struct gui *ui = &main_ui;
2946 gchar **uris;
2947 GtkWidget *source;
2948 int i;
2949
2950 source = gtk_drag_get_source_widget(ctx);
2951 if (source && widget == gtk_widget_get_toplevel(source)) {
2952 gtk_drag_finish(ctx, FALSE, FALSE, time);
2953 return;
2954 }
2955
2956 uris = gtk_selection_data_get_uris(data);
2957 if (!uris) {
2958 gtk_drag_finish(ctx, FALSE, FALSE, time);
2959 return;
2960 }
2961
2962 i = 0;
2963 while (uris[i]) {
2964 if (do_file_open_with_tab(ui, uris[i]))
2965 break;
2966 i++;
2967 }
2968
2969 gtk_drag_finish(ctx, TRUE, FALSE, time);
2970 g_strfreev(uris);
2971}
2972
Jens Axboe2f99deb2012-03-09 14:37:29 +01002973static void init_ui(int *argc, char **argv[], struct gui *ui)
2974{
2975 GtkSettings *settings;
Jens Axboe02421e62012-03-12 12:05:50 +01002976 GtkWidget *vbox;
Jens Axboe2f99deb2012-03-09 14:37:29 +01002977
2978 /* Magical g*thread incantation, you just need this thread stuff.
2979 * Without it, the update that happens in gfio_update_thread_status
2980 * doesn't really happen in a timely fashion, you need expose events
2981 */
2982 if (!g_thread_supported())
2983 g_thread_init(NULL);
2984 gdk_threads_init();
2985
2986 gtk_init(argc, argv);
2987 settings = gtk_settings_get_default();
2988 gtk_settings_set_long_property(settings, "gtk_tooltip_timeout", 10, "gfio setting");
2989 g_type_init();
2990
2991 ui->window = gtk_window_new(GTK_WINDOW_TOPLEVEL);
2992 gtk_window_set_title(GTK_WINDOW(ui->window), "fio");
2993 gtk_window_set_default_size(GTK_WINDOW(ui->window), 1024, 768);
2994
2995 g_signal_connect(ui->window, "delete-event", G_CALLBACK(quit_clicked), NULL);
2996 g_signal_connect(ui->window, "destroy", G_CALLBACK(quit_clicked), NULL);
2997
2998 ui->vbox = gtk_vbox_new(FALSE, 0);
2999 gtk_container_add(GTK_CONTAINER(ui->window), ui->vbox);
3000
Jens Axboe02421e62012-03-12 12:05:50 +01003001 ui->uimanager = gtk_ui_manager_new();
3002 ui->menu = get_menubar_menu(ui->window, ui->uimanager, ui);
3003 gfio_ui_setup(settings, ui->menu, ui->vbox, ui->uimanager);
Jens Axboe2f99deb2012-03-09 14:37:29 +01003004
Jens Axboe38634cb2012-03-13 12:26:41 +01003005 ui->recentmanager = gtk_recent_manager_get_default();
3006 add_recent_file_items(ui);
3007
Jens Axboe2f99deb2012-03-09 14:37:29 +01003008 ui->notebook = gtk_notebook_new();
3009 g_signal_connect(ui->notebook, "switch-page", G_CALLBACK(notebook_switch_page), ui);
Jens Axboeb870c312012-03-09 17:22:01 +01003010 gtk_notebook_set_scrollable(GTK_NOTEBOOK(ui->notebook), 1);
Jens Axboe0aa928c2012-03-09 17:24:07 +01003011 gtk_notebook_popup_enable(GTK_NOTEBOOK(ui->notebook));
Jens Axboe2f99deb2012-03-09 14:37:29 +01003012 gtk_container_add(GTK_CONTAINER(ui->vbox), ui->notebook);
3013
3014 vbox = new_main_page(ui);
Jens Axboea6790902012-03-13 15:16:11 +01003015 gtk_drag_dest_set(GTK_WIDGET(ui->window), GTK_DEST_DEFAULT_ALL, NULL, 0, GDK_ACTION_COPY);
3016 gtk_drag_dest_add_uri_targets(GTK_WIDGET(ui->window));
3017 g_signal_connect(ui->window, "drag-data-received", G_CALLBACK(drag_and_drop_received), ui);
Jens Axboe2f99deb2012-03-09 14:37:29 +01003018
3019 gtk_notebook_append_page(GTK_NOTEBOOK(ui->notebook), vbox, gtk_label_new("Main"));
3020
Jens Axboe9b260bd2012-03-06 11:02:52 +01003021 gfio_ui_setup_log(ui);
Jens Axboe3ec62ec2012-03-01 12:01:29 +01003022
Stephen M. Cameronff1f3282012-02-24 08:17:30 +01003023 gtk_widget_show_all(ui->window);
3024}
3025
Stephen M. Cameron8232e282012-02-24 08:17:31 +01003026int main(int argc, char *argv[], char *envp[])
Stephen M. Cameronff1f3282012-02-24 08:17:30 +01003027{
Stephen M. Cameron8232e282012-02-24 08:17:31 +01003028 if (initialize_fio(envp))
3029 return 1;
Jens Axboe0420ba62012-02-29 11:16:52 +01003030 if (fio_init_options())
3031 return 1;
Stephen M. Camerona1820202012-02-24 08:17:31 +01003032
Jens Axboe2f99deb2012-03-09 14:37:29 +01003033 memset(&main_ui, 0, sizeof(main_ui));
3034 INIT_FLIST_HEAD(&main_ui.list);
3035
3036 init_ui(&argc, &argv, &main_ui);
Stephen M. Cameron5b7573a2012-02-24 08:17:31 +01003037
Stephen M. Cameron2839f0c2012-02-24 08:17:31 +01003038 gdk_threads_enter();
Stephen M. Cameronff1f3282012-02-24 08:17:30 +01003039 gtk_main();
Stephen M. Cameron2839f0c2012-02-24 08:17:31 +01003040 gdk_threads_leave();
Stephen M. Cameronff1f3282012-02-24 08:17:30 +01003041 return 0;
3042}