/* * * (c) Copyright 1991 OPEN SOFTWARE FOUNDATION, INC. * (c) Copyright 1991 HEWLETT-PACKARD COMPANY * (c) Copyright 1991 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. * */ /* */ /* ** ** NAME: ** ** marbfman.c ** ** FACILITY: ** ** IDL Stub Runtime Support ** ** ABSTRACT: ** ** Buffer management when marshalling a node ** ** VERSION: DCE 1.0 ** */ #if HAVE_CONFIG_H #include #endif /* The ordering of the following 3 includes should NOT be changed! */ #include #include #include #ifdef PERFMON #include #endif void rpc_ss_marsh_change_buff #ifdef IDL_PROTOTYPES ( rpc_ss_marsh_state_t *msp, /* Pointer to marshalling state block */ unsigned long size_next_structure /* Size of next structure to be marshalled */ ) #else ( msp, size_next_structure ) rpc_ss_marsh_state_t *msp; /* Pointer to marshalling state block */ unsigned long size_next_structure; /* Size of next structure to be marshalled */ #endif { ndr_byte *wp_buff; unsigned long req_buff_size; int preserved_offset; /* Must start marshalling in new buffer at same offset (mod 8) we were at in old buffer */ #ifdef PERFMON RPC_SS_MARSH_CHANGE_BUFF_N; #endif preserved_offset = ((intptr_t)msp->mp) % 8; /* If a current iovector and buffer exist */ if (msp->p_iovec->elt[0].buff_addr != NULL) { /* Despatch buffer to the comm layer */ msp->p_iovec->elt[0].data_len = msp->p_iovec->elt[0].buff_len - (msp->p_iovec->elt[0].data_addr - msp->p_iovec->elt[0].buff_addr) - msp->space_in_buff; rpc_call_transmit ( msp->call_h, msp->p_iovec, msp->p_st ); #ifdef NO_EXCEPTIONS if (*msp->p_st != error_status_ok) return; #else /* If cancelled, raise the cancelled exception */ if (*msp->p_st==rpc_s_call_cancelled) DCETHREAD_RAISE(RPC_SS_THREADS_X_CANCELLED); /* * Otherwise, raise the pipe comm error which causes the stub to * report the value of the status variable. */ if (*msp->p_st != error_status_ok) DCETHREAD_RAISE(rpc_x_ss_pipe_comm_error); #endif } /* Get a new buffer */ req_buff_size = size_next_structure + 18; /* 18 = 7 bytes worst case alignment before data, then we expect another node to follow, so 3 bytes worst case alignment 4 bytes offset 4 bytes node number */ if (req_buff_size < NIDL_BUFF_SIZE) req_buff_size = NIDL_BUFF_SIZE; req_buff_size += 7; /* malloc may not deliver 8-byte aligned memory */ wp_buff = (ndr_byte *)malloc( req_buff_size ); if (wp_buff == NULL) { DCETHREAD_RAISE( rpc_x_no_memory ); return; } /* Fill in fields of the iovector */ msp->p_iovec->num_elt = 1; msp->p_iovec->elt[0].buff_dealloc = (rpc_ss_dealloc_t)free; msp->p_iovec->elt[0].flags = 0; msp->p_iovec->elt[0].buff_addr = wp_buff; msp->p_iovec->elt[0].buff_len = req_buff_size; /* malloc may not deliver 8-byte aligned memory */ wp_buff = (byte_p_t)(((wp_buff - (byte_p_t)0) + 7) & ~7); msp->p_iovec->elt[0].data_addr = wp_buff + preserved_offset; /* Output parameters */ msp->mp = (rpc_mp_t)msp->p_iovec->elt[0].data_addr; msp->space_in_buff = req_buff_size - (msp->p_iovec->elt[0].data_addr - msp->p_iovec->elt[0].buff_addr); #ifdef PERFMON RPC_SS_MARSH_CHANGE_BUFF_X; #endif }