epicsThread.cpp File Reference

#include <exception>
#include <typeinfo>
#include <stdio.h>
#include <stddef.h>
#include <float.h>
#include <string.h>
#include "epicsAlgorithm.h"
#include "epicsTime.h"
#include "epicsThread.h"
#include "epicsAssert.h"
#include "epicsGuard.h"
#include "errlog.h"

Include dependency graph for epicsThread.cpp:

Go to the source code of this file.

Classes
class	epicsThread::unableToCreateThread

Functions
epicsThreadId epicsStdCall	epicsThreadCreate (const char *name, unsigned int priority, unsigned int stackSize, EPICSTHREADFUNC funptr, void *parm)
void	epicsThreadCallEntryPoint (void *pPvt)
int epicsStdCall	epicsThreadIsOkToBlock (void)
void epicsStdCall	epicsThreadSetOkToBlock (int isOkToBlock)
epicsThreadId epicsStdCall	epicsThreadMustCreate (const char *name, unsigned int priority, unsigned int stackSize, EPICSTHREADFUNC funptr, void *parm)

Variables
epicsThreadPrivateId	okToBlockPrivate
epicsThreadId	epicsThreadMainId = initMainThread()

Function Documentation

void epicsThreadCallEntryPoint

(

void *

pPvt

)

Definition at line 86 of file epicsThread.cpp.

{
    epicsThread * pThread =
        static_cast <epicsThread *> ( pPvt );
    bool threadDestroyed = false;
    try {
        pThread->pThreadDestroyed = & threadDestroyed;
        if ( pThread->beginWait () ) {
            pThread->runable.run ();
            // The run() routine may have destroyed the epicsThread
            // object by now; pThread can only be used below here
            // when the threadDestroyed flag is false.
        }
    }
    catch ( const epicsThread::exitException & ) {
    }
    catch ( std :: exception & except ) {
        if ( ! threadDestroyed ) {
            pThread->printLastChanceExceptionMessage (
                typeid ( except ).name (), except.what () );
        }
    }
    catch ( ... ) {
        if ( ! threadDestroyed ) {
            pThread->printLastChanceExceptionMessage (
                "catch ( ... )", "Non-standard C++ exception" );
        }
    }
    if ( ! threadDestroyed ) {
        epicsGuard < epicsMutex > guard ( pThread->mutex );
        pThread->pThreadDestroyed = NULL;
        pThread->terminated = true;
        pThread->exitEvent.signal ();
        // After the terminated flag is set and guard's destructor
        // releases the lock, pThread must never be used again.
    }
}

epicsThreadId epicsStdCall epicsThreadCreate	(	const char *	name,
		unsigned int	priority,
		unsigned int	stackSize,
		EPICSTHREADFUNC	funptr,
		void *	parm
	)

Short-hand for epicsThreadCreateOpt() to create an un-joinable thread.

Definition at line 33 of file epicsThread.cpp.

{
    epicsThreadOpts opts = EPICS_THREAD_OPTS_INIT;
    opts.priority = priority;
    opts.stackSize = stackSize;
    opts.joinable = 0;

    return epicsThreadCreateOpt(name, funptr, parm, &opts);
}

int epicsStdCall epicsThreadIsOkToBlock

(

void

)

Is it OK for a thread to block? This can be called by support code that does not know if it is called in a thread that should not block. For example the errlog system calls this to decide when messages should be displayed on the console.

Definition at line 358 of file epicsThread.cpp.

    {
        const int *pokToBlock;
        epicsThreadOnce(&okToBlockOnce, epicsThreadOnceIdInit, NULL);
        pokToBlock = (int *) epicsThreadPrivateGet(okToBlockPrivate);
        return (pokToBlock ? *pokToBlock : 0);
    }

epicsThreadId epicsStdCall epicsThreadMustCreate	(	const char *	name,
		unsigned int	priority,
		unsigned int	stackSize,
		EPICSTHREADFUNC	funptr,
		void *	parm
	)

Short-hand for epicsThreadCreateOpt() to create an un-joinable thread. On error calls cantProceed()

Definition at line 374 of file epicsThread.cpp.

    {
        epicsThreadId id = epicsThreadCreate (
            name, priority, stackSize, funptr, parm );
        assert ( id );
        return id;
    }

void epicsStdCall epicsThreadSetOkToBlock

(

int

isOkToBlock

)

When a thread is started the default is that it is not allowed to block. This method can be called to change the state. For example iocsh calls this to specify that it is OK to block.

Definition at line 366 of file epicsThread.cpp.

    {
        const int *pokToBlock;
        epicsThreadOnce(&okToBlockOnce, epicsThreadOnceIdInit, NULL);
        pokToBlock = (isOkToBlock) ? &okToBlockYes : &okToBlockNo;
        epicsThreadPrivateSet(okToBlockPrivate, (void *)pokToBlock);
    }

Variable Documentation

epicsThreadId epicsThreadMainId = initMainThread()

Definition at line 392 of file epicsThread.cpp.

epicsThreadPrivateId okToBlockPrivate

Definition at line 349 of file epicsThread.cpp.