Home
last modified time | relevance | path

Searched refs:read_callback_ (Results 1 – 25 of 32) sorted by relevance

12

/external/chromium/net/spdy/
Dspdy_proxy_client_socket.cc36 read_callback_(NULL), in SpdyProxyClientSocket()
92 DCHECK(!read_callback_); in Connect()
101 read_callback_ = callback; in Connect()
108 read_callback_ = NULL; in Disconnect()
152 DCHECK(!read_callback_); in Read()
171 read_callback_ = callback; in Read()
268 CompletionCallback* c = read_callback_; in OnIOComplete()
269 read_callback_ = NULL; in OnIOComplete()
459 if (read_callback_) { in OnDataReceived()
461 CompletionCallback* c = read_callback_; in OnDataReceived()
[all …]
Dspdy_proxy_client_socket_unittest.cc103 TestCompletionCallback read_callback_; member in net::SpdyProxyClientSocketTest
129 read_callback_(), in SpdyProxyClientSocketTest()
215 ASSERT_EQ(ERR_IO_PENDING, sock_->Connect(&read_callback_)); in AssertConnectSucceeds()
217 ASSERT_EQ(OK, read_callback_.WaitForResult()); in AssertConnectSucceeds()
221 ASSERT_EQ(ERR_IO_PENDING, sock_->Connect(&read_callback_)); in AssertConnectFails()
223 ASSERT_EQ(result, read_callback_.WaitForResult()); in AssertConnectFails()
246 ASSERT_EQ(ERR_IO_PENDING, sock_->Read(buf, len, &read_callback_)); in AssertAsyncReadEquals()
253 EXPECT_EQ(len, read_callback_.WaitForResult()); in AssertAsyncReadEquals()
261 ASSERT_EQ(ERR_IO_PENDING, sock_->Read(read_buf_, len, &read_callback_)); in AssertReadStarts()
269 EXPECT_EQ(len, read_callback_.WaitForResult()); in AssertReadReturns()
[all …]
Dspdy_proxy_client_socket.h139 CompletionCallback* read_callback_; variable
/external/chromium/webkit/glue/media/
Dbuffered_data_source.cc56 read_callback_(NULL), in BufferedDataSource()
173 DCHECK(!read_callback_.get()); in Read()
182 read_callback_.reset(read_callback); in Read()
262 DCHECK(read_callback_.get()); in ReadTask()
289 if (read_callback_.get()) in CleanupTask()
316 if (!read_callback_.get()) in RestartLoadingTask()
337 if (!read_callback_.get()) in WatchDogTask()
427 DCHECK(read_callback_.get()); in DoneRead_Locked()
431 read_callback_->RunWithParams(Tuple1<size_t>(error)); in DoneRead_Locked()
433 read_callback_->RunWithParams( in DoneRead_Locked()
[all …]
Dbuffered_resource_loader.cc65 read_callback_(NULL), in BufferedResourceLoader()
127 read_callback_.reset(); in Stop()
153 DCHECK(!read_callback_.get()); in Read()
159 read_callback_.reset(read_callback); in Read()
479 return !read_callback_.get(); in ShouldEnableDefer()
504 return read_callback_.get() && amount_buffered < amount_to_read; in ShouldDisableDefer()
630 read_callback_->RunWithParams(Tuple1<int>(error)); in DoneRead()
631 read_callback_.reset(); in DoneRead()
Dbuffered_resource_loader.h208 bool HasPendingRead() { return read_callback_.get() != NULL; } in HasPendingRead()
250 scoped_ptr<net::CompletionCallback> read_callback_; variable
Dbuffered_data_source.h170 scoped_ptr<media::DataSource::ReadCallback> read_callback_; variable
/external/chromium/net/udp/
Dudp_socket_libevent.cc40 read_callback_(NULL), in UDPSocketLibevent()
63 read_callback_ = NULL; in Close()
137 DCHECK(!read_callback_); in RecvFrom()
156 read_callback_ = callback; in RecvFrom()
253 DCHECK(read_callback_); in DoReadCallback()
256 CompletionCallback* c = read_callback_; in DoReadCallback()
257 read_callback_ = NULL; in DoReadCallback()
Dudp_socket_win.cc40 read_callback_(NULL), in UDPSocketWin()
66 read_callback_ = NULL; in Close()
133 DCHECK(!read_callback_); in RecvFrom()
143 read_callback_ = callback; in RecvFrom()
232 DCHECK(read_callback_); in DoReadCallback()
235 CompletionCallback* c = read_callback_; in DoReadCallback()
236 read_callback_ = NULL; in DoReadCallback()
Dudp_socket_libevent.h106 if (socket_->read_callback_) in OnFileCanReadWithoutBlocking()
182 CompletionCallback* read_callback_; variable
Dudp_socket_win.h173 CompletionCallback* read_callback_; variable
/external/chromium/net/socket/
Ddeterministic_socket_data_unittest.cc44 TestCompletionCallback read_callback_; member in net::DeterministicSocketDataTest
65 : read_callback_(), in DeterministicSocketDataTest()
119 EXPECT_FALSE(read_callback_.have_result()); in AssertAsyncReadEquals()
124 ASSERT_EQ(len, read_callback_.WaitForResult()); in AssertAsyncReadEquals()
131 ASSERT_EQ(rv, sock_->Read(read_buf_, len, &read_callback_)); in AssertReadReturns()
153 EXPECT_FALSE(read_callback_.have_result()); in AssertAsyncWriteEquals()
479 ASSERT_EQ(kLen1, read_callback_.WaitForResult()); in TEST_F()
496 ASSERT_EQ(kLen2, read_callback_.WaitForResult()); in TEST_F()
533 ASSERT_EQ(kLen2, read_callback_.WaitForResult()); in TEST_F()
Dssl_server_socket_unittest.cc48 FakeDataChannel() : read_callback_(NULL), read_buf_len_(0) { in FakeDataChannel()
54 read_callback_ = callback; in Read()
71 if (!read_callback_) in DoReadCallback()
75 net::CompletionCallback* callback = read_callback_; in DoReadCallback()
76 read_callback_ = NULL; in DoReadCallback()
93 net::CompletionCallback* read_callback_; member in net::__anon5f9225790111::FakeDataChannel
Dtcp_client_socket_win.cc220 read_callback_(NULL), in TCPClientSocketWin()
278 read_callback_ = callback; in Connect()
522 DCHECK(!read_callback_); in Read()
559 read_callback_ = callback; in Read()
743 DCHECK(read_callback_); in DoReadCallback()
746 CompletionCallback* c = read_callback_; in DoReadCallback()
747 read_callback_ = NULL; in DoReadCallback()
Dtcp_client_socket_libevent.cc114 read_callback_(NULL), in TCPClientSocketLibevent()
386 DCHECK(!read_callback_); in Read()
415 read_callback_ = callback; in Read()
578 DCHECK(read_callback_); in DoReadCallback()
581 CompletionCallback* c = read_callback_; in DoReadCallback()
582 read_callback_ = NULL; in DoReadCallback()
Dtcp_client_socket_libevent.h85 if (socket_->read_callback_) in OnFileCanReadWithoutBlocking()
176 CompletionCallback* read_callback_; variable
Dtcp_client_socket_win.h122 CompletionCallback* read_callback_; variable
Dssl_client_socket_win.h113 CompletionCallbackImpl<SSLClientSocketWin> read_callback_; variable
Dsocket_test_util.cc872 read_callback_(NULL), in DeterministicMockTCPClientSocket()
906 read_callback_->Run(result); in CompleteRead()
948 read_callback_ = callback; in Read()
952 DCHECK(read_callback_); in Read()
/external/chromium/net/tools/fetch/
Dfetch_client.cc62 read_callback_(this, &Client::OnReadComplete)) { in Client()
77 int state = transaction_->Read(buffer_.get(), kBufferSize, &read_callback_); in OnConnectComplete()
96 int state = transaction_->Read(buffer_.get(), kBufferSize, &read_callback_); in OnReadComplete()
117 net::CompletionCallbackImpl<Client> read_callback_; member in Client
/external/chromium/net/url_request/
Durl_request_ftp_job.cc27 read_callback_(this, &URLRequestFtpJob::OnReadCompleted)), in URLRequestFtpJob()
241 int rv = transaction_->Read(buf, buf_size, &read_callback_); in ReadRawData()
Durl_request_ftp_job.h67 CompletionCallbackImpl<URLRequestFtpJob> read_callback_; variable
Durl_request_http_job.h109 CompletionCallbackImpl<URLRequestHttpJob> read_callback_; variable
/external/chromium/net/tools/dump_cache/
Dupgrade.cc595 net::CompletionCallbackImpl<SlaveSM> read_callback_; member in __anon09aa4b720111::SlaveSM
603 read_callback_(this, &SlaveSM::DoReadDataComplete)), in SlaveSM()
845 &read_callback_); in DoReadData()
/external/chromium/net/socket_stream/
Dsocket_stream.h308 CompletionCallbackImpl<SocketStream> read_callback_; variable

12