Searched defs:bytes_read (Results 226 - 250 of 299) sorted by relevance

1234567891011>>

/external/chromium_org/net/tools/quic/test_tools/
H A Dquic_test_client.cc482 size_t QuicTestClient::bytes_read() const { function in class:net::tools::test::QuicTestClient
/external/chromium_org/net/url_request/
H A Durl_request_job.cc67 bool URLRequestJob::Read(IOBuffer* buf, int buf_size, int *bytes_read) { argument
72 DCHECK(bytes_read);
76 *bytes_read = 0;
80 rv = ReadRawDataHelper(buf, buf_size, bytes_read);
87 if (ReadFilteredData(bytes_read)) {
93 if (*bytes_read == 0)
99 if (rv && *bytes_read == 0)
379 void URLRequestJob::NotifyReadComplete(int bytes_read) { argument
391 OnRawReadComplete(bytes_read);
406 FilteredDataRead(bytes_read);
513 ReadRawData(IOBuffer* buf, int buf_size, int *bytes_read) argument
527 FilteredDataRead(int bytes_read) argument
532 ReadFilteredData(int* bytes_read) argument
673 ReadRawDataForFilter(int* bytes_read) argument
692 ReadRawDataHelper(IOBuffer* buf, int buf_size, int* bytes_read) argument
718 OnRawReadComplete(int bytes_read) argument
734 RecordBytesRead(int bytes_read) argument
[all...]
H A Durl_request_test_util.cc258 int bytes_read = 0; local
259 if (request->Read(buf_.get(), kBufferSize, &bytes_read))
260 OnReadCompleted(request, bytes_read);
266 void TestDelegate::OnReadCompleted(URLRequest* request, int bytes_read) { argument
276 if (bytes_read >= 0) {
278 received_bytes_count_ += bytes_read;
281 data_received_.append(buf_->data(), bytes_read);
285 if (request->status().is_success() && bytes_read > 0) {
286 bytes_read = 0;
287 while (request->Read(buf_.get(), kBufferSize, &bytes_read)) {
494 OnRawBytesRead(const URLRequest& request, int bytes_read) argument
[all...]
H A Durl_fetcher_core.cc419 int bytes_read) {
432 if (!request_->status().is_success() || bytes_read <= 0)
435 current_response_bytes_ += bytes_read;
439 WriteBuffer(new DrainableIOBuffer(buffer_.get(), bytes_read));
444 } while (request_->Read(buffer_.get(), kBufferSize, &bytes_read));
646 // OnReadCompleted() with bytes_read = -1 via an asynchronous task posted by
848 int bytes_read = 0; local
851 if (!request_->Read(buffer_.get(), kBufferSize, &bytes_read))
852 bytes_read = -1; // Match OnReadCompleted() interface contract.
854 OnReadCompleted(request_.get(), bytes_read);
418 OnReadCompleted(URLRequest* request, int bytes_read) argument
[all...]
H A Durl_request.cc783 bool URLRequest::Read(IOBuffer* dest, int dest_size, int* bytes_read) { argument
785 DCHECK(bytes_read);
786 *bytes_read = 0;
809 bool rv = job_->Read(dest, dest_size, bytes_read);
812 if (rv && *bytes_read <= 0 && status_.is_success())
1155 void URLRequest::NotifyReadCompleted(int bytes_read) { argument
1157 if (bytes_read <= 0)
1164 if (bytes_read > 0 && !was_cached())
1165 NetworkChangeNotifier::NotifyDataReceived(*this, bytes_read);
1168 delegate_->OnReadCompleted(this, bytes_read);
[all...]
H A Durl_request_http_job.cc1238 int* bytes_read) {
1240 DCHECK(bytes_read);
1251 *bytes_read = rv;
1237 ReadRawData(IOBuffer* buf, int buf_size, int* bytes_read) argument
/external/chromium_org/v8/src/
H A Dd8-posix.cc278 int bytes_read; local
281 bytes_read = read(exec_error_fds[kReadFD], &err, sizeof(err));
282 } while (bytes_read == -1 && errno == EINTR);
283 if (bytes_read != 0) {
309 int bytes_read; local
311 bytes_read = read(child_fd,
314 if (bytes_read == -1) {
331 if (bytes_read + fullness > 0) {
332 int length = bytes_read == 0 ?
333 bytes_read
[all...]
/external/e2fsprogs/e2fsck/
H A Dutil.c347 track->bytes_read = 0;
352 track->bytes_read = io_start->bytes_read;
417 unsigned long long bytes_read = 0; local
425 bytes_read = delta->bytes_read - track->bytes_read;
431 mbytes(bytes_read), mbytes(bytes_written),
432 (double)mbytes(bytes_read + bytes_written) /
/external/lldb/source/Core/
H A DAddress.cpp184 size_t bytes_read; local
187 while ((bytes_read = ReadBytes (exe_scope, curr_address, buf, k_buf_len)) > 0)
192 if (len > bytes_read)
193 len = bytes_read;
206 total_len += bytes_read;
210 curr_address.SetOffset (curr_address.GetOffset() + bytes_read);
/external/lldb/source/Host/linux/
H A DHost.cpp77 size_t bytes_read = 0; local
82 size_t avail = buf_ap->GetByteSize() - bytes_read;
83 ssize_t status = read (fd, buf_ap->GetBytes() + bytes_read, avail);
90 buf_ap->SetByteSize (bytes_read);
95 bytes_read += status;
/external/lldb/source/Plugins/LanguageRuntime/ObjC/AppleObjCRuntime/
H A DAppleObjCTrampolineHandler.cpp291 size_t bytes_read = process->ReadMemory (m_header_addr, memory_buffer, actual_size, error); local
292 if (bytes_read != actual_size)
333 bytes_read = process->ReadMemory(desc_ptr, dst, desc_array_size, error);
334 if (bytes_read != desc_array_size)
/external/lldb/source/Plugins/Platform/MacOSX/
H A DPlatformDarwin.cpp957 size_t bytes_read = temp_file_spec.ReadFileContents(0, developer_dir_path, sizeof(developer_dir_path), NULL); local
958 if (bytes_read > 0)
960 developer_dir_path[bytes_read] = '\0';
961 while (developer_dir_path[bytes_read-1] == '\r' ||
962 developer_dir_path[bytes_read-1] == '\n')
963 developer_dir_path[--bytes_read] = '\0';
/external/chromium_org/base/files/
H A Dfile_util_posix.cc375 ssize_t bytes_read = local
377 if (bytes_read <= 0)
379 total_read += bytes_read;
673 ssize_t bytes_read = HANDLE_EINTR(read(fd, data, max_size));
676 return bytes_read;
880 ssize_t bytes_read = HANDLE_EINTR(read(infile, &buffer[0], buffer.size())); local
881 if (bytes_read < 0) {
885 if (bytes_read == 0)
893 bytes_read - bytes_written_per_read));
899 } while (bytes_written_per_read < bytes_read);
[all...]
/external/chromium_org/chrome/browser/media_galleries/linux/
H A Dmtp_device_delegate_impl_linux.cc831 const base::File::Info& file_info, int bytes_read) {
833 success_callback.Run(file_info, bytes_read);
829 OnDidReadBytes( const ReadBytesSuccessCallback& success_callback, const base::File::Info& file_info, int bytes_read) argument
/external/chromium_org/chrome/browser/
H A Dprocess_singleton_posix.cc198 size_t bytes_read = 0; local
200 ssize_t rv = HANDLE_EINTR(read(fd, buf + bytes_read, bufsize - bytes_read));
207 return bytes_read;
211 return bytes_read;
213 bytes_read += rv;
215 } while (bytes_read < bufsize);
217 return bytes_read;
/external/chromium_org/content/browser/appcache/
H A Dappcache_update_job.cc227 net::URLRequest* request, int bytes_read) {
230 if (request->status().is_success() && bytes_read > 0) {
232 data_consumed = ConsumeResponseData(bytes_read);
234 bytes_read = 0;
235 while (request->Read(buffer_.get(), kBufferSize, &bytes_read)) {
236 if (bytes_read > 0) {
237 data_consumed = ConsumeResponseData(bytes_read);
292 int bytes_read = 0; local
293 request_->Read(buffer_.get(), kBufferSize, &bytes_read);
294 OnReadCompleted(request_.get(), bytes_read);
226 OnReadCompleted( net::URLRequest* request, int bytes_read) argument
300 ConsumeResponseData(int bytes_read) argument
[all...]
H A Dappcache_url_request_job_unittest.cc140 int bytes_read) OVERRIDE {
141 if (bytes_read > 0) {
142 amount_received_ += bytes_read;
168 int bytes_read = 0; local
170 request->Read(wrapped_buffer.get(), kBlockSize, &bytes_read));
171 EXPECT_EQ(0, bytes_read);
/external/chromium_org/content/browser/gamepad/
H A Dxbox_data_fetcher_mac.cc497 size_t bytes_read = reinterpret_cast<size_t>(arg0); local
508 controller->ProcessXbox360Packet(bytes_read);
510 controller->ProcessXboxOnePacket(bytes_read);
/external/chromium_org/extensions/browser/api/socket/
H A Dsocket_api.cc396 void SocketReadFunction::OnCompleted(int bytes_read, argument
399 result->SetInteger(kResultCodeKey, bytes_read);
400 if (bytes_read > 0) {
403 bytes_read));
471 void SocketRecvFromFunction::OnCompleted(int bytes_read, argument
476 result->SetInteger(kResultCodeKey, bytes_read);
477 if (bytes_read > 0) {
480 bytes_read));
/external/chromium_org/net/ocsp/
H A Dnss_ocsp.cc303 int bytes_read = 0; variable
308 request_->Read(buffer_.get(), kRecvBufferSize, &bytes_read);
310 OnReadCompleted(request_.get(), bytes_read);
314 int bytes_read) OVERRIDE {
319 if (!request_->status().is_success() || bytes_read <= 0)
321 data_.append(buffer_->data(), bytes_read);
322 } while (request_->Read(buffer_.get(), kRecvBufferSize, &bytes_read));
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/
H A Dpseudotcp.cc546 size_t bytes_read = 0; local
548 buffer.get() + HEADER_SIZE, len, offset, &bytes_read);
551 ASSERT(static_cast<uint32>(bytes_read) == len);
/external/chromium_org/third_party/libjpeg_turbo/
H A Djdmarker.c105 unsigned int bytes_read; /* data bytes read so far in marker */ member in struct:__anon12745
760 unsigned int bytes_read, data_length; local
789 marker->bytes_read = 0;
790 bytes_read = 0;
794 bytes_read = data_length = 0;
799 bytes_read = marker->bytes_read;
801 data = cur_marker->data + bytes_read;
804 while (bytes_read < data_length) {
806 marker->bytes_read
[all...]
/external/chromium_org/third_party/libxml/src/
H A Dnanohttp.c1261 int bytes_read = 0; local
1281 ctxt->inptr - ctxt->inrptr - bytes_read;
1282 ctxt->strm->next_in = BAD_CAST (ctxt->inrptr + bytes_read);
1285 bytes_read += orig_avail_in - ctxt->strm->avail_in;
1290 ctxt->inrptr += bytes_read;
/external/chromium_org/third_party/webrtc/base/
H A Dstream.cc743 size_t* bytes_read, int* error) {
754 if (bytes_read) {
755 *bytes_read = bytes;
941 size_t offset, size_t* bytes_read) {
943 return ReadOffsetLocked(buffer, bytes, offset, bytes_read);
957 size_t* bytes_read, int* error) {
968 if (bytes_read) {
969 *bytes_read = copy;
1064 size_t* bytes_read) {
1077 if (bytes_read) {
742 Read(void* buffer, size_t bytes, size_t* bytes_read, int* error) argument
940 ReadOffset(void* buffer, size_t bytes, size_t offset, size_t* bytes_read) argument
956 Read(void* buffer, size_t bytes, size_t* bytes_read, int* error) argument
[all...]
/external/compiler-rt/lib/asan/
H A Dasan_interceptors.cc440 uptr bytes_read = (result ? result - str : REAL(strlen)(str)) + 1; local
441 ASAN_READ_RANGE(str, bytes_read);

Completed in 1941 milliseconds

1234567891011>>