Update ipc/ to use scoped_refptr<T>::get() rather than implicit "oper…

…ator T*"

Linux fixes

BUG=110610
TBR=darin

Review URL: https://chromiumcodereview.appspot.com/15703006

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@203562 0039d316-1c4b-4281-b951-d872f2087c98

ipc/ipc_channel_proxy.cc

@@ -51,7 +51,7 @@ ChannelProxy::Context::Context(Listener* listener,
       ipc_task_runner_(ipc_task_runner),
       channel_connected_called_(false),
       peer_pid_(base::kNullProcessId) {
-  DCHECK(ipc_task_runner_);
+  DCHECK(ipc_task_runner_.get());
 }
 
 ChannelProxy::Context::~Context() {

ipc/ipc_channel_proxy.h

@@ -197,7 +197,7 @@ class IPC_EXPORT ChannelProxy : public Sender, public base::NonThreadSafe {
     Context(Listener* listener, base::SingleThreadTaskRunner* ipc_thread);
     void ClearIPCTaskRunner();
     base::SingleThreadTaskRunner* ipc_task_runner() const {
-      return ipc_task_runner_;
+      return ipc_task_runner_.get();
     }
     const std::string& channel_id() const { return channel_id_; }
 
@@ -268,7 +268,7 @@ class IPC_EXPORT ChannelProxy : public Sender, public base::NonThreadSafe {
     base::ProcessId peer_pid_;
   };
 
-  Context* context() { return context_; }
+  Context* context() { return context_.get(); }
 
   OutgoingMessageFilter* outgoing_message_filter() {
     return outgoing_message_filter_;

ipc/ipc_forwarding_message_filter.cc

@@ -14,7 +14,7 @@ ForwardingMessageFilter::ForwardingMessageFilter(
     size_t num_message_ids_to_filter,
     base::TaskRunner* target_task_runner)
     : target_task_runner_(target_task_runner) {
-  DCHECK(target_task_runner_);
+  DCHECK(target_task_runner_.get());
   for (size_t i = 0; i < num_message_ids_to_filter; i++)
     message_ids_to_filter_.insert(message_ids_to_filter[i]);
 }

ipc/ipc_sync_channel.cc

@@ -133,7 +133,7 @@ class SyncChannel::ReceivedSyncMsgQueue :
 
     SyncMessageQueue::iterator iter = message_queue_.begin();
     while (iter != message_queue_.end()) {
-      if (iter->context == context) {
+      if (iter->context.get() == context) {
         delete iter->message;
         iter = message_queue_.erase(iter);
         message_queue_version_++;
@@ -150,7 +150,7 @@ class SyncChannel::ReceivedSyncMsgQueue :
 
   WaitableEvent* dispatch_event() { return &dispatch_event_; }
   base::SingleThreadTaskRunner* listener_task_runner() {
-    return listener_task_runner_;
+    return listener_task_runner_.get();
   }
 
   // Holds a pointer to the per-thread ReceivedSyncMsgQueue object.
@@ -483,7 +483,7 @@ bool SyncChannel::SendWithTimeout(Message* message, int timeout_ms) {
 
   // Wait for reply, or for any other incoming synchronous messages.
   // *this* might get deleted, so only call static functions at this point.
-  WaitForReply(context, pump_messages_event);
+  WaitForReply(context.get(), pump_messages_event);
 
   return context->Pop();
 }

ipc/ipc_sync_channel.h

@@ -150,7 +150,7 @@ class IPC_EXPORT SyncChannel : public ChannelProxy {
     base::WaitableEvent* shutdown_event() { return shutdown_event_; }
 
     ReceivedSyncMsgQueue* received_sync_msgs() {
-      return received_sync_msgs_;
+      return received_sync_msgs_.get();
     }
 
     void set_restrict_dispatch_group(int group) {

ipc/ipc_sync_message_filter.cc

@@ -24,7 +24,7 @@ SyncMessageFilter::SyncMessageFilter(base::WaitableEvent* shutdown_event)
 bool SyncMessageFilter::Send(Message* message) {
   {
     base::AutoLock auto_lock(lock_);
-    if (!io_loop_) {
+    if (!io_loop_.get()) {
       delete message;
       return false;
     }
@@ -46,8 +46,8 @@ bool SyncMessageFilter::Send(Message* message) {
     base::AutoLock auto_lock(lock_);
     // Can't use this class on the main thread or else it can lead to deadlocks.
     // Also by definition, can't use this on IO thread since we're blocking it.
-    DCHECK(MessageLoopProxy::current() != listener_loop_);
-    DCHECK(MessageLoopProxy::current() != io_loop_);
+    DCHECK(MessageLoopProxy::current() != listener_loop_.get());
+    DCHECK(MessageLoopProxy::current() != io_loop_.get());
     pending_sync_messages_.insert(&pending_message);
   }