| Index: net/socket/socket_test_util.cc
|
| diff --git a/net/socket/socket_test_util.cc b/net/socket/socket_test_util.cc
|
| index c5861faa796cdb373be504169b7ab5bbe548e1fd..92bd1c90ecae3e7c540c3b3c49f7653c4252e19a 100644
|
| --- a/net/socket/socket_test_util.cc
|
| +++ b/net/socket/socket_test_util.cc
|
| @@ -248,6 +248,14 @@ void StaticSocketDataProvider::Reset() {
|
| helper_.Reset();
|
| }
|
|
|
| +bool StaticSocketDataProvider::AllReadDataConsumed() const {
|
| + return helper_.at_read_eof();
|
| +}
|
| +
|
| +bool StaticSocketDataProvider::AllWriteDataConsumed() const {
|
| + return helper_.at_write_eof();
|
| +}
|
| +
|
| DynamicSocketDataProvider::DynamicSocketDataProvider()
|
| : short_read_limit_(0),
|
| allow_unconsumed_reads_(false) {
|
| @@ -600,6 +608,14 @@ void SequencedSocketData::Reset() {
|
| weak_factory_.InvalidateWeakPtrs();
|
| }
|
|
|
| +bool SequencedSocketData::AllReadDataConsumed() const {
|
| + return helper_.at_read_eof();
|
| +}
|
| +
|
| +bool SequencedSocketData::AllWriteDataConsumed() const {
|
| + return helper_.at_write_eof();
|
| +}
|
| +
|
| bool SequencedSocketData::at_read_eof() const {
|
| return helper_.at_read_eof();
|
| }
|
|
|