mirror of
https://github.com/nodejs/node.git
synced 2026-10-14 10:26:26 -04:00
http2: small clean up in OnStreamRead
PR-URL: https://github.com/nodejs/node/pull/30351 Reviewed-By: Anna Henningsen <anna@addaleax.net> Reviewed-By: David Carlier <devnexen@gmail.com> Reviewed-By: James M Snell <jasnell@gmail.com>
This commit is contained in:
1 parent
bfd9de63c9
commit
53fb7be5ea
1 file changed
+4
-8
+4
-8
@@ -1867,14 +1867,10 @@ void Http2Session::OnStreamRead(ssize_t nread, const uv_buf_t& buf_) {
|
||||
// call in OnStreamAfterWrite() immediately provides data. If that does
|
||||
// happen, we concatenate the data we received with the already-stored
|
||||
// pending input data, slicing off the already processed part.
|
||||
AllocatedBuffer new_buf = env()->AllocateManaged(
|
||||
stream_buf_.len - stream_buf_offset_ + nread);
|
||||
memcpy(new_buf.data(),
|
||||
stream_buf_.base + stream_buf_offset_,
|
||||
stream_buf_.len - stream_buf_offset_);
|
||||
memcpy(new_buf.data() + stream_buf_.len - stream_buf_offset_,
|
||||
buf.data(),
|
||||
nread);
|
||||
size_t pending_len = stream_buf_.len - stream_buf_offset_;
|
||||
AllocatedBuffer new_buf = env()->AllocateManaged(pending_len + nread);
|
||||
memcpy(new_buf.data(), stream_buf_.base + stream_buf_offset_, pending_len);
|
||||
memcpy(new_buf.data() + pending_len, buf.data(), nread);
|
||||
buf = std::move(new_buf);
|
||||
nread = buf.size();
|
||||
stream_buf_offset_ = 0;
|
||||
|
||||
Reference in new issue
Block a user