diff --git a/src/libsysprof-ui/meson.build b/src/libsysprof-ui/meson.build index 9ee8c6c6..5ec95baf 100644 --- a/src/libsysprof-ui/meson.build +++ b/src/libsysprof-ui/meson.build @@ -41,6 +41,7 @@ libsysprof_ui_private_sources = [ 'sysprof-environ-editor.c', 'sysprof-environ-variable.c', 'sysprof-environ.c', + 'sysprof-log-model.c', 'sysprof-tab.c', 'sysprof-time-label.c', 'sysprof-theme-manager.c', diff --git a/src/libsysprof-ui/sysprof-log-model.c b/src/libsysprof-ui/sysprof-log-model.c new file mode 100644 index 00000000..3726f911 --- /dev/null +++ b/src/libsysprof-ui/sysprof-log-model.c @@ -0,0 +1,380 @@ +/* sysprof-log-model.c + * + * Copyright 2019 Christian Hergert + * + * This program 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. + * + * This program 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 this program. If not, see . + * + * SPDX-License-Identifier: GPL-3.0-or-later + */ + +#define G_LOG_DOMAIN "sysprof-log-model" + +#include "config.h" + +#include +#include + +#include "sysprof-log-model.h" + +struct _SysprofLogModel +{ + GObject parent_instance; + GStringChunk *chunks; + GArray *items; +}; + +typedef struct +{ + gint64 time; + const gchar *domain; + const gchar *message; + guint16 severity; +} Item; + +static gint +sysprof_log_model_get_n_columns (GtkTreeModel *model) +{ + return SYSPROF_LOG_MODEL_COLUMN_LAST; +} + +static GType +sysprof_log_model_get_column_type (GtkTreeModel *model, + gint column) +{ + switch (column) + { + case SYSPROF_LOG_MODEL_COLUMN_TIME: + return G_TYPE_INT64; + + case SYSPROF_LOG_MODEL_COLUMN_SEVERITY: + return G_TYPE_UINT; + + case SYSPROF_LOG_MODEL_COLUMN_DOMAIN: + case SYSPROF_LOG_MODEL_COLUMN_MESSAGE: + return G_TYPE_STRING; + + default: + return 0; + } +} + +static GtkTreePath * +sysprof_log_model_get_path (GtkTreeModel *model, + GtkTreeIter *iter) +{ + gint off; + + g_assert (SYSPROF_IS_LOG_MODEL (model)); + g_assert (iter != NULL); + + off = GPOINTER_TO_INT (iter->user_data); + + return gtk_tree_path_new_from_indices (off, -1); +} + +static gboolean +sysprof_log_model_get_iter (GtkTreeModel *model, + GtkTreeIter *iter, + GtkTreePath *path) +{ + SysprofLogModel *self = (SysprofLogModel *)model; + gint off; + + g_assert (SYSPROF_IS_LOG_MODEL (self)); + g_assert (iter != NULL); + g_assert (path != NULL); + + memset (iter, 0, sizeof *iter); + + if (gtk_tree_path_get_depth (path) != 1) + return FALSE; + + off = gtk_tree_path_get_indices (path)[0]; + iter->user_data = GINT_TO_POINTER (off); + + return off >= 0 && off < self->items->len; +} + +static gboolean +sysprof_log_model_iter_next (GtkTreeModel *model, + GtkTreeIter *iter) +{ + SysprofLogModel *self = (SysprofLogModel *)model; + gint off; + + g_assert (SYSPROF_IS_LOG_MODEL (self)); + g_assert (iter != NULL); + + off = GPOINTER_TO_INT (iter->user_data); + off++; + iter->user_data = GINT_TO_POINTER (off); + + return off < self->items->len; +} + +static gboolean +sysprof_log_model_iter_nth_child (GtkTreeModel *model, + GtkTreeIter *iter, + GtkTreeIter *parent, + gint n) +{ + SysprofLogModel *self = (SysprofLogModel *)model; + + g_assert (SYSPROF_IS_LOG_MODEL (self)); + g_assert (iter != NULL); + + if (parent != NULL) + return FALSE; + + iter->user_data = GINT_TO_POINTER (n); + + return n < self->items->len; +} + +static gint +sysprof_log_model_iter_n_children (GtkTreeModel *model, + GtkTreeIter *iter) +{ + SysprofLogModel *self = (SysprofLogModel *)model; + + g_assert (SYSPROF_IS_LOG_MODEL (self)); + + return iter ? 0 : self->items->len; +} + +static gboolean +sysprof_log_model_iter_has_child (GtkTreeModel *model, + GtkTreeIter *iter) +{ + return FALSE; +} + +static GtkTreeModelFlags +sysprof_log_model_get_flags (GtkTreeModel *model) +{ + return GTK_TREE_MODEL_LIST_ONLY; +} + +static void +sysprof_log_model_get_value (GtkTreeModel *model, + GtkTreeIter *iter, + gint column, + GValue *value) +{ + SysprofLogModel *self = (SysprofLogModel *)model; + const Item *item; + + g_assert (SYSPROF_IS_LOG_MODEL (self)); + g_assert (iter != NULL); + g_assert (column < SYSPROF_LOG_MODEL_COLUMN_LAST); + + item = &g_array_index (self->items, Item, GPOINTER_TO_INT (iter->user_data)); + + switch (column) + { + case SYSPROF_LOG_MODEL_COLUMN_TIME: + g_value_init (value, G_TYPE_INT64); + g_value_set_int64 (value, item->time); + break; + + case SYSPROF_LOG_MODEL_COLUMN_SEVERITY: + g_value_init (value, G_TYPE_UINT); + g_value_set_uint (value, item->severity); + break; + + case SYSPROF_LOG_MODEL_COLUMN_DOMAIN: + g_value_init (value, G_TYPE_STRING); + g_value_set_string (value, item->domain); + break; + + case SYSPROF_LOG_MODEL_COLUMN_MESSAGE: + g_value_init (value, G_TYPE_STRING); + g_value_set_string (value, item->message); + break; + + default: + break; + } +} + +static void +tree_model_iface_init (GtkTreeModelIface *iface) +{ + iface->get_n_columns = sysprof_log_model_get_n_columns; + iface->get_column_type = sysprof_log_model_get_column_type; + iface->get_iter = sysprof_log_model_get_iter; + iface->get_path = sysprof_log_model_get_path; + iface->iter_next = sysprof_log_model_iter_next; + iface->iter_n_children = sysprof_log_model_iter_n_children; + iface->iter_nth_child = sysprof_log_model_iter_nth_child; + iface->iter_has_child = sysprof_log_model_iter_has_child; + iface->get_flags = sysprof_log_model_get_flags; + iface->get_value = sysprof_log_model_get_value; +} + +G_DEFINE_TYPE_WITH_CODE (SysprofLogModel, sysprof_log_model, G_TYPE_OBJECT, + G_IMPLEMENT_INTERFACE (GTK_TYPE_TREE_MODEL, tree_model_iface_init)) + +static void +sysprof_log_model_finalize (GObject *object) +{ + SysprofLogModel *self = (SysprofLogModel *)object; + + g_clear_pointer (&self->items, g_array_unref); + g_clear_pointer (&self->chunks, g_string_chunk_free); + + G_OBJECT_CLASS (sysprof_log_model_parent_class)->finalize (object); +} + +static void +sysprof_log_model_class_init (SysprofLogModelClass *klass) +{ + GObjectClass *object_class = G_OBJECT_CLASS (klass); + + object_class->finalize = sysprof_log_model_finalize; +} + +static void +sysprof_log_model_init (SysprofLogModel *self) +{ + self->chunks = g_string_chunk_new (4096*16); + self->items = g_array_new (FALSE, FALSE, sizeof (Item)); +} + +static gboolean +cursor_foreach_cb (const SysprofCaptureFrame *frame, + gpointer user_data) +{ + SysprofLogModel *self = user_data; + SysprofCaptureLog *log = (SysprofCaptureLog *)frame; + Item item; + + g_assert (SYSPROF_IS_LOG_MODEL (self)); + g_assert (frame->type == SYSPROF_CAPTURE_FRAME_LOG); + + item.time = frame->time; + item.severity = log->severity; + item.domain = g_string_chunk_insert_const (self->chunks, log->domain); + item.message = g_string_chunk_insert_const (self->chunks, log->message); + + g_array_append_val (self->items, item); + + return TRUE; +} + +static gint +item_compare (gconstpointer a, + gconstpointer b) +{ + const Item *ia = a; + const Item *ib = b; + + if (ia->time < ib->time) + return -1; + else if (ia->time > ib->time) + return 1; + else + return 0; +} + +static void +sysprof_log_model_new_worker (GTask *task, + gpointer source_object, + gpointer task_data, + GCancellable *cancellable) +{ + g_autoptr(SysprofLogModel) self = NULL; + SysprofCaptureCursor *cursor = task_data; + + g_assert (G_IS_TASK (task)); + g_assert (!cancellable || G_IS_CANCELLABLE (cancellable)); + + self = g_object_new (SYSPROF_TYPE_LOG_MODEL, NULL); + sysprof_capture_cursor_foreach (cursor, cursor_foreach_cb, self); + g_array_sort (self->items, item_compare); + + g_task_return_pointer (task, g_steal_pointer (&self), g_object_unref); +} + +static void +sysprof_log_model_selection_foreach_cb (SysprofSelection *selection, + gint64 begin, + gint64 end, + gpointer user_data) +{ + SysprofCaptureCondition **condition = user_data; + SysprofCaptureCondition *c; + + g_assert (SYSPROF_IS_SELECTION (selection)); + g_assert (condition != NULL); + + c = sysprof_capture_condition_new_where_time_between (begin, end); + + if (*condition != NULL) + *condition = sysprof_capture_condition_new_or (g_steal_pointer (&c), + g_steal_pointer (condition)); + else + *condition = g_steal_pointer (&c); +} + +void +sysprof_log_model_new_async (SysprofCaptureReader *reader, + SysprofSelection *selection, + GCancellable *cancellable, + GAsyncReadyCallback callback, + gpointer user_data) +{ + static const SysprofCaptureFrameType types[] = { + SYSPROF_CAPTURE_FRAME_LOG, + }; + g_autoptr(SysprofCaptureCursor) cursor = NULL; + SysprofCaptureCondition *c; + g_autoptr(GTask) task = NULL; + + g_return_if_fail (reader != NULL); + g_return_if_fail (!selection || SYSPROF_IS_SELECTION (selection)); + g_return_if_fail (!cancellable || G_IS_CANCELLABLE (cancellable)); + + cursor = sysprof_capture_cursor_new (reader); + c = sysprof_capture_condition_new_where_type_in (G_N_ELEMENTS (types), types); + + if (selection) + { + SysprofCaptureCondition *condition = NULL; + + sysprof_selection_foreach (selection, + sysprof_log_model_selection_foreach_cb, + &condition); + if (condition) + c = sysprof_capture_condition_new_and (c, g_steal_pointer (&condition)); + } + + sysprof_capture_cursor_add_condition (cursor, g_steal_pointer (&c)); + + task = g_task_new (NULL, cancellable, callback, user_data); + g_task_set_source_tag (task, sysprof_log_model_new_async); + g_task_set_task_data (task, + g_steal_pointer (&cursor), + (GDestroyNotify) sysprof_capture_cursor_unref); + g_task_run_in_thread (task, sysprof_log_model_new_worker); +} + +SysprofLogModel * +sysprof_log_model_new_finish (GAsyncResult *result, + GError **error) +{ + g_return_val_if_fail (G_IS_TASK (result), NULL); + + return g_task_propagate_pointer (G_TASK (result), error); +} diff --git a/src/libsysprof-ui/sysprof-log-model.h b/src/libsysprof-ui/sysprof-log-model.h new file mode 100644 index 00000000..cd8e8652 --- /dev/null +++ b/src/libsysprof-ui/sysprof-log-model.h @@ -0,0 +1,48 @@ +/* sysprof-log-model.h + * + * Copyright 2019 Christian Hergert + * + * This program 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. + * + * This program 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 this program. If not, see . + * + * SPDX-License-Identifier: GPL-3.0-or-later + */ + +#pragma once + +#include + +G_BEGIN_DECLS + +typedef enum +{ + SYSPROF_LOG_MODEL_COLUMN_TIME, + SYSPROF_LOG_MODEL_COLUMN_SEVERITY, + SYSPROF_LOG_MODEL_COLUMN_DOMAIN, + SYSPROF_LOG_MODEL_COLUMN_MESSAGE, + SYSPROF_LOG_MODEL_COLUMN_LAST +} SysprofLogModelColumn; + +#define SYSPROF_TYPE_LOG_MODEL (sysprof_log_model_get_type()) + +G_DECLARE_FINAL_TYPE (SysprofLogModel, sysprof_log_model, SYSPROF, LOG_MODEL, GObject) + +void sysprof_log_model_new_async (SysprofCaptureReader *reader, + SysprofSelection *selection, + GCancellable *cancellable, + GAsyncReadyCallback callback, + gpointer user_data); +SysprofLogModel *sysprof_log_model_new_finish (GAsyncResult *result, + GError **error); + +G_END_DECLS