rtec_initializer.cpp

这是广泛使用的通信开源项目,对于大容量,高并发的通讯要求完全能够胜任,他广泛可用于网络游戏医学图像网关的高qos要求.更详细的内容可阅读相应的材料

/**
 * @file RTEC_Initializer.cpp
 *
 * RTEC_Initializer.cpp,v 1.5 2002/03/13 19:58:38 coryan Exp
 *
 * @author Carlos O'Ryan <[e-mail]>
 */

#include "RTEC_Initializer.h"
#include "RTCORBA_Setup.h"

#include "orbsvcs/Event/EC_Event_Channel.h"
#include "orbsvcs/Event/EC_Default_Factory.h"
#include "orbsvcs/Event/EC_RTCORBA_Factory.h"

#include "ace/Dynamic_Service.h"

ACE_RCSID(TAO_PERF_RTEC, RTEC_Initializer, "RTEC_Initializer.cpp,v 1.5 2002/03/13 19:58:38 coryan Exp")

TAO_EC_Event_Channel *
RTEC_Initializer::create (PortableServer::POA_ptr consumer_poa,
                          PortableServer::POA_ptr supplier_poa,
                          RTCORBA_Setup * rtcorba_setup
                          ACE_ENV_ARG_DECL_NOT_USED)
{
  TAO_EC_Event_Channel_Attributes attr (consumer_poa,
                                        supplier_poa);

  if (rtcorba_setup == 0)
    {
      return new TAO_EC_Event_Channel (attr);
    }

  TAO_EC_Factory *body =
    ACE_Dynamic_Service<TAO_EC_Factory>::instance ("EC_Factory");
  auto_ptr<TAO_EC_Factory> factory (
      new TAO_EC_RTCORBA_Factory (body,
                                  rtcorba_setup->lanes ()));

  TAO_EC_Event_Channel *ec =
    new TAO_EC_Event_Channel (attr, factory.get (), 1);
  factory.release ();

  return ec;
}