| Index: media/cast/net/udp_transport.cc
|
| diff --git a/media/cast/net/udp_transport.cc b/media/cast/net/udp_transport.cc
|
| index 68cfff7783b41855073cae1068f48e6b28bbc8b9..b444d10b34a4170e81bd5a1c805e3f79f33c6984 100644
|
| --- a/media/cast/net/udp_transport.cc
|
| +++ b/media/cast/net/udp_transport.cc
|
| @@ -88,7 +88,7 @@ UdpTransport::~UdpTransport() {}
|
|
|
| void UdpTransport::StartReceiving(
|
| const PacketReceiverCallbackWithStatus& packet_receiver) {
|
| - DCHECK(io_thread_proxy_->RunsTasksOnCurrentThread());
|
| + DCHECK(io_thread_proxy_->RunsTasksInCurrentSequence());
|
|
|
| if (!udp_socket_) {
|
| status_callback_.Run(TRANSPORT_SOCKET_ERROR);
|
| @@ -129,19 +129,19 @@ void UdpTransport::StartReceiving(
|
| }
|
|
|
| void UdpTransport::StopReceiving() {
|
| - DCHECK(io_thread_proxy_->RunsTasksOnCurrentThread());
|
| + DCHECK(io_thread_proxy_->RunsTasksInCurrentSequence());
|
| packet_receiver_ = PacketReceiverCallbackWithStatus();
|
| }
|
|
|
|
|
| void UdpTransport::SetDscp(net::DiffServCodePoint dscp) {
|
| - DCHECK(io_thread_proxy_->RunsTasksOnCurrentThread());
|
| + DCHECK(io_thread_proxy_->RunsTasksInCurrentSequence());
|
| next_dscp_value_ = dscp;
|
| }
|
|
|
| #if defined(OS_WIN)
|
| void UdpTransport::UseNonBlockingIO() {
|
| - DCHECK(io_thread_proxy_->RunsTasksOnCurrentThread());
|
| + DCHECK(io_thread_proxy_->RunsTasksInCurrentSequence());
|
| if (!udp_socket_)
|
| return;
|
| udp_socket_->UseNonBlockingIO();
|
| @@ -149,7 +149,7 @@ void UdpTransport::UseNonBlockingIO() {
|
| #endif
|
|
|
| void UdpTransport::ScheduleReceiveNextPacket() {
|
| - DCHECK(io_thread_proxy_->RunsTasksOnCurrentThread());
|
| + DCHECK(io_thread_proxy_->RunsTasksInCurrentSequence());
|
| if (!packet_receiver_.is_null() && !receive_pending_) {
|
| receive_pending_ = true;
|
| io_thread_proxy_->PostTask(FROM_HERE,
|
| @@ -160,7 +160,7 @@ void UdpTransport::ScheduleReceiveNextPacket() {
|
| }
|
|
|
| void UdpTransport::ReceiveNextPacket(int length_or_status) {
|
| - DCHECK(io_thread_proxy_->RunsTasksOnCurrentThread());
|
| + DCHECK(io_thread_proxy_->RunsTasksInCurrentSequence());
|
|
|
| if (packet_receiver_.is_null())
|
| return;
|
| @@ -219,7 +219,7 @@ void UdpTransport::ReceiveNextPacket(int length_or_status) {
|
| }
|
|
|
| bool UdpTransport::SendPacket(PacketRef packet, const base::Closure& cb) {
|
| - DCHECK(io_thread_proxy_->RunsTasksOnCurrentThread());
|
| + DCHECK(io_thread_proxy_->RunsTasksInCurrentSequence());
|
| if (!udp_socket_)
|
| return true;
|
|
|
| @@ -287,7 +287,7 @@ void UdpTransport::OnSent(const scoped_refptr<net::IOBuffer>& buf,
|
| PacketRef packet,
|
| const base::Closure& cb,
|
| int result) {
|
| - DCHECK(io_thread_proxy_->RunsTasksOnCurrentThread());
|
| + DCHECK(io_thread_proxy_->RunsTasksInCurrentSequence());
|
|
|
| send_pending_ = false;
|
| if (result < 0) {
|
|
|