summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCollin <collin@livio.io>2019-10-01 13:02:59 -0400
committerCollin <collin@livio.io>2019-10-01 13:02:59 -0400
commitbca9b7be8c812d81686227b7b7790dd450942473 (patch)
treece66ce6dab1c91de684c14369cf410666f50ab25
parent599903a3d98bc525d8a24e93d4105617e8aedf31 (diff)
downloadsdl_core-fix/socket_streaming.tar.gz
update server_type checksfix/socket_streaming
-rw-r--r--src/components/media_manager/src/media_manager_impl.cc10
-rw-r--r--src/components/media_manager/test/media_manager_impl_test.cc3
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;