libreoffice-online/net/Buffer.hpp
Ashod Nakashian dc5ca2738e wsd: http: simplify appending to Buffer
Instead of supporting char appending,
we now support appending literal strings
with size capturing. This covers both
single- and multi-character appending
without the need for an explicit size.

Change-Id: Iee2c20b7aa2cdb6863c88e91cd770205719c2ba6
Signed-off-by: Ashod Nakashian <ashod.nakashian@collabora.co.uk>
(cherry picked from commit 96e3e88a014960a5249fc83a5b2f3b785ac8737d)
2021-05-02 22:35:39 -04:00

98 lines
2.6 KiB
C++

/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4; fill-column: 100 -*- */
/*
* This Source Code Form is subject to the terms of the Mozilla Public
* License, v. 2.0. If a copy of the MPL was not distributed with this
* file, You can obtain one at http://mozilla.org/MPL/2.0/.
*/
#pragma once
#include <assert.h>
#include <ostream>
#include <vector>
#include <Util.hpp>
// Blocks -> we can share from client -> server ... etc.
// headers / and a 'writeV' etc. =)
/**
* Encapsulate data we need to write.
*/
class Buffer
{
std::size_t _size;
std::size_t _offset;
std::vector<char> _buffer;
public:
Buffer() : _size(0), _offset(0)
{
}
std::size_t size() const { return _size; }
bool empty() const { return _size == 0; }
const char *getBlock() const
{
if (_size)
return &_buffer[_offset];
return nullptr;
}
std::size_t getBlockSize() const
{
return _size;
}
void eraseFirst(std::size_t len)
{
if (len <= 0)
return;
assert(_offset + len <= _buffer.size());
assert(_offset + _size == _buffer.size());
len = std::min(len, _size); // Avoid accidental damage.
// avoid regular shuffling down larger chunks of data
if (_buffer.size() > 16384 && // lots of queued data
len < _buffer.size() && // not a complete erase
_offset < 16384 * 64 && // do cleanup a Mb at a time or so:
_size > 512) // early cleanup if what remains is small.
{
_offset += len;
_size -= len;
return;
}
_buffer.erase(_buffer.begin(), _buffer.begin() + _offset + len);
_offset = 0;
_size = _buffer.size();
}
void append(const char *data, const int len)
{
_buffer.insert(_buffer.end(), data, data + len);
_size = _buffer.size() - _offset;
}
void append(const std::string& s) { append(s.c_str(), s.size()); }
/// Append a literal string, with compile-time size capturing.
template <std::size_t N> void append(const char (&s)[N])
{
static_assert(N > 1, "Cannot append empty strings.");
append(s, N - 1); // Minus null termination.
}
void dumpHex(std::ostream &os, const char *legend, const char *prefix) const
{
if (_size > 0 || _offset > 0)
os << prefix << "Buffer size: " << _size << " offset: " << _offset << '\n';
if (_buffer.size() > 0)
Util::dumpHex(os, _buffer, legend, prefix);
}
};
/* vim:set shiftwidth=4 softtabstop=4 expandtab: */