Lines Matching defs:buf
454 void Http2Session::StopTrackingRcbuf(nghttp2_rcbuf* buf) {
455 StopTrackingMemory(buf);
1197 uv_buf_t buf = stream->EmitAlloc(len);
1199 if (static_cast<ssize_t>(buf.len) < avail)
1200 avail = buf.len;
1202 // `buf.base == nullptr` is the default Http2StreamListener's way
1207 if (LIKELY(buf.base == nullptr))
1208 buf.base = reinterpret_cast<char*>(const_cast<uint8_t*>(data));
1210 memcpy(buf.base, data, avail);
1213 stream->EmitRead(avail, buf);
1294 void Http2StreamListener::OnStreamRead(ssize_t nread, const uv_buf_t& buf) {
1318 size_t offset = buf.base - session->stream_buf_.base;
1323 CHECK_LE(offset + buf.len, session->stream_buf_.len);
1706 outgoing_length_ += write.buf.len;
1786 statistics_.data_sent += write.buf.len;
1787 if (write.buf.base == nullptr) {
1790 write.buf.len);
1791 offset += write.buf.len;
1793 bufs[i++] = write.buf;
1843 if (write.buf.len <= length) {
1845 length -= write.buf.len;
1853 uv_buf_init(write.buf.base, length)
1855 write.buf.base += length;
1856 write.buf.len -= length;
1946 // remaining part into buf, which will be accounted for below).
2001 uv_buf_t buf = session->OnStreamAlloc(len);
2002 size_t copy = buf.len > len ? len : buf.len;
2003 memcpy(buf.base, data, copy);
2004 buf.len = copy;
2005 session->OnStreamRead(copy, buf);
2476 uint8_t* buf,
2495 while (!stream->queue_.empty() && stream->queue_.front().buf.len == 0) {
2521 return OnRead(handle, id, buf, length, flags, source, user_data);
3124 Local<Value> buf = Undefined(isolate);
3126 buf = Buffer::Copy(isolate,
3132 Boolean::New(isolate, ack), Number::New(isolate, duration_ms), buf};
3143 tracker->TrackField("buf", buf);