/external/chromium_org/v8/test/cctest/ |
test-socket.cc | 89 int bytes_read = 0; local 90 while (bytes_read < data_size_) { 91 bytes_read += client_->Receive(data_ + bytes_read, data_size_ - bytes_read);
|
/external/v8/test/cctest/ |
test-sockets.cc | 64 int bytes_read = 0; local 65 while (bytes_read < data_size_) { 66 bytes_read += client_->Receive(data_ + bytes_read, data_size_ - bytes_read);
|
/external/chromium/chrome/browser/ |
plugin_download_helper.cc | 78 int bytes_read = 0; local 80 &bytes_read)) { 86 } else if (bytes_read == 0) { 89 OnReadCompleted(request, bytes_read); 95 int bytes_read) { 98 if (bytes_read == 0) { 103 int request_bytes_read = bytes_read;
|
/external/chromium_org/net/test/spawned_test_server/ |
local_test_server_posix.cc | 64 ssize_t bytes_read = 0; local 66 while (bytes_read < bytes_max) { 76 LOG(ERROR) << "poll() timed out; bytes_read=" << bytes_read; 79 PLOG(ERROR) << "poll() failed for child file descriptor; bytes_read=" 80 << bytes_read; 90 ssize_t num_bytes = HANDLE_EINTR(read(fd, buffer + bytes_read, 91 bytes_max - bytes_read)); 94 bytes_read += num_bytes;
|
/external/flac/libFLAC/ |
ogg_helper.c | 47 size_t bytes_read = bytes; local 48 switch(read_callback(encoder, buffer, &bytes_read, client_data)) { 50 bytes -= bytes_read; 51 buffer += bytes_read; 54 if(bytes_read == 0) { 58 bytes -= bytes_read; 59 buffer += bytes_read;
|
/external/chromium/net/base/ |
file_stream_win.cc | 68 DWORD bytes_read, DWORD error); 98 MessageLoopForIO::IOContext* context, DWORD bytes_read, DWORD error) { 107 int result = static_cast<int>(bytes_read); 111 if (bytes_read) 112 IncrementOffset(&context->overlapped, bytes_read); 239 DWORD bytes_read; local 240 if (!ReadFile(file_, buf, buf_len, &bytes_read, overlapped)) { 255 rv = static_cast<int>(bytes_read); 265 int bytes_read = Read(buf, to_read, NULL); local 266 if (bytes_read <= 0) [all...] |
/external/chromium/net/socket/ |
transport_client_socket_unittest.cc | 136 uint32 bytes_read = 0; local 138 while (bytes_read < bytes_to_read) { 146 bytes_read += rv; 149 return static_cast<int>(bytes_read); 204 uint32 bytes_read; local 221 bytes_read = DrainClientSocket(buf, 1, 1, &callback); 222 ASSERT_EQ(bytes_read, 1u); 229 bytes_read = DrainClientSocket(buf, 4096, arraysize(kServerReply) - 2, 231 ASSERT_EQ(bytes_read, arraysize(kServerReply) - 2); 242 bytes_read = DrainClientSocket(buf, 1, 1, &callback) 271 uint32 bytes_read = DrainClientSocket(buf, 4096, arraysize(kServerReply) - 1, local 296 uint32 bytes_read = 0; local [all...] |
/external/chromium_org/net/socket/ |
transport_client_socket_unittest.cc | 144 uint32 bytes_read = 0; local 146 while (bytes_read < bytes_to_read) { 154 bytes_read += rv; 157 return static_cast<int>(bytes_read); 212 uint32 bytes_read; local 229 bytes_read = DrainClientSocket(buf.get(), 1, 1, &callback); 230 ASSERT_EQ(bytes_read, 1u); 237 bytes_read = DrainClientSocket( 239 ASSERT_EQ(bytes_read, arraysize(kServerReply) - 2); 250 bytes_read = DrainClientSocket(buf.get(), 1, 1, &callback) 285 uint32 bytes_read = DrainClientSocket( local 310 uint32 bytes_read = 0; local [all...] |
/external/chromium_org/native_client_sdk/src/tests/nacl_io_test/ |
mount_fuse_test.cc | 213 int bytes_read = 0; local 215 ASSERT_EQ(0, node->Read(attr, &buffer[0], sizeof(buffer), &bytes_read)); 217 ASSERT_EQ(sizeof(buffer), bytes_read); local 233 int bytes_read = 0; local 234 ASSERT_EQ(0, node->Read(attr, &buffer[0], sizeof(buffer), &bytes_read)); 236 ASSERT_EQ(sizeof(buffer), bytes_read); local 269 int bytes_read; local 272 ASSERT_EQ(0, root->GetDents(0, &entries[0], sizeof(entries), &bytes_read)); 273 ASSERT_EQ(3 * sizeof(dirent), bytes_read); 281 &bytes_read)); [all...] |
/external/chromium/chrome/browser/net/ |
view_http_cache_job_factory.cc | 39 virtual bool ReadRawData(net::IOBuffer* buf, int buf_size, int *bytes_read) { 40 return core_->ReadRawData(buf, buf_size, bytes_read); 62 bool ReadRawData(net::IOBuffer* buf, int buf_size, int *bytes_read); 160 int* bytes_read) { 161 DCHECK(bytes_read); 167 *bytes_read = buf_size;
|
/external/chromium_org/chrome_frame/ |
urlmon_upload_data_stream.cc | 94 int bytes_read = request_body_stream_->Read(buf, buf->size(), local 96 DCHECK_NE(net::ERR_IO_PENDING, bytes_read); 97 if (bytes_read == 0) // Reached the end of the stream. 100 memcpy(write_pointer, buf->data(), bytes_read); 103 bytes_copied += bytes_read; 106 write_pointer += bytes_read;
|
/external/chromium_org/content/browser/net/ |
view_http_cache_job_factory.cc | 46 int buf_size, int *bytes_read) OVERRIDE{ 47 return core_->ReadRawData(buf, buf_size, bytes_read); 67 bool ReadRawData(net::IOBuffer* buf, int buf_size, int *bytes_read); 167 int* bytes_read) { 168 DCHECK(bytes_read); 174 *bytes_read = buf_size;
|
/external/chromium_org/content/browser/loader/ |
stream_resource_handler.cc | 76 int bytes_read, 78 if (!bytes_read) 88 stream_->AddData(buffer, bytes_read);
|
certificate_resource_handler.cc | 77 int bytes_read, 79 if (!bytes_read) 84 content_length_ += bytes_read; 91 buffer_.push_back(std::make_pair(buffer, bytes_read));
|
/external/chromium_org/ipc/ |
ipc_channel_nacl.cc | 46 int bytes_read = imc_recvmsg(pipe, &msg, 0); local 48 if (bytes_read <= 0) { 55 DCHECK(bytes_read); 57 contents->data.resize(bytes_read); 299 int* bytes_read) { 300 *bytes_read = 0; 305 while (!read_queue_.empty() && *bytes_read < buffer_len) { 307 size_t bytes_to_read = buffer_len - *bytes_read; 310 std::copy(vec->begin(), vec->end(), buffer + *bytes_read); 311 *bytes_read += vec->size() [all...] |
/external/chromium_org/webkit/browser/fileapi/ |
file_writer_delegate.h | 61 int bytes_read) OVERRIDE; 69 void OnDataReceived(int bytes_read); 73 void OnProgress(int bytes_read, bool done);
|
/external/chromium/chrome/browser/safe_browsing/ |
bloom_filter.cc | 102 int bytes_read = filter.Read(reinterpret_cast<char*>(&file_version), local 104 if (bytes_read != sizeof(file_version) || file_version != kFileVersion) { 111 bytes_read = filter.Read(reinterpret_cast<char*>(&num_keys), 113 if (bytes_read != sizeof(num_keys) || 122 bytes_read = filter.Read(reinterpret_cast<char*>(&key), sizeof(key), NULL); 123 if (bytes_read != sizeof(key)) { 142 bytes_read = filter.Read(data.get(), byte_size, NULL); 143 if (bytes_read < byte_size) { 146 } else if (bytes_read != byte_size) {
|
/external/chromium/net/url_request/ |
url_request_simple_job.h | 23 virtual bool ReadRawData(IOBuffer* buf, int buf_size, int *bytes_read);
|
/external/chromium_org/android_webview/native/ |
input_stream_impl.h | 37 virtual bool Read(net::IOBuffer* dest, int length, int* bytes_read) OVERRIDE;
|
/external/chromium_org/base/debug/ |
proc_maps_linux.cc | 63 ssize_t bytes_read = HANDLE_EINTR(read(fd, buffer, kReadSize)); local 64 if (bytes_read < 0) { 71 proc_maps->resize(pos + bytes_read); 73 if (bytes_read == 0)
|
/external/chromium_org/chrome/browser/extensions/api/serial/ |
serial_io_handler.cc | 56 void SerialIoHandler::ReadCompleted(int bytes_read, 60 read_complete_.Run(std::string(pending_read_buffer_->data(), bytes_read), 105 void SerialIoHandler::QueueReadCompleted(int bytes_read, 109 bytes_read, error));
|
/external/chromium_org/chrome/browser/net/spdyproxy/ |
proxy_advisor.h | 46 int bytes_read) OVERRIDE;
|
/external/chromium_org/chrome/installer/util/ |
logging_installer.cc | 54 int bytes_read = base::ReadPlatformFile(old_log_file, local 58 if (bytes_read > 0 && 59 (bytes_read == file_util::WriteFile(log_file, 61 bytes_read) ||
|
/external/chromium_org/content/test/net/ |
url_request_abort_on_end_job.h | 34 int* bytes_read) OVERRIDE;
|
/external/chromium_org/media/mp3/ |
mp3_stream_parser.cc | 170 int bytes_read = 0; local 173 bytes_read = ParseMP3Frame(data, data_size, &buffers); 176 end_of_segment = bytes_read > 0; 179 bytes_read = ParseIcecastHeader(data, data_size); 181 bytes_read = ParseID3v1(data, data_size); 183 bytes_read = ParseID3v2(data, data_size); 185 bytes_read = FindNextValidStartCode(data, data_size); 187 if (bytes_read > 0) { 189 DVLOG(1) << "SKIPPING " << bytes_read << " bytes of garbage."; 193 CHECK_LE(bytes_read, data_size) 375 int bytes_read = ParseFrameHeader( local [all...] |