rosbag_fancy::BagWriter Class Reference

#include <bag_writer.h>

Public Types
enum	Naming { Naming::Verbatim, Naming::AppendTimestamp }

Public Member Functions
std::string	bagfileName () const
	BagWriter (MessageQueue &queue, const std::string &filename, Naming namingMode, std::uint64_t splitSizeInBytes, std::uint64_t deleteOldAtInBytes)
const std::vector< std::uint64_t > &	byteCounts () const
rosbag::compression::CompressionType	compression () const
std::uint64_t	deleteOldAtInBytes () const
std::uint64_t	directorySizeInBytes () const
std::uint64_t	freeSpace () const
const std::vector< std::uint64_t > &	messageCounts () const
bool	running () const
void	setCompression (rosbag::compression::CompressionType type)
std::uint64_t	sizeInBytes () const
std::uint64_t	splitSizeInBytes () const
void	start ()
void	stop ()
	~BagWriter ()

Private Member Functions
void	checkFreeSpace ()
void	cleanupThread ()
void	run ()

Private Attributes
rosbag::Bag	m_bag
bool	m_bagOpen {false}
std::vector< std::uint64_t >	m_byteCounts
std::thread	m_cleanup_thread
std::condition_variable	m_cleanupCondition
std::mutex	m_cleanupMutex
rosbag::compression::CompressionType	m_compressionType = rosbag::compression::Uncompressed
std::uint64_t	m_deleteOldAtInBytes = 0
std::atomic< std::uint64_t >	m_directorySizeInBytes {0}
std::string	m_expandedFilename
std::string	m_filename
std::uint64_t	m_freeSpace = 0
ros::SteadyTimer	m_freeSpaceTimer
bool	m_isReopeningBag {false}
std::vector< std::uint64_t >	m_messageCounts
std::mutex	m_mutex
Naming	m_namingMode
MessageQueue &	m_queue
std::atomic< bool >	m_running {false}
bool	m_shouldShutdown {false}
std::atomic< std::uint64_t >	m_sizeInBytes {0}
std::uint64_t	m_splitSizeInBytes = 0
tf2_ros::Buffer	m_tf_buf
boost::shared_ptr< std::map< std::string, std::string > >	m_tf_header
std::thread	m_thread

Detailed Description

Definition at line 23 of file bag_writer.h.

Member Enumeration Documentation

Naming

enum rosbag_fancy::BagWriter::Naming

strong

Enumerator
Verbatim
AppendTimestamp

Definition at line 26 of file bag_writer.h.

Constructor & Destructor Documentation

BagWriter()

rosbag_fancy::BagWriter::BagWriter ( rosbag_fancy::MessageQueue &  queue, const std::string &  filename, Naming  namingMode, std::uint64_t  splitSizeInBytes, std::uint64_t  deleteOldAtInBytes  )

explicit

Definition at line 87 of file bag_writer.cpp.

~BagWriter()

rosbag_fancy::BagWriter::~BagWriter

(

)

Definition at line 117 of file bag_writer.cpp.

Member Function Documentation

bagfileName()

std::string rosbag_fancy::BagWriter::bagfileName ( ) const

inline

Definition at line 58 of file bag_writer.h.

byteCounts()

const std::vector<std::uint64_t>& rosbag_fancy::BagWriter::byteCounts ( ) const

inline

Definition at line 64 of file bag_writer.h.

checkFreeSpace()

void rosbag_fancy::BagWriter::checkFreeSpace ( )

private

Definition at line 268 of file bag_writer.cpp.

cleanupThread()

void rosbag_fancy::BagWriter::cleanupThread ( )

private

Definition at line 278 of file bag_writer.cpp.

compression()

rosbag::compression::CompressionType rosbag_fancy::BagWriter::compression ( ) const

inline

Definition at line 67 of file bag_writer.h.

deleteOldAtInBytes()

std::uint64_t rosbag_fancy::BagWriter::deleteOldAtInBytes ( ) const

inline

Definition at line 52 of file bag_writer.h.

directorySizeInBytes()

std::uint64_t rosbag_fancy::BagWriter::directorySizeInBytes ( ) const

inline

Definition at line 49 of file bag_writer.h.

freeSpace()

std::uint64_t rosbag_fancy::BagWriter::freeSpace ( ) const

inline

Definition at line 55 of file bag_writer.h.

messageCounts()

const std::vector<std::uint64_t>& rosbag_fancy::BagWriter::messageCounts ( ) const

inline

Definition at line 61 of file bag_writer.h.

run()

void rosbag_fancy::BagWriter::run ( )

private

Definition at line 130 of file bag_writer.cpp.

running()

bool rosbag_fancy::BagWriter::running ( ) const

inline

Definition at line 40 of file bag_writer.h.

setCompression()

