client.cpp

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

  ACE_TRY_EX(bl_d)
  {
    for (i=0; i<c_breath; i++)
    {
      // Bind all level of context under root.
      CosNaming::Name wide;
      wide.length (1);
      char wide_name[16];
      ACE_OS::sprintf(wide_name, "wide_%d", i);
      wide[0].id = CORBA::string_dup (wide_name);
      CosNaming::NamingContext_var wide_context;
      wide_context = root_context_1->bind_new_context (wide
                                                       ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_d);
    }
  }
  ACE_CATCHANY
  {
    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
                         ACE_LIB_TEXT ("Unable to create wide context"));
    return -1;
  }
  ACE_ENDTRY;
  ACE_CHECK_RETURN (-1);

  // Delete three selected things, one from each tree
  ACE_TRY_EX(bl_e)
  {
    // Remove the second to last object from the Naming Context
    CosNaming::Name wide1;
    wide1.length (2);
    wide1[0].id = CORBA::string_dup ("level1_context");
    char wide_name[16];
    ACE_OS::sprintf(wide_name, "obj_%d", o_breath-2);
    wide1[1].id = CORBA::string_dup (wide_name);
    root_context_1->unbind (wide1 ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_e);

    // Remove the second to last context from the wide root Naming Context
    CosNaming::Name wide2;
    wide2.length (1);
    ACE_OS::sprintf(wide_name, "wide_%d", c_breath-2);
    wide2[0].id = CORBA::string_dup (wide_name);
    CORBA::Object_var result_obj_ref = root_context_1->resolve (wide2
                                                          ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_e);
    CosNaming::NamingContext_var result_object = 
      CosNaming::NamingContext::_narrow (result_obj_ref.in ()
                                         ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_e);
    if (CORBA::is_nil (result_object.in ()))
      ACE_ERROR_RETURN ((LM_ERROR,
                         ACE_LIB_TEXT ("Problems with resolving wide context ")
                         ACE_LIB_TEXT ("- nil object ref.\n")),
                         -1);
    result_object->destroy(ACE_ENV_SINGLE_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_e);
    root_context_1->unbind (wide2 ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_e);

    // Remove the last context from the deep Naming Context
    CosNaming::Name deep;
    deep.length (c_depth);
    char deep_name[16];
    for (i=0; i<c_depth; i++)
    {
      ACE_OS::sprintf(deep_name, "deep_%d", i);
      deep[i].id = CORBA::string_dup (deep_name);
    }
    result_obj_ref = root_context_1->resolve (deep ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_e);
    result_object = 
      CosNaming::NamingContext::_narrow (result_obj_ref.in ()
                                         ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_e);
    if (CORBA::is_nil (result_object.in ()))
      ACE_ERROR_RETURN ((LM_ERROR,
                         ACE_LIB_TEXT ("Problems with resolving deep context ")
                         ACE_LIB_TEXT ("- nil object ref.\n")),
                         -1);
    result_object->destroy(ACE_ENV_SINGLE_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_e);
    root_context_1->unbind (deep ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_e);

  }
  ACE_CATCHANY
  {
    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
                         ACE_LIB_TEXT ("Unable to delete objects"));
    return -1;
  }
  ACE_ENDTRY;
  ACE_CHECK_RETURN (-1);

  // Now use the other name server to access 3 objects next to the
  // deleted objects and the 3 deleted objects
  ACE_TRY_EX(bl_f)
  {
    // Access the last object from the Naming Context
    CosNaming::Name wide;
    wide.length (2);
    wide[0].id = CORBA::string_dup ("level1_context");
    char wide_name[16];
    ACE_OS::sprintf(wide_name, "obj_%d", o_breath-1);
    wide[1].id = CORBA::string_dup (wide_name);
    CORBA::Object_var result_obj_ref = root_context_2->resolve (wide
                                                          ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_f);
    Test_Object_var result_object = Test_Object::_narrow (result_obj_ref.in ()
                                                          ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_f);
    if (CORBA::is_nil (result_object.in ()))
      ACE_ERROR_RETURN ((LM_ERROR,
                         ACE_LIB_TEXT ("Problems with resolving object from ")
                         ACE_LIB_TEXT ("redundant server - nil object ref.\n")),
                         -1);
    ACE_TRY_CHECK_EX(bl_f);
  }
  ACE_CATCHANY
  {
    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
      ACE_LIB_TEXT ("Unable to resolve object from redundant server"));
    return -1;
  }
  ACE_ENDTRY;
  ACE_CHECK_RETURN (-1);

  ACE_TRY_EX(bl_g)
  {
    // Access the deleted second to last object from the Naming Context
    CosNaming::Name wide;
    wide.length (2);
    wide[0].id = CORBA::string_dup ("level1_context");
    char wide_name[16];
    ACE_OS::sprintf(wide_name, "obj_%d", o_breath-2);
    wide[1].id = CORBA::string_dup (wide_name);
    CORBA::Object_var result_obj_ref = root_context_2->resolve (wide
                                                          ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_g);
    ACE_ERROR_RETURN ((LM_ERROR,
                    ACE_LIB_TEXT ("Problems with resolving object from ")
                    ACE_LIB_TEXT ("redundant server - deleted object found.\n")),
                    -1);
  }
  ACE_CATCHANY
  {
    //expect exception since the context was deleted
  }
  ACE_ENDTRY;

  ACE_TRY_EX(bl_h)
  {
    // Access the last context from the wide Naming Context
    CosNaming::Name wide;
    wide.length (1);
    char wide_name[16];
    ACE_OS::sprintf(wide_name, "wide_%d", c_breath-1);
    wide[0].id = CORBA::string_dup (wide_name);
    CORBA::Object_var result_obj_ref = root_context_2->resolve (wide
                                                          ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_h);
    CosNaming::NamingContext_var result_object = 
      CosNaming::NamingContext::_narrow (result_obj_ref.in ()
                                         ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_h);
    if (CORBA::is_nil (result_object.in ()))
      ACE_ERROR_RETURN ((LM_ERROR,
                      ACE_LIB_TEXT ("Problems with resolving wide context from ")
                      ACE_LIB_TEXT ("redundant server - nil object ref.\n")),
                      -1);
    ACE_TRY_CHECK_EX(bl_h);
  }
  ACE_CATCHANY
  {
    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
      ACE_LIB_TEXT ("Unable to resolve wide context from redundant server"));
    return -1;
  }
  ACE_ENDTRY;
  ACE_CHECK_RETURN (-1);

  ACE_TRY_EX(bl_i)
  {
    // Access the deleted second to last object from the Naming Context
    CosNaming::Name wide;
    wide.length (2);
    char wide_name[16];
    ACE_OS::sprintf(wide_name, "wide_%d", c_breath-2);
    wide[0].id = CORBA::string_dup (wide_name);
    CORBA::Object_var result_obj_ref = root_context_2->resolve (wide
                                                          ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_i);
    ACE_ERROR_RETURN ((LM_ERROR,
                    ACE_LIB_TEXT ("Problems with resolving wide context from ")
                    ACE_LIB_TEXT ("redundant server - deleted object found.\n")),
                    -1);
  }
  ACE_CATCHANY
  {
    //expect exception since the context was deleted
  }
  ACE_ENDTRY;

  ACE_TRY_EX(bl_j)
  {
    // Access the deleted last context from the deep Naming Context
    CosNaming::Name deep;
    deep.length (c_depth);
    char deep_name[16];
    for (i=0; i<c_depth; i++)
    {
      ACE_OS::sprintf(deep_name, "deep_%d", i);
      deep[i].id = CORBA::string_dup (deep_name);
    }
    CORBA::Object_var result_obj_ref = root_context_1->resolve (deep
                                                          ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_j);
    ACE_ERROR_RETURN ((LM_ERROR,
                    ACE_LIB_TEXT ("Problems with resolving deep context from ")
                    ACE_LIB_TEXT ("redundant server - deleted object found.\n")),
                    -1);
  }
  ACE_CATCHANY
  {
    //expect exception since the context was deleted
  }
  ACE_ENDTRY;

  ACE_TRY_EX(bl_k)
  {
    // Access the second to last object from the Naming Context
    CosNaming::Name deep;
    deep.length (c_depth-1);
    char deep_name[16];
    for (i=0; i<c_depth-1; i++)
    {
      ACE_OS::sprintf(deep_name, "deep_%d", i);
      deep[i].id = CORBA::string_dup (deep_name);
    }
    CORBA::Object_var result_obj_ref = root_context_1->resolve (deep
                                                          ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_k);
    CosNaming::NamingContext_var result_object = 
      CosNaming::NamingContext::_narrow (result_obj_ref.in ()
                                         ACE_ENV_ARG_PARAMETER);
    ACE_TRY_CHECK_EX(bl_k);
    if (CORBA::is_nil (result_object.in ()))
      ACE_ERROR_RETURN ((LM_ERROR,
                      ACE_LIB_TEXT ("Problems with resolving deep context from ")
                      ACE_LIB_TEXT ("redundant server - nil object ref.\n")),
                      -1);

    ACE_TRY_CHECK_EX(bl_k);

  }
  ACE_CATCHANY
  {
    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
      ACE_LIB_TEXT ("Unable to resolve deep context from redundant server"));
    return -1;
  }
  ACE_ENDTRY;
  ACE_CHECK_RETURN (-1);

  ACE_DEBUG ((LM_DEBUG, ACE_LIB_TEXT ("Redundancy test OK\n")));
  return 0;

}