1 /*
2  * Copyright (c) 2001-2002 Apple Computer, Inc. All rights reserved.
3  *
4  * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
5  *
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. The rights granted to you under the License
10  * may not be used to create, or enable the creation or redistribution of,
11  * unlawful or unlicensed copies of an Apple operating system, or to
12  * circumvent, violate, or enable the circumvention or violation of, any
13  * terms of an Apple operating system software license agreement.
14  *
15  * Please obtain a copy of the License at
16  * http://www.opensource.apple.com/apsl/ and read it before using this file.
17  *
18  * The Original Code and all software distributed under the License are
19  * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
20  * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
21  * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
22  * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
23  * Please see the License for the specific language governing rights and
24  * limitations under the License.
25  *
26  * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
27  */
28 
29 #include "IOPMPowerStateQueue.h"
30 
31 #define super IOEventSource
32 OSDefineMetaClassAndStructors( IOPMPowerStateQueue, IOEventSource )
33 
34 IOPMPowerStateQueue * IOPMPowerStateQueue::PMPowerStateQueue(
35 	OSObject * inOwner, Action inAction )
36 {
37 	IOPMPowerStateQueue * me = new IOPMPowerStateQueue;
38 
39 	if (me && !me->init(inOwner, inAction)) {
40 		me->release();
41 		return NULL;
42 	}
43 
44 	return me;
45 }
46 
47 bool
48 IOPMPowerStateQueue::init( OSObject * inOwner, Action inAction )
49 {
50 	if (!inAction || !(super::init(inOwner, inAction))) {
51 		return false;
52 	}
53 
54 	queue_init( &queueHead );
55 
56 	queueLock = IOLockAlloc();
57 	if (!queueLock) {
58 		return false;
59 	}
60 
61 	return true;
62 }
63 
64 bool
65 IOPMPowerStateQueue::submitPowerEvent(
66 	uint32_t eventType,
67 	void *   arg0,
68 	uint64_t arg1 )
69 {
70 	PowerEventEntry * entry;
71 
72 	entry = IONew(PowerEventEntry, 1);
73 	if (!entry) {
74 		return false;
75 	}
76 
77 	entry->eventType = eventType;
78 	entry->arg0 = arg0;
79 	entry->arg1 = arg1;
80 
81 	IOLockLock(queueLock);
82 	queue_enter(&queueHead, entry, PowerEventEntry *, chain);
83 	IOLockUnlock(queueLock);
84 	signalWorkAvailable();
85 
86 	return true;
87 }
88 
89 bool
90 IOPMPowerStateQueue::checkForWork( void )
91 {
92 	IOPMPowerStateQueueAction queueAction = (IOPMPowerStateQueueAction) action;
93 	PowerEventEntry * entry;
94 
95 	IOLockLock(queueLock);
96 	while (!queue_empty(&queueHead)) {
97 		queue_remove_first(&queueHead, entry, PowerEventEntry *, chain);
98 		IOLockUnlock(queueLock);
99 
100 		(*queueAction)(owner, entry->eventType, entry->arg0, entry->arg1);
101 		IODelete(entry, PowerEventEntry, 1);
102 
103 		IOLockLock(queueLock);
104 	}
105 	IOLockUnlock(queueLock);
106 
107 	return false;
108 }
109