@@ -212,175 +212,4 @@ void MacCFSocketServer::OnWakeUpCallback() {
212212 ASSERT (run_loop_ == CFRunLoopGetCurrent ());
213213 CFRunLoopStop (run_loop_);
214214}
215-
216- // /////////////////////////////////////////////////////////////////////////////
217- // MacCarbonSocketServer
218- // /////////////////////////////////////////////////////////////////////////////
219- #ifndef CARBON_DEPRECATED
220-
221- const UInt32 kEventClassSocketServer = ' MCSS'
222- const UInt32 kEventWakeUp = ' WAKE'
223- const EventTypeSpec kEventWakeUpSpec [] = {
224- { kEventClassSocketServer , kEventWakeUp }
225- };
226-
227- std::string DecodeEvent (EventRef event) {
228- std::string str;
229- DecodeFourChar (::GetEventClass (event), &str);
230- str.push_back (' :'
231- DecodeFourChar (::GetEventKind (event), &str);
232- return str;
233- }
234-
235- MacCarbonSocketServer::MacCarbonSocketServer ()
236- : event_queue_(GetCurrentEventQueue()), wake_up_(NULL ) {
237- VERIFY (noErr == CreateEvent (NULL , kEventClassSocketServer , kEventWakeUp , 0 ,
238- kEventAttributeUserEvent , &wake_up_));
239- }
240-
241- MacCarbonSocketServer::~MacCarbonSocketServer () {
242- if (wake_up_) {
243- ReleaseEvent (wake_up_);
244- }
245- }
246-
247- bool MacCarbonSocketServer::Wait (int cms, bool process_io) {
248- ASSERT (GetCurrentEventQueue () == event_queue_);
249-
250- // Listen to all events if we're processing I/O.
251- // Only listen for our wakeup event if we're not.
252- UInt32 num_types = 0 ;
253- const EventTypeSpec* events = NULL ;
254- if (!process_io) {
255- num_types = GetEventTypeCount (kEventWakeUpSpec );
256- events = kEventWakeUpSpec ;
257- }
258-
259- EventTargetRef target = GetEventDispatcherTarget ();
260- EventTimeout timeout =
261- (kForever == cms) ? kEventDurationForever : cms / 1000.0 ;
262- EventTimeout end_time = GetCurrentEventTime () + timeout;
263-
264- bool done = false ;
265- while (!done) {
266- EventRef event;
267- OSStatus result = ReceiveNextEvent (num_types, events, timeout, true ,
268- &event);
269- if (noErr == result) {
270- if (wake_up_ != event) {
271- LOG_F (LS_VERBOSE) << " Dispatching event: " DecodeEvent (event);
272- result = SendEventToEventTarget (event, target);
273- if ((noErr != result) && (eventNotHandledErr != result)) {
274- LOG_E (LS_ERROR, OS, result) << " SendEventToEventTarget"
275- }
276- } else {
277- done = true ;
278- }
279- ReleaseEvent (event);
280- } else if (eventLoopTimedOutErr == result) {
281- ASSERT (cms != kForever );
282- done = true ;
283- } else if (eventLoopQuitErr == result) {
284- // Ignore this... we get spurious quits for a variety of reasons.
285- LOG_E (LS_VERBOSE, OS, result) << " ReceiveNextEvent"
286- } else {
287- // Some strange error occurred. Log it.
288- LOG_E (LS_WARNING, OS, result) << " ReceiveNextEvent"
289- return false ;
290- }
291- if (kForever != cms) {
292- timeout = end_time - GetCurrentEventTime ();
293- }
294- }
295- return true ;
296- }
297-
298- void MacCarbonSocketServer::WakeUp () {
299- if (!IsEventInQueue (event_queue_, wake_up_)) {
300- RetainEvent (wake_up_);
301- OSStatus result = PostEventToQueue (event_queue_, wake_up_,
302- kEventPriorityStandard );
303- if (noErr != result) {
304- LOG_E (LS_ERROR, OS, result) << " PostEventToQueue"
305- }
306- }
307- }
308-
309- // /////////////////////////////////////////////////////////////////////////////
310- // MacCarbonAppSocketServer
311- // /////////////////////////////////////////////////////////////////////////////
312-
313- MacCarbonAppSocketServer::MacCarbonAppSocketServer ()
314- : event_queue_(GetCurrentEventQueue()) {
315- // Install event handler
316- VERIFY (noErr == InstallApplicationEventHandler (
317- NewEventHandlerUPP (WakeUpEventHandler), 1 , kEventWakeUpSpec , this ,
318- &event_handler_));
319-
320- // Install a timer and set it idle to begin with.
321- VERIFY (noErr == InstallEventLoopTimer (GetMainEventLoop (),
322- kEventDurationForever ,
323- kEventDurationForever ,
324- NewEventLoopTimerUPP (TimerHandler),
325- this ,
326- &timer_));
327- }
328-
329- MacCarbonAppSocketServer::~MacCarbonAppSocketServer () {
330- RemoveEventLoopTimer (timer_);
331- RemoveEventHandler (event_handler_);
332- }
333-
334- OSStatus MacCarbonAppSocketServer::WakeUpEventHandler (
335- EventHandlerCallRef next, EventRef event, void *data) {
336- QuitApplicationEventLoop ();
337- return noErr;
338- }
339-
340- void MacCarbonAppSocketServer::TimerHandler (
341- EventLoopTimerRef timer, void *data) {
342- QuitApplicationEventLoop ();
343- }
344-
345- bool MacCarbonAppSocketServer::Wait (int cms, bool process_io) {
346- if (!process_io && cms == 0 ) {
347- // No op.
348- return true ;
349- }
350- if (kForever != cms) {
351- // Start a timer.
352- OSStatus error =
353- SetEventLoopTimerNextFireTime (timer_, cms / 1000.0 );
354- if (error != noErr) {
355- LOG (LS_ERROR) << " Failed setting next fire time."
356- }
357- }
358- if (!process_io) {
359- // No way to listen to common modes and not get socket events, unless
360- // we disable each one's callbacks.
361- EnableSocketCallbacks (false );
362- }
363- RunApplicationEventLoop ();
364- if (!process_io) {
365- // Reenable them. Hopefully this won't cause spurious callbacks or
366- // missing ones while they were disabled.
367- EnableSocketCallbacks (true );
368- }
369- return true ;
370- }
371-
372- void MacCarbonAppSocketServer::WakeUp () {
373- // TODO: No-op if there's already a WakeUp in flight.
374- EventRef wake_up;
375- VERIFY (noErr == CreateEvent (NULL , kEventClassSocketServer , kEventWakeUp , 0 ,
376- kEventAttributeUserEvent , &wake_up));
377- OSStatus result = PostEventToQueue (event_queue_, wake_up,
378- kEventPriorityStandard );
379- if (noErr != result) {
380- LOG_E (LS_ERROR, OS, result) << " PostEventToQueue"
381- }
382- ReleaseEvent (wake_up);
383- }
384-
385- #endif
386215} // namespace rtc
0 commit comments