SocketInputStream 22 google_apis/gcm/base/socket_stream.cc SocketInputStream::SocketInputStream(net::StreamSocket* socket) SocketInputStream 33 google_apis/gcm/base/socket_stream.cc SocketInputStream::~SocketInputStream() { SocketInputStream 36 google_apis/gcm/base/socket_stream.cc bool SocketInputStream::Next(const void** data, int* size) { SocketInputStream 57 google_apis/gcm/base/socket_stream.cc void SocketInputStream::BackUp(int count) { SocketInputStream 68 google_apis/gcm/base/socket_stream.cc bool SocketInputStream::Skip(int count) { SocketInputStream 73 google_apis/gcm/base/socket_stream.cc int64 SocketInputStream::ByteCount() const { SocketInputStream 79 google_apis/gcm/base/socket_stream.cc size_t SocketInputStream::UnreadByteCount() const { SocketInputStream 85 google_apis/gcm/base/socket_stream.cc net::Error SocketInputStream::Refresh(const base::Closure& callback, SocketInputStream 107 google_apis/gcm/base/socket_stream.cc base::Bind(&SocketInputStream::RefreshCompletionCallback, SocketInputStream 120 google_apis/gcm/base/socket_stream.cc void SocketInputStream::RebuildBuffer() { SocketInputStream 142 google_apis/gcm/base/socket_stream.cc net::Error SocketInputStream::last_error() const { SocketInputStream 146 google_apis/gcm/base/socket_stream.cc SocketInputStream::State SocketInputStream::GetState() const { SocketInputStream 160 google_apis/gcm/base/socket_stream.cc void SocketInputStream::RefreshCompletionCallback( SocketInputStream 191 google_apis/gcm/base/socket_stream.cc void SocketInputStream::ResetInternal() { SocketInputStream 198 google_apis/gcm/base/socket_stream.cc void SocketInputStream::CloseStream(net::Error error, SocketInputStream 49 google_apis/gcm/base/socket_stream.h class GCM_EXPORT SocketInputStream SocketInputStream 65 google_apis/gcm/base/socket_stream.h explicit SocketInputStream(net::StreamSocket* socket); SocketInputStream 66 google_apis/gcm/base/socket_stream.h virtual ~SocketInputStream(); SocketInputStream 125 google_apis/gcm/base/socket_stream.h base::WeakPtrFactory<SocketInputStream> weak_ptr_factory_; SocketInputStream 127 google_apis/gcm/base/socket_stream.h DISALLOW_COPY_AND_ASSIGN(SocketInputStream); SocketInputStream 50 google_apis/gcm/base/socket_stream_unittest.cc SocketInputStream* input_stream() { return socket_input_stream_.get(); } SocketInputStream 65 google_apis/gcm/base/socket_stream_unittest.cc scoped_ptr<SocketInputStream> socket_input_stream_; SocketInputStream 111 google_apis/gcm/base/socket_stream_unittest.cc DCHECK(socket_input_stream_->GetState() == SocketInputStream::EMPTY || SocketInputStream 112 google_apis/gcm/base/socket_stream_unittest.cc socket_input_stream_->GetState() == SocketInputStream::READY); SocketInputStream 170 google_apis/gcm/base/socket_stream_unittest.cc if (input_stream()->GetState() == SocketInputStream::CLOSED) SocketInputStream 188 google_apis/gcm/base/socket_stream_unittest.cc socket_input_stream_.reset(new SocketInputStream(socket_.get())); SocketInputStream 295 google_apis/gcm/base/socket_stream_unittest.cc ASSERT_EQ(SocketInputStream::CLOSED, input_stream()->GetState()); SocketInputStream 304 google_apis/gcm/base/socket_stream_unittest.cc ASSERT_EQ(SocketInputStream::CLOSED, input_stream()->GetState()); SocketInputStream 27 google_apis/gcm/engine/connection_handler.h class SocketInputStream; SocketInputStream 67 google_apis/gcm/engine/connection_handler_impl.cc input_stream_.reset(new SocketInputStream(socket_)); SocketInputStream 156 google_apis/gcm/engine/connection_handler_impl.cc DCHECK(SocketInputStream::EMPTY == input_stream_->GetState() || SocketInputStream 157 google_apis/gcm/engine/connection_handler_impl.cc SocketInputStream::READY == input_stream_->GetState()); SocketInputStream 174 google_apis/gcm/engine/connection_handler_impl.cc if (input_stream_->GetState() != SocketInputStream::EMPTY && SocketInputStream 175 google_apis/gcm/engine/connection_handler_impl.cc input_stream_->GetState() != SocketInputStream::READY) { SocketInputStream 228 google_apis/gcm/engine/connection_handler_impl.cc if (input_stream_->GetState() != SocketInputStream::READY) { SocketInputStream 279 google_apis/gcm/engine/connection_handler_impl.cc if (input_stream_->GetState() != SocketInputStream::READY) { SocketInputStream 303 google_apis/gcm/engine/connection_handler_impl.cc if (input_stream_->GetState() != SocketInputStream::READY) { SocketInputStream 357 google_apis/gcm/engine/connection_handler_impl.cc input_stream_->GetState() != SocketInputStream::READY) { SocketInputStream 101 google_apis/gcm/engine/connection_handler_impl.h scoped_ptr<SocketInputStream> input_stream_; SocketInputStream 139 google_apis/gcm/engine/connection_handler_impl_unittest.cc scoped_ptr<SocketInputStream> socket_input_stream_;