summaryrefslogtreecommitdiff
path: root/TAO/tao/deep_copy.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/deep_copy.cpp')
-rw-r--r--TAO/tao/deep_copy.cpp1213
1 files changed, 0 insertions, 1213 deletions
diff --git a/TAO/tao/deep_copy.cpp b/TAO/tao/deep_copy.cpp
deleted file mode 100644
index 00b199cf777..00000000000
--- a/TAO/tao/deep_copy.cpp
+++ /dev/null
@@ -1,1213 +0,0 @@
-// ============================================================================
-//
-// = LIBRARY
-// TAO
-//
-// = FILENAME
-// deep_copy.cpp
-//
-// = DESCRIPTION
-// Code for deep_copy
-// The original code had a single static deep_copy function that called
-// traverse to interpret the data types. This version defines a static method
-// "deep_copy" on each class and avoids calling traverse.
-//
-//
-// Helper routine for "Any" copy constructor ...
-//
-// "Deep Copy" from source to dest. Memory is always there to be
-// copied to ... if this calls other deep_copy methods, it ensures that
-// this remains true (only really an issue for sequences) .
-//
-// = AUTHOR
-// Copyright 1994-1995 by Sun Microsystems Inc.
-// and
-// Aniruddha Gokhale
-//
-// ============================================================================
-
-#include "tao/corba.h"
-
-extern CORBA::TypeCode TC_opaque;
-
-// Deep copy from "source" to "dest" ... this code "knows" a bit about
-// representations, verify it when porting to oddball platforms with
-// non-IEEE floating point values or atypical byte and word sizes.
-
-CORBA::TypeCode::traverse_status
-DEEP_COPY (CORBA::TypeCode_ptr param,
- const void *source,
- const void *dest,
- CORBA::Environment &env)
-{
- CORBA::TypeCode::traverse_status retval = CORBA::TypeCode::TRAVERSE_CONTINUE;
-
- switch (param->kind_)
- {
- case CORBA::tk_null:
- case CORBA::tk_void:
- break;
- case CORBA::tk_short:
- case CORBA::tk_ushort:
- *(CORBA::Short *) dest = *(CORBA::Short *) source;
- break;
- case CORBA::tk_long:
- case CORBA::tk_ulong:
- case CORBA::tk_float:
- case CORBA::tk_enum:
- *(CORBA::Long *) dest = *(CORBA::Long *) source;
- break;
- case CORBA::tk_double:
- case CORBA::tk_longlong:
- case CORBA::tk_ulonglong:
- *(CORBA::LongLong *) dest = *(CORBA::LongLong *) source;
- break;
- case CORBA::tk_boolean:
- *(CORBA::Boolean *) dest = *(CORBA::Boolean *) source;
- break;
- case CORBA::tk_char:
- case CORBA::tk_octet:
- *(CORBA::Char *) dest = *(CORBA::Char *) source;
- break;
- case CORBA::tk_longdouble:
- *(CORBA::LongDouble *) dest = *(CORBA::LongDouble *) source;
- break;
- case CORBA::tk_wchar:
- *(CORBA::WChar *) dest = *(CORBA::WChar *) source;
- break;
- case CORBA::tk_any:
- retval = TAO_Marshal_Any::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_TypeCode:
- retval = TAO_Marshal_TypeCode::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_Principal:
- retval = TAO_Marshal_Principal::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_objref:
- retval = TAO_Marshal_ObjRef::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_struct:
- retval = TAO_Marshal_Struct::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_union:
- retval = TAO_Marshal_Union::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_string:
- retval = TAO_Marshal_String::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_sequence:
- retval = TAO_Marshal_Sequence::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_array:
- retval = TAO_Marshal_Array::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_alias:
- retval = TAO_Marshal_Alias::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_except:
- retval = TAO_Marshal_Except::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_wstring:
- retval = TAO_Marshal_WString::deep_copy (param, source, dest, env);
- break;
- default:
- retval = CORBA::TypeCode::TRAVERSE_STOP;
- } // end of switch
- return retval;
-}
-
-// deep copy for primitives
-CORBA::TypeCode::traverse_status
-TAO_Marshal_Primitive::deep_copy (CORBA::TypeCode_ptr tc,
- const void *source,
- const void *dest,
- CORBA::Environment &env)
-{
- if (tc)
- {
- CORBA::TCKind mykind_ = tc->kind (env);
-
- if (env.exception () == 0)
- {
- switch (mykind_)
- {
- case CORBA::tk_null:
- case CORBA::tk_void:
- // @@ I assume this should be an error...
- break;
-
- case CORBA::tk_char:
- case CORBA::tk_octet:
- *(CORBA::Octet *) dest = *(CORBA::Octet *) source;
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
-
- case CORBA::tk_short:
- case CORBA::tk_ushort:
- *(CORBA::Short *) dest = *(CORBA::Short *) source;
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
-
- case CORBA::tk_wchar:
- *(CORBA::WChar *) dest = *(CORBA::WChar *) source;
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
-
- case CORBA::tk_long:
- case CORBA::tk_ulong:
- case CORBA::tk_float:
- case CORBA::tk_enum:
- *(CORBA::Long *) dest = *(CORBA::Long *) source;
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
-
- case CORBA::tk_longlong:
- case CORBA::tk_ulonglong:
- case CORBA::tk_double:
- *(CORBA::LongLong *) dest = *(CORBA::LongLong *) source;
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
-
- case CORBA::tk_longdouble:
- *(CORBA::LongDouble *) dest = *(CORBA::LongDouble *) source;
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
-
- case CORBA::tk_boolean:
- *(CORBA::Boolean *) dest = *(CORBA::Boolean *) source;
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- default:
- env.exception (new CORBA::BAD_TYPECODE (CORBA::COMPLETED_MAYBE));
- dmsg ("TAO_Marshal_Primitive::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else
- {
- dmsg ("TAO_Marshal_Primitive::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
-
- env.exception (new CORBA::BAD_TYPECODE (CORBA::COMPLETED_MAYBE) );
- dmsg ("TAO_Marshal_Primitive::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
-}
-
-// deep_copy for Principal
-CORBA::TypeCode::traverse_status
-TAO_Marshal_Principal::deep_copy (CORBA::TypeCode_ptr tc,
- const void *source,
- const void *dest,
- CORBA::Environment &env)
-{
- if (tc)
- {
- CORBA::Principal_ptr src = *(CORBA::Principal_ptr *) source;
- CORBA::Principal_ptr dst = *(CORBA::Principal_ptr *) dest = new CORBA::Principal;
-
- if (dst)
- {
- // Principals are just opaque IDs ... copy them
- assert (src->id.length <= UINT_MAX);
- dst->id.length = dst->id.maximum = src->id.length;
-
- if (dst->id.length > 0)
- {
- dst->id.buffer = new CORBA::Octet [(u_int) dst->id.length];
- if (dst->id.buffer)
- {
- ACE_OS::memcpy (dst->id.buffer,
- src->id.buffer,
- (size_t) dst->id.length);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- }
- else
- {
- env.exception (new CORBA::NO_MEMORY (CORBA::COMPLETED_MAYBE) );
- dmsg ("TAO_Marshal_Principal::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else
- {
- dst->id.buffer = 0;
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- }
- }
- else
- {
- env.exception (new CORBA::NO_MEMORY (CORBA::COMPLETED_MAYBE) );
- dmsg ("TAO_Marshal_Principal::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else
- {
- env.exception (new CORBA::BAD_TYPECODE (CORBA::COMPLETED_MAYBE) );
- dmsg ("TAO_Marshal_Primitive::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
-}
-
-// deep_copy structs
-CORBA::TypeCode::traverse_status
-TAO_Marshal_Struct::deep_copy (CORBA::TypeCode_ptr tc,
- const void *source,
- const void *dest,
- CORBA::Environment &env)
-{
- if (tc)
- {
- // compute the number of fields in the struct
- int member_count = tc->member_count (env);
-
- if (env.exception () == 0)
- {
- CORBA::TypeCode::traverse_status retval =
- CORBA::TypeCode::TRAVERSE_CONTINUE;
-
- for (int i = 0; i < member_count
- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE;
- i++)
- {
- // get the typecode for the ith field
- CORBA::TypeCode_ptr param = tc->member_type (i, env);
- if (env.exception () == 0)
- {
- // get the size of the field
- CORBA::Long size = param->size (env);
- if (env.exception () == 0)
- {
- // get the alignment of the field
-#if defined(TAO_NEEDS_UNUSED_VARIABLES)
- CORBA::Long alignment = param->alignment (env);
-#endif
- if (env.exception () == 0)
- {
- switch (param->kind_)
- {
- case CORBA::tk_null:
- case CORBA::tk_void:
- break;
- case CORBA::tk_short:
- case CORBA::tk_ushort:
- *(CORBA::Short *) dest = *(CORBA::Short *) source;
- break;
- case CORBA::tk_long:
- case CORBA::tk_ulong:
- case CORBA::tk_float:
- case CORBA::tk_enum:
- *(CORBA::Long *) dest = *(CORBA::Long *) source;
- break;
- case CORBA::tk_double:
- case CORBA::tk_longlong:
- case CORBA::tk_ulonglong:
- *(CORBA::LongLong *) dest = *(CORBA::LongLong *) source;
- break;
- case CORBA::tk_boolean:
- *(CORBA::Boolean *) dest = *(CORBA::Boolean *) source;
- break;
- case CORBA::tk_char:
- case CORBA::tk_octet:
- *(CORBA::Char *) dest = *(CORBA::Char *) source;
- break;
- case CORBA::tk_longdouble:
- *(CORBA::LongDouble *) dest = *(CORBA::LongDouble *) source;
- break;
- case CORBA::tk_wchar:
- *(CORBA::WChar *) dest = *(CORBA::WChar *) source;
- break;
- case CORBA::tk_any:
- retval = TAO_Marshal_Any::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_TypeCode:
- retval = TAO_Marshal_TypeCode::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_Principal:
- retval = TAO_Marshal_Principal::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_objref:
- retval = TAO_Marshal_ObjRef::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_struct:
- retval = TAO_Marshal_Struct::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_union:
- retval = TAO_Marshal_Union::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_string:
- retval = TAO_Marshal_String::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_sequence:
- retval = TAO_Marshal_Sequence::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_array:
- retval = TAO_Marshal_Array::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_alias:
- retval = TAO_Marshal_Alias::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_except:
- retval = TAO_Marshal_Except::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_wstring:
- retval = TAO_Marshal_WString::deep_copy (param, source, dest, env);
- break;
- default:
- retval = CORBA::TypeCode::TRAVERSE_STOP;
- } // end of switch
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- else // exception computing alignment
- {
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // exception computing size
- {
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // exception computing typecode
- {
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- } // end of loop
- if (retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- else
- {
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_MAYBE));
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // exception getting member count
- {
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // no typecode
- {
- env.exception (new CORBA::BAD_TYPECODE (CORBA::COMPLETED_MAYBE));
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
-}
-
-// deep_copy for union
-CORBA::TypeCode::traverse_status
-TAO_Marshal_Union::deep_copy (CORBA::TypeCode_ptr tc,
- const void *data,
- const void *data2,
- CORBA::Environment &env)
-{
- CORBA::TypeCode_ptr discrim_tc = tc->discriminator_type (env);
-
- // Get the discriminator type.
- if (env.exception () == 0)
- {
- // deep_copy the discriminator value
- CORBA::TypeCode::traverse_status retval =
- DEEP_COPY (discrim_tc, data, data2, env);
-
- if (retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- CORBA::ULong discrim_size_with_pad =
- tc->TAO_discrim_pad_size (env);
-
- if (env.exception () == 0)
- {
- CORBA::TypeCode_ptr default_tc = 0;
-
- const void *discrim_val = data; // save the pointer to the discriminator
- // value
- // move the pointer to point to the actual value
- data = (char *) data + discrim_size_with_pad;
- data2 = (char *) data2 + discrim_size_with_pad;
- // now get ready to marshal the actual union value
- CORBA::Long default_index = tc->default_index (env);
- if (env.exception () == 0)
- {
- int member_count = tc->member_count (env);
- if (env.exception () == 0)
- {
- // check which label value matches with the discriminator
- // value. Accordingly, marshal the corresponding
- // member_type. If none match, check if default exists
- // and marshal accordingly. Otherwise it is an error.
- for (int i = 0; member_count-- != 0; i++)
- {
- CORBA::Any_ptr member_label = tc->member_label (i, env);
- if (env.exception () == 0)
- {
- CORBA::Boolean discrim_matched = CORBA::B_FALSE;
-
- // do the matching
- switch (member_label->type ()->kind (env))
- {
- case CORBA::tk_short:
- case CORBA::tk_ushort:
- if (*(CORBA::Short *) member_label->value () ==
- *(CORBA::Short *) discrim_val)
- discrim_matched = CORBA::B_TRUE;
- break;
- case CORBA::tk_long:
- case CORBA::tk_ulong:
- case CORBA::tk_enum:
- if (*(CORBA::ULong *) member_label->value () ==
- *(CORBA::ULong *) discrim_val)
- discrim_matched = CORBA::B_TRUE;
- break;
- case CORBA::tk_char:
- if (*(CORBA::Char *) member_label->value () ==
- *(CORBA::Char *) discrim_val)
- discrim_matched = CORBA::B_TRUE;
- break;
- case CORBA::tk_wchar:
- if (*(CORBA::WChar *) member_label->value () ==
- *(CORBA::WChar *) discrim_val)
- discrim_matched = CORBA::B_TRUE;
- break;
- case CORBA::tk_boolean:
- if (*(CORBA::Boolean *) member_label->value () ==
- *(CORBA::Boolean *) discrim_val)
- discrim_matched = CORBA::B_TRUE;
- break;
- default:
- env.exception (new CORBA::BAD_TYPECODE (CORBA::COMPLETED_NO));
- return CORBA::TypeCode::TRAVERSE_STOP;
- }// end of switch
-
- // get the member typecode
- CORBA::TypeCode_ptr member_tc = tc->member_type (i, env);
- if (env.exception () == 0)
- {
- if (default_index >= 0 && default_index-- == 0)
- // have we reached the default label?, if so,
- // save a handle to the typecode for the default
- default_tc = member_tc;
- if (discrim_matched)
- // marshal according to the matched typecode
- return DEEP_COPY (member_tc, data,
- data2, env);
- }
- else
- {
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_MAYBE));
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else
- {
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_MAYBE));
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- } // end of while
-
- // we are here only if there was no match
- if (default_tc)
- return DEEP_COPY (default_tc, data, data2, env);
- else
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- }
- else
- {
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_MAYBE));
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else
- {
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_MAYBE));
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else
- {
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_MAYBE));
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else
- {
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_MAYBE));
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else
- {
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_MAYBE));
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
-}
-
-// deep_copy for Sequence
-CORBA::TypeCode::traverse_status
-TAO_Marshal_Sequence::deep_copy (CORBA::TypeCode_ptr tc,
- const void *source,
- const void *dest,
- CORBA::Environment &env)
-{
- CORBA::TypeCode::traverse_status retval =
- CORBA::TypeCode::TRAVERSE_CONTINUE; // return status
- CORBA::TypeCode_ptr tc2; // typecode of the element
- size_t size; // size of element
- CORBA::ULong bounds;
- char *value1, *value2;
- CORBA::OctetSeq *src, *dst;
- CDR stream; // used only to access the marshal_object factory
-
- // Rely on binary format of sequences -- all are the same
- // except for the type pointed to by "buffer"
-
- if (tc)
- {
- src = (CORBA::OctetSeq *) source;
- dst = (CORBA::OctetSeq *) dest;
-
- assert (src->length <= UINT_MAX);
- dst->length = dst->maximum = src->length;
-
- // get element typecode
- tc2 = tc->content_type (env);
- if (env.exception () == 0)
- {
- // get the size of the element
- size = tc2->size (env);
- if (env.exception () == 0)
- {
- // compute the length of the sequence
- bounds = src->length;
-
- // allocate a buffer to hold the sequence
- dst->buffer = new CORBA::Octet [size *(size_t) src->maximum];
- if (dst->buffer)
- {
- value1 = (char *) src->buffer;
- value2 = (char *) dst->buffer;
-
- switch (tc2->kind_)
- {
- case CORBA::tk_null:
- case CORBA::tk_void:
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- case CORBA::tk_short:
- case CORBA::tk_ushort:
- case CORBA::tk_long:
- case CORBA::tk_ulong:
- case CORBA::tk_float:
- case CORBA::tk_double:
- case CORBA::tk_longlong:
- case CORBA::tk_ulonglong:
- case CORBA::tk_boolean:
- case CORBA::tk_char:
- case CORBA::tk_octet:
- case CORBA::tk_longdouble:
- case CORBA::tk_wchar:
- case CORBA::tk_enum:
- // just do a memcpy rather than copying each element
- ACE_OS::memcpy (value2, value1, size*bounds);
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
-
- // handle all aggregate types here
- case CORBA::tk_any:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Any::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- case CORBA::tk_TypeCode:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_TypeCode::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- case CORBA::tk_Principal:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Principal::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- case CORBA::tk_objref:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_ObjRef::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- case CORBA::tk_struct:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Struct::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- case CORBA::tk_union:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Union::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- case CORBA::tk_string:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Any::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- retval = TAO_Marshal_String::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_sequence:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Sequence::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- case CORBA::tk_array:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Array::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- case CORBA::tk_alias:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Alias::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- case CORBA::tk_except:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Except::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- case CORBA::tk_wstring:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_WString::deep_copy (tc2, source, dest, env);
- value1 = (char *) value1 + size;
- value2 = (char *) value2 + size;
- }
- break;
- default:
- retval = CORBA::TypeCode::TRAVERSE_STOP;
- break;
- } // end of switch
- // CORBA::release (tc2);
- if (retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- else
- {
- // error exit
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_NO));
- dmsg ("marshaling TAO_Marshal_Sequence::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else
- {
- // error exit
- // CORBA::release (tc2);
- env.exception (new CORBA::NO_MEMORY (CORBA::COMPLETED_MAYBE));
- dmsg ("marshaling TAO_Marshal_Sequence::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // exception computing size
- {
- // CORBA::release (tc2);
- dmsg ("marshaling TAO_Marshal_Sequence::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // exception computing content type
- {
- dmsg ("marshaling TAO_Marshal_Sequence::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // no typecode
- {
- env.exception (new CORBA::BAD_TYPECODE (CORBA::COMPLETED_MAYBE));
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
-}
-
-// deep_copy for Array
-CORBA::TypeCode::traverse_status
-TAO_Marshal_Array::deep_copy (CORBA::TypeCode_ptr tc,
- const void *source,
- const void *dest,
- CORBA::Environment &env)
-{
- CORBA::TypeCode::traverse_status retval =
- CORBA::TypeCode::TRAVERSE_CONTINUE; // return status
- CORBA::TypeCode_ptr tc2; // typecode of the element
- size_t size; // size of element
- CORBA::ULong bounds;
- CDR stream; // used only to access the marshal_object factory
-
- // Rely on binary format of sequences -- all are the same
- // except for the type pointed to by "buffer"
-
- if (tc)
- {
- bounds = tc->length (env);
- if (env.exception () == 0)
- {
- // get element typecode
- tc2 = tc->content_type (env);
- if (env.exception () == 0)
- {
- // get the size of the element type
- size = tc2->size (env);
- if (env.exception () == 0)
- {
- switch (tc2->kind_)
- {
- case CORBA::tk_null:
- case CORBA::tk_void:
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- case CORBA::tk_short:
- case CORBA::tk_ushort:
- case CORBA::tk_long:
- case CORBA::tk_ulong:
- case CORBA::tk_float:
- case CORBA::tk_double:
- case CORBA::tk_longlong:
- case CORBA::tk_ulonglong:
- case CORBA::tk_boolean:
- case CORBA::tk_char:
- case CORBA::tk_octet:
- case CORBA::tk_longdouble:
- case CORBA::tk_wchar:
- case CORBA::tk_enum:
- // just do a memcpy rather than copying each element
- ACE_OS::memcpy ((char *) dest, (char *) source, size*bounds);
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- // handle all aggregate types here
- case CORBA::tk_any:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Any::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- case CORBA::tk_TypeCode:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_TypeCode::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- case CORBA::tk_Principal:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Principal::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- case CORBA::tk_objref:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_ObjRef::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- case CORBA::tk_struct:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Struct::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- case CORBA::tk_union:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Union::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- case CORBA::tk_string:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Any::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- retval = TAO_Marshal_String::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_sequence:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Sequence::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- case CORBA::tk_array:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Array::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- case CORBA::tk_alias:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Alias::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- case CORBA::tk_except:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_Except::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- case CORBA::tk_wstring:
- while (bounds-- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- {
- retval = TAO_Marshal_WString::deep_copy (tc2, source, dest, env);
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- break;
- default:
- retval = CORBA::TypeCode::TRAVERSE_STOP;
- break;
- } // end of switch
- // CORBA::release (tc2);
- if (retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- else
- {
- // error exit
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_NO));
- dmsg ("marshaling TAO_Marshal_Sequence::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- } // no exception computing size
- else
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_STOP;
- } // no exception computing content type
- else
- return CORBA::TypeCode::TRAVERSE_STOP;
- } // bounds are fine
- else
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- else // no typecode
- {
- env.exception (new CORBA::BAD_TYPECODE (CORBA::COMPLETED_MAYBE));
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
-}
-
-// deep_copy alias
-CORBA::TypeCode::traverse_status
-TAO_Marshal_Alias::deep_copy (CORBA::TypeCode_ptr tc,
- const void *source,
- const void *dest,
- CORBA::Environment &env)
-{
- CORBA::TypeCode_ptr tc2; // typecode of the aliased type
- CDR stream; // to access the marshal object
- CORBA::TypeCode::traverse_status retval =
- CORBA::TypeCode::TRAVERSE_CONTINUE; // status of deep_copy operation
-
- if (tc)
- {
- // get element type
- tc2 = tc->content_type (env);
- if (env.exception () == 0)
- {
- // switch on the data type and handle the cases for primitives here for
- // efficiency
- switch (tc2->kind_)
- {
- case CORBA::tk_null:
- case CORBA::tk_void:
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- case CORBA::tk_short:
- case CORBA::tk_ushort:
- *(CORBA::Short *) dest = *(CORBA::Short *) source;
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- case CORBA::tk_long:
- case CORBA::tk_ulong:
- case CORBA::tk_float:
- case CORBA::tk_enum:
- *(CORBA::Long *) dest = *(CORBA::Long *) source;
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- case CORBA::tk_double:
- case CORBA::tk_longlong:
- case CORBA::tk_ulonglong:
- *(CORBA::LongLong *) dest = *(CORBA::LongLong *) source;
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- case CORBA::tk_boolean:
- *(CORBA::Boolean *) dest = *(CORBA::Boolean *) source;
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- case CORBA::tk_char:
- case CORBA::tk_octet:
- *(CORBA::Char *) dest = *(CORBA::Char *) source;
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- case CORBA::tk_longdouble:
- *(CORBA::LongDouble *) dest = *(CORBA::LongDouble *) source;
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- case CORBA::tk_wchar:
- *(CORBA::WChar *) dest = *(CORBA::WChar *) source;
- // CORBA::release (tc2);
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- case CORBA::tk_any:
- retval = TAO_Marshal_Any::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_TypeCode:
- retval = TAO_Marshal_TypeCode::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_Principal:
- retval = TAO_Marshal_Principal::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_objref:
- retval = TAO_Marshal_ObjRef::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_struct:
- retval = TAO_Marshal_Struct::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_union:
- retval = TAO_Marshal_Union::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_string:
- retval = TAO_Marshal_String::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_sequence:
- retval = TAO_Marshal_Sequence::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_array:
- retval = TAO_Marshal_Array::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_alias:
- retval = TAO_Marshal_Alias::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_except:
- retval = TAO_Marshal_Except::deep_copy (tc2, source, dest, env);
- break;
- case CORBA::tk_wstring:
- retval = TAO_Marshal_WString::deep_copy (tc2, source, dest, env);
- break;
- default:
- // anything else is an error
- retval = CORBA::TypeCode::TRAVERSE_STOP;
- }
- // CORBA::release (tc2);
- if (retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- else
- {
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_MAYBE));
- dmsg ("TAO_Marshal_Alias::decode detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // exception getting content_type
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- else // no typecode
- {
- env.exception (new CORBA::BAD_TYPECODE (CORBA::COMPLETED_MAYBE));
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
-}
-
-// deep_copy structs
-CORBA::TypeCode::traverse_status
-TAO_Marshal_Except::deep_copy (CORBA::TypeCode_ptr tc,
- const void *source,
- const void *dest,
- CORBA::Environment &env)
-{
- CORBA::TypeCode::traverse_status retval = CORBA::TypeCode::TRAVERSE_CONTINUE;
- CORBA::TypeCode_ptr param;
- CORBA::Long size;
-
- CDR stream;
-
- if (tc)
- {
- // Exceptions in memory have a "hidden" typecode up front, used
- // to ensure that memory is appropriately freed and to hold the
- // exception ID. We just copy that typecode
-
- *(CORBA::TypeCode_ptr *) dest = *(CORBA::TypeCode_ptr *) source;
- (void) (*(CORBA::TypeCode_ptr *) dest)->AddRef ();
-
- // compute the number of fields in the struct
- int member_count = tc->member_count (env);
- if (env.exception () == 0)
- {
- for (int i = 0;
- i < member_count
- && retval == CORBA::TypeCode::TRAVERSE_CONTINUE;
- i++)
- {
- // get the typecode for the ith field
- param = tc->member_type (i, env);
- if (env.exception () == 0)
- {
- // get the size of the field
- size = param->size (env);
- if (env.exception () == 0)
- {
- switch (param->kind_)
- {
- case CORBA::tk_null:
- case CORBA::tk_void:
- break;
- case CORBA::tk_short:
- case CORBA::tk_ushort:
- *(CORBA::Short *) dest = *(CORBA::Short *) source;
- break;
- case CORBA::tk_long:
- case CORBA::tk_ulong:
- case CORBA::tk_float:
- case CORBA::tk_enum:
- *(CORBA::Long *) dest = *(CORBA::Long *) source;
- break;
- case CORBA::tk_double:
- case CORBA::tk_longlong:
- case CORBA::tk_ulonglong:
- *(CORBA::LongLong *) dest = *(CORBA::LongLong *) source;
- break;
- case CORBA::tk_boolean:
- *(CORBA::Boolean *) dest = *(CORBA::Boolean *) source;
- break;
- case CORBA::tk_char:
- case CORBA::tk_octet:
- *(CORBA::Char *) dest = *(CORBA::Char *) source;
- break;
- case CORBA::tk_longdouble:
- *(CORBA::LongDouble *) dest = *(CORBA::LongDouble *) source;
- break;
- case CORBA::tk_wchar:
- *(CORBA::WChar *) dest = *(CORBA::WChar *) source;
- break;
- case CORBA::tk_any:
- retval = TAO_Marshal_Any::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_TypeCode:
- retval = TAO_Marshal_TypeCode::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_Principal:
- retval = TAO_Marshal_Principal::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_objref:
- retval = TAO_Marshal_ObjRef::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_struct:
- retval = TAO_Marshal_Struct::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_union:
- retval = TAO_Marshal_Union::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_string:
- retval = TAO_Marshal_String::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_sequence:
- retval = TAO_Marshal_Sequence::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_array:
- retval = TAO_Marshal_Array::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_alias:
- retval = TAO_Marshal_Alias::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_except:
- retval = TAO_Marshal_Except::deep_copy (param, source, dest, env);
- break;
- case CORBA::tk_wstring:
- retval = TAO_Marshal_WString::deep_copy (param, source, dest, env);
- break;
- default:
- retval = CORBA::TypeCode::TRAVERSE_STOP;
- } // end of switch
- source = (char *) source + size;
- dest = (char *) dest + size;
- }
- else // exception computing size
- {
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // exception computing typecode
- {
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- } // end of loop
- if (retval == CORBA::TypeCode::TRAVERSE_CONTINUE)
- return CORBA::TypeCode::TRAVERSE_CONTINUE;
- else
- {
- env.exception (new CORBA::MARSHAL (CORBA::COMPLETED_MAYBE));
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // exception getting member count
- {
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
- }
- else // no typecode
- {
- env.exception (new CORBA::BAD_TYPECODE (CORBA::COMPLETED_MAYBE));
- dmsg ("TAO_Marshal_Struct::deep_copy detected error");
- return CORBA::TypeCode::TRAVERSE_STOP;
- }
-}
View Lorry Controller Status