configd-293.8.tar.gz

[apple/configd.git] / configd.tproj / _notifyviaport.c

diff --git a/configd.tproj/_notifyviaport.c b/configd.tproj/_notifyviaport.c
index ac270ec6edbc9da5801a829f96f6a9ee5ed01426..84561085389237190b6012a6f9abdac307e1023b 100644 (file)
--- a/configd.tproj/_notifyviaport.c
+++ b/configd.tproj/_notifyviaport.c
@@ -1,53 +1,65 @@
 /*
 /*

- * Copyright (c) 2000 Apple Computer, Inc. All rights reserved.
+ * Copyright (c) 2000, 2001, 2003, 2004, 2006, 2009 Apple Inc. All rights reserved.

  *
  * @APPLE_LICENSE_HEADER_START@
  *
  * @APPLE_LICENSE_HEADER_START@

- *
- * The contents of this file constitute Original Code as defined in and
- * are subject to the Apple Public Source License Version 1.1 (the
- * "License").  You may not use this file except in compliance with the
- * License.  Please obtain a copy of the License at
- * http://www.apple.com/publicsource and read it before using this file.
- *
- * This Original Code and all software distributed under the License are
- * distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, EITHER
+ * 
+ * This file contains Original Code and/or Modifications of Original Code
+ * as defined in and that are subject to the Apple Public Source License
+ * Version 2.0 (the 'License'). You may not use this file except in
+ * compliance with the License. Please obtain a copy of the License at
+ * http://www.opensource.apple.com/apsl/ and read it before using this
+ * file.
+ * 
+ * The Original Code and all software distributed under the License are
+ * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER

  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,

- * FITNESS FOR A PARTICULAR PURPOSE OR NON-INFRINGEMENT.  Please see the
- * License for the specific language governing rights and limitations
- * under the License.
- *
+ * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
+ * Please see the License for the specific language governing rights and
+ * limitations under the License.
+ * 

  * @APPLE_LICENSE_HEADER_END@
  */
 
  * @APPLE_LICENSE_HEADER_END@
  */
 

+/*
+ * Modification History
+ *
+ * June 1, 2001                        Allan Nathanson <ajn@apple.com>
+ * - public API conversion
+ *
+ * March 24, 2000              Allan Nathanson <ajn@apple.com>
+ * - initial revision
+ */
+

 #include "configd.h"
 #include "session.h"
 
 #include "configd.h"
 #include "session.h"
 

-SCDStatus
-_SCDNotifierInformViaMachPort(SCDSessionRef session, mach_msg_id_t identifier, mach_port_t *port)
+__private_extern__
+int
+__SCDynamicStoreNotifyMachPort(SCDynamicStoreRef       store,
+                              mach_msg_id_t            identifier,
+                              mach_port_t              port)

 {
 {

-       SCDSessionPrivateRef    sessionPrivate = (SCDSessionPrivateRef)session;
-       CFStringRef             sessionKey;
-       CFDictionaryRef         info;
-
-       SCDLog(LOG_DEBUG, CFSTR("_SCDNotifierInformViaMachPort:"));
+       SCDynamicStorePrivateRef        storePrivate = (SCDynamicStorePrivateRef)store;
+       CFStringRef                     sessionKey;
+       CFDictionaryRef                 info;

 
 

-       if ((session == NULL) || (sessionPrivate->server == MACH_PORT_NULL)) {
-               return SCD_NOSESSION;   /* you must have an open session to play */
+       if ((store == NULL) || (storePrivate->server == MACH_PORT_NULL)) {
+               return kSCStatusNoStoreSession;         /* you must have an open session to play */

        }
 
        }
 

-       if (sessionPrivate->notifyStatus != NotifierNotRegistered) {
+       if (storePrivate->notifyStatus != NotifierNotRegistered) {

                /* sorry, you can only have one notification registered at once */
                /* sorry, you can only have one notification registered at once */

-               return SCD_NOTIFIERACTIVE;
+               return kSCStatusNotifierActive;

        }
 
        }
 

-       if (*port == MACH_PORT_NULL) {
+       if (port == MACH_PORT_NULL) {

                /* sorry, you must specify a valid mach port */
                /* sorry, you must specify a valid mach port */

-               return SCD_INVALIDARGUMENT;
+               return kSCStatusInvalidArgument;

        }
 
        /* push out a notification if any changes are pending */
        }
 
        /* push out a notification if any changes are pending */

-       sessionKey = CFStringCreateWithFormat(NULL, NULL, CFSTR("%d"), sessionPrivate->server);
+       sessionKey = CFStringCreateWithFormat(NULL, NULL, CFSTR("%d"), storePrivate->server);

        info = CFDictionaryGetValue(sessionData, sessionKey);
        CFRelease(sessionKey);
        if (info && CFDictionaryContainsKey(info, kSCDChangedKeys)) {
        info = CFDictionaryGetValue(sessionData, sessionKey);
        CFRelease(sessionKey);
        if (info && CFDictionaryContainsKey(info, kSCDChangedKeys)) {


@@ -58,43 +70,51 @@ _SCDNotifierInformViaMachPort(SCDSessionRef session, mach_msg_id_t identifier, m
                                                               0,
                                                               &kCFTypeSetCallBacks);
 
                                                               0,
                                                               &kCFTypeSetCallBacks);
 

-               sessionNum = CFNumberCreate(NULL, kCFNumberIntType, &sessionPrivate->server);
+               sessionNum = CFNumberCreate(NULL, kCFNumberIntType, &storePrivate->server);

                CFSetAddValue(needsNotification, sessionNum);
                CFRelease(sessionNum);
        }
 
                CFSetAddValue(needsNotification, sessionNum);
                CFRelease(sessionNum);
        }
 

-       return SCD_OK;
+       return kSCStatusOK;

 }
 
 
 }
 
 

