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