OLD | NEW |
1 /* | 1 /* |
2 * Copyright 2004 The WebRTC project authors. All Rights Reserved. | 2 * Copyright 2004 The WebRTC project authors. All Rights Reserved. |
3 * | 3 * |
4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
9 */ | 9 */ |
10 | 10 |
(...skipping 327 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
338 | 338 |
339 video_channels_.erase(it); | 339 video_channels_.erase(it); |
340 delete video_channel; | 340 delete video_channel; |
341 } | 341 } |
342 | 342 |
343 DataChannel* ChannelManager::CreateDataChannel( | 343 DataChannel* ChannelManager::CreateDataChannel( |
344 TransportController* transport_controller, | 344 TransportController* transport_controller, |
345 const std::string& content_name, | 345 const std::string& content_name, |
346 const std::string* bundle_transport_name, | 346 const std::string* bundle_transport_name, |
347 bool rtcp, | 347 bool rtcp, |
348 DataChannelType channel_type) { | 348 DataChannelType channel_type, |
| 349 webrtc::MediaControllerInterface* media_controller) { |
349 return worker_thread_->Invoke<DataChannel*>( | 350 return worker_thread_->Invoke<DataChannel*>( |
350 RTC_FROM_HERE, | 351 RTC_FROM_HERE, |
351 Bind(&ChannelManager::CreateDataChannel_w, this, transport_controller, | 352 Bind(&ChannelManager::CreateDataChannel_w, this, transport_controller, |
352 content_name, bundle_transport_name, rtcp, channel_type)); | 353 content_name, bundle_transport_name, rtcp, channel_type, |
| 354 media_controller)); |
353 } | 355 } |
354 | 356 |
355 DataChannel* ChannelManager::CreateDataChannel_w( | 357 DataChannel* ChannelManager::CreateDataChannel_w( |
356 TransportController* transport_controller, | 358 TransportController* transport_controller, |
357 const std::string& content_name, | 359 const std::string& content_name, |
358 const std::string* bundle_transport_name, | 360 const std::string* bundle_transport_name, |
359 bool rtcp, | 361 bool rtcp, |
360 DataChannelType data_channel_type) { | 362 DataChannelType data_channel_type, |
| 363 webrtc::MediaControllerInterface* media_controller) { |
361 // This is ok to alloc from a thread other than the worker thread. | 364 // This is ok to alloc from a thread other than the worker thread. |
362 ASSERT(initialized_); | 365 ASSERT(initialized_); |
363 DataMediaChannel* media_channel = data_media_engine_->CreateChannel( | 366 DataMediaChannel* media_channel = data_media_engine_->CreateChannel( |
364 data_channel_type); | 367 data_channel_type, media_controller->config()); |
365 if (!media_channel) { | 368 if (!media_channel) { |
366 LOG(LS_WARNING) << "Failed to create data channel of type " | 369 LOG(LS_WARNING) << "Failed to create data channel of type " |
367 << data_channel_type; | 370 << data_channel_type; |
368 return NULL; | 371 return NULL; |
369 } | 372 } |
370 | 373 |
371 DataChannel* data_channel = | 374 DataChannel* data_channel = |
372 new DataChannel(worker_thread_, network_thread_, media_channel, | 375 new DataChannel(worker_thread_, network_thread_, media_channel, |
373 transport_controller, content_name, rtcp); | 376 transport_controller, content_name, rtcp); |
374 data_channel->SetCryptoOptions(crypto_options_); | 377 data_channel->SetCryptoOptions(crypto_options_); |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
411 media_engine_.get(), file, max_size_bytes)); | 414 media_engine_.get(), file, max_size_bytes)); |
412 } | 415 } |
413 | 416 |
414 void ChannelManager::StopAecDump() { | 417 void ChannelManager::StopAecDump() { |
415 worker_thread_->Invoke<void>( | 418 worker_thread_->Invoke<void>( |
416 RTC_FROM_HERE, | 419 RTC_FROM_HERE, |
417 Bind(&MediaEngineInterface::StopAecDump, media_engine_.get())); | 420 Bind(&MediaEngineInterface::StopAecDump, media_engine_.get())); |
418 } | 421 } |
419 | 422 |
420 } // namespace cricket | 423 } // namespace cricket |
OLD | NEW |