Threading Class Reference

#include "Threading.h"

Inheritance diagram for Threading:

Collaboration diagram for Threading:

Public Member Functions
uint8	Count ()
Threading.cpp
lightweight thread pool specifically for EvEmu Sockets this code is very basic and very specific. : Allan Date : 05 March 2016
	Threading ()
	~Threading ()
void	Initialize ()
void	RunLoop ()
void	Process ()
void	AddSocket (SOCKET soc)
void	AddThread (pthread_t thread)
void	RemoveThread (pthread_t thread)
void	CreateThread (void *(*start_routine)(void *), void *args)
void	EndThreads ()
void	ListThreads ()
Public Member Functions inherited from Singleton< Threading >
	Singleton ()
	Primary constructor. More...

Protected Attributes
char *	buf
fd_set	rSoc
fd_set	wSoc
struct timeval	tv
uint8	nfds
uint8	sleepTime
uint32	bufferLen

Private Attributes
std::vector< pthread_t >	m_threads

Additional Inherited Members
Static Public Member Functions inherited from Singleton< Threading >
static Threading &	get ()
Static Protected Attributes inherited from Singleton< Threading >
static std::shared_ptr< Threading >	mInstance

Detailed Description

Definition at line 16 of file Threading.h.

Constructor & Destructor Documentation

Threading::Threading

(

)

Todo:

the entire concurrency idea needs work throughout evemu. currently, it uses posix threads, boost, and shared_pointer. they all need updating

Note

image server uses boost::asio::thread and has no problems....leave for now, and may leave as is.

update this to use thread pools and strictly for network sockets

Definition at line 22 of file Threading.cpp.

: buf(nullptr),
 tv(timeval()),
 nfds(0),
 sleepTime(0),
 bufferLen(0)
{
}

Threading::~Threading

(

)

Definition at line 31 of file Threading.cpp.

References m_threads.

{
    m_threads.clear();
}

Member Function Documentation

void Threading::AddSocket

(

SOCKET

soc

)

Definition at line 81 of file Threading.cpp.

References nfds, rSoc, and wSoc.

                                    {
    /* when adding a new socket, we must add it to the read and write sets, with it's fd# */
    FD_SET(soc, &rSoc);
    FD_SET(soc, &wSoc);
    ++nfds;
}

void Threading::AddThread

(

pthread_t

thread

)

Definition at line 100 of file Threading.cpp.

References _log, and m_threads.

Referenced by CreateThread().

                                          {
    m_threads.push_back(thread);
    _log(THREAD__INFO, "AddThread() - Added thread ID 0x%X", thread);
}

Here is the caller graph for this function:

uint8 Threading::Count ( )

inline

Definition at line 34 of file Threading.h.

References m_threads.

{ return (uint8)(m_threads.size()); }

void Threading::CreateThread	(	void *(*)(void *)	start_routine,
		void *	args
	)

Definition at line 88 of file Threading.cpp.

References _log, and AddThread().

                                                                        {
    pthread_t thread;
    int status = pthread_create( &thread, nullptr, start_routine, args);
    if (status) {
        _log(THREAD__ERROR, "CreateThread() - Error Creating new thread: %s", strerror(errno));
    } else {
        _log(THREAD__INFO, "CreateThread() - Creating new threadID 0x%X", thread);
        AddThread(thread);
        pthread_detach(thread);
    }
}

Here is the call graph for this function:

void Threading::EndThreads

(

)

Definition at line 121 of file Threading.cpp.

References _log, and m_threads.

                           {
    if (!m_threads.size()) {
        _log(THREAD__MESSAGE, "EndThreads() - There are no active threads.");
        return;
    }
    _log(THREAD__MESSAGE, "EndThreads() - Joining %u currently active threads.", m_threads.size());
    std::vector<pthread_t>::iterator cur = m_threads.begin();
    while ((cur != m_threads.end())) {
        _log(THREAD__TRACE, "EndThreads() - Removing threadID 0x%X", (*cur));
        cur = m_threads.erase(cur);
    }
    m_threads.clear();
}

void Threading::Initialize

(

)

