MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2025-01-02 19:04:17 +01:00
Code Issues Releases Wiki Activity

ircd::buffer: Functions for a non-const iov to keep xfer state using the iov.

Browse source
This commit is contained in:
Jason Volk 2017-03-13 12:00:12 -07:00
parent 2147832658
commit f2ac156e6a
1 changed files with 31 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

31
include/ircd/buffer.h
View file

@ -29,6 +29,8 @@ template<class it>
struct buffer
:std::tuple<it, it>
{
using value_type = it;
operator string_view() const;
operator std::string_view() const;
explicit operator std::string() const;
@ -95,6 +97,9 @@ template<class it> size_t size(const buffer<it> &buffer);
template<class T> size_t size(const buffers<T> &buffers);
template<class it> it data(const buffer<it> &buffer);
template<class it> size_t consume(buffer<it> &buffer, const size_t &bytes);
template<class T> size_t consume(buffers<T> &buffers, const size_t &bytes);
} // namespace buffer
using buffer::const_buffer;
@ -107,6 +112,32 @@ using buffer::null_buffers;
} // namespace ircd
template<class T>
size_t
ircd::buffer::consume(buffers<T> &buffers,
const size_t &bytes)
{
size_t remain(bytes);
for(auto it(begin(buffers)); it != end(buffers) && remain > 0; ++it)
{
using buffer = typename buffers<T>::value_type;
using iterator = typename buffer::value_type;
buffer &b(const_cast<buffer &>(*it));
remain -= consume(b, remain);
}
return bytes - remain;
}
template<class it>
size_t
ircd::buffer::consume(buffer<it> &buffer,
const size_t &bytes)
{
get<0>(buffer) += std::min(size(buffer), bytes);
return bytes - size(buffer);
}
template<class it>
it