XrdOucAvahiBonjour Class Reference

#include <XrdOucAvahiBonjour.hh>

Inheritance diagram for XrdOucAvahiBonjour:

Collaboration diagram for XrdOucAvahiBonjour:

List of all members.

Classes
class	XrdOucAvahiBonjourSearchNode
class	XrdOucAvahiBonjourSingletonCleanup
Public Member Functions
int	RegisterService (XrdOucBonjourRecord &record, unsigned short port=0)
int	SubscribeForUpdates (const char *servicetype, XrdOucBonjourUpdateCallback callback, void *context)
int	ResolveNodeInformation (XrdOucBonjourResolutionEntry *nodeAndCallback)
Static Public Member Functions
static XrdOucAvahiBonjour &	getInstance ()
Private Member Functions
	XrdOucAvahiBonjour ()
virtual	~XrdOucAvahiBonjour ()
	XrdOucAvahiBonjour (const XrdOucAvahiBonjour &)
XrdOucAvahiBonjour &	operator= (const XrdOucAvahiBonjour &)
Static Private Member Functions
static void *	BrowseEventLoopThread (void *context)
static void	RegisterReply (AvahiClient *c, AvahiClientState state, void *userdata)
static void	RegisterEntries (XrdOucBonjourRegisteredEntry *entry)
static void	EntryGroupReply (AvahiEntryGroup *g, AvahiEntryGroupState state, void *userdata)
static void	ClientReply (AvahiClient *c, AvahiClientState state, void *userdata)
static void	BrowseReply (AvahiServiceBrowser *b, AvahiIfIndex interface, AvahiProtocol protocol, AvahiBrowserEvent event, const char *name, const char *type, const char *domain, AvahiLookupResultFlags flags, void *userdata)
static void	ResolveReply (AvahiServiceResolver *r, AvahiIfIndex interface, AvahiProtocol protocol, AvahiResolverEvent event, const char *name, const char *type, const char *domain, const char *host_name, const AvahiAddress *address, uint16_t port, AvahiStringList *txt, AvahiLookupResultFlags flags, void *userdata)
Private Attributes
std::list < XrdOucBonjourRegisteredEntry * >	ListOfRegistrations
pthread_t	BrowseEventLoopThreadInfo
AvahiSimplePoll *	poller
Static Private Attributes
static XrdOucAvahiBonjour *	_Instance = NULL
static XrdSysMutex	SingletonMutex
Friends
class	XrdOucAvahiBonjourSingletonCleanup

---

Constructor & Destructor Documentation

XrdOucAvahiBonjour::XrdOucAvahiBonjour

(

)

[private]

References poller.

Referenced by getInstance().

XrdOucAvahiBonjour::~XrdOucAvahiBonjour

(

)

[private, virtual]

References poller.

XrdOucAvahiBonjour::XrdOucAvahiBonjour

(

const XrdOucAvahiBonjour &

)

[inline, private]

---

Member Function Documentation

void * XrdOucAvahiBonjour::BrowseEventLoopThread

(

void *

context

)

[static, private]

References XrdSysError::Emsg(), ClientReply(), XrdOucBonjourSubscribedEntry::serviceType, XrdOucString::c_str(), and BrowseReply().

Referenced by SubscribeForUpdates().

void XrdOucAvahiBonjour::BrowseReply	(	AvahiServiceBrowser *	b,
		AvahiIfIndex	interface,
		AvahiProtocol	protocol,
		AvahiBrowserEvent	event,
		const char *	name,
		const char *	type,
		const char *	domain,
		AvahiLookupResultFlags	flags,
		void *	userdata
	)		[static, private]

References getInstance(), XrdSysError::Emsg(), XrdOucBonjour::LockNodeList(), XrdOucBonjourResolutionEntry::node, XrdOucBonjourResolutionEntry::callbackID, XrdSysError::Say(), ResolveReply(), XrdOucBonjour::UnLockNodeList(), XrdOucBonjour::ListOfNodes, XrdOucBonjourSubscribedEntry::callback, and XrdOucBonjourSubscribedEntry::context.

Referenced by BrowseEventLoopThread().

void XrdOucAvahiBonjour::ClientReply	(	AvahiClient *	c,
		AvahiClientState	state,
		void *	userdata
	)		[static, private]

References XrdSysError::Emsg().

Referenced by BrowseEventLoopThread().

void XrdOucAvahiBonjour::EntryGroupReply	(	AvahiEntryGroup *	g,
		AvahiEntryGroupState	state,
		void *	userdata
	)		[static, private]

References XrdOucBonjourRegisteredEntry::record, XrdOucBonjourRecord::GetServiceName(), XrdOucBonjourRecord::SetServiceName(), XrdSysError::Emsg(), and RegisterEntries().

Referenced by RegisterEntries().

XrdOucAvahiBonjour & XrdOucAvahiBonjour::getInstance

(

)

[static]

Reimplemented from XrdOucBonjour.

References SingletonMutex, XrdSysMutex::Lock(), _Instance, XrdOucAvahiBonjour(), and XrdSysMutex::UnLock().

Referenced by BrowseReply(), ResolveReply(), and XrdOucAvahiBonjourFactory::GetBonjourManager().

XrdOucAvahiBonjour& XrdOucAvahiBonjour::operator=

(

const XrdOucAvahiBonjour &

)

[inline, private]

void XrdOucAvahiBonjour::RegisterEntries

(

XrdOucBonjourRegisteredEntry *

entry

)

[static, private]

References EntryGroupReply(), XrdSysError::Emsg(), XrdOucBonjourRegisteredEntry::record, XrdOucBonjourRecord::GetServiceName(), XrdOucBonjourRecord::GetRegisteredType(), XrdOucBonjourRecord::GetReplyDomain(), XrdOucBonjourRegisteredEntry::port, and XrdOucBonjourRecord::SetServiceName().

Referenced by EntryGroupReply(), and RegisterReply().

void XrdOucAvahiBonjour::RegisterReply	(	AvahiClient *	c,
		AvahiClientState	state,
		void *	userdata
	)		[static, private]

References RegisterEntries(), and XrdSysError::Emsg().

Referenced by RegisterService().

int XrdOucAvahiBonjour::RegisterService	(	XrdOucBonjourRecord &	record,
		unsigned short	port = 0
	)		[virtual]

Implements XrdOucBonjour.

References XrdNet::Port(), XrdOucBonjourRegisteredEntry::record, XrdOucBonjourRegisteredEntry::port, XrdMonCtrCollector::port, poller, RegisterReply(), XrdSysError::Emsg(), XrdOucBonjourRecord::GetRegisteredType(), and ListOfRegistrations.

int XrdOucAvahiBonjour::ResolveNodeInformation

(

XrdOucBonjourResolutionEntry *

nodeAndCallback

)

[virtual]

Implements XrdOucBonjour.

void XrdOucAvahiBonjour::ResolveReply	(	AvahiServiceResolver *	r,
		AvahiIfIndex	interface,
		AvahiProtocol	protocol,
		AvahiResolverEvent	event,
		const char *	name,
		const char *	type,
		const char *	domain,
		const char *	host_name,
		const AvahiAddress *	address,
		uint16_t	port,
		AvahiStringList *	txt,
		AvahiLookupResultFlags	flags,
		void *	userdata
	)		[static, private]

References XrdOucBonjourResolutionEntry::callbackID, XrdSysError::Emsg(), getInstance(), XrdOucBonjour::LockNodeList(), XrdSysError::Say(), XrdOucBonjourResolutionEntry::node, XrdOucBonjourNode::SetHostName(), XrdOucBonjourNode::SetPort(), XrdOucBonjourNode::GetBonjourRecord(), XrdOucBonjourRecord::AddTXTRecord(), XrdOucBonjour::ListOfNodes, XrdOucBonjour::UnLockNodeList(), XrdOucBonjourSubscribedEntry::callback, and XrdOucBonjourSubscribedEntry::context.

Referenced by BrowseReply().

int XrdOucAvahiBonjour::SubscribeForUpdates	(	const char *	servicetype,
		XrdOucBonjourUpdateCallback	callback,
		void *	context
	)		[virtual]

Implements XrdOucBonjour.

References XrdOucBonjourSubscribedEntry::callback, XrdOucBonjourSubscribedEntry::context, XrdOucBonjourSubscribedEntry::serviceType, XrdSysThread::Run(), and BrowseEventLoopThread().

---

Friends And Related Function Documentation

friend class XrdOucAvahiBonjourSingletonCleanup [friend]

---

Member Data Documentation

XrdOucAvahiBonjour * XrdOucAvahiBonjour::_Instance = NULL [static, private]

Referenced by getInstance(), and XrdOucAvahiBonjour::XrdOucAvahiBonjourSingletonCleanup::~XrdOucAvahiBonjourSingletonCleanup().

pthread_t XrdOucAvahiBonjour::BrowseEventLoopThreadInfo [private]

std::list<XrdOucBonjourRegisteredEntry *> XrdOucAvahiBonjour::ListOfRegistrations [private]

Referenced by RegisterService().

AvahiSimplePoll* XrdOucAvahiBonjour::poller [private]

Referenced by RegisterService(), XrdOucAvahiBonjour(), and ~XrdOucAvahiBonjour().

XrdSysMutex XrdOucAvahiBonjour::SingletonMutex [static, private]

Referenced by getInstance(), and XrdOucAvahiBonjour::XrdOucAvahiBonjourSingletonCleanup::~XrdOucAvahiBonjourSingletonCleanup().

---

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

• XrdOucAvahiBonjour.hh
• XrdOucAvahiBonjour.cc