pickling.c   [plain text]

/*
 * Copyright (c) 2010 Apple Inc. All rights reserved.
 *
 * @APPLE_LICENSE_HEADER_START@
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * 1.  Redistributions of source code must retain the above copyright
 *     notice, this list of conditions and the following disclaimer.
 * 2.  Redistributions in binary form must reproduce the above copyright
 *     notice, this list of conditions and the following disclaimer in the
 *     documentation and/or other materials provided with the distribution.
 * 3.  Neither the name of Apple Inc. ("Apple") nor the names of its
 *     contributors may be used to endorse or promote products derived from
 *     this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY APPLE AND ITS CONTRIBUTORS "AS IS" AND ANY
 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 * DISCLAIMED. IN NO EVENT SHALL APPLE OR ITS CONTRIBUTORS BE LIABLE FOR ANY
 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * Portions of this software have been released under the following terms:
 *
 * (c) Copyright 1989-1993 OPEN SOFTWARE FOUNDATION, INC.
 * (c) Copyright 1989-1993 HEWLETT-PACKARD COMPANY
 * (c) Copyright 1989-1993 DIGITAL EQUIPMENT CORPORATION
 *
 * To anyone who acknowledges that this file is provided "AS IS"
 * without any express or implied warranty:
 * permission to use, copy, modify, and distribute this file for any
 * purpose is hereby granted without fee, provided that the above
 * copyright notices and this notice appears in all source code copies,
 * and that none of the names of Open Software Foundation, Inc., Hewlett-
 * Packard Company or Digital Equipment Corporation be used
 * in advertising or publicity pertaining to distribution of the software
 * without specific, written prior permission.  Neither Open Software
 * Foundation, Inc., Hewlett-Packard Company nor Digital
 * Equipment Corporation makes any representations about the suitability
 * of this software for any purpose.
 *
 * Copyright (c) 2007, Novell, Inc. All rights reserved.
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 *
 * 1.  Redistributions of source code must retain the above copyright
 *     notice, this list of conditions and the following disclaimer.
 * 2.  Redistributions in binary form must reproduce the above copyright
 *     notice, this list of conditions and the following disclaimer in the
 *     documentation and/or other materials provided with the distribution.
 * 3.  Neither the name of Novell Inc. nor the names of its contributors
 *     may be used to endorse or promote products derived from this
 *     this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY
 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
 * DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS OR CONTRIBUTORS BE LIABLE FOR ANY
 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * @APPLE_LICENSE_HEADER_END@
 */

/*
**
**      pickling.c
**
**  FACILITY:
**
**      Interface Definition Language (IDL) Compiler
**
**  ABSTRACT:
**
**      Routines for IDL encoding services
**
*/
#if HAVE_CONFIG_H
#include <config.h>
#endif

#include <assert.h>

#include <dce/idlddefs.h>
#include <ndrmi.h>
#include <ndrui.h>
#include <dce/rpcsts.h>
#include <lsysdep.h>

static rpc_syntax_id_t ndr_transfer_syntax_id = {
    {0x8a885d04, 0x1ceb, 0x11c9, 0x9f, 0xe8, {0x8, 0x0, 0x2b, 0x10, 0x48,
0x60}},
    2};