void rosbag_fancy::BagWriter::setCompression

(

rosbag::compression::CompressionType

type

)

Definition at line 336 of file bag_writer.cpp.

sizeInBytes()

std::uint64_t rosbag_fancy::BagWriter::sizeInBytes ( ) const

inline

Definition at line 43 of file bag_writer.h.

splitSizeInBytes()

std::uint64_t rosbag_fancy::BagWriter::splitSizeInBytes ( ) const

inline

Definition at line 46 of file bag_writer.h.

start()

void rosbag_fancy::BagWriter::start

(

)

Definition at line 175 of file bag_writer.cpp.

stop()

void rosbag_fancy::BagWriter::stop

(

)

Definition at line 249 of file bag_writer.cpp.

Member Data Documentation

m_bag

rosbag::Bag rosbag_fancy::BagWriter::m_bag

private

Definition at line 89 of file bag_writer.h.

m_bagOpen

bool rosbag_fancy::BagWriter::m_bagOpen {false}

private

Definition at line 90 of file bag_writer.h.

m_byteCounts

std::vector<std::uint64_t> rosbag_fancy::BagWriter::m_byteCounts

private

Definition at line 112 of file bag_writer.h.

m_cleanup_thread

std::thread rosbag_fancy::BagWriter::m_cleanup_thread

private

Definition at line 93 of file bag_writer.h.

m_cleanupCondition

std::condition_variable rosbag_fancy::BagWriter::m_cleanupCondition

private

Definition at line 106 of file bag_writer.h.

m_cleanupMutex

std::mutex rosbag_fancy::BagWriter::m_cleanupMutex

private

Definition at line 105 of file bag_writer.h.

m_compressionType

rosbag::compression::CompressionType rosbag_fancy::BagWriter::m_compressionType = rosbag::compression::Uncompressed

private

Definition at line 114 of file bag_writer.h.

m_deleteOldAtInBytes

std::uint64_t rosbag_fancy::BagWriter::m_deleteOldAtInBytes = 0

private

Definition at line 86 of file bag_writer.h.

m_directorySizeInBytes

std::atomic<std::uint64_t> rosbag_fancy::BagWriter::m_directorySizeInBytes {0}

private

Definition at line 87 of file bag_writer.h.

m_expandedFilename

std::string rosbag_fancy::BagWriter::m_expandedFilename

private

Definition at line 82 of file bag_writer.h.

m_filename

std::string rosbag_fancy::BagWriter::m_filename

private

Definition at line 79 of file bag_writer.h.

m_freeSpace

std::uint64_t rosbag_fancy::BagWriter::m_freeSpace = 0

private

Definition at line 98 of file bag_writer.h.

m_freeSpaceTimer

ros::SteadyTimer rosbag_fancy::BagWriter::m_freeSpaceTimer

private

Definition at line 100 of file bag_writer.h.

m_isReopeningBag

bool rosbag_fancy::BagWriter::m_isReopeningBag {false}

private

Definition at line 84 of file bag_writer.h.

m_messageCounts

std::vector<std::uint64_t> rosbag_fancy::BagWriter::m_messageCounts

private

Definition at line 111 of file bag_writer.h.

m_mutex

std::mutex rosbag_fancy::BagWriter::m_mutex

private

Definition at line 103 of file bag_writer.h.

m_namingMode

Naming rosbag_fancy::BagWriter::m_namingMode

private

Definition at line 80 of file bag_writer.h.

m_queue

MessageQueue& rosbag_fancy::BagWriter::m_queue

private

Definition at line 77 of file bag_writer.h.

m_running

std::atomic<bool> rosbag_fancy::BagWriter::m_running {false}

private

Definition at line 102 of file bag_writer.h.

m_shouldShutdown

bool rosbag_fancy::BagWriter::m_shouldShutdown {false}

private

Definition at line 95 of file bag_writer.h.

m_sizeInBytes

std::atomic<std::uint64_t> rosbag_fancy::BagWriter::m_sizeInBytes {0}

private

Definition at line 97 of file bag_writer.h.

m_splitSizeInBytes

std::uint64_t rosbag_fancy::BagWriter::m_splitSizeInBytes = 0

private

Definition at line 85 of file bag_writer.h.

m_tf_buf

tf2_ros::Buffer rosbag_fancy::BagWriter::m_tf_buf

private

Definition at line 108 of file bag_writer.h.

m_tf_header

boost::shared_ptr<std::map<std::string, std::string> > rosbag_fancy::BagWriter::m_tf_header

private

Definition at line 109 of file bag_writer.h.

m_thread

std::thread rosbag_fancy::BagWriter::m_thread

private

Definition at line 92 of file bag_writer.h.

---

The documentation for this class was generated from the following files:

• bag_writer.h
• bag_writer.cpp