Definition at line 36 of file Threading.cpp.

References bufferLen, m_threads, nfds, sleepTime, sLog, and tv.

                           {
    nfds = 1;
    bufferLen = 64 * 1024; // 64kbyte recieve buffer, up from default of 8k
    sleepTime = 10;     //sConfig.rates.NetSleepTime
    tv.tv_sec = 0;
    tv.tv_usec = 0;
    m_threads.clear();
    sLog.Blue( "        Threading", "Threading System Initialized.");
}

void Threading::ListThreads

(

)

Definition at line 116 of file Threading.cpp.

References m_threads, and sLog.

                            {
    for (auto cur : m_threads)
        sLog.Warning( "                 ", "ThreadID 0x%X", cur );
}

void Threading::Process

(

)

Todo:

begin basic thread pool for processing sockets, using select()

Definition at line 54 of file Threading.cpp.

References _log, buf, bufferLen, nfds, rSoc, tv, and wSoc.

Referenced by RunLoop().

                        {
    /* reset timeouts because select() reset them */
    tv.tv_sec = 0;
    tv.tv_usec = 0;
    FD_ZERO(&rSoc);
    FD_ZERO(&wSoc);
    FD_SET(0, &rSoc);
    FD_SET(0, &wSoc);
    int status = select(nfds, &rSoc, &wSoc, nullptr, &tv);
    if (status == 0) /* nothing ready yet */
        return;
    else if (status == -1) {  /* error */
        _log(THREAD__ERROR, "Process() - select() returned: %s", strerror(status));
        return;
    }
    if (FD_ISSET(nfds, &rSoc)) {
        buf = (char*) malloc (bufferLen);
        /* read from socket here */
        free(buf);
    }
    if (FD_ISSET(nfds, &wSoc)) {
        buf = (char*) malloc (bufferLen);
        /* write to socket here */
        free(buf);
    }

}

Here is the caller graph for this function:

void Threading::RemoveThread

(

pthread_t

thread

)

Definition at line 105 of file Threading.cpp.

References _log, and m_threads.

                                             {
    for (std::vector<pthread_t>::iterator cur = m_threads.begin(); cur != m_threads.end(); ++cur) {
        if ((*cur) == thread) {
            _log(THREAD__INFO, "RemoveThread() called for thread ID 0x%X", thread);
            m_threads.erase(cur);
            return;
        }
    }
    _log(THREAD__ERROR, "RemoveThread() - Called on unregistered threadID 0x%X", thread);
}

void Threading::RunLoop

(

)

Definition at line 46 of file Threading.cpp.

References Process(), Sleep(), and sleepTime.

                        {
    while (true) {
        Process();
        Sleep(sleepTime);
    }
}

Here is the call graph for this function:

Member Data Documentation

char* Threading::buf

protected

Definition at line 37 of file Threading.h.

Referenced by Process().

uint32 Threading::bufferLen

protected

Definition at line 43 of file Threading.h.

Referenced by Initialize(), and Process().

std::vector<pthread_t> Threading::m_threads

private

Definition at line 46 of file Threading.h.

Referenced by AddThread(), Count(), EndThreads(), Initialize(), ListThreads(), RemoveThread(), and ~Threading().

uint8 Threading::nfds

protected

Definition at line 41 of file Threading.h.

Referenced by AddSocket(), Initialize(), and Process().

fd_set Threading::rSoc

protected

Definition at line 38 of file Threading.h.

Referenced by AddSocket(), and Process().

uint8 Threading::sleepTime

protected

Definition at line 42 of file Threading.h.

Referenced by Initialize(), and RunLoop().

struct timeval Threading::tv

protected

Definition at line 39 of file Threading.h.

Referenced by Initialize(), and Process().

fd_set Threading::wSoc

protected

Definition at line 38 of file Threading.h.

Referenced by AddSocket(), and Process().

---

The documentation for this class was generated from the following files:

• /backups/local/src/eve/EvEmu_Crucible/src/eve-core/threading/Threading.h
• /backups/local/src/eve/EvEmu_Crucible/src/eve-core/threading/Threading.cpp