PollThread Class Reference

#include <PollThread.h>

Inheritance diagram for PollThread:

Classes
struct	Update

Protected Types
typedef List< Update >	UpdateList

Protected Member Functions
virtual int	run ()
virtual void	onRemoved (PollAble *_pPollAble)
Protected Member Functions inherited from Thread
virtual bool	init ()
Protected Member Functions inherited from Object
virtual	~Object ()
	Object ()

Protected Attributes
UpdateList	__updateList
Thread::Mutex	__updateLock
Thread::Event	__pollInterrupt
volatile bool	__terminate

Additional Inherited Members
Public Types inherited from Thread
typedef void(*	initRoutine) ()
typedef SingleLock< Mutex >	SingleLockMutex
typedef SingleLock< SpinLock >	SingleLockSpin
typedef SingleTryLock< Mutex >	SingleTryLockMutex
typedef SingleTryLock< SpinLock >	SingleTryLockSpin
Public Member Functions inherited from Object
virtual String	toString () const
virtual void	destroy ()
String	className () const
bool	isInstanceOf (const std::type_info &typeinfo) const
virtual const std::type_info &	typeInfo () const
Static Public Member Functions inherited from Thread
static void	sleep (unsigned int _mills)
static void	yield ()
static unsigned long	getCurrentThreadId ()
static Thread *	getCurrentThread ()
static void	crtLock (const void *_p)
static void	crtUnlock (const void *_p)
static long	incrementAndGet (volatile long &_n)
static long long	incrementAndGet (volatile long long &_n)
static long	decrementAndGet (volatile long &_n)
static long long	decrementAndGet (volatile long long &_n)

Detailed Description

Non-Blocking 입출력 장치에대한 비동기 감시기능을 제공한다.

UNIX에서는 poll을 사용하여 구현되어 있으며, 모든 입출력 fd에 대하여 사용하능하다.

Windows에서는 WSAPoll를 사용한다. 이 때문에, Windows은 Windows Vista, Windows 2008 이상의 버전(_WIN32_WINNT >= 0x0600) 의 WinSock2의 SOCKET을 감시에서만 사용할 수 있다. Windows에서 다른 입출력에 대한 감시는 관련 클래스를 참고한다.

See also

SerialPollThread

SocketPollThread

Author

Daejung Kim

Since

DCL Version 3.0

Definition at line 34 of file PollThread.h.

Member Typedef Documentation

UpdateList

typedef List<Update> PollThread::UpdateList

protected

Definition at line 95 of file PollThread.h.

Member Function Documentation

onRemoved()

void PollThread::onRemoved ( PollAble * _pPollAble )

protectedvirtual

입출력 감시대상에서 제거된 후 해당 객체를 처분한다.

기본구현은 _pPollAble의 destroy()를 호출하여 파괴한다

Definition at line 221 of file PollThread.cpp.

{
    __DCL_TRACE1(__T("PollThread::onRemoved, destroy [%ls]\n"), _pPollAble->toString().data());
    _pPollAble->destroy();
}

run()

int PollThread::run ( )

protectedvirtual

스레드의 주 실행 루프를 구현한다.

잊지말자!! 다음의 코드를 ~PollThread() 에 포함시키면 파생클래스 영역은 이미 파괴된 후 이기 때문에 파생클래스의 onRemoved는 호출되지 않는다.

Implements Thread.

Definition at line 97 of file PollThread.cpp.

