| /****************************************************************************\ |
| * popups.c - put different popup displays here |
| ***************************************************************************** |
| * Copyright (C) 2002-2006 The Regents of the University of California. |
| * Produced at Lawrence Livermore National Laboratory (cf, DISCLAIMER). |
| * Written by Danny Auble <da@llnl.gov>, et. al. |
| * UCRL-CODE-226842. |
| * |
| * This file is part of SLURM, a resource management program. |
| * For details, see <http://www.llnl.gov/linux/slurm/>. |
| * |
| * SLURM is free software; you can redistribute it and/or modify it under |
| * the terms of the GNU General Public License as published by the Free |
| * Software Foundation; either version 2 of the License, or (at your option) |
| * any later version. |
| * |
| * In addition, as a special exception, the copyright holders give permission |
| * to link the code of portions of this program with the OpenSSL library under |
| * certain conditions as described in each individual source file, and |
| * distribute linked combinations including the two. You must obey the GNU |
| * General Public License in all respects for all of the code used other than |
| * OpenSSL. If you modify file(s) with this exception, you may extend this |
| * exception to your version of the file(s), but you are not obligated to do |
| * so. If you do not wish to do so, delete this exception statement from your |
| * version. If you delete this exception statement from all source files in |
| * the program, then also delete it here. |
| * |
| * SLURM is distributed in the hope that it will be useful, but WITHOUT ANY |
| * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS |
| * FOR A PARTICULAR PURPOSE. See the GNU General Public License for more |
| * details. |
| * |
| * You should have received a copy of the GNU General Public License along |
| * with SLURM; if not, write to the Free Software Foundation, Inc., |
| * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. |
| \*****************************************************************************/ |
| #include "sview.h" |
| #include "src/common/parse_time.h" |
| |
| void *_refresh_thr(gpointer arg) |
| { |
| int msg_id = GPOINTER_TO_INT(arg); |
| sleep(5); |
| gdk_threads_enter(); |
| gtk_statusbar_remove(GTK_STATUSBAR(main_statusbar), |
| STATUS_REFRESH, msg_id); |
| gdk_flush(); |
| gdk_threads_leave(); |
| return NULL; |
| } |
| |
| static gboolean _delete_popup(GtkWidget *widget, |
| GtkWidget *event, |
| gpointer data) |
| { |
| gtk_widget_destroy(widget); |
| return FALSE; |
| } |
| |
| /* Creates a tree model containing the completions */ |
| void _search_entry(sview_search_info_t *sview_search_info) |
| { |
| int id = 0; |
| char title[100]; |
| ListIterator itr = NULL; |
| popup_info_t *popup_win = NULL; |
| GError *error = NULL; |
| char *upper = NULL, *lower = NULL; |
| |
| if(sview_search_info->int_data == NO_VAL && |
| (!sview_search_info->gchar_data |
| || !strlen(sview_search_info->gchar_data))) { |
| g_print("nothing given to search for.\n"); |
| return; |
| } |
| |
| switch(sview_search_info->search_type) { |
| case SEARCH_JOB_STATE: |
| id = JOB_PAGE; |
| upper = job_state_string(sview_search_info->int_data); |
| lower = str_tolower(upper); |
| snprintf(title, 100, "Job(s) in the %s state", lower); |
| xfree(lower); |
| break; |
| case SEARCH_JOB_ID: |
| id = JOB_PAGE; |
| snprintf(title, 100, "Job %s info", |
| sview_search_info->gchar_data); |
| break; |
| case SEARCH_JOB_USER: |
| id = JOB_PAGE; |
| snprintf(title, 100, "Job(s) info for user %s", |
| sview_search_info->gchar_data); |
| break; |
| case SEARCH_BLOCK_STATE: |
| id = BLOCK_PAGE; |
| upper = bg_block_state_string(sview_search_info->int_data); |
| lower = str_tolower(upper); |
| snprintf(title, 100, "BG Block(s) in the %s state", lower); |
| xfree(lower); |
| break; |
| case SEARCH_BLOCK_NAME: |
| id = BLOCK_PAGE; |
| snprintf(title, 100, "Block %s info", |
| sview_search_info->gchar_data); |
| break; |
| case SEARCH_BLOCK_SIZE: |
| id = BLOCK_PAGE; |
| sview_search_info->int_data = |
| revert_num_unit(sview_search_info->gchar_data); |
| if(sview_search_info->int_data == -1) |
| return; |
| snprintf(title, 100, "Block(s) of size %d cnodes", |
| sview_search_info->int_data); |
| break; |
| case SEARCH_PARTITION_NAME: |
| id = PART_PAGE; |
| snprintf(title, 100, "Partition %s info", |
| sview_search_info->gchar_data); |
| break; |
| case SEARCH_PARTITION_STATE: |
| id = PART_PAGE; |
| if(sview_search_info->int_data) |
| snprintf(title, 100, "Partition(s) that are up"); |
| else |
| snprintf(title, 100, "Partition(s) that are down"); |
| break; |
| case SEARCH_NODE_NAME: |
| id = NODE_PAGE; |
| #ifdef HAVE_BG |
| snprintf(title, 100, "Base partition(s) %s info", |
| sview_search_info->gchar_data); |
| #else |
| snprintf(title, 100, "Node(s) %s info", |
| sview_search_info->gchar_data); |
| #endif |
| |
| break; |
| case SEARCH_NODE_STATE: |
| id = NODE_PAGE; |
| upper = node_state_string(sview_search_info->int_data); |
| lower = str_tolower(upper); |
| #ifdef HAVE_BG |
| snprintf(title, 100, "Base partition(s) in the %s state", |
| lower); |
| #else |
| snprintf(title, 100, "Node(s) in the %s state", lower); |
| #endif |
| xfree(lower); |
| |
| break; |
| default: |
| g_print("unknown search type %d.\n", |
| sview_search_info->search_type); |
| |
| return; |
| } |
| |
| itr = list_iterator_create(popup_list); |
| while((popup_win = list_next(itr))) { |
| if(popup_win->spec_info) |
| if(!strcmp(popup_win->spec_info->title, title)) { |
| break; |
| } |
| } |
| list_iterator_destroy(itr); |
| |
| if(!popup_win) { |
| popup_win = create_popup_info(id, id, title); |
| } else { |
| gtk_window_present(GTK_WINDOW(popup_win->popup)); |
| return; |
| } |
| memcpy(popup_win->spec_info->search_info, sview_search_info, |
| sizeof(sview_search_info_t)); |
| |
| if (!g_thread_create((gpointer)popup_thr, popup_win, FALSE, &error)) |
| { |
| g_printerr ("Failed to create main popup thread: %s\n", |
| error->message); |
| return; |
| } |
| return; |
| } |
| |
| static GtkTreeStore *_local_create_treestore_2cols(GtkWidget *popup, |
| int x, int y) |
| { |
| GtkScrolledWindow *window = create_scrolled_window(); |
| GtkBin *bin = NULL; |
| GtkViewport *view = NULL; |
| GtkTable *table = NULL; |
| GtkTreeView *treeview = NULL; |
| GtkTreeStore *treestore = NULL; |
| |
| bin = GTK_BIN(&window->container); |
| view = GTK_VIEWPORT(bin->child); |
| bin = GTK_BIN(&view->bin); |
| table = GTK_TABLE(bin->child); |
| |
| gtk_window_set_default_size(GTK_WINDOW(popup), |
| x, y); |
| |
| gtk_box_pack_start(GTK_BOX(GTK_DIALOG(popup)->vbox), |
| GTK_WIDGET(window), TRUE, TRUE, 0); |
| |
| treeview = create_treeview_2cols_attach_to_table(table); |
| treestore = GTK_TREE_STORE(gtk_tree_view_get_model(treeview)); |
| return treestore; |
| } |
| |
| static void _layout_ctl_conf(GtkTreeStore *treestore, |
| slurm_ctl_conf_info_msg_t *slurm_ctl_conf_ptr) |
| { |
| char temp_str[32]; |
| int update = 0; |
| GtkTreeIter iter; |
| |
| if(!slurm_ctl_conf_ptr) |
| return; |
| |
| slurm_make_time_str((time_t *)&slurm_ctl_conf_ptr->last_update, |
| temp_str, sizeof(temp_str)); |
| add_display_treestore_line(update, treestore, &iter, |
| "Configuration data as of", temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "AuthType", slurm_ctl_conf_ptr->authtype); |
| add_display_treestore_line(update, treestore, &iter, |
| "BackupAddr", slurm_ctl_conf_ptr->backup_addr); |
| add_display_treestore_line(update, treestore, &iter, |
| "BackupController", |
| slurm_ctl_conf_ptr->backup_controller); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->cache_groups); |
| add_display_treestore_line(update, treestore, &iter, |
| "CacheGroups", temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "CheckpointType", |
| slurm_ctl_conf_ptr->checkpoint_type); |
| add_display_treestore_line(update, treestore, &iter, |
| "ControlAddr", |
| slurm_ctl_conf_ptr->control_addr); |
| add_display_treestore_line(update, treestore, &iter, |
| "ControlMachine", |
| slurm_ctl_conf_ptr->control_machine); |
| add_display_treestore_line(update, treestore, &iter, |
| "Epilog", |
| slurm_ctl_conf_ptr->epilog); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->fast_schedule); |
| add_display_treestore_line(update, treestore, &iter, |
| "FastSchedule", |
| temp_str); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->first_job_id); |
| add_display_treestore_line(update, treestore, &iter, |
| "FirstJobId", |
| temp_str); |
| #ifdef HAVE_XCPU |
| add_display_treestore_line(update, treestore, &iter, |
| "HAVE_XCPU", "1"); |
| #endif |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->inactive_limit); |
| add_display_treestore_line(update, treestore, &iter, |
| "InactiveLimit", |
| temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "JobAcctLogFile", |
| slurm_ctl_conf_ptr->job_acct_logfile); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->job_acct_freq); |
| add_display_treestore_line(update, treestore, &iter, |
| "JobAcctFrequency", |
| temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "JobAcctType", |
| slurm_ctl_conf_ptr->job_acct_type); |
| add_display_treestore_line(update, treestore, &iter, |
| "JobCompLoc", |
| slurm_ctl_conf_ptr->job_comp_loc); |
| add_display_treestore_line(update, treestore, &iter, |
| "JobCompType", |
| slurm_ctl_conf_ptr->job_comp_type); |
| add_display_treestore_line(update, treestore, &iter, |
| "JobCredentialPrivateKey", |
| slurm_ctl_conf_ptr->job_credential_private_key); |
| add_display_treestore_line(update, treestore, &iter, |
| "JobCredentialPublicCertificate", |
| slurm_ctl_conf_ptr-> |
| job_credential_public_certificate); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->kill_wait); |
| add_display_treestore_line(update, treestore, &iter, |
| "KillWait", |
| temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "MailProg", |
| slurm_ctl_conf_ptr->mail_prog); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->max_job_cnt); |
| add_display_treestore_line(update, treestore, &iter, |
| "MaxJobCount", |
| temp_str); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->msg_timeout); |
| add_display_treestore_line(update, treestore, &iter, |
| "MessageTimeout", |
| temp_str); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->min_job_age); |
| add_display_treestore_line(update, treestore, &iter, |
| "MinJobAge", |
| temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "MpiDefault", |
| slurm_ctl_conf_ptr->mpi_default); |
| #ifdef MULTIPLE_SLURMD |
| add_display_treestore_line(update, treestore, &iter, |
| "MULTIPLE_SLURMD", "1"); |
| #endif |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->next_job_id); |
| add_display_treestore_line(update, treestore, &iter, |
| "NEXT_JOB_ID", |
| temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "PluginDir", |
| slurm_ctl_conf_ptr->plugindir); |
| add_display_treestore_line(update, treestore, &iter, |
| "PlugStackConfig", |
| slurm_ctl_conf_ptr->plugstack); |
| add_display_treestore_line(update, treestore, &iter, |
| "ProctrackType", |
| slurm_ctl_conf_ptr->proctrack_type); |
| add_display_treestore_line(update, treestore, &iter, |
| "Prolog", |
| slurm_ctl_conf_ptr->prolog); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->propagate_prio_process); |
| add_display_treestore_line(update, treestore, &iter, |
| "PropagatePrioProcess", temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "PropagateResourceLimits", |
| slurm_ctl_conf_ptr->propagate_rlimits); |
| add_display_treestore_line(update, treestore, &iter, |
| "PropagateResourceLimitsExcept", |
| slurm_ctl_conf_ptr->propagate_rlimits_except); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->ret2service); |
| add_display_treestore_line(update, treestore, &iter, |
| "ReturnToService", temp_str); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->schedport); |
| add_display_treestore_line(update, treestore, &iter, |
| "SchedulerPort", temp_str); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->schedrootfltr); |
| add_display_treestore_line(update, treestore, &iter, |
| "SchedulerRootFilter", temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "SchedulerType", |
| slurm_ctl_conf_ptr->schedtype); |
| add_display_treestore_line(update, treestore, &iter, |
| "SelectType", |
| slurm_ctl_conf_ptr->select_type); |
| snprintf(temp_str, sizeof(temp_str), "%s(%u)", |
| slurm_ctl_conf_ptr->slurm_user_name, |
| slurm_ctl_conf_ptr->slurm_user_id); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmUser", temp_str); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->slurmctld_debug); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmctldDebug", temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmctldLogFile", |
| slurm_ctl_conf_ptr->slurmctld_logfile); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmctldPidFile", |
| slurm_ctl_conf_ptr->slurmctld_pidfile); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->slurmctld_port); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmctldPort", temp_str); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->slurmctld_timeout); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmctldTimeout", temp_str); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->slurmd_debug); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmdDebug", temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmdLogFile", |
| slurm_ctl_conf_ptr->slurmd_logfile); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmdPidFile", |
| slurm_ctl_conf_ptr->slurmd_pidfile); |
| #ifndef MULTIPLE_SLURMD |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->slurmd_port); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmdPort", temp_str); |
| #endif |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmdSpoolDir", |
| slurm_ctl_conf_ptr->slurmd_spooldir); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->slurmd_timeout); |
| add_display_treestore_line(update, treestore, &iter, |
| "SlurmdTimeout", temp_str); |
| add_display_treestore_line(update, treestore, &iter, |
| "SLURM_CONFIG_FILE", |
| slurm_ctl_conf_ptr->slurm_conf); |
| add_display_treestore_line(update, treestore, &iter, |
| "SLURM_VERSION", SLURM_VERSION); |
| add_display_treestore_line(update, treestore, &iter, |
| "SrunProlog", |
| slurm_ctl_conf_ptr->srun_prolog); |
| add_display_treestore_line(update, treestore, &iter, |
| "SrunEpilog", |
| slurm_ctl_conf_ptr->srun_epilog); |
| add_display_treestore_line(update, treestore, &iter, |
| "StateSaveLocation", |
| slurm_ctl_conf_ptr->state_save_location); |
| add_display_treestore_line(update, treestore, &iter, |
| "SwitchType", |
| slurm_ctl_conf_ptr->switch_type); |
| add_display_treestore_line(update, treestore, &iter, |
| "TaskEpilog", |
| slurm_ctl_conf_ptr->task_epilog); |
| add_display_treestore_line(update, treestore, &iter, |
| "TaskPlugin", |
| slurm_ctl_conf_ptr->task_plugin); |
| add_display_treestore_line(update, treestore, &iter, |
| "TaskProlog", |
| slurm_ctl_conf_ptr->task_prolog); |
| add_display_treestore_line(update, treestore, &iter, |
| "TmpFS", |
| slurm_ctl_conf_ptr->tmp_fs); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->tree_width); |
| add_display_treestore_line(update, treestore, &iter, |
| "TreeWidth", temp_str); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->use_pam); |
| add_display_treestore_line(update, treestore, &iter, |
| "UsePam", temp_str); |
| snprintf(temp_str, sizeof(temp_str), "%u", |
| slurm_ctl_conf_ptr->wait_time); |
| add_display_treestore_line(update, treestore, &iter, |
| "WaitTime", temp_str); |
| } |
| |
| extern void create_config_popup(GtkAction *action, gpointer user_data) |
| { |
| GtkWidget *popup = gtk_dialog_new_with_buttons( |
| "SLURM Config Info", |
| GTK_WINDOW(user_data), |
| GTK_DIALOG_DESTROY_WITH_PARENT, |
| GTK_STOCK_CLOSE, |
| GTK_RESPONSE_OK, |
| NULL); |
| int error_code; |
| GtkTreeStore *treestore = |
| _local_create_treestore_2cols(popup, 600, 400); |
| static slurm_ctl_conf_info_msg_t *old_slurm_ctl_conf_ptr = NULL; |
| slurm_ctl_conf_info_msg_t *slurm_ctl_conf_ptr = NULL; |
| |
| g_signal_connect(G_OBJECT(popup), "delete_event", |
| G_CALLBACK(_delete_popup), NULL); |
| g_signal_connect(G_OBJECT(popup), "response", |
| G_CALLBACK(_delete_popup), NULL); |
| |
| |
| if (old_slurm_ctl_conf_ptr) { |
| error_code = slurm_load_ctl_conf( |
| old_slurm_ctl_conf_ptr->last_update, |
| &slurm_ctl_conf_ptr); |
| if (error_code == SLURM_SUCCESS) |
| slurm_free_ctl_conf(old_slurm_ctl_conf_ptr); |
| else if (slurm_get_errno () == SLURM_NO_CHANGE_IN_DATA) { |
| slurm_ctl_conf_ptr = old_slurm_ctl_conf_ptr; |
| error_code = SLURM_SUCCESS; |
| } |
| } |
| else |
| error_code = slurm_load_ctl_conf((time_t) NULL, |
| &slurm_ctl_conf_ptr); |
| |
| _layout_ctl_conf(treestore, slurm_ctl_conf_ptr); |
| |
| |
| gtk_widget_show_all(popup); |
| |
| return; |
| } |
| |
| extern void create_daemon_popup(GtkAction *action, gpointer user_data) |
| { |
| GtkWidget *popup = gtk_dialog_new_with_buttons( |
| "SLURM Daemons running", |
| GTK_WINDOW(user_data), |
| GTK_DIALOG_DESTROY_WITH_PARENT, |
| GTK_STOCK_CLOSE, |
| GTK_RESPONSE_OK, |
| NULL); |
| |
| int update = 0; |
| slurm_ctl_conf_info_msg_t *conf; |
| char me[MAX_SLURM_NAME], *b, *c, *n; |
| int actld = 0, ctld = 0, d = 0; |
| GtkTreeStore *treestore = |
| _local_create_treestore_2cols(popup, 300, 100); |
| GtkTreeIter iter; |
| g_signal_connect(G_OBJECT(popup), "delete_event", |
| G_CALLBACK(_delete_popup), NULL); |
| g_signal_connect(G_OBJECT(popup), "response", |
| G_CALLBACK(_delete_popup), NULL); |
| |
| slurm_conf_init(NULL); |
| conf = slurm_conf_lock(); |
| |
| gethostname_short(me, MAX_SLURM_NAME); |
| if ((b = conf->backup_controller)) { |
| if ((strcmp(b, me) == 0) || |
| (strcasecmp(b, "localhost") == 0)) |
| ctld = 1; |
| } |
| if ((c = conf->control_machine)) { |
| actld = 1; |
| if ((strcmp(c, me) == 0) || |
| (strcasecmp(c, "localhost") == 0)) |
| ctld = 1; |
| } |
| slurm_conf_unlock(); |
| |
| if ((n = slurm_conf_get_nodename(me))) { |
| d = 1; |
| xfree(n); |
| } else if ((n = slurm_conf_get_nodename("localhost"))) { |
| d = 1; |
| xfree(n); |
| } |
| if (actld && ctld) |
| add_display_treestore_line(update, treestore, &iter, |
| "Slurmctld", "1"); |
| if (actld && d) |
| add_display_treestore_line(update, treestore, &iter, |
| "Slurmd", "1"); |
| |
| |
| gtk_widget_show_all(popup); |
| |
| return; |
| } |
| |
| extern void create_search_popup(GtkAction *action, gpointer user_data) |
| { |
| GtkWidget *popup = gtk_dialog_new_with_buttons( |
| "Search", |
| GTK_WINDOW(user_data), |
| GTK_DIALOG_MODAL | GTK_DIALOG_DESTROY_WITH_PARENT, |
| NULL); |
| |
| int response = 0; |
| GtkWidget *label = NULL; |
| GtkWidget *entry = NULL; |
| GtkTreeModel *model = NULL; |
| GtkTreeIter iter; |
| const gchar *name = gtk_action_get_name(action); |
| sview_search_info_t sview_search_info; |
| |
| sview_search_info.gchar_data = NULL; |
| sview_search_info.int_data = NO_VAL; |
| sview_search_info.int_data2 = NO_VAL; |
| |
| label = gtk_dialog_add_button(GTK_DIALOG(popup), |
| GTK_STOCK_OK, GTK_RESPONSE_OK); |
| gtk_window_set_default(GTK_WINDOW(popup), label); |
| gtk_dialog_add_button(GTK_DIALOG(popup), |
| GTK_STOCK_CANCEL, GTK_RESPONSE_CANCEL); |
| |
| if(!strcmp(name, "jobid")) { |
| sview_search_info.search_type = SEARCH_JOB_ID; |
| entry = create_entry(); |
| label = gtk_label_new("Which job id?"); |
| } else if(!strcmp(name, "user_jobs")) { |
| sview_search_info.search_type = SEARCH_JOB_USER; |
| entry = create_entry(); |
| label = gtk_label_new("Which user?"); |
| } else if(!strcmp(name, "state_jobs")) { |
| display_data_t pulldown_display_data[] = { |
| {G_TYPE_NONE, JOB_PENDING, "Pending", TRUE, -1}, |
| {G_TYPE_NONE, JOB_RUNNING, "Running", TRUE, -1}, |
| {G_TYPE_NONE, JOB_SUSPENDED, "Suspended", TRUE, -1}, |
| {G_TYPE_NONE, JOB_COMPLETE, "Complete", TRUE, -1}, |
| {G_TYPE_NONE, JOB_CANCELLED, "Cancelled", TRUE, -1}, |
| {G_TYPE_NONE, JOB_FAILED, "Failed", TRUE, -1}, |
| {G_TYPE_NONE, JOB_TIMEOUT, "Timeout", TRUE, -1}, |
| {G_TYPE_NONE, JOB_NODE_FAIL, "Node Failure", TRUE, -1}, |
| {G_TYPE_NONE, -1, NULL, FALSE, -1} |
| }; |
| |
| sview_search_info.search_type = SEARCH_JOB_STATE; |
| entry = create_pulldown_combo(pulldown_display_data, PAGE_CNT); |
| label = gtk_label_new("Which state?"); |
| } else if(!strcmp(name, "partition_name")) { |
| sview_search_info.search_type = SEARCH_PARTITION_NAME; |
| entry = create_entry(); |
| label = gtk_label_new("Which partition"); |
| } else if(!strcmp(name, "partition_state")) { |
| display_data_t pulldown_display_data[] = { |
| {G_TYPE_NONE, 0, "Down", TRUE, -1}, |
| {G_TYPE_NONE, 1, "Up", TRUE, -1}, |
| {G_TYPE_NONE, -1, NULL, FALSE, -1} |
| }; |
| |
| sview_search_info.search_type = SEARCH_PARTITION_STATE; |
| entry = create_pulldown_combo(pulldown_display_data, PAGE_CNT); |
| label = gtk_label_new("Which state?"); |
| } else if(!strcmp(name, "node_name")) { |
| sview_search_info.search_type = SEARCH_NODE_NAME; |
| entry = create_entry(); |
| #ifdef HAVE_BG |
| label = gtk_label_new("Which base partition(s)?\n" |
| "(ranged or comma separated)"); |
| #else |
| label = gtk_label_new("Which node(s)?\n" |
| "(ranged or comma separated)"); |
| #endif |
| } else if(!strcmp(name, "node_state")) { |
| display_data_t pulldown_display_data[] = { |
| {G_TYPE_NONE, NODE_STATE_UNKNOWN, "Down", TRUE, -1}, |
| {G_TYPE_NONE, NODE_STATE_NO_RESPOND, "No Response", |
| TRUE, -1}, |
| {G_TYPE_NONE, NODE_STATE_DRAIN, "Drained", TRUE, -1}, |
| {G_TYPE_NONE, NODE_STATE_IDLE, "Idle", TRUE, -1}, |
| {G_TYPE_NONE, NODE_STATE_ALLOCATED, "Allocated", |
| TRUE, -1}, |
| {G_TYPE_NONE, NODE_STATE_COMPLETING, "Completing", |
| TRUE, -1}, |
| {G_TYPE_NONE, NODE_STATE_UNKNOWN, "Unknown", TRUE, -1}, |
| {G_TYPE_NONE, -1, NULL, FALSE, -1} |
| }; |
| |
| sview_search_info.search_type = SEARCH_NODE_STATE; |
| entry = create_pulldown_combo(pulldown_display_data, PAGE_CNT); |
| label = gtk_label_new("Which state?"); |
| } |
| #ifdef HAVE_BG |
| else if(!strcmp(name, "bg_block_name")) { |
| sview_search_info.search_type = SEARCH_BLOCK_NAME; |
| entry = create_entry(); |
| label = gtk_label_new("Which block?"); |
| } else if(!strcmp(name, "bg_block_size")) { |
| sview_search_info.search_type = SEARCH_BLOCK_SIZE; |
| entry = create_entry(); |
| label = gtk_label_new("Which block size?"); |
| } else if(!strcmp(name, "bg_block_state")) { |
| display_data_t pulldown_display_data[] = { |
| {G_TYPE_NONE, RM_PARTITION_FREE, "Free", TRUE, -1}, |
| {G_TYPE_NONE, RM_PARTITION_CONFIGURING, "Configuring", |
| TRUE, -1}, |
| {G_TYPE_NONE, RM_PARTITION_READY, "Ready", TRUE, -1}, |
| {G_TYPE_NONE, RM_PARTITION_BUSY, "Busy", TRUE, -1}, |
| {G_TYPE_NONE, RM_PARTITION_DEALLOCATING, |
| "Deallocating", TRUE, -1}, |
| {G_TYPE_NONE, RM_PARTITION_ERROR, "Error", TRUE, -1}, |
| {G_TYPE_NONE, -1, NULL, FALSE, -1} |
| }; |
| sview_search_info.search_type = SEARCH_BLOCK_STATE; |
| entry = create_pulldown_combo(pulldown_display_data, PAGE_CNT); |
| label = gtk_label_new("Which state?"); |
| } |
| #endif |
| else { |
| sview_search_info.search_type = 0; |
| goto end_it; |
| } |
| |
| gtk_box_pack_start(GTK_BOX(GTK_DIALOG(popup)->vbox), |
| label, FALSE, FALSE, 0); |
| gtk_box_pack_start(GTK_BOX(GTK_DIALOG(popup)->vbox), |
| entry, FALSE, FALSE, 0); |
| |
| gtk_widget_show_all(popup); |
| response = gtk_dialog_run (GTK_DIALOG(popup)); |
| |
| if (response == GTK_RESPONSE_OK) { |
| if(!sview_search_info.search_type) |
| goto end_it; |
| |
| switch(sview_search_info.search_type) { |
| case SEARCH_BLOCK_STATE: |
| case SEARCH_JOB_STATE: |
| case SEARCH_NODE_STATE: |
| case SEARCH_PARTITION_STATE: |
| if(!gtk_combo_box_get_active_iter(GTK_COMBO_BOX(entry), |
| &iter)) { |
| g_print("nothing selected\n"); |
| return; |
| } |
| model = gtk_combo_box_get_model(GTK_COMBO_BOX(entry)); |
| if(!model) { |
| g_print("nothing selected\n"); |
| return; |
| } |
| |
| gtk_tree_model_get(model, &iter, 0, |
| &sview_search_info.int_data, -1); |
| break; |
| case SEARCH_JOB_ID: |
| case SEARCH_JOB_USER: |
| case SEARCH_BLOCK_NAME: |
| case SEARCH_BLOCK_SIZE: |
| case SEARCH_PARTITION_NAME: |
| case SEARCH_NODE_NAME: |
| sview_search_info.gchar_data = |
| g_strdup(gtk_entry_get_text(GTK_ENTRY(entry))); |
| break; |
| default: |
| |
| break; |
| } |
| |
| _search_entry(&sview_search_info); |
| } |
| end_it: |
| gtk_widget_destroy(popup); |
| |
| return; |
| } |
| |
| extern void change_refresh_popup(GtkAction *action, gpointer user_data) |
| { |
| GtkWidget *table = gtk_table_new(1, 2, FALSE); |
| GtkWidget *label = NULL; |
| GtkObject *adjustment = gtk_adjustment_new(global_sleep_time, |
| 1, 10000, |
| 5, 60, |
| 1); |
| GtkWidget *spin_button = |
| gtk_spin_button_new(GTK_ADJUSTMENT(adjustment), 1, 0); |
| GtkWidget *popup = gtk_dialog_new_with_buttons( |
| "Refresh Interval", |
| GTK_WINDOW (user_data), |
| GTK_DIALOG_MODAL | GTK_DIALOG_DESTROY_WITH_PARENT, |
| NULL); |
| GError *error = NULL; |
| int response = 0; |
| char *temp = NULL; |
| |
| label = gtk_dialog_add_button(GTK_DIALOG(popup), |
| GTK_STOCK_OK, GTK_RESPONSE_OK); |
| gtk_window_set_default(GTK_WINDOW(popup), label); |
| gtk_dialog_add_button(GTK_DIALOG(popup), |
| GTK_STOCK_CANCEL, GTK_RESPONSE_CANCEL); |
| |
| label = gtk_label_new("Interval in Seconds "); |
| |
| gtk_container_set_border_width(GTK_CONTAINER(table), 10); |
| |
| gtk_box_pack_start(GTK_BOX(GTK_DIALOG(popup)->vbox), |
| table, FALSE, FALSE, 0); |
| |
| gtk_table_attach_defaults(GTK_TABLE(table), label, 0, 1, 0, 1); |
| gtk_table_attach_defaults(GTK_TABLE(table), spin_button, 1, 2, 0, 1); |
| |
| gtk_widget_show_all(popup); |
| response = gtk_dialog_run (GTK_DIALOG(popup)); |
| |
| if (response == GTK_RESPONSE_OK) |
| { |
| global_sleep_time = |
| gtk_spin_button_get_value_as_int(GTK_SPIN_BUTTON(spin_button)); |
| temp = g_strdup_printf("Refresh Interval set to %d seconds.", |
| global_sleep_time); |
| gtk_statusbar_pop(GTK_STATUSBAR(main_statusbar), |
| STATUS_REFRESH); |
| response = gtk_statusbar_push(GTK_STATUSBAR(main_statusbar), |
| STATUS_REFRESH, |
| temp); |
| g_free(temp); |
| if (!g_thread_create(_refresh_thr, GINT_TO_POINTER(response), |
| FALSE, &error)) |
| { |
| g_printerr ("Failed to create refresh thread: %s\n", |
| error->message); |
| } |
| } |
| |
| gtk_widget_destroy(popup); |
| |
| return; |
| } |
| |
