Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1032)

Unified Diff: media/cast/net/udp_transport.cc

Issue 2888303002: Rename TaskRunner::RunsTasksOnCurrentThread() in //media, //ui, //ipc (Closed)
Patch Set: Created 3 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « media/cast/cast_environment.cc ('k') | media/cast/sender/external_video_encoder.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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) {
« no previous file with comments | « media/cast/cast_environment.cc ('k') | media/cast/sender/external_video_encoder.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698