%%--------------------------------------------------------------------
%%
%% %CopyrightBegin%
%%
%% Copyright Ericsson AB 1997-2010. All Rights Reserved.
%%
%% Licensed under the Apache License, Version 2.0 (the "License");
%% you may not use this file except in compliance with the License.
%% You may obtain a copy of the License at
%%
%% http://www.apache.org/licenses/LICENSE-2.0
%%
%% Unless required by applicable law or agreed to in writing, software
%% distributed under the License is distributed on an "AS IS" BASIS,
%% WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
%% See the License for the specific language governing permissions 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) when is_list(TypeCodeList) ->
{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_union(Env, Value, _DiscrTC, _Default, Module, Bytes, Len) when is_atom(Module) ->
case catch Module:tc() of
{tk_union, _, _, DiscrTC, Default, ElementList} ->
enc_union(Env, Value, DiscrTC, Default, ElementList, Bytes, Len);
What ->
orber:dbg("[~p] ~p:enc_union(~p). Union module doesn't exist or incorrect.",
[?LINE, ?MODULE, What], ?DEBUG_LEVEL),
corba:raise(#'MARSHAL'{completion_status=?COMPLETED_MAYBE})
end.
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) when is_list(TypeCodeList) ->
[_Name | StructList] = tuple_to_list(Struct),
enc_struct1(Env, StructList, TypeCodeList, Bytes, Len);
enc_struct(Env, Struct, Module, Bytes, Len) ->
[Module | StructList] = tuple_to_list(Struct),
case catch Module:tc() of
{tk_struct, _, _, TypeCodeList} ->
enc_struct1(Env, StructList, TypeCodeList, Bytes, Len);
What ->
orber:dbg("[~p] ~p:enc_struct([], ~p). Struct module doesn't exist or incorrect.",
[?LINE, ?MODULE, What], ?DEBUG_LEVEL),
corba:raise(#'MARSHAL'{completion_status=?COMPLETED_MAYBE})
end.
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).
