| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -1867,14 +1867,10 @@ void Http2Session::OnStreamRead(ssize_t nread, const uv_buf_t& buf_) { | |||
| 1867 | 1867 | // call in OnStreamAfterWrite() immediately provides data. If that does | |
| 1868 | 1868 | // happen, we concatenate the data we received with the already-stored | |
| 1869 | 1869 | // pending input data, slicing off the already processed part. | |
| 1870 | - AllocatedBuffer new_buf = env()->AllocateManaged( | ||
| 1871 | - stream_buf_.len - stream_buf_offset_ + nread); | ||
| 1872 | - memcpy(new_buf.data(), | ||
| 1873 | - stream_buf_.base + stream_buf_offset_, | ||
| 1874 | - stream_buf_.len - stream_buf_offset_); | ||
| 1875 | - memcpy(new_buf.data() + stream_buf_.len - stream_buf_offset_, | ||
| 1876 | - buf.data(), | ||
| 1877 | - nread); | ||
| 1870 | + size_t pending_len = stream_buf_.len - stream_buf_offset_; | ||
| 1871 | + AllocatedBuffer new_buf = env()->AllocateManaged(pending_len + nread); | ||
| 1872 | + memcpy(new_buf.data(), stream_buf_.base + stream_buf_offset_, pending_len); | ||
| 1873 | + memcpy(new_buf.data() + pending_len, buf.data(), nread); | ||
| 1878 | 1874 | buf = std::move(new_buf); | |
| 1879 | 1875 | nread = buf.size(); | |
| 1880 | 1876 | stream_buf_offset_ = 0; | |
| Back | FazBrowse Home | New Git URL |
0 commit comments