DataDurabilityCache.cpp File Reference

#include "DCPS/DdsDcps_pch.h"
#include "DataDurabilityCache.h"
#include "Service_Participant.h"
#include "DataSampleList.h"
#include "WriteDataContainer.h"
#include "DataWriterImpl.h"
#include "Qos_Helper.h"
#include "debug.h"
#include "tao/ORB_Core.h"
#include "ace/Reactor.h"
#include "ace/Message_Block.h"
#include "ace/Log_Msg.h"
#include "ace/Malloc_T.h"
#include "ace/MMAP_Memory_Pool.h"
#include "ace/OS_NS_sys_time.h"
#include <string>
#include <sstream>
#include <fstream>
#include <algorithm>

Include dependency graph for DataDurabilityCache.cpp:

Defines
#define	OPENDDS_MAP_TYPE   ACE_Hash_Map_With_Allocator<key_type, sample_list_type *>
Typedefs
typedef OpenDDS::DCPS::DataDurabilityCache::sample_data_type	data_type
typedef OpenDDS::DCPS::DataDurabilityCache::sample_list_type	list_type
typedef ptrdiff_t	list_difference_type
Functions
void	cleanup_directory (const std::vector< std::string > &path, const ACE_CString &data_dir)
Variables
list_type &	sample_list_
list_difference_type const	index_
	Location in list/array of queue to be deallocated.
ACE_Allocator *const	allocator_
	Allocator to be used when deallocating data queue.
long	tid_
	Timer ID corresponding to this cleanup event handler.
OpenDDS::DCPS::DataDurabilityCache::timer_id_list_type *	timer_ids_
	List of timer IDs.
std::vector< std::string >	path_
ACE_CString	data_dir_

---

Define Documentation

#define OPENDDS_MAP_TYPE   ACE_Hash_Map_With_Allocator<key_type, sample_list_type *>

---

Typedef Documentation

typedef OpenDDS::DCPS::DataDurabilityCache::sample_data_type data_type

typedef ptrdiff_t list_difference_type

typedef OpenDDS::DCPS::DataDurabilityCache::sample_list_type list_type

---

Function Documentation

void @1::cleanup_directory	(	const std::vector< std::string > &	path,
		const ACE_CString &	data_dir
	)			[static]

---

Variable Documentation

ACE_Allocator* const allocator_

Allocator to be used when deallocating data queue.

ACE_CString data_dir_

list_difference_type const index_

Location in list/array of queue to be deallocated.

std::vector<std::string> path_

list_type& sample_list_

List containing samples to be cleaned up when the cleanup timer expires.

long tid_

Timer ID corresponding to this cleanup event handler.

OpenDDS::DCPS::DataDurabilityCache::timer_id_list_type* timer_ids_

List of timer IDs.

If the cleanup timer fires successfully, the timer ID must be removed from the timer ID list so that a subsequent attempt to cancel the timer during durability cache destruction does not occur.

---