syncscope_setup.cpp

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

/**
 * @file SyncScope_Setup.cpp
 *
 * SyncScope_Setup.cpp,v 1.5 2002/03/04 17:13:29 coryan Exp
 *
 * @author Carlos O'Ryan <[e-mail]>
 */

#include "SyncScope_Setup.h"
#include "RIR_Narrow.h"

#if !defined(__ACE_INLINE__)
#include "SyncScope_Setup.inl"
#endif /* __ACE_INLINE__ */

ACE_RCSID(TAO_PERF_RTEC, SyncScope_Setup, "SyncScope_Setup.cpp,v 1.5 2002/03/04 17:13:29 coryan Exp")

SyncScope_Setup::SyncScope_Setup (CORBA::ORB_ptr orb,
                                  Messaging::SyncScope value
                                  ACE_ENV_ARG_DECL)
{
  this->init (orb, value
              ACE_ENV_ARG_PARAMETER);
}

SyncScope_Setup::SyncScope_Setup (CORBA::ORB_ptr orb
                                  ACE_ENV_ARG_DECL)
{
  this->init (orb, Messaging::SYNC_WITH_TARGET
              ACE_ENV_ARG_PARAMETER);
}

void
SyncScope_Setup::init (CORBA::ORB_ptr orb,
                       Messaging::SyncScope value
                       ACE_ENV_ARG_DECL)
{
  CORBA::PolicyManager_var policy_manager =
    RIR_Narrow<CORBA::PolicyManager>::resolve (orb,
                                               "ORBPolicyManager"
                                               ACE_ENV_ARG_PARAMETER);
  ACE_CHECK;

  CORBA::PolicyList policy_list (1);
  policy_list.length (1);

  CORBA::Any sync_scope;
  sync_scope <<= value;

  // @@ We need a helper class that automatically calls the
  //    destroy() method on each policy...
  policy_list[0] =
    orb->create_policy (Messaging::SYNC_SCOPE_POLICY_TYPE,
                        sync_scope
                        ACE_ENV_ARG_PARAMETER);
  ACE_CHECK;
  policy_manager->set_policy_overrides (policy_list,
                                        CORBA::ADD_OVERRIDE
                                        ACE_ENV_ARG_PARAMETER);
  ACE_CHECK;

  policy_list[0]->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
  ACE_CHECK;
}

SyncScope_Setup::~SyncScope_Setup (void)
{
}