OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "media/remoting/remote_demuxer_stream_adapter.h" | 5 #include "media/remoting/remote_demuxer_stream_adapter.h" |
6 | 6 |
7 #include <memory> | 7 #include <memory> |
8 | 8 |
9 #include "base/callback_helpers.h" | 9 #include "base/callback_helpers.h" |
10 #include "base/run_loop.h" | 10 #include "base/run_loop.h" |
(...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
87 sizeof(MojoCreateDataPipeOptions), | 87 sizeof(MojoCreateDataPipeOptions), |
88 MOJO_CREATE_DATA_PIPE_OPTIONS_FLAG_NONE, 1, kDataPipeCapacity}; | 88 MOJO_CREATE_DATA_PIPE_OPTIONS_FLAG_NONE, 1, kDataPipeCapacity}; |
89 mojom::RemotingDataStreamSenderPtr stream_sender; | 89 mojom::RemotingDataStreamSenderPtr stream_sender; |
90 mojo::ScopedDataPipeProducerHandle producer_end; | 90 mojo::ScopedDataPipeProducerHandle producer_end; |
91 mojo::ScopedDataPipeConsumerHandle consumer_end; | 91 mojo::ScopedDataPipeConsumerHandle consumer_end; |
92 CHECK_EQ( | 92 CHECK_EQ( |
93 MOJO_RESULT_OK, | 93 MOJO_RESULT_OK, |
94 mojo::CreateDataPipe(&data_pipe_options, &producer_end, &consumer_end)); | 94 mojo::CreateDataPipe(&data_pipe_options, &producer_end, &consumer_end)); |
95 | 95 |
96 data_stream_sender_.reset(new FakeRemotingDataStreamSender( | 96 data_stream_sender_.reset(new FakeRemotingDataStreamSender( |
97 GetProxy(&stream_sender), std::move(consumer_end))); | 97 MakeRequest(&stream_sender), std::move(consumer_end))); |
98 demuxer_stream_adapter_.reset(new MockRemoteDemuxerStreamAdapter( | 98 demuxer_stream_adapter_.reset(new MockRemoteDemuxerStreamAdapter( |
99 message_loop_.task_runner(), message_loop_.task_runner(), "test", | 99 message_loop_.task_runner(), message_loop_.task_runner(), "test", |
100 demuxer_stream_.get(), stream_sender.PassInterface(), | 100 demuxer_stream_.get(), stream_sender.PassInterface(), |
101 std::move(producer_end))); | 101 std::move(producer_end))); |
102 // RemoteDemuxerStreamAdapter constructor posts task to main thread to | 102 // RemoteDemuxerStreamAdapter constructor posts task to main thread to |
103 // register MessageReceiverCallback. Therefore it should call | 103 // register MessageReceiverCallback. Therefore it should call |
104 // RunPendingTasks() to make sure task is executed. | 104 // RunPendingTasks() to make sure task is executed. |
105 RunPendingTasks(); | 105 RunPendingTasks(); |
106 } | 106 } |
107 | 107 |
(...skipping 104 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
212 // Re-issues ReadUntil request with frame count up to 4 (fetch #3). | 212 // Re-issues ReadUntil request with frame count up to 4 (fetch #3). |
213 demuxer_stream_adapter_->FakeReadUntil(4); | 213 demuxer_stream_adapter_->FakeReadUntil(4); |
214 RunPendingTasks(); | 214 RunPendingTasks(); |
215 ASSERT_EQ(data_stream_sender_->send_frame_count(), 1U); | 215 ASSERT_EQ(data_stream_sender_->send_frame_count(), 1U); |
216 ASSERT_TRUE(data_stream_sender_->ValidateFrameBuffer(0, 100, false, 4)); | 216 ASSERT_TRUE(data_stream_sender_->ValidateFrameBuffer(0, 100, false, 4)); |
217 data_stream_sender_->ResetHistory(); | 217 data_stream_sender_->ResetHistory(); |
218 } | 218 } |
219 | 219 |
220 } // namesapce remoting | 220 } // namesapce remoting |
221 } // namespace media | 221 } // namespace media |
OLD | NEW |