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