/* * 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@ */ /* ** ** NAME ** ** cninit.c ** ** FACILITY: ** ** Remote Procedure Call (RPC) ** ** ABSTRACT: ** ** The NCA Connection Protocol Initialization Service. ** ** */ #include <commonp.h> /* Common declarations for all RPC runtime */ #include <com.h> /* Common communications services */ #include <comprot.h> /* Common protocol services */ #include <cnp.h> /* NCA connection private declarations */ #include <cncall.h> /* NCA connection call service */ #include <cnid.h> /* NCA Connection local ID service */ #include <cnbind.h> /* NCA connection binding service */ #include <cnmgmt.h> /* NCA connection management service */ #include <cnnet.h> /* NCA connection network service */ #include <cnfbuf.h> /* NCA connection fragment buffer service */ #include <cnpkt.h> /* NCA connection packet layout */ #include <cnassoc.h> /* NCA connection association service */ void rpc__cn_minute_system_time (void); void rpc__cn_init_func(void); /* * INTERNAL variables. */ INTERNAL rpc_prot_call_epv_t cn_call_epv = { .call_start = rpc__cn_call_start, .call_transmit = rpc__cn_call_transmit, .call_transceive = rpc__cn_call_transceive, .call_receive = rpc__cn_call_receive, .call_end = rpc__cn_call_end, .call_block_until_free = rpc__cn_call_block_until_free, .call_transmit_fault = rpc__cn_call_transmit_fault, .call_cancel = rpc__cn_call_alert, .call_receive_fault = rpc__cn_call_receive_fault, .call_did_mgr_execute = rpc__cn_call_did_mgr_execute }; INTERNAL rpc_prot_mgmt_epv_t cn_mgmt_epv = { .mgmt_inq_calls_sent = rpc__cn_mgmt_inq_calls_sent, .mgmt_inq_calls_rcvd = rpc__cn_mgmt_inq_calls_rcvd, .mgmt_inq_pkts_sent = rpc__cn_mgmt_inq_pkts_sent, .mgmt_inq_pkts_rcvd = rpc__cn_mgmt_inq_pkts_rcvd, }; INTERNAL rpc_prot_binding_epv_t cn_binding_epv = { .binding_alloc = rpc__cn_binding_alloc, .binding_init = rpc__cn_binding_init, .binding_reset = rpc__cn_binding_reset, .binding_changed = rpc__cn_binding_changed, .binding_free = rpc__cn_binding_free, .binding_inq_addr = rpc__cn_binding_inq_addr, .binding_inq_client = rpc__cn_binding_inq_client, .binding_copy = rpc__cn_binding_copy, .binding_cross_fork = rpc__cn_binding_cross_fork }; INTERNAL rpc_prot_network_epv_t cn_network_epv = { .network_use_socket = rpc__cn_network_use_socket, .network_use_protseq = rpc__cn_network_use_protseq, .network_mon = rpc__cn_network_mon, .network_stop_mon = rpc__cn_network_stop_mon, .network_maint = rpc__cn_network_maint, .network_stop_maint = rpc__cn_network_stop_maint, .network_select_disp = rpc__cn_network_select_dispatch, .network_inq_prot_vers = rpc__cn_network_inq_prot_vers, .network_close = rpc__cn_network_close, .network_getpeereid = rpc__cn_network_getpeereid }; /***********************************************************************/ #include <comp.h> void rpc__cn_init_func(void) { static rpc_protocol_id_elt_t prot[1] = { { rpc__ncacn_init, /* Connection-RPC */ NULL, RPC_C_PROTOCOL_ID_NCACN, NULL, NULL, NULL, NULL } }; rpc__register_protocol_id(prot, 1); } /* **++ ** ** ROUTINE NAME: rpc__ncacn_init ** ** SCOPE: PRIVATE - declared in comprot.h ** ** DESCRIPTION: ** ** This routine will handle one-time initialization for the NCA ** Connection Protocol Service. It will also return the Entry Point ** Vectors which comprise the external interface to the NCA ** Connection Protocol Service. ** ** INPUTS: none ** ** INPUTS/OUTPUTS: ** ** call_epv The Call Service interface. ** mgmt_epv The Manangement Service interface. ** binding_epv The Binding Service interface. ** network_epv The Network Service interface. ** fork_handler The fork handler routine. ** ** OUTPUTS: ** ** st The return status of this routine. ** ** IMPLICIT INPUTS: none ** ** IMPLICIT OUTPUTS: none ** ** FUNCTION VALUE: ** ** rpc_s_coding_error ** rpc_s_ok ** ** SIDE EFFECTS: none ** **-- **/ void rpc__ncacn_init ( rpc_prot_call_epv_p_t *call_epv, rpc_prot_mgmt_epv_p_t *mgmt_epv, rpc_prot_binding_epv_p_t *binding_epv, rpc_prot_network_epv_p_t *network_epv, rpc_prot_fork_handler_fn_t *fork_handler, unsigned32 *st ) { CODING_ERROR (st); /* * Initialize the management counters. */ rpc__cn_mgmt_init (); /* * Initialize the CN lookaside list condition variable. */ RPC_COND_INIT (rpc_g_cn_lookaside_cond, rpc_g_global_mutex); /* * Initialize the global sequence number cell. */ rpc__cn_init_seqnum (); /* * Initialize the global call_id cell. */ rpc_g_cn_call_id = 0; /* * Initialize the call rep lookaside list. */ rpc__list_desc_init (&rpc_g_cn_call_lookaside_list, RPC_C_CN_CALL_LOOKASIDE_MAX, sizeof (rpc_cn_call_rep_t), RPC_C_MEM_CN_CALL_REP, (rpc_list_element_alloc_fn_t) rpc__cn_call_ccb_create, (rpc_list_element_alloc_fn_t) rpc__cn_call_ccb_free, &rpc_g_global_mutex, &rpc_g_cn_lookaside_cond); /* * Initialize binding_rep lookaside list. */ rpc__list_desc_init (&rpc_g_cn_binding_lookaside_list, RPC_C_CN_BINDING_LOOKASIDE_MAX, sizeof (rpc_cn_binding_rep_t), RPC_C_MEM_CN_BINDING_REP, NULL, NULL, &rpc_g_global_mutex, &rpc_g_cn_lookaside_cond); /* * Initialize fragment buffer lookaside lists. Note that 7 extra * bytes will be allocated per structure. This is so that we can * adjust the data pointer to be on an 8 byte boundary and still * have the same size data area. Note that the CN global mutex * cannot be used to protect the large fragbuf lookaside list, * hence the NULL input args for mutex and cond to * rpc__list_desc_init. This is because large fragbufs are given * to stubs which indirectly call the fragbuf free routine which * calls the list free routine. Since this fragbuf free routine is * also called internally, where the CN global mutex is held, * it would be difficult to determine whether the CN global mutex * needed to be acquired in the fragbuf free routine. */ rpc__list_desc_init (&rpc_g_cn_lg_fbuf_lookaside_list, RPC_C_CN_FRAGBUF_LOOKASIDE_MAX, RPC_C_CN_LG_FRAGBUF_ALLOC_SIZE + 7, RPC_C_MEM_CN_LG_FRAGBUF, NULL, NULL, NULL, NULL); rpc__list_desc_init (&rpc_g_cn_sm_fbuf_lookaside_list, RPC_C_CN_FRAGBUF_LOOKASIDE_MAX, RPC_C_CN_SM_FRAGBUF_ALLOC_SIZE + 7, RPC_C_MEM_CN_SM_FRAGBUF, NULL, NULL, &rpc_g_global_mutex, &rpc_g_cn_lookaside_cond); /* * Initialize the association control block lookaside list. */ rpc__list_desc_init (&rpc_g_cn_assoc_lookaside_list, RPC_C_CN_ASSOC_LOOKASIDE_MAX, sizeof(rpc_cn_assoc_t), RPC_C_MEM_CN_ASSOC, (rpc_list_element_alloc_fn_t) rpc__cn_assoc_acb_create, (rpc_list_element_alloc_fn_t) rpc__cn_assoc_acb_free, &rpc_g_global_mutex, &rpc_g_cn_lookaside_cond); /* * Initialize the association syntax element lookaside list. */ rpc__list_desc_init (&rpc_g_cn_syntax_lookaside_list, RPC_C_CN_SYNTAX_LOOKASIDE_MAX, sizeof(rpc_cn_syntax_t), RPC_C_MEM_CN_SYNTAX, NULL, NULL, &rpc_g_global_mutex, &rpc_g_cn_lookaside_cond); /* * Initialize the association security context element lookaside list. */ rpc__list_desc_init (&rpc_g_cn_sec_lookaside_list, RPC_C_CN_SEC_LOOKASIDE_MAX, sizeof(rpc_cn_sec_context_t), RPC_C_MEM_CN_SEC_CONTEXT, NULL, NULL, &rpc_g_global_mutex, &rpc_g_cn_lookaside_cond); /* * Initialize the association group table. */ rpc__cn_assoc_grp_tbl_init (); /* * Return the interface to the NCA Connection Protocol Service in the four * EPVs. */ *call_epv = &cn_call_epv; *mgmt_epv = &cn_mgmt_epv; *binding_epv = &cn_binding_epv; *network_epv = &cn_network_epv; if (RPC_DBG(rpc_es_dbg_stats, 5)) { atexit (rpc__cn_stats_print); } *fork_handler = NULL; *st = rpc_s_ok; }