mirror of https://github.com/pvnis/srsRAN_4G.git
- Import latest srslog version.
- Remove string allocs in some log lines in radio.cc. Add new tracing buffer capcity options into srsenb and srsue. Add missing file.master
faluco
4 years ago
committed by
Ismael Gomez
parent
60cd649b8f
commit
173dcdd421
@ -0,0 +1,90 @@
|
|||||||
|
/**
|
||||||
|
*
|
||||||
|
* \section COPYRIGHT
|
||||||
|
*
|
||||||
|
* Copyright 2013-2020 Software Radio Systems Limited
|
||||||
|
*
|
||||||
|
* By using this file, you agree to the terms and conditions set
|
||||||
|
* forth in the LICENSE file which can be found at the top level of
|
||||||
|
* the distribution.
|
||||||
|
*
|
||||||
|
*/
|
||||||
|
|
||||||
|
#ifndef SRSLOG_SINGLE_WRITE_FILE_SINK_H
|
||||||
|
#define SRSLOG_SINGLE_WRITE_FILE_SINK_H
|
||||||
|
|
||||||
|
#include "file_utils.h"
|
||||||
|
#include "srslte/srslog/sink.h"
|
||||||
|
|
||||||
|
namespace srslog {
|
||||||
|
|
||||||
|
/// This class is a wrapper of a file handle that stores the input data into an
|
||||||
|
/// internal buffer and writes its contents to the file once the buffer is full
|
||||||
|
/// or in object destruction.
|
||||||
|
class single_write_file_sink : public sink
|
||||||
|
{
|
||||||
|
public:
|
||||||
|
single_write_file_sink(std::string filename,
|
||||||
|
std::size_t capacity,
|
||||||
|
std::unique_ptr<log_formatter> f) :
|
||||||
|
sink(std::move(f)), filename(std::move(filename))
|
||||||
|
{
|
||||||
|
buffer.reserve(capacity);
|
||||||
|
}
|
||||||
|
|
||||||
|
~single_write_file_sink() override
|
||||||
|
{
|
||||||
|
if (!is_written) {
|
||||||
|
write_contents();
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
single_write_file_sink(const single_write_file_sink& other) = delete;
|
||||||
|
single_write_file_sink&
|
||||||
|
operator=(const single_write_file_sink& other) = delete;
|
||||||
|
|
||||||
|
detail::error_string write(detail::memory_buffer input_buffer) override
|
||||||
|
{
|
||||||
|
// Nothing to do when the contents have been already written.
|
||||||
|
if (is_written) {
|
||||||
|
return {};
|
||||||
|
}
|
||||||
|
|
||||||
|
if (has_room_for(input_buffer.size())) {
|
||||||
|
buffer.insert(buffer.end(), input_buffer.begin(), input_buffer.end());
|
||||||
|
return {};
|
||||||
|
}
|
||||||
|
|
||||||
|
return write_contents();
|
||||||
|
}
|
||||||
|
|
||||||
|
detail::error_string flush() override { return handler.flush(); }
|
||||||
|
|
||||||
|
private:
|
||||||
|
/// Returns true if the internal buffer has room for the specified input size,
|
||||||
|
/// otherwise returns false.
|
||||||
|
bool has_room_for(std::size_t s) const
|
||||||
|
{
|
||||||
|
return s + buffer.size() < buffer.capacity();
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Writes the buffer contents into the file.
|
||||||
|
detail::error_string write_contents()
|
||||||
|
{
|
||||||
|
is_written = true;
|
||||||
|
if (auto err_str = handler.create(filename)) {
|
||||||
|
return err_str;
|
||||||
|
}
|
||||||
|
return handler.write(detail::memory_buffer(buffer.data(), buffer.size()));
|
||||||
|
}
|
||||||
|
|
||||||
|
private:
|
||||||
|
const std::string filename;
|
||||||
|
file_utils::file handler;
|
||||||
|
std::vector<char> buffer;
|
||||||
|
bool is_written = false;
|
||||||
|
};
|
||||||
|
|
||||||
|
} // namespace srslog
|
||||||
|
|
||||||
|
#endif // SRSLOG_SINGLE_WRITE_FILE_SINK_H
|
||||||
Loading…
Reference in New Issue