TAO_EC_TPC_ProxyPushSupplier Class Reference

#include <EC_TPC_ProxySupplier.h>

Inheritance diagram for TAO_EC_TPC_ProxyPushSupplier:

[legend]Collaboration diagram for TAO_EC_TPC_ProxyPushSupplier:

[legend]List of all members.

Public Member Functions
	TAO_EC_TPC_ProxyPushSupplier (TAO_EC_Event_Channel_Base *event_channel, int validate_connection)
	Constructor.
virtual	~TAO_EC_TPC_ProxyPushSupplier (void)
	Dtor.
virtual void	connect_push_consumer (RtecEventComm::PushConsumer_ptr push_consumer, const RtecEventChannelAdmin::ConsumerQOS &qos)
virtual void	disconnect_push_supplier (void)
	Disconnect this from.
Private Types
typedef TAO_EC_Default_ProxyPushSupplier	BASECLASS
Private Member Functions
TAO_EC_TPC_Dispatching *	tpc_dispatching ()

---

Detailed Description

Definition at line 26 of file EC_TPC_ProxySupplier.h.

---

Member Typedef Documentation

typedef TAO_EC_Default_ProxyPushSupplier TAO_EC_TPC_ProxyPushSupplier::BASECLASS [private]

Definition at line 47 of file EC_TPC_ProxySupplier.h.

---

Constructor & Destructor Documentation

ACE_INLINE TAO_EC_TPC_ProxyPushSupplier::TAO_EC_TPC_ProxyPushSupplier	(	TAO_EC_Event_Channel_Base *	event_channel,
		int	validate_connection
	)

Constructor.

Definition at line 10 of file EC_TPC_ProxySupplier.inl.

References ACE_DEBUG, LM_DEBUG, and TAO_EC_TPC_debug_level.

: TAO_EC_Default_ProxyPushSupplier (ec, validate_connection)
{
  if (TAO_EC_TPC_debug_level > 0)        
    ACE_DEBUG ((LM_DEBUG, "(%P|%t) EC_TPC_ProxyPushSupplier::CTOR (%@)\n", this));
}

TAO_EC_TPC_ProxyPushSupplier::~TAO_EC_TPC_ProxyPushSupplier

(

void

)

[virtual]

Dtor.

Definition at line 18 of file EC_TPC_ProxySupplier.cpp.

{

}

---

Member Function Documentation

void TAO_EC_TPC_ProxyPushSupplier::connect_push_consumer	(	RtecEventComm::PushConsumer_ptr	push_consumer,
		const RtecEventChannelAdmin::ConsumerQOS &	qos
	)			[virtual]

These are overriden from the base class in order to maintain the map in the dispatcher class.

Reimplemented from TAO_EC_Default_ProxyPushSupplier.

Definition at line 51 of file EC_TPC_ProxySupplier.cpp.

References ACE_DEBUG, TAO_EC_TPC_Dispatching::add_consumer(), TAO_EC_Default_ProxyPushSupplier::connect_push_consumer(), LM_DEBUG, and tpc_dispatching().

{
  BASECLASS::connect_push_consumer (push_consumer, qos);

  if (TAO_EC_TPC_debug_level > 0)
    ACE_DEBUG ((LM_DEBUG, "EC (%P|%t): EC_ProxySupplier(%@): refcount=%u,consumer=%@\n",
              this, this->refcount_, this->consumer_.in()));

  TAO_EC_TPC_Dispatching* tpcdispatcher = this->tpc_dispatching ();

  // the new dispatching task gets automatically created
  tpcdispatcher->add_consumer (push_consumer);
}

void TAO_EC_TPC_ProxyPushSupplier::disconnect_push_supplier

(

void

)

[virtual]

Disconnect this from.

Reimplemented from TAO_EC_Default_ProxyPushSupplier.

Definition at line 24 of file EC_TPC_ProxySupplier.cpp.

References ACE_DEBUG, TAO_EC_Default_ProxyPushSupplier::disconnect_push_supplier(), and LM_DEBUG.

{
  if (TAO_EC_TPC_debug_level > 0)
    ACE_DEBUG ((LM_DEBUG, "EC (%P|%t): enter EC_TPC_ProxySupplier::disconnect_push_supplier (%@): refcount=%u,consumer=%@\n",
                this,
                this->refcount_,
                this->consumer_.in()));

  if (this->is_connected_i ())
    {
      this->tpc_dispatching ()->remove_consumer (this->consumer_.in());
    }
  BASECLASS::disconnect_push_supplier ();

  if (TAO_EC_TPC_debug_level > 0)
    ACE_DEBUG ((LM_DEBUG, "EC (%P|%t): leave EC_TPC_ProxySupplier::disconnect_push_supplier (%@)\n", this));
}

TAO_EC_TPC_Dispatching * TAO_EC_TPC_ProxyPushSupplier::tpc_dispatching

(

)

[private]

Definition at line 43 of file EC_TPC_ProxySupplier.cpp.

References TAO_EC_Event_Channel_Base::dispatching(), and TAO_EC_ProxyPushSupplier::event_channel_.

Referenced by connect_push_consumer().

{
  TAO_EC_Dispatching* dispatcher = this->event_channel_->dispatching ();

  return dynamic_cast <TAO_EC_TPC_Dispatching*> (dispatcher);
}

---

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

• EC_TPC_ProxySupplier.h
• EC_TPC_ProxySupplier.cpp
• EC_TPC_ProxySupplier.inl

---