Lines Matching refs:req

91 def GetWorkqueueThreadRequestSummary(proc, req): # req is the actual structure, not pointer  argument
94     req_addr = addressof(req)
96     if req.tr_flags & 0x01:
99     if req.tr_flags & 0x02:
102     if req.tr_flags & 0x04: tr_flags.append("OVERCOMMIT")
103     if req.tr_flags & 0x08: tr_flags.append("PARAMS")
104     if req.tr_flags & 0x10: tr_flags.append("OUTSIDE_QOS")
105     if req.tr_flags & 0x20: tr_flags.append("COOPERATIVE")
106     if req.tr_flags & 0x40: tr_flags.append("PERMANENT_BIND")
108 …state = {0: "IDLE", 1: "NEW", 2: "QUEUED", 3: "CANCELED", 4: "BINDING", 5: "BOUND" }[int(req.tr_st…
111     if int(req.tr_state) in [4, 5]: # BINDING or BOUND
112         thread = req.tr_thread
114     qos = int(req.tr_qos)
122     kq_qos = xnudefines.thread_qos_short_strings[int(req.tr_kq_qos_index)]
123     kq_ovr = xnudefines.thread_qos_short_strings[int(req.tr_kq_override_index)]
126 …hread=thread, state=state, qos=qos, kq_qos=kq_qos, kq_ovr=kq_ovr, tr_count=req.tr_count, tr_flags=…
169 …for req in IterateSchedPriorityQueue(wq.wq_overcommit_queue, 'struct workq_threadreq_s', 'tr_entry…
170                 print(GetWorkqueueThreadRequestSummary(proc, dereference(req)))
171 …for req in IterateSchedPriorityQueue(wq.wq_constrained_queue, 'struct workq_threadreq_s', 'tr_entr…
172                 print(GetWorkqueueThreadRequestSummary(proc, dereference(req)))
173 … for req in IterateSchedPriorityQueue(wq.wq_special_queue, 'struct workq_threadreq_s', 'tr_entry'):
174                 print(GetWorkqueueThreadRequestSummary(proc, dereference(req)))
179                 for req in IterateSTAILQ_HEAD(wq.wq_cooperative_queue[bucket], "tr_link"):
180                     print(GetWorkqueueThreadRequestSummary(proc, dereference(req)))