stack_buf improvement after code revie
This commit is contained in:
		@@ -14,9 +14,9 @@ using namespace std::chrono;
 | 
				
			|||||||
using namespace c11log;
 | 
					using namespace c11log;
 | 
				
			||||||
using namespace utils;
 | 
					using namespace utils;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
					 | 
				
			||||||
int main(int argc, char* argv[])
 | 
					int main(int argc, char* argv[])
 | 
				
			||||||
{
 | 
					{
 | 
				
			||||||
 | 
						details::stack_buf<12> a;	
 | 
				
			||||||
	
 | 
						
 | 
				
			||||||
    const unsigned int howmany = argc <= 1 ? 1000000:atoi(argv[1]);
 | 
					    const unsigned int howmany = argc <= 1 ? 1000000:atoi(argv[1]);
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@@ -33,7 +33,7 @@ int main(int argc, char* argv[])
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
    auto start = system_clock::now();
 | 
					    auto start = system_clock::now();
 | 
				
			||||||
    for (unsigned int i = 1; i <= howmany; ++i)
 | 
					    for (unsigned int i = 1; i <= howmany; ++i)
 | 
				
			||||||
        my_logger.info("Hello logger: msg #") << i;
 | 
					        my_logger.info() << "Hello logger: msg #" << i;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    //as->shutdown(std::chrono::milliseconds(15000));
 | 
					    //as->shutdown(std::chrono::milliseconds(15000));
 | 
				
			||||||
    auto delta = system_clock::now() - start;
 | 
					    auto delta = system_clock::now() - start;
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -14,6 +14,7 @@ class stack_devicebuf :public std::streambuf
 | 
				
			|||||||
{
 | 
					{
 | 
				
			||||||
public:
 | 
					public:
 | 
				
			||||||
    using Base = std::streambuf;
 | 
					    using Base = std::streambuf;
 | 
				
			||||||
 | 
						using stackbuf = stack_buf<192>;
 | 
				
			||||||
    stack_devicebuf() = default;
 | 
					    stack_devicebuf() = default;
 | 
				
			||||||
    ~stack_devicebuf() = default;
 | 
					    ~stack_devicebuf() = default;
 | 
				
			||||||
    stack_devicebuf& operator=(const stack_devicebuf&) = delete;
 | 
					    stack_devicebuf& operator=(const stack_devicebuf&) = delete;
 | 
				
			||||||
@@ -28,7 +29,7 @@ public:
 | 
				
			|||||||
        other.clear();
 | 
					        other.clear();
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    bufpair_t buf() const
 | 
					    stackbuf::bufpair_t buf() const
 | 
				
			||||||
    {
 | 
					    {
 | 
				
			||||||
        return _stackbuf.get();
 | 
					        return _stackbuf.get();
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
@@ -61,7 +62,7 @@ protected:
 | 
				
			|||||||
        return ch;
 | 
					        return ch;
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
private:
 | 
					private:
 | 
				
			||||||
    stack_buf<128> _stackbuf;
 | 
					    stackbuf _stackbuf;
 | 
				
			||||||
};
 | 
					};
 | 
				
			||||||
 | 
					
 | 
				
			||||||
class fast_oss :public std::ostream
 | 
					class fast_oss :public std::ostream
 | 
				
			||||||
 
 | 
				
			|||||||
@@ -3,7 +3,6 @@
 | 
				
			|||||||
#include <array>
 | 
					#include <array>
 | 
				
			||||||
#include <vector>
 | 
					#include <vector>
 | 
				
			||||||
#include <algorithm>
 | 
					#include <algorithm>
 | 
				
			||||||
#include <cstring>
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
// Fast memory storage on the stack when possible or in std::vector
 | 
					// Fast memory storage on the stack when possible or in std::vector
 | 
				
			||||||
namespace c11log
 | 
					namespace c11log
 | 
				
			||||||
@@ -11,40 +10,32 @@ namespace c11log
 | 
				
			|||||||
namespace details
 | 
					namespace details
 | 
				
			||||||
{
 | 
					{
 | 
				
			||||||
 | 
					
 | 
				
			||||||
using bufpair_t = std::pair<const char*, std::size_t>;
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
template<std::size_t STACK_SIZE = 128>
 | 
					
 | 
				
			||||||
 | 
					template<unsigned short STACK_SIZE = 128>
 | 
				
			||||||
class stack_buf
 | 
					class stack_buf
 | 
				
			||||||
{
 | 
					{
 | 
				
			||||||
public:
 | 
					public:
 | 
				
			||||||
    stack_buf() :_v(), _stack_array(), _stack_size(0) {}
 | 
						using bufpair_t = std::pair<const char*, std::size_t>;
 | 
				
			||||||
    ~stack_buf() {};
 | 
						using iterator = char const*;
 | 
				
			||||||
 | 
						static constexpr unsigned short stack_size = STACK_SIZE;
 | 
				
			||||||
 | 
					    stack_buf() :_v(), _stack_size(0) {}
 | 
				
			||||||
 | 
					    ~stack_buf() = default;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    stack_buf& operator=(const stack_buf& other) = delete;
 | 
					    stack_buf& operator=(const stack_buf& other) = delete;
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    stack_buf(const stack_buf& other)
 | 
					    stack_buf(const stack_buf& other):stack_buf(other, false)
 | 
				
			||||||
    {
 | 
					    {}
 | 
				
			||||||
        _stack_size = other._stack_size;
 | 
					 | 
				
			||||||
        if (!other._v.empty())
 | 
					 | 
				
			||||||
            _v = other._v;
 | 
					 | 
				
			||||||
        else if (_stack_size)
 | 
					 | 
				
			||||||
            std::copy(other._stack_array.begin(), other._stack_array.begin() + _stack_size, _stack_array.begin());
 | 
					 | 
				
			||||||
    }
 | 
					 | 
				
			||||||
 | 
					
 | 
				
			||||||
    stack_buf(stack_buf&& other)
 | 
					    stack_buf(stack_buf&& other):stack_buf(other, true)
 | 
				
			||||||
    {        
 | 
					    {        
 | 
				
			||||||
        _stack_size = other._stack_size;
 | 
					 | 
				
			||||||
        if (!other._v.empty())
 | 
					 | 
				
			||||||
            _v = std::move(other._v);
 | 
					 | 
				
			||||||
        else if (_stack_size)
 | 
					 | 
				
			||||||
            std::copy(other._stack_array.begin(), other._stack_array.begin() + _stack_size, _stack_array.begin());
 | 
					 | 
				
			||||||
        other.clear();
 | 
					        other.clear();
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    void append(const char* buf, std::size_t buf_size)
 | 
					    void append(const char* buf, std::size_t buf_size)
 | 
				
			||||||
    {
 | 
					    {
 | 
				
			||||||
        //If we are aleady using _v, forget about the stack
 | 
					        //If we are aleady using _v, forget about the stack
 | 
				
			||||||
        if (!_v.empty())
 | 
					        if (vector_used())
 | 
				
			||||||
        {
 | 
					        {
 | 
				
			||||||
            _v.insert(_v.end(), buf, buf + buf_size);
 | 
					            _v.insert(_v.end(), buf, buf + buf_size);
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
@@ -60,17 +51,12 @@ public:
 | 
				
			|||||||
            else
 | 
					            else
 | 
				
			||||||
            {
 | 
					            {
 | 
				
			||||||
                _v.reserve(_stack_size + buf_size);                
 | 
					                _v.reserve(_stack_size + buf_size);                
 | 
				
			||||||
                if (_stack_size)
 | 
					 | 
				
			||||||
				_v.insert(_v.end(), _stack_array.begin(), _stack_array.begin() + _stack_size);
 | 
									_v.insert(_v.end(), _stack_array.begin(), _stack_array.begin() + _stack_size);
 | 
				
			||||||
                _v.insert(_v.end(), buf, buf + buf_size);
 | 
					                _v.insert(_v.end(), buf, buf + buf_size);
 | 
				
			||||||
            }
 | 
					            }
 | 
				
			||||||
        }
 | 
					        }
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    void append(const bufpair_t &buf)
 | 
					 | 
				
			||||||
    {
 | 
					 | 
				
			||||||
        append(buf.first, buf.second);
 | 
					 | 
				
			||||||
    }
 | 
					 | 
				
			||||||
	
 | 
						
 | 
				
			||||||
    void clear()
 | 
					    void clear()
 | 
				
			||||||
    {
 | 
					    {
 | 
				
			||||||
@@ -80,21 +66,47 @@ public:
 | 
				
			|||||||
 | 
					
 | 
				
			||||||
    bufpair_t get() const
 | 
					    bufpair_t get() const
 | 
				
			||||||
    {
 | 
					    {
 | 
				
			||||||
        if (!_v.empty())
 | 
					        if (vector_used())
 | 
				
			||||||
            return bufpair_t(_v.data(), _v.size());
 | 
					            return bufpair_t(_v.data(), _v.size());
 | 
				
			||||||
        else
 | 
					        else
 | 
				
			||||||
            return bufpair_t(_stack_array.data(), _stack_size);
 | 
					            return bufpair_t(_stack_array.data(), _stack_size);
 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						iterator begin() const
 | 
				
			||||||
 | 
						{
 | 
				
			||||||
 | 
							return get().first;
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						iterator end() const
 | 
				
			||||||
 | 
						{
 | 
				
			||||||
 | 
							bufpair_t bpair = get();
 | 
				
			||||||
 | 
							return bpair.first + bpair.second;
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    std::size_t size() const
 | 
					    std::size_t size() const
 | 
				
			||||||
    {
 | 
					    {
 | 
				
			||||||
        if (!_v.empty())
 | 
					       return get().second;
 | 
				
			||||||
            return _v.size();
 | 
					 | 
				
			||||||
        else
 | 
					 | 
				
			||||||
            return _stack_size;
 | 
					 | 
				
			||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
private:
 | 
					private:
 | 
				
			||||||
 | 
						template<class T1>
 | 
				
			||||||
 | 
						stack_buf(T1&& other, bool is_rval)
 | 
				
			||||||
 | 
						{
 | 
				
			||||||
 | 
							_stack_size = other._stack_size;
 | 
				
			||||||
 | 
					        if (other.vector_used())
 | 
				
			||||||
 | 
							{
 | 
				
			||||||
 | 
								_v = is_rval? std::move(other._v) : other._v;
 | 
				
			||||||
 | 
					            //_v = std::forward<T1>(other)._v;
 | 
				
			||||||
 | 
							}	
 | 
				
			||||||
 | 
					        else
 | 
				
			||||||
 | 
					            std::copy_n(other._stack_array.begin(), other._stack_size, _stack_array.begin());        
 | 
				
			||||||
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
						bool vector_used() const
 | 
				
			||||||
 | 
						{
 | 
				
			||||||
 | 
							return !(_v.empty());
 | 
				
			||||||
 | 
						}
 | 
				
			||||||
 | 
						
 | 
				
			||||||
    std::vector<char> _v;
 | 
					    std::vector<char> _v;
 | 
				
			||||||
    std::array<char, STACK_SIZE> _stack_array;
 | 
					    std::array<char, STACK_SIZE> _stack_array;
 | 
				
			||||||
    std::size_t _stack_size;
 | 
					    std::size_t _stack_size;
 | 
				
			||||||
 
 | 
				
			|||||||
		Reference in New Issue
	
	Block a user