illumos/illumos-gate: usr/src/lib/libsysevent/libsysevent.c comparison

comparison usr/src/lib/libsysevent/libsysevent.c @ 12979:ab9ae749152f

PSARC/2009/617 Software Events Notification Parameters CLI PSARC/2009/618 snmp-notify: SNMP Notification Daemon for Software Events PSARC/2009/619 smtp-notify: Email Notification Daemon for Software Events PSARC/2010/225 fmd for non-global Solaris zones PSARC/2010/226 Solaris Instance UUID PSARC/2010/227 nvlist_nvflag(3NVPAIR) PSARC/2010/228 libfmevent additions PSARC/2010/257 sysevent_evc_setpropnvl and sysevent_evc_getpropnvl PSARC/2010/265 FMRI and FMA Event Stabilty, 'ireport' category 1 event class, and the 'sw' FMRI scheme PSARC/2010/278 FMA/SMF integration: instance state transitions PSARC/2010/279 Modelling panics within FMA PSARC/2010/290 logadm.conf upgrade 6392476 fmdump needs to pretty-print 6393375 userland ereport/ireport event generation interfaces 6445732 Add email notification agent for FMA and software events 6804168 RFE: Allow an efficient means to monitor SMF services status changes 6866661 scf_values_destroy(3SCF) will segfault if is passed NULL 6884709 Add snmp notification agent for FMA and software events 6884712 Add private interface to tap into libfmd_msg macro expansion capabilities 6897919 fmd to run in a non-global zone 6897937 fmd use of non-private doors is not safe 6900081 add a UUID to Solaris kernel image for use in crashdump identification 6914884 model panic events as a defect diagnosis in FMA 6944862 fmd_case_open_uuid, fmd_case_uuisresolved, fmd_nvl_create_defect 6944866 log legacy sysevents in fmd 6944867 enumerate svc scheme in topo 6944868 software-diagnosis and software-response fmd modules 6944870 model SMF maintenance state as a defect diagnosis in FMA 6944876 savecore runs in foreground for systems with zfs root and dedicated dump 6965796 Implement notification parameters for SMF state transitions and FMA events 6968287 SUN-FM-MIB.mib needs to be updated to reflect Oracle information 6972331 logadm.conf upgrade PSARC/2010/290

author	Gavin Maltby <gavin.maltby@oracle.com>
date	Fri, 30 Jul 2010 17:04:17 +1000
parents	8f30d0e611c6
children

comparison

equal deleted inserted replaced

-:19d842faf8e4
+:ab9ae749152f
 *
 * CDDL HEADER END
 */
 /*
-* Copyright 2010 Sun Microsystems, Inc.  All rights reserved.
+* Copyright (c) 2000, 2010, Oracle and/or its affiliates. All rights reserved.
-* Use is subject to license terms.
 */
 #include <stdio.h>
 #include <fcntl.h>
 #include <errno.h>
 #include <stdlib.h>
 #include <string.h>
 #include <strings.h>
 #include <synch.h>
 #include <pthread.h>
+#include <signal.h>
 #include <thread.h>
 #include <libnvpair.h>
 #include <assert.h>
 #include <sys/stat.h>
 #include <sys/types.h>
 	subscriber_priv_t *sub_info;
 	sysevent_queue_t *evqp;
 	sub_info = (subscriber_priv_t *)SH_PRIV_DATA(shp);
+	/* See hack alert in sysevent_bind_subscriber_cmn */
+	if (sub_info->sp_handler_tid == NULL)
+		sub_info->sp_handler_tid = thr_self();
 	(void) mutex_lock(&sub_info->sp_qlock);
 	for (;;) {
 		while (sub_info->sp_evq_head == NULL && SH_BOUND(shp)) {
 			(void) cond_wait(&sub_info->sp_cv, &sub_info->sp_qlock);
 		}
 	(void) mutex_unlock(SH_LOCK(shp));
 	errno = error;
 	return (-1);
 }
