| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -1907,14 +1907,10 @@ void Http2Session::OnStreamRead(ssize_t nread, const uv_buf_t& buf_) { | |||
| 1907 | 1907 | // call in OnStreamAfterWrite() immediately provides data. If that does | |
| 1908 | 1908 | // happen, we concatenate the data we received with the already-stored | |
| 1909 | 1909 | // pending input data, slicing off the already processed part. | |
| 1910 | - AllocatedBuffer new_buf = env()->AllocateManaged( | ||
| 1911 | - stream_buf_.len - stream_buf_offset_ + nread); | ||
| 1912 | - memcpy(new_buf.data(), | ||
| 1913 | - stream_buf_.base + stream_buf_offset_, | ||
| 1914 | - stream_buf_.len - stream_buf_offset_); | ||
| 1915 | - memcpy(new_buf.data() + stream_buf_.len - stream_buf_offset_, | ||
| 1916 | - buf.data(), | ||
| 1917 | - nread); | ||
| 1910 | + size_t pending_len = stream_buf_.len - stream_buf_offset_; | ||
| 1911 | + AllocatedBuffer new_buf = env()->AllocateManaged(pending_len + nread); | ||
| 1912 | + memcpy(new_buf.data(), stream_buf_.base + stream_buf_offset_, pending_len); | ||
| 1913 | + memcpy(new_buf.data() + pending_len, buf.data(), nread); | ||
| 1918 | 1914 | buf = std::move(new_buf); | |
| 1919 | 1915 | nread = buf.size(); | |
| 1920 | 1916 | stream_buf_offset_ = 0; | |
| Back | FazBrowse Home | New Git URL |
0 commit comments