Mojo: Armed Watchers

chrome/browser/media/cast_remoting_sender.cc

 // Copyright 2016 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "chrome/browser/media/cast_remoting_sender.h"
 
 #include <algorithm>
 #include <map>
 
 #include "base/bind.h"
@@ skipping 74 matching lines @@
                 media::cast::RtpPayloadType::REMOTE_AUDIO),
       logging_flush_interval_(logging_flush_interval),
       frame_event_cb_(cb),
       clock_(new base::DefaultTickClock()),
       binding_(this),
       max_ack_delay_(kMaxAckDelay),
       last_sent_frame_id_(media::cast::FrameId::first() - 1),
       latest_acked_frame_id_(media::cast::FrameId::first() - 1),
       duplicate_ack_counter_(0),
       input_queue_discards_remaining_(0),
-      pipe_watcher_(FROM_HERE),
+      pipe_watcher_(FROM_HERE, mojo::Watcher::ArmingPolicy::AUTOMATIC),
       flow_restart_pending_(true),
       weak_factory_(this) {
   // Confirm this constructor is running on the IO BrowserThread.
   DCHECK_CURRENTLY_ON(BrowserThread::IO);
 
   CastRemotingSender*& pointer_in_map = g_sender_map.Get()[rtp_stream_id_];
   DCHECK(!pointer_in_map);
   pointer_in_map = this;
 
   transport_->InitializeStream(
@@ skipping 429 matching lines @@
     frame_event_cb_.Run(frame_events);
   }
 
   base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
       FROM_HERE, base::Bind(&CastRemotingSender::SendFrameEvents,
                             weak_factory_.GetWeakPtr()),
       logging_flush_interval_);
 }
 
 }  // namespace cast