ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/cebix/BasiliskII/src/MacOSX/sys_darwin.cpp
(Generate patch)

Comparing BasiliskII/src/MacOSX/sys_darwin.cpp (file contents):
Revision 1.7 by gbeauche, 2005-01-30T21:42:13Z vs.
Revision 1.17 by asvitkine, 2012-04-21T16:04:51Z

# Line 7 | Line 7
7   *
8   *      Based on Apple's CDROMSample.c and Evan Jones' cd-discid.c patches
9   *
10 < *  Basilisk II (C) 1997-2005 Christian Bauer
10 > *  Basilisk II (C) 1997-2008 Christian Bauer
11   *
12   *  This program is free software; you can redistribute it and/or modify
13   *  it under the terms of the GNU General Public License as published by
# Line 31 | Line 31
31   #import <IOKit/serial/IOSerialKeys.h>
32   #import <IOKit/storage/IOMedia.h>
33   #import <IOKit/storage/IOMediaBSDClient.h>
34 < #ifdef MAC_OS_X_VERSION_10_2
34 > #ifdef HAVE_IOKIT_STORAGE_IOBLOCKSTORAGEDEVICE_H
35          #import <IOKit/storage/IOBlockStorageDevice.h>
36   #endif
37   #import <IOKit/storage/IOCDMedia.h>
38   #import <IOKit/storage/IOCDMediaBSDClient.h>
39   #import <CoreFoundation/CoreFoundation.h>
40  
41 < #import "sysdeps.h"
41 > #include "sysdeps.h"
42  
43 < #import "prefs.h"
43 > #include "sys.h"
44 > #include "prefs.h"
45  
46   #define DEBUG 0
47   #import "debug.h"
48  
49  
50 + // Global variables
51 + static volatile CFRunLoopRef media_poll_loop = NULL;
52 + static bool media_thread_active = false;
53 + static pthread_t media_thread;
54 +
55 + // Prototypes
56 + static void *media_poll_func(void *);
57 +
58 + // From sys_unix.cpp
59 + extern void SysMediaArrived(const char *path, int type);
60 + extern void SysMediaRemoved(const char *path, int type);
61 +
62  
63   /*
64 < *  This gets called when no "cdrom" prefs items are found
52 < *  It scans for available CD-ROM drives and adds appropriate prefs items
64 > *  Initialization
65   */
66  
67 < void DarwinAddCDROMPrefs(void)
67 > void DarwinSysInit(void)
68   {
69 <        mach_port_t                             masterPort;     // The way to talk to the kernel
70 <        io_iterator_t                   allCDs;         // List of CD drives on the system
71 <        CFMutableDictionaryRef  classesToMatch;
72 <        io_object_t                             nextCD;
69 >        if (PrefsFindBool("nocdrom")) {
70 >                media_thread_active = (pthread_create(&media_thread, NULL, media_poll_func, NULL) == 0);
71 >                D(bug("Media poll thread installed (%ld)\n", media_thread));
72 >        }
73 > }
74  
75  
76 <        // Don't scan for drives if nocdrom option given
77 <        if ( PrefsFindBool("nocdrom") )
78 <                return;
76 > /*
77 > *  Deinitialization
78 > */
79  
80 + void DarwinSysExit(void)
81 + {
82 +        // Stop media poll thread
83 +        if (media_thread_active) {
84 +                while (media_poll_loop == NULL || !CFRunLoopIsWaiting(media_poll_loop))
85 +                        usleep(0);
86 +                CFRunLoopStop(media_poll_loop);
87 +                pthread_join(media_thread, NULL);
88 +                media_poll_loop = NULL;
89 +                media_thread_active = false;
90 +        }
91 + }
92  
68        // Let this task talk to the guts of the kernel:
69        if ( IOMasterPort(MACH_PORT_NULL, &masterPort) != KERN_SUCCESS )
70                bug("IOMasterPort failed. Won't be able to do anything with CD drives\n");
93  
94 + /*
95 + *  Get the BSD-style path of specified object
96 + */
97  
98 <        // CD media are instances of class kIOCDMediaClass
99 <        classesToMatch = IOServiceMatching(kIOCDMediaClass);
100 <        if ( classesToMatch )
101 <        {
102 <                // Narrow the search a little further. Each IOMedia object
103 <                // has a property with key kIOMediaEjectable.  We limit
104 <                // the match only to those CDs that are actually ejectable
105 <                CFDictionarySetValue(classesToMatch,
106 <                                                         CFSTR(kIOMediaEjectableKey), kCFBooleanTrue);
98 > static kern_return_t get_device_path(io_object_t obj, char *path, size_t maxPathLength)
99 > {
100 >        kern_return_t kernResult = KERN_FAILURE;
101 >        CFTypeRef pathAsCFString = IORegistryEntryCreateCFProperty(obj, CFSTR(kIOBSDNameKey),
102 >                                                                                                                           kCFAllocatorDefault, 0);
103 >        if (pathAsCFString) {
104 >                strcpy(path, "/dev/");
105 >                size_t pathLength = strlen(path);
106 >                if (CFStringGetCString((const __CFString *)pathAsCFString,
107 >                                                           path + pathLength,
108 >                                                           maxPathLength - pathLength,
109 >                                                           kCFStringEncodingASCII))
110 >                        kernResult = KERN_SUCCESS;
111 >                CFRelease(pathAsCFString);
112          }
113 +        return kernResult;
114 + }
115  
84        if ( IOServiceGetMatchingServices(masterPort,
85                                                                          classesToMatch, &allCDs) != KERN_SUCCESS )
86        {
87                D(bug("IOServiceGetMatchingServices failed. No CD media drives found?\n"));
88                return;
89        }
116  
117 + /*
118 + *  kIOMatchedNotification handler
119 + */
120  
121 <        // Iterate through each CD drive
122 <        while ( nextCD = IOIteratorNext(allCDs))
123 <        {
124 <                char            bsdPath[MAXPATHLEN];
125 <                CFTypeRef       bsdPathAsCFString =
126 <                                                IORegistryEntryCreateCFProperty(nextCD,
127 <                                                                                                                CFSTR(kIOBSDNameKey),
128 <                                                                                                                kCFAllocatorDefault, 0);
129 <                *bsdPath = '\0';
130 <                if ( bsdPathAsCFString )
131 <                {
132 <                        size_t devPathLength;
121 > static void media_arrived(int type, io_iterator_t iterator)
122 > {
123 >        io_object_t obj;
124 >        while ((obj = IOIteratorNext(iterator))) {
125 >                char path[MAXPATHLEN];
126 >                kern_return_t kernResult = get_device_path(obj, path, sizeof(path));
127 >                if (kernResult == KERN_SUCCESS) {
128 >                        D(bug("Media Arrived: %s\n", path));
129 >                        SysMediaArrived(path, type);
130 >                }
131 >                kernResult = IOObjectRelease(obj);
132 >                if (kernResult != KERN_SUCCESS) {
133 >                        fprintf(stderr, "IOObjectRelease() returned %d\n", kernResult);
134 >                }
135 >        }
136 > }
137  
105                        strcpy(bsdPath, "/dev/");
106                        devPathLength = strlen(bsdPath);
138  
139 <                        if ( CFStringGetCString((const __CFString *)bsdPathAsCFString,
140 <                                                                         bsdPath + devPathLength,
141 <                                                                         MAXPATHLEN - devPathLength,
111 <                                                                         kCFStringEncodingASCII) )
112 <                        {
113 <                                D(bug("CDROM BSD path: %s\n", bsdPath));
114 <                                PrefsAddString("cdrom", bsdPath);
115 <                        }
116 <                        else
117 <                                D(bug("Could not get BSD device path for CD\n"));
139 > /*
140 > *  kIOTerminatedNotification handler
141 > */
142  
143 <                        CFRelease(bsdPathAsCFString);
143 > static void media_removed(int type, io_iterator_t iterator)
144 > {
145 >        io_object_t obj;
146 >        while ((obj = IOIteratorNext(iterator))) {
147 >                char path[MAXPATHLEN];
148 >                kern_return_t kernResult = get_device_path(obj, path, sizeof(path));
149 >                if (kernResult == KERN_SUCCESS) {
150 >                        D(bug("Media Removed: %s\n", path));
151 >                        SysMediaRemoved(path, type);
152 >                }
153 >                kernResult = IOObjectRelease(obj);
154 >                if (kernResult != KERN_SUCCESS) {
155 >                        fprintf(stderr, "IOObjectRelease() returned %d\n", kernResult);
156                  }
121                else
122                        D(bug("Cannot determine bsdPath for CD\n"));
157          }
158 + }
159 +
160 +
161 + /*
162 + *  Media poll function
163 + *
164 + *  NOTE: to facilitate orderly thread termination, media_poll_func MUST end up waiting in CFRunLoopRun.
165 + *  Early returns must be avoided, even if there is nothing useful to be done here. See DarwinSysExit.
166 + */
167  
168 <        IOObjectRelease(nextCD);
169 <        IOObjectRelease(allCDs);
168 > static void dummy(void *) { };  // stub for dummy runloop source
169 >
170 > static void *media_poll_func(void *)
171 > {
172 >        media_poll_loop = CFRunLoopGetCurrent();
173 >
174 >        mach_port_t masterPort;
175 >        kern_return_t kernResult;
176 >        CFMutableDictionaryRef matchingDictionary;
177 >        CFRunLoopSourceRef loopSource = NULL;
178 >        CFRunLoopSourceRef dummySource = NULL;
179 >
180 >        if ((kernResult = IOMasterPort(bootstrap_port, &masterPort)) != KERN_SUCCESS)
181 >                fprintf(stderr, "IOMasterPort() returned %d\n", kernResult);
182 >        else if ((matchingDictionary = IOServiceMatching(kIOCDMediaClass)) == NULL)
183 >                fprintf(stderr, "IOServiceMatching() returned a NULL dictionary\n");
184 >        else {
185 >                matchingDictionary = (CFMutableDictionaryRef)CFRetain(matchingDictionary);
186 >                IONotificationPortRef notificationPort = IONotificationPortCreate(kIOMasterPortDefault);
187 >                loopSource = IONotificationPortGetRunLoopSource(notificationPort);
188 >                CFRunLoopAddSource(media_poll_loop, loopSource, kCFRunLoopDefaultMode);
189 >
190 >                io_iterator_t mediaArrivedIterator;
191 >                kernResult = IOServiceAddMatchingNotification(notificationPort,
192 >                        kIOMatchedNotification,
193 >                        matchingDictionary,
194 >                        (IOServiceMatchingCallback)media_arrived,
195 >                        (void *)MEDIA_CD, &mediaArrivedIterator);
196 >                if (kernResult != KERN_SUCCESS)
197 >                        fprintf(stderr, "IOServiceAddMatchingNotification() returned %d\n", kernResult);
198 >                media_arrived(MEDIA_CD, mediaArrivedIterator);
199 >
200 >                io_iterator_t mediaRemovedIterator;
201 >                kernResult = IOServiceAddMatchingNotification(notificationPort,
202 >                        kIOTerminatedNotification,
203 >                        matchingDictionary,
204 >                        (IOServiceMatchingCallback)media_removed,
205 >                        (void *)MEDIA_CD, &mediaRemovedIterator);
206 >                if (kernResult != KERN_SUCCESS)
207 >                        fprintf(stderr, "IOServiceAddMatchingNotification() returned %d\n", kernResult);
208 >                media_removed(MEDIA_CD, mediaRemovedIterator);
209 >        }
210 >
211 >        if (loopSource == NULL) {
212 >                // add a dummy runloop source to prevent premature return from CFRunLoopRun
213 >                CFRunLoopSourceContext context = { 0, NULL, NULL, NULL, NULL, NULL, NULL, NULL, NULL, dummy };
214 >                dummySource = CFRunLoopSourceCreate(NULL, 0, &context);
215 >                CFRunLoopAddSource(media_poll_loop, dummySource, kCFRunLoopDefaultMode);
216 >        }
217 >
218 >        CFRunLoopRun();
219 >
220 >        if (dummySource != NULL)
221 >                CFRelease(dummySource);
222 >        return NULL;
223   }
224  
225  
# Line 159 | Line 255 | void DarwinAddFloppyPrefs(void)
255                  return;
256          }
257  
162
258          // Iterate through each floppy
259          while ( nextFloppy = IOIteratorNext(allFloppies))
260          {
261                  char            bsdPath[MAXPATHLEN];
167                CFTypeRef       bsdPathAsCFString =
168                                                IORegistryEntryCreateCFProperty(nextFloppy,
169                                                                                                                CFSTR(kIOBSDNameKey),
170                                                                                                                kCFAllocatorDefault, 0);
262                  long            size;
263                  CFTypeRef       sizeAsCFNumber =
264                                                  IORegistryEntryCreateCFProperty(nextFloppy,
# Line 184 | Line 275 | void DarwinAddFloppyPrefs(void)
275                                  continue;
276                          }
277                  }
278 <                else
279 <                        bug("Couldn't get kIOMediaSizeKey of device");
280 <                
281 <                
191 <                *bsdPath = '\0';
192 <                if ( bsdPathAsCFString )
193 <                {
194 <                        size_t devPathLength;
195 <
196 <                        strcpy(bsdPath, "/dev/");
197 <                        devPathLength = strlen(bsdPath);
198 <
199 <                        if ( CFStringGetCString((const __CFString *)bsdPathAsCFString,
200 <                                                                         bsdPath + devPathLength,
201 <                                                                         MAXPATHLEN - devPathLength,
202 <                                                                         kCFStringEncodingASCII) )
203 <                        {
204 <                                D(bug("Floppy BSD path: %s\n", bsdPath));
205 <                                PrefsAddString("floppy", bsdPath);
206 <                        }
207 <                        else
208 <                                D(bug("Could not get BSD device path for floppy\n"));
278 >                else {
279 >                        D(puts("Couldn't get kIOMediaSizeKey of device"));
280 >                        continue; // if kIOMediaSizeKey is unavailable, we shouldn't use it anyway
281 >                }
282  
283 <                        CFRelease(bsdPathAsCFString);
283 >                if (get_device_path(nextFloppy, bsdPath, sizeof(bsdPath)) == KERN_SUCCESS) {
284 >                        PrefsAddString("floppy", bsdPath);
285 >                } else {
286 >                        D(bug("Could not get BSD device path for floppy\n"));
287                  }
212                else
213                        D(bug("Cannot determine bsdPath for floppy\n"));
288          }
289  
290          IOObjectRelease(nextFloppy);

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines