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