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(); |
} |