diff options
author | Collin <collin@livio.io> | 2019-10-01 13:02:59 -0400 |
---|---|---|
committer | Collin <collin@livio.io> | 2019-10-01 13:02:59 -0400 |
commit | bca9b7be8c812d81686227b7b7790dd450942473 (patch) | |
tree | ce66ce6dab1c91de684c14369cf410666f50ab25 | |
parent | 599903a3d98bc525d8a24e93d4105617e8aedf31 (diff) | |
download | sdl_core-fix/socket_streaming.tar.gz |
update server_type checksfix/socket_streaming
-rw-r--r-- | src/components/media_manager/src/media_manager_impl.cc | 10 | ||||
-rw-r--r-- | src/components/media_manager/test/media_manager_impl_test.cc | 3 |
2 files changed, 3 insertions, 10 deletions
diff --git a/src/components/media_manager/src/media_manager_impl.cc b/src/components/media_manager/src/media_manager_impl.cc index ffd392a654..2e09f25884 100644 --- a/src/components/media_manager/src/media_manager_impl.cc +++ b/src/components/media_manager/src/media_manager_impl.cc @@ -321,7 +321,7 @@ void MediaManagerImpl::OnMessageReceived( ApplicationSharedPtr app = application_manager_.application(streaming_app_id); if (app) { if (ServiceType::kAudio == service_type && - "socket" == settings().video_server_type()) { + "socket" == settings().audio_server_type()) { stream_data_size_ += message->data_size(); uint32_t ms_for_all_data = DataSizeToMilliseconds(stream_data_size_); uint32_t ms_since_stream_start = @@ -347,10 +347,6 @@ void MediaManagerImpl::FramesProcessed(int32_t application_key, protocol_handler_->SendFramesNumber(application_key, frame_number); } - if ("pipe" != settings().audio_server_type()) { - return; - } - application_manager::ApplicationSharedPtr app = application_manager_.application(application_key); @@ -360,7 +356,7 @@ void MediaManagerImpl::FramesProcessed(int32_t application_key, auto video_stream = std::dynamic_pointer_cast<StreamerAdapter>( streamer_[protocol_handler::ServiceType::kMobileNav]); - if (audio_stream.use_count() != 0) { + if (audio_stream.use_count() != 0 && "pipe" == settings().audio_server_type()) { size_t audio_queue_size = audio_stream->GetMsgQueueSize(); LOG4CXX_DEBUG(logger_, "# Messages in audio queue = " << audio_queue_size); @@ -369,7 +365,7 @@ void MediaManagerImpl::FramesProcessed(int32_t application_key, } } - if (video_stream.use_count() != 0) { + if (video_stream.use_count() != 0 && "pipe" == settings().video_server_type()) { size_t video_queue_size = video_stream->GetMsgQueueSize(); LOG4CXX_DEBUG(logger_, "# Messages in video queue = " << video_queue_size); diff --git a/src/components/media_manager/test/media_manager_impl_test.cc b/src/components/media_manager/test/media_manager_impl_test.cc index 00d4fe0e33..ff35ac7dbb 100644 --- a/src/components/media_manager/test/media_manager_impl_test.cc +++ b/src/components/media_manager/test/media_manager_impl_test.cc @@ -405,9 +405,6 @@ TEST_F(MediaManagerImplTest, .WillByDefault(ReturnRef(kDefaultValue)); ON_CALL(mock_media_manager_settings_, audio_server_type()) .WillByDefault(ReturnRef(kDefaultValue)); - const std::string audio_server_type_pipe = "pipe"; - EXPECT_CALL(mock_media_manager_settings_, audio_server_type()) - .WillOnce(ReturnRef(audio_server_type_pipe)); protocol_handler_test::MockProtocolHandler mock_protocol_handler; media_manager_impl_->SetProtocolHandler(&mock_protocol_handler); const int32_t frame_number = 10; |