1 /*!
2 * \copy
3 * Copyright (c) 2009-2015, Cisco Systems
4 * All rights reserved.
5 *
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
8 * are met:
9 *
10 * * Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 *
13 * * Redistributions in binary form must reproduce the above copyright
14 * notice, this list of conditions and the following disclaimer in
15 * the documentation and/or other materials provided with the
16 * distribution.
17 *
18 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
19 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
20 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
21 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
22 * COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
23 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING,
24 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
25 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER
26 * CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
28 * ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
29 * POSSIBILITY OF SUCH DAMAGE.
30 *
31 *
32 * \file WelsTaskThread.cpp
33 *
34 * \brief functions for TaskThread
35 *
36 * \date 5/09/2012 Created
37 *
38 *************************************************************************************
39 */
40 #include "WelsTaskThread.h"
41
42 namespace WelsCommon {
43
CWelsTaskThread(IWelsTaskThreadSink * pSink)44 CWelsTaskThread::CWelsTaskThread (IWelsTaskThreadSink* pSink) : m_pSink (pSink) {
45 WelsThreadSetName ("CWelsTaskThread");
46
47 m_uiID = (uintptr_t) (this);
48 m_pTask = NULL;
49 }
50
51
~CWelsTaskThread()52 CWelsTaskThread::~CWelsTaskThread() {
53 }
54
ExecuteTask()55 void CWelsTaskThread::ExecuteTask() {
56 CWelsAutoLock cLock (m_cLockTask);
57 if (m_pSink) {
58 m_pSink->OnTaskStart (this, m_pTask);
59 }
60
61 if (m_pTask) {
62 m_pTask->Execute();
63 }
64
65 if (m_pSink) {
66 m_pSink->OnTaskStop (this, m_pTask);
67 }
68
69 m_pTask = NULL;
70 }
71
SetTask(WelsCommon::IWelsTask * pTask)72 WELS_THREAD_ERROR_CODE CWelsTaskThread::SetTask (WelsCommon::IWelsTask* pTask) {
73 CWelsAutoLock cLock (m_cLockTask);
74
75 if (!GetRunning()) {
76 return WELS_THREAD_ERROR_GENERAL;
77 }
78 WelsMutexLock(&m_hMutex);
79 m_pTask = pTask;
80 WelsMutexUnlock(&m_hMutex);
81 SignalThread();
82
83 return WELS_THREAD_ERROR_OK;
84 }
85
86
87 }
88
89