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