Index: webrtc/test/channel_transport/udp_socket2_manager_win.cc |
diff --git a/webrtc/test/channel_transport/udp_socket2_manager_win.cc b/webrtc/test/channel_transport/udp_socket2_manager_win.cc |
index bd466a24ca6a3d3b46a8c6ff1a4f6fe79c10a40a..9f40350287b61b8a810800a8e73901371a51291c 100644 |
--- a/webrtc/test/channel_transport/udp_socket2_manager_win.cc |
+++ b/webrtc/test/channel_transport/udp_socket2_manager_win.cc |
@@ -520,8 +520,8 @@ int32_t UdpSocket2WorkerWindows::_numOfWorkers = 0; |
UdpSocket2WorkerWindows::UdpSocket2WorkerWindows(HANDLE ioCompletionHandle) |
: _ioCompletionHandle(ioCompletionHandle), |
- _init(false) |
-{ |
+ _pThread(Run, this, "UdpSocket2ManagerWindows_thread"), |
+ _init(false) { |
_workerNumber = _numOfWorkers++; |
WEBRTC_TRACE(kTraceMemory, kTraceTransport, -1, |
"UdpSocket2WorkerWindows created"); |
@@ -537,10 +537,9 @@ bool UdpSocket2WorkerWindows::Start() |
{ |
WEBRTC_TRACE(kTraceStateInfo, kTraceTransport, -1, |
"Start UdpSocket2WorkerWindows"); |
- if (!_pThread->Start()) |
- return false; |
+ _pThread.Start(); |
- _pThread->SetPriority(kRealtimePriority); |
+ _pThread.SetPriority(rtc::kRealtimePriority); |
return true; |
} |
@@ -548,18 +547,14 @@ bool UdpSocket2WorkerWindows::Stop() |
{ |
WEBRTC_TRACE(kTraceStateInfo, kTraceTransport, -1, |
"Stop UdpSocket2WorkerWindows"); |
- return _pThread->Stop(); |
+ _pThread.Stop(); |
+ return true; |
} |
int32_t UdpSocket2WorkerWindows::Init() |
{ |
- if(!_init) |
- { |
- const char* threadName = "UdpSocket2ManagerWindows_thread"; |
- _pThread = PlatformThread::CreateThread(Run, this, threadName); |
- _init = true; |
- } |
- return 0; |
+ _init = true; |
+ return 0; |
} |
bool UdpSocket2WorkerWindows::Run(void* obj) |