/*
* This file is part of YAD.
*
* YAD 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 3 of the License, or
* (at your option) any later version.
*
* YAD 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 YAD. If not, see <http://www.gnu.org/licenses/>.
*
* Copyright (C) 2008-2019, Victor Ananjevsky <ananasik@gmail.com>
*/
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <unistd.h>
#include <signal.h>
#include "yad.h"
static GSList *progress_bars = NULL;
static guint nbars = 0;
static gboolean
pulsate_progress_bar (GtkProgressBar *bar)
{
gtk_progress_bar_pulse (bar);
return TRUE;
}
static gboolean
handle_stdin (GIOChannel * channel, GIOCondition condition, gpointer data)
{
float percentage = 0.0;
if ((condition == G_IO_IN) || (condition == G_IO_IN + G_IO_HUP))
{
GString *string;
gchar **value;
GError *err = NULL;
string = g_string_new (NULL);
while (channel->is_readable != TRUE);
do
{
gint status, num;
GtkProgressBar *pb;
YadProgressBar *b;
do
{
status = g_io_channel_read_line_string (channel, string, NULL, &err);
while (gtk_events_pending ())
gtk_main_iteration ();
}
while (status == G_IO_STATUS_AGAIN);
if (status != G_IO_STATUS_NORMAL)
{
if (err)
{
g_printerr ("yad_multi_progress_handle_stdin(): %s\n", err->message);
g_error_free (err);
err = NULL;
}
/* stop handling */
g_io_channel_shutdown (channel, TRUE, NULL);
return FALSE;
}
value = g_strsplit (string->str, ":", 2);
num = atoi (value[0]) - 1;
if (num < 0 || num > nbars - 1)
continue;
pb = GTK_PROGRESS_BAR (g_slist_nth_data (progress_bars, num));
b = (YadProgressBar *) g_slist_nth_data (options.multi_progress_data.bars, num);
if (value[1] && value[1][0] == '#')
{
gchar *match;
/* We have a comment, so let's try to change the label */
match = g_strcompress (value[1] + 1);
strip_new_line (match);
gtk_progress_bar_set_text (pb, match);
g_free (match);
}
else
{
if (value[1] && b->type == YAD_PROGRESS_PULSE)
gtk_progress_bar_pulse (pb);
else if (value[1] && b->type == YAD_PROGRESS_PERM)
{
guint id;
if (strncmp (value[1], "start", 5) == 0)
{
id = GPOINTER_TO_INT (g_object_get_data (G_OBJECT (pb), "id"));
if (id == 0)
{
id = g_timeout_add (100, (GSourceFunc) pulsate_progress_bar, pb);
g_object_set_data (G_OBJECT (pb), "id", GINT_TO_POINTER (id));
}
}
else if (strncmp (value[1], "stop", 4) == 0)
{
id = GPOINTER_TO_INT (g_object_get_data (G_OBJECT (pb), "id"));
if (id > 0)
{
g_source_remove (id);
g_object_set_data (G_OBJECT (pb), "id", GINT_TO_POINTER (0));
}
}
}
else
{
if (!value[1] || !g_ascii_isdigit (*value[1]))
continue;
/* Now try to convert the thing to a number */
percentage = atoi (value[1]);
if (percentage >= 100)
gtk_progress_bar_set_fraction (pb, 1.0);
else
gtk_progress_bar_set_fraction (pb, percentage / 100.0);
/* Check if all of progress bars reaches 100% */
if (options.progress_data.autoclose && options.plug == -1)
{
guint i;
gboolean close = TRUE;
gboolean need_close = FALSE;
if (options.multi_progress_data.watch_bar > 0 && options.multi_progress_data.watch_bar <= nbars)
{
GtkProgressBar *cpb = GTK_PROGRESS_BAR (g_slist_nth_data (progress_bars,
options.multi_progress_data.watch_bar - 1));
need_close = TRUE;
if (gtk_progress_bar_get_fraction (cpb) != 1.0)
close = FALSE;
}
else
{
for (i = 0; i < nbars; i++)
{
GtkProgressBar *cpb = GTK_PROGRESS_BAR (g_slist_nth_data (progress_bars, i));
YadProgressBar *cb = (YadProgressBar *) g_slist_nth_data (options.multi_progress_data.bars, i);
if (cb->type != YAD_PROGRESS_PULSE)
{
need_close = TRUE;
if (gtk_progress_bar_get_fraction (cpb) != 1.0)
{
close = FALSE;
break;
}
}
}
}
if (need_close && close)
yad_exit (options.data.def_resp);
}
}
}
}
while (g_io_channel_get_buffer_condition (channel) == G_IO_IN);
g_string_free (string, TRUE);
}
if ((condition != G_IO_IN) && (condition != G_IO_IN + G_IO_HUP))
{
g_io_channel_shutdown (channel, TRUE, NULL);
return FALSE;
}
return TRUE;
}
GtkWidget *
multi_progress_create_widget (GtkWidget * dlg)
{
GtkWidget *table;
GIOChannel *channel;
GSList *b;
gint i = 0;
nbars = g_slist_length (options.multi_progress_data.bars);
if (nbars < 1)
return NULL;
table = gtk_grid_new ();
gtk_grid_set_row_spacing (GTK_GRID (table), 2);
gtk_grid_set_column_spacing (GTK_GRID (table), 2);
for (b = options.multi_progress_data.bars; b; b = b->next)
{
GtkWidget *l, *w;
YadProgressBar *p = (YadProgressBar *) b->data;
/* add label */
l = gtk_label_new (NULL);
if (options.data.no_markup)
gtk_label_set_text (GTK_LABEL (l), p->name);
else
gtk_label_set_markup (GTK_LABEL (l), p->name);
gtk_label_set_xalign (GTK_LABEL (l), options.common_data.align);
if (options.common_data.vertical)
gtk_grid_attach (GTK_GRID (table), l, i, 1, 1, 1);
else
gtk_grid_attach (GTK_GRID (table), l, 0, i, 1, 1);
/* add progress bar */
w = gtk_progress_bar_new ();
gtk_widget_set_name (w, "yad-progress-widget");
gtk_progress_bar_set_show_text (GTK_PROGRESS_BAR (w), TRUE);
if (p->type != YAD_PROGRESS_PULSE)
{
if (options.extra_data && options.extra_data[i])
{
if (g_ascii_isdigit (*options.extra_data[i]))
gtk_progress_bar_set_fraction (GTK_PROGRESS_BAR (w), atoi (options.extra_data[i]) / 100.0);
}
}
else
{
if (options.extra_data && options.extra_data[i])
{
if (g_ascii_isdigit (*options.extra_data[i]))
gtk_progress_bar_set_pulse_step (GTK_PROGRESS_BAR (w), atoi (options.extra_data[i]) / 100.0);
}
}
gtk_progress_bar_set_inverted (GTK_PROGRESS_BAR (w), p->type == YAD_PROGRESS_RTL);
if (options.common_data.vertical)
gtk_orientable_set_orientation (GTK_ORIENTABLE (w), GTK_ORIENTATION_VERTICAL);
if (options.common_data.vertical)
{
gtk_grid_attach (GTK_GRID (table), w, i, 0, 1, 1);
gtk_widget_set_vexpand (w, TRUE);
}
else
{
gtk_grid_attach (GTK_GRID (table), w, 1, i, 1, 1);
gtk_widget_set_hexpand (w, TRUE);
}
progress_bars = g_slist_append (progress_bars, w);
i++;
}
channel = g_io_channel_unix_new (0);
g_io_channel_set_encoding (channel, NULL, NULL);
g_io_channel_set_flags (channel, G_IO_FLAG_NONBLOCK, NULL);
g_io_add_watch (channel, G_IO_IN | G_IO_HUP, handle_stdin, dlg);
return table;
}