146             for kmsgp in IterateCircleQueue(port.ip_messages.imq_messages, 'ipc_kmsg', 'ikm_link'):
147                 print(prefix + GetKMsgSummary(kmsgp, prefix))
220 def GetKmsgHeader(kmsgp):  argument
228     if kmsgp.ikm_type == GetEnumValue('ipc_kmsg_type_t', 'IKM_TYPE_ALL_INLINED'):
229         return kern.GetValueFromAddress(int(addressof(kmsgp.ikm_big_data)), 'mach_msg_header_t *')
230     if kmsgp.ikm_type == GetEnumValue('ipc_kmsg_type_t', 'IKM_TYPE_UDATA_OOL'):
231         return kern.GetValueFromAddress(int(addressof(kmsgp.ikm_small_data)), 'mach_msg_header_t *')
232     return kern.GetValueFromAddress(unsigned(kmsgp.ikm_kdata), 'mach_msg_header_t *')
236 def GetKMsgSummary(kmsgp, prefix_str=""):  argument
243     kmsghp = GetKmsgHeader(kmsgp)
247             '', unsigned(kmsgp), unsigned(kmsghp), kmsgh=kmsghp)
303     if GetKmsgHeader(kmsgp).msgh_remote_port:
304         dest_proc_name = GetPortDestinationSummary(GetKmsgHeader(kmsgp).msgh_remote_port)
306     out_string += "  {:<26s} {:<26s}\n".format(GetKMsgSrc(kmsgp), dest_proc_name)
310         out_string += prefix_str + "\t" + GetKMsgComplexBodyDesc(kmsgp, prefix_str + "\t") + "\n"
323 def GetKmsgDescriptors(kmsgp):  argument
326     kmsghp = GetKmsgHeader(kmsgp)
343 def GetKmsgTotalDescSize(kmsgp):  argument
351     kmsghp = GetKmsgHeader(kmsgp)
356         (body, _, _) = GetKmsgDescriptors(kmsgp)
362 def GetKMsgComplexBodyDesc(kmsgp, prefix_str=""):  argument
365     kmsghp = GetKmsgHeader(kmsgp)
372     (body, dschead, dsc_list) = GetKmsgDescriptors(kmsgp)
391 def GetKmsgTrailer(kmsgp):  argument
398     kmsghp = GetKmsgHeader(kmsgp)
401     if (kmsgp.ikm_type == int(GetEnumValue('ipc_kmsg_type_t', 'IKM_TYPE_ALL_INLINED')) or
402         kmsgp.ikm_type == int(GetEnumValue('ipc_kmsg_type_t', 'IKM_TYPE_KDATA_OOL'))):
406             content_size = kmsgh.msgh_size - sizeof('mach_msg_base_t') - GetKmsgTotalDescSize(kmsgp)
409 …return kern.GetValueFromAddress(unsigned(kmsgp.ikm_udata) + content_size, 'mach_msg_max_trailer_t …
411 def GetKMsgSrc(kmsgp):  argument
418     trailer = GetKmsgTrailer(kmsgp)
1129 def CollectKmsgPorts(task, task_port, kmsgp):  argument
1135     kmsgh = dereference(GetKmsgHeader(kmsgp))
1149     if kmsgp.ikm_voucher_port:
1150         p_list += list(CollectPortsForAnalysis(kmsgp.ikm_voucher_port, 0))
1155         (body, dschead, dsc_list) = GetKmsgDescriptors(kmsgp)
1173 def CollectKmsgPortRefs(task, task_port, kmsgp, p_refs):  argument
1177     p_list = CollectKmsgPorts(task, task_port, kmsgp)
1192 def FindKmsgPortRefs(instr, task, task_port, kmsgp, qport):  argument
1200     p_list = CollectKmsgPorts(task, task_port, kmsgp)
1209             out_str += GetInTransitPortSummary(p, pdisp, task_port, kmsgp)
1295 …           for kmsgp in IterateCircleQueue(eport.ip_messages.imq_messages, 'ipc_kmsg', 'ikm_link'):
1297                         CollectKmsgPortRefs(t, eport, kmsgp, p_refs)
1411         for kmsgp in IterateCircleQueue(ipc_port.ip_messages.imq_messages, 'ipc_kmsg', 'ikm_link'):
1412             entry_str = FindKmsgPortRefs(entry_str, task, ipc_port, kmsgp, qport)