Index: chrome/renderer/media/cast_session_delegate.h |
diff --git a/chrome/renderer/media/cast_session_delegate.h b/chrome/renderer/media/cast_session_delegate.h |
index 9c51b7f503e8dc1a1288fb064da0eca1cf397a51..324c11706fc50861479a71e168ff29dd959720a1 100644 |
--- a/chrome/renderer/media/cast_session_delegate.h |
+++ b/chrome/renderer/media/cast_session_delegate.h |
@@ -10,35 +10,52 @@ |
#include "base/threading/thread.h" |
#include "base/threading/thread_checker.h" |
#include "base/time/default_tick_clock.h" |
+#include "chrome/renderer/media/cast_session.h" |
+#include "content/public/renderer/p2p_socket_client.h" |
+#include "media/cast/cast_sender.h" |
namespace base { |
class MessageLoopProxy; |
} // namespace base |
-namespace media { |
-namespace cast { |
-class CastEnvironment; |
-class CastSender; |
-} // namespace cast |
-} // namespace media |
- |
// This class hosts CastSender and connects it to audio/video frame input |
// and network socket. |
// This class is created on the render thread and destroyed on the IO |
// thread. All methods are accessible only on the IO thread. |
-class CastSessionDelegate { |
+class CastSessionDelegate |
+ : public media::cast::PacketSender, |
+ public content::P2PSocketClient::Delegate { |
public: |
CastSessionDelegate(); |
- ~CastSessionDelegate(); |
+ virtual ~CastSessionDelegate(); |
+ |
+ void SetSocketFactory(CastSession::SocketFactory* socket_factory, |
+ const net::IPEndPoint& remote_address); |
// Start encoding threads and configure CastSender. It is ready to accept |
// audio/video frames after this call. |
void PrepareForSending(); |
+ // media::cast::PacketSender Implementation |
+ virtual bool SendPacket(const media::cast::Packet& packet) OVERRIDE; |
+ virtual bool SendPackets(const media::cast::PacketList& packets) OVERRIDE; |
+ |
+ // content::P2PSocketClient::Delegate Implementation |
+ virtual void OnOpen(const net::IPEndPoint& address) OVERRIDE; |
+ virtual void OnIncomingTcpConnection( |
+ const net::IPEndPoint& address, |
+ content::P2PSocketClient* client) OVERRIDE; |
+ virtual void OnSendComplete() OVERRIDE; |
+ virtual void OnError() OVERRIDE; |
+ virtual void OnDataReceived(const net::IPEndPoint& address, |
+ const std::vector<char>& data) OVERRIDE; |
private: |
base::ThreadChecker thread_checker_; |
scoped_refptr<media::cast::CastEnvironment> cast_environment_; |
scoped_ptr<media::cast::CastSender> cast_sender_; |
+ scoped_ptr<CastSession::SocketFactory> socket_factory_; |
+ net::IPEndPoint remote_address_; |
+ scoped_refptr<content::P2PSocketClient> socket_; |
// Utilities threads owned by this class. They are used by CastSender for |
// encoding. |