/******************************************************************************/
/*                                                                            */
/*  idl_es_add_state_to_handle - local routine                                */
/*  Allocate an IDL_ms_t block, initialize it, and attach it to an encoding   */
/*      handle                                                                */
/*  Also mark the state block's copy of the pickle header as invalid          */
/*  Returns error_status_ok or rpc_s_no_memory                                */
/*                                                                            */
/******************************************************************************/
static error_status_t idl_es_add_state_to_handle
(
    IDL_es_state_t *p_es_state
)
{
    IDL_msp_t IDL_msp;

    IDL_msp = (IDL_msp_t)malloc(sizeof(IDL_ms_t));
    if (IDL_msp == NULL)
        return(rpc_s_no_memory);
    /* Initialize state block, except stub must fill in type vector */
    rpc_ss_init_marsh_state(NULL, IDL_msp);
    IDL_msp->IDL_pickling_handle = (rpc_void_p_t)p_es_state;
    p_es_state->IDL_msp = IDL_msp;
    p_es_state->IDL_pickle_header.IDL_op_num = IDL_INVALID_OP_NUM;
    return(error_status_ok);
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_encode_incremental - API routine                                   */
/*  Return an encoding handle for incremental encoding                        */
/*                                                                            */
/******************************************************************************/
void idl_es_encode_incremental
(
    idl_void_p_t	    state,  /* [in] user state */
    idl_es_allocate_fn_t    alloc,  /* [in] alloc routine */
    idl_es_write_fn_t	    writefn,  /* [in] write routine */
    idl_es_handle_t	    *h,	    /* [out] encoding handle */
    error_status_t	    *st	    /* [out] status */
)
{
    IDL_es_state_t *p_es_state;

    p_es_state = (IDL_es_state_t *)malloc(sizeof(IDL_es_state_t));
    if (p_es_state == NULL)
    {
        *st = rpc_s_no_memory;
        return;
    }

    p_es_state->IDL_version = IDL_ES_STATE_VERSION;
    p_es_state->IDL_action = IDL_encoding_k;
    p_es_state->IDL_style = IDL_incremental_k;
    /* Set transfer syntax null to indicate "not yet determined" */
    uuid_create_nil(&(p_es_state->IDL_pickle_header.IDL_syntax_id.id), st);
    p_es_state->IDL_pickle_header.IDL_syntax_id.version = 0;
    p_es_state->IDL_state = state;
    p_es_state->IDL_alloc = alloc;
    p_es_state->IDL_write = writefn;
    p_es_state->IDL_es_flags = 0;

    *st = idl_es_add_state_to_handle(p_es_state);
    if (*st == error_status_ok)
        *h = (idl_es_handle_t)p_es_state;
    else
        free(p_es_state);
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_encode_fixed_buffer - API routine                                  */
/*  Return an encoding handle for fixed buffer encoding                       */
/*                                                                            */
/******************************************************************************/
void idl_es_encode_fixed_buffer
(
    idl_byte		    *ep,    /* [out] buffer to   */
				    /* receive the encoding (must   */
				    /* be 8-byte aligned).	    */
    idl_ulong_int	    bsize,  /* [in] size of buffer provided */
    idl_ulong_int	    *esize, /* [out] size of the resulting  */
				    /* encoding	(set after	    */
				    /* execution of the stub)	    */
    idl_es_handle_t	    *h,	    /* [out] encoding handle */
    error_status_t	    *st	    /* [out] status */
)
{
    IDL_es_state_t *p_es_state;

    p_es_state = (IDL_es_state_t *)malloc(sizeof(IDL_es_state_t));
    if (p_es_state == NULL)
    {
        *st = rpc_s_no_memory;
        return;
    }

    p_es_state->IDL_version = IDL_ES_STATE_VERSION;
    p_es_state->IDL_action = IDL_encoding_k;
    p_es_state->IDL_style = IDL_fixed_k;
    /* Set transfer syntax null to indicate "not yet determined" */
    uuid_create_nil(&(p_es_state->IDL_pickle_header.IDL_syntax_id.id), st);
    p_es_state->IDL_pickle_header.IDL_syntax_id.version = 0;
    if (((ep - (idl_byte *)0) & 7) != 0)
    {
        /* User buffer is not 8-byte aligned */
        free(p_es_state);
        *st = rpc_s_ss_bad_buffer;
        return;
    }
    p_es_state->IDL_buff_addr = ep;
    if ((bsize & 7) != 0)
    {
        /* User buffer is not multiple of 8 bytes */
        free(p_es_state);
        *st = rpc_s_ss_bad_buffer;
        return;
    }
    p_es_state->IDL_bsize = bsize;
    p_es_state->IDL_esize = esize;
    p_es_state->IDL_es_flags = 0;

    *st = idl_es_add_state_to_handle(p_es_state);
    if (*st == error_status_ok)
    {
        *h = (idl_es_handle_t)p_es_state;
        p_es_state->IDL_msp->IDL_mp = ep;
        p_es_state->IDL_msp->IDL_buff_addr = ep;
        p_es_state->IDL_msp->IDL_data_addr = ep;
        p_es_state->IDL_msp->IDL_left_in_buff = bsize;
    }
    else
        free(p_es_state);
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_encode_dyn_buffer - API routine                                    */
/*  Return an encoding handle for dynamic buffer encoding                     */
/*                                                                            */
/******************************************************************************/
void idl_es_encode_dyn_buffer
(
    idl_byte		    **ep,   /* [out] pointer to receive the */
				    /* dynamically allocated buffer */
				    /* which contains the encoding  */
    idl_ulong_int	    *esize, /* [out] size of the resulting  */
				    /* encoding (set after	    */
				    /* execution of the stub)	    */
    idl_es_handle_t	    *h,	    /* [out] decoding handle */
    error_status_t	    *st	    /* [out] status */
)
{
    IDL_es_state_t *p_es_state;

    p_es_state = (IDL_es_state_t *)malloc(sizeof(IDL_es_state_t));
    if (p_es_state == NULL)
    {
        *st = rpc_s_no_memory;
        return;
    }

    p_es_state->IDL_version = IDL_ES_STATE_VERSION;
    p_es_state->IDL_action = IDL_encoding_k;
    p_es_state->IDL_style = IDL_dynamic_k;
    /* Set transfer syntax null to indicate "not yet determined" */
    uuid_create_nil(&(p_es_state->IDL_pickle_header.IDL_syntax_id.id), st);
    p_es_state->IDL_pickle_header.IDL_syntax_id.version = 0;
    p_es_state->IDL_p_buff_addr = ep;
    *ep = NULL;     /* Marker to indicate that no encoding call has yet been
                        made using this handle */
    p_es_state->IDL_esize = esize;
    p_es_state->IDL_dyn_buff_chain_head = NULL;
    p_es_state->IDL_dyn_buff_chain_tail = NULL;
    p_es_state->IDL_es_flags = 0;

    *st = idl_es_add_state_to_handle(p_es_state);
    if (*st == error_status_ok)
        *h = (idl_es_handle_t)p_es_state;
    else
        free(p_es_state);
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_decode_incremental - API routine                                   */
/*  Return an encoding handle for incremental decoding                        */
/*                                                                            */
/******************************************************************************/
void idl_es_decode_incremental
(
    idl_void_p_t	    state,  /* [in] user state */
    idl_es_read_fn_t	    readfn,   /* [in] routine to supply buffers */
    idl_es_handle_t	    *h,	    /* [out] decoding handle */
    error_status_t	    *st	    /* [out] status */
)
{
    IDL_es_state_t *p_es_state;
    IDL_msp_t IDL_msp;

    p_es_state = (IDL_es_state_t *)malloc(sizeof(IDL_es_state_t));
    if (p_es_state == NULL)
    {
        *st = rpc_s_no_memory;
        return;
    }

    p_es_state->IDL_version = IDL_ES_STATE_VERSION;
    p_es_state->IDL_action = IDL_decoding_k;
    p_es_state->IDL_style = IDL_incremental_k;
    p_es_state->IDL_state = state;
    p_es_state->IDL_read = readfn;
    p_es_state->IDL_pickle_header_read = idl_false;
    p_es_state->IDL_es_flags = 0;

    *st = idl_es_add_state_to_handle(p_es_state);
    if (*st == error_status_ok)
    {
        *h = (idl_es_handle_t)p_es_state;
        IDL_msp = p_es_state->IDL_msp;
        IDL_msp->IDL_left_in_buff = 0;
    }
    else
        free(p_es_state);
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_decode_buffer - API routine                                        */
/*  Return an encoding handle for fixed decoding                              */
/*                                                                            */
/******************************************************************************/
void idl_es_decode_buffer
(
    idl_byte		    *ep,    /* [in] pointer to buffer	    */
				    /* containing the encoding	    */
    idl_ulong_int	    size,   /* [in] size of buffer provided */
    idl_es_handle_t	    *h,	    /* [out] decoding handle */
    error_status_t	    *st	    /* [out] status */
)
{
    IDL_es_state_t *p_es_state;
    IDL_msp_t IDL_msp;

    p_es_state = (IDL_es_state_t *)malloc(sizeof(IDL_es_state_t));
    if (p_es_state == NULL)
    {
        *st = rpc_s_no_memory;
        return;
    }

    p_es_state->IDL_version = IDL_ES_STATE_VERSION;
    p_es_state->IDL_action = IDL_decoding_k;
    p_es_state->IDL_style = IDL_fixed_k;
    p_es_state->IDL_bsize = size;
    p_es_state->IDL_buff_addr = ep;
    p_es_state->IDL_pickle_header_read = idl_false;
    p_es_state->IDL_es_flags = 0;

    *st = idl_es_add_state_to_handle(p_es_state);
    if (*st == error_status_ok)
        *h = (idl_es_handle_t)p_es_state;
    else
    {
        free(p_es_state);
        return;
    }

    /* Set up buffer management state */
    IDL_msp = p_es_state->IDL_msp;
    if (((p_es_state->IDL_buff_addr - (idl_byte *)0) & 7) != 0)
    {
        /* User buffer is not 8-byte aligned. Copy data to an area
                    that is */
        p_es_state->IDL_align_buff_addr = (idl_byte *)
                                            malloc(p_es_state->IDL_bsize + 7);
        if (p_es_state->IDL_align_buff_addr == NULL)
        {
            free(p_es_state);
            *st = rpc_s_no_memory;
            return;
        }
        IDL_msp->IDL_data_addr = (idl_byte *)
               (((p_es_state->IDL_align_buff_addr - (idl_byte *)0) + 7) & (~7));
        memcpy(IDL_msp->IDL_data_addr, p_es_state->IDL_buff_addr,
                                                        p_es_state->IDL_bsize);
    }
    else
    {
        p_es_state->IDL_align_buff_addr = NULL;
        IDL_msp->IDL_data_addr = p_es_state->IDL_buff_addr;
    }
    IDL_msp->IDL_mp = IDL_msp->IDL_data_addr;
    IDL_msp->IDL_left_in_buff = p_es_state->IDL_bsize;
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_set_transfer_syntax - API routine                                  */
/*  Set a transfer syntax (user must call this before encoding using a stub   */
/*      which supports more than one transfer syntax)                         */
/*                                                                            */
/******************************************************************************/
void idl_es_set_transfer_syntax
(
    idl_es_handle_t h,      /* [in,out] User's encoding handle */
    idl_es_transfer_syntax_t es_transfer_syntax,
                            /* [in] requested transfer syntax */
    error_status_t *st
)
{
    IDL_es_state_t *p_es_state;

    p_es_state = (IDL_es_state_t *)h;
    switch (es_transfer_syntax)
    {
        case idl_es_transfer_syntax_ndr:
            p_es_state->IDL_pickle_header.IDL_syntax_id
                                                     = ndr_transfer_syntax_id;
            *st = error_status_ok;
            break;
        default:
            *st = rpc_s_tsyntaxes_unsupported;
            break;
    }
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_check_transfer_syntax - local routine                              */
/*  Check the stub supports the transfer syntax and return the appropriate    */
/*      enumeration value                                                     */
/*                                                                            */
/******************************************************************************/
static void idl_es_check_transfer_syntax
(
    rpc_if_rep_t *p_if_spec,    /* [in] Pointer to stub's if_spec */
    IDL_es_state_t *p_es_state, /* [in] State block containing transfer syntax
                                        to be checked */
    idl_es_transfer_syntax_t *p_es_transfer_syntax,
                            /* [out] Transfer syntax to use for encoding */
    IDL_msp_t IDL_msp
)
{
    unsigned32 i;

    /* Check the stub supports the transfer syntax */
    for (i=0; i<p_if_spec->syntax_vector.count; i++)
    {
        if ( uuid_equal(&(p_es_state->IDL_pickle_header.IDL_syntax_id.id),
                        &(p_if_spec->syntax_vector.syntax_id[i].id),
                        (error_status_t *)&IDL_msp->IDL_status)
            && (p_es_state->IDL_pickle_header.IDL_syntax_id.version
                            == p_if_spec->syntax_vector.syntax_id[i].version) )
        {
            break;
        }
    }
    if ( i >= p_if_spec->syntax_vector.count )
    {
        /* No match found in list in stub's ifspec */
        IDL_msp->IDL_status = rpc_s_tsyntaxes_unsupported;
        DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
    }

    /* Return the enumeration value for the transfer syntax */
        *p_es_transfer_syntax = idl_es_transfer_syntax_ndr;
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_encode_get_xfer_syntax - local routine                             */
/*  Get the transfer syntax to be used for the encoding                       */
/*                                                                            */
/******************************************************************************/
static void idl_es_encode_get_xfer_syntax
(
    idl_es_handle_t h,      /* [in] User's encoding handle */
    rpc_if_handle_t ifp,    /* [in] Pointer to stub's ifspec */
    idl_es_transfer_syntax_t *p_es_transfer_syntax,
                            /* [out] Transfer syntax to use for encoding */
    IDL_msp_t IDL_msp
)
{
    IDL_es_state_t *p_es_state;
    rpc_if_rep_t *p_if_spec;

    p_es_state = (IDL_es_state_t *)h;
    p_if_spec = (rpc_if_rep_t *)ifp;
    if ( uuid_is_nil(&(p_es_state->IDL_pickle_header.IDL_syntax_id.id),
                     (error_status_t *)&IDL_msp->IDL_status) )
    {
        /* No transfer syntax specified in the handle,
            so can the transfer syntax to use be determined from the stub? */
        if (p_if_spec->syntax_vector.count != 1)
        {
            /* Transfer syntax not adequately specified by stub */
            IDL_msp->IDL_status = rpc_s_tsyntaxes_unsupported;
            DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
        }
        else
        {
            /* Copy the transfer syntax into the encoding state block */
            p_es_state->IDL_pickle_header.IDL_syntax_id =
                                        *(p_if_spec->syntax_vector.syntax_id);
        }
    }

    /* Check the stub supports the transfer syntax the user chose */
    idl_es_check_transfer_syntax(p_if_spec, p_es_state, p_es_transfer_syntax,
                                 IDL_msp);
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_encode_new_dyn_buff - Called locally and from MIA/BER support      */
/*  Create new intermediate buffer list element                               */
/*  Returns error_status_ok or rpc_s_no_memory                                */
/*  Does not raise exceptions because it can be called from below DDIS        */
/*                                                                            */
/******************************************************************************/
error_status_t idl_es_encode_new_dyn_buff
(
    idl_ulong_int *p_buff_size,     /* [out] Size of buffer returned */
    IDL_msp_t IDL_msp
)
{
    IDL_dyn_buff_link_t *p_new_link;
    rpc_iovector_elt_t *p_new_iovec_elt;
    IDL_es_state_t *p_es_state;

    p_es_state = (IDL_es_state_t *)(IDL_msp->IDL_pickling_handle);

    if ( (*(p_es_state->IDL_p_buff_addr) != NULL)
            && (p_es_state->IDL_dyn_buff_chain_head == NULL) )
    {
        /* A previous encoding operation was called using the current
            encoding handle (signified by IDL_p_buff_addr not NULL)
            and this is the first intermediate buffer needed by the
            current operation (signified by IDL_dyn_buff_chain_head == NULL).
            Make the output from the preceding operation(s) be the first element
            of the list of intermediate buffers */
        p_new_link = (IDL_dyn_buff_link_t *)malloc
                                        (sizeof(IDL_dyn_buff_link_t));
        if (p_new_link == NULL)
        {
	    rpc_allocator_free(&IDL_msp->IDL_allocator,
		    *(p_es_state->IDL_p_buff_addr));
            return(rpc_s_no_memory);
        }
        p_new_link->IDL_p_iovec_elt = NULL;
        p_new_link->IDL_next = NULL;
        p_es_state->IDL_dyn_buff_chain_head = p_new_link;
        p_es_state->IDL_dyn_buff_chain_tail = p_new_link;
        /* Create an rpc_iovector_elt to describe the buffer */
        p_new_iovec_elt = (rpc_iovector_elt_t *)malloc
                                        (sizeof(rpc_iovector_elt_t));
        if (p_new_iovec_elt == NULL)
        {
	    rpc_allocator_free(&IDL_msp->IDL_allocator,
		    *(p_es_state->IDL_p_buff_addr));
            return(rpc_s_no_memory);
        }
        p_new_link->IDL_p_iovec_elt = p_new_iovec_elt;
        p_new_iovec_elt->buff_addr = *(p_es_state->IDL_p_buff_addr);
        p_new_iovec_elt->data_addr = *(p_es_state->IDL_p_buff_addr);
        p_new_iovec_elt->data_len = *(p_es_state->IDL_esize);
    }

    p_new_link = (IDL_dyn_buff_link_t *)malloc
                                        (sizeof(IDL_dyn_buff_link_t));
    if (p_new_link == NULL)
        return(rpc_s_no_memory);
    p_new_link->IDL_p_iovec_elt = NULL;
    p_new_link->IDL_next = NULL;
    /* Connect it to the state block */
    if (p_es_state->IDL_dyn_buff_chain_head == NULL)
        p_es_state->IDL_dyn_buff_chain_head = p_new_link;
    else
        p_es_state->IDL_dyn_buff_chain_tail->IDL_next = p_new_link;
    p_es_state->IDL_dyn_buff_chain_tail = p_new_link;
    /* Create an rpc_iovector_elt to describe the buffer */
    p_new_iovec_elt = (rpc_iovector_elt_t *)malloc
                                        (sizeof(rpc_iovector_elt_t));
    if (p_new_iovec_elt == NULL)
        return(rpc_s_no_memory);
    p_new_iovec_elt->buff_addr = NULL;
    /* Attach the rpc_iovector_elt to the chain */
    p_new_link->IDL_p_iovec_elt = p_new_iovec_elt;
    /* Create the buffer */
    IDL_msp->IDL_buff_addr = (idl_byte *)
	rpc_allocator_allocate(&IDL_msp->IDL_allocator, IDL_BUFF_SIZE);
    if (IDL_msp->IDL_buff_addr == NULL)
        return(rpc_s_no_memory);
    memset(IDL_msp->IDL_buff_addr, 0, IDL_BUFF_SIZE);
    /* Attach the buffer to the rpc_iovector_elt */
    p_new_iovec_elt->buff_addr = IDL_msp->IDL_buff_addr;
    *p_buff_size = IDL_BUFF_SIZE;
    return(error_status_ok);
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_encode_init_buffer - called from NDR marshalling interpreter       */
/*  Action to be taken by rpc_ss_marsh_init_buffer when used for encoding     */
/*                                                                            */
/******************************************************************************/
void idl_es_encode_init_buffer
(
    idl_ulong_int *p_buff_size,     /* [out] Size of buffer returned */
    IDL_msp_t IDL_msp
)
{
    IDL_es_state_t *p_es_state;

    p_es_state = (IDL_es_state_t *)(IDL_msp->IDL_pickling_handle);
    switch (p_es_state->IDL_style)
    {
        case IDL_incremental_k:
            *p_buff_size = IDL_BUFF_SIZE;
            (*(p_es_state->IDL_alloc))(p_es_state->IDL_state,
                                         &IDL_msp->IDL_buff_addr, p_buff_size);
            if (((IDL_msp->IDL_buff_addr - (idl_byte *)0) & 7) != 0)
            {
                /* User buffer is not 8-byte aligned */
                IDL_msp->IDL_status = rpc_s_ss_bad_buffer;
                DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
            }
            if (((*p_buff_size & 7) != 0) || (*p_buff_size < 8))
            {
                /* User buffer is not multiple of 8 bytes */
                IDL_msp->IDL_status = rpc_s_ss_bad_buffer;
                DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
            }
            break;
        case IDL_fixed_k:
            /* Ran out of buffer space with data still to be marshalled */
            DCETHREAD_RAISE(rpc_x_no_memory);
            break;
        case IDL_dynamic_k:
            /* Create new intermediate buffer list element */
            if (idl_es_encode_new_dyn_buff(p_buff_size, IDL_msp)
                                                            != error_status_ok)
                DCETHREAD_RAISE(rpc_x_no_memory);
            break;
        default:
#ifdef DEBUG_INTERP
            printf("idl_es_encode_init_buffer - unknown encoding style\n");
            exit(0);
#endif
            DCETHREAD_RAISE(rpc_x_coding_error);
    }
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_encode_attach_buff - called from NDR marshalling interpreter       */
/*  Action to be taken by rpc_ss_attach_buff_to_iovec when used for encoding  */
/*                                                                            */
/******************************************************************************/
void idl_es_encode_attach_buff
(
    IDL_msp_t IDL_msp
)
{
    IDL_es_state_t *p_es_state;
    rpc_iovector_elt_t *p_iovec_elt;

    p_es_state = (IDL_es_state_t *)(IDL_msp->IDL_pickling_handle);
    switch (p_es_state->IDL_style)
    {
        case IDL_incremental_k:
            (*(p_es_state->IDL_write))(p_es_state->IDL_state,
                                      IDL_msp->IDL_buff_addr,
                                      IDL_msp->IDL_mp - IDL_msp->IDL_data_addr);
            break;
        case IDL_fixed_k:
            /* Can only happen at end of operation - do nothing */
            break;
        case IDL_dynamic_k:
            p_iovec_elt = p_es_state->IDL_dyn_buff_chain_tail->IDL_p_iovec_elt;
            p_iovec_elt->data_addr = (byte_p_t)IDL_msp->IDL_data_addr;
            p_iovec_elt->data_len = IDL_msp->IDL_mp - IDL_msp->IDL_data_addr;
            break;
        default:
#ifdef DEBUG_INTERP
            printf("idl_es_encode_attach_buff - unknown encoding style\n");
            exit(0);
#endif
            DCETHREAD_RAISE(rpc_x_coding_error);
    }
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_put_encoding_uuid - local routine                                  */
/*  Write a UUID in the header for a pickle                                   */
/*                                                                            */
/******************************************************************************/
static void idl_es_put_encoding_uuid
(
    idl_uuid_t *p_uuid,     /* [in] Address of UUID */
    IDL_msp_t IDL_msp
)
{
    int i;

    IDL_MARSH_ULONG(&p_uuid->time_low);
    IDL_MARSH_USHORT(&p_uuid->time_mid);
    IDL_MARSH_USHORT(&p_uuid->time_hi_and_version);
    IDL_MARSH_USMALL(&p_uuid->clock_seq_hi_and_reserved);
    IDL_MARSH_USMALL(&p_uuid->clock_seq_low);
    for (i=0; i<6; i++)
    {
        IDL_MARSH_BYTE(&p_uuid->node[i]);
    }
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_put_encoding_header - local routine                                */
/*  Write the header for this pickle                                          */
/*                                                                            */
/******************************************************************************/
static void idl_es_put_encoding_header
(
    rpc_if_handle_t ifp,    /* [in] Pointer to stub's ifspec */
    idl_ulong_int op_num,   /* [in] operation number */
    idl_es_transfer_syntax_t es_transfer_syntax,
                         /* [in] Transfer syntax user data will be encoded in */
    IDL_msp_t IDL_msp
)
{
    idl_usmall_int version = IDL_ES_HEADER_VERSION;
    idl_usmall_int fill = 0;
    IDL_es_state_t *p_es_state;
    rpc_if_rep_t *p_if_spec;
    int i;
    idl_ushort_int vers_field;

    p_es_state = (IDL_es_state_t *)(IDL_msp->IDL_pickling_handle);
    p_if_spec = (rpc_if_rep_t *)ifp;

    IDL_MARSH_USMALL(&version);
    IDL_MARSH_USMALL(&ndr_g_local_drep.int_rep);
    IDL_MARSH_USMALL(&fill);
    IDL_MARSH_USMALL(&fill);
    idl_es_put_encoding_uuid(&p_es_state->IDL_pickle_header.IDL_syntax_id.id,
                                                                     IDL_msp);
    IDL_MARSH_ULONG(&p_es_state->IDL_pickle_header.IDL_syntax_id.version);
    idl_es_put_encoding_uuid(&p_if_spec->id, IDL_msp);
    vers_field = p_if_spec->vers / 65536;   /* Major version */
    IDL_MARSH_USHORT(&vers_field);
    vers_field = p_if_spec->vers % 65536;   /* Minor version */
    IDL_MARSH_USHORT(&vers_field);
    IDL_MARSH_ULONG(&op_num);
    if (es_transfer_syntax == idl_es_transfer_syntax_ndr)
    {
        IDL_MARSH_USMALL(&ndr_g_local_drep.int_rep);
        IDL_MARSH_USMALL(&ndr_g_local_drep.char_rep);
        IDL_MARSH_USMALL(&ndr_g_local_drep.float_rep);
        IDL_MARSH_BYTE(&ndr_g_local_drep.reserved);
        /* Four filler bytes to make the user data start at (0 mod 8) */
        for (i=0; i<4; i++)
        {
            IDL_MARSH_USMALL(&fill);
        }
    }

    /* Store interface ID and operation number in state block */
    p_es_state->IDL_pickle_header.IDL_if_id.uuid = p_if_spec->id;
    p_es_state->IDL_pickle_header.IDL_if_id.vers_major
                                                     = p_if_spec->vers / 65536;
    p_es_state->IDL_pickle_header.IDL_if_id.vers_minor
                                                     = p_if_spec->vers % 65536;
    p_es_state->IDL_pickle_header.IDL_op_num = op_num;
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_get_encoding_uuid - local routine                                  */
/*  Read a UUID in the header for a pickle                                    */
/*                                                                            */
/******************************************************************************/
static void idl_es_get_encoding_uuid
(
    idl_uuid_t *p_uuid,     /* [in] Address of UUID */
    IDL_msp_t IDL_msp
)
{
    int i;

    IDL_UNMAR_ULONG(&p_uuid->time_low);
    IDL_UNMAR_USHORT(&p_uuid->time_mid);
    IDL_UNMAR_USHORT(&p_uuid->time_hi_and_version);
    IDL_UNMAR_USMALL(&p_uuid->clock_seq_hi_and_reserved);
    IDL_UNMAR_USMALL(&p_uuid->clock_seq_low);
    for (i=0; i<6; i++)
    {
        IDL_UNMAR_BYTE(&p_uuid->node[i]);
    }
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_get_encoding_header - local routine                                */
/*  Read pickle header into local storage                                     */
/*                                                                            */
/******************************************************************************/
static void idl_es_get_encoding_header
(
    idl_es_pvt_header_t *p_pickle_header,       /* [out] local copy of pickle
                                                         header */
    IDL_msp_t IDL_msp
)
{
    IDL_es_state_t *p_es_state = NULL;

    p_es_state = (IDL_es_state_t *)(IDL_msp->IDL_pickling_handle);

    IDL_UNMAR_USMALL(&p_pickle_header->IDL_version);
    if (p_pickle_header->IDL_version != IDL_ES_HEADER_VERSION)
    {
        IDL_msp->IDL_status = rpc_s_ss_wrong_es_version;
        DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
    }
    IDL_UNMAR_USMALL(&p_pickle_header->IDL_int_drep);
    /* This drep is needed to control decoding the rest of header */
    IDL_msp->IDL_drep.int_rep = p_pickle_header->IDL_int_drep;
    /* Called rtn will do an alignment operation, discarding the filler bytes */
    idl_es_get_encoding_uuid(&p_pickle_header->IDL_syntax_id.id, IDL_msp);
    IDL_UNMAR_ULONG(&p_pickle_header->IDL_syntax_id.version);
    idl_es_get_encoding_uuid(&p_pickle_header->IDL_if_id.uuid, IDL_msp);
    IDL_UNMAR_USHORT(&p_pickle_header->IDL_if_id.vers_major);
    IDL_UNMAR_USHORT(&p_pickle_header->IDL_if_id.vers_minor);
    IDL_UNMAR_ULONG(&p_pickle_header->IDL_op_num);

    /* If the pickle uses NDR encoding, get its drep's */
    if (uuid_equal(&p_pickle_header->IDL_syntax_id.id,
                   &ndr_transfer_syntax_id.id,
                   (error_status_t *)&IDL_msp->IDL_status))
    {
        IDL_UNMAR_USMALL(&IDL_msp->IDL_drep.int_rep);
        IDL_UNMAR_USMALL(&IDL_msp->IDL_drep.char_rep);
        IDL_UNMAR_USMALL(&IDL_msp->IDL_drep.float_rep);
        /* And align to 8 bytes */
        IDL_UNMAR_ALIGN_MP(IDL_msp, 8);
    }
    assert(p_es_state != NULL);
    p_es_state->IDL_pickle_header_read = idl_true;
}

/*
 * Support for Microsoft Encoding Services (MES).
 */
static void idl_mes_put_encoding_header
(
    IDL_msp_t IDL_msp
)
{
    idl_es_type_pvt_header_t common_header;
    int i;
    idl_usmall_int hdr_length_low, hdr_length_high;
    idl_byte length_pad = 0;

    common_header.IDL_version = IDL_ES_HEADER_VERSION;
    common_header.IDL_endianness = (ndr_g_local_drep.int_rep << 4);
    common_header.IDL_common_header_length = IDL_ES_TYPE_COMMON_HEADER_LEN;
    memset(common_header.IDL_fill, 0xcc, 4);

    IDL_MARSH_USMALL(&common_header.IDL_version);
    IDL_MARSH_USMALL(&common_header.IDL_endianness);

    hdr_length_low  = (common_header.IDL_common_header_length >> 0) & 0xff;
    hdr_length_high = (common_header.IDL_common_header_length >> 8) & 0xff;

    IDL_MARSH_USMALL(&hdr_length_low);
    IDL_MARSH_USMALL(&hdr_length_high);

    for (i = 0; i < 4; i++)
    {
        IDL_MARSH_BYTE(&common_header.IDL_fill[i]);
    }

    for (i = 0; i < 8; i++)
    {
        IDL_MARSH_BYTE(&length_pad);
    }
}

static void idl_mes_get_encoding_header
(
    idl_es_pvt_header_t *p_pickle_header,
    IDL_msp_t IDL_msp
)
{
    idl_es_type_pvt_header_t common_header;
    IDL_es_state_t *p_es_state;
    int i;
    idl_uhyper_int length;
    idl_usmall_int hdr_length_low, hdr_length_high;
    unsigned32 status;

    p_es_state = (IDL_es_state_t *)(IDL_msp->IDL_pickling_handle);

    IDL_UNMAR_USMALL(&common_header.IDL_version);
    if (common_header.IDL_version != IDL_ES_HEADER_VERSION)
    {
        IDL_msp->IDL_status = rpc_s_ss_wrong_es_version;
        DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
    }
    p_pickle_header->IDL_version = common_header.IDL_version;

    IDL_UNMAR_USMALL(&common_header.IDL_endianness);

    IDL_msp->IDL_drep.int_rep  = (common_header.IDL_endianness >> 4) & 0xF;

    IDL_UNMAR_USMALL(&hdr_length_low);
    IDL_UNMAR_USMALL(&hdr_length_high);

    common_header.IDL_common_header_length = (hdr_length_low  << 0) |
                                             (hdr_length_high << 8);

    if (common_header.IDL_common_header_length != IDL_ES_TYPE_COMMON_HEADER_LEN)
    {
        IDL_msp->IDL_status = rpc_s_ss_wrong_es_version;
        DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
    }

    for (i = 0; i < common_header.IDL_common_header_length - 4; i++)
    {
        IDL_UNMAR_BYTE(&common_header.IDL_fill[i]);
    }

    IDL_UNMAR_HYPER(&length);

    p_pickle_header->IDL_syntax_id = ndr_transfer_syntax_id;
    uuid_create_nil(&p_pickle_header->IDL_if_id.uuid, &status);
    if (status != rpc_s_ok)
    {
        IDL_msp->IDL_status = status;
        DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
    }
    p_pickle_header->IDL_if_id.vers_major = 0;
    p_pickle_header->IDL_if_id.vers_minor = 0;
    p_pickle_header->IDL_op_num = 0;

    IDL_msp->IDL_drep.char_rep = ndr_c_char_ascii;
    IDL_msp->IDL_drep.float_rep = ndr_c_float_ieee;

    p_es_state->IDL_pickle_header_read = idl_true;
}

static void idl_mes_forge_encoding_header
(
    idl_es_pvt_header_t *p_pickle_header,
    IDL_msp_t IDL_msp
)
{
    IDL_es_state_t *p_es_state;
    unsigned32 status;

    p_es_state = (IDL_es_state_t *)(IDL_msp->IDL_pickling_handle);

    IDL_msp->IDL_drep.int_rep = ndr_c_int_little_endian;

    p_pickle_header->IDL_syntax_id = ndr_transfer_syntax_id;
    uuid_create_nil(&p_pickle_header->IDL_if_id.uuid, &status);
    if (status != rpc_s_ok)
    {
        IDL_msp->IDL_status = status;
        DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
    }
    p_pickle_header->IDL_if_id.vers_major = 0;
    p_pickle_header->IDL_if_id.vers_minor = 0;
    p_pickle_header->IDL_op_num = 0;

    IDL_msp->IDL_drep.int_rep = ndr_c_int_little_endian;
    IDL_msp->IDL_drep.char_rep = ndr_c_char_ascii;
    IDL_msp->IDL_drep.float_rep = ndr_c_float_ieee;

    p_es_state->IDL_pickle_header_read = idl_true;
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_before_interp_call - SPI routine                                   */
/*  Set up for interpreter call to encode/decode user data                    */
/*                                                                            */
/******************************************************************************/
void idl_es_before_interp_call
(
    idl_es_handle_t h,      /* [in] User's encoding handle */
    rpc_if_handle_t ifp,    /* [in] Pointer to stub's ifspec */
    idl_byte IDL_type_vec[],    /* [in] Stub's type vector */
    idl_ulong_int op_num,   /* [in] operation number */
    IDL_es_action_type_k_t stub_action, /* [in] Is this operation labelled
                                            [encode], [decode] */
    idl_es_transfer_syntax_t *p_es_transfer_syntax,
                            /* [out] Transfer syntax to use for encoding */
    IDL_msp_t IDL_msp
)
{
    IDL_es_state_t * volatile p_es_state;
    rpc_if_rep_t *p_if_spec;

    //DO_NOT_CLOBBER(p_es_state);
    p_es_state = NULL;

    /* If we get any abnormal condition we need to cope with the situation
        where this is a dynamic encoding and the operation is not the first
        that used the handle. In this case we need to release the encoding
        resulting from the preceding operations */
    DCETHREAD_TRY
        /* Complete initialization of state block */
        IDL_msp->IDL_type_vec = IDL_type_vec;
        rpc_ss_type_vec_vers_check( IDL_msp );

        p_es_state = (IDL_es_state_t *)h;
        /* Was operation specified to support action? */
        if (stub_action != IDL_both_k)
        {
            if (stub_action != p_es_state->IDL_action)
            {
                IDL_msp->IDL_status = rpc_s_ss_bad_es_action;
                DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
            }
        }

        if (p_es_state->IDL_action == IDL_encoding_k)
        {
            idl_es_encode_get_xfer_syntax(h, ifp, p_es_transfer_syntax, IDL_msp);
            if (p_es_state->IDL_style == IDL_dynamic_k)
            {
                /* Need user allocator for intermediate and final buffers */
                rpc_ss_mts_client_estab_alloc(IDL_msp);
            }
            if ((p_es_state->IDL_es_flags & IDL_ES_NO_HEADER) == 0)
            {
                if (p_es_state->IDL_es_flags & IDL_ES_MIDL_COMPAT)
                    idl_mes_put_encoding_header(IDL_msp);
                else
                    idl_es_put_encoding_header(ifp, op_num, *p_es_transfer_syntax, IDL_msp);
            }
        }
        else    /* decoding */
        {
            if ( ! p_es_state->IDL_pickle_header_read )
            {
                if (p_es_state->IDL_es_flags & IDL_ES_NO_HEADER)
                    idl_mes_forge_encoding_header(&p_es_state->IDL_pickle_header, IDL_msp);
                else if (p_es_state->IDL_es_flags & IDL_ES_MIDL_COMPAT)
                    idl_mes_get_encoding_header(&p_es_state->IDL_pickle_header, IDL_msp);
                else
                    idl_es_get_encoding_header(&p_es_state->IDL_pickle_header, IDL_msp);
            }
            p_if_spec = (rpc_if_rep_t *)ifp;

            /*
             * Don't check interface uuid's or version number if the user
             * doesn't want to.
             */
            if ( ! (p_es_state->IDL_es_flags & ( IDL_ES_NO_ENCODING_CHECK
                                               | IDL_ES_MIDL_COMPAT
                                               | IDL_ES_NO_HEADER
                                               ) ) )
            {
                if ( ! uuid_equal(&p_es_state->IDL_pickle_header.IDL_if_id.uuid,
                                  &p_if_spec->id,
                                  (error_status_t *)&IDL_msp->IDL_status) )
                {
                    /* Wrong interface */
                    IDL_msp->IDL_status = rpc_s_unknown_if;
                    DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
                }
                if (p_if_spec->vers != (unsigned32)
							 (p_es_state->IDL_pickle_header.IDL_if_id.vers_major * 65536
                        + p_es_state->IDL_pickle_header.IDL_if_id.vers_minor))
                {
                    /* Wrong version */
                    IDL_msp->IDL_status = rpc_s_unknown_if;
                    DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
                }
            }

            /* Check the stub supports the transfer syntax of the pickle */
            idl_es_check_transfer_syntax(p_if_spec, p_es_state,
                                         p_es_transfer_syntax, IDL_msp);
            /* Now at a point where we won't test for "pickle header read" again
            for this operation. Reset it in case user has another operation in
            the pickle */
            p_es_state->IDL_pickle_header_read = idl_false;
        }
        DCETHREAD_CATCH_ALL(exc)
        assert(p_es_state != NULL);
        if ( (p_es_state->IDL_action == IDL_encoding_k)
            && (p_es_state->IDL_style == IDL_dynamic_k)
            && (*(p_es_state->IDL_p_buff_addr) != NULL) )
        {
	    rpc_allocator_free(&IDL_msp->IDL_allocator,
		*(p_es_state->IDL_p_buff_addr));
        }
        DCETHREAD_RERAISE;
    DCETHREAD_ENDTRY
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_encode_dyn_size - local routine                                    */
/*  Get the total size of a dynamic encoding                                  */
/*                                                                            */
/******************************************************************************/
static void idl_es_encode_dyn_size
(
    IDL_dyn_buff_link_t *p_list_elt,    /* [in] pointer to list of
                                                    intermediate buffers */
    idl_ulong_int *p_dyn_size           /* [out] size of encoding */
)
{
    idl_ulong_int dyn_size = 0;

    for ( ; p_list_elt != NULL; p_list_elt = p_list_elt->IDL_next)
    {
        dyn_size += p_list_elt->IDL_p_iovec_elt->data_len;
    }
    *p_dyn_size = dyn_size;
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_encode_dyn_copy_rel - local routine                                */
/*  Copy the intermediate buffers for a dynamic encoding to the buffer to be  */
/*      delivered to the user, and release the intermediate buffer chain      */
/*                                                                            */
/******************************************************************************/
static void idl_es_encode_dyn_copy_rel
(
    IDL_dyn_buff_link_t *p_list_elt,    /* [in] pointer to list of
                                                    intermediate buffers */
    idl_byte *dyn_buff,      /* [out] location to copy intermediate buffer to */
    IDL_msp_t IDL_msp
)
{
    rpc_iovector_elt_t *p_iovec_elt;
    idl_ulong_int inter_data_len;   /* Length of data in intermediate buffer */
    IDL_dyn_buff_link_t *p_old_list_elt;

    while (p_list_elt != NULL)
    {
        p_iovec_elt = p_list_elt->IDL_p_iovec_elt;
        /* Copy data */
        inter_data_len = p_iovec_elt->data_len;
        memcpy(dyn_buff, p_iovec_elt->data_addr, inter_data_len);
        dyn_buff += inter_data_len;
        /* Release head of chain */
	rpc_allocator_free(&IDL_msp->IDL_allocator, p_iovec_elt->buff_addr);
        free(p_iovec_elt);
        p_old_list_elt = p_list_elt;
        p_list_elt = p_list_elt->IDL_next;
        free(p_old_list_elt);
    }
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_after_interp_call - SPI routine                                    */
/*  Tidy up after normal return from interpreter call to encode/decode user   */
/*      data                                                                  */
/*                                                                            */
/******************************************************************************/
void idl_es_after_interp_call
(
    IDL_msp_t IDL_msp
)
{
    IDL_es_state_t *p_es_state;
    rpc_iovector_elt_t *p_iovec_elt;
    idl_ulong_int dyn_size;     /* Size of dynamic encoding */
    idl_byte *dyn_buff;         /* Dynamic buffer delivered to user */

    p_es_state = (IDL_es_state_t *)(IDL_msp->IDL_pickling_handle);

    if (p_es_state->IDL_action == IDL_encoding_k)
    {
        switch (p_es_state->IDL_style)
        {
            case IDL_incremental_k:
                /* Last part of pickle already handed to user */
                /* There may be another operation using the same handle
                    - reset state */
                if (IDL_msp->IDL_mem_handle.memory)
                {
                    rpc_ss_mem_free(&IDL_msp->IDL_mem_handle);
                }
                rpc_ss_init_marsh_state(NULL, IDL_msp);
                IDL_msp->IDL_pickling_handle = (rpc_void_p_t)p_es_state;
                break;
            case IDL_fixed_k:
                /* Set size of pickle for user */
                *(p_es_state->IDL_esize) = IDL_msp->IDL_mp
                                                     - IDL_msp->IDL_data_addr;
                break;
            case IDL_dynamic_k:
                if ( (p_es_state->IDL_dyn_buff_chain_head->IDL_next == NULL)
                    && (IDL_msp->IDL_data_addr == IDL_msp->IDL_buff_addr) )
                {
                    /* Intermediate buffer can be handed off to user */
                    p_iovec_elt =
                           p_es_state->IDL_dyn_buff_chain_head->IDL_p_iovec_elt;
                    *(p_es_state->IDL_p_buff_addr) = (idl_byte *)
                                                    (p_iovec_elt->buff_addr);
                    *(p_es_state->IDL_esize) = p_iovec_elt->data_len;
                    /* Release chain machinery */
                    free(p_iovec_elt);
                    free(p_es_state->IDL_dyn_buff_chain_head);
                }
                else
                {
                    idl_es_encode_dyn_size(p_es_state->IDL_dyn_buff_chain_head,
                                                                     &dyn_size);
                    *(p_es_state->IDL_esize) = dyn_size;
                    dyn_buff = (idl_byte *)
			rpc_allocator_allocate(
                                        &IDL_msp->IDL_allocator, dyn_size);
                    if (dyn_buff == NULL)
                        DCETHREAD_RAISE(rpc_x_no_memory);
		    memset(dyn_buff, 0, dyn_size);
                    idl_es_encode_dyn_copy_rel(
                                            p_es_state->IDL_dyn_buff_chain_head,
                                            dyn_buff, IDL_msp);
                    *(p_es_state->IDL_p_buff_addr) = dyn_buff;
                }
                p_es_state->IDL_dyn_buff_chain_head = NULL;
                /* There may be another operation using the same handle
                    - reset state */
                if (IDL_msp->IDL_mem_handle.memory)
                {
                    rpc_ss_mem_free(&IDL_msp->IDL_mem_handle);
                }
                rpc_ss_init_marsh_state(NULL, IDL_msp);
                IDL_msp->IDL_pickling_handle = (rpc_void_p_t)p_es_state;
                break;
            default:
#ifdef DEBUG_INTERP
                printf(
                  "idl_es_after_normal_interp_call - unknown encoding style\n");
                exit(0);
#endif
                DCETHREAD_RAISE(rpc_x_coding_error);
        }

        if (p_es_state->IDL_es_flags & IDL_ES_MIDL_COMPAT)
        {
            idl_byte *mp;
            idl_ulong_int length; /* length without header */

            length = *(p_es_state->IDL_esize) - IDL_ES_TYPE_HEADER_LEN;

            if (p_es_state->IDL_style == IDL_fixed_k)
                mp = p_es_state->IDL_buff_addr;
            else if (p_es_state->IDL_style == IDL_dynamic_k)
                mp = *(p_es_state->IDL_p_buff_addr);
            else
                mp = NULL;

            if (mp != NULL)
            {
                mp += IDL_ES_TYPE_COMMON_HEADER_LEN;

                mp[0] = (length >> 0)  & 0xff;
                mp[1] = (length >> 8)  & 0xff;
                mp[2] = (length >> 16) & 0xff;
                mp[3] = (length >> 24) & 0xff;

                memset(&mp[4], 0, 4);
            }
        }
    }
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_clean_up - SPI routine                                             */
/*  Tidy up after un/pickling action                                          */
/*                                                                            */
/******************************************************************************/
void idl_es_clean_up
(
    IDL_msp_t IDL_msp
)
{
    IDL_es_state_t *p_es_state;
    IDL_dyn_buff_link_t *p_list_elt;
    IDL_dyn_buff_link_t *p_old_list_elt;
    rpc_iovector_elt_t *p_iovec_elt;

    p_es_state = (IDL_es_state_t *)(IDL_msp->IDL_pickling_handle);

    /* Tidy up if abnormal end during incremental encoding */
    if (p_es_state->IDL_action == IDL_encoding_k)
    {
        if (p_es_state->IDL_style == IDL_dynamic_k)
        {
            p_list_elt = p_es_state->IDL_dyn_buff_chain_head;
            /* Release chain of intermediate buffers */
            while (p_list_elt != NULL)
            {
                p_iovec_elt = p_list_elt->IDL_p_iovec_elt;
                if (p_iovec_elt != NULL)
                {
                    if (p_iovec_elt->buff_addr != NULL)
		    {
			rpc_allocator_free(&IDL_msp->IDL_allocator,
				p_iovec_elt->buff_addr);
		    }
                    free(p_iovec_elt);
                }
                p_old_list_elt = p_list_elt;
                p_list_elt = p_list_elt->IDL_next;
                free(p_old_list_elt);
            }
            p_es_state->IDL_dyn_buff_chain_head = NULL;
        }
    }
    /* Release memory allocated by interpreter */
    if (IDL_msp->IDL_mem_handle.memory)
    {
        rpc_ss_mem_free(&IDL_msp->IDL_mem_handle);
    }
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_decode_check_buffer - called from NDR unmarshalling interpreter    */
/*  Called when interpreter has exhausted current buffer                      */
/*                                                                            */
/******************************************************************************/
void idl_es_decode_check_buffer
(
    IDL_msp_t IDL_msp
)
{
    IDL_es_state_t *p_es_state;

    p_es_state = (IDL_es_state_t *)(IDL_msp->IDL_pickling_handle);
    if (p_es_state->IDL_style == IDL_incremental_k)
    {
        (*(p_es_state->IDL_read))(p_es_state->IDL_state,
                                  &IDL_msp->IDL_data_addr,
                                  &IDL_msp->IDL_left_in_buff);
        if (((IDL_msp->IDL_data_addr - (idl_byte *)0) & 7) != 0)
        {
            /* User buffer is not 8-byte aligned */
            IDL_msp->IDL_status = rpc_s_ss_bad_buffer;
            DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
        }
        IDL_msp->IDL_mp = IDL_msp->IDL_data_addr;
    }
    else    /* Exhausted fixed buffer */
    {
        IDL_msp->IDL_status = rpc_s_ss_bad_buffer;
        DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error);
    }
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_inq_encoding_id - API routine                                      */
/*  Give interface ID and operation number to user                            */
/*                                                                            */
/******************************************************************************/
void idl_es_inq_encoding_id
(
    idl_es_handle_t	    h,	    /* [in] decoding handle */
    rpc_if_id_t		    * volatile if_id, /* [out] RPC interface	    */
				    /* identifier (including	    */
				    /* version information)	    */
    idl_ulong_int	    *op,    /* [out] operation number */
    error_status_t	    *st	    /* [out] status */
)
{
    IDL_es_state_t *p_es_state;

    *st = error_status_ok;
    p_es_state = (IDL_es_state_t *)h;
    if ( (p_es_state->IDL_action == IDL_decoding_k)
        && ( ! p_es_state->IDL_pickle_header_read ) )
    {
        /* User wants operation number before decoding pickle body */
        DCETHREAD_TRY
            idl_es_get_encoding_header(&p_es_state->IDL_pickle_header,
                                                         p_es_state->IDL_msp);
        DCETHREAD_CATCH(rpc_x_ss_pipe_comm_error)
            *st = p_es_state->IDL_msp->IDL_status;
        DCETHREAD_ENDTRY
        if (*st != error_status_ok)
            return;
    }
    else if (p_es_state->IDL_pickle_header.IDL_op_num == IDL_INVALID_OP_NUM)
    {
        /* Encoding, and no operation has yet been invoked */
        *st = rpc_s_ss_bad_es_action;
        return;
    }
    *if_id = p_es_state->IDL_pickle_header.IDL_if_id;
    *op = p_es_state->IDL_pickle_header.IDL_op_num;
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_handle_free - API routine                                          */
/*  Frees a idl_es_handle_t and its associated resources                      */
/*                                                                            */
/******************************************************************************/
void idl_es_handle_free
(
    idl_es_handle_t	*h,	    /* [in,out] handle to free */
    error_status_t	*st	    /* [out] status */
)
{
    IDL_es_state_t *p_es_state;

    p_es_state = (IDL_es_state_t *)(*h);
    free(p_es_state->IDL_msp);
    if ((p_es_state->IDL_action == IDL_decoding_k)
        && (p_es_state->IDL_style == IDL_fixed_k)
        && (p_es_state->IDL_align_buff_addr != NULL))
    {
        free(p_es_state->IDL_align_buff_addr);
    }
    free(p_es_state);
    *h = NULL;
    *st = error_status_ok;
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_set_attrs - API routine                                            */
/*  Set attribute flags in a idl_es_handle_t                                  */
/*                                                                            */
/******************************************************************************/
void idl_es_set_attrs(
	idl_es_handle_t h,
	unsigned32 flags,
	error_status_t *st)
{
	IDL_es_state_t *p_es_state = (IDL_es_state_t *)h;

	p_es_state->IDL_es_flags = flags;
	*st = error_status_ok;
	return;
}

/******************************************************************************/
/*                                                                            */
/*  idl_es_inq_attrs - API routine                                            */
/*  Get the flags from a idl_es_handle_t                                      */
/*                                                                            */
/******************************************************************************/
void idl_es_inq_attrs(
	idl_es_handle_t h,
	unsigned32 *flags,
	error_status_t *st)
{
	IDL_es_state_t *p_es_state = (IDL_es_state_t *)h;

	*flags = p_es_state->IDL_es_flags;
	*st = error_status_ok;
	return;
}