-/*
+static pthread_once_t xdoor_thrattr_once = PTHREAD_ONCE_INIT;
-* sysevent_bind_subscriber - Bind an event receiver to an event channel
+static pthread_attr_t xdoor_thrattr;
-*/
-int
+static void
-sysevent_bind_subscriber(sysevent_handle_t *shp,
+xdoor_thrattr_init(void)
-	void (*event_handler)(sysevent_t *ev))
+{
+	(void) pthread_attr_init(&xdoor_thrattr);
+	(void) pthread_attr_setdetachstate(&xdoor_thrattr,
+	    PTHREAD_CREATE_DETACHED);
+	(void) pthread_attr_setscope(&xdoor_thrattr, PTHREAD_SCOPE_SYSTEM);
+}
+static int
+xdoor_server_create(door_info_t *dip, void *(*startf)(void *),
+void *startfarg, void *cookie)
+{
+	struct sysevent_subattr_impl *xsa = cookie;
+	pthread_attr_t *thrattr;
+	sigset_t oset;
+	int err;
+	if (xsa->xs_thrcreate) {
+		return (xsa->xs_thrcreate(dip, startf, startfarg,
+		    xsa->xs_thrcreate_cookie));
+	}
+	if (xsa->xs_thrattr == NULL) {
+		(void) pthread_once(&xdoor_thrattr_once, xdoor_thrattr_init);
+		thrattr = &xdoor_thrattr;
+	} else {
+		thrattr = xsa->xs_thrattr;
+	}
+	(void) pthread_sigmask(SIG_SETMASK, &xsa->xs_sigmask, &oset);
+	err = pthread_create(NULL, thrattr, startf, startfarg);
+	(void) pthread_sigmask(SIG_SETMASK, &oset, NULL);
+	return (err == 0 ? 1 : -1);
+}
+static void
+xdoor_server_setup(void *cookie)
+{
+	struct sysevent_subattr_impl *xsa = cookie;
+	if (xsa->xs_thrsetup) {
+		xsa->xs_thrsetup(xsa->xs_thrsetup_cookie);
+	} else {
+		(void) pthread_setcancelstate(PTHREAD_CANCEL_DISABLE, NULL);
+		(void) pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL);
+	}
+}
+static int
+sysevent_bind_subscriber_cmn(sysevent_handle_t *shp,
+	void (*event_handler)(sysevent_t *ev),
+	sysevent_subattr_t *subattr)
 {
 	int fd = -1;
 	int error = 0;
 	uint32_t sub_id = 0;
 	char door_name[MAXPATHLEN];
 	subscriber_priv_t *sub_info;
+	int created;
+	struct sysevent_subattr_impl *xsa =
+	    (struct sysevent_subattr_impl *)subattr;
 	if (shp == NULL || event_handler == NULL) {
 		errno = EINVAL;
 		return (-1);
 	}
 	/*
 	 * Create the sysevent door service for this client.
 	 * syseventd will use this door service to propagate
 	 * events to the client.
 	 */
-	if ((SH_DOOR_DESC(shp) = door_create(event_deliver_service,
+	if (subattr == NULL) {
-	    (void *)shp, DOOR_REFUSE_DESC | DOOR_NO_CANCEL)) == -1) {
+		SH_DOOR_DESC(shp) = door_create(event_deliver_service,
+		    (void *)shp, DOOR_REFUSE_DESC | DOOR_NO_CANCEL);
+	} else {
+		SH_DOOR_DESC(shp) = door_xcreate(event_deliver_service,
+		    (void *)shp,
+		    DOOR_REFUSE_DESC | DOOR_NO_CANCEL | DOOR_NO_DEPLETION_CB,
+		    xdoor_server_create, xdoor_server_setup,
+		    (void *)subattr, 1);
+	}
+	if (SH_DOOR_DESC(shp) == -1) {
 		dprint("sysevent_bind_subscriber: door create failed: "
 		    "%s\n", strerror(errno));
 		error = EFAULT;
 		goto fail;
 	}
 	SH_BOUND(shp) = 1;
 	SH_TYPE(shp) = SUBSCRIBER;
 	SH_PRIV_DATA(shp) = (void *)sub_info;
 	/* Create an event handler thread */
-	if (thr_create(NULL, NULL, (void *(*)(void *))subscriber_event_handler,
+	if (xsa == NULL || xsa->xs_thrcreate == NULL) {
-	    shp, THR_BOUND, &sub_info->sp_handler_tid) != 0) {
+		created = thr_create(NULL, NULL,
+		    (void *(*)(void *))subscriber_event_handler,
+		    shp, THR_BOUND, &sub_info->sp_handler_tid) == 0;
+	} else {
+		/*
+		 * A terrible hack.  We will use the extended private
+		 * door thread creation function the caller passed in to
+		 * create the event handler thread.  That function will
+		 * be called with our chosen thread start function and arg
+		 * instead of the usual libc-provided ones, but that's ok
+		 * as it is required to use them verbatim anyway.  We will
+		 * pass a NULL door_info_t pointer to the function - so
+		 * callers depending on this hack had better be prepared
+		 * for that.  All this allow the caller to rubberstamp
+		 * the created thread as it wishes.  But we don't get
+		 * the created threadid with this, so we modify the
+		 * thread start function to stash it.
+		 */
+		created = xsa->xs_thrcreate(NULL,
+		    (void *(*)(void *))subscriber_event_handler,
+		    shp, xsa->xs_thrcreate_cookie) == 1;
+	}
+	if (!created) {
 		error = EFAULT;
 		goto fail;
 	}
 	(void) mutex_unlock(SH_LOCK(shp));
 	return (-1);
 }
 /*
+* sysevent_bind_subscriber - Bind an event receiver to an event channel
+*/
+int
+sysevent_bind_subscriber(sysevent_handle_t *shp,
+	void (*event_handler)(sysevent_t *ev))
+{
+	return (sysevent_bind_subscriber_cmn(shp, event_handler, NULL));
+}
+/*
+* sysevent_bind_xsubscriber - Bind a subscriber using door_xcreate with
+* attributes specified.
+*/
+int
+sysevent_bind_xsubscriber(sysevent_handle_t *shp,
+	void (*event_handler)(sysevent_t *ev), sysevent_subattr_t *subattr)
+{
+	return (sysevent_bind_subscriber_cmn(shp, event_handler, subattr));
+}
+/*
 * sysevent_register_event - register an event class and associated subclasses
 *		for an event subscriber
 */
 int
 sysevent_register_event(sysevent_handle_t *shp,
 	    SH_ID(shp), 0, NULL);
 	/* Close down event delivery facilities */
 	(void) door_revoke(SH_DOOR_DESC(shp));
 	(void) fdetach(SH_DOOR_NAME(shp));
 	/*
 	 * Release resources and wait for pending event delivery to
 	 * complete.
 	 */
 	(void) mutex_lock(&sub_info->sp_qlock);
 	SH_BOUND(shp) = 0;
 	/* Signal event handler and drain the subscriber's event queue */
 	(void) cond_signal(&sub_info->sp_cv);
 	(void) mutex_unlock(&sub_info->sp_qlock);
-	(void) thr_join(sub_info->sp_handler_tid, NULL, NULL);
+	if (sub_info->sp_handler_tid != NULL)
+		(void) thr_join(sub_info->sp_handler_tid, NULL, NULL);
 	(void) cond_destroy(&sub_info->sp_cv);
 	(void) mutex_destroy(&sub_info->sp_qlock);
 	free(sub_info->sp_door_name);
 	free(sub_info);
 /*
 * Evolving APIs to subscribe to syseventd(1M) system events.
 */
-/*
+static sysevent_handle_t *
-* sysevent_bind_handle - Bind application event handler for syseventd
+sysevent_bind_handle_cmn(void (*event_handler)(sysevent_t *ev),
-*		subscription.
+sysevent_subattr_t *subattr)
-*/
-sysevent_handle_t *
-sysevent_bind_handle(void (*event_handler)(sysevent_t *ev))
 {
 	sysevent_handle_t *shp;
 	if (getuid() != 0) {
 		errno = EACCES;
 	if ((shp = sysevent_open_channel(SYSEVENTD_CHAN)) == NULL) {
 		return (NULL);
 	}
-	if (sysevent_bind_subscriber(shp, event_handler) != 0) {
+	if (sysevent_bind_xsubscriber(shp, event_handler, subattr) != 0) {
 		/*
 		 * Ask syseventd to clean-up any stale subcribers and try to
 		 * to bind again
 		 */
 		if (errno == EBUSY) {
 			(void) clnt_deliver_event(pub_fd, (void *)&rargs,
 			    sizeof (struct reg_args), &result, sizeof (result));
 			(void) close(pub_fd);
 			/* Try to bind again */
-			if (sysevent_bind_subscriber(shp, event_handler) != 0) {
+			if (sysevent_bind_xsubscriber(shp, event_handler,
+			    subattr) != 0) {
 				sysevent_close_channel(shp);
 				return (NULL);
 			}
 		} else {
 			sysevent_close_channel(shp);
 	return (shp);
 }
 /*
+* sysevent_bind_handle - Bind application event handler for syseventd
+*		subscription.
+*/
+sysevent_handle_t *
+sysevent_bind_handle(void (*event_handler)(sysevent_t *ev))
+{
+	return (sysevent_bind_handle_cmn(event_handler, NULL));
+}
+/*
+* sysevent_bind_xhandle - Bind application event handler for syseventd
+*		subscription, using door_xcreate and attributes as specified.
+*/
+sysevent_handle_t *
+sysevent_bind_xhandle(void (*event_handler)(sysevent_t *ev),
+sysevent_subattr_t *subattr)
+{
+	return (sysevent_bind_handle_cmn(event_handler, subattr));
+}
+/*
 * sysevent_unbind_handle - Unbind caller from syseventd subscriptions
 */
 void
 sysevent_unbind_handle(sysevent_handle_t *shp)
 {

Mercurial > illumos > illumos-gate

comparison usr/src/lib/libsysevent/libsysevent.c @ 12979:ab9ae749152f