diff options
Diffstat (limited to 'lib/orber/src/cdr_encode.erl')
| -rw-r--r-- | lib/orber/src/cdr_encode.erl | 1151 |
1 files changed, 1151 insertions, 0 deletions
diff --git a/lib/orber/src/cdr_encode.erl b/lib/orber/src/cdr_encode.erl new file mode 100644 index 0000000000..3ecb8833f5 --- /dev/null +++ b/lib/orber/src/cdr_encode.erl @@ -0,0 +1,1151 @@ +%%-------------------------------------------------------------------- +%% +%% %CopyrightBegin% +%% +%% Copyright Ericsson AB 1997-2009. All Rights Reserved. +%% +%% The contents of this file are subject to the Erlang Public License, +%% Version 1.1, (the "License"); you may not use this file except in +%% compliance with the License. You should have received a copy of the +%% Erlang Public License along with this software. If not, it can be +%% retrieved online at http://www.erlang.org/. +%% +%% Software distributed under the License is distributed on an "AS IS" +%% basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See +%% the License for the specific language governing rights and limitations +%% under the License. +%% +%% %CopyrightEnd% +%% +%% +%%----------------------------------------------------------------- +%% File: cdr_encode.erl +%% +%% Description: +%% This file contains all encoding functions for the CDR +%% format. +%% +%%----------------------------------------------------------------- +-module(cdr_encode). + +-include_lib("orber/include/corba.hrl"). +-include_lib("orber/src/orber_iiop.hrl"). + +%%----------------------------------------------------------------- +%% External exports +%%----------------------------------------------------------------- +-export([enc_giop_msg_type/1, + enc_request/1, enc_request_split/1, + enc_reply/1, enc_reply_split/1, + enc_type/3, enc_type/5, + enc_cancel_request/1, + enc_locate_request/1, + enc_locate_reply/1, + enc_close_connection/1, + enc_message_error/1, + enc_fragment/1, + enc_giop_message_header/5, + validate_request_body/1, + validate_reply_body/2]). + +%%----------------------------------------------------------------- +%% Internal exports +%%----------------------------------------------------------------- +-export([]). + +%%----------------------------------------------------------------- +%% Macros +%%----------------------------------------------------------------- +-define(DEBUG_LEVEL, 9). + +-define(ODD(N), (N rem 2) == 1). + +%%----------------------------------------------------------------- +%% External functions +%%----------------------------------------------------------------- +%%----------------------------------------------------------------- +%% Func: enc_giop_message_header/5 +%%----------------------------------------------------------------- +%% The header size is known so we know that the size will be aligned. +%% MessSize already includes the header length. +%%----------------------------------------------------------------- +enc_giop_message_header(#giop_env{version = {Major,Minor}}, MessType, + _Flags, MessSize, Message) -> + Type = enc_giop_msg_type(MessType), + %% The Flag handling must be fixed, i.e., it's not correct to only use '0'. + %% If IIOP-1.0 a boolean (FALSE == 0), otherwise, IIOP-1.1 or 1.2, + %% an octet. The octet bits represents: + %% * The least significant the byteorder (0 eq. big-endian) + %% * The second least significant indicates if the message is fragmented. + %% If set to 0 it's not fragmented. + %% * The most significant 6 bits are reserved. Hence, must be set to 0. + %% Since we currently don't support fragmented messages and we always + %% encode using big-endian it's ok to use '0' for now. + list_to_binary([ <<"GIOP",Major:8,Minor:8,0:8, + Type:8,MessSize:32/big-unsigned-integer>> | Message]). + +enc_byte_order(Env, Message) -> + enc_type('tk_boolean', Env, 'false', Message, 0). + +%%----------------------------------------------------------------- +%% Func: enc_parameters/2 +%%----------------------------------------------------------------- +enc_parameters(_, [], [], Message, Len) -> + {Message, Len}; +enc_parameters(_, [], P, _, _) -> + orber:dbg("[~p] cdr_encode:encode_parameters(~p); to many parameters.", + [?LINE, P], ?DEBUG_LEVEL), + corba:raise(#'MARSHAL'{minor=(?ORBER_VMCID bor 17), completion_status=?COMPLETED_MAYBE}); +enc_parameters(_, _, [], TC, _) -> + orber:dbg("[~p] cdr_encode:encode_parameters(~p); to few parameters.", + [?LINE, TC], ?DEBUG_LEVEL), + corba:raise(#'MARSHAL'{minor=(?ORBER_VMCID bor 17), completion_status=?COMPLETED_MAYBE}); +enc_parameters(Env, [PT1 |TypeList], [ P1 | Parameters], Message, Len) -> + {Message1, Len1} = enc_type(PT1, Env, P1, Message, Len), + enc_parameters(Env, TypeList, Parameters, Message1, Len1). + +%%----------------------------------------------------------------- +%% Func: enc_request/8 +%%----------------------------------------------------------------- +%% ## NEW IIOP 1.2 ## +enc_request(#giop_env{version = {1,2}} = Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len} = enc_request_id(Env, [], ?GIOP_HEADER_SIZE), + {Message1, Len1} = enc_response_flags(Env, Message, Len), + {Message2, Len2} = enc_reserved(Env, {0,0,0}, Message1, Len1), + {Message3, Len3} = enc_target_address(Env, Message2, Len2), + {Message4, Len4} = enc_operation(Env, Message3, Len3), + {Message5, Len5} = enc_service_context(Env, Message4, Len4), + {Message6, Len6} = enc_request_body(Env, Message5, Len5), + enc_giop_message_header(Env, 'request', Flags, Len6 - ?GIOP_HEADER_SIZE, + lists:reverse(Message6)); +enc_request(#giop_env{version = Version} = Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message0, Len0} = enc_service_context(Env, [], ?GIOP_HEADER_SIZE), + {Message, Len} = enc_request_id(Env, Message0, Len0), + {Message1, Len1} = enc_response(Env, Message, Len), + {Message1b, Len1b} = + if + Version /= {1,0} -> + enc_reserved(Env, {0,0,0}, Message1, Len1); + true -> + {Message1, Len1} + end, + {Message2, Len2} = enc_object_key(Env, Message1b, Len1b), + {Message3, Len3} = enc_operation(Env, Message2, Len2), + {Message4, Len4} = enc_principal(Env, Message3, Len3), + {Message5, Len5} = enc_request_body(Env, Message4, Len4), + enc_giop_message_header(Env, 'request', Flags, Len5 - ?GIOP_HEADER_SIZE, + lists:reverse(Message5)). + +%% ## NEW IIOP 1.2 ## +enc_request_split(#giop_env{version = {1,2}} = Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len} = enc_request_id(Env, [], ?GIOP_HEADER_SIZE), + {Message1, Len1} = enc_response_flags(Env, Message, Len), + {Message2, Len2} = enc_reserved(Env, {0,0,0}, Message1, Len1), + {Message3, Len3} = enc_target_address(Env, Message2, Len2), + {Message4, Len4} = enc_operation(Env, Message3, Len3), + {Message5, Len5} = enc_service_context(Env, Message4, Len4), + {Body, Len6} = enc_request_body(Env, [], Len5), + {lists:reverse(Message5), list_to_binary(lists:reverse(Body)), + Len5 - ?GIOP_HEADER_SIZE, Len6-Len5, Flags}; +enc_request_split(#giop_env{version = Version} = Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message0, Len0} = enc_service_context(Env, [], ?GIOP_HEADER_SIZE), + {Message, Len} = enc_request_id(Env, Message0, Len0), + {Message1, Len1} = enc_response(Env, Message, Len), + {Message1b, Len1b} = + if + Version /= {1,0} -> + enc_reserved(Env, {0,0,0}, Message1, Len1); + true -> + {Message1, Len1} + end, + {Message2, Len2} = enc_object_key(Env, Message1b, Len1b), + {Message3, Len3} = enc_operation(Env, Message2, Len2), + {Message4, Len4} = enc_principal(Env, Message3, Len3), + {Body, Len5} = enc_request_body(Env, [], Len4), + {lists:reverse(Message4), list_to_binary(lists:reverse(Body)), + Len4 - ?GIOP_HEADER_SIZE, Len5-Len4, Flags}. + +enc_principal(Env, Mess, Len) -> + enc_type({'tk_string', 0}, Env, atom_to_list(node()), Mess, Len). + +enc_operation(Env, Mess, Len) -> + enc_type({'tk_string', 0}, Env, atom_to_list(Env#giop_env.op), Mess, Len). + +enc_object_key(Env, Mess, Len) -> + enc_type({'tk_sequence', 'tk_octet', 0}, Env, Env#giop_env.objkey, Mess, Len). + +enc_reserved(Env, Reserved, Mess, Len) -> + enc_type({'tk_array', 'tk_octet', 3}, Env, Reserved, Mess, Len). + +enc_response(Env, Mess, Len) -> + enc_type('tk_boolean', Env, Env#giop_env.response_expected, Mess, Len). + +enc_request_id(Env, Mess, Len) -> + enc_type('tk_ulong', Env, Env#giop_env.request_id, Mess, Len). + +enc_service_context(Env, Message, Len) -> + Ctxs = enc_used_contexts(Env, Env#giop_env.ctx, []), + enc_type(?IOP_SERVICECONTEXT, Env, Ctxs, Message, Len). + +enc_used_contexts(_Env, [], Message) -> + Message; +enc_used_contexts(#giop_env{version = {1, 0}} = Env, + [#'IOP_ServiceContext'{context_id=?IOP_CodeSets}|T], Ctxs) -> + %% Not supported by 1.0, drop it. + enc_used_contexts(Env, T, Ctxs); +enc_used_contexts(Env, [#'IOP_ServiceContext'{context_id=?IOP_CodeSets, + context_data = CodeSetCtx}|T], + Ctxs) -> + %% Encode ByteOrder + {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Env, 0, [], 0), + {Bytes1, _Len1} = enc_type(?CONV_FRAME_CODESETCONTEXT, Env, CodeSetCtx, + Bytes0, Len0), + Bytes = list_to_binary(lists:reverse(Bytes1)), + enc_used_contexts(Env, T, + [#'IOP_ServiceContext'{context_id=?IOP_CodeSets, + context_data = Bytes}|Ctxs]); +enc_used_contexts(Env, [#'IOP_ServiceContext'{context_id=?IOP_BI_DIR_IIOP, + context_data = BiDirCtx}|T], + Ctxs) -> + %% Encode ByteOrder + {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Env, 0, [], 0), + {Bytes1, _Len1} = enc_type(?IIOP_BIDIRIIOPSERVICECONTEXT, Env, BiDirCtx, + Bytes0, Len0), + Bytes = list_to_binary(lists:reverse(Bytes1)), + enc_used_contexts(Env, T, + [#'IOP_ServiceContext'{context_id=?IOP_BI_DIR_IIOP, + context_data = Bytes}|Ctxs]); +enc_used_contexts(Env, [#'IOP_ServiceContext'{context_id=?IOP_FT_REQUEST, + context_data = Ctx}|T], + Ctxs) -> + %% Encode ByteOrder + {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Env, 0, [], 0), + {Bytes1, _Len1} = enc_type(?FT_FTRequestServiceContext, Env, Ctx, + Bytes0, Len0), + Bytes = list_to_binary(lists:reverse(Bytes1)), + enc_used_contexts(Env, T, + [#'IOP_ServiceContext'{context_id=?IOP_FT_REQUEST, + context_data = Bytes}|Ctxs]); +enc_used_contexts(Env, [#'IOP_ServiceContext'{context_id=?IOP_FT_GROUP_VERSION, + context_data = Ctx}|T], + Ctxs) -> + %% Encode ByteOrder + {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Env, 0, [], 0), + {Bytes1, _Len1} = enc_type(?FT_FTGroupVersionServiceContext, Env, Ctx, + Bytes0, Len0), + Bytes = list_to_binary(lists:reverse(Bytes1)), + enc_used_contexts(Env, T, + [#'IOP_ServiceContext'{context_id=?IOP_FT_GROUP_VERSION, + context_data = Bytes}|Ctxs]); +enc_used_contexts(Env, [#'IOP_ServiceContext'{context_id=?IOP_SecurityAttributeService, + context_data = Ctx}|T], + Ctxs) -> + %% Encode ByteOrder + {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Env, 0, [], 0), + {Bytes1, _Len1} = enc_type(?CSI_SASContextBody, Env, Ctx, + Bytes0, Len0), + Bytes = list_to_binary(lists:reverse(Bytes1)), + enc_used_contexts(Env, T, + [#'IOP_ServiceContext'{context_id=?IOP_SecurityAttributeService, + context_data = Bytes}|Ctxs]); +enc_used_contexts(Env, [#'IOP_ServiceContext'{context_id=?ORBER_GENERIC_CTX_ID, + context_data = {interface, _I}}|T], + Ctxs) -> + %% This shall not be forwarded. + enc_used_contexts(Env, T, Ctxs); +enc_used_contexts(Env, [#'IOP_ServiceContext'{context_id=?ORBER_GENERIC_CTX_ID, + context_data = {configuration, _O}}|T], + Ctxs) -> + %% This shall not be forwarded. + enc_used_contexts(Env, T, Ctxs); +enc_used_contexts(Env, [#'IOP_ServiceContext'{context_id=?ORBER_GENERIC_CTX_ID, + context_data = Ctx}|T], + Ctxs) -> + %% Encode ByteOrder + {Bytes0, Len0} = cdr_encode:enc_type('tk_octet', Env, 0, [], 0), + {Bytes1, _Len1} = enc_type(?ORBER_GENERIC_CTX, Env, + binary_to_list(term_to_binary(Ctx)), + Bytes0, Len0), + Bytes = list_to_binary(lists:reverse(Bytes1)), + enc_used_contexts(Env, T, + [#'IOP_ServiceContext'{context_id=?ORBER_GENERIC_CTX_ID, + context_data = Bytes}|Ctxs]); +enc_used_contexts(Env, [H|T], Ctxs) -> + enc_used_contexts(Env, T, [H|Ctxs]). + +%% ## NEW IIOP 1.2 ## +enc_target_address(#giop_env{objkey = TargetAddr} = Env, Mess, Len) + when is_record(TargetAddr, 'GIOP_TargetAddress') -> + enc_type(?TARGETADDRESS, Env, TargetAddr, Mess, Len); +enc_target_address(#giop_env{objkey = IORInfo} = Env, Mess, Len) + when is_record(IORInfo, 'GIOP_IORAddressingInfo') -> + enc_type(?TARGETADDRESS, Env, #'GIOP_TargetAddress'{label = ?GIOP_ReferenceAddr, + value = IORInfo}, + Mess, Len); +enc_target_address(#giop_env{objkey = TP} = Env, Mess, Len) + when is_record(TP, 'IOP_TaggedProfile') -> + enc_type(?TARGETADDRESS, Env, #'GIOP_TargetAddress'{label = ?GIOP_ProfileAddr, + value = TP}, + Mess, Len); +enc_target_address(#giop_env{objkey = ObjKey} = Env, Mess, Len) -> + enc_type(?TARGETADDRESS, Env, #'GIOP_TargetAddress'{label = ?GIOP_KeyAddr, + value = ObjKey}, + Mess, Len). + +%% FIX ME!! This is temporary, not proper flag handling. +enc_response_flags(#giop_env{response_expected = true} = Env, Mess, Len) -> + enc_type('tk_octet', Env, 3, Mess, Len); +enc_response_flags(#giop_env{response_expected = false} = Env, Mess, Len) -> + enc_type('tk_octet', Env, 0, Mess, Len). + +%%----------------------------------------------------------------- +%% Func: enc_request_body/5 +%%----------------------------------------------------------------- +enc_request_body(#giop_env{tc = {_, [], _}}, Message, Len) -> + %% This case is used to avoid adding alignment even though no body will be added. + {Message, Len}; +enc_request_body(#giop_env{version = {1,2}, + tc = {_RetType, InParameters, _OutParameters}, + parameters = Parameters} = Env, + Message, Len) -> + {Message1, Len1} = enc_align(Message, Len, 8), + enc_parameters(Env, InParameters, Parameters, Message1, Len1); +enc_request_body(#giop_env{tc = {_RetType, InParameters, _OutParameters}, + parameters = Parameters} = Env, + Message, Len) -> + enc_parameters(Env, InParameters, Parameters, Message, Len). + +%%----------------------------------------------------------------- +%% Func: validate_request_body/1 +%%----------------------------------------------------------------- +validate_request_body(#giop_env{tc = {_RetType, InParameters, _OutParameters}, + parameters = Parameters} = Env) -> + enc_parameters(Env, InParameters, Parameters, [], 0). + +%%----------------------------------------------------------------- +%% Func: enc_reply/6 +%%----------------------------------------------------------------- +%% ## NEW IIOP 1.2 ## +enc_reply(#giop_env{version = {1,2}} = Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len} = enc_request_id(Env, [], ?GIOP_HEADER_SIZE), + {Message1, Len1} = enc_reply_status(Env, Message, Len), + {Message2, Len2} = enc_service_context(Env, Message1, Len1), + {Message3, Len3} = enc_reply_body(Env, Message2, Len2), + enc_giop_message_header(Env, 'reply', Flags, Len3 - ?GIOP_HEADER_SIZE, + lists:reverse(Message3)); +enc_reply(Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len} = enc_service_context(Env, [], ?GIOP_HEADER_SIZE), + {Message1, Len1} = enc_request_id(Env, Message, Len), + {Message2, Len2} = enc_reply_status(Env, Message1, Len1), + {Message3, Len3} = enc_reply_body(Env, Message2, Len2), + enc_giop_message_header(Env, 'reply', Flags, Len3 - ?GIOP_HEADER_SIZE, + lists:reverse(Message3)). + +%% ## NEW IIOP 1.2 ## +enc_reply_split(#giop_env{version = {1,2}} = Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len0} = enc_request_id(Env, [], ?GIOP_HEADER_SIZE), + {Message1, Len1} = enc_reply_status(Env, Message, Len0), + {Message2, Len2} = enc_service_context(Env, Message1, Len1), + {Body, Len} = enc_reply_body(Env, [], Len2), + {lists:reverse(Message2), list_to_binary(lists:reverse(Body)), + Len2 - ?GIOP_HEADER_SIZE, Len-Len2, Flags}; +enc_reply_split(Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len0} = enc_service_context(Env, [], ?GIOP_HEADER_SIZE), + {Message1, Len1} = enc_request_id(Env, Message, Len0), + {Message2, Len2} = enc_reply_status(Env, Message1, Len1), + {Body, Len} = enc_reply_body(Env, [], Len2), + {lists:reverse(Message2), list_to_binary(lists:reverse(Body)), + Len2 - ?GIOP_HEADER_SIZE, Len-Len2, Flags}. + +enc_reply_status(Env, Mess, Len) -> + L = enc_giop_reply_status_type(Env#giop_env.reply_status), + enc_type('tk_ulong', Env, L, Mess, Len). + +%%----------------------------------------------------------------- +%% Func: enc_reply_body/6 +%%----------------------------------------------------------------- +enc_reply_body(#giop_env{tc = {'tk_void', _, []}, result = ok, + parameters = []}, Message, Len) -> + %% This case is mainly to be able to avoid adding alignment for + %% IIOP-1.2 messages if the body should be empty, i.e., void return value and + %% no out parameters. + {Message, Len}; +enc_reply_body(#giop_env{version = {1,2}, + tc = {RetType, _InParameters, OutParameters}, + parameters = Parameters, result = Result} = Env, + Message, Len) -> + {Message1, Len1} = enc_align(Message, Len, 8), + {Message2, Len2} = enc_type(RetType, Env, Result, Message1, Len1), + enc_parameters(Env, OutParameters, Parameters, Message2, Len2); +enc_reply_body(#giop_env{tc = {RetType, _InParameters, OutParameters}, + parameters = Parameters, result = Result} = Env, + Message, Len) -> + {Message1, Len1} = enc_type(RetType, Env, Result, Message, Len), + enc_parameters(Env, OutParameters, Parameters, Message1, Len1). + + +%%----------------------------------------------------------------- +%% Func: validate_reply_body/3 +%%----------------------------------------------------------------- +validate_reply_body(Env, {'EXCEPTION', Exception}) -> + {TypeOfException, ExceptionTypeCode, NewExc} = + orber_exceptions:get_def(Exception), + {'tk_except', TypeOfException, ExceptionTypeCode, + (catch enc_reply_body(Env#giop_env{tc = {ExceptionTypeCode, [], []}, + result = NewExc, parameters = []}, [], 0))}; +validate_reply_body(#giop_env{tc = {_RetType, _InParameters, []}} = Env, Reply) -> + enc_reply_body(Env#giop_env{result = Reply}, [], 0); +validate_reply_body(Env, Reply) when is_tuple(Reply) -> + [Result|Parameters] = tuple_to_list(Reply), + enc_reply_body(Env#giop_env{result = Result, parameters = Parameters}, [], 0); +validate_reply_body(Env, Reply) -> + enc_reply_body(Env#giop_env{result = Reply}, [], 0). + +%%----------------------------------------------------------------- +%% Func: enc_cancel_request/2 +%%----------------------------------------------------------------- +enc_cancel_request(Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len} = enc_request_id(Env, [], ?GIOP_HEADER_SIZE), + enc_giop_message_header(Env, 'cancel_request', Flags, Len - ?GIOP_HEADER_SIZE, + lists:reverse(Message)). + +%%----------------------------------------------------------------- +%% Func: enc_locate_request/3 +%%----------------------------------------------------------------- +%% ## NEW IIOP 1.2 ## +enc_locate_request(#giop_env{version = {1,2}} = Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len} = enc_request_id(Env, [], ?GIOP_HEADER_SIZE), + {Message1, Len1} = enc_target_address(Env, Message, Len), + enc_giop_message_header(Env, 'locate_request', Flags, Len1-?GIOP_HEADER_SIZE, + lists:reverse(Message1)); +enc_locate_request(Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len} = enc_request_id(Env, [], ?GIOP_HEADER_SIZE), + {Message1, Len1} = enc_object_key(Env, Message, Len), + enc_giop_message_header(Env, 'locate_request', Flags, Len1-?GIOP_HEADER_SIZE, + lists:reverse(Message1)). + +%%----------------------------------------------------------------- +%% Func: enc_locate_reply +%%----------------------------------------------------------------- +%% No forward etc. Just encode the status. +enc_locate_reply(#giop_env{tc = undefined} = Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len} = enc_request_id(Env, [], ?GIOP_HEADER_SIZE), + {Message1, Len1} = enc_locate_status(Env, Message, Len), + enc_giop_message_header(Env, 'locate_reply', Flags, Len1 - ?GIOP_HEADER_SIZE, + lists:reverse(Message1)); +enc_locate_reply(Env) -> + Flags = 1, %% LTH Not correct, just placeholder + {Message, Len} = enc_request_id(Env, [], ?GIOP_HEADER_SIZE), + {Message1, Len1} = enc_locate_status(Env, Message, Len), + {Message2, Len2} = enc_locate_reply_body(Env, Message1, Len1), + enc_giop_message_header(Env, 'locate_reply', Flags, Len2 - ?GIOP_HEADER_SIZE, + lists:reverse(Message2)). + +enc_locate_reply_body(#giop_env{tc = TC, result = Data} = Env, Message, Len) -> + %% In CORBA-2.3.1 the LocateReply body didn't align the body (8-octet + %% boundry) for IIOP-1.2. This have been changed in later specs. + %% Un-comment the line below when we want to be CORBA-2.4 compliant. + %% But in CORB-2.6 this was changed once again (i.e. no alignment). + %% The best solution is to keep it as is. + enc_type(TC, Env, Data, Message, Len). + +enc_locate_status(Env, Mess, Len) -> + L = enc_giop_locate_status_type(Env#giop_env.reply_status), + enc_type('tk_ulong', Env, L, Mess, Len). +%%----------------------------------------------------------------- +%% Func: enc_close_connection/1 +%%----------------------------------------------------------------- +enc_close_connection(Env) -> + Flags = 1, %% LTH Not correct, just placeholder + enc_giop_message_header(Env, 'close_connection', Flags, 0, []). + +%%----------------------------------------------------------------- +%% Func: enc_message_error/1 +%%----------------------------------------------------------------- +enc_message_error(Env) -> + Flags = 1, %% LTH Not correct, just placeholder + enc_giop_message_header(Env, 'message_error', Flags, 0, []). + +%%----------------------------------------------------------------- +%% Func: enc_fragment/1 +%%----------------------------------------------------------------- +enc_fragment(Env) -> + Flags = 1, %% LTH Not correct, just placeholder + enc_giop_message_header(Env, 'fragment', Flags, 0, []). + +%%----------------------------------------------------------------- +%% Func: enc_giop_msg_type +%% Args: An integer message type code +%% Returns: An atom which is the message type code name +%%----------------------------------------------------------------- +enc_giop_msg_type('request') -> + 0; +enc_giop_msg_type('reply') -> + 1; +enc_giop_msg_type('cancel_request') -> + 2; +enc_giop_msg_type('locate_request') -> + 3; +enc_giop_msg_type('locate_reply') -> + 4; +enc_giop_msg_type('close_connection') -> + 5; +enc_giop_msg_type('message_error') -> + 6; +enc_giop_msg_type('fragment') -> + 7. + + +%%----------------------------------------------------------------- +%% Func: enc_giop_reply_status_type +%% Args: An atom which is the reply status +%% Returns: An integer status code +%%----------------------------------------------------------------- +enc_giop_reply_status_type(?NO_EXCEPTION) -> + 0; +enc_giop_reply_status_type(?USER_EXCEPTION) -> + 1; +enc_giop_reply_status_type(?SYSTEM_EXCEPTION) -> + 2; +enc_giop_reply_status_type('location_forward') -> + 3; +%% ## NEW IIOP 1.2 ## +enc_giop_reply_status_type('location_forward_perm') -> + 4; +enc_giop_reply_status_type('needs_addressing_mode') -> + 5. + +%%----------------------------------------------------------------- +%% Func: enc_giop_locate_status_type +%% Args: An integer status code +%% Returns: An atom which is the reply status +%%----------------------------------------------------------------- +enc_giop_locate_status_type('unknown_object') -> + 0; +enc_giop_locate_status_type('object_here') -> + 1; +enc_giop_locate_status_type('object_forward') -> + 2; +%% ## NEW IIOP 1.2 ## +enc_giop_locate_status_type('object_forward_perm') -> + 3; +enc_giop_locate_status_type('loc_system_exception') -> + 4; +enc_giop_locate_status_type('loc_needs_addressing_mode') -> + 5. + +%%----------------------------------------------------------------- +%% Func: enc_type/3 +%%----------------------------------------------------------------- +enc_type(Env, TypeCode, Value) -> + {Bytes, _Len} = enc_type(TypeCode, Env, Value, [], 0), + list_to_binary(lists:reverse(Bytes)). + +%%----------------------------------------------------------------- +%% Func: enc_type/5 +%%----------------------------------------------------------------- +enc_type('tk_null', _Env, null, Bytes, Len) -> + {Bytes, Len}; +enc_type('tk_void', _Env, ok, Bytes, Len) -> + {Bytes, Len}; +enc_type('tk_short', _Env, Value, Bytes, Len) -> + {Rest, Len1} = enc_align(Bytes, Len, 2), + {cdrlib:enc_short(Value, Rest), Len1 + 2}; +enc_type('tk_long', _Env, Value, Bytes, Len) -> + {Rest, Len1} = enc_align(Bytes, Len, 4), + {cdrlib:enc_long(Value, Rest ), Len1 + 4}; +enc_type('tk_longlong', _Env, Value, Bytes, Len) -> + {Rest, Len1} = enc_align(Bytes, Len, 8), + {cdrlib:enc_longlong(Value, Rest ), Len1 + 8}; +enc_type('tk_ushort', _Env, Value, Bytes, Len) -> + {Rest, Len1} = enc_align(Bytes, Len, 2), + {cdrlib:enc_unsigned_short(Value, Rest), Len1 + 2}; +enc_type('tk_ulong', _Env, Value, Bytes, Len) -> + {Rest, Len1} = enc_align(Bytes, Len, 4), + {cdrlib:enc_unsigned_long(Value, Rest), Len1 + 4}; +enc_type('tk_ulonglong', _Env, Value, Bytes, Len) -> + {Rest, Len1} = enc_align(Bytes, Len, 8), + {cdrlib:enc_unsigned_longlong(Value, Rest), Len1 + 8}; +enc_type('tk_float', _Env, Value, Bytes, Len) -> + {Rest, Len1} = enc_align(Bytes, Len, 4), + {cdrlib:enc_float(Value, Rest), Len1 + 4}; +enc_type('tk_double', _Env, Value, Bytes, Len) -> + {Rest, Len1} = enc_align(Bytes, Len, 8), + {cdrlib:enc_double(Value, Rest), Len1 + 8}; +enc_type('tk_boolean', _Env, Value, Bytes, Len) -> + {cdrlib:enc_bool(Value, Bytes), Len + 1}; +enc_type('tk_char', _Env, Value, Bytes, Len) -> + {cdrlib:enc_char(Value, Bytes), Len + 1}; +%% The wchar decoding can be 1, 2 or 4 bytes but for now we only accept 2. +enc_type('tk_wchar', #giop_env{version = {1,2}}, Value, Bytes, Len) -> + Bytes1 = cdrlib:enc_octet(2, Bytes), + {cdrlib:enc_unsigned_short(Value, Bytes1), Len + 3}; +enc_type('tk_wchar', _Env, Value, Bytes, Len) -> + {Rest, Len1} = enc_align(Bytes, Len, 2), + {cdrlib:enc_unsigned_short(Value, Rest), Len1 + 2}; +enc_type('tk_octet', _Env, Value, Bytes, Len) -> + {cdrlib:enc_octet(Value, Bytes), Len + 1}; +enc_type('tk_any', Env, Any, Bytes, Len) when is_record(Any, any) -> + {Rest, Len1} = enc_type('tk_TypeCode', Env, Any#any.typecode, Bytes, Len), + enc_type(Any#any.typecode, Env, Any#any.value, Rest, Len1); +enc_type('tk_TypeCode', Env, Value, Bytes, Len) -> + enc_type_code(Value, Env, Bytes, Len); +enc_type('tk_Principal', Env, Value, Bytes, Len) -> + %% Set MaxLength no 0 (i.e. unlimited). + enc_sequence(Env, Value, 0, 'tk_octet', Bytes, Len); +enc_type({'tk_objref', _IFRId, Name}, Env, Value, Bytes, Len) -> + enc_objref(Env, Name,Value, Bytes, Len); +enc_type({'tk_struct', _IFRId, _Name, ElementList}, Env, Value, Bytes, Len) -> + enc_struct(Env, Value, ElementList, Bytes, Len); +enc_type({'tk_union', _IFRId, _Name, DiscrTC, Default, ElementList}, + Env, Value, Bytes, Len) -> + enc_union(Env, Value, DiscrTC, Default, ElementList, Bytes, Len); +enc_type({'tk_enum', _IFRId, _Name, ElementList}, _Env, Value, Bytes, Len) -> + {Rest, Len1} = enc_align(Bytes, Len, 4), + {cdrlib:enc_enum(atom_to_list(Value), ElementList, Rest), Len1 + 4}; +enc_type({'tk_string', MaxLength}, Env, Value, Bytes, Len) -> + enc_string(Env, Value, MaxLength, Bytes, Len); +enc_type({'tk_wstring', MaxLength}, Env, Value, Bytes, Len) -> + enc_wstring(Env, Value, MaxLength, Bytes, Len); +enc_type({'tk_sequence', ElemTC, MaxLength}, Env, Value, Bytes, Len) -> + enc_sequence(Env, Value, MaxLength, ElemTC, Bytes, Len); +enc_type({'tk_array', ElemTC, Size}, Env, Value, Bytes, Len) -> + enc_array(Env, Value, Size, ElemTC, Bytes, Len); +enc_type({'tk_alias', _IFRId, _Name, TC}, Env, Value, Bytes, Len) -> + enc_type(TC, Env, Value, Bytes, Len); +enc_type({'tk_except', IFRId, Name, ElementList}, Env, Value, Bytes, Len) -> + enc_exception(Env, Name, IFRId, Value, ElementList, Bytes, Len); +enc_type({'tk_fixed', Digits, Scale}, Env, Value, Bytes, Len) -> + enc_fixed(Env, Digits, Scale, Value, Bytes, Len); +enc_type(Type, _, Value, _, _) -> + orber:dbg("[~p] cdr_encode:type(~p, ~p)~n" + "Incorrect TypeCode or unsupported type.", + [?LINE, Type, Value], ?DEBUG_LEVEL), + corba:raise(#'MARSHAL'{minor=(?ORBER_VMCID bor 13), completion_status=?COMPLETED_MAYBE}). + + + + +%%----------------------------------------------------------------- +%% Func: enc_fixed +%%----------------------------------------------------------------- +%% Digits eq. total number of digits. +%% Scale eq. position of the decimal point. +%% E.g. fixed<5,2> - "123.45" eq. #fixed{digits = 5, scale = 2, value = 12345} +%% E.g. fixed<4,2> - "12.34" eq. #fixed{digits = 4, scale = 2, value = 1234} +%% These are encoded as: +%% ## <5,2> ## ## <4,2> ## +%% 1,2 0,1 eq. 1 octet +%% 3,4 2,3 +%% 5,0xC 4,0xC +%% +%% Each number is encoded as a half-octet. Note, for <4,2> a zero is +%% added first to to be able to create "even" octets. +enc_fixed(Env, Digits, Scale, + #fixed{digits = Digits, scale = Scale, value = Value}, Bytes, Len) + when is_integer(Value) andalso is_integer(Digits) andalso is_integer(Scale) + andalso Digits < 32 andalso Digits >= Scale -> + %% This isn't very efficient and we should improve it before supporting it + %% officially. + Odd = ?ODD(Digits), + case integer_to_list(Value) of + [$-|ValueList] when Odd == true -> + Padded = lists:duplicate((Digits-length(ValueList)), 0) ++ ValueList, + enc_fixed_2(Env, Digits, Scale, Padded, + Bytes, Len, ?FIXED_NEGATIVE); + [$-|ValueList] -> + Padded = lists:duplicate((Digits-length(ValueList)), 0) ++ ValueList, + enc_fixed_2(Env, Digits, Scale, [0|Padded], + Bytes, Len, ?FIXED_NEGATIVE); + ValueList when Odd == true -> + Padded = lists:duplicate((Digits-length(ValueList)), 0) ++ ValueList, + enc_fixed_2(Env, Digits, Scale, Padded, + Bytes, Len, ?FIXED_POSITIVE); + ValueList -> + Padded = lists:duplicate((Digits-length(ValueList)), 0) ++ ValueList, + enc_fixed_2(Env, Digits, Scale, [0|Padded], + Bytes, Len, ?FIXED_POSITIVE) + end; +enc_fixed(_Env, Digits, Scale, Fixed, _Bytes, _Len) -> + orber:dbg("[~p] cdr_encode:enc_fixed(~p, ~p, ~p)~n" + "The supplied fixed type incorrect. Check that the 'digits' and 'scale' field~n" + "match the definition in the IDL-specification. The value field must be~n" + "a list of Digits lenght.", + [?LINE, Digits, Scale, Fixed], ?DEBUG_LEVEL), + corba:raise(#'MARSHAL'{completion_status=?COMPLETED_MAYBE}). + +enc_fixed_2(_Env, _Digits, _Scale, [D1], Bytes, Len, Sign) -> + {[<<D1:4,Sign:4>>|Bytes], Len+1}; +enc_fixed_2(Env, Digits, Scale, [D1, D2|Ds], Bytes, Len, Sign) -> + %% We could convert the ASCII-value to digit values but the bit-syntax will + %% truncate it correctly. + enc_fixed_2(Env, Digits, Scale, Ds, [<<D1:4,D2:4>> | Bytes], Len+1, Sign); +enc_fixed_2(_Env, Digits, Scale, Value, _Bytes, _Len, Sign) -> + orber:dbg("[~p] cdr_encode:enc_fixed_2(~p, ~p, ~p, ~p)~n" + "The supplied fixed type incorrect. Most likely the 'digits' field don't match the~n" + "supplied value. Hence, check that the value is correct.", + [?LINE, Digits, Scale, Value, Sign], ?DEBUG_LEVEL), + corba:raise(#'MARSHAL'{completion_status=?COMPLETED_MAYBE}). + + + +%%----------------------------------------------------------------- +%% Func: enc_sequence/5 +%%----------------------------------------------------------------- +%% This is a special case used when encoding encapsualted data, i.e., contained +%% in an octet-sequence. +enc_sequence(_Env, Sequence, MaxLength, 'tk_octet', Bytes, Len) + when is_binary(Sequence) -> + {ByteSequence, Len1} = enc_align(Bytes, Len, 4), + Size = size(Sequence), + if + Size > MaxLength, MaxLength > 0 -> + orber:dbg("[~p] cdr_encode:enc_sequnce(~p, ~p). Sequence exceeds max.", + [?LINE, Sequence, MaxLength], ?DEBUG_LEVEL), + corba:raise(#'MARSHAL'{minor=(?ORBER_VMCID bor 19), + completion_status=?COMPLETED_MAYBE}); + true -> + ByteSequence1 = cdrlib:enc_unsigned_long(Size, ByteSequence), + {[Sequence |ByteSequence1], Len1 + 4 + Size} + end; +enc_sequence(Env, Sequence, MaxLength, TypeCode, Bytes, Len) -> + Length = length(Sequence), + if + Length > MaxLength, MaxLength > 0 -> + orber:dbg("[~p] cdr_encode:enc_sequnce(~p, ~p). Sequence exceeds max.", + [?LINE, Sequence, MaxLength], ?DEBUG_LEVEL), + corba:raise(#'MARSHAL'{minor=(?ORBER_VMCID bor 19), + completion_status=?COMPLETED_MAYBE}); + true -> + {ByteSequence, Len1} = enc_align(Bytes, Len, 4), + ByteSequence1 = cdrlib:enc_unsigned_long(Length, ByteSequence), + enc_sequence1(Env, Sequence, TypeCode, ByteSequence1, Len1 + 4) + end. + +%%----------------------------------------------------------------- +%% Func: enc_sequence1/4 +%%----------------------------------------------------------------- +enc_sequence1(_Env, [], _TypeCode, Bytes, Len) -> + {Bytes, Len}; +enc_sequence1(_Env, CharSeq, 'tk_char', Bytes, Len) -> + {[list_to_binary(CharSeq) |Bytes], Len + length(CharSeq)}; +enc_sequence1(_Env, OctetSeq, 'tk_octet', Bytes, Len) -> + {[list_to_binary(OctetSeq) |Bytes], Len + length(OctetSeq)}; +enc_sequence1(Env, [Object| Rest], TypeCode, Bytes, Len) -> + {ByteSequence, Len1} = enc_type(TypeCode, Env, Object, Bytes, Len), + enc_sequence1(Env, Rest, TypeCode, ByteSequence, Len1). + +%%----------------------------------------------------------------- +%% Func: enc_array/4 +%%----------------------------------------------------------------- +enc_array(Env, Array, Size, TypeCode, Bytes, Len) when size(Array) == Size -> + Sequence = tuple_to_list(Array), + enc_sequence1(Env, Sequence, TypeCode, Bytes, Len); +enc_array(_,Array, Size, _, _, _) -> + orber:dbg("[~p] cdr_encode:enc_array(~p, ~p). Incorrect size.", + [?LINE, Array, Size], ?DEBUG_LEVEL), + corba:raise(#'MARSHAL'{minor=(?ORBER_VMCID bor 15), completion_status=?COMPLETED_MAYBE}). + +%%----------------------------------------------------------------- +%% Func: enc_string/4 +%%----------------------------------------------------------------- +enc_string(_Env, String, MaxLength, Bytes, Len) -> + StrLen = length(String), + if + StrLen > MaxLength, MaxLength > 0 -> + orber:dbg("[~p] cdr_encode:enc_string(~p, ~p). String exceeds max.", + [?LINE, String, MaxLength], ?DEBUG_LEVEL), + corba:raise(#'MARSHAL'{minor=(?ORBER_VMCID bor 16), + completion_status=?COMPLETED_MAYBE}); + true -> + {ByteSequence, Len1} = enc_align(Bytes, Len, 4), + ByteSequence1 = cdrlib:enc_unsigned_long(StrLen + 1, ByteSequence), + {cdrlib:enc_octet(0, [String | ByteSequence1]), Len1 + StrLen + 5} + end. + + +%%----------------------------------------------------------------- +%% Func: enc_wstring/4 +%%----------------------------------------------------------------- +enc_wstring(#giop_env{version = {1,2}} = Env, String, MaxLength, Bytes, Len) -> + %% Encode the length of the string (ulong). + {Bytes1, Len1} = enc_align(Bytes, Len, 4), + %% For IIOP-1.2 the length is the total number of octets. Hence, since the wchar's + %% we accepts is encoded as <<255, 255>> the total size is 2*length of the list. + ListLen = length(String), + if + ListLen > MaxLength, MaxLength > 0 -> + corba:raise(#'MARSHAL'{minor=(?ORBER_VMCID bor 16), + completion_status=?COMPLETED_MAYBE}); + true -> + StrLen = ListLen * 2, + Bytes2 = cdrlib:enc_unsigned_long(StrLen, Bytes1), + %% For IIOP-1.2 no terminating null character is used. + enc_sequence1(Env, String, 'tk_ushort', Bytes2, Len1+4) + end; +enc_wstring(Env, String, MaxLength, Bytes, Len) -> + %% Encode the length of the string (ulong). + {Bytes1, Len1} = enc_align(Bytes, Len, 4), + ListLen = length(String), + if + ListLen > MaxLength, MaxLength > 0 -> + corba:raise(#'MARSHAL'{minor=(?ORBER_VMCID bor 16), + completion_status=?COMPLETED_MAYBE}); + true -> + StrLen = ListLen + 1, + Bytes2 = cdrlib:enc_unsigned_long(StrLen, Bytes1), + {Bytes3, Len3} = enc_sequence1(Env, String, 'tk_wchar', Bytes2, Len1+4), + %% The terminating null character is also a wchar. + {cdrlib:enc_unsigned_short(0, Bytes3), Len3+2} + end. + + +%%----------------------------------------------------------------- +%% Func: enc_union/5 +%%----------------------------------------------------------------- +enc_union(Env, {_, Label, Value}, DiscrTC, Default, TypeCodeList, Bytes, Len) -> + {ByteSequence, Len1} = enc_type(DiscrTC, Env, Label, Bytes, Len), + Label2 = stringify_enum(DiscrTC,Label), + enc_union2(Env, {Label2, Value},TypeCodeList, Default, + ByteSequence, Len1, undefined). + +enc_union2(_Env, _What, [], Default, Bytes, Len, _) when Default < 0 -> + {Bytes, Len}; +enc_union2(Env, {_, Value}, [], _Default, Bytes, Len, Type) -> + enc_type(Type, Env, Value, Bytes, Len); +enc_union2(Env, {Label,Value} ,[{Label, _Name, Type} |_List], + _Default, Bytes, Len, _) -> + enc_type(Type, Env, Value, Bytes, Len); +enc_union2(Env, Union ,[{default, _Name, Type} |List], Default, Bytes, Len, _) -> + enc_union2(Env, Union, List, Default, Bytes, Len, Type); +enc_union2(Env, Union,[_ | List], Default, Bytes, Len, DefaultType) -> + enc_union2(Env, Union, List, Default, Bytes, Len, DefaultType). + +stringify_enum({tk_enum, _,_,_}, Label) -> + atom_to_list(Label); +stringify_enum(_, Label) -> + Label. +%%----------------------------------------------------------------- +%% Func: enc_struct/4 +%%----------------------------------------------------------------- +enc_struct(Env, Struct, TypeCodeList, Bytes, Len) -> + [_Name | StructList] = tuple_to_list(Struct), + enc_struct1(Env, StructList, TypeCodeList, Bytes, Len). + +enc_struct1(_Env, [], [], Bytes, Len) -> + {Bytes, Len}; +enc_struct1(Env, [Object | Rest], [{_ElemName, ElemType} | TypeCodeList], Bytes, + Len) -> + {ByteSequence, Len1} = enc_type(ElemType, Env, Object, Bytes, Len), + enc_struct1(Env, Rest, TypeCodeList, ByteSequence, Len1). + +%%----------------------------------------------------------------- +%% Func: enc_objref/4 +%%----------------------------------------------------------------- +enc_objref(Env, _Name, Value, Bytes, Len) -> + iop_ior:code(Env, Value, Bytes, Len). + +%%----------------------------------------------------------------- +%% Func: enc_exception/5 +%%----------------------------------------------------------------- +enc_exception(Env, _Name, IFRId, Value, ElementList, Bytes, Len) -> + [_Name1, _TypeId | Args] = tuple_to_list(Value), + {Bytes1, Len1} = enc_type({'tk_string', 0}, Env, IFRId , Bytes, Len), + enc_exception_1(Env, Args, ElementList, Bytes1, Len1). + +enc_exception_1(_Env, [], [], Bytes, Len) -> + {Bytes, Len}; +enc_exception_1(Env, [Arg |Args], [{_ElemName, ElemType} |ElementList], + Bytes, Len) -> + {Bytes1, Len1} = enc_type(ElemType, Env, Arg, Bytes, Len), + enc_exception_1(Env, Args, ElementList, Bytes1, Len1). + + +%%----------------------------------------------------------------- +%% Func: enc_type_code/3 +%%----------------------------------------------------------------- +enc_type_code('tk_null', Env, Message, Len) -> + enc_type('tk_ulong', Env, 0, Message, Len); +enc_type_code('tk_void', Env, Message, Len) -> + enc_type('tk_ulong', Env, 1, Message, Len); +enc_type_code('tk_short', Env, Message, Len) -> + enc_type('tk_ulong', Env, 2, Message, Len); +enc_type_code('tk_long', Env, Message, Len) -> + enc_type('tk_ulong', Env, 3, Message, Len); +enc_type_code('tk_longlong', Env, Message, Len) -> + enc_type('tk_ulong', Env, 23, Message, Len); +enc_type_code('tk_longdouble', Env, Message, Len) -> + enc_type('tk_ulong', Env, 25, Message, Len); +enc_type_code('tk_ushort', Env, Message, Len) -> + enc_type('tk_ulong', Env, 4, Message, Len); +enc_type_code('tk_ulong', Env, Message, Len) -> + enc_type('tk_ulong', Env, 5, Message, Len); +enc_type_code('tk_ulonglong', Env, Message, Len) -> + enc_type('tk_ulong', Env, 24, Message, Len); +enc_type_code('tk_float', Env, Message, Len) -> + enc_type('tk_ulong', Env, 6, Message, Len); +enc_type_code('tk_double', Env, Message, Len) -> + enc_type('tk_ulong', Env, 7, Message, Len); +enc_type_code('tk_boolean', Env, Message, Len) -> + enc_type('tk_ulong', Env, 8, Message, Len); +enc_type_code('tk_char', Env, Message, Len) -> + enc_type('tk_ulong', Env, 9, Message, Len); +enc_type_code('tk_wchar', Env, Message, Len) -> + enc_type('tk_ulong', Env, 26, Message, Len); +enc_type_code('tk_octet', Env, Message, Len) -> + enc_type('tk_ulong', Env, 10, Message, Len); +enc_type_code('tk_any', Env, Message, Len) -> + enc_type('tk_ulong', Env, 11, Message, Len); +enc_type_code('tk_TypeCode', Env, Message, Len) -> + enc_type('tk_ulong', Env, 12, Message, Len); +enc_type_code('tk_Principal', Env, Message, Len) -> + enc_type('tk_ulong', Env, 13, Message, Len); +enc_type_code({'tk_objref', RepId, Name}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 14, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", [{"repository ID", {'tk_string', 0}}, + {"name", {'tk_string', 0}}]}, + Env, + {"", RepId, Name}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_struct', RepId, SimpleName, ElementList}, Env, Message, Len) -> + %% Using SimpleName should be enough (and we avoid some overhead). + %% Name = ifrid_to_name(RepId), + {Message1, Len1} = enc_type('tk_ulong', Env, 15, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", [{"repository ID", {'tk_string', 0}}, + {"name", {'tk_string', 0}}, + {"element list", + {'tk_sequence', {'tk_struct', "","", + [{"member name", {'tk_string', 0}}, + {"member type", 'tk_TypeCode'}]}, + 0}}]}, + Env, + {"", RepId, SimpleName, + lists:map(fun({N,T}) -> {"",N,T} end, ElementList)}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_union', RepId, Name, DiscrTC, Default, ElementList}, + Env, Message, Len) -> + NewElementList = + case check_enum(DiscrTC) of + true -> + lists:map(fun({L,N,T}) -> {"",list_to_atom(L),N,T} end, ElementList); + false -> + lists:map(fun({L,N,T}) -> {"",L,N,T} end, ElementList) + end, + {Message1, Len1} = enc_type('tk_ulong', Env, 16, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", [{"repository ID", {'tk_string', 0}}, + {"name", {'tk_string', 0}}, + {"discriminant type", 'tk_TypeCode'}, + {"default used", 'tk_long'}, + {"element list", + {'tk_sequence', {'tk_struct', "","", + [{"label value", DiscrTC}, + {"member name", {'tk_string', 0}}, + {"member type", 'tk_TypeCode'}]}, + 0}}]}, + Env, + {"", RepId, Name, DiscrTC, Default, NewElementList}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_enum', RepId, Name, ElementList}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 17, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", [{"repository ID", {'tk_string', 0}}, + {"name", {'tk_string', 0}}, + {"element list", + {'tk_sequence', {'tk_string', 0}, 0}}]}, + Env, + {"", RepId, Name, ElementList}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_string', MaxLength}, Env, Message, Len) -> + enc_type({'tk_struct', "", "", [{"TCKind", 'tk_ulong'}, + {"max length", 'tk_ulong'}]}, + Env, + {"", 18, MaxLength}, + Message, Len); +enc_type_code({'tk_wstring', MaxLength}, Env, Message, Len) -> + enc_type({'tk_struct', "", "", [{"TCKind", 'tk_ulong'}, + {"max length", 'tk_ulong'}]}, + Env, + {"", 27, MaxLength}, + Message, Len); +enc_type_code({'tk_sequence', ElemTC, MaxLength}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 19, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", [{"element type", 'tk_TypeCode'}, + {"max length", 'tk_ulong'}]}, + Env, + {"", ElemTC, MaxLength}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_array', ElemTC, Length}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 20, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", [{"element type", 'tk_TypeCode'}, + {"length", 'tk_ulong'}]}, + Env, + {"", ElemTC, Length}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_alias', RepId, Name, TC}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 21, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", [{"repository ID", {'tk_string', 0}}, + {"name", {'tk_string', 0}}, + {"TypeCode", 'tk_TypeCode'}]}, + Env, + {"", RepId, Name, TC}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_except', RepId, Name, ElementList}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 22, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", [{"repository ID", {'tk_string', 0}}, + {"name", {'tk_string', 0}}, + {"element list", + {'tk_sequence', + {'tk_struct', "", "", + [{"member name", {'tk_string', 0}}, + {"member type", 'tk_TypeCode'}]}, 0}}]}, + Env, + {"", RepId, Name, + lists:map(fun({N,T}) -> {"",N,T} end, ElementList)}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_fixed', Digits, Scale}, Env, Message, Len) -> + enc_type({'tk_struct', "", "", [{"TCKind", 'tk_ulong'}, + {"digits", 'tk_ushort'}, + {"scale", 'tk_short'}]}, + Env, + {"", 28, Digits, Scale}, + Message, Len); +enc_type_code({'tk_value', RepId, Name, ValueModifier, TC, ElementList}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 29, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", + [{"repository ID", {'tk_string', 0}}, + {"name", {'tk_string', 0}}, + {"ValueModifier", 'tk_short'}, + {"TypeCode", 'tk_TypeCode'}, + {"element list", + {'tk_sequence', + {'tk_struct', "","", + [{"member name", {'tk_string', 0}}, + {"member type", 'tk_TypeCode'}, + {"Visibility", 'tk_short'}]}, + 0}}]}, + Env, + {"", RepId, Name, ValueModifier, TC, + lists:map(fun({N,T,V}) -> {"",N,T,V} end, ElementList)}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_value_box', RepId, Name, TC}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 30, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", + [{"repository ID", {'tk_string', 0}}, + {"name", {'tk_string', 0}}, + {"TypeCode", 'tk_TypeCode'}]}, + Env, + {"", RepId, Name, TC}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_native', RepId, Name}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 31, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", + [{"repository ID", {'tk_string', 0}}, + {"name", {'tk_string', 0}}]}, + Env, + {"", RepId, Name}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_abstract_interface', RepId, Name}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 32, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", + [{"RepositoryId", {'tk_string', 0}}, + {"name", {'tk_string', 0}}]}, + Env, + {"", RepId, Name}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'tk_local_interface', RepId, Name}, Env, Message, Len) -> + {Message1, Len1} = enc_type('tk_ulong', Env, 33, Message, Len), + {Message2, _} = enc_byte_order(Env, []), + {ComplexParams, Len2} = enc_type({'tk_struct', "", "", + [{"RepositoryId", {'tk_string', 0}}, + {"name", {'tk_string', 0}}]}, + Env, + {"", RepId, Name}, + Message2, 1), + encode_complex_tc_paramters(lists:reverse(ComplexParams), Len2, Message1, Len1); +enc_type_code({'none', Indirection}, Env, Message, Len) -> %% placeholder + enc_type({'tk_struct', "", "", [{"TCKind", 'tk_ulong'}, + {"indirection", 'tk_long'}]}, + Env, + {"", 16#ffffffff, Indirection}, + Message, Len); +enc_type_code(Type, _, _, _) -> + orber:dbg("[~p] cdr_encode:enc_type_code(~p); No match.", + [?LINE, Type], ?DEBUG_LEVEL), + corba:raise(#'MARSHAL'{minor=(?ORBER_VMCID bor 7), completion_status=?COMPLETED_MAYBE}). + +check_enum({'tk_enum', _, _, _}) -> + true; +check_enum(_) -> + false. + +encode_complex_tc_paramters(Value, ValueLength, Message, Len) -> + {Message1, _Len1} = enc_align(Message, Len, 4), + Message2 = cdrlib:enc_unsigned_long(ValueLength, Message1), + {[Value |Message2], Len+ValueLength+4}. + +%%----------------------------------------------------------------- +%% Func: enc_align/1 +%%----------------------------------------------------------------- +enc_align(R, Len, Alignment) -> + Rem = Len rem Alignment, + if Rem == 0 -> + {R, Len}; + true -> + Diff = Alignment - Rem, + {add_bytes(R, Diff), Len + Diff} + end. + +add_bytes(R, 0) -> + R; +add_bytes(R, 1) -> + [<<16#01:8>> | R]; +add_bytes(R, 2) -> + [<<16#02:8, 16#02:8>> | R]; +add_bytes(R, 3) -> + [<<16#03:8, 16#03:8, 16#03:8>> | R]; +add_bytes(R, 4) -> + [<<16#04:8, 16#04:8, 16#04:8, 16#04:8>> | R]; +add_bytes(R, 5) -> + [<<16#05:8, 16#05:8, 16#05:8, 16#05:8, 16#05:8>> | R]; +add_bytes(R, 6) -> + [<<16#06:8, 16#06:8, 16#06:8, 16#06:8, 16#06:8, 16#06:8>> | R]; +add_bytes(R, 7) -> + [<<16#07:8, 16#07:8, 16#07:8, 16#07:8, 16#07:8, 16#07:8, 16#07:8>> | R]; +add_bytes(R,N) -> + add_bytes([<<16#08:8>> | R], N - 1). + |