OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "content/renderer/p2p/ipc_socket_factory.h" | 5 #include "content/renderer/p2p/ipc_socket_factory.h" |
6 | 6 |
7 #include <deque> | 7 #include <deque> |
8 | 8 |
9 #include "base/compiler_specific.h" | 9 #include "base/compiler_specific.h" |
10 #include "base/debug/trace_event.h" | 10 #include "base/debug/trace_event.h" |
(...skipping 376 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
387 DCHECK_EQ(base::MessageLoop::current(), message_loop_); | 387 DCHECK_EQ(base::MessageLoop::current(), message_loop_); |
388 | 388 |
389 talk_base::SocketAddress address_lj; | 389 talk_base::SocketAddress address_lj; |
390 if (!jingle_glue::IPEndPointToSocketAddress(address, &address_lj)) { | 390 if (!jingle_glue::IPEndPointToSocketAddress(address, &address_lj)) { |
391 // We should always be able to convert address here because we | 391 // We should always be able to convert address here because we |
392 // don't expect IPv6 address on IPv4 connections. | 392 // don't expect IPv6 address on IPv4 connections. |
393 NOTREACHED(); | 393 NOTREACHED(); |
394 return; | 394 return; |
395 } | 395 } |
396 | 396 |
397 // TODO(mallinath) - Pass timestamp after updating the libjingle. | 397 talk_base::PacketTime packet_time(timestamp.ToInternalValue(), 0); |
398 // talk_base::PacketTime packet_time(timestamp.ToInternalValue(), 0); | 398 SignalReadPacket(this, &data[0], data.size(), address_lj, |
399 SignalReadPacket(this, &data[0], data.size(), address_lj); | 399 packet_time); |
400 } | 400 } |
401 | 401 |
402 } // namespace | 402 } // namespace |
403 | 403 |
404 IpcPacketSocketFactory::IpcPacketSocketFactory( | 404 IpcPacketSocketFactory::IpcPacketSocketFactory( |
405 P2PSocketDispatcher* socket_dispatcher) | 405 P2PSocketDispatcher* socket_dispatcher) |
406 : socket_dispatcher_(socket_dispatcher) { | 406 : socket_dispatcher_(socket_dispatcher) { |
407 } | 407 } |
408 | 408 |
409 IpcPacketSocketFactory::~IpcPacketSocketFactory() { | 409 IpcPacketSocketFactory::~IpcPacketSocketFactory() { |
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
467 return socket.release(); | 467 return socket.release(); |
468 } | 468 } |
469 | 469 |
470 talk_base::AsyncResolverInterface* | 470 talk_base::AsyncResolverInterface* |
471 IpcPacketSocketFactory::CreateAsyncResolver() { | 471 IpcPacketSocketFactory::CreateAsyncResolver() { |
472 NOTREACHED(); | 472 NOTREACHED(); |
473 return NULL; | 473 return NULL; |
474 } | 474 } |
475 | 475 |
476 } // namespace content | 476 } // namespace content |
OLD | NEW |