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 <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
Variables
char const	dds_backing_store [] = "OpenDDS-durable-data"
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.

---

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

---

Variable Documentation

ACE_Allocator* const allocator_

Allocator to be used when deallocating data queue.

char const dds_backing_store[] = "OpenDDS-durable-data" [static]

Todo:

Make the backing store name configurable.

list_difference_type const index_

Location in list/array of queue to be deallocated.

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.

---