Home
last modified time | relevance | path

Searched refs:bytes_consumed (Results 1 – 25 of 38) sorted by relevance

12

/external/chromium_org/remoting/client/
Daudio_player_unittest.cc167 int bytes_consumed = 0; in TEST_F() local
176 ASSERT_EQ(bytes_consumed, GetBytesConsumed()); in TEST_F()
181 bytes_consumed += kAudioFrameBytes; in TEST_F()
184 ASSERT_EQ(bytes_consumed, GetBytesConsumed()); in TEST_F()
189 ASSERT_EQ(25 * kAudioSampleBytes, bytes_consumed); in TEST_F()
196 int bytes_consumed = 0; in TEST_F() local
211 ASSERT_EQ(bytes_consumed, GetBytesConsumed()); in TEST_F()
217 bytes_consumed += kAudioFrameBytes - (packet1_samples * kAudioSampleBytes); in TEST_F()
220 ASSERT_EQ(bytes_consumed, GetBytesConsumed()); in TEST_F()
226 bytes_consumed += kAudioFrameBytes; in TEST_F()
[all …]
/external/chromium_org/net/quic/
Dquic_stream_sequencer.cc70 size_t bytes_consumed = 0; in OnStreamFrame() local
72 bytes_consumed += stream_->ProcessRawData( in OnStreamFrame()
76 num_bytes_consumed_ += bytes_consumed; in OnStreamFrame()
77 stream_->AddBytesConsumed(bytes_consumed); in OnStreamFrame()
82 if (bytes_consumed > data_len) { in OnStreamFrame()
85 } else if (bytes_consumed == data_len) { in OnStreamFrame()
90 data_len -= bytes_consumed; in OnStreamFrame()
91 data.Consume(bytes_consumed); in OnStreamFrame()
92 byte_offset += bytes_consumed; in OnStreamFrame()
265 size_t bytes_consumed = stream_->ProcessRawData(data->c_str(), in FlushBufferedFrames() local
[all …]
Dquic_types.cc11 QuicConsumedData::QuicConsumedData(size_t bytes_consumed, in QuicConsumedData() argument
13 : bytes_consumed(bytes_consumed), in QuicConsumedData()
18 os << "bytes_consumed: " << s.bytes_consumed in operator <<()
Dquic_data_stream.cc67 size_t bytes_consumed = 0; in Readv() local
70 decompressed_headers_.length() > bytes_consumed) { in Readv()
72 decompressed_headers_.length() - bytes_consumed); in Readv()
75 decompressed_headers_.data() + bytes_consumed, bytes_to_read); in Readv()
76 bytes_consumed += bytes_to_read; in Readv()
79 decompressed_headers_.erase(0, bytes_consumed); in Readv()
83 return bytes_consumed; in Readv()
Dreliable_quic_stream.cc287 DCHECK_LE(consumed_data.bytes_consumed, data.length()); in WriteOrBufferData()
292 if (consumed_data.bytes_consumed < data.length() || in WriteOrBufferData()
294 StringPiece remainder(data.substr(consumed_data.bytes_consumed)); in WriteOrBufferData()
302 (consumed_data.bytes_consumed > 0 || consumed_data.fin_consumed)) { in WriteOrBufferData()
317 if (consumed_data.bytes_consumed == pending_data->data.size() && in OnCanWrite()
324 if (consumed_data.bytes_consumed > 0) { in OnCanWrite()
325 pending_data->data.erase(0, consumed_data.bytes_consumed); in OnCanWrite()
399 stream_bytes_written_ += consumed_data.bytes_consumed; in WritevData()
401 AddBytesSent(consumed_data.bytes_consumed); in WritevData()
403 if (consumed_data.bytes_consumed == write_length) { in WritevData()
[all …]
Dquic_packet_generator_test.cc377 EXPECT_EQ(0u, consumed.bytes_consumed); in TEST_F()
388 EXPECT_EQ(3u, consumed.bytes_consumed); in TEST_F()
399 EXPECT_EQ(3u, consumed.bytes_consumed); in TEST_F()
417 EXPECT_EQ(4u, consumed.bytes_consumed); in TEST_F()
430 EXPECT_EQ(4u, consumed.bytes_consumed); in TEST_F()
470 EXPECT_EQ(data_len, consumed.bytes_consumed); in TEST_F()
503 EXPECT_EQ(data_len, consumed.bytes_consumed); in TEST_F()
539 EXPECT_EQ(3u, consumed.bytes_consumed); in TEST_F()
548 EXPECT_EQ(3u, consumed.bytes_consumed); in TEST_F()
600 EXPECT_EQ(data_len, consumed.bytes_consumed); in TEST_F()
[all …]
Dquic_types.h21 QuicConsumedData(size_t bytes_consumed, bool fin_consumed);
31 size_t bytes_consumed; member
Dquic_packet_generator.cc143 size_t bytes_consumed; in ConsumeData() local
146 bytes_consumed = packet_creator_.CreateStreamFrameWithNotifier( in ConsumeData()
149 bytes_consumed = packet_creator_.CreateStreamFrame( in ConsumeData()
160 total_bytes_consumed += bytes_consumed; in ConsumeData()
162 data.Consume(bytes_consumed); in ConsumeData()
Dquic_packet_creator.cc255 size_t bytes_consumed = min<size_t>(BytesFree() - min_frame_size, data_size); in CreateStreamFrame() local
257 bool set_fin = fin && bytes_consumed == data_size; // Last frame. in CreateStreamFrame()
260 bytes_consumed); in CreateStreamFrame()
261 DCHECK_EQ(frame_data.TotalBufferSize(), bytes_consumed); in CreateStreamFrame()
263 return bytes_consumed; in CreateStreamFrame()
273 size_t bytes_consumed = CreateStreamFrame(id, data, offset, fin, frame); in CreateStreamFrameWithNotifier() local
280 return bytes_consumed; in CreateStreamFrameWithNotifier()
Dquic_flow_controller.h44 void AddBytesConsumed(uint64 bytes_consumed);
71 uint64 bytes_consumed() const { return bytes_consumed_; } in bytes_consumed() function
Dquic_flow_controller.cc46 void QuicFlowController::AddBytesConsumed(uint64 bytes_consumed) { in AddBytesConsumed() argument
51 bytes_consumed_ += bytes_consumed; in AddBytesConsumed()
Dquic_packet_creator_test.cc639 size_t bytes_consumed = creator_.CreateStreamFrame( in TEST_P() local
642 EXPECT_LT(0u, bytes_consumed); in TEST_P()
662 size_t bytes_consumed = creator_.CreateStreamFrame( in TEST_P() local
664 EXPECT_EQ(capacity - bytes_free, bytes_consumed); in TEST_P()
691 size_t bytes_consumed = creator_.CreateStreamFrame( in TEST_P() local
693 EXPECT_EQ(capacity - bytes_free, bytes_consumed); in TEST_P()
721 size_t bytes_consumed = creator_.CreateStreamFrame( in TEST_P() local
723 EXPECT_LT(0u, bytes_consumed); in TEST_P()
754 size_t bytes_consumed = creator_.CreateStreamFrame( in TEST_P() local
756 EXPECT_LT(0u, bytes_consumed); in TEST_P()
/external/chromium_org/net/http/
Dhttp_chunked_decoder.cc91 int bytes_consumed = ScanForChunkRemaining(buf, buf_len); in FilterBuf() local
92 if (bytes_consumed < 0) in FilterBuf()
93 return bytes_consumed; // Error in FilterBuf()
95 buf_len -= bytes_consumed; in FilterBuf()
97 memmove(buf, buf + bytes_consumed, buf_len); in FilterBuf()
107 int bytes_consumed = 0; in ScanForChunkRemaining() local
114 bytes_consumed = static_cast<int>(index_of_lf) + 1; in ScanForChunkRemaining()
155 bytes_consumed = buf_len; in ScanForChunkRemaining()
168 return bytes_consumed; in ScanForChunkRemaining()
/external/chromium_org/device/serial/
Ddata_receiver.cc71 virtual void Done(uint32_t bytes_consumed) OVERRIDE;
72 virtual void DoneWithError(uint32_t bytes_consumed, int32_t error) OVERRIDE;
169 void DataReceiver::Done(uint32_t bytes_consumed) { in Done() argument
174 MojoResult result = mojo::EndReadDataRaw(handle_.get(), bytes_consumed); in Done()
177 bytes_received_ += bytes_consumed; in Done()
296 void DataReceiver::PendingReceive::Done(uint32_t bytes_consumed) { in Done() argument
299 receiver_->Done(bytes_consumed); in Done()
326 void DataReceiver::PendingReceive::Buffer::Done(uint32_t bytes_consumed) { in Done() argument
327 pending_receive_->Done(bytes_consumed); in Done()
335 uint32_t bytes_consumed, in DoneWithError() argument
[all …]
/external/chromium_org/content/child/npapi/
Dplugin_stream.cc204 int bytes_consumed = instance_->NPP_Write( in TryWriteToPlugin() local
207 if (bytes_consumed < 0) { in TryWriteToPlugin()
212 if (bytes_consumed == 0) { in TryWriteToPlugin()
218 bytes_consumed = std::min(bytes_consumed, bytes_to_write); in TryWriteToPlugin()
220 data_offset_ += bytes_consumed; in TryWriteToPlugin()
221 byte_offset += bytes_consumed; in TryWriteToPlugin()
/external/chromium_org/third_party/libphonenumber/src/phonenumbers/utf/
Dunilib.cc53 int bytes_consumed = charntorune(&rune, p, end - p); in SpanInterchangeValid() local
57 if ((rune == Runeerror && bytes_consumed == 1) || in SpanInterchangeValid()
61 p += bytes_consumed; in SpanInterchangeValid()
/external/chromium_org/third_party/cld/encodings/compact_lang_det/win/
Dcld_utf8utils_windows.cc12 int* bytes_consumed) { in UTF8GenericScan() argument
14 bytes_consumed); in UTF8GenericScan()
Dcld_utf8statetable.cc135 int* bytes_consumed) { in UTF8GenericScan() argument
145 *bytes_consumed = 0; in UTF8GenericScan()
224 *bytes_consumed = src - isrc; in UTF8GenericScan()
Dcld_utf8utils.h18 int* bytes_consumed);
/external/chromium_org/content/browser/
Dbyte_stream.cc69 size_t bytes_consumed);
73 void UpdateWindowInternal(size_t bytes_consumed);
265 size_t bytes_consumed) { in UpdateWindow() argument
269 target->UpdateWindowInternal(bytes_consumed); in UpdateWindow()
272 void ByteStreamWriterImpl::UpdateWindowInternal(size_t bytes_consumed) { in UpdateWindowInternal() argument
277 DCHECK_GE(output_size_used_, bytes_consumed); in UpdateWindowInternal()
278 output_size_used_ -= bytes_consumed; in UpdateWindowInternal()
/external/chromium_org/net/base/registry_controlled_domains/
Dregistry_controlled_domain.cc84 size_t bytes_consumed; in GetNextOffset() local
88 bytes_consumed = 3; in GetNextOffset()
92 bytes_consumed = 2; in GetNextOffset()
96 bytes_consumed = 1; in GetNextOffset()
101 *pos += bytes_consumed; in GetNextOffset()
/external/chromium_org/chrome/browser/devtools/device/
Dandroid_web_socket.cc204 int bytes_consumed; in OnBytesRead() local
207 response_buffer_, false, &bytes_consumed, &output); in OnBytesRead()
210 response_buffer_ = response_buffer_.substr(bytes_consumed); in OnBytesRead()
213 response_buffer_, false, &bytes_consumed, &output); in OnBytesRead()
/external/chromium_org/net/server/
Dweb_socket.cc223 int bytes_consumed = 0; in Read() local
225 WebSocket::DecodeFrameHybi17(frame, true, &bytes_consumed, message); in Read()
227 read_buf->DidConsume(bytes_consumed); in Read()
289 int* bytes_consumed, in DecodeFrameHybi17() argument
372 *bytes_consumed = pos; in DecodeFrameHybi17()
/external/chromium_org/net/tools/flip_server/
Dsm_connection.cc501 size_t bytes_consumed = sm_interface_->ProcessReadInput(bytes, size); in DoConsumeReadData() local
503 << bytes_consumed << " bytes"; in DoConsumeReadData()
504 if (bytes_consumed == 0) { in DoConsumeReadData()
507 read_buffer_.AdvanceReadablePtr(bytes_consumed); in DoConsumeReadData()
/external/protobuf/src/google/protobuf/stubs/
Dstructurally_valid.cc359 int* bytes_consumed) { in UTF8GenericScan() argument
360 *bytes_consumed = 0; in UTF8GenericScan()
462 *bytes_consumed = src - isrc; in UTF8GenericScan()
469 int* bytes_consumed) { in UTF8GenericScanFastAscii() argument
470 *bytes_consumed = 0; in UTF8GenericScanFastAscii()
502 *bytes_consumed = src - isrc; in UTF8GenericScanFastAscii()
528 int bytes_consumed = 0; in IsStructurallyValidUTF8() local
530 buf, len, &bytes_consumed); in IsStructurallyValidUTF8()
531 return (bytes_consumed == len); in IsStructurallyValidUTF8()

12