{
    Array<PollAble*> pollAbles;
    Array<POLLFD> fds;
 
#if __DCL_WINDOWS
    // Windows에서 __pollInterrupt를 사용하지 않는다.
    pollAbles.add(NULL);
    fds.add(POLLFD((File::HandleType) INVALID_SOCKET, POLLIN));
#else
    pollAbles.add(NULL);
    fds.add(POLLFD(__pollInterrupt.handle(), POLLIN));
#endif
 
    while (!__terminate) {
        {
            Thread::SingleLockMutex lock(__updateLock);
            if (!__updateList.isEmpty()) {
#if !__DCL_WINDOWS
                __pollInterrupt.reset();
#endif
                for (UpdateList::Iterator itUpdate = __updateList.begin(); 
                        itUpdate != __updateList.end(); itUpdate++) {
                    Update& update = *itUpdate;
    //              __DCL_TRACE2(__T("add [%ls][%d]\n"), update.pPollAble->path(), update.bAdd);
                    if (update.bAdd) {
                        __DCL_TRACE1(__T("added [%ls]\n"), update.pPollAble->toString().data());
                        pollAbles.add(update.pPollAble);
                        fds.add(POLLFD(update.pPollAble->handle(), update.pPollAble->__events));
                    }
                    else {
                        Array<PollAble*>::Iterator itPollAble =
                            pollAbles.find(update.pPollAble);
                        if (itPollAble != pollAbles.end())   {
                            __DCL_TRACE1(__T("remove [%ls]\n"), update.pPollAble->toString().data());
                            onRemoved(*itPollAble);
                            pollAbles.erase(itPollAble);
                            fds.erase(pollAbles.index(itPollAble));
                        }
                    }
                }   // end of for
                __updateList.clear();
            }
        }
 
        // Wait poll
#if __DCL_WINDOWS
        int r = WSAPoll(fds.data() + 1, (ULONG)(fds.size() - 1), WSA_INFINITE);
#else
        int r = poll(fds.data(), fds.size(), INFINITE);
#endif
        if (r > 0) {
#if !__DCL_WINDOWS
            if (fds[0].revents)
                __pollInterrupt.reset();
            else
#endif
            {
                for (size_t i = 1; i < fds.size(); i++) {
                    if (fds[i].revents)
                    {
                        PollAble* pPollAble = pollAbles[i];
                        try {
                            if (!(pPollAble->onEvent(fds[i].revents, this)))
                                remove(pPollAble);
                        }
                        catch (IOException* cause) {
                            remove(pPollAble);
                            /*
                             *  복구 불가능한 치명적 포트오류가 발생했다.
                             *  USB to COM 변환기를 사용한 경우 포트가 제거된 경우일 수 있다.
                             */
                            __DCL_TRACE1(__T("onEvent Fail! %ls\n"), cause->toString().data());
                            cause->destroy();
                        }
                    }   // end of fds[i].revents
                } // end of for
            }
        }
        else if (r < 0) {
#if __DCL_DEBUG
    #if __DCL_WINDOWS
            // SOCKET_ERROR
            __DCL_TRACE1(__T("WSAPoll error [%d]\n"), WSAGetLastError());
    #else
            // fd error
            __DCL_TRACE1(__T("poll error [%d]\n"), errno);
    #endif
            Thread::sleep(1000);
#endif  
        }
        else {
            // r == 0, time out
            __DCL_ASSERT(false);
        }
    }   // end of while

    for (Array<PollAble*>::Iterator itPollAble = pollAbles.begin();
            itPollAble != pollAbles.end(); itPollAble++) {
        // NULL 인 것은 __pollInterrupt를 위한 것이다.
        if (*itPollAble != NULL) {
            __DCL_TRACE1(__T("terminate remove [%ls]\n"), (*itPollAble)->toString().data());
            onRemoved(*itPollAble);
        }
    }
 
    // __updateList에 추가된 것이 있을 수 있다.
    for (UpdateList::Iterator itUpdate = __updateList.begin(); 
            itUpdate != __updateList.end(); itUpdate++) {
        Update& update = *itUpdate;
        if (update.bAdd) {
            __DCL_TRACE1(__T("terminate remove [%ls]\n"), update.pPollAble->toString().data());
            onRemoved(update.pPollAble);
        }
    }
 
    return 0;
}

Member Data Documentation

__pollInterrupt

Thread::Event PollThread::__pollInterrupt

protected

Definition at line 103 of file PollThread.h.

__terminate

volatile bool PollThread::__terminate

protected

Definition at line 105 of file PollThread.h.

__updateList

UpdateList PollThread::__updateList

protected

Definition at line 96 of file PollThread.h.

__updateLock

Thread::Mutex PollThread::__updateLock

protected

Definition at line 97 of file PollThread.h.

---

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

• PollThread.h
• PollThread.cpp