+__private_extern__

 kern_return_t
 _notifyviaport(mach_port_t     server,
               mach_port_t      port,
               mach_msg_id_t    identifier,
 kern_return_t
 _notifyviaport(mach_port_t     server,
               mach_port_t      port,
               mach_msg_id_t    identifier,

-              int              *scd_status
+              int              *sc_status

 )
 {
 )
 {

-       serverSessionRef        mySession = getSession(server);
-       SCDSessionPrivateRef    sessionPrivate = (SCDSessionPrivateRef)mySession->session;
-
-       SCDLog(LOG_DEBUG, CFSTR("Send mach message when a notification key changes."));
-       SCDLog(LOG_DEBUG, CFSTR("  server     = %d"), server);
-       SCDLog(LOG_DEBUG, CFSTR("  port       = %d"), port);
-       SCDLog(LOG_DEBUG, CFSTR("  message id = %d"), identifier);
-
-       if (sessionPrivate->notifyPort != MACH_PORT_NULL) {
-               SCDLog(LOG_DEBUG, CFSTR("  destroying old callback mach port %d"), sessionPrivate->notifyPort);
-               (void) mach_port_destroy(mach_task_self(), sessionPrivate->notifyPort);
+       serverSessionRef                mySession       = getSession(server);
+       SCDynamicStorePrivateRef        storePrivate;
+
+       if (mySession == NULL) {
+               /* sorry, you must have an open session to play */
+               *sc_status = kSCStatusNoStoreSession;
+               if (port != MACH_PORT_NULL) {
+                       (void) mach_port_deallocate(mach_task_self(), port);
+               }
+               return KERN_SUCCESS;

        }
        }

-
-       *scd_status = _SCDNotifierInformViaMachPort(mySession->session, identifier, &port);
-
-       if (*scd_status == SCD_OK) {
-               /* save notification port, requested identifier, and set notifier active */
-               sessionPrivate->notifyStatus         = Using_NotifierInformViaMachPort;
-               sessionPrivate->notifyPort           = port;
-               sessionPrivate->notifyPortIdentifier = identifier;
+       storePrivate = (SCDynamicStorePrivateRef)mySession->store;
+
+       *sc_status = __SCDynamicStoreNotifyMachPort(mySession->store, identifier, port);
+       if (*sc_status != kSCStatusOK) {
+               // if we can't enable the notification, release the provided callback port
+               if (port != MACH_PORT_NULL) {
+                       __MACH_PORT_DEBUG(TRUE, "*** _notifyviaport __SCDynamicStoreNotifyMachPort failed: releasing port", port);
+                       (void) mach_port_deallocate(mach_task_self(), port);
+               }
+               return KERN_SUCCESS;

        }
 
        }
 

+       /* save notification port, requested identifier, and set notifier active */
+       __MACH_PORT_DEBUG(TRUE, "*** _notifyviaport", port);
+       storePrivate->notifyStatus         = Using_NotifierInformViaMachPort;
+       storePrivate->notifyPort           = port;
+       storePrivate->notifyPortIdentifier = identifier;
+

        return KERN_SUCCESS;
 }
        return KERN_SUCCESS;
 }