2 * Copyright (c) 2000, 2001, 2004, 2005, 2008, 2009 Apple 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 * April 5, 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 */
44 #include <sys/types.h>
45 #include <sys/socket.h>
49 SCDynamicStoreNotifyFileDescriptor(SCDynamicStoreRef store
,
56 SCDynamicStorePrivateRef storePrivate
= (SCDynamicStorePrivateRef
)store
;
58 char tmpdir
[PATH_MAX
];
59 struct sockaddr_un un
;
62 /* sorry, you must provide a session */
63 _SCErrorSet(kSCStatusNoStoreSession
);
67 if (storePrivate
->server
== MACH_PORT_NULL
) {
68 /* sorry, you must have an open session to play */
69 _SCErrorSet(kSCStatusNoStoreServer
);
73 if (storePrivate
->notifyStatus
!= NotifierNotRegistered
) {
74 /* sorry, you can only have one notification registered at once */
75 _SCErrorSet(kSCStatusNotifierActive
);
79 if ((sock
= socket(AF_UNIX
, SOCK_STREAM
, 0)) == -1) {
81 SCLog(TRUE
, LOG_NOTICE
, CFSTR("SCDynamicStoreNotifyFileDescriptor socket(): %s"), strerror(errno
));
85 /* establish a UNIX domain socket for server->client notification */
87 n
= confstr(_CS_DARWIN_USER_TEMP_DIR
, tmpdir
, sizeof(tmpdir
));
88 if ((n
<= 0) || (n
>= sizeof(tmpdir
))) {
89 (void) strlcpy(tmpdir
, _PATH_TMP
, sizeof(tmpdir
));
92 bzero(&un
, sizeof(un
));
93 un
.sun_family
= AF_UNIX
;
95 sizeof(un
.sun_path
)-1,
98 "SCDynamicStoreNotifyFileDescriptor",
100 storePrivate
->server
);
102 /* ensure that the path does not already exist */
103 (void) unlink(un
.sun_path
);
105 if (bind(sock
, (struct sockaddr
*)&un
, sizeof(un
)) == -1) {
107 SCLog(TRUE
, LOG_NOTICE
, CFSTR("SCDynamicStoreNotifyFileDescriptor bind(): %s"), strerror(errno
));
108 (void) unlink(un
.sun_path
);
113 if (listen(sock
, 0) == -1) {
115 SCLog(TRUE
, LOG_NOTICE
, CFSTR("SCDynamicStoreNotifyFileDescriptor listen(): %s"), strerror(errno
));
116 (void) unlink(un
.sun_path
);
121 status
= notifyviafd(storePrivate
->server
,
127 if (status
!= KERN_SUCCESS
) {
128 if (status
== MACH_SEND_INVALID_DEST
) {
129 /* the server's gone and our session port's dead, remove the dead name right */
130 (void) mach_port_deallocate(mach_task_self(), storePrivate
->server
);
132 /* we got an unexpected error, leave the [session] port alone */
133 SCLog(TRUE
, LOG_ERR
, CFSTR("SCDynamicStoreNotifyFileDescriptor notifyviafd(): %s"), mach_error_string(status
));
135 storePrivate
->server
= MACH_PORT_NULL
;
140 (void) unlink(un
.sun_path
);
142 if (sc_status
!= kSCStatusOK
) {
143 _SCErrorSet(sc_status
);
144 SCLog(TRUE
, LOG_NOTICE
,
145 CFSTR("SCDynamicStoreNotifyFileDescriptor server error: %s"),
146 SCErrorString(sc_status
));
151 *fd
= accept(sock
, 0, 0);
154 SCLog(TRUE
, LOG_NOTICE
, CFSTR("SCDynamicStoreNotifyFileDescriptor accept(): %s"), strerror(errno
));
160 /* set notifier active */
161 storePrivate
->notifyStatus
= Using_NotifierInformViaFD
;