threadShow.c

Go to the documentation of this file.

/********************************************/
#include <stdlib.h>
#include <sched.h>
#include <string.h>
#include <pthread.h>

#include <ellLib.h>
#include <errlog.h>
#include <epicsStdio.h>
#include <epicsEvent.h>
#include <epicsThread.h>
#include <epicsMath.h>
#include <shareLib.h>

#include "utils.h"

#define epicsExportSharedSymbols

#include "mcoreutils.h"

static epicsThreadId showThread;
static unsigned int showLevel;
static char *buffer;
static char *cpuspec;
static const char *policies;

static void mcoreThreadShowPrint(epicsThreadOSD *pthreadInfo, unsigned int level)
{
    if (!pthreadInfo) {
        fprintf(epicsGetStdout(), "            NAME       EPICS ID   "
            "LWP ID   OSIPRI  OSSPRI  STATE  POLICY CPUSET\n");
    } else {
        struct sched_param param;
        int priority = 0;
        int policy;

        policies = "?";
        cpuspec[0] = '?'; cpuspec[1] = '\0';
        if (pthreadInfo->tid) {
            cpu_set_t cpuset;
            int status;
            status = pthread_getschedparam(pthreadInfo->tid,
                                           &policy,
                                           &param);
            if (errVerbose)
                checkStatus(status,"pthread_getschedparam");

            if (!status) {
                priority = param.sched_priority;
                policies = policyToStr(policy);
            }

            status = pthread_getaffinity_np(pthreadInfo->tid,
                                            sizeof(cpu_set_t),
                                            &cpuset);
            if (!status) {
                cpusetToStr(cpuspec, NO_OF_CPUS+2, &cpuset);
            }
        }

        fprintf(epicsGetStdout(),"%16.16s %14p %8lu    %3d%8d %8.8s %7.7s %s\n",
                pthreadInfo->name,
                (void *)pthreadInfo,
                (unsigned long)pthreadInfo->lwpId,
                pthreadInfo->osiPriority, priority,
                pthreadInfo->isSuspended ? "SUSPEND" : "OK",
                policies, cpuspec);
    }
}

static void mcoreThreadInfo(epicsThreadId id)
{
    mcoreThreadShowPrint(id, showLevel);
}

static void mcoreThreadInfoOne(epicsThreadId id)
{
    intptr_t u = id->lwpId;
    if (id == showThread || (epicsThreadId) u == showThread) {
        mcoreThreadInfo(id);
    }
}

void mcoreThreadShow(epicsThreadId thread, unsigned int level)
{
    if (!thread) {
        mcoreThreadShowPrint(0, level);
        return;
    }
    showThread = thread;
    showLevel = level;
    epicsThreadMap(mcoreThreadInfoOne);
}

void mcoreThreadShowAll(unsigned int level)
{
    showLevel = level;
    mcoreThreadShowPrint(0, level);
    epicsThreadMap(mcoreThreadInfo);
}

static void once(void *arg)
{
    cpuDigits = (int) log10(NO_OF_CPUS-1) + 1;
    if (!buffer)  buffer  = (char *) calloc(cpuDigits+2, sizeof(char));
    if (!cpuspec) cpuspec = (char *) calloc(NO_OF_CPUS + 2, sizeof(char));
    printf("MCoreUtils version " VERSION "\n");
}

void mcoreThreadShowInit(void)
{
    static epicsThreadOnceId onceFlag = EPICS_THREAD_ONCE_INIT;
    epicsThreadOnce(&onceFlag, once, NULL);
}