1*aca3beaaSApple OSS Distributions /*
2*aca3beaaSApple OSS Distributions * Copyright (c) 2012-2013 Apple Computer, Inc. All Rights Reserved.
3*aca3beaaSApple OSS Distributions *
4*aca3beaaSApple OSS Distributions * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
5*aca3beaaSApple OSS Distributions *
6*aca3beaaSApple OSS Distributions * This file contains Original Code and/or Modifications of Original Code
7*aca3beaaSApple OSS Distributions * as defined in and that are subject to the Apple Public Source License
8*aca3beaaSApple OSS Distributions * Version 2.0 (the 'License'). You may not use this file except in
9*aca3beaaSApple OSS Distributions * compliance with the License. The rights granted to you under the License
10*aca3beaaSApple OSS Distributions * may not be used to create, or enable the creation or redistribution of,
11*aca3beaaSApple OSS Distributions * unlawful or unlicensed copies of an Apple operating system, or to
12*aca3beaaSApple OSS Distributions * circumvent, violate, or enable the circumvention or violation of, any
13*aca3beaaSApple OSS Distributions * terms of an Apple operating system software license agreement.
14*aca3beaaSApple OSS Distributions *
15*aca3beaaSApple OSS Distributions * Please obtain a copy of the License at
16*aca3beaaSApple OSS Distributions * http://www.opensource.apple.com/apsl/ and read it before using this file.
17*aca3beaaSApple OSS Distributions *
18*aca3beaaSApple OSS Distributions * The Original Code and all software distributed under the License are
19*aca3beaaSApple OSS Distributions * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
20*aca3beaaSApple OSS Distributions * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
21*aca3beaaSApple OSS Distributions * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
22*aca3beaaSApple OSS Distributions * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
23*aca3beaaSApple OSS Distributions * Please see the License for the specific language governing rights and
24*aca3beaaSApple OSS Distributions * limitations under the License.
25*aca3beaaSApple OSS Distributions *
26*aca3beaaSApple OSS Distributions * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
27*aca3beaaSApple OSS Distributions */
28*aca3beaaSApple OSS Distributions
29*aca3beaaSApple OSS Distributions #define IOKIT_ENABLE_SHARED_PTR
30*aca3beaaSApple OSS Distributions
31*aca3beaaSApple OSS Distributions #include <libkern/c++/OSSharedPtr.h>
32*aca3beaaSApple OSS Distributions #include <IOKit/IOKernelReportStructs.h>
33*aca3beaaSApple OSS Distributions #include <IOKit/IOKernelReporters.h>
34*aca3beaaSApple OSS Distributions #include "IOReporterDefs.h"
35*aca3beaaSApple OSS Distributions
36*aca3beaaSApple OSS Distributions
37*aca3beaaSApple OSS Distributions #define super IOReporter
38*aca3beaaSApple OSS Distributions OSDefineMetaClassAndStructors(IOStateReporter, IOReporter);
39*aca3beaaSApple OSS Distributions
40*aca3beaaSApple OSS Distributions
41*aca3beaaSApple OSS Distributions /* static */
42*aca3beaaSApple OSS Distributions OSSharedPtr<IOStateReporter>
with(IOService * reportingService,IOReportCategories categories,int nstates,IOReportUnit unit)43*aca3beaaSApple OSS Distributions IOStateReporter::with(IOService *reportingService,
44*aca3beaaSApple OSS Distributions IOReportCategories categories,
45*aca3beaaSApple OSS Distributions int nstates,
46*aca3beaaSApple OSS Distributions IOReportUnit unit /* = kIOReportUnitHWTicks*/)
47*aca3beaaSApple OSS Distributions {
48*aca3beaaSApple OSS Distributions OSSharedPtr<IOStateReporter> reporter;
49*aca3beaaSApple OSS Distributions
50*aca3beaaSApple OSS Distributions if (nstates > INT16_MAX) {
51*aca3beaaSApple OSS Distributions return nullptr;
52*aca3beaaSApple OSS Distributions }
53*aca3beaaSApple OSS Distributions
54*aca3beaaSApple OSS Distributions reporter = OSMakeShared<IOStateReporter>();
55*aca3beaaSApple OSS Distributions if (!reporter) {
56*aca3beaaSApple OSS Distributions return nullptr;
57*aca3beaaSApple OSS Distributions }
58*aca3beaaSApple OSS Distributions
59*aca3beaaSApple OSS Distributions if (!reporter->initWith(reportingService, categories, (int16_t) nstates, unit)) {
60*aca3beaaSApple OSS Distributions return nullptr;
61*aca3beaaSApple OSS Distributions }
62*aca3beaaSApple OSS Distributions
63*aca3beaaSApple OSS Distributions return reporter;
64*aca3beaaSApple OSS Distributions }
65*aca3beaaSApple OSS Distributions
66*aca3beaaSApple OSS Distributions bool
initWith(IOService * reportingService,IOReportCategories categories,int16_t nstates,IOReportUnit unit)67*aca3beaaSApple OSS Distributions IOStateReporter::initWith(IOService *reportingService,
68*aca3beaaSApple OSS Distributions IOReportCategories categories,
69*aca3beaaSApple OSS Distributions int16_t nstates,
70*aca3beaaSApple OSS Distributions IOReportUnit unit)
71*aca3beaaSApple OSS Distributions {
72*aca3beaaSApple OSS Distributions bool success = false;
73*aca3beaaSApple OSS Distributions
74*aca3beaaSApple OSS Distributions IOReportChannelType channelType = {
75*aca3beaaSApple OSS Distributions .categories = categories,
76*aca3beaaSApple OSS Distributions .report_format = kIOReportFormatState,
77*aca3beaaSApple OSS Distributions .nelements = static_cast<uint16_t>(nstates),
78*aca3beaaSApple OSS Distributions .element_idx = 0
79*aca3beaaSApple OSS Distributions };
80*aca3beaaSApple OSS Distributions
81*aca3beaaSApple OSS Distributions if (super::init(reportingService, channelType, unit) != true) {
82*aca3beaaSApple OSS Distributions IORLOG("ERROR super::initWith failed");
83*aca3beaaSApple OSS Distributions success = false;
84*aca3beaaSApple OSS Distributions goto finish;
85*aca3beaaSApple OSS Distributions }
86*aca3beaaSApple OSS Distributions
87*aca3beaaSApple OSS Distributions _currentStates = NULL;
88*aca3beaaSApple OSS Distributions _lastUpdateTimes = NULL;
89*aca3beaaSApple OSS Distributions
90*aca3beaaSApple OSS Distributions success = true;
91*aca3beaaSApple OSS Distributions
92*aca3beaaSApple OSS Distributions finish:
93*aca3beaaSApple OSS Distributions return success;
94*aca3beaaSApple OSS Distributions }
95*aca3beaaSApple OSS Distributions
96*aca3beaaSApple OSS Distributions
97*aca3beaaSApple OSS Distributions void
free(void)98*aca3beaaSApple OSS Distributions IOStateReporter::free(void)
99*aca3beaaSApple OSS Distributions {
100*aca3beaaSApple OSS Distributions if (_currentStates) {
101*aca3beaaSApple OSS Distributions PREFL_MEMOP_PANIC(_nChannels, int);
102*aca3beaaSApple OSS Distributions IOFreeData(_currentStates, (size_t)_nChannels * sizeof(int));
103*aca3beaaSApple OSS Distributions }
104*aca3beaaSApple OSS Distributions if (_lastUpdateTimes) {
105*aca3beaaSApple OSS Distributions PREFL_MEMOP_PANIC(_nChannels, uint64_t);
106*aca3beaaSApple OSS Distributions IOFreeData(_lastUpdateTimes, (size_t)_nChannels * sizeof(uint64_t));
107*aca3beaaSApple OSS Distributions }
108*aca3beaaSApple OSS Distributions
109*aca3beaaSApple OSS Distributions super::free();
110*aca3beaaSApple OSS Distributions }
111*aca3beaaSApple OSS Distributions
112*aca3beaaSApple OSS Distributions
113*aca3beaaSApple OSS Distributions IOReturn
handleSwapPrepare(int newNChannels)114*aca3beaaSApple OSS Distributions IOStateReporter::handleSwapPrepare(int newNChannels)
115*aca3beaaSApple OSS Distributions {
116*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
117*aca3beaaSApple OSS Distributions size_t newCurStatesSize, newTSSize;
118*aca3beaaSApple OSS Distributions
119*aca3beaaSApple OSS Distributions //IORLOG("handleSwapPrepare (state) _nChannels before = %u", _nChannels);
120*aca3beaaSApple OSS Distributions
121*aca3beaaSApple OSS Distributions IOREPORTER_CHECK_CONFIG_LOCK();
122*aca3beaaSApple OSS Distributions
123*aca3beaaSApple OSS Distributions if (_swapCurrentStates || _swapLastUpdateTimes) {
124*aca3beaaSApple OSS Distributions panic("IOStateReporter::_swap* already in use");
125*aca3beaaSApple OSS Distributions }
126*aca3beaaSApple OSS Distributions
127*aca3beaaSApple OSS Distributions // new currentStates buffer
128*aca3beaaSApple OSS Distributions PREFL_MEMOP_FAIL(newNChannels, int);
129*aca3beaaSApple OSS Distributions newCurStatesSize = (size_t)newNChannels * sizeof(int);
130*aca3beaaSApple OSS Distributions _swapCurrentStates = (int*)IOMallocData(newCurStatesSize);
131*aca3beaaSApple OSS Distributions if (_swapCurrentStates == NULL) {
132*aca3beaaSApple OSS Distributions res = kIOReturnNoMemory; goto finish;
133*aca3beaaSApple OSS Distributions }
134*aca3beaaSApple OSS Distributions memset(_swapCurrentStates, -1, newCurStatesSize); // init w/"no state"
135*aca3beaaSApple OSS Distributions
136*aca3beaaSApple OSS Distributions // new timestamps buffer
137*aca3beaaSApple OSS Distributions PREFL_MEMOP_FAIL(newNChannels, uint64_t);
138*aca3beaaSApple OSS Distributions newTSSize = (size_t)newNChannels * sizeof(uint64_t);
139*aca3beaaSApple OSS Distributions _swapLastUpdateTimes = (uint64_t *)IOMallocZeroData(newTSSize);
140*aca3beaaSApple OSS Distributions if (_swapLastUpdateTimes == NULL) {
141*aca3beaaSApple OSS Distributions res = kIOReturnNoMemory; goto finish;
142*aca3beaaSApple OSS Distributions }
143*aca3beaaSApple OSS Distributions
144*aca3beaaSApple OSS Distributions res = super::handleSwapPrepare(newNChannels);
145*aca3beaaSApple OSS Distributions
146*aca3beaaSApple OSS Distributions finish:
147*aca3beaaSApple OSS Distributions if (res) {
148*aca3beaaSApple OSS Distributions if (_swapCurrentStates) {
149*aca3beaaSApple OSS Distributions IOFreeData(_swapCurrentStates, newCurStatesSize);
150*aca3beaaSApple OSS Distributions _swapCurrentStates = NULL;
151*aca3beaaSApple OSS Distributions }
152*aca3beaaSApple OSS Distributions if (_swapLastUpdateTimes) {
153*aca3beaaSApple OSS Distributions IOFreeData(_swapLastUpdateTimes, newTSSize);
154*aca3beaaSApple OSS Distributions _swapLastUpdateTimes = NULL;
155*aca3beaaSApple OSS Distributions }
156*aca3beaaSApple OSS Distributions }
157*aca3beaaSApple OSS Distributions
158*aca3beaaSApple OSS Distributions return res;
159*aca3beaaSApple OSS Distributions }
160*aca3beaaSApple OSS Distributions
161*aca3beaaSApple OSS Distributions IOReturn
handleAddChannelSwap(uint64_t channelID,const OSSymbol * symChannelName)162*aca3beaaSApple OSS Distributions IOStateReporter::handleAddChannelSwap(uint64_t channelID,
163*aca3beaaSApple OSS Distributions const OSSymbol *symChannelName)
164*aca3beaaSApple OSS Distributions {
165*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
166*aca3beaaSApple OSS Distributions int cnt;
167*aca3beaaSApple OSS Distributions int *tmpCurStates;
168*aca3beaaSApple OSS Distributions uint64_t *tmpTimestamps;
169*aca3beaaSApple OSS Distributions bool swapComplete = false;
170*aca3beaaSApple OSS Distributions
171*aca3beaaSApple OSS Distributions //IORLOG("IOStateReporter::handleSwap");
172*aca3beaaSApple OSS Distributions
173*aca3beaaSApple OSS Distributions if (!_swapCurrentStates || !_swapLastUpdateTimes) {
174*aca3beaaSApple OSS Distributions IORLOG("IOReporter::handleSwap ERROR swap variables uninitialized!");
175*aca3beaaSApple OSS Distributions goto finish;
176*aca3beaaSApple OSS Distributions }
177*aca3beaaSApple OSS Distributions
178*aca3beaaSApple OSS Distributions IOREPORTER_CHECK_CONFIG_LOCK();
179*aca3beaaSApple OSS Distributions IOREPORTER_CHECK_LOCK();
180*aca3beaaSApple OSS Distributions
181*aca3beaaSApple OSS Distributions // Copy any existing buffers
182*aca3beaaSApple OSS Distributions if (_currentStates) {
183*aca3beaaSApple OSS Distributions PREFL_MEMOP_FAIL(_nChannels, int);
184*aca3beaaSApple OSS Distributions memcpy(_swapCurrentStates, _currentStates,
185*aca3beaaSApple OSS Distributions (size_t)_nChannels * sizeof(int));
186*aca3beaaSApple OSS Distributions
187*aca3beaaSApple OSS Distributions if (!_lastUpdateTimes) {
188*aca3beaaSApple OSS Distributions panic("IOStateReporter::handleAddChannelSwap _lastUpdateTimes unset despite non-NULL _currentStates");
189*aca3beaaSApple OSS Distributions }
190*aca3beaaSApple OSS Distributions PREFL_MEMOP_FAIL(_nChannels, uint64_t);
191*aca3beaaSApple OSS Distributions memcpy(_swapLastUpdateTimes, _lastUpdateTimes,
192*aca3beaaSApple OSS Distributions (size_t)_nChannels * sizeof(uint64_t));
193*aca3beaaSApple OSS Distributions }
194*aca3beaaSApple OSS Distributions
195*aca3beaaSApple OSS Distributions // Update principal instance variables, keep old values in _swap* for cleanup
196*aca3beaaSApple OSS Distributions tmpCurStates = _currentStates;
197*aca3beaaSApple OSS Distributions _currentStates = _swapCurrentStates;
198*aca3beaaSApple OSS Distributions _swapCurrentStates = tmpCurStates;
199*aca3beaaSApple OSS Distributions
200*aca3beaaSApple OSS Distributions tmpTimestamps = _lastUpdateTimes;
201*aca3beaaSApple OSS Distributions _lastUpdateTimes = _swapLastUpdateTimes;
202*aca3beaaSApple OSS Distributions _swapLastUpdateTimes = tmpTimestamps;
203*aca3beaaSApple OSS Distributions
204*aca3beaaSApple OSS Distributions swapComplete = true;
205*aca3beaaSApple OSS Distributions
206*aca3beaaSApple OSS Distributions // subclass success
207*aca3beaaSApple OSS Distributions
208*aca3beaaSApple OSS Distributions // invoke superclass(es): base class updates _nChannels & _nElements
209*aca3beaaSApple OSS Distributions res = super::handleAddChannelSwap(channelID, symChannelName);
210*aca3beaaSApple OSS Distributions if (res) {
211*aca3beaaSApple OSS Distributions IORLOG("handleSwap(state) ERROR super::handleSwap failed!");
212*aca3beaaSApple OSS Distributions goto finish;
213*aca3beaaSApple OSS Distributions }
214*aca3beaaSApple OSS Distributions
215*aca3beaaSApple OSS Distributions // Channel added successfully, initialize the new channel's state_ids to 0..nStates-1
216*aca3beaaSApple OSS Distributions for (cnt = 0; cnt < _channelDimension; cnt++) {
217*aca3beaaSApple OSS Distributions handleSetStateID(channelID, cnt, (uint64_t)cnt);
218*aca3beaaSApple OSS Distributions }
219*aca3beaaSApple OSS Distributions
220*aca3beaaSApple OSS Distributions finish:
221*aca3beaaSApple OSS Distributions if (res && swapComplete) {
222*aca3beaaSApple OSS Distributions // unswap so the unused buffers get cleaned up
223*aca3beaaSApple OSS Distributions tmpCurStates = _currentStates;
224*aca3beaaSApple OSS Distributions _currentStates = _swapCurrentStates;
225*aca3beaaSApple OSS Distributions _swapCurrentStates = tmpCurStates;
226*aca3beaaSApple OSS Distributions
227*aca3beaaSApple OSS Distributions tmpTimestamps = _lastUpdateTimes;
228*aca3beaaSApple OSS Distributions _lastUpdateTimes = _swapLastUpdateTimes;
229*aca3beaaSApple OSS Distributions _swapLastUpdateTimes = tmpTimestamps;
230*aca3beaaSApple OSS Distributions }
231*aca3beaaSApple OSS Distributions
232*aca3beaaSApple OSS Distributions return res;
233*aca3beaaSApple OSS Distributions }
234*aca3beaaSApple OSS Distributions
235*aca3beaaSApple OSS Distributions
236*aca3beaaSApple OSS Distributions void
handleSwapCleanup(int swapNChannels)237*aca3beaaSApple OSS Distributions IOStateReporter::handleSwapCleanup(int swapNChannels)
238*aca3beaaSApple OSS Distributions {
239*aca3beaaSApple OSS Distributions IOREPORTER_CHECK_CONFIG_LOCK();
240*aca3beaaSApple OSS Distributions
241*aca3beaaSApple OSS Distributions super::handleSwapCleanup(swapNChannels);
242*aca3beaaSApple OSS Distributions
243*aca3beaaSApple OSS Distributions if (_swapCurrentStates) {
244*aca3beaaSApple OSS Distributions PREFL_MEMOP_PANIC(swapNChannels, int);
245*aca3beaaSApple OSS Distributions IOFreeData(_swapCurrentStates, (size_t)swapNChannels * sizeof(int));
246*aca3beaaSApple OSS Distributions _swapCurrentStates = NULL;
247*aca3beaaSApple OSS Distributions }
248*aca3beaaSApple OSS Distributions if (_swapLastUpdateTimes) {
249*aca3beaaSApple OSS Distributions PREFL_MEMOP_PANIC(swapNChannels, uint64_t);
250*aca3beaaSApple OSS Distributions IOFreeData(_swapLastUpdateTimes, (size_t)swapNChannels * sizeof(uint64_t));
251*aca3beaaSApple OSS Distributions _swapLastUpdateTimes = NULL;
252*aca3beaaSApple OSS Distributions }
253*aca3beaaSApple OSS Distributions }
254*aca3beaaSApple OSS Distributions
255*aca3beaaSApple OSS Distributions
256*aca3beaaSApple OSS Distributions IOReturn
_getStateIndices(uint64_t channel_id,uint64_t state_id,int * channel_index,int * state_index)257*aca3beaaSApple OSS Distributions IOStateReporter::_getStateIndices(uint64_t channel_id,
258*aca3beaaSApple OSS Distributions uint64_t state_id,
259*aca3beaaSApple OSS Distributions int *channel_index,
260*aca3beaaSApple OSS Distributions int *state_index)
261*aca3beaaSApple OSS Distributions {
262*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
263*aca3beaaSApple OSS Distributions int cnt;
264*aca3beaaSApple OSS Distributions IOStateReportValues *values;
265*aca3beaaSApple OSS Distributions int element_index = 0;
266*aca3beaaSApple OSS Distributions
267*aca3beaaSApple OSS Distributions IOREPORTER_CHECK_LOCK();
268*aca3beaaSApple OSS Distributions
269*aca3beaaSApple OSS Distributions if (getChannelIndices(channel_id,
270*aca3beaaSApple OSS Distributions channel_index,
271*aca3beaaSApple OSS Distributions &element_index) != kIOReturnSuccess) {
272*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument;
273*aca3beaaSApple OSS Distributions
274*aca3beaaSApple OSS Distributions goto finish;
275*aca3beaaSApple OSS Distributions }
276*aca3beaaSApple OSS Distributions
277*aca3beaaSApple OSS Distributions for (cnt = 0; cnt < _channelDimension; cnt++) {
278*aca3beaaSApple OSS Distributions values = (IOStateReportValues *)getElementValues(element_index + cnt);
279*aca3beaaSApple OSS Distributions
280*aca3beaaSApple OSS Distributions if (values == NULL) {
281*aca3beaaSApple OSS Distributions res = kIOReturnError;
282*aca3beaaSApple OSS Distributions goto finish;
283*aca3beaaSApple OSS Distributions }
284*aca3beaaSApple OSS Distributions
285*aca3beaaSApple OSS Distributions if (values->state_id == state_id) {
286*aca3beaaSApple OSS Distributions *state_index = cnt;
287*aca3beaaSApple OSS Distributions res = kIOReturnSuccess;
288*aca3beaaSApple OSS Distributions goto finish;
289*aca3beaaSApple OSS Distributions }
290*aca3beaaSApple OSS Distributions }
291*aca3beaaSApple OSS Distributions
292*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument;
293*aca3beaaSApple OSS Distributions
294*aca3beaaSApple OSS Distributions finish:
295*aca3beaaSApple OSS Distributions return res;
296*aca3beaaSApple OSS Distributions }
297*aca3beaaSApple OSS Distributions
298*aca3beaaSApple OSS Distributions
299*aca3beaaSApple OSS Distributions IOReturn
setChannelState(uint64_t channel_id,uint64_t new_state_id)300*aca3beaaSApple OSS Distributions IOStateReporter::setChannelState(uint64_t channel_id,
301*aca3beaaSApple OSS Distributions uint64_t new_state_id)
302*aca3beaaSApple OSS Distributions {
303*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
304*aca3beaaSApple OSS Distributions int channel_index, new_state_index;
305*aca3beaaSApple OSS Distributions uint64_t last_intransition = 0;
306*aca3beaaSApple OSS Distributions uint64_t prev_state_residency = 0;
307*aca3beaaSApple OSS Distributions
308*aca3beaaSApple OSS Distributions lockReporter();
309*aca3beaaSApple OSS Distributions
310*aca3beaaSApple OSS Distributions if (_getStateIndices(channel_id, new_state_id, &channel_index, &new_state_index) == kIOReturnSuccess) {
311*aca3beaaSApple OSS Distributions res = handleSetStateByIndices(channel_index, new_state_index,
312*aca3beaaSApple OSS Distributions last_intransition,
313*aca3beaaSApple OSS Distributions prev_state_residency);
314*aca3beaaSApple OSS Distributions goto finish;
315*aca3beaaSApple OSS Distributions }
316*aca3beaaSApple OSS Distributions
317*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument;
318*aca3beaaSApple OSS Distributions
319*aca3beaaSApple OSS Distributions finish:
320*aca3beaaSApple OSS Distributions unlockReporter();
321*aca3beaaSApple OSS Distributions return res;
322*aca3beaaSApple OSS Distributions }
323*aca3beaaSApple OSS Distributions
324*aca3beaaSApple OSS Distributions IOReturn
setChannelState(uint64_t channel_id,uint64_t new_state_id,uint64_t last_intransition,uint64_t prev_state_residency)325*aca3beaaSApple OSS Distributions IOStateReporter::setChannelState(uint64_t channel_id,
326*aca3beaaSApple OSS Distributions uint64_t new_state_id,
327*aca3beaaSApple OSS Distributions uint64_t last_intransition,
328*aca3beaaSApple OSS Distributions uint64_t prev_state_residency)
329*aca3beaaSApple OSS Distributions {
330*aca3beaaSApple OSS Distributions return setChannelState(channel_id, new_state_id);
331*aca3beaaSApple OSS Distributions }
332*aca3beaaSApple OSS Distributions
333*aca3beaaSApple OSS Distributions IOReturn
overrideChannelState(uint64_t channel_id,uint64_t state_id,uint64_t time_in_state,uint64_t intransitions,uint64_t last_intransition)334*aca3beaaSApple OSS Distributions IOStateReporter::overrideChannelState(uint64_t channel_id,
335*aca3beaaSApple OSS Distributions uint64_t state_id,
336*aca3beaaSApple OSS Distributions uint64_t time_in_state,
337*aca3beaaSApple OSS Distributions uint64_t intransitions,
338*aca3beaaSApple OSS Distributions uint64_t last_intransition /*=0*/)
339*aca3beaaSApple OSS Distributions {
340*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
341*aca3beaaSApple OSS Distributions int channel_index, state_index;
342*aca3beaaSApple OSS Distributions
343*aca3beaaSApple OSS Distributions lockReporter();
344*aca3beaaSApple OSS Distributions
345*aca3beaaSApple OSS Distributions if (_getStateIndices(channel_id, state_id, &channel_index, &state_index) == kIOReturnSuccess) {
346*aca3beaaSApple OSS Distributions if (_lastUpdateTimes[channel_index]) {
347*aca3beaaSApple OSS Distributions panic("overrideChannelState() cannot be used after setChannelState()!");
348*aca3beaaSApple OSS Distributions }
349*aca3beaaSApple OSS Distributions
350*aca3beaaSApple OSS Distributions res = handleOverrideChannelStateByIndices(channel_index, state_index,
351*aca3beaaSApple OSS Distributions time_in_state, intransitions,
352*aca3beaaSApple OSS Distributions last_intransition);
353*aca3beaaSApple OSS Distributions goto finish;
354*aca3beaaSApple OSS Distributions }
355*aca3beaaSApple OSS Distributions
356*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument;
357*aca3beaaSApple OSS Distributions
358*aca3beaaSApple OSS Distributions finish:
359*aca3beaaSApple OSS Distributions unlockReporter();
360*aca3beaaSApple OSS Distributions return res;
361*aca3beaaSApple OSS Distributions }
362*aca3beaaSApple OSS Distributions
363*aca3beaaSApple OSS Distributions
364*aca3beaaSApple OSS Distributions IOReturn
handleOverrideChannelStateByIndices(int channel_index,int state_index,uint64_t time_in_state,uint64_t intransitions,uint64_t last_intransition)365*aca3beaaSApple OSS Distributions IOStateReporter::handleOverrideChannelStateByIndices(int channel_index,
366*aca3beaaSApple OSS Distributions int state_index,
367*aca3beaaSApple OSS Distributions uint64_t time_in_state,
368*aca3beaaSApple OSS Distributions uint64_t intransitions,
369*aca3beaaSApple OSS Distributions uint64_t last_intransition /*=0*/)
370*aca3beaaSApple OSS Distributions {
371*aca3beaaSApple OSS Distributions IOReturn kerr, result = kIOReturnError;
372*aca3beaaSApple OSS Distributions IOStateReportValues state_values;
373*aca3beaaSApple OSS Distributions int element_index;
374*aca3beaaSApple OSS Distributions
375*aca3beaaSApple OSS Distributions if (channel_index < 0 || channel_index >= _nChannels) {
376*aca3beaaSApple OSS Distributions result = kIOReturnBadArgument; goto finish;
377*aca3beaaSApple OSS Distributions }
378*aca3beaaSApple OSS Distributions
379*aca3beaaSApple OSS Distributions if (channel_index < 0 || channel_index > (_nElements - state_index)
380*aca3beaaSApple OSS Distributions / _channelDimension) {
381*aca3beaaSApple OSS Distributions result = kIOReturnOverrun; goto finish;
382*aca3beaaSApple OSS Distributions }
383*aca3beaaSApple OSS Distributions element_index = channel_index * _channelDimension + state_index;
384*aca3beaaSApple OSS Distributions
385*aca3beaaSApple OSS Distributions kerr = copyElementValues(element_index, (IOReportElementValues*)&state_values);
386*aca3beaaSApple OSS Distributions if (kerr) {
387*aca3beaaSApple OSS Distributions result = kerr; goto finish;
388*aca3beaaSApple OSS Distributions }
389*aca3beaaSApple OSS Distributions
390*aca3beaaSApple OSS Distributions // last_intransition = 0 -> no current state ("residency summary only")
391*aca3beaaSApple OSS Distributions state_values.last_intransition = last_intransition;
392*aca3beaaSApple OSS Distributions state_values.intransitions = intransitions;
393*aca3beaaSApple OSS Distributions state_values.upticks = time_in_state;
394*aca3beaaSApple OSS Distributions
395*aca3beaaSApple OSS Distributions // determines current time for metadata
396*aca3beaaSApple OSS Distributions kerr = setElementValues(element_index, (IOReportElementValues *)&state_values);
397*aca3beaaSApple OSS Distributions if (kerr) {
398*aca3beaaSApple OSS Distributions result = kerr; goto finish;
399*aca3beaaSApple OSS Distributions }
400*aca3beaaSApple OSS Distributions
401*aca3beaaSApple OSS Distributions // success
402*aca3beaaSApple OSS Distributions result = kIOReturnSuccess;
403*aca3beaaSApple OSS Distributions
404*aca3beaaSApple OSS Distributions finish:
405*aca3beaaSApple OSS Distributions return result;
406*aca3beaaSApple OSS Distributions }
407*aca3beaaSApple OSS Distributions
408*aca3beaaSApple OSS Distributions
409*aca3beaaSApple OSS Distributions IOReturn
incrementChannelState(uint64_t channel_id,uint64_t state_id,uint64_t time_in_state,uint64_t intransitions,uint64_t last_intransition)410*aca3beaaSApple OSS Distributions IOStateReporter::incrementChannelState(uint64_t channel_id,
411*aca3beaaSApple OSS Distributions uint64_t state_id,
412*aca3beaaSApple OSS Distributions uint64_t time_in_state,
413*aca3beaaSApple OSS Distributions uint64_t intransitions,
414*aca3beaaSApple OSS Distributions uint64_t last_intransition /*=0*/)
415*aca3beaaSApple OSS Distributions {
416*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
417*aca3beaaSApple OSS Distributions int channel_index, state_index;
418*aca3beaaSApple OSS Distributions
419*aca3beaaSApple OSS Distributions lockReporter();
420*aca3beaaSApple OSS Distributions
421*aca3beaaSApple OSS Distributions if (_getStateIndices(channel_id, state_id, &channel_index, &state_index) == kIOReturnSuccess) {
422*aca3beaaSApple OSS Distributions if (_lastUpdateTimes[channel_index]) {
423*aca3beaaSApple OSS Distributions panic("incrementChannelState() cannot be used after setChannelState()!");
424*aca3beaaSApple OSS Distributions }
425*aca3beaaSApple OSS Distributions
426*aca3beaaSApple OSS Distributions res = handleIncrementChannelStateByIndices(channel_index, state_index,
427*aca3beaaSApple OSS Distributions time_in_state, intransitions,
428*aca3beaaSApple OSS Distributions last_intransition);
429*aca3beaaSApple OSS Distributions goto finish;
430*aca3beaaSApple OSS Distributions }
431*aca3beaaSApple OSS Distributions
432*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument;
433*aca3beaaSApple OSS Distributions
434*aca3beaaSApple OSS Distributions finish:
435*aca3beaaSApple OSS Distributions unlockReporter();
436*aca3beaaSApple OSS Distributions return res;
437*aca3beaaSApple OSS Distributions }
438*aca3beaaSApple OSS Distributions
439*aca3beaaSApple OSS Distributions
440*aca3beaaSApple OSS Distributions IOReturn
handleIncrementChannelStateByIndices(int channel_index,int state_index,uint64_t time_in_state,uint64_t intransitions,uint64_t last_intransition)441*aca3beaaSApple OSS Distributions IOStateReporter::handleIncrementChannelStateByIndices(int channel_index,
442*aca3beaaSApple OSS Distributions int state_index,
443*aca3beaaSApple OSS Distributions uint64_t time_in_state,
444*aca3beaaSApple OSS Distributions uint64_t intransitions,
445*aca3beaaSApple OSS Distributions uint64_t last_intransition /*=0*/)
446*aca3beaaSApple OSS Distributions {
447*aca3beaaSApple OSS Distributions IOReturn kerr, result = kIOReturnError;
448*aca3beaaSApple OSS Distributions IOStateReportValues state_values;
449*aca3beaaSApple OSS Distributions int element_index;
450*aca3beaaSApple OSS Distributions
451*aca3beaaSApple OSS Distributions if (channel_index < 0 || channel_index >= _nChannels) {
452*aca3beaaSApple OSS Distributions result = kIOReturnBadArgument; goto finish;
453*aca3beaaSApple OSS Distributions }
454*aca3beaaSApple OSS Distributions
455*aca3beaaSApple OSS Distributions if (channel_index < 0 || channel_index > (_nElements - state_index)
456*aca3beaaSApple OSS Distributions / _channelDimension) {
457*aca3beaaSApple OSS Distributions result = kIOReturnOverrun; goto finish;
458*aca3beaaSApple OSS Distributions }
459*aca3beaaSApple OSS Distributions element_index = channel_index * _channelDimension + state_index;
460*aca3beaaSApple OSS Distributions
461*aca3beaaSApple OSS Distributions kerr = copyElementValues(element_index, (IOReportElementValues*)&state_values);
462*aca3beaaSApple OSS Distributions if (kerr) {
463*aca3beaaSApple OSS Distributions result = kerr;
464*aca3beaaSApple OSS Distributions goto finish;
465*aca3beaaSApple OSS Distributions }
466*aca3beaaSApple OSS Distributions
467*aca3beaaSApple OSS Distributions state_values.last_intransition = last_intransition;
468*aca3beaaSApple OSS Distributions state_values.intransitions += intransitions;
469*aca3beaaSApple OSS Distributions state_values.upticks += time_in_state;
470*aca3beaaSApple OSS Distributions
471*aca3beaaSApple OSS Distributions // determines current time for metadata
472*aca3beaaSApple OSS Distributions kerr = setElementValues(element_index, (IOReportElementValues *)&state_values);
473*aca3beaaSApple OSS Distributions if (kerr) {
474*aca3beaaSApple OSS Distributions result = kerr;
475*aca3beaaSApple OSS Distributions goto finish;
476*aca3beaaSApple OSS Distributions }
477*aca3beaaSApple OSS Distributions
478*aca3beaaSApple OSS Distributions // success
479*aca3beaaSApple OSS Distributions result = kIOReturnSuccess;
480*aca3beaaSApple OSS Distributions
481*aca3beaaSApple OSS Distributions finish:
482*aca3beaaSApple OSS Distributions return result;
483*aca3beaaSApple OSS Distributions }
484*aca3beaaSApple OSS Distributions
485*aca3beaaSApple OSS Distributions
486*aca3beaaSApple OSS Distributions IOReturn
setState(uint64_t new_state_id)487*aca3beaaSApple OSS Distributions IOStateReporter::setState(uint64_t new_state_id)
488*aca3beaaSApple OSS Distributions {
489*aca3beaaSApple OSS Distributions uint64_t last_intransition = 0;
490*aca3beaaSApple OSS Distributions uint64_t prev_state_residency = 0;
491*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
492*aca3beaaSApple OSS Distributions IOStateReportValues *values;
493*aca3beaaSApple OSS Distributions int channel_index = 0, element_index = 0, new_state_index = 0;
494*aca3beaaSApple OSS Distributions int cnt;
495*aca3beaaSApple OSS Distributions
496*aca3beaaSApple OSS Distributions lockReporter();
497*aca3beaaSApple OSS Distributions
498*aca3beaaSApple OSS Distributions if (_nChannels == 1) {
499*aca3beaaSApple OSS Distributions for (cnt = 0; cnt < _channelDimension; cnt++) {
500*aca3beaaSApple OSS Distributions new_state_index = element_index + cnt;
501*aca3beaaSApple OSS Distributions
502*aca3beaaSApple OSS Distributions values = (IOStateReportValues *)getElementValues(new_state_index);
503*aca3beaaSApple OSS Distributions
504*aca3beaaSApple OSS Distributions if (values == NULL) {
505*aca3beaaSApple OSS Distributions res = kIOReturnError;
506*aca3beaaSApple OSS Distributions goto finish;
507*aca3beaaSApple OSS Distributions }
508*aca3beaaSApple OSS Distributions
509*aca3beaaSApple OSS Distributions if (values->state_id == new_state_id) {
510*aca3beaaSApple OSS Distributions res = handleSetStateByIndices(channel_index, new_state_index,
511*aca3beaaSApple OSS Distributions last_intransition,
512*aca3beaaSApple OSS Distributions prev_state_residency);
513*aca3beaaSApple OSS Distributions goto finish;
514*aca3beaaSApple OSS Distributions }
515*aca3beaaSApple OSS Distributions }
516*aca3beaaSApple OSS Distributions }
517*aca3beaaSApple OSS Distributions
518*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument;
519*aca3beaaSApple OSS Distributions
520*aca3beaaSApple OSS Distributions finish:
521*aca3beaaSApple OSS Distributions unlockReporter();
522*aca3beaaSApple OSS Distributions return res;
523*aca3beaaSApple OSS Distributions }
524*aca3beaaSApple OSS Distributions
525*aca3beaaSApple OSS Distributions IOReturn
setState(uint64_t new_state_id,uint64_t last_intransition,uint64_t prev_state_residency)526*aca3beaaSApple OSS Distributions IOStateReporter::setState(uint64_t new_state_id,
527*aca3beaaSApple OSS Distributions uint64_t last_intransition,
528*aca3beaaSApple OSS Distributions uint64_t prev_state_residency)
529*aca3beaaSApple OSS Distributions {
530*aca3beaaSApple OSS Distributions return setState(new_state_id);
531*aca3beaaSApple OSS Distributions }
532*aca3beaaSApple OSS Distributions
533*aca3beaaSApple OSS Distributions IOReturn
setStateID(uint64_t channel_id,int state_index,uint64_t state_id)534*aca3beaaSApple OSS Distributions IOStateReporter::setStateID(uint64_t channel_id,
535*aca3beaaSApple OSS Distributions int state_index,
536*aca3beaaSApple OSS Distributions uint64_t state_id)
537*aca3beaaSApple OSS Distributions {
538*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
539*aca3beaaSApple OSS Distributions
540*aca3beaaSApple OSS Distributions lockReporter();
541*aca3beaaSApple OSS Distributions
542*aca3beaaSApple OSS Distributions res = handleSetStateID(channel_id, state_index, state_id);
543*aca3beaaSApple OSS Distributions
544*aca3beaaSApple OSS Distributions unlockReporter();
545*aca3beaaSApple OSS Distributions
546*aca3beaaSApple OSS Distributions return res;
547*aca3beaaSApple OSS Distributions }
548*aca3beaaSApple OSS Distributions
549*aca3beaaSApple OSS Distributions
550*aca3beaaSApple OSS Distributions IOReturn
handleSetStateID(uint64_t channel_id,int state_index,uint64_t state_id)551*aca3beaaSApple OSS Distributions IOStateReporter::handleSetStateID(uint64_t channel_id,
552*aca3beaaSApple OSS Distributions int state_index,
553*aca3beaaSApple OSS Distributions uint64_t state_id)
554*aca3beaaSApple OSS Distributions {
555*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
556*aca3beaaSApple OSS Distributions IOStateReportValues state_values;
557*aca3beaaSApple OSS Distributions int element_index = 0;
558*aca3beaaSApple OSS Distributions
559*aca3beaaSApple OSS Distributions IOREPORTER_CHECK_LOCK();
560*aca3beaaSApple OSS Distributions
561*aca3beaaSApple OSS Distributions if (getFirstElementIndex(channel_id, &element_index) == kIOReturnSuccess) {
562*aca3beaaSApple OSS Distributions if (state_index >= _channelDimension) {
563*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument; goto finish;
564*aca3beaaSApple OSS Distributions }
565*aca3beaaSApple OSS Distributions if (_nElements - state_index <= element_index) {
566*aca3beaaSApple OSS Distributions res = kIOReturnOverrun; goto finish;
567*aca3beaaSApple OSS Distributions }
568*aca3beaaSApple OSS Distributions element_index += state_index;
569*aca3beaaSApple OSS Distributions
570*aca3beaaSApple OSS Distributions if (copyElementValues(element_index, (IOReportElementValues *)&state_values) != kIOReturnSuccess) {
571*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument;
572*aca3beaaSApple OSS Distributions goto finish;
573*aca3beaaSApple OSS Distributions }
574*aca3beaaSApple OSS Distributions
575*aca3beaaSApple OSS Distributions state_values.state_id = state_id;
576*aca3beaaSApple OSS Distributions
577*aca3beaaSApple OSS Distributions res = setElementValues(element_index, (IOReportElementValues *)&state_values);
578*aca3beaaSApple OSS Distributions }
579*aca3beaaSApple OSS Distributions
580*aca3beaaSApple OSS Distributions // FIXME: set a bit somewhere (reporter-wide?) that state_ids can no longer be
581*aca3beaaSApple OSS Distributions // assumed to be contiguous
582*aca3beaaSApple OSS Distributions finish:
583*aca3beaaSApple OSS Distributions return res;
584*aca3beaaSApple OSS Distributions }
585*aca3beaaSApple OSS Distributions
586*aca3beaaSApple OSS Distributions IOReturn
setStateByIndices(int channel_index,int new_state_index)587*aca3beaaSApple OSS Distributions IOStateReporter::setStateByIndices(int channel_index,
588*aca3beaaSApple OSS Distributions int new_state_index)
589*aca3beaaSApple OSS Distributions {
590*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
591*aca3beaaSApple OSS Distributions uint64_t last_intransition = 0;
592*aca3beaaSApple OSS Distributions uint64_t prev_state_residency = 0;
593*aca3beaaSApple OSS Distributions
594*aca3beaaSApple OSS Distributions lockReporter();
595*aca3beaaSApple OSS Distributions
596*aca3beaaSApple OSS Distributions res = handleSetStateByIndices(channel_index, new_state_index,
597*aca3beaaSApple OSS Distributions last_intransition, prev_state_residency);
598*aca3beaaSApple OSS Distributions
599*aca3beaaSApple OSS Distributions unlockReporter();
600*aca3beaaSApple OSS Distributions
601*aca3beaaSApple OSS Distributions return res;
602*aca3beaaSApple OSS Distributions }
603*aca3beaaSApple OSS Distributions
604*aca3beaaSApple OSS Distributions IOReturn
setStateByIndices(int channel_index,int new_state_index,uint64_t last_intransition,uint64_t prev_state_residency)605*aca3beaaSApple OSS Distributions IOStateReporter::setStateByIndices(int channel_index,
606*aca3beaaSApple OSS Distributions int new_state_index,
607*aca3beaaSApple OSS Distributions uint64_t last_intransition,
608*aca3beaaSApple OSS Distributions uint64_t prev_state_residency)
609*aca3beaaSApple OSS Distributions {
610*aca3beaaSApple OSS Distributions return setStateByIndices(channel_index, new_state_index);
611*aca3beaaSApple OSS Distributions }
612*aca3beaaSApple OSS Distributions
613*aca3beaaSApple OSS Distributions IOReturn
handleSetStateByIndices(int channel_index,int new_state_index,uint64_t last_intransition,uint64_t prev_state_residency)614*aca3beaaSApple OSS Distributions IOStateReporter::handleSetStateByIndices(int channel_index,
615*aca3beaaSApple OSS Distributions int new_state_index,
616*aca3beaaSApple OSS Distributions uint64_t last_intransition,
617*aca3beaaSApple OSS Distributions uint64_t prev_state_residency)
618*aca3beaaSApple OSS Distributions {
619*aca3beaaSApple OSS Distributions IOReturn res = kIOReturnError;
620*aca3beaaSApple OSS Distributions
621*aca3beaaSApple OSS Distributions IOStateReportValues curr_state_values, new_state_values;
622*aca3beaaSApple OSS Distributions int curr_state_index = 0;
623*aca3beaaSApple OSS Distributions int curr_element_index, new_element_index;
624*aca3beaaSApple OSS Distributions uint64_t last_ch_update_time = 0;
625*aca3beaaSApple OSS Distributions uint64_t recordTime = mach_absolute_time();
626*aca3beaaSApple OSS Distributions
627*aca3beaaSApple OSS Distributions IOREPORTER_CHECK_LOCK();
628*aca3beaaSApple OSS Distributions
629*aca3beaaSApple OSS Distributions if (channel_index < 0 || channel_index >= _nChannels) {
630*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument; goto finish;
631*aca3beaaSApple OSS Distributions }
632*aca3beaaSApple OSS Distributions
633*aca3beaaSApple OSS Distributions // if no timestamp provided, last_intransition = time of recording (now)
634*aca3beaaSApple OSS Distributions if (last_intransition == 0) {
635*aca3beaaSApple OSS Distributions last_intransition = recordTime;
636*aca3beaaSApple OSS Distributions }
637*aca3beaaSApple OSS Distributions
638*aca3beaaSApple OSS Distributions // First update target state if different than the current state
639*aca3beaaSApple OSS Distributions // _currentStates[] initialized to -1 to detect first state transition
640*aca3beaaSApple OSS Distributions curr_state_index = _currentStates[channel_index];
641*aca3beaaSApple OSS Distributions if (new_state_index != curr_state_index) {
642*aca3beaaSApple OSS Distributions // fetch element data
643*aca3beaaSApple OSS Distributions if (channel_index < 0 || channel_index > (_nElements - new_state_index)
644*aca3beaaSApple OSS Distributions / _channelDimension) {
645*aca3beaaSApple OSS Distributions res = kIOReturnOverrun; goto finish;
646*aca3beaaSApple OSS Distributions }
647*aca3beaaSApple OSS Distributions new_element_index = channel_index * _channelDimension + new_state_index;
648*aca3beaaSApple OSS Distributions if (copyElementValues(new_element_index,
649*aca3beaaSApple OSS Distributions (IOReportElementValues *)&new_state_values)) {
650*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument;
651*aca3beaaSApple OSS Distributions goto finish;
652*aca3beaaSApple OSS Distributions }
653*aca3beaaSApple OSS Distributions
654*aca3beaaSApple OSS Distributions // Update new state's transition info
655*aca3beaaSApple OSS Distributions new_state_values.intransitions += 1;
656*aca3beaaSApple OSS Distributions new_state_values.last_intransition = last_intransition;
657*aca3beaaSApple OSS Distributions
658*aca3beaaSApple OSS Distributions // and store the values
659*aca3beaaSApple OSS Distributions res = setElementValues(new_element_index,
660*aca3beaaSApple OSS Distributions (IOReportElementValues *)&new_state_values,
661*aca3beaaSApple OSS Distributions recordTime);
662*aca3beaaSApple OSS Distributions
663*aca3beaaSApple OSS Distributions if (res != kIOReturnSuccess) {
664*aca3beaaSApple OSS Distributions goto finish;
665*aca3beaaSApple OSS Distributions }
666*aca3beaaSApple OSS Distributions
667*aca3beaaSApple OSS Distributions _currentStates[channel_index] = new_state_index;
668*aca3beaaSApple OSS Distributions }
669*aca3beaaSApple OSS Distributions
670*aca3beaaSApple OSS Distributions /* Now update time spent in any previous state
671*aca3beaaSApple OSS Distributions * If new_state_index = curr_state_index, this updates time in the
672*aca3beaaSApple OSS Distributions * current state. If this is the channel's first state transition,
673*aca3beaaSApple OSS Distributions * the last update time will be zero.
674*aca3beaaSApple OSS Distributions *
675*aca3beaaSApple OSS Distributions * Note: While setState() should never be called on a channel being
676*aca3beaaSApple OSS Distributions * updated with increment/overrideChannelState(), that's another way
677*aca3beaaSApple OSS Distributions * that the last update time might not exist. Regardless, if there
678*aca3beaaSApple OSS Distributions * is no basis for determining time spent in previous state, there's
679*aca3beaaSApple OSS Distributions * nothing to update!
680*aca3beaaSApple OSS Distributions */
681*aca3beaaSApple OSS Distributions last_ch_update_time = _lastUpdateTimes[channel_index];
682*aca3beaaSApple OSS Distributions if (last_ch_update_time != 0) {
683*aca3beaaSApple OSS Distributions if (channel_index < 0 || channel_index > (_nElements - curr_state_index)
684*aca3beaaSApple OSS Distributions / _channelDimension) {
685*aca3beaaSApple OSS Distributions res = kIOReturnOverrun; goto finish;
686*aca3beaaSApple OSS Distributions }
687*aca3beaaSApple OSS Distributions curr_element_index = channel_index * _channelDimension + curr_state_index;
688*aca3beaaSApple OSS Distributions if (copyElementValues(curr_element_index,
689*aca3beaaSApple OSS Distributions (IOReportElementValues *)&curr_state_values)) {
690*aca3beaaSApple OSS Distributions res = kIOReturnBadArgument;
691*aca3beaaSApple OSS Distributions goto finish;
692*aca3beaaSApple OSS Distributions }
693*aca3beaaSApple OSS Distributions // compute the time spent in previous state, unless provided
694*aca3beaaSApple OSS Distributions if (prev_state_residency == 0) {
695*aca3beaaSApple OSS Distributions prev_state_residency = last_intransition - last_ch_update_time;
696*aca3beaaSApple OSS Distributions }
697*aca3beaaSApple OSS Distributions
698*aca3beaaSApple OSS Distributions curr_state_values.upticks += prev_state_residency;
699*aca3beaaSApple OSS Distributions
700*aca3beaaSApple OSS Distributions res = setElementValues(curr_element_index,
701*aca3beaaSApple OSS Distributions (IOReportElementValues*)&curr_state_values,
702*aca3beaaSApple OSS Distributions recordTime);
703*aca3beaaSApple OSS Distributions
704*aca3beaaSApple OSS Distributions if (res != kIOReturnSuccess) {
705*aca3beaaSApple OSS Distributions goto finish;
706*aca3beaaSApple OSS Distributions }
707*aca3beaaSApple OSS Distributions }
708*aca3beaaSApple OSS Distributions
709*aca3beaaSApple OSS Distributions // record basis for next "time in prior state" calculation
710*aca3beaaSApple OSS Distributions // (also arms a panic in override/incrementChannelState())
711*aca3beaaSApple OSS Distributions _lastUpdateTimes[channel_index] = last_intransition;
712*aca3beaaSApple OSS Distributions
713*aca3beaaSApple OSS Distributions finish:
714*aca3beaaSApple OSS Distributions return res;
715*aca3beaaSApple OSS Distributions }
716*aca3beaaSApple OSS Distributions
717*aca3beaaSApple OSS Distributions
718*aca3beaaSApple OSS Distributions // blocks might make this slightly easier?
719*aca3beaaSApple OSS Distributions uint64_t
getStateInTransitions(uint64_t channel_id,uint64_t state_id)720*aca3beaaSApple OSS Distributions IOStateReporter::getStateInTransitions(uint64_t channel_id,
721*aca3beaaSApple OSS Distributions uint64_t state_id)
722*aca3beaaSApple OSS Distributions {
723*aca3beaaSApple OSS Distributions return _getStateValue(channel_id, state_id, kInTransitions);
724*aca3beaaSApple OSS Distributions }
725*aca3beaaSApple OSS Distributions
726*aca3beaaSApple OSS Distributions uint64_t
getStateResidencyTime(uint64_t channel_id,uint64_t state_id)727*aca3beaaSApple OSS Distributions IOStateReporter::getStateResidencyTime(uint64_t channel_id,
728*aca3beaaSApple OSS Distributions uint64_t state_id)
729*aca3beaaSApple OSS Distributions {
730*aca3beaaSApple OSS Distributions return _getStateValue(channel_id, state_id, kResidencyTime);
731*aca3beaaSApple OSS Distributions }
732*aca3beaaSApple OSS Distributions
733*aca3beaaSApple OSS Distributions uint64_t
getStateLastTransitionTime(uint64_t channel_id,uint64_t state_id)734*aca3beaaSApple OSS Distributions IOStateReporter::getStateLastTransitionTime(uint64_t channel_id,
735*aca3beaaSApple OSS Distributions uint64_t state_id)
736*aca3beaaSApple OSS Distributions {
737*aca3beaaSApple OSS Distributions return _getStateValue(channel_id, state_id, kLastTransitionTime);
738*aca3beaaSApple OSS Distributions }
739*aca3beaaSApple OSS Distributions
740*aca3beaaSApple OSS Distributions uint64_t
_getStateValue(uint64_t channel_id,uint64_t state_id,enum valueSelector value)741*aca3beaaSApple OSS Distributions IOStateReporter::_getStateValue(uint64_t channel_id,
742*aca3beaaSApple OSS Distributions uint64_t state_id,
743*aca3beaaSApple OSS Distributions enum valueSelector value)
744*aca3beaaSApple OSS Distributions {
745*aca3beaaSApple OSS Distributions int channel_index = 0, element_index = 0, cnt;
746*aca3beaaSApple OSS Distributions IOStateReportValues *values = NULL;
747*aca3beaaSApple OSS Distributions uint64_t result = kIOReportInvalidValue;
748*aca3beaaSApple OSS Distributions
749*aca3beaaSApple OSS Distributions lockReporter();
750*aca3beaaSApple OSS Distributions
751*aca3beaaSApple OSS Distributions if (getChannelIndices(channel_id, &channel_index, &element_index) == kIOReturnSuccess) {
752*aca3beaaSApple OSS Distributions if (updateChannelValues(channel_index) == kIOReturnSuccess) {
753*aca3beaaSApple OSS Distributions for (cnt = 0; cnt < _channelDimension; cnt++) {
754*aca3beaaSApple OSS Distributions values = (IOStateReportValues *)getElementValues(element_index);
755*aca3beaaSApple OSS Distributions
756*aca3beaaSApple OSS Distributions if (state_id == values->state_id) {
757*aca3beaaSApple OSS Distributions switch (value) {
758*aca3beaaSApple OSS Distributions case kInTransitions:
759*aca3beaaSApple OSS Distributions result = values->intransitions;
760*aca3beaaSApple OSS Distributions break;
761*aca3beaaSApple OSS Distributions case kResidencyTime:
762*aca3beaaSApple OSS Distributions result = values->upticks;
763*aca3beaaSApple OSS Distributions break;
764*aca3beaaSApple OSS Distributions case kLastTransitionTime:
765*aca3beaaSApple OSS Distributions result = values->last_intransition;
766*aca3beaaSApple OSS Distributions break;
767*aca3beaaSApple OSS Distributions default:
768*aca3beaaSApple OSS Distributions break;
769*aca3beaaSApple OSS Distributions }
770*aca3beaaSApple OSS Distributions
771*aca3beaaSApple OSS Distributions break;
772*aca3beaaSApple OSS Distributions }
773*aca3beaaSApple OSS Distributions
774*aca3beaaSApple OSS Distributions element_index++;
775*aca3beaaSApple OSS Distributions }
776*aca3beaaSApple OSS Distributions }
777*aca3beaaSApple OSS Distributions }
778*aca3beaaSApple OSS Distributions
779*aca3beaaSApple OSS Distributions unlockReporter();
780*aca3beaaSApple OSS Distributions return result;
781*aca3beaaSApple OSS Distributions }
782*aca3beaaSApple OSS Distributions
783*aca3beaaSApple OSS Distributions
784*aca3beaaSApple OSS Distributions uint64_t
getStateLastChannelUpdateTime(uint64_t channel_id)785*aca3beaaSApple OSS Distributions IOStateReporter::getStateLastChannelUpdateTime(uint64_t channel_id)
786*aca3beaaSApple OSS Distributions {
787*aca3beaaSApple OSS Distributions int channel_index;
788*aca3beaaSApple OSS Distributions uint64_t result = kIOReportInvalidValue;
789*aca3beaaSApple OSS Distributions
790*aca3beaaSApple OSS Distributions lockReporter();
791*aca3beaaSApple OSS Distributions
792*aca3beaaSApple OSS Distributions if (getChannelIndex(channel_id, &channel_index) == kIOReturnSuccess) {
793*aca3beaaSApple OSS Distributions result = _lastUpdateTimes[channel_index];
794*aca3beaaSApple OSS Distributions }
795*aca3beaaSApple OSS Distributions
796*aca3beaaSApple OSS Distributions unlockReporter();
797*aca3beaaSApple OSS Distributions
798*aca3beaaSApple OSS Distributions return result;
799*aca3beaaSApple OSS Distributions }
800*aca3beaaSApple OSS Distributions
801*aca3beaaSApple OSS Distributions
802*aca3beaaSApple OSS Distributions /* updateChannelValues() is called to refresh state before being
803*aca3beaaSApple OSS Distributions * reported outside the reporter. In the case of IOStateReporter,
804*aca3beaaSApple OSS Distributions * this is primarily an update to the "time in state" data.
805*aca3beaaSApple OSS Distributions */
806*aca3beaaSApple OSS Distributions IOReturn
updateChannelValues(int channel_index)807*aca3beaaSApple OSS Distributions IOStateReporter::updateChannelValues(int channel_index)
808*aca3beaaSApple OSS Distributions {
809*aca3beaaSApple OSS Distributions IOReturn kerr, result = kIOReturnError;
810*aca3beaaSApple OSS Distributions
811*aca3beaaSApple OSS Distributions int state_index, element_idx;
812*aca3beaaSApple OSS Distributions uint64_t currentTime;
813*aca3beaaSApple OSS Distributions uint64_t last_ch_update_time;
814*aca3beaaSApple OSS Distributions uint64_t time_in_state;
815*aca3beaaSApple OSS Distributions IOStateReportValues state_values;
816*aca3beaaSApple OSS Distributions
817*aca3beaaSApple OSS Distributions IOREPORTER_CHECK_LOCK();
818*aca3beaaSApple OSS Distributions
819*aca3beaaSApple OSS Distributions if (channel_index < 0 || channel_index >= _nChannels) {
820*aca3beaaSApple OSS Distributions result = kIOReturnBadArgument; goto finish;
821*aca3beaaSApple OSS Distributions }
822*aca3beaaSApple OSS Distributions
823*aca3beaaSApple OSS Distributions /* First check to see whether this channel has begun self-
824*aca3beaaSApple OSS Distributions * calculation of time in state. It's possible this channel
825*aca3beaaSApple OSS Distributions * has yet to be initialized or that the driver is updating
826*aca3beaaSApple OSS Distributions * the channel with override/incrementChannelState() which
827*aca3beaaSApple OSS Distributions * never enable automatic time-in-state updates. In that case,
828*aca3beaaSApple OSS Distributions * there is nothing to update and we return success.
829*aca3beaaSApple OSS Distributions */
830*aca3beaaSApple OSS Distributions last_ch_update_time = _lastUpdateTimes[channel_index];
831*aca3beaaSApple OSS Distributions if (last_ch_update_time == 0) {
832*aca3beaaSApple OSS Distributions result = kIOReturnSuccess; goto finish;
833*aca3beaaSApple OSS Distributions }
834*aca3beaaSApple OSS Distributions
835*aca3beaaSApple OSS Distributions // figure out the current state (if any)
836*aca3beaaSApple OSS Distributions state_index = _currentStates[channel_index];
837*aca3beaaSApple OSS Distributions
838*aca3beaaSApple OSS Distributions // e.g. given 4 4-state channels, the boundary is ch[3].st[3] <- _elems[15]
839*aca3beaaSApple OSS Distributions if (channel_index < 0 || channel_index > (_nElements - state_index)
840*aca3beaaSApple OSS Distributions / _channelDimension) {
841*aca3beaaSApple OSS Distributions result = kIOReturnOverrun; goto finish;
842*aca3beaaSApple OSS Distributions }
843*aca3beaaSApple OSS Distributions element_idx = channel_index * _channelDimension + state_index;
844*aca3beaaSApple OSS Distributions
845*aca3beaaSApple OSS Distributions // get the current values
846*aca3beaaSApple OSS Distributions kerr = copyElementValues(element_idx, (IOReportElementValues*)&state_values);
847*aca3beaaSApple OSS Distributions if (kerr) {
848*aca3beaaSApple OSS Distributions result = kerr; goto finish;
849*aca3beaaSApple OSS Distributions }
850*aca3beaaSApple OSS Distributions
851*aca3beaaSApple OSS Distributions // calculate time in state
852*aca3beaaSApple OSS Distributions currentTime = mach_absolute_time();
853*aca3beaaSApple OSS Distributions time_in_state = currentTime - last_ch_update_time;
854*aca3beaaSApple OSS Distributions state_values.upticks += time_in_state;
855*aca3beaaSApple OSS Distributions
856*aca3beaaSApple OSS Distributions // and store the values
857*aca3beaaSApple OSS Distributions kerr = setElementValues(element_idx,
858*aca3beaaSApple OSS Distributions (IOReportElementValues *)&state_values,
859*aca3beaaSApple OSS Distributions currentTime);
860*aca3beaaSApple OSS Distributions if (kerr) {
861*aca3beaaSApple OSS Distributions result = kerr; goto finish;
862*aca3beaaSApple OSS Distributions }
863*aca3beaaSApple OSS Distributions
864*aca3beaaSApple OSS Distributions // Record basis for next "prior time" calculation
865*aca3beaaSApple OSS Distributions _lastUpdateTimes[channel_index] = currentTime;
866*aca3beaaSApple OSS Distributions
867*aca3beaaSApple OSS Distributions
868*aca3beaaSApple OSS Distributions // success
869*aca3beaaSApple OSS Distributions result = kIOReturnSuccess;
870*aca3beaaSApple OSS Distributions
871*aca3beaaSApple OSS Distributions finish:
872*aca3beaaSApple OSS Distributions return result;
873*aca3beaaSApple OSS Distributions }
874*aca3beaaSApple OSS Distributions
875*aca3beaaSApple OSS Distributions /* static */ OSPtr<IOReportLegendEntry>
createLegend(const uint64_t * channelIDs,const char ** channelNames,int channelCount,int nstates,IOReportCategories categories,IOReportUnit unit)876*aca3beaaSApple OSS Distributions IOStateReporter::createLegend(const uint64_t *channelIDs,
877*aca3beaaSApple OSS Distributions const char **channelNames,
878*aca3beaaSApple OSS Distributions int channelCount,
879*aca3beaaSApple OSS Distributions int nstates,
880*aca3beaaSApple OSS Distributions IOReportCategories categories,
881*aca3beaaSApple OSS Distributions IOReportUnit unit)
882*aca3beaaSApple OSS Distributions {
883*aca3beaaSApple OSS Distributions IOReportChannelType channelType = {
884*aca3beaaSApple OSS Distributions .categories = categories,
885*aca3beaaSApple OSS Distributions .report_format = kIOReportFormatState,
886*aca3beaaSApple OSS Distributions .nelements = static_cast<uint16_t>(nstates),
887*aca3beaaSApple OSS Distributions .element_idx = 0
888*aca3beaaSApple OSS Distributions };
889*aca3beaaSApple OSS Distributions
890*aca3beaaSApple OSS Distributions return IOReporter::legendWith(channelIDs, channelNames, channelCount, channelType, unit);
891*aca3beaaSApple OSS Distributions }
892