| 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 #ifndef MEDIA_REMOTING_REMOTE_DEMUXER_STREAM_ADAPTER_H_ | 5 #ifndef MEDIA_REMOTING_REMOTE_DEMUXER_STREAM_ADAPTER_H_ |
| 6 #define MEDIA_REMOTING_REMOTE_DEMUXER_STREAM_ADAPTER_H_ | 6 #define MEDIA_REMOTING_REMOTE_DEMUXER_STREAM_ADAPTER_H_ |
| 7 | 7 |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | 9 |
| 10 #include <memory> | 10 #include <memory> |
| (...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 67 base::Optional<uint32_t> SignalFlush(bool flushing); | 67 base::Optional<uint32_t> SignalFlush(bool flushing); |
| 68 | 68 |
| 69 private: | 69 private: |
| 70 friend class MockRemoteDemuxerStreamAdapter; | 70 friend class MockRemoteDemuxerStreamAdapter; |
| 71 | 71 |
| 72 // Receives RPC message from RpcBroker. | 72 // Receives RPC message from RpcBroker. |
| 73 void OnReceivedRpc(std::unique_ptr<remoting::pb::RpcMessage> message); | 73 void OnReceivedRpc(std::unique_ptr<remoting::pb::RpcMessage> message); |
| 74 | 74 |
| 75 // RPC message tasks. | 75 // RPC message tasks. |
| 76 void Initialize(int remote_callback_handle); | 76 void Initialize(int remote_callback_handle); |
| 77 void EnableBitstreamConverter(); |
| 77 void ReadUntil(std::unique_ptr<remoting::pb::RpcMessage> message); | 78 void ReadUntil(std::unique_ptr<remoting::pb::RpcMessage> message); |
| 78 void RequestBuffer(int callback_handle); | 79 void RequestBuffer(int callback_handle); |
| 79 void SendReadAck(int callback_handle); | 80 void SendReadAck(int callback_handle); |
| 80 | 81 |
| 81 // Callback function when retrieving data from demuxer. | 82 // Callback function when retrieving data from demuxer. |
| 82 void OnNewBuffer(int callback_handle, | 83 void OnNewBuffer(int callback_handle, |
| 83 ::media::DemuxerStream::Status status, | 84 ::media::DemuxerStream::Status status, |
| 84 const scoped_refptr<::media::DecoderBuffer>& input); | 85 const scoped_refptr<::media::DecoderBuffer>& input); |
| 85 void TryWriteData(int callback_handle, MojoResult result); | 86 void TryWriteData(int callback_handle, MojoResult result); |
| 86 void ResetPendingFrame(); | 87 void ResetPendingFrame(); |
| (...skipping 65 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 152 | 153 |
| 153 DISALLOW_COPY_AND_ASSIGN(RemoteDemuxerStreamAdapter); | 154 DISALLOW_COPY_AND_ASSIGN(RemoteDemuxerStreamAdapter); |
| 154 }; | 155 }; |
| 155 | 156 |
| 156 mojo::DataPipe* CreateDataPipe(); | 157 mojo::DataPipe* CreateDataPipe(); |
| 157 | 158 |
| 158 } // namespace remoting | 159 } // namespace remoting |
| 159 } // namespace media | 160 } // namespace media |
| 160 | 161 |
| 161 #endif // MEDIA_REMOTING_REMOTE_DEMUXER_STREAM_ADAPTER_H_ | 162 #endif // MEDIA_REMOTING_REMOTE_DEMUXER_STREAM_ADAPTER_H_ |
| OLD | NEW |