Clean up PlatformThread.

webrtc/modules/audio_device/linux/audio_device_alsa_linux.cc

 /*
  *  Copyright (c) 2012 The WebRTC project authors. All Rights Reserved.
  *
  *  Use of this source code is governed by a BSD-style license
  *  that can be found in the LICENSE file in the root of the source
  *  tree. An additional intellectual property rights grant can be found
  *  in the file PATENTS.  All contributing project authors may
  *  be found in the AUTHORS file in the root of the source tree.
  */
 
@@ skipping 189 matching lines @@
         return 0;
     }
 
     CriticalSectionScoped lock(&_critSect);
 
     _mixerManager.Close();
 
     // RECORDING
     if (_ptrThreadRec)
     {
-        PlatformThread* tmpThread = _ptrThreadRec.release();
+        rtc::PlatformThread* tmpThread = _ptrThreadRec.release();
         _critSect.Leave();
 
         tmpThread->Stop();
         delete tmpThread;
 
         _critSect.Enter();
     }
 
     // PLAYOUT
     if (_ptrThreadPlay)
     {
-        PlatformThread* tmpThread = _ptrThreadPlay.release();
+        rtc::PlatformThread* tmpThread = _ptrThreadPlay.release();
         _critSect.Leave();
 
         tmpThread->Stop();
         delete tmpThread;
 
         _critSect.Enter();
     }
 #if defined(USE_X11)
     if (_XDisplay)
     {
@@ skipping 1123 matching lines @@
     if (!_recordingBuffer)
         _recordingBuffer = new int8_t[_recordingBufferSizeIn10MS];
     if (!_recordingBuffer)
     {
         WEBRTC_TRACE(kTraceCritical, kTraceAudioDevice, _id,
                      "   failed to alloc recording buffer");
         _recording = false;
         return -1;
     }
     // RECORDING
-    const char* threadName = "webrtc_audio_module_capture_thread";
-    _ptrThreadRec =
-        PlatformThread::CreateThread(RecThreadFunc, this, threadName);
+    _ptrThreadRec.reset(new rtc::PlatformThread(
+        RecThreadFunc, this, "webrtc_audio_module_capture_thread"));
 
-    if (!_ptrThreadRec->Start())
-    {
-        WEBRTC_TRACE(kTraceCritical, kTraceAudioDevice, _id,
-                     "  failed to start the rec audio thread");
-        _recording = false;
-        _ptrThreadRec.reset();
-        delete [] _recordingBuffer;
-        _recordingBuffer = NULL;
-        return -1;
-    }
-    _ptrThreadRec->SetPriority(kRealtimePriority);
+    _ptrThreadRec->Start();
+    _ptrThreadRec->SetPriority(rtc::kRealtimePriority);
 
     errVal = LATE(snd_pcm_prepare)(_handleRecord);
     if (errVal < 0)
     {
         WEBRTC_TRACE(kTraceError, kTraceAudioDevice, _id,
                      "     capture snd_pcm_prepare failed (%s)\n",
                      LATE(snd_strerror)(errVal));
         // just log error
         // if snd_pcm_open fails will return -1
     }
@@ skipping 119 matching lines @@
         _playoutBuffer = new int8_t[_playoutBufferSizeIn10MS];
     if (!_playoutBuffer)
     {
       WEBRTC_TRACE(kTraceError, kTraceAudioDevice, _id,
                    "    failed to alloc playout buf");
       _playing = false;
       return -1;
     }
 
     // PLAYOUT
-    const char* threadName = "webrtc_audio_module_play_thread";
-    _ptrThreadPlay =
-        PlatformThread::CreateThread(PlayThreadFunc, this, threadName);
-    if (!_ptrThreadPlay->Start())
-    {
-        WEBRTC_TRACE(kTraceCritical, kTraceAudioDevice, _id,
-                     "  failed to start the play audio thread");
-        _playing = false;
-        _ptrThreadPlay.reset();
-        delete [] _playoutBuffer;
-        _playoutBuffer = NULL;
-        return -1;
-    }
-    _ptrThreadPlay->SetPriority(kRealtimePriority);
+    _ptrThreadPlay.reset(new rtc::PlatformThread(
+        PlayThreadFunc, this, "webrtc_audio_module_play_thread"));
+    _ptrThreadPlay->Start();
+    _ptrThreadPlay->SetPriority(rtc::kRealtimePriority);
 
     int errVal = LATE(snd_pcm_prepare)(_handlePlayout);
     if (errVal < 0)
     {
         WEBRTC_TRACE(kTraceCritical, kTraceAudioDevice, _id,
                      "     playout snd_pcm_prepare failed (%s)\n",
                      LATE(snd_strerror)(errVal));
         // just log error
         // if snd_pcm_open fails will return -1
     }
@@ skipping 694 matching lines @@
     state |= (szKey[i] ^ _oldKeyState[i]) & szKey[i];
 
   // Save old state
   memcpy((char*)_oldKeyState, (char*)szKey, sizeof(_oldKeyState));
   return (state != 0);
 #else
   return false;
 #endif
 }
 }  // namespace webrtc