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

Side by Side Diff: remoting/protocol/pseudotcp_adapter.cc

Issue 2911893003: Deprecate NonThreadSafe in remoting in favor of SequenceChecker. (Closed)
Patch Set: Created 3 years, 6 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
« no previous file with comments | « remoting/protocol/pseudotcp_adapter.h ('k') | remoting/protocol/session_manager.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 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 "remoting/protocol/pseudotcp_adapter.h" 5 #include "remoting/protocol/pseudotcp_adapter.h"
6 6
7 #include <stddef.h> 7 #include <stddef.h>
8 8
9 #include <utility> 9 #include <utility>
10 10
(...skipping 437 matching lines...) Expand 10 before | Expand all | Expand 10 after
448 } 448 }
449 } 449 }
450 } 450 }
451 451
452 // Public interface implementation. 452 // Public interface implementation.
453 453
454 PseudoTcpAdapter::PseudoTcpAdapter(std::unique_ptr<P2PDatagramSocket> socket) 454 PseudoTcpAdapter::PseudoTcpAdapter(std::unique_ptr<P2PDatagramSocket> socket)
455 : core_(new Core(std::move(socket))) {} 455 : core_(new Core(std::move(socket))) {}
456 456
457 PseudoTcpAdapter::~PseudoTcpAdapter() { 457 PseudoTcpAdapter::~PseudoTcpAdapter() {
458 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
458 // Make sure that the underlying socket is destroyed before PseudoTcp. 459 // Make sure that the underlying socket is destroyed before PseudoTcp.
459 core_->DeleteSocket(); 460 core_->DeleteSocket();
460 } 461 }
461 462
462 int PseudoTcpAdapter::Read(const scoped_refptr<net::IOBuffer>& buffer, 463 int PseudoTcpAdapter::Read(const scoped_refptr<net::IOBuffer>& buffer,
463 int buffer_size, 464 int buffer_size,
464 const net::CompletionCallback& callback) { 465 const net::CompletionCallback& callback) {
465 DCHECK(CalledOnValidThread()); 466 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
466 return core_->Read(buffer, buffer_size, callback); 467 return core_->Read(buffer, buffer_size, callback);
467 } 468 }
468 469
469 int PseudoTcpAdapter::Write(const scoped_refptr<net::IOBuffer>& buffer, 470 int PseudoTcpAdapter::Write(const scoped_refptr<net::IOBuffer>& buffer,
470 int buffer_size, 471 int buffer_size,
471 const net::CompletionCallback& callback) { 472 const net::CompletionCallback& callback) {
472 DCHECK(CalledOnValidThread()); 473 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
473 return core_->Write(buffer, buffer_size, callback); 474 return core_->Write(buffer, buffer_size, callback);
474 } 475 }
475 476
476 int PseudoTcpAdapter::SetReceiveBufferSize(int32_t size) { 477 int PseudoTcpAdapter::SetReceiveBufferSize(int32_t size) {
477 DCHECK(CalledOnValidThread()); 478 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
478 core_->SetReceiveBufferSize(size); 479 core_->SetReceiveBufferSize(size);
479 return net::OK; 480 return net::OK;
480 } 481 }
481 482
482 int PseudoTcpAdapter::SetSendBufferSize(int32_t size) { 483 int PseudoTcpAdapter::SetSendBufferSize(int32_t size) {
483 DCHECK(CalledOnValidThread()); 484 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
484 core_->SetSendBufferSize(size); 485 core_->SetSendBufferSize(size);
485 return net::OK; 486 return net::OK;
486 } 487 }
487 488
488 int PseudoTcpAdapter::Connect(const net::CompletionCallback& callback) { 489 int PseudoTcpAdapter::Connect(const net::CompletionCallback& callback) {
489 DCHECK(CalledOnValidThread()); 490 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
490 return core_->Connect(callback); 491 return core_->Connect(callback);
491 } 492 }
492 493
493 void PseudoTcpAdapter::SetAckDelay(int delay_ms) { 494 void PseudoTcpAdapter::SetAckDelay(int delay_ms) {
494 DCHECK(CalledOnValidThread()); 495 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
495 core_->SetAckDelay(delay_ms); 496 core_->SetAckDelay(delay_ms);
496 } 497 }
497 498
498 void PseudoTcpAdapter::SetNoDelay(bool no_delay) { 499 void PseudoTcpAdapter::SetNoDelay(bool no_delay) {
499 DCHECK(CalledOnValidThread()); 500 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
500 core_->SetNoDelay(no_delay); 501 core_->SetNoDelay(no_delay);
501 } 502 }
502 503
503 void PseudoTcpAdapter::SetWriteWaitsForSend(bool write_waits_for_send) { 504 void PseudoTcpAdapter::SetWriteWaitsForSend(bool write_waits_for_send) {
504 DCHECK(CalledOnValidThread()); 505 DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
505 core_->SetWriteWaitsForSend(write_waits_for_send); 506 core_->SetWriteWaitsForSend(write_waits_for_send);
506 } 507 }
507 508
508 } // namespace protocol 509 } // namespace protocol
509 } // namespace remoting 510 } // namespace remoting
OLDNEW
« no previous file with comments | « remoting/protocol/pseudotcp_adapter.h ('k') | remoting/protocol/session_manager.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698