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

Side by Side Diff: tools/android/forwarder2/forwarder.cc

Issue 1555613002: Convert Pass()→std::move() in //tools/android (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 11 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 unified diff | Download patch
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "tools/android/forwarder2/forwarder.h" 5 #include "tools/android/forwarder2/forwarder.h"
6 6
7 #include <utility>
8
7 #include "base/logging.h" 9 #include "base/logging.h"
8 #include "base/macros.h" 10 #include "base/macros.h"
9 #include "base/posix/eintr_wrapper.h" 11 #include "base/posix/eintr_wrapper.h"
10 #include "tools/android/forwarder2/socket.h" 12 #include "tools/android/forwarder2/socket.h"
11 13
12 namespace forwarder2 { 14 namespace forwarder2 {
13 namespace { 15 namespace {
14 16
15 const int kBufferSize = 32 * 1024; 17 const int kBufferSize = 32 * 1024;
16 18
(...skipping 197 matching lines...) Expand 10 before | Expand all | Expand 10 after
214 216
215 int bytes_read_; 217 int bytes_read_;
216 int write_offset_; 218 int write_offset_;
217 BufferedCopier* peer_; 219 BufferedCopier* peer_;
218 State state_; 220 State state_;
219 char buffer_[kBufferSize]; 221 char buffer_[kBufferSize];
220 222
221 DISALLOW_COPY_AND_ASSIGN(BufferedCopier); 223 DISALLOW_COPY_AND_ASSIGN(BufferedCopier);
222 }; 224 };
223 225
224 Forwarder::Forwarder(scoped_ptr<Socket> socket1, 226 Forwarder::Forwarder(scoped_ptr<Socket> socket1, scoped_ptr<Socket> socket2)
225 scoped_ptr<Socket> socket2) 227 : socket1_(std::move(socket1)),
226 : socket1_(socket1.Pass()), 228 socket2_(std::move(socket2)),
227 socket2_(socket2.Pass()),
228 buffer1_(new BufferedCopier(socket1_.get(), socket2_.get())), 229 buffer1_(new BufferedCopier(socket1_.get(), socket2_.get())),
229 buffer2_(new BufferedCopier(socket2_.get(), socket1_.get())) { 230 buffer2_(new BufferedCopier(socket2_.get(), socket1_.get())) {
230 buffer1_->SetPeer(buffer2_.get()); 231 buffer1_->SetPeer(buffer2_.get());
231 buffer2_->SetPeer(buffer1_.get()); 232 buffer2_->SetPeer(buffer1_.get());
232 } 233 }
233 234
234 Forwarder::~Forwarder() { 235 Forwarder::~Forwarder() {
235 DCHECK(thread_checker_.CalledOnValidThread()); 236 DCHECK(thread_checker_.CalledOnValidThread());
236 } 237 }
237 238
(...skipping 14 matching lines...) Expand all
252 return buffer1_->is_closed() && buffer2_->is_closed(); 253 return buffer1_->is_closed() && buffer2_->is_closed();
253 } 254 }
254 255
255 void Forwarder::Shutdown() { 256 void Forwarder::Shutdown() {
256 DCHECK(thread_checker_.CalledOnValidThread()); 257 DCHECK(thread_checker_.CalledOnValidThread());
257 buffer1_->Close(); 258 buffer1_->Close();
258 buffer2_->Close(); 259 buffer2_->Close();
259 } 260 }
260 261
261 } // namespace forwarder2 262 } // namespace forwarder2
OLDNEW
« no previous file with comments | « tools/android/forwarder2/device_listener.cc ('k') | tools/android/forwarder2/forwarders_manager.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698