workbench/system/SysMon/tasks.c

   1 /*
   2     Copyright 2010-2016, The AROS Development Team. All rights reserved.
   3     $Id$
   4 */
   5
   6 #include <exec/execbase.h>
   7 #include <resources/task.h>
   8 #include <clib/alib_protos.h>
   9
  10 #include <proto/task.h>
  11 #include <proto/dos.h>
  12
  13 #include "locale.h"
  14
  15 #include "sysmon_intern.h"
  16
  17 //#define DEBUG 1
  18 #include <aros/debug.h>
  19
  20
  21 APTR TaskResBase = NULL;
  22
  23 /* Task information handling*/
  24 struct TaskInfo
  25 {
  26     struct Node TINode;
  27     struct Task *Task;
  28     ULONG TimeCurrent;
  29     ULONG TimeLast;
  30 };
  31
  32 VOID UpdateTasksInformation(struct SysMonData * smdata)
  33 {
  34     struct Task * task;
  35     IPTR firstvis = 0, entryid = 0;
  36     struct Task *selected = smdata->sm_TaskSelected;
  37     struct TaskList *systasklist;
  38
  39     set(smdata->tasklist, MUIA_List_Quiet, TRUE);
  40
  41     get(smdata->tasklist, MUIA_List_First, &firstvis);
  42
  43     DoMethod(smdata->tasklist, MUIM_List_Clear);
  44
  45     smdata->sm_TasksWaiting = 0;
  46     smdata->sm_TasksReady = 0;
  47     smdata->sm_TaskTotalRuntime = 0;
  48
  49     systasklist = LockTaskList(0);
  50     while ((task = NextTaskEntry(systasklist, 0)) != NULL)
  51     {
  52         D(bug("[SysMon] task %s state %d\n", task->tc_Node.ln_Name, task->tc_State));
  53
  54         if (task->tc_State == TS_READY)
  55         {
  56             smdata->sm_TasksReady++;
  57         }
  58         if (task->tc_State == TS_WAIT)
  59         {
  60             smdata->sm_TasksWaiting++;
  61         }
  62
  63         entryid = DoMethod(smdata->tasklist, MUIM_List_InsertSingle, task, MUIV_List_Insert_Bottom);
  64         if (task == selected)
  65         {
  66             set(smdata->tasklist, MUIA_List_Active, entryid);
  67         }
  68     }
  69     UnLockTaskList(0);
  70
  71     if (XGET(smdata->tasklist, MUIA_List_Active) == 0)
  72         smdata->sm_TaskSelected = NULL;
  73
  74     /* Keep the "pre-refresh" view on List as much as possible */
  75     LONG v = (LONG)firstvis;
  76     if (firstvis + XGET(smdata->tasklist, MUIA_List_Visible) >= XGET(smdata->tasklist, MUIA_List_Entries))
  77     {
  78         v = XGET(smdata->tasklist, MUIA_List_Entries) - XGET(smdata->tasklist, MUIA_List_Visible);
  79         if (v < 0) v = 0;
  80     }
  81
  82     set(smdata->tasklist, MUIA_List_First, v);
  83
  84     __sprintf(smdata->tasklistinfobuf, (STRPTR)__(MSG_TASK_READY_AND_WAIT), smdata->sm_TasksReady, smdata->sm_TasksWaiting);
  85     set(smdata->tasklistinfo, MUIA_Text_Contents, smdata->tasklistinfobuf);
  86     set(smdata->tasklist, MUIA_List_Quiet, FALSE);
  87 }
  88
  89 AROS_UFH3(struct TaskInfo *, TasksListConstructFunction,
  90     AROS_UFHA(struct Hook *, h,  A0),
  91     AROS_UFHA(APTR, pool, A2),
  92     AROS_UFHA(struct Task *, curTask, A1))
  93 {
  94     AROS_USERFUNC_INIT
  95
  96     struct TaskInfo *ti = NULL;
  97
  98     if ((ti = AllocVecPooled(pool, sizeof(struct TaskInfo))) != NULL)
  99     {
 100         ti->Task = curTask;
 101
 102         /* Cache values we need incase something happens to the task .. */
 103         ti->TINode.ln_Type = curTask->tc_Node.ln_Type;
 104         ti->TINode.ln_Pri = (WORD)curTask->tc_Node.ln_Pri;
 105         ti->TINode.ln_Name = StrDup(curTask->tc_Node.ln_Name);
 106
 107         AddTail(&((struct SysMonData *)h->h_Data)->sm_TaskList, &ti->TINode);
 108     }
 109     return ti;
 110
 111     AROS_USERFUNC_EXIT
 112 }
 113
 114 AROS_UFH3(VOID, TasksListDestructFunction,
 115     AROS_UFHA(struct Hook *, h,  A0),
 116     AROS_UFHA(APTR, pool, A2),
 117     AROS_UFHA(struct TaskInfo *, ti, A1))
 118 {
 119     AROS_USERFUNC_INIT
 120
 121     Remove(&ti->TINode);
 122     FreeVec(ti->TINode.ln_Name);
 123     FreeVecPooled(pool, ti);
 124
 125     AROS_USERFUNC_EXIT
 126 }
 127
 128 AROS_UFH3(VOID, TaskSelectedFunction,
 129     AROS_UFHA(struct Hook *, h, A0),
 130     AROS_UFHA(Object *, obj, A2),
 131     AROS_UFHA(APTR, msg, A1))
 132 {
 133     AROS_USERFUNC_INIT
 134
 135     struct SysMonData *smdata = h->h_Data;
 136     struct TaskInfo *ti = NULL;
 137
 138     DoMethod(smdata->tasklist, MUIM_List_GetEntry, MUIV_List_GetEntry_Active, &ti);
 139
 140     if (ti != NULL)
 141     {
 142         smdata->sm_TaskSelected = ti->Task;
 143     }
 144     else
 145         smdata->sm_TaskSelected = NULL;
 146
 147     AROS_USERFUNC_EXIT
 148 }
 149
 150
 151 AROS_UFH3(VOID, TasksListDisplayFunction,
 152     AROS_UFHA(struct Hook *, h,  A0),
 153     AROS_UFHA(STRPTR *, strings, A2),
 154     AROS_UFHA(struct TaskInfo *, ti, A1))
 155 {
 156     AROS_USERFUNC_INIT
 157
 158     static TEXT bufprio[8];
 159
 160     if (ti)
 161     {
 162         __sprintf(bufprio, "%d", (LONG)ti->TINode.ln_Pri);
 163
 164         strings[0] = ti->TINode.ln_Name;
 165         strings[1] = bufprio;
 166         strings[2] = ti->TINode.ln_Type == NT_TASK ? (STRPTR)_(MSG_TASK) : (STRPTR)_(MSG_PROCESS);
 167     }
 168     else
 169     {
 170         strings[0] = (STRPTR)_(MSG_TASK_NAME);
 171         strings[1] = (STRPTR)_(MSG_TASK_PRIORITY);
 172         strings[2] = (STRPTR)_(MSG_TASK_TYPE);
 173     }
 174
 175     AROS_USERFUNC_EXIT
 176 }
 177
 178 static BOOL InitTasks(struct SysMonData *smdata)
 179 {
 180     TaskResBase = OpenResource("task.resource");
 181     if (TaskResBase == NULL)
 182     {
 183         FPuts(Output(), (STRPTR)_(MSG_CANT_OPEN_TASK_RESOURCE));
 184         return FALSE;
 185     }
 186
 187     smdata->sm_Task = FindTask(NULL);
 188     NewList(&smdata->sm_TaskList);
 189
 190     smdata->tasklistinfobuf = AllocVec(30, MEMF_PUBLIC);
 191
 192     smdata->sm_TaskSelected = NULL;
 193     smdata->sm_TaskTotalRuntime = 0;
 194
 195     return TRUE;
 196 }
 197
 198 static VOID DeInitTasks(struct SysMonData *smdata)
 199 {
 200     FreeVec(smdata->tasklistinfobuf);
 201 }
 202
 203 struct SysMonModule tasksmodule =
 204 {
 205     .Init = InitTasks,
 206     .DeInit = DeInitTasks,
 207 };
 208