Index: webrtc/sdk/objc/Framework/Classes/RTCPeerConnectionFactory.mm |
diff --git a/webrtc/sdk/objc/Framework/Classes/RTCPeerConnectionFactory.mm b/webrtc/sdk/objc/Framework/Classes/RTCPeerConnectionFactory.mm |
index 82d77077d71accd05855f3bf245c3db6655a21ea..2398ce5ddc40c2552e82d25666043bd977a41ba0 100644 |
--- a/webrtc/sdk/objc/Framework/Classes/RTCPeerConnectionFactory.mm |
+++ b/webrtc/sdk/objc/Framework/Classes/RTCPeerConnectionFactory.mm |
@@ -23,23 +23,30 @@ |
#include <memory> |
@implementation RTCPeerConnectionFactory { |
- std::unique_ptr<rtc::Thread> _signalingThread; |
+ std::unique_ptr<rtc::Thread> _networkThread; |
std::unique_ptr<rtc::Thread> _workerThread; |
+ std::unique_ptr<rtc::Thread> _signalingThread; |
} |
@synthesize nativeFactory = _nativeFactory; |
- (instancetype)init { |
if ((self = [super init])) { |
- _signalingThread.reset(new rtc::Thread()); |
- BOOL result = _signalingThread->Start(); |
- NSAssert(result, @"Failed to start signaling thread."); |
- _workerThread.reset(new rtc::Thread()); |
+ _networkThread = rtc::Thread::CreateWithSocketServer(); |
+ BOOL result = _networkThread->Start(); |
+ NSAssert(result, @"Failed to start network thread."); |
+ |
+ _workerThread = rtc::Thread::Create(); |
result = _workerThread->Start(); |
NSAssert(result, @"Failed to start worker thread."); |
+ _signalingThread = rtc::Thread::Create(); |
+ result = _signalingThread->Start(); |
+ NSAssert(result, @"Failed to start signaling thread."); |
+ |
_nativeFactory = webrtc::CreatePeerConnectionFactory( |
- _workerThread.get(), _signalingThread.get(), nullptr, nullptr, nullptr); |
+ _networkThread.get(), _workerThread.get(), _signalingThread.get(), |
+ nullptr, nullptr, nullptr); |
NSAssert(_nativeFactory, @"Failed to initialize PeerConnectionFactory!"); |
} |
return self; |