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

Side by Side Diff: net/socket/socket_test_util.cc

Issue 1113203002: Convert DnsTransactionTest to use SequencedSocketData (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Rebase Created 5 years, 7 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 "net/socket/socket_test_util.h" 5 #include "net/socket/socket_test_util.h"
6 6
7 #include <algorithm> 7 #include <algorithm>
8 #include <vector> 8 #include <vector>
9 9
10 #include "base/basictypes.h" 10 #include "base/basictypes.h"
(...skipping 582 matching lines...) Expand 10 before | Expand all | Expand 10 after
593 } 593 }
594 594
595 void SequencedSocketData::Reset() { 595 void SequencedSocketData::Reset() {
596 helper_.Reset(); 596 helper_.Reset();
597 sequence_number_ = 0; 597 sequence_number_ = 0;
598 read_state_ = IDLE; 598 read_state_ = IDLE;
599 write_state_ = IDLE; 599 write_state_ = IDLE;
600 weak_factory_.InvalidateWeakPtrs(); 600 weak_factory_.InvalidateWeakPtrs();
601 } 601 }
602 602
603 bool SequencedSocketData::WasDataWritten() const {
604 return helper_.write_index() > 0 || write_state_ != IDLE;
605 }
606
603 bool SequencedSocketData::at_read_eof() const { 607 bool SequencedSocketData::at_read_eof() const {
604 return helper_.at_read_eof(); 608 return helper_.at_read_eof();
605 } 609 }
606 610
607 bool SequencedSocketData::at_write_eof() const { 611 bool SequencedSocketData::at_write_eof() const {
608 return helper_.at_read_eof(); 612 return helper_.at_read_eof();
609 } 613 }
610 614
611 void SequencedSocketData::MaybePostReadCompleteTask() { 615 void SequencedSocketData::MaybePostReadCompleteTask() {
612 NET_TRACE(1, " ****** ") << " current: " << sequence_number_; 616 NET_TRACE(1, " ****** ") << " current: " << sequence_number_;
(...skipping 1082 matching lines...) Expand 10 before | Expand all | Expand 10 after
1695 source_port_(123), 1699 source_port_(123),
1696 pending_read_buf_(NULL), 1700 pending_read_buf_(NULL),
1697 pending_read_buf_len_(0), 1701 pending_read_buf_len_(0),
1698 net_log_(BoundNetLog::Make(net_log, NetLog::SOURCE_NONE)), 1702 net_log_(BoundNetLog::Make(net_log, NetLog::SOURCE_NONE)),
1699 weak_factory_(this) { 1703 weak_factory_(this) {
1700 DCHECK(data_); 1704 DCHECK(data_);
1701 data_->Reset(); 1705 data_->Reset();
1702 peer_addr_ = data->connect_data().peer_addr; 1706 peer_addr_ = data->connect_data().peer_addr;
1703 } 1707 }
1704 1708
1705 MockUDPClientSocket::~MockUDPClientSocket() {} 1709 MockUDPClientSocket::~MockUDPClientSocket() {
1710 data_->set_socket(nullptr);
1711 }
1706 1712
1707 int MockUDPClientSocket::Read(IOBuffer* buf, 1713 int MockUDPClientSocket::Read(IOBuffer* buf,
1708 int buf_len, 1714 int buf_len,
1709 const CompletionCallback& callback) { 1715 const CompletionCallback& callback) {
1710 if (!connected_) 1716 if (!connected_)
1711 return ERR_UNEXPECTED; 1717 return ERR_UNEXPECTED;
1712 1718
1713 // If the buffer is already in use, a read is already in progress! 1719 // If the buffer is already in use, a read is already in progress!
1714 DCHECK(pending_read_buf_.get() == NULL); 1720 DCHECK(pending_read_buf_.get() == NULL);
1715 1721
(...skipping 463 matching lines...) Expand 10 before | Expand all | Expand 10 after
2179 2185
2180 const char kSOCKS5OkRequest[] = 2186 const char kSOCKS5OkRequest[] =
2181 { 0x05, 0x01, 0x00, 0x03, 0x04, 'h', 'o', 's', 't', 0x00, 0x50 }; 2187 { 0x05, 0x01, 0x00, 0x03, 0x04, 'h', 'o', 's', 't', 0x00, 0x50 };
2182 const int kSOCKS5OkRequestLength = arraysize(kSOCKS5OkRequest); 2188 const int kSOCKS5OkRequestLength = arraysize(kSOCKS5OkRequest);
2183 2189
2184 const char kSOCKS5OkResponse[] = 2190 const char kSOCKS5OkResponse[] =
2185 { 0x05, 0x00, 0x00, 0x01, 127, 0, 0, 1, 0x00, 0x50 }; 2191 { 0x05, 0x00, 0x00, 0x01, 127, 0, 0, 1, 0x00, 0x50 };
2186 const int kSOCKS5OkResponseLength = arraysize(kSOCKS5OkResponse); 2192 const int kSOCKS5OkResponseLength = arraysize(kSOCKS5OkResponse);
2187 2193
2188 } // namespace net 2194 } // namespace net
OLDNEW
« net/dns/dns_transaction_unittest.cc ('K') | « net/socket/socket_test_util.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698