1*4d495c6eSApple OSS Distributions /*
2*4d495c6eSApple OSS Distributions * Copyright (c) 2021 Apple Inc. All rights reserved.
3*4d495c6eSApple OSS Distributions *
4*4d495c6eSApple OSS Distributions * @APPLE_OSREFERENCE_LICENSE_HEADER_START@
5*4d495c6eSApple OSS Distributions *
6*4d495c6eSApple OSS Distributions * This file contains Original Code and/or Modifications of Original Code
7*4d495c6eSApple OSS Distributions * as defined in and that are subject to the Apple Public Source License
8*4d495c6eSApple OSS Distributions * Version 2.0 (the 'License'). You may not use this file except in
9*4d495c6eSApple OSS Distributions * compliance with the License. The rights granted to you under the License
10*4d495c6eSApple OSS Distributions * may not be used to create, or enable the creation or redistribution of,
11*4d495c6eSApple OSS Distributions * unlawful or unlicensed copies of an Apple operating system, or to
12*4d495c6eSApple OSS Distributions * circumvent, violate, or enable the circumvention or violation of, any
13*4d495c6eSApple OSS Distributions * terms of an Apple operating system software license agreement.
14*4d495c6eSApple OSS Distributions *
15*4d495c6eSApple OSS Distributions * Please obtain a copy of the License at
16*4d495c6eSApple OSS Distributions * http://www.opensource.apple.com/apsl/ and read it before using this file.
17*4d495c6eSApple OSS Distributions *
18*4d495c6eSApple OSS Distributions * The Original Code and all software distributed under the License are
19*4d495c6eSApple OSS Distributions * distributed on an 'AS IS' basis, WITHOUT WARRANTY OF ANY KIND, EITHER
20*4d495c6eSApple OSS Distributions * EXPRESS OR IMPLIED, AND APPLE HEREBY DISCLAIMS ALL SUCH WARRANTIES,
21*4d495c6eSApple OSS Distributions * INCLUDING WITHOUT LIMITATION, ANY WARRANTIES OF MERCHANTABILITY,
22*4d495c6eSApple OSS Distributions * FITNESS FOR A PARTICULAR PURPOSE, QUIET ENJOYMENT OR NON-INFRINGEMENT.
23*4d495c6eSApple OSS Distributions * Please see the License for the specific language governing rights and
24*4d495c6eSApple OSS Distributions * limitations under the License.
25*4d495c6eSApple OSS Distributions *
26*4d495c6eSApple OSS Distributions * @APPLE_OSREFERENCE_LICENSE_HEADER_END@
27*4d495c6eSApple OSS Distributions */
28*4d495c6eSApple OSS Distributions
29*4d495c6eSApple OSS Distributions #define IOKIT_ENABLE_SHARED_PTR
30*4d495c6eSApple OSS Distributions
31*4d495c6eSApple OSS Distributions #include <IOKit/IOLib.h>
32*4d495c6eSApple OSS Distributions #include <IOKit/IOReturn.h>
33*4d495c6eSApple OSS Distributions
34*4d495c6eSApple OSS Distributions #include <libkern/c++/OSArray.h>
35*4d495c6eSApple OSS Distributions #include <libkern/c++/OSDictionary.h>
36*4d495c6eSApple OSS Distributions #include <libkern/c++/OSNumber.h>
37*4d495c6eSApple OSS Distributions #include <libkern/c++/OSString.h>
38*4d495c6eSApple OSS Distributions #include <libkern/c++/OSSymbol.h>
39*4d495c6eSApple OSS Distributions #include <libkern/c++/OSUnserialize.h>
40*4d495c6eSApple OSS Distributions #include <libkern/c++/OSSharedPtr.h>
41*4d495c6eSApple OSS Distributions #include <libkern/c++/OSSerialize.h>
42*4d495c6eSApple OSS Distributions
43*4d495c6eSApple OSS Distributions #include <sys/work_interval.h>
44*4d495c6eSApple OSS Distributions #include <sys/param.h>
45*4d495c6eSApple OSS Distributions
46*4d495c6eSApple OSS Distributions #include <kern/thread_group.h>
47*4d495c6eSApple OSS Distributions #include <kern/work_interval.h>
48*4d495c6eSApple OSS Distributions #include <kern/workload_config.h>
49*4d495c6eSApple OSS Distributions
50*4d495c6eSApple OSS Distributions #if DEVELOPMENT || DEBUG
51*4d495c6eSApple OSS Distributions #define WLC_LOG(fmt, args...) IOLog("WorkloadConfig: " fmt, ##args)
52*4d495c6eSApple OSS Distributions #else
53*4d495c6eSApple OSS Distributions #define WLC_LOG(fmt, args...)
54*4d495c6eSApple OSS Distributions #endif
55*4d495c6eSApple OSS Distributions
56*4d495c6eSApple OSS Distributions /* Limit criticality offsets. */
57*4d495c6eSApple OSS Distributions #define MAX_CRITICALITY_OFFSET 16
58*4d495c6eSApple OSS Distributions
59*4d495c6eSApple OSS Distributions
60*4d495c6eSApple OSS Distributions /* Plist keys/values. */
61*4d495c6eSApple OSS Distributions #define kWorkloadIDTableKey "WorkloadIDTable"
62*4d495c6eSApple OSS Distributions #define kRootKey "Root"
63*4d495c6eSApple OSS Distributions #define kPhasesKey "Phases"
64*4d495c6eSApple OSS Distributions #define kWorkIntervalTypeKey "WorkIntervalType"
65*4d495c6eSApple OSS Distributions #define kWorkloadClassKey "WorkloadClass"
66*4d495c6eSApple OSS Distributions #define kCriticalityOffsetKey "CriticalityOffset"
67*4d495c6eSApple OSS Distributions #define kDefaultPhaseKey "DefaultPhase"
68*4d495c6eSApple OSS Distributions #define kFlagsKey "Flags"
69*4d495c6eSApple OSS Distributions #define kWorkloadIDConfigurationFlagsKey "WorkloadIDConfigurationFlags"
70*4d495c6eSApple OSS Distributions
71*4d495c6eSApple OSS Distributions #define kDisableWorkloadClassThreadPolicyValue "DisableWorkloadClassThreadPolicy"
72*4d495c6eSApple OSS Distributions #define kWIComplexityAllowedValue "ComplexityAllowed"
73*4d495c6eSApple OSS Distributions #if defined(XNU_TARGET_OS_XR)
74*4d495c6eSApple OSS Distributions #if defined(CONFIG_THREAD_GROUPS)
75*4d495c6eSApple OSS Distributions #define kUXMValue "UXM"
76*4d495c6eSApple OSS Distributions #define kStrictTimersValue "StrictTimers"
77*4d495c6eSApple OSS Distributions #endif /* CONFIG_THREAD_GROUPS */
78*4d495c6eSApple OSS Distributions #endif /* XNU_TARGET_OS_XR */
79*4d495c6eSApple OSS Distributions
80*4d495c6eSApple OSS Distributions #define ARRAY_LEN(x) (sizeof (x) / sizeof (x[0]))
81*4d495c6eSApple OSS Distributions
82*4d495c6eSApple OSS Distributions #if !CONFIG_THREAD_GROUPS
83*4d495c6eSApple OSS Distributions #define THREAD_GROUP_FLAGS_EFFICIENT 0
84*4d495c6eSApple OSS Distributions #define THREAD_GROUP_FLAGS_APPLICATION 0
85*4d495c6eSApple OSS Distributions #define THREAD_GROUP_FLAGS_CRITICAL 0
86*4d495c6eSApple OSS Distributions #define THREAD_GROUP_FLAGS_BEST_EFFORT 0
87*4d495c6eSApple OSS Distributions #define THREAD_GROUP_FLAGS_ABSENT 0
88*4d495c6eSApple OSS Distributions #endif /* CONFIG_THREAD_GROUPS */
89*4d495c6eSApple OSS Distributions
90*4d495c6eSApple OSS Distributions /* BEGIN IGNORE CODESTYLE */
91*4d495c6eSApple OSS Distributions static const struct WorkloadClassData {
92*4d495c6eSApple OSS Distributions const char *name;
93*4d495c6eSApple OSS Distributions UInt32 workIntervalFlags;
94*4d495c6eSApple OSS Distributions UInt32 threadGroupFlags;
95*4d495c6eSApple OSS Distributions } wlClassData[] = {
96*4d495c6eSApple OSS Distributions [WI_CLASS_NONE] =
97*4d495c6eSApple OSS Distributions {
98*4d495c6eSApple OSS Distributions .name = "NONE",
99*4d495c6eSApple OSS Distributions .workIntervalFlags = WORK_INTERVAL_WORKLOAD_ID_HAS_ID,
100*4d495c6eSApple OSS Distributions .threadGroupFlags = THREAD_GROUP_FLAGS_ABSENT,
101*4d495c6eSApple OSS Distributions },
102*4d495c6eSApple OSS Distributions [WI_CLASS_DISCRETIONARY] =
103*4d495c6eSApple OSS Distributions {
104*4d495c6eSApple OSS Distributions .name = "DISCRETIONARY",
105*4d495c6eSApple OSS Distributions .workIntervalFlags = WORK_INTERVAL_WORKLOAD_ID_HAS_ID,
106*4d495c6eSApple OSS Distributions .threadGroupFlags = THREAD_GROUP_FLAGS_EFFICIENT,
107*4d495c6eSApple OSS Distributions },
108*4d495c6eSApple OSS Distributions [WI_CLASS_BEST_EFFORT] =
109*4d495c6eSApple OSS Distributions {
110*4d495c6eSApple OSS Distributions .name = "BEST_EFFORT",
111*4d495c6eSApple OSS Distributions .workIntervalFlags = WORK_INTERVAL_WORKLOAD_ID_HAS_ID,
112*4d495c6eSApple OSS Distributions .threadGroupFlags = THREAD_GROUP_FLAGS_BEST_EFFORT,
113*4d495c6eSApple OSS Distributions },
114*4d495c6eSApple OSS Distributions [WI_CLASS_APP_SUPPORT] =
115*4d495c6eSApple OSS Distributions {
116*4d495c6eSApple OSS Distributions .name = "APPLICATION_SUPPORT",
117*4d495c6eSApple OSS Distributions .workIntervalFlags = WORK_INTERVAL_WORKLOAD_ID_HAS_ID,
118*4d495c6eSApple OSS Distributions .threadGroupFlags = 0,
119*4d495c6eSApple OSS Distributions },
120*4d495c6eSApple OSS Distributions [WI_CLASS_APPLICATION] =
121*4d495c6eSApple OSS Distributions {
122*4d495c6eSApple OSS Distributions .name = "APPLICATION",
123*4d495c6eSApple OSS Distributions .workIntervalFlags = WORK_INTERVAL_WORKLOAD_ID_HAS_ID,
124*4d495c6eSApple OSS Distributions .threadGroupFlags = THREAD_GROUP_FLAGS_APPLICATION,
125*4d495c6eSApple OSS Distributions },
126*4d495c6eSApple OSS Distributions [WI_CLASS_SYSTEM] =
127*4d495c6eSApple OSS Distributions {
128*4d495c6eSApple OSS Distributions .name = "SYSTEM",
129*4d495c6eSApple OSS Distributions .workIntervalFlags = WORK_INTERVAL_WORKLOAD_ID_HAS_ID,
130*4d495c6eSApple OSS Distributions .threadGroupFlags = 0,
131*4d495c6eSApple OSS Distributions },
132*4d495c6eSApple OSS Distributions [WI_CLASS_SYSTEM_CRITICAL] =
133*4d495c6eSApple OSS Distributions {
134*4d495c6eSApple OSS Distributions .name = "SYSTEM_CRITICAL",
135*4d495c6eSApple OSS Distributions .workIntervalFlags = WORK_INTERVAL_WORKLOAD_ID_HAS_ID,
136*4d495c6eSApple OSS Distributions .threadGroupFlags = THREAD_GROUP_FLAGS_CRITICAL,
137*4d495c6eSApple OSS Distributions },
138*4d495c6eSApple OSS Distributions [WI_CLASS_REALTIME] =
139*4d495c6eSApple OSS Distributions {
140*4d495c6eSApple OSS Distributions .name = "REALTIME",
141*4d495c6eSApple OSS Distributions .workIntervalFlags = WORK_INTERVAL_WORKLOAD_ID_HAS_ID |
142*4d495c6eSApple OSS Distributions WORK_INTERVAL_WORKLOAD_ID_RT_ALLOWED,
143*4d495c6eSApple OSS Distributions .threadGroupFlags = 0,
144*4d495c6eSApple OSS Distributions },
145*4d495c6eSApple OSS Distributions [WI_CLASS_REALTIME_CRITICAL] =
146*4d495c6eSApple OSS Distributions {
147*4d495c6eSApple OSS Distributions .name = "REALTIME_CRITICAL",
148*4d495c6eSApple OSS Distributions .workIntervalFlags = WORK_INTERVAL_WORKLOAD_ID_HAS_ID |
149*4d495c6eSApple OSS Distributions WORK_INTERVAL_WORKLOAD_ID_RT_ALLOWED |
150*4d495c6eSApple OSS Distributions WORK_INTERVAL_WORKLOAD_ID_RT_CRITICAL,
151*4d495c6eSApple OSS Distributions .threadGroupFlags = THREAD_GROUP_FLAGS_CRITICAL,
152*4d495c6eSApple OSS Distributions },
153*4d495c6eSApple OSS Distributions };
154*4d495c6eSApple OSS Distributions /* END IGNORE CODESTYLE */
155*4d495c6eSApple OSS Distributions
156*4d495c6eSApple OSS Distributions struct FlagMap {
157*4d495c6eSApple OSS Distributions const char *str;
158*4d495c6eSApple OSS Distributions UInt32 flags;
159*4d495c6eSApple OSS Distributions };
160*4d495c6eSApple OSS Distributions
161*4d495c6eSApple OSS Distributions static inline IOReturn
stringToFlags(const OSString & str,UInt32 & flags,const struct FlagMap * map,size_t mapLen)162*4d495c6eSApple OSS Distributions stringToFlags(const OSString &str, UInt32 &flags, const struct FlagMap *map,
163*4d495c6eSApple OSS Distributions size_t mapLen)
164*4d495c6eSApple OSS Distributions {
165*4d495c6eSApple OSS Distributions for (size_t i = 0; i < mapLen; i++) {
166*4d495c6eSApple OSS Distributions if (str.isEqualTo(map[i].str)) {
167*4d495c6eSApple OSS Distributions flags = map[i].flags;
168*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
169*4d495c6eSApple OSS Distributions }
170*4d495c6eSApple OSS Distributions }
171*4d495c6eSApple OSS Distributions
172*4d495c6eSApple OSS Distributions return kIOReturnNotFound;
173*4d495c6eSApple OSS Distributions }
174*4d495c6eSApple OSS Distributions
175*4d495c6eSApple OSS Distributions static inline IOReturn
flagsToString(const UInt32 flags,OSSharedPtr<OSString> & str,const struct FlagMap * map,size_t mapLen)176*4d495c6eSApple OSS Distributions flagsToString(const UInt32 flags, OSSharedPtr<OSString> &str, const struct FlagMap *map,
177*4d495c6eSApple OSS Distributions size_t mapLen)
178*4d495c6eSApple OSS Distributions {
179*4d495c6eSApple OSS Distributions for (size_t i = 0; i < mapLen; i++) {
180*4d495c6eSApple OSS Distributions if (flags == map[i].flags) {
181*4d495c6eSApple OSS Distributions str = OSString::withCStringNoCopy(map[i].str);
182*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
183*4d495c6eSApple OSS Distributions }
184*4d495c6eSApple OSS Distributions }
185*4d495c6eSApple OSS Distributions
186*4d495c6eSApple OSS Distributions return kIOReturnNotFound;
187*4d495c6eSApple OSS Distributions }
188*4d495c6eSApple OSS Distributions
189*4d495c6eSApple OSS Distributions /* BEGIN IGNORE CODESTYLE */
190*4d495c6eSApple OSS Distributions static const struct FlagMap typeMap[] = {
191*4d495c6eSApple OSS Distributions {
192*4d495c6eSApple OSS Distributions .str = "DEFAULT",
193*4d495c6eSApple OSS Distributions .flags = WORK_INTERVAL_TYPE_DEFAULT |
194*4d495c6eSApple OSS Distributions WORK_INTERVAL_FLAG_UNRESTRICTED,
195*4d495c6eSApple OSS Distributions },
196*4d495c6eSApple OSS Distributions {
197*4d495c6eSApple OSS Distributions .str = "COREAUDIO",
198*4d495c6eSApple OSS Distributions .flags = WORK_INTERVAL_TYPE_COREAUDIO |
199*4d495c6eSApple OSS Distributions WORK_INTERVAL_FLAG_ENABLE_AUTO_JOIN |
200*4d495c6eSApple OSS Distributions WORK_INTERVAL_FLAG_ENABLE_DEFERRED_FINISH,
201*4d495c6eSApple OSS Distributions },
202*4d495c6eSApple OSS Distributions {
203*4d495c6eSApple OSS Distributions .str = "COREANIMATION",
204*4d495c6eSApple OSS Distributions .flags = WORK_INTERVAL_TYPE_COREANIMATION,
205*4d495c6eSApple OSS Distributions },
206*4d495c6eSApple OSS Distributions {
207*4d495c6eSApple OSS Distributions .str = "CA_RENDER_SERVER",
208*4d495c6eSApple OSS Distributions .flags = WORK_INTERVAL_TYPE_CA_RENDER_SERVER,
209*4d495c6eSApple OSS Distributions },
210*4d495c6eSApple OSS Distributions {
211*4d495c6eSApple OSS Distributions .str = "FRAME_COMPOSITOR",
212*4d495c6eSApple OSS Distributions .flags = WORK_INTERVAL_TYPE_FRAME_COMPOSITOR,
213*4d495c6eSApple OSS Distributions },
214*4d495c6eSApple OSS Distributions {
215*4d495c6eSApple OSS Distributions .str = "CA_CLIENT",
216*4d495c6eSApple OSS Distributions .flags = WORK_INTERVAL_TYPE_CA_CLIENT |
217*4d495c6eSApple OSS Distributions WORK_INTERVAL_FLAG_UNRESTRICTED,
218*4d495c6eSApple OSS Distributions },
219*4d495c6eSApple OSS Distributions {
220*4d495c6eSApple OSS Distributions .str = "HID_DELIVERY",
221*4d495c6eSApple OSS Distributions .flags = WORK_INTERVAL_TYPE_HID_DELIVERY,
222*4d495c6eSApple OSS Distributions },
223*4d495c6eSApple OSS Distributions {
224*4d495c6eSApple OSS Distributions .str = "COREMEDIA",
225*4d495c6eSApple OSS Distributions .flags = WORK_INTERVAL_TYPE_COREMEDIA,
226*4d495c6eSApple OSS Distributions },
227*4d495c6eSApple OSS Distributions {
228*4d495c6eSApple OSS Distributions .str = "ARKIT",
229*4d495c6eSApple OSS Distributions .flags = WORK_INTERVAL_TYPE_ARKIT |
230*4d495c6eSApple OSS Distributions WORK_INTERVAL_FLAG_FINISH_AT_DEADLINE,
231*4d495c6eSApple OSS Distributions },
232*4d495c6eSApple OSS Distributions {
233*4d495c6eSApple OSS Distributions .str = "AUDIO_CLIENT",
234*4d495c6eSApple OSS Distributions .flags = WORK_INTERVAL_TYPE_COREAUDIO |
235*4d495c6eSApple OSS Distributions WORK_INTERVAL_FLAG_UNRESTRICTED |
236*4d495c6eSApple OSS Distributions WORK_INTERVAL_FLAG_ENABLE_AUTO_JOIN |
237*4d495c6eSApple OSS Distributions WORK_INTERVAL_FLAG_ENABLE_DEFERRED_FINISH
238*4d495c6eSApple OSS Distributions },
239*4d495c6eSApple OSS Distributions };
240*4d495c6eSApple OSS Distributions /* END IGNORE CODESTYLE */
241*4d495c6eSApple OSS Distributions
242*4d495c6eSApple OSS Distributions static IOReturn
unparseWorkIntervalType(const UInt32 createFlags,OSSharedPtr<OSString> & typeStr)243*4d495c6eSApple OSS Distributions unparseWorkIntervalType(const UInt32 createFlags, OSSharedPtr<OSString> &typeStr)
244*4d495c6eSApple OSS Distributions {
245*4d495c6eSApple OSS Distributions IOReturn ret = flagsToString(createFlags, typeStr, typeMap,
246*4d495c6eSApple OSS Distributions ARRAY_LEN(typeMap));
247*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
248*4d495c6eSApple OSS Distributions WLC_LOG("unrecognised create flags: 0x%x\n", createFlags);
249*4d495c6eSApple OSS Distributions }
250*4d495c6eSApple OSS Distributions
251*4d495c6eSApple OSS Distributions return ret;
252*4d495c6eSApple OSS Distributions }
253*4d495c6eSApple OSS Distributions
254*4d495c6eSApple OSS Distributions static IOReturn
parseWorkIntervalType(const OSSymbol & id,const OSObject * typeObj,UInt32 & createFlags)255*4d495c6eSApple OSS Distributions parseWorkIntervalType(const OSSymbol &id, const OSObject *typeObj, UInt32 &createFlags)
256*4d495c6eSApple OSS Distributions {
257*4d495c6eSApple OSS Distributions OSSharedPtr<OSString> defaultIntervalType = OSString::withCString("DEFAULT");
258*4d495c6eSApple OSS Distributions
259*4d495c6eSApple OSS Distributions const OSString *typeStr = OSDynamicCast(OSString, typeObj);
260*4d495c6eSApple OSS Distributions if (typeStr == nullptr) {
261*4d495c6eSApple OSS Distributions typeStr = defaultIntervalType.get();
262*4d495c6eSApple OSS Distributions }
263*4d495c6eSApple OSS Distributions
264*4d495c6eSApple OSS Distributions IOReturn ret = stringToFlags(*typeStr, createFlags, typeMap,
265*4d495c6eSApple OSS Distributions ARRAY_LEN(typeMap));
266*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
267*4d495c6eSApple OSS Distributions WLC_LOG("unrecognised \"" kWorkIntervalTypeKey "\": \"%s\"\n",
268*4d495c6eSApple OSS Distributions typeStr->getCStringNoCopy());
269*4d495c6eSApple OSS Distributions }
270*4d495c6eSApple OSS Distributions
271*4d495c6eSApple OSS Distributions return ret;
272*4d495c6eSApple OSS Distributions }
273*4d495c6eSApple OSS Distributions
274*4d495c6eSApple OSS Distributions static IOReturn
parseWorkloadClass(const OSSymbol & id,const OSObject * wlClassObj,wi_class_t & wiClass)275*4d495c6eSApple OSS Distributions parseWorkloadClass(const OSSymbol &id, const OSObject *wlClassObj, wi_class_t &wiClass)
276*4d495c6eSApple OSS Distributions {
277*4d495c6eSApple OSS Distributions const OSString *wlClass = OSDynamicCast(OSString, wlClassObj);
278*4d495c6eSApple OSS Distributions if (wlClass == nullptr) {
279*4d495c6eSApple OSS Distributions wiClass = WI_CLASS_NONE;
280*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
281*4d495c6eSApple OSS Distributions }
282*4d495c6eSApple OSS Distributions
283*4d495c6eSApple OSS Distributions for (size_t i = 0; i < ARRAY_LEN(wlClassData); i++) {
284*4d495c6eSApple OSS Distributions if (wlClassData[i].name != nullptr &&
285*4d495c6eSApple OSS Distributions wlClass->isEqualTo(wlClassData[i].name)) {
286*4d495c6eSApple OSS Distributions wiClass = (wi_class_t)i;
287*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
288*4d495c6eSApple OSS Distributions }
289*4d495c6eSApple OSS Distributions }
290*4d495c6eSApple OSS Distributions
291*4d495c6eSApple OSS Distributions WLC_LOG("%s: unknown %s: \"%s\"\n", id.getCStringNoCopy(),
292*4d495c6eSApple OSS Distributions kWorkloadClassKey, wlClass->getCStringNoCopy());
293*4d495c6eSApple OSS Distributions return kIOReturnError;
294*4d495c6eSApple OSS Distributions }
295*4d495c6eSApple OSS Distributions
296*4d495c6eSApple OSS Distributions static IOReturn
parseCriticalityOffset(const OSSymbol & id,const wi_class_t wiClass,const OSObject * cOffsetObj,uint8_t & criticalityOffset)297*4d495c6eSApple OSS Distributions parseCriticalityOffset(const OSSymbol &id, const wi_class_t wiClass,
298*4d495c6eSApple OSS Distributions const OSObject *cOffsetObj, uint8_t &criticalityOffset)
299*4d495c6eSApple OSS Distributions {
300*4d495c6eSApple OSS Distributions if (wiClass != WI_CLASS_SYSTEM_CRITICAL &&
301*4d495c6eSApple OSS Distributions wiClass != WI_CLASS_REALTIME_CRITICAL &&
302*4d495c6eSApple OSS Distributions wiClass != WI_CLASS_BEST_EFFORT &&
303*4d495c6eSApple OSS Distributions wiClass != WI_CLASS_APP_SUPPORT &&
304*4d495c6eSApple OSS Distributions wiClass != WI_CLASS_SYSTEM) {
305*4d495c6eSApple OSS Distributions criticalityOffset = 0;
306*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
307*4d495c6eSApple OSS Distributions }
308*4d495c6eSApple OSS Distributions
309*4d495c6eSApple OSS Distributions const OSNumber *cOffset = OSDynamicCast(OSNumber, cOffsetObj);
310*4d495c6eSApple OSS Distributions if (cOffset == nullptr) {
311*4d495c6eSApple OSS Distributions criticalityOffset = 0;
312*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
313*4d495c6eSApple OSS Distributions }
314*4d495c6eSApple OSS Distributions
315*4d495c6eSApple OSS Distributions UInt64 criticalityOffset64 = cOffset->unsigned64BitValue();
316*4d495c6eSApple OSS Distributions const int nBytes = cOffset->numberOfBytes();
317*4d495c6eSApple OSS Distributions if (nBytes <= sizeof(criticalityOffset64) &&
318*4d495c6eSApple OSS Distributions criticalityOffset64 < MAX_CRITICALITY_OFFSET) {
319*4d495c6eSApple OSS Distributions criticalityOffset = (uint8_t)criticalityOffset64;
320*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
321*4d495c6eSApple OSS Distributions }
322*4d495c6eSApple OSS Distributions
323*4d495c6eSApple OSS Distributions WLC_LOG("%s: criticality offset too large\n", id.getCStringNoCopy());
324*4d495c6eSApple OSS Distributions return kIOReturnError;
325*4d495c6eSApple OSS Distributions }
326*4d495c6eSApple OSS Distributions
327*4d495c6eSApple OSS Distributions static IOReturn
parseFlags(const OSSymbol & id,const OSObject * flagsObj,UInt32 & threadGroupFlags,UInt32 & workIntervalFlags)328*4d495c6eSApple OSS Distributions parseFlags(const OSSymbol &id, const OSObject *flagsObj, UInt32 &threadGroupFlags,
329*4d495c6eSApple OSS Distributions UInt32 &workIntervalFlags)
330*4d495c6eSApple OSS Distributions {
331*4d495c6eSApple OSS Distributions /* Optional, so just carry on if not found. */
332*4d495c6eSApple OSS Distributions if (flagsObj == nullptr) {
333*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
334*4d495c6eSApple OSS Distributions }
335*4d495c6eSApple OSS Distributions
336*4d495c6eSApple OSS Distributions OSArray *flags = OSDynamicCast(OSArray, flagsObj);
337*4d495c6eSApple OSS Distributions if (flags == nullptr) {
338*4d495c6eSApple OSS Distributions WLC_LOG("failed to parse \"" kFlagsKey "\"\n");
339*4d495c6eSApple OSS Distributions return kIOReturnError;
340*4d495c6eSApple OSS Distributions }
341*4d495c6eSApple OSS Distributions
342*4d495c6eSApple OSS Distributions /* BEGIN IGNORE CODESTYLE */
343*4d495c6eSApple OSS Distributions __block IOReturn ret = kIOReturnSuccess;
344*4d495c6eSApple OSS Distributions flags->iterateObjects(^bool (OSObject *object) {
345*4d495c6eSApple OSS Distributions const OSString *flag = OSDynamicCast(OSString, object);
346*4d495c6eSApple OSS Distributions if (flag == nullptr) {
347*4d495c6eSApple OSS Distributions WLC_LOG("%s: non-string flag found\n", id.getCStringNoCopy());
348*4d495c6eSApple OSS Distributions ret = kIOReturnError;
349*4d495c6eSApple OSS Distributions return true;
350*4d495c6eSApple OSS Distributions
351*4d495c6eSApple OSS Distributions }
352*4d495c6eSApple OSS Distributions
353*4d495c6eSApple OSS Distributions /* Ignore unknown flags. */
354*4d495c6eSApple OSS Distributions #if defined(XNU_TARGET_OS_XR)
355*4d495c6eSApple OSS Distributions #if CONFIG_THREAD_GROUPS
356*4d495c6eSApple OSS Distributions if (flag->isEqualTo(kUXMValue)) {
357*4d495c6eSApple OSS Distributions threadGroupFlags |= THREAD_GROUP_FLAGS_MANAGED;
358*4d495c6eSApple OSS Distributions }
359*4d495c6eSApple OSS Distributions if (flag->isEqualTo(kStrictTimersValue)) {
360*4d495c6eSApple OSS Distributions threadGroupFlags |= THREAD_GROUP_FLAGS_STRICT_TIMERS;
361*4d495c6eSApple OSS Distributions }
362*4d495c6eSApple OSS Distributions #endif /* CONFIG_THREAD_GROUPS */
363*4d495c6eSApple OSS Distributions #endif /* XNU_TARGET_OS_XR */
364*4d495c6eSApple OSS Distributions if (flag->isEqualTo(kWIComplexityAllowedValue)) {
365*4d495c6eSApple OSS Distributions workIntervalFlags |= WORK_INTERVAL_WORKLOAD_ID_COMPLEXITY_ALLOWED;
366*4d495c6eSApple OSS Distributions }
367*4d495c6eSApple OSS Distributions
368*4d495c6eSApple OSS Distributions return false;
369*4d495c6eSApple OSS Distributions });
370*4d495c6eSApple OSS Distributions /* END IGNORE CODESTYLE */
371*4d495c6eSApple OSS Distributions
372*4d495c6eSApple OSS Distributions return ret;
373*4d495c6eSApple OSS Distributions }
374*4d495c6eSApple OSS Distributions
375*4d495c6eSApple OSS Distributions static
376*4d495c6eSApple OSS Distributions IOReturn
parsePhases(workload_config_ctx_t * ctx,const OSSymbol & id,OSObject * phasesObj)377*4d495c6eSApple OSS Distributions parsePhases(workload_config_ctx_t *ctx, const OSSymbol &id, OSObject *phasesObj)
378*4d495c6eSApple OSS Distributions {
379*4d495c6eSApple OSS Distributions __block IOReturn ret = kIOReturnError;
380*4d495c6eSApple OSS Distributions
381*4d495c6eSApple OSS Distributions OSDictionary *phases = OSDynamicCast(OSDictionary, phasesObj);
382*4d495c6eSApple OSS Distributions if (phases == nullptr) {
383*4d495c6eSApple OSS Distributions WLC_LOG("%s: failed to find dictionary for \"" kPhasesKey "\"\n",
384*4d495c6eSApple OSS Distributions id.getCStringNoCopy());
385*4d495c6eSApple OSS Distributions return kIOReturnError;
386*4d495c6eSApple OSS Distributions }
387*4d495c6eSApple OSS Distributions
388*4d495c6eSApple OSS Distributions /* There should be at least one phase described. */
389*4d495c6eSApple OSS Distributions ret = kIOReturnError;
390*4d495c6eSApple OSS Distributions
391*4d495c6eSApple OSS Distributions /* BEGIN IGNORE CODESTYLE */
392*4d495c6eSApple OSS Distributions phases->iterateObjects(^bool (const OSSymbol *phase, OSObject *value) {
393*4d495c6eSApple OSS Distributions const OSDictionary *dict = OSDynamicCast(OSDictionary, value);
394*4d495c6eSApple OSS Distributions if (dict == nullptr) {
395*4d495c6eSApple OSS Distributions WLC_LOG("%s: failed to find dictionary for \"%s\" phase\n",
396*4d495c6eSApple OSS Distributions id.getCStringNoCopy(), phase->getCStringNoCopy());
397*4d495c6eSApple OSS Distributions ret = kIOReturnError;
398*4d495c6eSApple OSS Distributions return true;
399*4d495c6eSApple OSS Distributions }
400*4d495c6eSApple OSS Distributions
401*4d495c6eSApple OSS Distributions UInt32 createFlags = 0;
402*4d495c6eSApple OSS Distributions ret = parseWorkIntervalType(id, dict->getObject(kWorkIntervalTypeKey),
403*4d495c6eSApple OSS Distributions createFlags);
404*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
405*4d495c6eSApple OSS Distributions return true;
406*4d495c6eSApple OSS Distributions }
407*4d495c6eSApple OSS Distributions
408*4d495c6eSApple OSS Distributions wi_class_t wiClass = WI_CLASS_NONE;
409*4d495c6eSApple OSS Distributions ret = parseWorkloadClass(id, dict->getObject(kWorkloadClassKey), wiClass);
410*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
411*4d495c6eSApple OSS Distributions return true;
412*4d495c6eSApple OSS Distributions }
413*4d495c6eSApple OSS Distributions const struct WorkloadClassData classData = wlClassData[wiClass];
414*4d495c6eSApple OSS Distributions
415*4d495c6eSApple OSS Distributions uint8_t criticalityOffset = 0;
416*4d495c6eSApple OSS Distributions ret = parseCriticalityOffset(id, wiClass,
417*4d495c6eSApple OSS Distributions dict->getObject(kCriticalityOffsetKey), criticalityOffset);
418*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
419*4d495c6eSApple OSS Distributions return true;
420*4d495c6eSApple OSS Distributions }
421*4d495c6eSApple OSS Distributions
422*4d495c6eSApple OSS Distributions UInt32 threadGroupFlags = classData.threadGroupFlags;
423*4d495c6eSApple OSS Distributions UInt32 workIntervalFlags = classData.workIntervalFlags;
424*4d495c6eSApple OSS Distributions ret = parseFlags(id, dict->getObject(kFlagsKey), threadGroupFlags, workIntervalFlags);
425*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
426*4d495c6eSApple OSS Distributions return true;
427*4d495c6eSApple OSS Distributions }
428*4d495c6eSApple OSS Distributions
429*4d495c6eSApple OSS Distributions const workload_config_t config = {
430*4d495c6eSApple OSS Distributions .wc_thread_group_flags = threadGroupFlags,
431*4d495c6eSApple OSS Distributions .wc_flags = workIntervalFlags,
432*4d495c6eSApple OSS Distributions .wc_create_flags = createFlags,
433*4d495c6eSApple OSS Distributions .wc_class_offset = (uint8_t)criticalityOffset,
434*4d495c6eSApple OSS Distributions .wc_class = wiClass,
435*4d495c6eSApple OSS Distributions };
436*4d495c6eSApple OSS Distributions ret = workload_config_insert(ctx, id.getCStringNoCopy(), phase->getCStringNoCopy(), &config);
437*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
438*4d495c6eSApple OSS Distributions WLC_LOG("%s: failed to add \"%s\" phase\n",
439*4d495c6eSApple OSS Distributions id.getCStringNoCopy(), phase->getCStringNoCopy());
440*4d495c6eSApple OSS Distributions return true;
441*4d495c6eSApple OSS Distributions }
442*4d495c6eSApple OSS Distributions
443*4d495c6eSApple OSS Distributions return false;
444*4d495c6eSApple OSS Distributions });
445*4d495c6eSApple OSS Distributions /* END IGNORE CODESTYLE */
446*4d495c6eSApple OSS Distributions
447*4d495c6eSApple OSS Distributions return ret;
448*4d495c6eSApple OSS Distributions }
449*4d495c6eSApple OSS Distributions
450*4d495c6eSApple OSS Distributions static IOReturn
parseRoot(const OSSymbol & id,const OSObject * rootDict,OSString * & defaultPhase)451*4d495c6eSApple OSS Distributions parseRoot(const OSSymbol &id, const OSObject *rootDict, OSString *&defaultPhase)
452*4d495c6eSApple OSS Distributions {
453*4d495c6eSApple OSS Distributions const OSDictionary *root = OSDynamicCast(OSDictionary, rootDict);
454*4d495c6eSApple OSS Distributions if (root == nullptr) {
455*4d495c6eSApple OSS Distributions WLC_LOG("%s: failed to find dictionary for \"" kRootKey "\"\n",
456*4d495c6eSApple OSS Distributions id.getCStringNoCopy());
457*4d495c6eSApple OSS Distributions return kIOReturnError;
458*4d495c6eSApple OSS Distributions }
459*4d495c6eSApple OSS Distributions
460*4d495c6eSApple OSS Distributions defaultPhase = OSDynamicCast(OSString, root->getObject(kDefaultPhaseKey));
461*4d495c6eSApple OSS Distributions if (defaultPhase == nullptr) {
462*4d495c6eSApple OSS Distributions WLC_LOG("%s: failed to find \"" kDefaultPhaseKey"\" in \"" kRootKey "\" dictionary\n",
463*4d495c6eSApple OSS Distributions id.getCStringNoCopy());
464*4d495c6eSApple OSS Distributions return kIOReturnError;
465*4d495c6eSApple OSS Distributions }
466*4d495c6eSApple OSS Distributions
467*4d495c6eSApple OSS Distributions if (defaultPhase->getLength() == 0) {
468*4d495c6eSApple OSS Distributions WLC_LOG("%s: \"" kDefaultPhaseKey" \" is empty in \"" kRootKey "\" dictionary\n",
469*4d495c6eSApple OSS Distributions id.getCStringNoCopy());
470*4d495c6eSApple OSS Distributions return kIOReturnError;
471*4d495c6eSApple OSS Distributions }
472*4d495c6eSApple OSS Distributions
473*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
474*4d495c6eSApple OSS Distributions }
475*4d495c6eSApple OSS Distributions
476*4d495c6eSApple OSS Distributions static IOReturn
parseWorkloadIDTable(workload_config_ctx_t * ctx,OSDictionary * IDTable)477*4d495c6eSApple OSS Distributions parseWorkloadIDTable(workload_config_ctx_t *ctx, OSDictionary *IDTable)
478*4d495c6eSApple OSS Distributions {
479*4d495c6eSApple OSS Distributions /*
480*4d495c6eSApple OSS Distributions * At least one valid entry is expected, so start off with error to
481*4d495c6eSApple OSS Distributions * catch an empty table or one with no valid entries.
482*4d495c6eSApple OSS Distributions */
483*4d495c6eSApple OSS Distributions __block IOReturn ret = kIOReturnError;
484*4d495c6eSApple OSS Distributions
485*4d495c6eSApple OSS Distributions /* BEGIN IGNORE CODESTYLE */
486*4d495c6eSApple OSS Distributions IDTable->iterateObjects(^bool (const OSSymbol *id, OSObject *value) {
487*4d495c6eSApple OSS Distributions /* Validate the workload ID. */
488*4d495c6eSApple OSS Distributions if (id->getLength() == 0) {
489*4d495c6eSApple OSS Distributions WLC_LOG("zero length ID in \"" kWorkloadIDTableKey "\"\n");
490*4d495c6eSApple OSS Distributions ret = kIOReturnError;
491*4d495c6eSApple OSS Distributions return true;
492*4d495c6eSApple OSS Distributions }
493*4d495c6eSApple OSS Distributions
494*4d495c6eSApple OSS Distributions /* Parse its properties. */
495*4d495c6eSApple OSS Distributions OSDictionary *idConfig = OSDynamicCast(OSDictionary, value);
496*4d495c6eSApple OSS Distributions if (idConfig == nullptr) {
497*4d495c6eSApple OSS Distributions WLC_LOG("failed to find dictionary for \"%s\"\n",
498*4d495c6eSApple OSS Distributions id->getCStringNoCopy());
499*4d495c6eSApple OSS Distributions ret = kIOReturnError;
500*4d495c6eSApple OSS Distributions return true;
501*4d495c6eSApple OSS Distributions }
502*4d495c6eSApple OSS Distributions
503*4d495c6eSApple OSS Distributions ret = parsePhases(ctx, *id, idConfig->getObject(kPhasesKey));
504*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
505*4d495c6eSApple OSS Distributions return true;
506*4d495c6eSApple OSS Distributions }
507*4d495c6eSApple OSS Distributions
508*4d495c6eSApple OSS Distributions OSString *defaultPhase = nullptr;
509*4d495c6eSApple OSS Distributions ret = parseRoot(*id, idConfig->getObject(kRootKey), defaultPhase);
510*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
511*4d495c6eSApple OSS Distributions return true;
512*4d495c6eSApple OSS Distributions }
513*4d495c6eSApple OSS Distributions
514*4d495c6eSApple OSS Distributions /* Fails if the specified phase doesn't exist.. */
515*4d495c6eSApple OSS Distributions ret = workload_config_set_default(ctx, id->getCStringNoCopy(),
516*4d495c6eSApple OSS Distributions defaultPhase->getCStringNoCopy());
517*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
518*4d495c6eSApple OSS Distributions WLC_LOG("failed to set default phase (%s) for \"%s\"\n",
519*4d495c6eSApple OSS Distributions defaultPhase->getCStringNoCopy(), id->getCStringNoCopy());
520*4d495c6eSApple OSS Distributions return true;
521*4d495c6eSApple OSS Distributions }
522*4d495c6eSApple OSS Distributions
523*4d495c6eSApple OSS Distributions return false;
524*4d495c6eSApple OSS Distributions });
525*4d495c6eSApple OSS Distributions /* END IGNORE CODESTYLE */
526*4d495c6eSApple OSS Distributions
527*4d495c6eSApple OSS Distributions return ret;
528*4d495c6eSApple OSS Distributions }
529*4d495c6eSApple OSS Distributions
530*4d495c6eSApple OSS Distributions static IOReturn
parseWorkloadIDConfigurationFlags(workload_config_ctx_t * ctx,const OSObject * idTableFlagsObj)531*4d495c6eSApple OSS Distributions parseWorkloadIDConfigurationFlags(workload_config_ctx_t *ctx, const OSObject *idTableFlagsObj)
532*4d495c6eSApple OSS Distributions {
533*4d495c6eSApple OSS Distributions /* Optional, so just carry on if not found. */
534*4d495c6eSApple OSS Distributions if (idTableFlagsObj == nullptr) {
535*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
536*4d495c6eSApple OSS Distributions }
537*4d495c6eSApple OSS Distributions
538*4d495c6eSApple OSS Distributions OSArray *idTableFlags = OSDynamicCast(OSArray, idTableFlagsObj);
539*4d495c6eSApple OSS Distributions if (idTableFlags == nullptr) {
540*4d495c6eSApple OSS Distributions WLC_LOG("failed to parse \""
541*4d495c6eSApple OSS Distributions kWorkloadIDConfigurationFlagsKey "\"\n");
542*4d495c6eSApple OSS Distributions return kIOReturnError;
543*4d495c6eSApple OSS Distributions }
544*4d495c6eSApple OSS Distributions
545*4d495c6eSApple OSS Distributions /* BEGIN IGNORE CODESTYLE */
546*4d495c6eSApple OSS Distributions __block IOReturn ret = kIOReturnSuccess;
547*4d495c6eSApple OSS Distributions idTableFlags->iterateObjects(^bool (OSObject *object) {
548*4d495c6eSApple OSS Distributions const OSString *flag = OSDynamicCast(OSString, object);
549*4d495c6eSApple OSS Distributions if (flag == nullptr) {
550*4d495c6eSApple OSS Distributions WLC_LOG("non-string Workload ID Table flag found\n");
551*4d495c6eSApple OSS Distributions ret = kIOReturnError;
552*4d495c6eSApple OSS Distributions return true;
553*4d495c6eSApple OSS Distributions }
554*4d495c6eSApple OSS Distributions
555*4d495c6eSApple OSS Distributions if (flag->isEqualTo(kDisableWorkloadClassThreadPolicyValue)) {
556*4d495c6eSApple OSS Distributions workload_config_clear_flag(ctx, WLC_F_THREAD_POLICY);
557*4d495c6eSApple OSS Distributions }
558*4d495c6eSApple OSS Distributions
559*4d495c6eSApple OSS Distributions return false;
560*4d495c6eSApple OSS Distributions });
561*4d495c6eSApple OSS Distributions /* END IGNORE CODESTYLE */
562*4d495c6eSApple OSS Distributions
563*4d495c6eSApple OSS Distributions return ret;
564*4d495c6eSApple OSS Distributions }
565*4d495c6eSApple OSS Distributions
566*4d495c6eSApple OSS Distributions static IOReturn
unparseWorkloadIDConfigurationFlags(OSSharedPtr<OSDictionary> & plist)567*4d495c6eSApple OSS Distributions unparseWorkloadIDConfigurationFlags(OSSharedPtr<OSDictionary> &plist)
568*4d495c6eSApple OSS Distributions {
569*4d495c6eSApple OSS Distributions workload_config_flags_t flags = WLC_F_NONE;
570*4d495c6eSApple OSS Distributions
571*4d495c6eSApple OSS Distributions /* There may be no config at all. That's ok. */
572*4d495c6eSApple OSS Distributions if (workload_config_get_flags(&flags) != KERN_SUCCESS) {
573*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
574*4d495c6eSApple OSS Distributions }
575*4d495c6eSApple OSS Distributions
576*4d495c6eSApple OSS Distributions /* Workload config can change thread policy scheduling - the default. */
577*4d495c6eSApple OSS Distributions if ((flags & WLC_F_THREAD_POLICY) != 0) {
578*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
579*4d495c6eSApple OSS Distributions }
580*4d495c6eSApple OSS Distributions
581*4d495c6eSApple OSS Distributions OSSharedPtr<OSArray> idTableFlags = OSArray::withCapacity(1);
582*4d495c6eSApple OSS Distributions OSSharedPtr<OSString> flag = OSString::withCString(kDisableWorkloadClassThreadPolicyValue);
583*4d495c6eSApple OSS Distributions if (!idTableFlags->setObject(flag) ||
584*4d495c6eSApple OSS Distributions !plist->setObject(kWorkloadIDConfigurationFlagsKey, idTableFlags)) {
585*4d495c6eSApple OSS Distributions return kIOReturnError;
586*4d495c6eSApple OSS Distributions }
587*4d495c6eSApple OSS Distributions
588*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
589*4d495c6eSApple OSS Distributions }
590*4d495c6eSApple OSS Distributions
591*4d495c6eSApple OSS Distributions extern "C" {
592*4d495c6eSApple OSS Distributions extern IOReturn IOParseWorkloadConfig(workload_config_ctx_t *, const char *, size_t);
593*4d495c6eSApple OSS Distributions extern IOReturn IOUnparseWorkloadConfig(char *, size_t *);
594*4d495c6eSApple OSS Distributions }
595*4d495c6eSApple OSS Distributions
596*4d495c6eSApple OSS Distributions /* Called locked. */
597*4d495c6eSApple OSS Distributions IOReturn
IOParseWorkloadConfig(workload_config_ctx_t * ctx,const char * buffer,size_t size)598*4d495c6eSApple OSS Distributions IOParseWorkloadConfig(workload_config_ctx_t *ctx, const char *buffer, size_t size)
599*4d495c6eSApple OSS Distributions {
600*4d495c6eSApple OSS Distributions IOReturn ret = kIOReturnError;
601*4d495c6eSApple OSS Distributions
602*4d495c6eSApple OSS Distributions OSSharedPtr<OSString> unserializeErrorString = nullptr;
603*4d495c6eSApple OSS Distributions OSSharedPtr<OSObject> obj = nullptr;
604*4d495c6eSApple OSS Distributions OSDictionary *idTable = nullptr;
605*4d495c6eSApple OSS Distributions OSDictionary *dict = nullptr;
606*4d495c6eSApple OSS Distributions
607*4d495c6eSApple OSS Distributions ret = workload_config_init(ctx);
608*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
609*4d495c6eSApple OSS Distributions WLC_LOG("failed to initialize workload configuration\n");
610*4d495c6eSApple OSS Distributions goto out;
611*4d495c6eSApple OSS Distributions }
612*4d495c6eSApple OSS Distributions
613*4d495c6eSApple OSS Distributions obj = OSUnserializeXML(buffer, unserializeErrorString);
614*4d495c6eSApple OSS Distributions dict = OSDynamicCast(OSDictionary, obj.get());
615*4d495c6eSApple OSS Distributions if (dict == nullptr) {
616*4d495c6eSApple OSS Distributions WLC_LOG("failed to unserialize plist\n");
617*4d495c6eSApple OSS Distributions ret = kIOReturnError;
618*4d495c6eSApple OSS Distributions goto out;
619*4d495c6eSApple OSS Distributions }
620*4d495c6eSApple OSS Distributions
621*4d495c6eSApple OSS Distributions idTable = OSDynamicCast(OSDictionary, dict->getObject(kWorkloadIDTableKey));
622*4d495c6eSApple OSS Distributions if (idTable == nullptr) {
623*4d495c6eSApple OSS Distributions WLC_LOG("failed to find " kWorkloadIDTableKey "\n");
624*4d495c6eSApple OSS Distributions ret = kIOReturnError;
625*4d495c6eSApple OSS Distributions goto out;
626*4d495c6eSApple OSS Distributions }
627*4d495c6eSApple OSS Distributions
628*4d495c6eSApple OSS Distributions ret = parseWorkloadIDTable(ctx, idTable);
629*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
630*4d495c6eSApple OSS Distributions goto out;
631*4d495c6eSApple OSS Distributions }
632*4d495c6eSApple OSS Distributions
633*4d495c6eSApple OSS Distributions ret = parseWorkloadIDConfigurationFlags(ctx, dict->getObject(kWorkloadIDConfigurationFlagsKey));
634*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
635*4d495c6eSApple OSS Distributions goto out;
636*4d495c6eSApple OSS Distributions }
637*4d495c6eSApple OSS Distributions
638*4d495c6eSApple OSS Distributions ret = kIOReturnSuccess;
639*4d495c6eSApple OSS Distributions
640*4d495c6eSApple OSS Distributions out:
641*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
642*4d495c6eSApple OSS Distributions workload_config_free(ctx);
643*4d495c6eSApple OSS Distributions }
644*4d495c6eSApple OSS Distributions
645*4d495c6eSApple OSS Distributions return ret;
646*4d495c6eSApple OSS Distributions }
647*4d495c6eSApple OSS Distributions
648*4d495c6eSApple OSS Distributions /*
649*4d495c6eSApple OSS Distributions * Does the reverse of IOParseWorkloadConfig() - i.e. serializes the internal
650*4d495c6eSApple OSS Distributions * workload configuration.
651*4d495c6eSApple OSS Distributions * The serialized workload config is copied to 'buffer' (if non-NULL).
652*4d495c6eSApple OSS Distributions * size is in/out - it describes the size of buffer and on return the length of
653*4d495c6eSApple OSS Distributions * the serialized config.
654*4d495c6eSApple OSS Distributions */
655*4d495c6eSApple OSS Distributions IOReturn
IOUnparseWorkloadConfig(char * buffer,size_t * size)656*4d495c6eSApple OSS Distributions IOUnparseWorkloadConfig(char *buffer, size_t *size)
657*4d495c6eSApple OSS Distributions {
658*4d495c6eSApple OSS Distributions assert(size != nullptr);
659*4d495c6eSApple OSS Distributions
660*4d495c6eSApple OSS Distributions OSSharedPtr<OSDictionary> dict = nullptr;;
661*4d495c6eSApple OSS Distributions OSSharedPtr<OSDictionary> idTable = nullptr;
662*4d495c6eSApple OSS Distributions OSSharedPtr<OSSerialize> serialize = nullptr;
663*4d495c6eSApple OSS Distributions
664*4d495c6eSApple OSS Distributions serialize = OSSerialize::withCapacity(1);
665*4d495c6eSApple OSS Distributions if (serialize == nullptr) {
666*4d495c6eSApple OSS Distributions return kIOReturnNoMemory;
667*4d495c6eSApple OSS Distributions }
668*4d495c6eSApple OSS Distributions
669*4d495c6eSApple OSS Distributions dict = OSDictionary::withCapacity(1);
670*4d495c6eSApple OSS Distributions if (dict == nullptr) {
671*4d495c6eSApple OSS Distributions return kIOReturnNoMemory;
672*4d495c6eSApple OSS Distributions }
673*4d495c6eSApple OSS Distributions
674*4d495c6eSApple OSS Distributions idTable = OSDictionary::withCapacity(1);
675*4d495c6eSApple OSS Distributions if (idTable == nullptr) {
676*4d495c6eSApple OSS Distributions return kIOReturnNoMemory;
677*4d495c6eSApple OSS Distributions }
678*4d495c6eSApple OSS Distributions
679*4d495c6eSApple OSS Distributions __block IOReturn ret = kIOReturnSuccess;
680*4d495c6eSApple OSS Distributions /* BEGIN IGNORE CODESTYLE */
681*4d495c6eSApple OSS Distributions workload_config_iterate(^(const char *id_str, const void *config) {
682*4d495c6eSApple OSS Distributions OSSharedPtr<OSDictionary> idDict = OSDictionary::withCapacity(1);
683*4d495c6eSApple OSS Distributions if (idDict == nullptr) {
684*4d495c6eSApple OSS Distributions ret = kIOReturnNoMemory;
685*4d495c6eSApple OSS Distributions return true;
686*4d495c6eSApple OSS Distributions }
687*4d495c6eSApple OSS Distributions
688*4d495c6eSApple OSS Distributions OSSharedPtr<OSDictionary> phase = OSDictionary::withCapacity(1);
689*4d495c6eSApple OSS Distributions if (phase == nullptr) {
690*4d495c6eSApple OSS Distributions ret = kIOReturnNoMemory;
691*4d495c6eSApple OSS Distributions return true;
692*4d495c6eSApple OSS Distributions }
693*4d495c6eSApple OSS Distributions
694*4d495c6eSApple OSS Distributions workload_config_phases_iterate(config, ^(const char *phase_str,
695*4d495c6eSApple OSS Distributions const bool is_default, const workload_config_t *wc) {
696*4d495c6eSApple OSS Distributions OSSharedPtr<OSDictionary> phaseData = OSDictionary::withCapacity(1);
697*4d495c6eSApple OSS Distributions if (phaseData == nullptr) {
698*4d495c6eSApple OSS Distributions ret = kIOReturnNoMemory;
699*4d495c6eSApple OSS Distributions return true;
700*4d495c6eSApple OSS Distributions }
701*4d495c6eSApple OSS Distributions
702*4d495c6eSApple OSS Distributions if (wc->wc_class != WI_CLASS_NONE) {
703*4d495c6eSApple OSS Distributions assert3u(wc->wc_class, <, WI_CLASS_COUNT);
704*4d495c6eSApple OSS Distributions OSSharedPtr<OSString> wClass = OSString::withCString(wlClassData[wc->wc_class].name);
705*4d495c6eSApple OSS Distributions if (wClass == nullptr || !phaseData->setObject(kWorkloadClassKey, wClass)) {
706*4d495c6eSApple OSS Distributions ret = kIOReturnError;
707*4d495c6eSApple OSS Distributions return true;
708*4d495c6eSApple OSS Distributions }
709*4d495c6eSApple OSS Distributions }
710*4d495c6eSApple OSS Distributions
711*4d495c6eSApple OSS Distributions if (wc->wc_class_offset > 0) {
712*4d495c6eSApple OSS Distributions OSSharedPtr<OSNumber> criticalityOffset = OSNumber::withNumber(wc->wc_class_offset, 8);
713*4d495c6eSApple OSS Distributions if (criticalityOffset == nullptr ||
714*4d495c6eSApple OSS Distributions !phaseData->setObject(kCriticalityOffsetKey, criticalityOffset)) {
715*4d495c6eSApple OSS Distributions ret = kIOReturnError;
716*4d495c6eSApple OSS Distributions return true;
717*4d495c6eSApple OSS Distributions }
718*4d495c6eSApple OSS Distributions }
719*4d495c6eSApple OSS Distributions
720*4d495c6eSApple OSS Distributions OSSharedPtr<OSString> type = nullptr;
721*4d495c6eSApple OSS Distributions if (unparseWorkIntervalType(wc->wc_create_flags, type) != kIOReturnSuccess ||
722*4d495c6eSApple OSS Distributions !phaseData->setObject(kWorkIntervalTypeKey, type)) {
723*4d495c6eSApple OSS Distributions ret = kIOReturnError;
724*4d495c6eSApple OSS Distributions return true;
725*4d495c6eSApple OSS Distributions }
726*4d495c6eSApple OSS Distributions
727*4d495c6eSApple OSS Distributions
728*4d495c6eSApple OSS Distributions OSSharedPtr<OSArray> flags = OSArray::withCapacity(2);
729*4d495c6eSApple OSS Distributions if (flags == nullptr) {
730*4d495c6eSApple OSS Distributions ret = kIOReturnError;
731*4d495c6eSApple OSS Distributions return true;
732*4d495c6eSApple OSS Distributions }
733*4d495c6eSApple OSS Distributions #if defined(XNU_TARGET_OS_XR)
734*4d495c6eSApple OSS Distributions #if CONFIG_THREAD_GROUPS
735*4d495c6eSApple OSS Distributions if ((wc->wc_thread_group_flags & THREAD_GROUP_FLAGS_MANAGED) != 0) {
736*4d495c6eSApple OSS Distributions OSSharedPtr<OSString> UXMStr = OSString::withCString(kUXMValue);
737*4d495c6eSApple OSS Distributions if (UXMStr == nullptr || !flags->setObject(UXMStr)) {
738*4d495c6eSApple OSS Distributions ret = kIOReturnError;
739*4d495c6eSApple OSS Distributions return true;
740*4d495c6eSApple OSS Distributions }
741*4d495c6eSApple OSS Distributions }
742*4d495c6eSApple OSS Distributions if ((wc->wc_thread_group_flags & THREAD_GROUP_FLAGS_STRICT_TIMERS) != 0) {
743*4d495c6eSApple OSS Distributions OSSharedPtr<OSString> StrictTimersStr = OSString::withCString(kStrictTimersValue);
744*4d495c6eSApple OSS Distributions if (StrictTimersStr == nullptr || !flags->setObject(StrictTimersStr)) {
745*4d495c6eSApple OSS Distributions ret = kIOReturnError;
746*4d495c6eSApple OSS Distributions return true;
747*4d495c6eSApple OSS Distributions }
748*4d495c6eSApple OSS Distributions }
749*4d495c6eSApple OSS Distributions #endif /* CONFIG_THREAD_GROUPS */
750*4d495c6eSApple OSS Distributions #endif /* XNU_TARGET_OS_XR */
751*4d495c6eSApple OSS Distributions if ((wc->wc_flags & WORK_INTERVAL_WORKLOAD_ID_COMPLEXITY_ALLOWED) != 0) {
752*4d495c6eSApple OSS Distributions OSSharedPtr<OSString> WIComplexityAllowedStr =
753*4d495c6eSApple OSS Distributions OSString::withCString(kWIComplexityAllowedValue);
754*4d495c6eSApple OSS Distributions if (WIComplexityAllowedStr == nullptr || !flags->setObject(WIComplexityAllowedStr)) {
755*4d495c6eSApple OSS Distributions ret = kIOReturnError;
756*4d495c6eSApple OSS Distributions return true;
757*4d495c6eSApple OSS Distributions }
758*4d495c6eSApple OSS Distributions }
759*4d495c6eSApple OSS Distributions if (flags->getCount() && !phaseData->setObject(kFlagsKey, flags)) {
760*4d495c6eSApple OSS Distributions ret = kIOReturnError;
761*4d495c6eSApple OSS Distributions return true;
762*4d495c6eSApple OSS Distributions }
763*4d495c6eSApple OSS Distributions
764*4d495c6eSApple OSS Distributions if (!phase->setObject(phase_str, phaseData)) {
765*4d495c6eSApple OSS Distributions ret = kIOReturnError;
766*4d495c6eSApple OSS Distributions return true;
767*4d495c6eSApple OSS Distributions }
768*4d495c6eSApple OSS Distributions
769*4d495c6eSApple OSS Distributions if (is_default) {
770*4d495c6eSApple OSS Distributions OSSharedPtr<OSDictionary> root = OSDictionary::withCapacity(1);
771*4d495c6eSApple OSS Distributions OSSharedPtr<OSString> phaseStr = OSString::withCString(phase_str);
772*4d495c6eSApple OSS Distributions
773*4d495c6eSApple OSS Distributions if (root == nullptr || phaseStr == nullptr ||
774*4d495c6eSApple OSS Distributions !root->setObject(kDefaultPhaseKey, phaseStr)) {
775*4d495c6eSApple OSS Distributions ret = kIOReturnError;
776*4d495c6eSApple OSS Distributions return true;
777*4d495c6eSApple OSS Distributions }
778*4d495c6eSApple OSS Distributions
779*4d495c6eSApple OSS Distributions if (!idDict->setObject(kRootKey, root)) {
780*4d495c6eSApple OSS Distributions ret = kIOReturnError;
781*4d495c6eSApple OSS Distributions return true;
782*4d495c6eSApple OSS Distributions }
783*4d495c6eSApple OSS Distributions }
784*4d495c6eSApple OSS Distributions
785*4d495c6eSApple OSS Distributions return false;
786*4d495c6eSApple OSS Distributions
787*4d495c6eSApple OSS Distributions });
788*4d495c6eSApple OSS Distributions
789*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
790*4d495c6eSApple OSS Distributions return true;
791*4d495c6eSApple OSS Distributions }
792*4d495c6eSApple OSS Distributions
793*4d495c6eSApple OSS Distributions if (!idDict->setObject(kPhasesKey, phase)) {
794*4d495c6eSApple OSS Distributions ret = kIOReturnError;
795*4d495c6eSApple OSS Distributions return true;
796*4d495c6eSApple OSS Distributions }
797*4d495c6eSApple OSS Distributions
798*4d495c6eSApple OSS Distributions if (!idTable->setObject(id_str, idDict)) {
799*4d495c6eSApple OSS Distributions ret = kIOReturnError;
800*4d495c6eSApple OSS Distributions return true;
801*4d495c6eSApple OSS Distributions }
802*4d495c6eSApple OSS Distributions
803*4d495c6eSApple OSS Distributions return false;
804*4d495c6eSApple OSS Distributions });
805*4d495c6eSApple OSS Distributions /* END IGNORE CODESTYLE */
806*4d495c6eSApple OSS Distributions
807*4d495c6eSApple OSS Distributions if (ret != kIOReturnSuccess) {
808*4d495c6eSApple OSS Distributions return ret;
809*4d495c6eSApple OSS Distributions }
810*4d495c6eSApple OSS Distributions
811*4d495c6eSApple OSS Distributions OSSharedPtr<OSDictionary> plist = OSDictionary::withCapacity(1);
812*4d495c6eSApple OSS Distributions if (plist == nullptr) {
813*4d495c6eSApple OSS Distributions return kIOReturnError;
814*4d495c6eSApple OSS Distributions }
815*4d495c6eSApple OSS Distributions
816*4d495c6eSApple OSS Distributions if (idTable->getCount() > 0 &&
817*4d495c6eSApple OSS Distributions !plist->setObject(kWorkloadIDTableKey, idTable)) {
818*4d495c6eSApple OSS Distributions return kIOReturnError;
819*4d495c6eSApple OSS Distributions }
820*4d495c6eSApple OSS Distributions
821*4d495c6eSApple OSS Distributions if (unparseWorkloadIDConfigurationFlags(plist) != kIOReturnSuccess) {
822*4d495c6eSApple OSS Distributions return kIOReturnError;
823*4d495c6eSApple OSS Distributions }
824*4d495c6eSApple OSS Distributions
825*4d495c6eSApple OSS Distributions if (!plist->serialize(serialize.get())) {
826*4d495c6eSApple OSS Distributions return kIOReturnError;
827*4d495c6eSApple OSS Distributions }
828*4d495c6eSApple OSS Distributions
829*4d495c6eSApple OSS Distributions if (buffer != nullptr) {
830*4d495c6eSApple OSS Distributions (void) strlcpy(buffer, serialize->text(), *size);
831*4d495c6eSApple OSS Distributions }
832*4d495c6eSApple OSS Distributions *size = serialize->getLength();
833*4d495c6eSApple OSS Distributions
834*4d495c6eSApple OSS Distributions return kIOReturnSuccess;
835*4d495c6eSApple OSS Distributions }
836