Base class for PartialProducer and FullProducer. More...

#include <producer-base.hpp>

Inheritance diagram for psync::ProducerBase:

Collaboration diagram for psync::ProducerBase:

Public Member Functions
bool	addUserNode (const ndn::Name &prefix)
	Adds a user node for synchronization. More...

ndn::optional< uint64_t >	getSeqNo (const ndn::Name &prefix) const
	Returns the current sequence number of the given prefix. More...

void	removeUserNode (const ndn::Name &prefix)
	Remove the user node from synchronization. More...

Protected Member Functions
	ProducerBase (size_t expectedNumEntries, ndn::Face &face, const ndn::Name &syncPrefix, const ndn::Name &userPrefix, ndn::time::milliseconds syncReplyFreshness=SYNC_REPLY_FRESHNESS, ndn::time::milliseconds helloReplyFreshness=HELLO_REPLY_FRESHNESS)
	constructor More...

bool	isUserNode (const ndn::Name &prefix)

void	onRegisterFailed (const ndn::Name &prefix, const std::string &msg) const
	Logs a message if setting an interest filter fails. More...

void	sendApplicationNack (const ndn::Name &name)
	Sends a data packet with content type nack. More...

void	updateSeqNo (const ndn::Name &prefix, uint64_t seq)
	Update m_prefixes and IBF with the given prefix and seq. More...

Protected Attributes
uint32_t	m_expectedNumEntries

ndn::Face &	m_face

std::map< uint32_t, ndn::Name >	m_hash2prefix

ndn::time::milliseconds	m_helloReplyFreshness

IBLT	m_iblt

ndn::KeyChain	m_keyChain

std::map< ndn::Name, uint32_t >	m_prefix2hash

std::map< ndn::Name, uint64_t >	m_prefixes

ndn::random::RandomNumberEngine &	m_rng

ndn::Scheduler	m_scheduler

SegmentPublisher	m_segmentPublisher

ndn::Name	m_syncPrefix

ndn::time::milliseconds	m_syncReplyFreshness

uint32_t	m_threshold

ndn::Name	m_userPrefix

Detailed Description

Base class for PartialProducer and FullProducer.

Contains code common to both

Definition at line 51 of file producer-base.hpp.

Constructor & Destructor Documentation

psync::ProducerBase::ProducerBase	(	size_t	expectedNumEntries,
		ndn::Face &	face,
		const ndn::Name &	syncPrefix,
		const ndn::Name &	userPrefix,
		ndn::time::milliseconds	syncReplyFreshness = `SYNC_REPLY_FRESHNESS`,
		ndn::time::milliseconds	helloReplyFreshness = `HELLO_REPLY_FRESHNESS`
	)

protected

constructor

Parameters

expectedNumEntries	expected number entries in IBF
face	application's face
syncPrefix	The prefix of the sync group
userPrefix	The prefix of the first user in the group
syncReplyFreshness	freshness of sync data
helloReplyFreshness	freshness of hello data

Definition at line 33 of file producer-base.cpp.

Member Function Documentation

bool psync::ProducerBase::addUserNode ( const ndn::Name & prefix )

Adds a user node for synchronization.

Initializes m_prefixes[prefix] to zero Does not add zero-th sequence number to IBF because if a large number of user nodes are added then decoding of the difference between own IBF and other IBF will not be possible

Parameters

prefix the user node to be added

Definition at line 55 of file producer-base.cpp.

ndn::optional<uint64_t> psync::ProducerBase::getSeqNo ( const ndn::Name & prefix ) const

inline

Returns the current sequence number of the given prefix.

Parameters

prefix prefix to get the sequence number of

Definition at line 83 of file producer-base.hpp.

bool psync::ProducerBase::isUserNode ( const ndn::Name & prefix )

inlineprotected

Definition at line 132 of file producer-base.hpp.

void psync::ProducerBase::onRegisterFailed	(	const ndn::Name &	prefix,
		const std::string &	msg
	)		const

protected

Logs a message if setting an interest filter fails.

Parameters

prefix
msg

Definition at line 144 of file producer-base.cpp.

void psync::ProducerBase::removeUserNode ( const ndn::Name & prefix )

Remove the user node from synchronization.

Erases prefix from IBF and other maps

Parameters

prefix the user node to be removed

Definition at line 67 of file producer-base.cpp.

void psync::ProducerBase::sendApplicationNack ( const ndn::Name & name )

protected

Sends a data packet with content type nack.

Producer sends a nack to consumer if consumer has very old IBF whose differences with latest IBF can't be decoded successfully

Parameters

name	send application nack with this name

Definition at line 128 of file producer-base.cpp.

void psync::ProducerBase::updateSeqNo	(	const ndn::Name &	prefix,
		uint64_t	seq
	)

protected

Update m_prefixes and IBF with the given prefix and seq.

Whoever calls this needs to make sure that prefix is in m_prefixes We remove already existing prefix/seq from IBF (unless seq is zero because we don't insert zero seq into IBF) Then we update m_prefix, m_prefix2hash, m_hash2prefix, and IBF

Parameters

prefix	prefix of the update
seq	sequence number of the update

Definition at line 86 of file producer-base.cpp.

Member Data Documentation

uint32_t psync::ProducerBase::m_expectedNumEntries

protected

Definition at line 161 of file producer-base.hpp.

ndn::Face& psync::ProducerBase::m_face

protected

Definition at line 174 of file producer-base.hpp.

std::map<uint32_t, ndn::Name> psync::ProducerBase::m_hash2prefix

protected

Definition at line 172 of file producer-base.hpp.

ndn::time::milliseconds psync::ProducerBase::m_helloReplyFreshness

protected

Definition at line 182 of file producer-base.hpp.

IBLT psync::ProducerBase::m_iblt

protected

Definition at line 160 of file producer-base.hpp.

ndn::KeyChain psync::ProducerBase::m_keyChain

protected

Definition at line 175 of file producer-base.hpp.

std::map<ndn::Name, uint32_t> psync::ProducerBase::m_prefix2hash

protected

Definition at line 170 of file producer-base.hpp.

std::map<ndn::Name, uint64_t> psync::ProducerBase::m_prefixes

protected

Definition at line 167 of file producer-base.hpp.

ndn::random::RandomNumberEngine& psync::ProducerBase::m_rng

protected

Definition at line 186 of file producer-base.hpp.

ndn::Scheduler psync::ProducerBase::m_scheduler

protected

Definition at line 176 of file producer-base.hpp.

SegmentPublisher psync::ProducerBase::m_segmentPublisher

protected

Definition at line 184 of file producer-base.hpp.

ndn::Name psync::ProducerBase::m_syncPrefix

protected

Definition at line 178 of file producer-base.hpp.

ndn::time::milliseconds psync::ProducerBase::m_syncReplyFreshness

protected

Definition at line 181 of file producer-base.hpp.

uint32_t psync::ProducerBase::m_threshold

protected

Definition at line 164 of file producer-base.hpp.

ndn::Name psync::ProducerBase::m_userPrefix

protected

Definition at line 179 of file producer-base.hpp.

PSync 0.1.0 documentation

Public Member Functions

Protected Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation