diff options
Diffstat (limited to 'ACE/TAO/tests/Codec/client.cpp')
| -rw-r--r-- | ACE/TAO/tests/Codec/client.cpp | 233 |
1 files changed, 233 insertions, 0 deletions
diff --git a/ACE/TAO/tests/Codec/client.cpp b/ACE/TAO/tests/Codec/client.cpp new file mode 100644 index 00000000000..f4f33f4fd41 --- /dev/null +++ b/ACE/TAO/tests/Codec/client.cpp @@ -0,0 +1,233 @@ +// -*- C++ -*- + +#include "tao/CodecFactory/CodecFactory.h" +#include "tao/Codeset/Codeset.h" +#include "testC.h" +#include "ace/OS_NS_string.h" + +#include "ace/Log_Msg.h" + +ACE_RCSID (Codec, + client, + "$Id$") + +CORBA::WChar * +gen_wstring (CORBA::ULong max_length) +{ + CORBA::ULong len = max_length; + CORBA::WChar *buf = CORBA::wstring_alloc (len); + CORBA::ULong i = 0; + CORBA::WChar limit = + ACE_OutputCDR::wchar_maxbytes() == 1 ? ACE_OCTET_MAX : ACE_WCHAR_MAX; + while (i < len) + { + CORBA::WChar wc = ACE_OS::rand () % limit; + if (wc) + { + buf[i] = wc; + i++; + } + } + + buf[i] = 0; + return buf; +} + +int +verify_data (Foo::Bar *original, Foo::Bar *extracted) +{ + if (!original || !extracted) + return -1; + + ACE_DEBUG ((LM_DEBUG, + "Original\n" + "--------\n" + "%d\n" + "%d\n" +// "%Lu\n" + "%C\n\n" + "Extracted\n" + "---------\n" + "%d\n" + "%d\n" +// "%Lu\n" + "%C\n\n", + original->A, + original->B, +// original->C, + original->D.in (), + extracted->A, + extracted->B, +// extracted->C, + extracted->D.in ())); + + if (original->A != extracted->A + || original->B != extracted->B + || original->C != extracted->C + || (ACE_OS::strcmp (original->D, extracted->D) != 0) + || (ACE_OS::strcmp (original->E, extracted->E) != 0)) + return -1; + + return 0; +} + +int +test_codec (IOP::Codec_ptr codec) +{ + // ---------------------------------------------------------- + + // Test values to be placed in the test structure. + const CORBA::Long A = 1010; + const CORBA::Long B = -3427; + const CORBA::ULongLong C = ACE_UINT64_LITERAL (2001); + const CORBA::Char D[] = "I'm Batman."; + const CORBA::WChar* E = gen_wstring (25); + + // Create the structure to be encoded. + Foo::Bar value; + value.A = A; + value.B = B; + value.C = C; + value.D = CORBA::string_dup (D); + value.E = CORBA::wstring_dup (E); + + CORBA::Any data; + data <<= value; + + // ---------------------------------------------------------- + + CORBA::OctetSeq_var encoded_data; + CORBA::Any_var decoded_data; + Foo::Bar *extracted_value = 0; + + // Encode the structure into an octet sequence using the CDR + // enscapsulation Codec. + + ACE_DEBUG ((LM_DEBUG, + "Testing CDR encapsulation Codec encode()/decode()\n" + "=================================================\n")); + + // Start out with the encode() method, i.e. the one that + // includes the TypeCode in the CDR encapsulation. + encoded_data = codec->encode (data); + + if ((reinterpret_cast<ptrdiff_t> (encoded_data->get_buffer ()) + % ACE_CDR::MAX_ALIGNMENT) == 0) + ACE_DEBUG ((LM_DEBUG, + "\nData for decoding are already aligned " + "on MAX_ALIGNMENT.\n\n")); + // Extract the data from the octet sequence. + decoded_data = codec->decode (encoded_data.in ()); + + if (!(decoded_data.in() >>= extracted_value)) + ACE_ERROR_RETURN ((LM_ERROR, + "ERROR: Unable to extract decoded data " + "from Any\n"), + -1); + + // Verify that the extracted data matches the data that was + // originally encoded into the octet sequence. + if (::verify_data (&value, extracted_value) != 0) + ACE_ERROR_RETURN ((LM_ERROR, + "ERROR: Data extracted using " + "IOP::Codec::decode() does not match " + "original data.\n"), + -1); + + ACE_DEBUG ((LM_DEBUG, + "Testing CDR encapsulation Codec " + "encode_value()/decode_value()\n" + "================================" + "=============================\n")); + + // Now use the encode_value() method, i.e. the one that does + // *not* include the TypeCode in the CDR encapsulation. + encoded_data = codec->encode_value (data); + + if ((reinterpret_cast<ptrdiff_t> (encoded_data->get_buffer ()) + % ACE_CDR::MAX_ALIGNMENT) == 0) + ACE_DEBUG ((LM_WARNING, + "\n" + "WARNING: Data to be decoded is already aligned " + "on MAX_ALIGNMENT.\n\n")); + + // Extract the data from the octet sequence. + decoded_data = codec->decode_value (encoded_data.in (), + Foo::_tc_Bar); + + if (!(decoded_data.in() >>= extracted_value)) + ACE_ERROR_RETURN ((LM_ERROR, + "ERROR: Unable to extract decoded data " + "from Any\n"), + -1); + + // Verify that the extracted data matches the data that was + // originally encoded into the octet sequence. + if (::verify_data (&value, extracted_value) != 0) + ACE_ERROR_RETURN ((LM_ERROR, + "ERROR: Data extracted using " + "IOP::Codec::decode_value() does not match " + "original data.\n"), + -1); + + return 0; +} + +int +ACE_TMAIN(int argc, ACE_TCHAR *argv[]) +{ + int retval = 0; + try + { + CORBA::ORB_var orb = + CORBA::ORB_init (argc, + argv, + "my_orb"); + + // Obtain a reference to the CodecFactory. + CORBA::Object_var obj = + orb->resolve_initial_references ("CodecFactory"); + + IOP::CodecFactory_var codec_factory = + IOP::CodecFactory::_narrow (obj.in ()); + + // Set up a structure that contains information necessary to + // create a GIOP 1.1 CDR encapsulation Codec. + IOP::Encoding_1_2 encoding_1_2; + encoding_1_2.format = IOP::ENCODING_CDR_ENCAPS; + encoding_1_2.major_version = 1; + encoding_1_2.minor_version = 2; + encoding_1_2.char_codeset = 0x00010001U; + encoding_1_2.wchar_codeset = 0x00010109U; + + // Obtain the CDR encapsulation Codec. + IOP::Codec_var codec_1_2 = + codec_factory->create_codec_with_codesets (encoding_1_2); + + retval = test_codec (codec_1_2.in ()); + + // ---------------------------------------------------------- + + // Set up a structure that contains information necessary to + // create a GIOP 1.1 CDR encapsulation Codec. + IOP::Encoding encoding; + encoding.format = IOP::ENCODING_CDR_ENCAPS; + encoding.major_version = 1; + encoding.minor_version = 1; + + // Obtain the CDR encapsulation Codec. + IOP::Codec_var codec = + codec_factory->create_codec (encoding); + + retval = test_codec (codec.in ()); + } + catch (const CORBA::Exception& ex) + { + ex._tao_print_exception ("Codec test:"); + return -1; + } + + ACE_DEBUG ((LM_DEBUG, "Codec test passed.\n")); + + return retval; +} |