ACE_SupplierQOS_Factory Class Reference

#include <Event_Utilities.h>

Collaboration diagram for ACE_SupplierQOS_Factory:

[legend]List of all members.

Public Member Functions
	ACE_SupplierQOS_Factory (TAO_EC_Event_Initializer initializer=0, int qos_max_len=0)
	Default construction.
int	insert (RtecEventComm::EventSourceID sid, RtecEventComm::EventType type, RtecBase::handle_t rtinfo, u_int ncalls)
const RtecEventChannelAdmin::SupplierQOS &	get_SupplierQOS (void)
	operator const RtecEventChannelAdmin::SupplierQOS & (void)
	Calls this->get_SupplierQOS().
Static Public Member Functions
static void	debug (const RtecEventChannelAdmin::SupplierQOS &qos)
Private Attributes
RtecEventChannelAdmin::SupplierQOS	qos_
	Representation needed by channel.
TAO_EC_Event_Initializer	event_initializer_

---

Detailed Description

Definition at line 209 of file Event_Utilities.h.

---

Constructor & Destructor Documentation

ACE_SupplierQOS_Factory::ACE_SupplierQOS_Factory	(	TAO_EC_Event_Initializer	initializer = 0,
		int	qos_max_len = 0
	)

Default construction.

Definition at line 159 of file Event_Utilities.cpp.

References RtecEventChannelAdmin::SupplierQOS::is_gateway, RtecEventChannelAdmin::SupplierQOS::publications, and qos_.

  : event_initializer_ (initializer)
{
  qos_.is_gateway = 0;

  // Allocate the space requested by the application....
  qos_.publications.length (qos_max_len);

  // ... now reset the length, we do not want to use any elements in
  // the sequence that have not been initialized....
  qos_.publications.length (0);
}

---

Member Function Documentation

void ACE_SupplierQOS_Factory::debug

(

const RtecEventChannelAdmin::SupplierQOS &

qos

)

[static]

Definition at line 201 of file Event_Utilities.cpp.

References ACE_DEBUG, event_debug(), RtecEventChannelAdmin::SupplierQOS::is_gateway, LM_DEBUG, RtecEventChannelAdmin::SupplierQOS::publications, ACE_OS::sprintf(), and TAO_END_VERSIONED_NAMESPACE_DECL.

{
  ACE_DEBUG ((LM_DEBUG, "SupplierQOS { \n"));
  ACE_DEBUG ((LM_DEBUG, "  is_gateway: %d\n", qos.is_gateway));

  for (u_int i = 0; i < qos.publications.length (); ++i)
    {
      char buf[128] = { 0 };
      ACE_OS::sprintf (buf, " publications[%d]", i);
      event_debug (buf, qos.publications[i].event);
      ACE_DEBUG ((LM_DEBUG,
                  "%s   dependency_info.rt_info: %d\n"
                  "%s   dependency_info.number_of_calls: %d\n",
                  buf, qos.publications[i].dependency_info.rt_info,
                  buf, qos.publications[i].dependency_info.number_of_calls));
        }
  ACE_DEBUG ((LM_DEBUG, "}\n"));

}

ACE_INLINE const RtecEventChannelAdmin::SupplierQOS & ACE_SupplierQOS_Factory::get_SupplierQOS

(

void

)

Allows conversions to SupplierQOS, which is expected by the PushSupplierProxy::connect_push_supplier interface.

Definition at line 141 of file Event_Utilities.inl.

References qos_.

Referenced by TAO_ECG_Mcast_Gateway::init_receiver().

{
  return qos_;
}

int ACE_SupplierQOS_Factory::insert	(	RtecEventComm::EventSourceID	sid,
		RtecEventComm::EventType	type,
		RtecBase::handle_t	rtinfo,
		u_int	ncalls
	)

Publish sid and type that is generate by a method described by rtinfo. The method generates type ncalls number of times per "iteration."

Definition at line 174 of file Event_Utilities.cpp.

References event_initializer_, RtecEventChannelAdmin::SupplierQOS::publications, and qos_.

Referenced by TAO_ECG_Mcast_Gateway::init_receiver().

{
  CORBA::ULong l = this->qos_.publications.length ();
  if (l >= this->qos_.publications.maximum ())
    {
      // There is not enough space for the next element, grow the
      // buffer.
      this->qos_.publications.length (l + 1);

      // @@ TODO We may want to consider more efficient growing
      // strategies here, for example, duplicating the size of the
      // buffer, or growing in fixed sized chunks...
    }

  if (this->event_initializer_ != 0)
    (*this->event_initializer_) (qos_.publications[l].event);
  this->qos_.publications[l].event.header.source = sid;
  this->qos_.publications[l].event.header.type = type;
  // TODO: IDL union this->qos_.publications[l].event.data_.lval (0);
  this->qos_.publications[l].dependency_info.rt_info = rt_info;
  this->qos_.publications[l].dependency_info.number_of_calls = ncalls;
  return 0;
}

ACE_INLINE ACE_SupplierQOS_Factory::operator const RtecEventChannelAdmin::SupplierQOS &

(

void

)

Calls this->get_SupplierQOS().

Definition at line 147 of file Event_Utilities.inl.

References qos_.

{
  return qos_;
}

---

Member Data Documentation

TAO_EC_Event_Initializer ACE_SupplierQOS_Factory::event_initializer_ [private]

If not zero this is a user-provided function used to initialize the events. When the event contains unions this is required to avoid marshaling and demarshaling of default initialized unions that (AFAIK) is not CORBA compliant.

Definition at line 245 of file Event_Utilities.h.

Referenced by insert().

RtecEventChannelAdmin::SupplierQOS ACE_SupplierQOS_Factory::qos_ [private]

Representation needed by channel.

Definition at line 237 of file Event_Utilities.h.

Referenced by ACE_SupplierQOS_Factory(), get_SupplierQOS(), insert(), and operator const RtecEventChannelAdmin::SupplierQOS &().

---

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

• Event_Utilities.h
• Event_Utilities.inl
• Event_Utilities.cpp

---