2 * Copyright (c) 2000 Apple Computer, Inc. All rights reserved.
4 * @APPLE_LICENSE_HEADER_START@
6 * This file contains Original Code and/or Modifications of Original Code
7 * as defined in and that are subject to the Apple Public Source License
8 * Version 2.0 (the 'License'). You may not use this file except in
9 * compliance with the License. Please obtain a copy of the License at
10 * http://www.opensource.apple.com/apsl/ and read it before using this
13 * The Original Code and all software distributed under the License are
14 * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
15 * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
16 * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
17 * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
18 * Please see the License for the specific language governing rights and
19 * limitations under the License.
21 * @APPLE_LICENSE_HEADER_END@
25 * Modification History
27 * June 1, 2001 Allan Nathanson <ajn@apple.com>
28 * - public API conversion
30 * March 31, 2000 Allan Nathanson <ajn@apple.com>
34 #include <mach/mach.h>
35 #include <mach/mach_error.h>
37 #include <SystemConfiguration/SystemConfiguration.h>
38 #include <SystemConfiguration/SCPrivate.h>
39 #include "SCDynamicStoreInternal.h"
40 #include "config.h" /* MiG generated file */
43 waitForMachMessage(mach_port_t port
)
46 mach_msg_empty_rcv_t
*buf
;
48 mach_msg_size_t size
= sizeof(mach_msg_empty_t
) + MAX_TRAILER_SIZE
;
50 status
= vm_allocate(mach_task_self(), (vm_address_t
*)&buf
, size
, TRUE
);
51 if (status
!= KERN_SUCCESS
) {
52 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("vm_allocate(): %s"), mach_error_string(status
));
56 status
= mach_msg(&buf
->header
, /* msg */
57 MACH_RCV_MSG
, /* options */
61 MACH_MSG_TIMEOUT_NONE
, /* timeout */
62 MACH_PORT_NULL
); /* notify */
63 if (status
!= KERN_SUCCESS
) {
64 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("mach_msg(): %s"), mach_error_string(status
));
68 return buf
->header
.msgh_id
;
73 SCDynamicStoreNotifyWait(SCDynamicStoreRef store
)
75 SCDynamicStorePrivateRef storePrivate
= (SCDynamicStorePrivateRef
)store
;
78 mach_port_t oldNotify
;
82 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("SCDynamicStoreNotifyWait:"));
85 /* sorry, you must provide a session */
86 _SCErrorSet(kSCStatusNoStoreSession
);
90 if (storePrivate
->server
== MACH_PORT_NULL
) {
91 /* sorry, you must have an open session to play */
92 _SCErrorSet(kSCStatusNoStoreServer
);
96 if (storePrivate
->notifyStatus
!= NotifierNotRegistered
) {
97 /* sorry, you can only have one notification registered at once */
98 _SCErrorSet(kSCStatusNotifierActive
);
102 /* Allocating port (for server response) */
103 status
= mach_port_allocate(mach_task_self(), MACH_PORT_RIGHT_RECEIVE
, &port
);
104 if (status
!= KERN_SUCCESS
) {
105 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("mach_port_allocate(): %s"), mach_error_string(status
));
109 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR(" port = %d"), port
);
111 status
= mach_port_insert_right(mach_task_self(),
114 MACH_MSG_TYPE_MAKE_SEND
);
115 if (status
!= KERN_SUCCESS
) {
116 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("mach_port_insert_right(): %s"), mach_error_string(status
));
117 (void) mach_port_destroy(mach_task_self(), port
);
122 /* Request a notification when/if the server dies */
123 status
= mach_port_request_notification(mach_task_self(),
125 MACH_NOTIFY_NO_SENDERS
,
128 MACH_MSG_TYPE_MAKE_SEND_ONCE
,
130 if (status
!= KERN_SUCCESS
) {
131 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("mach_port_request_notification(): %s"), mach_error_string(status
));
132 (void) mach_port_destroy(mach_task_self(), port
);
137 if (oldNotify
!= MACH_PORT_NULL
) {
138 SCLog(_sc_verbose
, LOG_ERR
, CFSTR("SCDynamicStoreNotifyWait(): why is oldNotify != MACH_PORT_NULL?"));
141 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("Requesting notification via mach port %d"), port
);
142 status
= notifyviaport(storePrivate
->server
,
147 if (status
!= KERN_SUCCESS
) {
148 if (status
!= MACH_SEND_INVALID_DEST
)
149 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("notifyviaport(): %s"), mach_error_string(status
));
150 (void) mach_port_destroy(mach_task_self(), storePrivate
->server
);
151 storePrivate
->server
= MACH_PORT_NULL
;
156 if (sc_status
!= kSCStatusOK
) {
157 _SCErrorSet(sc_status
);
161 /* set notifier active */
162 storePrivate
->notifyStatus
= Using_NotifierWait
;
164 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("Waiting..."));
166 msgid
= waitForMachMessage(port
);
168 /* set notifier inactive */
169 storePrivate
->notifyStatus
= NotifierNotRegistered
;
171 if (msgid
== MACH_NOTIFY_NO_SENDERS
) {
172 /* the server closed the notifier port */
173 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR(" notifier port closed, destroying port %d"), port
);
174 _SCErrorSet(kSCStatusNoStoreServer
);
179 /* one of the mach routines returned an error */
180 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR(" communication with server failed, destroying port %d"), port
);
181 (void) mach_port_destroy(mach_task_self(), port
);
182 _SCErrorSet(kSCStatusNoStoreServer
);
186 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("Something changed, cancelling notification request"));
187 status
= notifycancel(storePrivate
->server
,
190 if (status
!= KERN_SUCCESS
) {
191 if (status
!= MACH_SEND_INVALID_DEST
)
192 SCLog(_sc_verbose
, LOG_DEBUG
, CFSTR("notifycancel(): %s"), mach_error_string(status
));
193 (void) mach_port_destroy(mach_task_self(), storePrivate
->server
);
194 storePrivate
->server
= MACH_PORT_NULL
;
199 (void) mach_port_destroy(mach_task_self(), port
);