17c478bd9Sstevel@tonic-gate /*
27c478bd9Sstevel@tonic-gate * CDDL HEADER START
37c478bd9Sstevel@tonic-gate *
47c478bd9Sstevel@tonic-gate * The contents of this file are subject to the terms of the
57c478bd9Sstevel@tonic-gate * Common Development and Distribution License, Version 1.0 only
67c478bd9Sstevel@tonic-gate * (the "License"). You may not use this file except in compliance
77c478bd9Sstevel@tonic-gate * with the License.
87c478bd9Sstevel@tonic-gate *
97c478bd9Sstevel@tonic-gate * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
107c478bd9Sstevel@tonic-gate * or http://www.opensolaris.org/os/licensing.
117c478bd9Sstevel@tonic-gate * See the License for the specific language governing permissions
127c478bd9Sstevel@tonic-gate * and limitations under the License.
137c478bd9Sstevel@tonic-gate *
147c478bd9Sstevel@tonic-gate * When distributing Covered Code, include this CDDL HEADER in each
157c478bd9Sstevel@tonic-gate * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
167c478bd9Sstevel@tonic-gate * If applicable, add the following below this CDDL HEADER, with the
177c478bd9Sstevel@tonic-gate * fields enclosed by brackets "[]" replaced with your own identifying
187c478bd9Sstevel@tonic-gate * information: Portions Copyright [yyyy] [name of copyright owner]
197c478bd9Sstevel@tonic-gate *
207c478bd9Sstevel@tonic-gate * CDDL HEADER END
217c478bd9Sstevel@tonic-gate */
227c478bd9Sstevel@tonic-gate /*
237c478bd9Sstevel@tonic-gate * Copyright (c) 1999 by Sun Microsystems, Inc.
247c478bd9Sstevel@tonic-gate * All rights reserved.
257c478bd9Sstevel@tonic-gate */
267c478bd9Sstevel@tonic-gate
277c478bd9Sstevel@tonic-gate #include <stdio.h>
287c478bd9Sstevel@tonic-gate #include <stdlib.h>
297c478bd9Sstevel@tonic-gate #include <thread.h>
307c478bd9Sstevel@tonic-gate #include <synch.h>
317c478bd9Sstevel@tonic-gate #include <syslog.h>
327c478bd9Sstevel@tonic-gate #include <arpa/inet.h>
337c478bd9Sstevel@tonic-gate #include <slp-internal.h>
347c478bd9Sstevel@tonic-gate #include <slp_net_utils.h>
357c478bd9Sstevel@tonic-gate
SLPOpen(const char * pcLang,SLPBoolean isAsync,SLPHandle * phSLP)367c478bd9Sstevel@tonic-gate SLPError SLPOpen(const char *pcLang, SLPBoolean isAsync, SLPHandle *phSLP) {
377c478bd9Sstevel@tonic-gate slp_handle_impl_t *hp;
387c478bd9Sstevel@tonic-gate
397c478bd9Sstevel@tonic-gate if (!pcLang || !phSLP) {
407c478bd9Sstevel@tonic-gate return (SLP_PARAMETER_BAD);
417c478bd9Sstevel@tonic-gate }
427c478bd9Sstevel@tonic-gate
437c478bd9Sstevel@tonic-gate /* allocate the handle */
447c478bd9Sstevel@tonic-gate if (!(hp = malloc(sizeof (*hp)))) {
457c478bd9Sstevel@tonic-gate slp_err(LOG_CRIT, 0, "SLPOpen", "out of memory");
467c478bd9Sstevel@tonic-gate return (SLP_MEMORY_ALLOC_FAILED);
477c478bd9Sstevel@tonic-gate }
487c478bd9Sstevel@tonic-gate
497c478bd9Sstevel@tonic-gate /* initialize outcall synchronization */
507c478bd9Sstevel@tonic-gate hp->pending_outcall = SLP_FALSE;
51*0daffde0SToomas Soome (void) mutex_init(&(hp->outcall_lock), USYNC_THREAD, NULL);
52*0daffde0SToomas Soome (void) cond_init(&(hp->outcall_cv), USYNC_THREAD, NULL);
537c478bd9Sstevel@tonic-gate hp->close_on_end = SLP_FALSE;
547c478bd9Sstevel@tonic-gate hp->consumer_tid = 0;
557c478bd9Sstevel@tonic-gate
567c478bd9Sstevel@tonic-gate /* locale property overrides argument */
577c478bd9Sstevel@tonic-gate if (!(hp->locale = SLPGetProperty(SLP_CONFIG_LOCALE))) {
587c478bd9Sstevel@tonic-gate hp->locale = pcLang;
597c478bd9Sstevel@tonic-gate }
607c478bd9Sstevel@tonic-gate /* Make sure the language string is under our ownership */
617c478bd9Sstevel@tonic-gate if (!(hp->locale = strdup(hp->locale))) {
627c478bd9Sstevel@tonic-gate free(hp);
637c478bd9Sstevel@tonic-gate slp_err(LOG_CRIT, 0, "SLPOpen", "out of memory");
647c478bd9Sstevel@tonic-gate return (SLP_MEMORY_ALLOC_FAILED);
657c478bd9Sstevel@tonic-gate }
667c478bd9Sstevel@tonic-gate
677c478bd9Sstevel@tonic-gate hp->cancel = 0;
687c478bd9Sstevel@tonic-gate
697c478bd9Sstevel@tonic-gate /* Asynchronous operation? */
707c478bd9Sstevel@tonic-gate if (isAsync)
717c478bd9Sstevel@tonic-gate hp->async = SLP_TRUE;
727c478bd9Sstevel@tonic-gate else
737c478bd9Sstevel@tonic-gate hp->async = SLP_FALSE;
747c478bd9Sstevel@tonic-gate
757c478bd9Sstevel@tonic-gate /* TCP vars -- these are NULL until actually needed */
767c478bd9Sstevel@tonic-gate hp->tcp_lock = NULL;
777c478bd9Sstevel@tonic-gate hp->tcp_wait = NULL;
787c478bd9Sstevel@tonic-gate hp->tcp_ref_cnt = 0;
797c478bd9Sstevel@tonic-gate
807c478bd9Sstevel@tonic-gate /* Consumer / Producer pipe */
817c478bd9Sstevel@tonic-gate hp->q = NULL;
827c478bd9Sstevel@tonic-gate
837c478bd9Sstevel@tonic-gate /* Interface info, loaded on demand */
847c478bd9Sstevel@tonic-gate hp->ifinfo = NULL;
857c478bd9Sstevel@tonic-gate
867c478bd9Sstevel@tonic-gate /* force multicast, false by default */
877c478bd9Sstevel@tonic-gate hp->force_multicast = SLP_FALSE;
887c478bd9Sstevel@tonic-gate
897c478bd9Sstevel@tonic-gate /* internal call, false by default */
907c478bd9Sstevel@tonic-gate hp->internal_call = SLP_FALSE;
917c478bd9Sstevel@tonic-gate
927c478bd9Sstevel@tonic-gate *phSLP = hp;
937c478bd9Sstevel@tonic-gate return (SLP_OK);
947c478bd9Sstevel@tonic-gate }
957c478bd9Sstevel@tonic-gate
slp_cleanup_handle(slp_handle_impl_t * hp)967c478bd9Sstevel@tonic-gate void slp_cleanup_handle(slp_handle_impl_t *hp) {
977c478bd9Sstevel@tonic-gate /* free the handle */
987c478bd9Sstevel@tonic-gate if (hp->tcp_lock) free(hp->tcp_lock);
997c478bd9Sstevel@tonic-gate if (hp->tcp_wait) free(hp->tcp_wait);
1007c478bd9Sstevel@tonic-gate if (hp->ifinfo) {
1017c478bd9Sstevel@tonic-gate slp_free_ifinfo(hp->ifinfo);
1027c478bd9Sstevel@tonic-gate free(hp->ifinfo);
1037c478bd9Sstevel@tonic-gate }
1047c478bd9Sstevel@tonic-gate free((void *) hp->locale);
1057c478bd9Sstevel@tonic-gate free(hp);
1067c478bd9Sstevel@tonic-gate }
1077c478bd9Sstevel@tonic-gate
SLPClose(SLPHandle hSLP)1087c478bd9Sstevel@tonic-gate void SLPClose(SLPHandle hSLP) {
1097c478bd9Sstevel@tonic-gate slp_handle_impl_t *hp = (slp_handle_impl_t *)hSLP;
1107c478bd9Sstevel@tonic-gate
1117c478bd9Sstevel@tonic-gate if (!hSLP) {
1127c478bd9Sstevel@tonic-gate return;
1137c478bd9Sstevel@tonic-gate }
1147c478bd9Sstevel@tonic-gate
1157c478bd9Sstevel@tonic-gate /*
1167c478bd9Sstevel@tonic-gate * If an outcall is pending on this handle:
1177c478bd9Sstevel@tonic-gate * If we are being called from a callback resulting
1187c478bd9Sstevel@tonic-gate * from the outcall associated with this handle or
1197c478bd9Sstevel@tonic-gate * if close_on_end has already been set:
1207c478bd9Sstevel@tonic-gate * just set close on end and return -- the cleanup
1217c478bd9Sstevel@tonic-gate * will be done when the outcall is finished.
1227c478bd9Sstevel@tonic-gate * else
1237c478bd9Sstevel@tonic-gate * wait on the outcall cv for the outcall to complete
1247c478bd9Sstevel@tonic-gate * Proceed with cleanup
1257c478bd9Sstevel@tonic-gate */
1267c478bd9Sstevel@tonic-gate (void) mutex_lock(&(hp->outcall_lock));
1277c478bd9Sstevel@tonic-gate if (hp->pending_outcall) {
1287c478bd9Sstevel@tonic-gate /* end the consumer thread */
1297c478bd9Sstevel@tonic-gate /* this will also kill the producer thread and close net */
1307c478bd9Sstevel@tonic-gate hp->cancel = 1;
1317c478bd9Sstevel@tonic-gate if (hp->q) {
1327c478bd9Sstevel@tonic-gate if (slp_enqueue_at_head(hp->q, NULL) != SLP_OK) {
1337c478bd9Sstevel@tonic-gate goto cleanup;
1347c478bd9Sstevel@tonic-gate }
1357c478bd9Sstevel@tonic-gate }
1367c478bd9Sstevel@tonic-gate
1377c478bd9Sstevel@tonic-gate if (thr_self() == hp->consumer_tid || hp->close_on_end) {
1387c478bd9Sstevel@tonic-gate /* SLPClose called from callback */
1397c478bd9Sstevel@tonic-gate hp->close_on_end = SLP_TRUE;
1407c478bd9Sstevel@tonic-gate (void) mutex_unlock(&(hp->outcall_lock));
1417c478bd9Sstevel@tonic-gate return;
1427c478bd9Sstevel@tonic-gate }
1437c478bd9Sstevel@tonic-gate /* else not called from callback; wait for outcall to end */
1447c478bd9Sstevel@tonic-gate while (hp->pending_outcall) {
1457c478bd9Sstevel@tonic-gate (void) cond_wait(&(hp->outcall_cv), &(hp->outcall_lock));
1467c478bd9Sstevel@tonic-gate }
1477c478bd9Sstevel@tonic-gate }
1487c478bd9Sstevel@tonic-gate (void) mutex_unlock(&(hp->outcall_lock));
1497c478bd9Sstevel@tonic-gate
1507c478bd9Sstevel@tonic-gate cleanup:
1517c478bd9Sstevel@tonic-gate slp_cleanup_handle(hp);
1527c478bd9Sstevel@tonic-gate }
153