Index: media/cast/transport/transport/transport.cc |
diff --git a/media/cast/net/transport/transport.cc b/media/cast/transport/transport/transport.cc |
similarity index 92% |
rename from media/cast/net/transport/transport.cc |
rename to media/cast/transport/transport/transport.cc |
index f28e8893b8e52053903ae41f90ddd497489f16e1..dfa155a4c72cad8e3cb46f3117e50ae0e5aff560 100644 |
--- a/media/cast/net/transport/transport.cc |
+++ b/media/cast/transport/transport/transport.cc |
@@ -2,7 +2,7 @@ |
// Use of this source code is governed by a BSD-style license that can be |
// found in the LICENSE file. |
-#include "media/cast/net/transport/transport.h" |
+#include "media/cast/transport/transport/transport.h" |
#include <string> |
@@ -13,11 +13,12 @@ |
#include "base/message_loop/message_loop.h" |
#include "base/rand_util.h" |
#include "net/base/io_buffer.h" |
+#include "net/base/net_errors.h" |
#include "net/base/rand_callback.h" |
-#include "net/base/test_completion_callback.h" |
namespace media { |
namespace cast { |
+namespace transport { |
const int kMaxPacketSize = 1500; |
@@ -118,12 +119,20 @@ class LocalPacketSender : public PacketSender, |
virtual void SendPacketToNetwork(const Packet& packet) { |
DCHECK(io_thread_proxy_->RunsTasksOnCurrentThread()); |
- const uint8* data = packet.data(); |
- net::TestCompletionCallback callback; |
+ const uint8* data = &packet[0]; |
scoped_refptr<net::WrappedIOBuffer> buffer( |
new net::WrappedIOBuffer(reinterpret_cast<const char*>(data))); |
udp_socket_->SendTo(buffer.get(), static_cast<int>(packet.size()), |
- send_address_, callback.callback()); |
+ send_address_, |
+ base::Bind(&LocalPacketSender::OnSendCompleted, |
+ base::Unretained(this))); |
+ } |
+ |
+ virtual void OnSendCompleted(int result) { |
+ if (result < 0) { |
+ // TODO(mikhal): Add to error messages. |
+ VLOG(0) << "Send failed on UDP socket : " << result; |
+ } |
} |
virtual bool SendPackets(const PacketList& packets) OVERRIDE { |
@@ -191,5 +200,6 @@ void Transport::SetSendDestination(std::string ip_address, int port) { |
packet_sender_->SetSendAddress(send_address); |
} |
+} // namespace transport |
} // namespace cast |
} // namespace media |