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

Unified Diff: base/posix/unix_domain_socket_linux_unittest.cc

Issue 1100773004: base: Remove most uses of MessageLoopProxy (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 5 years, 8 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
Index: base/posix/unix_domain_socket_linux_unittest.cc
diff --git a/base/posix/unix_domain_socket_linux_unittest.cc b/base/posix/unix_domain_socket_linux_unittest.cc
index 60b2bb8a47070496e47acd4448e979408ac0f084..442215e5ea8bbcc758e3c8ec1e6334faaeb99971 100644
--- a/base/posix/unix_domain_socket_linux_unittest.cc
+++ b/base/posix/unix_domain_socket_linux_unittest.cc
@@ -10,9 +10,11 @@
#include "base/bind_helpers.h"
#include "base/files/file_util.h"
#include "base/files/scoped_file.h"
+#include "base/location.h"
#include "base/memory/scoped_vector.h"
#include "base/pickle.h"
#include "base/posix/unix_domain_socket_linux.h"
+#include "base/single_thread_task_runner.h"
#include "base/synchronization/waitable_event.h"
#include "base/threading/thread.h"
#include "testing/gtest/include/gtest/gtest.h"
@@ -32,11 +34,10 @@ TEST(UnixDomainSocketTest, SendRecvMsgAbortOnReplyFDClose) {
// Have the thread send a synchronous message via the socket.
Pickle request;
- message_thread.message_loop()->PostTask(
+ message_thread.message_loop()->task_runner()->PostTask(
danakj 2015/04/21 20:16:30 thread.task_runner() here too? I think there's som
Sami 2015/04/23 17:48:24 Yep, these should be fixed now.
FROM_HERE,
- Bind(IgnoreResult(&UnixDomainSocket::SendRecvMsg),
- fds[1], static_cast<uint8_t*>(NULL), 0U, static_cast<int*>(NULL),
- request));
+ Bind(IgnoreResult(&UnixDomainSocket::SendRecvMsg), fds[1],
+ static_cast<uint8_t*>(NULL), 0U, static_cast<int*>(NULL), request));
// Receive the message.
ScopedVector<base::ScopedFD> message_fds;
@@ -51,9 +52,8 @@ TEST(UnixDomainSocketTest, SendRecvMsgAbortOnReplyFDClose) {
// Check that the thread didn't get blocked.
WaitableEvent event(false, false);
- message_thread.message_loop()->PostTask(
- FROM_HERE,
- Bind(&WaitableEvent::Signal, Unretained(&event)));
+ message_thread.message_loop()->task_runner()->PostTask(
+ FROM_HERE, Bind(&WaitableEvent::Signal, Unretained(&event)));
ASSERT_TRUE(event.TimedWait(TimeDelta::FromMilliseconds(5000)));
}

Powered by Google App Engine
This is Rietveld 408576698