1from xnu import * 2from process import GetBSDThread, GetMachThread 3from scheduler import GetRecentTimestamp 4import xnudefines 5 6def GetProcWorkqueue(proc): 7 wq = proc.p_wqptr; 8 if unsigned(wq): 9 return Cast(wq, "struct workqueue *"); 10 return None 11 12@header("{:<20s} {:<20s} {:<20s} {:<10s} {:<10s} {:<10s} {:<10s} {:<10s} {:<10s} {:<30s}".format( 13 'task', 'proc', 'wq', 'sched', 'pending', 'idle', 'dying', 'creations', 'fulfilled', 'wq_flags')) 14def GetWorkqueueSummary(proc, wq): 15 wq_flags = [] 16 if wq.wq_flags & GetEnumValue("workq_state_flags_t::WQ_EXITING"): 17 wq_flags.append("EXITING") 18 if wq.wq_flags & GetEnumValue("workq_state_flags_t::WQ_PROC_SUSPENDED"): 19 wq_flags.append("PROC_SUSPENDED") 20 if wq.wq_flags & GetEnumValue("workq_state_flags_t::WQ_DEATH_CALL_SCHEDULED"): 21 wq_flags.append("DEATH_CALL") 22 23 scheduled = GetEnumValue("workq_state_flags_t::WQ_DELAYED_CALL_SCHEDULED") 24 pended = GetEnumValue("workq_state_flags_t::WQ_DELAYED_CALL_PENDED") 25 if wq.wq_flags & (scheduled | pended): 26 s = "DELAYED_CALL[" 27 if wq.wq_flags & scheduled: s += 'S' 28 if wq.wq_flags & pended: s += 'P' 29 s += ']' 30 wq_flags.append(s) 31 32 scheduled = GetEnumValue("workq_state_flags_t::WQ_IMMEDIATE_CALL_SCHEDULED") 33 pended = GetEnumValue("workq_state_flags_t::WQ_IMMEDIATE_CALL_PENDED") 34 if wq.wq_flags & (scheduled | pended): 35 s = "IMMEDIATE_CALL[" 36 if wq.wq_flags & scheduled: s += 'S' 37 if wq.wq_flags & pended: s += 'P' 38 s += ']' 39 wq_flags.append(s) 40 task = GetTaskFromProc(proc) 41 42 return "{task: <#020x} {p: <#020x} {wq: <#020x} {wq.wq_threads_scheduled: <10d} {wq.wq_reqcount: <10d} {wq.wq_thidlecount: <10d} {wq.wq_thdying_count: <10d} {wq.wq_creations: <10d} {wq.wq_fulfilled: <10d} {wq_flags: <30s}".format(task=task, p=proc, wq=wq, wq_flags=" ".join(wq_flags)); 43 44@header("{:<20s} {:<20s} {:>10s} {:9s} {:<20s} {:<10s} {:<30s}".format( 45 'thread', 'uthread', 'thport', 'kind', 'kqueue', 'idle (ms)', 'uu_workq_flags')) 46def GetWQThreadSummary(th, uth): 47 p = th.t_tro.tro_proc 48 wq = p.p_wqptr 49 50 uu_workq_flags = [] 51 if uth.uu_workq_flags & 0x01: uu_workq_flags.append("NEW") 52 if uth.uu_workq_flags & 0x02: 53 uu_workq_flags.append("RUNNING") 54 if wq.wq_creator == uth: 55 kind = "creator" 56 else: 57 kind = "workq" 58 idle = "" 59 else: 60 ts = kern.GetNanotimeFromAbstime(GetRecentTimestamp() - uth.uu_save.uus_workq_park_data.idle_stamp) / 1e9 61 kind = "idle" 62 idle = "%#.03f" % (ts) 63 if uth.uu_workq_flags & 0x04: uu_workq_flags.append("DYING") 64 if uth.uu_workq_flags & 0x08: uu_workq_flags.append("OVERCOMMIT") 65 if uth.uu_workq_flags & 0x100: uu_workq_flags.append("COOPERATIVE") 66 if uth.uu_workq_flags & 0x10: uu_workq_flags.append("OUTSIDE_QOS") 67 if uth.uu_workq_flags & 0x20: uu_workq_flags.append("IDLE_CLEANUP") 68 if uth.uu_workq_flags & 0x40: uu_workq_flags.append("EARLY_BOUND") 69 if uth.uu_workq_flags & 0x80: uu_workq_flags.append("CPU%") 70 71 kqr = uth.uu_kqr_bound 72 if not kqr: 73 kq = 0 74 elif kqr.tr_flags & 0x1: # kevent 75 kq = p.p_fd.fd_wqkqueue 76 kind = "kqwq[%s]" % (xnudefines.thread_qos_short_strings[int(kqr.tr_kq_qos_index)]) 77 elif kqr.tr_flags & 0x2: # workloop 78 kq = ContainerOf(kqr, 'struct kqworkloop', 'kqwl_request') 79 kind = "workloop" 80 else: 81 kq = 0 82 kind = "???" 83 84 return "{th: <#020x} {uth: <#020x} {thport: >#010x} {kind: <9s} {kq: <#020x} {idle: <10s} {uu_workq_flags: <30s}".format(th=th, uth=uth, thport=uth.uu_workq_thport, kind=kind, kq=kq, idle=idle, uu_workq_flags=" ".join(uu_workq_flags)) 85 86@header("{:<20s} {:<20s} {:<20s} {:<10s} {:<4s} {:<6s} {:<6s} {:<6s} {:<30s}".format( 87 'request', 'kqueue', 'thread', 'state', '#', 'qos', 'kq_qos', 'kq_ovr', 'tr_flags')) 88def GetWorkqueueThreadRequestSummary(proc, req): # req is the actual structure, not pointer 89 kq = 0 90 tr_flags = [] 91 req_addr = addressof(req) 92 93 if req.tr_flags & 0x01: 94 tr_flags.append("KEVENT") 95 kq = proc.p_fd.fd_wqkqueue 96 if req.tr_flags & 0x02: 97 tr_flags.append("WORKLOOP") 98 kq = ContainerOf(req_addr, 'struct kqworkloop', 'kqwl_request') 99 if req.tr_flags & 0x04: tr_flags.append("OVERCOMMIT") 100 if req.tr_flags & 0x08: tr_flags.append("PARAMS") 101 if req.tr_flags & 0x10: tr_flags.append("OUTSIDE_QOS") 102 if req.tr_flags & 0x20: tr_flags.append("COOPERATIVE") 103 104 state = {0: "IDLE", 1: "NEW", 2: "QUEUED", 3: "CANCELED", 4: "BINDING", 5: "BOUND" }[int(req.tr_state)] 105 106 thread = 0 107 if int(req.tr_state) in [4, 5]: # BINDING or BOUND 108 thread = req.tr_thread 109 110 qos = int(req.tr_qos) 111 if qos == 8: 112 qos = "MG" 113 elif qos == 7: 114 qos = "SP" 115 else: 116 qos = xnudefines.thread_qos_short_strings[qos] 117 118 kq_qos = xnudefines.thread_qos_short_strings[int(req.tr_kq_qos_index)] 119 kq_ovr = xnudefines.thread_qos_short_strings[int(req.tr_kq_override_index)] 120 121 return "{req_addr: <#020x} {kq: <#020x} {thread: <#020x} {state: <10s} {tr_count: <4d} {qos: <6s} {kq_qos: <6s} {kq_ovr: <6s} {tr_flags: <30s}".format( 122 req_addr=unsigned(req_addr), kq=kq, thread=thread, state=state, qos=qos, kq_qos=kq_qos, kq_ovr=kq_ovr, tr_count=req.tr_count, tr_flags=" ".join(tr_flags)) 123 124@lldb_command('showwqthread', fancy=True) 125def ShowWQThread(cmd_args=None, cmd_options={}, O=None): 126 """ Shows info about a workqueue thread 127 128 usage: showworkqthread <thread_t> 129 """ 130 131 if not cmd_args: 132 return O.error('missing struct proc * argument') 133 134 th = kern.GetValueFromAddress(cmd_args[0], "struct thread *") 135 if not (th.thread_tag & 0x20): 136 raise ArgumentError('not a workqueue thread') 137 138 with O.table(GetWQThreadSummary.header): 139 print(GetWQThreadSummary(th, GetBSDThread(th))) 140 141 142@lldb_command('showprocworkqueue', fancy=True) 143def ShowProcWorkqueue(cmd_args=None, cmd_options={}, O=None): 144 """ Shows the process workqueue 145 146 usage: showprocworkqueue <proc_t> 147 """ 148 149 if not cmd_args: 150 return O.error('missing struct proc * argument') 151 152 proc = kern.GetValueFromAddress(cmd_args[0], "proc_t") 153 wq = Cast(proc.p_wqptr, "struct workqueue *") 154 if not wq: 155 return O.error("{:#x} doesn't have a workqueue", proc) 156 157 with O.table(GetWorkqueueSummary.header): 158 print(GetWorkqueueSummary(proc, wq)) 159 160 with O.table(GetWorkqueueThreadRequestSummary.header, indent=True): 161 if wq.wq_reqcount: 162 print("") 163 if wq.wq_event_manager_threadreq: 164 print(GetWorkqueueThreadRequestSummary(proc, dereference(wq.wq_event_manager_threadreq))) 165 for req in IterateSchedPriorityQueue(wq.wq_overcommit_queue, 'struct workq_threadreq_s', 'tr_entry'): 166 print(GetWorkqueueThreadRequestSummary(proc, dereference(req))) 167 for req in IterateSchedPriorityQueue(wq.wq_constrained_queue, 'struct workq_threadreq_s', 'tr_entry'): 168 print(GetWorkqueueThreadRequestSummary(proc, dereference(req))) 169 for req in IterateSchedPriorityQueue(wq.wq_special_queue, 'struct workq_threadreq_s', 'tr_entry'): 170 print(GetWorkqueueThreadRequestSummary(proc, dereference(req))) 171 for qos in xnudefines.thread_qos_short_strings: 172 bucket = 0; 173 if qos > 2: #Greater than BG 174 bucket = qos - 2; 175 for req in IterateSTAILQ_HEAD(wq.wq_cooperative_queue[bucket], "tr_link"): 176 print(GetWorkqueueThreadRequestSummary(proc, dereference(req))) 177 178 179 with O.table(GetWQThreadSummary.header, indent=True): 180 print("") 181 for uth in IterateTAILQ_HEAD(wq.wq_thrunlist, "uu_workq_entry"): 182 print(GetWQThreadSummary(GetMachThread(uth), uth)) 183 for uth in IterateTAILQ_HEAD(wq.wq_thidlelist, "uu_workq_entry"): 184 print(GetWQThreadSummary(GetMachThread(uth), uth)) 185 for uth in IterateTAILQ_HEAD(wq.wq_thnewlist, "uu_workq_entry"): 186 print(GetWQThreadSummary(GetMachThread(uth), uth)) 187 188@lldb_command('showallworkqueues', fancy=True) 189def ShowAllWorkqueues(cmd_args=None, cmd_options={}, O=None): 190 """ Display a summary of all the workqueues in the system 191 192 usage: showallworkqueues 193 """ 194 195 with O.table(GetWorkqueueSummary.header): 196 for t in kern.tasks: 197 proc = GetProcFromTask(t) 198 if not proc: 199 continue 200 wq = Cast(proc.p_wqptr, "struct workqueue *"); 201 if wq: 202 print(GetWorkqueueSummary(proc, wq)) 203