| /external/chromium_org/jingle/glue/ |
| channel_socket_adapter.cc | 50 CHECK(read_callback_.is_null());
57 read_callback_ = callback;
123 if (!read_callback_.is_null()) {
124 net::CompletionCallback callback = read_callback_;
125 read_callback_.Reset();
145 if (!read_callback_.is_null()) {
157 net::CompletionCallback callback = read_callback_;
158 read_callback_.Reset();
|
| pseudotcp_adapter.cc | 81 net::CompletionCallback read_callback_; member in class:jingle_glue::PseudoTcpAdapter::Core
128 DCHECK(read_callback_.is_null());
142 read_callback_ = callback;
211 read_callback_.Reset();
246 if (read_callback_.is_null())
259 net::CompletionCallback callback = read_callback_;
260 read_callback_.Reset();
307 if (!read_callback_.is_null()) {
308 net::CompletionCallback callback = read_callback_;
309 read_callback_.Reset()
[all...] |
| pseudotcp_adapter_unittest.cc | 92 if (!read_callback_.is_null()) {
95 net::CompletionCallback cb = read_callback_;
96 read_callback_.Reset();
117 CHECK(read_callback_.is_null());
128 read_callback_ = callback;
162 net::CompletionCallback read_callback_; member in class:jingle_glue::__anon10753::FakeSocket
|
| /external/chromium_org/net/spdy/ |
| spdy_proxy_client_socket.cc | 119 DCHECK(read_callback_.is_null());
128 read_callback_ = callback;
136 read_callback_.Reset();
197 DCHECK(read_callback_.is_null());
214 read_callback_ = callback;
275 CompletionCallback c = read_callback_;
276 read_callback_.Reset();
470 if (!read_callback_.is_null()) {
472 CompletionCallback c = read_callback_;
473 read_callback_.Reset()
[all...] |
| spdy_proxy_client_socket_unittest.cc | 117 TestCompletionCallback read_callback_; member in class:net::SpdyProxyClientSocketTest
217 ASSERT_EQ(ERR_IO_PENDING, sock_->Connect(read_callback_.callback()));
219 ASSERT_EQ(OK, read_callback_.WaitForResult());
223 ASSERT_EQ(ERR_IO_PENDING, sock_->Connect(read_callback_.callback()));
225 ASSERT_EQ(result, read_callback_.WaitForResult());
249 sock_->Read(buf.get(), len, read_callback_.callback()));
256 EXPECT_EQ(len, read_callback_.WaitForResult());
266 sock_->Read(read_buf_.get(), len, read_callback_.callback()));
275 EXPECT_EQ(len, read_callback_.WaitForResult());
892 ASSERT_EQ(kLen3, sock_->Read(buf.get(), kLen33, read_callback_.callback()))
[all...] |
| /external/chromium/net/udp/ |
| udp_socket_libevent.cc | 40 read_callback_(NULL),
63 read_callback_ = NULL;
137 DCHECK(!read_callback_);
156 read_callback_ = callback;
253 DCHECK(read_callback_);
255 // since Run may result in Read being called, clear read_callback_ up front.
256 CompletionCallback* c = read_callback_;
257 read_callback_ = NULL;
|
| udp_socket_win.cc | 40 read_callback_(NULL),
66 read_callback_ = NULL;
133 DCHECK(!read_callback_);
143 read_callback_ = callback;
232 DCHECK(read_callback_);
234 // since Run may result in Read being called, clear read_callback_ up front.
235 CompletionCallback* c = read_callback_;
236 read_callback_ = NULL;
|
| /external/chromium_org/ppapi/shared_impl/ |
| tcp_socket_shared.cc | 98 // It is possible that |read_callback_| is pending while |read_buffer_| is
100 // came earlier than the task to abort |read_callback_|. We shouldn't access
102 if (!TrackedCallback::IsPending(read_callback_) || !read_buffer_)
115 read_callback_->Run(
205 TrackedCallback::IsPending(read_callback_) ||
262 if (TrackedCallback::IsPending(read_callback_) ||
267 read_callback_ = callback;
307 PostAbortIfNecessary(&read_callback_);
|
| /external/chromium/net/spdy/ |
| spdy_proxy_client_socket.cc | 36 read_callback_(NULL),
92 DCHECK(!read_callback_);
101 read_callback_ = callback;
108 read_callback_ = NULL;
152 DCHECK(!read_callback_);
171 read_callback_ = callback;
268 CompletionCallback* c = read_callback_;
269 read_callback_ = NULL;
459 if (read_callback_) {
461 CompletionCallback* c = read_callback_;
[all...] |
| spdy_proxy_client_socket_unittest.cc | 103 TestCompletionCallback read_callback_; member in class:net::SpdyProxyClientSocketTest
129 read_callback_(),
215 ASSERT_EQ(ERR_IO_PENDING, sock_->Connect(&read_callback_));
217 ASSERT_EQ(OK, read_callback_.WaitForResult());
221 ASSERT_EQ(ERR_IO_PENDING, sock_->Connect(&read_callback_));
223 ASSERT_EQ(result, read_callback_.WaitForResult());
246 ASSERT_EQ(ERR_IO_PENDING, sock_->Read(buf, len, &read_callback_));
253 EXPECT_EQ(len, read_callback_.WaitForResult());
261 ASSERT_EQ(ERR_IO_PENDING, sock_->Read(read_buf_, len, &read_callback_));
269 EXPECT_EQ(len, read_callback_.WaitForResult())
[all...] |
| /external/chromium_org/chrome/browser/extensions/api/socket/ |
| udp_socket.cc | 69 if (!read_callback_.is_null()) {
73 read_callback_ = callback;
207 DCHECK(!read_callback_.is_null());
208 read_callback_.Run(result, io_buffer);
209 read_callback_.Reset();
|
| tcp_socket.cc | 116 if (!read_callback_.is_null()) {
120 read_callback_ = callback;
273 DCHECK(!read_callback_.is_null());
274 read_callback_.Run(result, io_buffer);
275 read_callback_.Reset();
|
| udp_socket.h | 68 ReadCompletionCallback read_callback_; member in class:extensions::UDPSocket
|
| /external/flac/libFLAC/ |
| stream_decoder.c | 127 static FLAC__bool read_callback_(FLAC__byte buffer[], size_t *bytes, void *client_data);
453 if(!FLAC__bitreader_init(decoder->private_->input, decoder->private_->cpuinfo, read_callback_, decoder)) {
2792 FLAC__bool read_callback_(FLAC__byte buffer[], size_t *bytes, void *client_data) function
[all...] |
| /external/chromium_org/net/socket/ |
| deterministic_socket_data_unittest.cc | 50 TestCompletionCallback read_callback_; member in class:net::DeterministicSocketDataTest
120 EXPECT_FALSE(read_callback_.have_result());
125 ASSERT_EQ(len, read_callback_.WaitForResult());
132 ASSERT_EQ(rv, sock_->Read(read_buf_.get(), len, read_callback_.callback()));
154 EXPECT_FALSE(read_callback_.have_result());
557 ASSERT_TRUE(read_callback_.have_result());
558 ASSERT_EQ(kLen1, read_callback_.WaitForResult());
577 ASSERT_TRUE(read_callback_.have_result());
578 ASSERT_EQ(kLen2, read_callback_.WaitForResult());
616 ASSERT_TRUE(read_callback_.have_result())
[all...] |
| /external/chromium/net/tools/fetch/ |
| fetch_client.cc | 62 read_callback_(this, &Client::OnReadComplete)) {
77 int state = transaction_->Read(buffer_.get(), kBufferSize, &read_callback_);
96 int state = transaction_->Read(buffer_.get(), kBufferSize, &read_callback_);
117 net::CompletionCallbackImpl<Client> read_callback_; member in class:Client
|
| /external/chromium/net/socket/ |
| deterministic_socket_data_unittest.cc | 44 TestCompletionCallback read_callback_; member in class:net::DeterministicSocketDataTest
65 : read_callback_(),
119 EXPECT_FALSE(read_callback_.have_result());
124 ASSERT_EQ(len, read_callback_.WaitForResult());
131 ASSERT_EQ(rv, sock_->Read(read_buf_, len, &read_callback_));
153 EXPECT_FALSE(read_callback_.have_result());
479 ASSERT_EQ(kLen1, read_callback_.WaitForResult());
496 ASSERT_EQ(kLen2, read_callback_.WaitForResult());
533 ASSERT_EQ(kLen2, read_callback_.WaitForResult());
|
| ssl_server_socket_unittest.cc | 48 FakeDataChannel() : read_callback_(NULL), read_buf_len_(0) {
54 read_callback_ = callback;
71 if (!read_callback_)
75 net::CompletionCallback* callback = read_callback_;
76 read_callback_ = NULL;
93 net::CompletionCallback* read_callback_; member in class:net::__anon5619::FakeDataChannel
|
| tcp_client_socket_libevent.cc | 114 read_callback_(NULL),
386 DCHECK(!read_callback_);
415 read_callback_ = callback;
578 DCHECK(read_callback_);
580 // since Run may result in Read being called, clear read_callback_ up front.
581 CompletionCallback* c = read_callback_;
582 read_callback_ = NULL;
|
| /external/chromium_org/chrome/browser/nacl_host/ |
| pnacl_translation_cache.cc | 102 GetNexeCallback read_callback_; member in class:pnacl::PnaclTranslationCacheEntry
116 entry->read_callback_ = callback;
145 DCHECK(read_callback_.is_null());
213 if (!read_callback_.is_null()) {
214 read_callback_.Run(rv, io_buf_);
215 read_callback_.Reset();
|
| /external/chromium/webkit/glue/media/ |
| buffered_resource_loader.cc | 65 read_callback_(NULL),
127 read_callback_.reset();
153 DCHECK(!read_callback_.get());
159 read_callback_.reset(read_callback);
479 return !read_callback_.get();
504 return read_callback_.get() && amount_buffered < amount_to_read;
630 read_callback_->RunWithParams(Tuple1<int>(error));
631 read_callback_.reset();
|
| buffered_data_source.cc | 56 read_callback_(NULL),
173 DCHECK(!read_callback_.get());
182 read_callback_.reset(read_callback);
262 DCHECK(read_callback_.get());
286 // before registering a new |read_callback_| (which is cleared below).
289 if (read_callback_.get())
316 if (!read_callback_.get())
337 if (!read_callback_.get())
427 DCHECK(read_callback_.get());
431 read_callback_->RunWithParams(Tuple1<size_t>(error))
[all...] |
| /external/chromium_org/net/udp/ |
| udp_socket_libevent.cc | 73 read_callback_.Reset();
146 DCHECK(read_callback_.is_null());
167 read_callback_ = callback;
314 if (!socket_->read_callback_.is_null())
325 DCHECK(!read_callback_.is_null());
327 // since Run may result in Read being called, clear read_callback_ up front.
328 CompletionCallback c = read_callback_;
329 read_callback_.Reset();
|
| /external/chromium/net/url_request/ |
| url_request_ftp_job.h | 67 CompletionCallbackImpl<URLRequestFtpJob> read_callback_; member in class:net::URLRequestFtpJob
|
| /external/chromium_org/content/browser/renderer_host/p2p/ |
| socket_host_test_utils.h | 91 net::CompletionCallback read_callback_; member in class:__anon10149::FakeSocket
127 net::CompletionCallback cb = read_callback_;
128 read_callback_.Reset();
154 read_callback_ = callback;
|
