1 | //===-- SystemRuntimeMacOSX.cpp -------------------------------------------===// |
2 | // |
3 | // Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions. |
4 | // See https://llvm.org/LICENSE.txt for license information. |
5 | // SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception |
6 | // |
7 | //===----------------------------------------------------------------------===// |
8 | |
9 | #include "Plugins/Process/Utility/HistoryThread.h" |
10 | #include "Plugins/TypeSystem/Clang/TypeSystemClang.h" |
11 | #include "lldb/Breakpoint/StoppointCallbackContext.h" |
12 | #include "lldb/Core/Module.h" |
13 | #include "lldb/Core/ModuleSpec.h" |
14 | #include "lldb/Core/PluginManager.h" |
15 | #include "lldb/Core/Section.h" |
16 | #include "lldb/Symbol/ObjectFile.h" |
17 | #include "lldb/Symbol/SymbolContext.h" |
18 | #include "lldb/Target/Process.h" |
19 | #include "lldb/Target/ProcessStructReader.h" |
20 | #include "lldb/Target/Queue.h" |
21 | #include "lldb/Target/QueueList.h" |
22 | #include "lldb/Target/Target.h" |
23 | #include "lldb/Target/Thread.h" |
24 | #include "lldb/Utility/DataBufferHeap.h" |
25 | #include "lldb/Utility/DataExtractor.h" |
26 | #include "lldb/Utility/FileSpec.h" |
27 | #include "lldb/Utility/LLDBLog.h" |
28 | #include "lldb/Utility/Log.h" |
29 | #include "lldb/Utility/StreamString.h" |
30 | |
31 | #include "AbortWithPayloadFrameRecognizer.h" |
32 | #include "SystemRuntimeMacOSX.h" |
33 | |
34 | #include <memory> |
35 | |
36 | using namespace lldb; |
37 | using namespace lldb_private; |
38 | |
39 | LLDB_PLUGIN_DEFINE(SystemRuntimeMacOSX) |
40 | |
41 | // Create an instance of this class. This function is filled into the plugin |
42 | // info class that gets handed out by the plugin factory and allows the lldb to |
43 | // instantiate an instance of this class. |
44 | SystemRuntime *SystemRuntimeMacOSX::CreateInstance(Process *process) { |
45 | bool create = false; |
46 | if (!create) { |
47 | create = true; |
48 | Module *exe_module = process->GetTarget().GetExecutableModulePointer(); |
49 | if (exe_module) { |
50 | ObjectFile *object_file = exe_module->GetObjectFile(); |
51 | if (object_file) { |
52 | create = (object_file->GetStrata() == ObjectFile::eStrataUser); |
53 | } |
54 | } |
55 | |
56 | if (create) { |
57 | const llvm::Triple &triple_ref = |
58 | process->GetTarget().GetArchitecture().GetTriple(); |
59 | switch (triple_ref.getOS()) { |
60 | case llvm::Triple::Darwin: |
61 | case llvm::Triple::MacOSX: |
62 | case llvm::Triple::IOS: |
63 | case llvm::Triple::TvOS: |
64 | case llvm::Triple::WatchOS: |
65 | case llvm::Triple::BridgeOS: |
66 | case llvm::Triple::DriverKit: |
67 | case llvm::Triple::XROS: |
68 | create = triple_ref.getVendor() == llvm::Triple::Apple; |
69 | break; |
70 | default: |
71 | create = false; |
72 | break; |
73 | } |
74 | } |
75 | } |
76 | |
77 | if (create) |
78 | return new SystemRuntimeMacOSX(process); |
79 | return nullptr; |
80 | } |
81 | |
82 | // Constructor |
83 | SystemRuntimeMacOSX::SystemRuntimeMacOSX(Process *process) |
84 | : SystemRuntime(process), m_break_id(LLDB_INVALID_BREAK_ID), m_mutex(), |
85 | m_get_queues_handler(process), m_get_pending_items_handler(process), |
86 | m_get_item_info_handler(process), m_get_thread_item_info_handler(process), |
87 | m_page_to_free(LLDB_INVALID_ADDRESS), m_page_to_free_size(0), |
88 | m_lib_backtrace_recording_info(), |
89 | m_dispatch_queue_offsets_addr(LLDB_INVALID_ADDRESS), |
90 | m_libdispatch_offsets(), |
91 | m_libpthread_layout_offsets_addr(LLDB_INVALID_ADDRESS), |
92 | m_libpthread_offsets(), m_dispatch_tsd_indexes_addr(LLDB_INVALID_ADDRESS), |
93 | m_libdispatch_tsd_indexes(), |
94 | m_dispatch_voucher_offsets_addr(LLDB_INVALID_ADDRESS), |
95 | m_libdispatch_voucher_offsets() { |
96 | |
97 | RegisterAbortWithPayloadFrameRecognizer(process); |
98 | } |
99 | |
100 | // Destructor |
101 | SystemRuntimeMacOSX::~SystemRuntimeMacOSX() { Clear(clear_process: true); } |
102 | |
103 | void SystemRuntimeMacOSX::Detach() { |
104 | m_get_queues_handler.Detach(); |
105 | m_get_pending_items_handler.Detach(); |
106 | m_get_item_info_handler.Detach(); |
107 | m_get_thread_item_info_handler.Detach(); |
108 | } |
109 | |
110 | // Clear out the state of this class. |
111 | void SystemRuntimeMacOSX::Clear(bool clear_process) { |
112 | std::lock_guard<std::recursive_mutex> guard(m_mutex); |
113 | |
114 | if (m_process->IsAlive() && LLDB_BREAK_ID_IS_VALID(m_break_id)) |
115 | m_process->ClearBreakpointSiteByID(break_id: m_break_id); |
116 | |
117 | if (clear_process) |
118 | m_process = nullptr; |
119 | m_break_id = LLDB_INVALID_BREAK_ID; |
120 | } |
121 | |
122 | std::string |
123 | SystemRuntimeMacOSX::GetQueueNameFromThreadQAddress(addr_t dispatch_qaddr) { |
124 | std::string dispatch_queue_name; |
125 | if (dispatch_qaddr == LLDB_INVALID_ADDRESS || dispatch_qaddr == 0) |
126 | return "" ; |
127 | |
128 | ReadLibdispatchOffsets(); |
129 | if (m_libdispatch_offsets.IsValid()) { |
130 | // dispatch_qaddr is from a thread_info(THREAD_IDENTIFIER_INFO) call for a |
131 | // thread - deref it to get the address of the dispatch_queue_t structure |
132 | // for this thread's queue. |
133 | Status error; |
134 | addr_t dispatch_queue_addr = |
135 | m_process->ReadPointerFromMemory(vm_addr: dispatch_qaddr, error); |
136 | if (error.Success()) { |
137 | if (m_libdispatch_offsets.dqo_version >= 4) { |
138 | // libdispatch versions 4+, pointer to dispatch name is in the queue |
139 | // structure. |
140 | addr_t pointer_to_label_address = |
141 | dispatch_queue_addr + m_libdispatch_offsets.dqo_label; |
142 | addr_t label_addr = |
143 | m_process->ReadPointerFromMemory(vm_addr: pointer_to_label_address, error); |
144 | if (error.Success()) { |
145 | m_process->ReadCStringFromMemory(vm_addr: label_addr, out_str&: dispatch_queue_name, |
146 | error); |
147 | } |
148 | } else { |
149 | // libdispatch versions 1-3, dispatch name is a fixed width char array |
150 | // in the queue structure. |
151 | addr_t label_addr = |
152 | dispatch_queue_addr + m_libdispatch_offsets.dqo_label; |
153 | dispatch_queue_name.resize(n: m_libdispatch_offsets.dqo_label_size, c: '\0'); |
154 | size_t bytes_read = |
155 | m_process->ReadMemory(vm_addr: label_addr, buf: &dispatch_queue_name[0], |
156 | size: m_libdispatch_offsets.dqo_label_size, error); |
157 | if (bytes_read < m_libdispatch_offsets.dqo_label_size) |
158 | dispatch_queue_name.erase(pos: bytes_read); |
159 | } |
160 | } |
161 | } |
162 | return dispatch_queue_name; |
163 | } |
164 | |
165 | lldb::addr_t SystemRuntimeMacOSX::GetLibdispatchQueueAddressFromThreadQAddress( |
166 | addr_t dispatch_qaddr) { |
167 | addr_t libdispatch_queue_t_address = LLDB_INVALID_ADDRESS; |
168 | Status error; |
169 | libdispatch_queue_t_address = |
170 | m_process->ReadPointerFromMemory(vm_addr: dispatch_qaddr, error); |
171 | if (!error.Success()) { |
172 | libdispatch_queue_t_address = LLDB_INVALID_ADDRESS; |
173 | } |
174 | return libdispatch_queue_t_address; |
175 | } |
176 | |
177 | lldb::QueueKind SystemRuntimeMacOSX::GetQueueKind(addr_t dispatch_queue_addr) { |
178 | if (dispatch_queue_addr == LLDB_INVALID_ADDRESS || dispatch_queue_addr == 0) |
179 | return eQueueKindUnknown; |
180 | |
181 | QueueKind kind = eQueueKindUnknown; |
182 | ReadLibdispatchOffsets(); |
183 | if (m_libdispatch_offsets.IsValid() && |
184 | m_libdispatch_offsets.dqo_version >= 4) { |
185 | Status error; |
186 | uint64_t width = m_process->ReadUnsignedIntegerFromMemory( |
187 | load_addr: dispatch_queue_addr + m_libdispatch_offsets.dqo_width, |
188 | byte_size: m_libdispatch_offsets.dqo_width_size, fail_value: 0, error); |
189 | if (error.Success()) { |
190 | if (width == 1) { |
191 | kind = eQueueKindSerial; |
192 | } |
193 | if (width > 1) { |
194 | kind = eQueueKindConcurrent; |
195 | } |
196 | } |
197 | } |
198 | return kind; |
199 | } |
200 | |
201 | void SystemRuntimeMacOSX::AddThreadExtendedInfoPacketHints( |
202 | lldb_private::StructuredData::ObjectSP dict_sp) { |
203 | StructuredData::Dictionary *dict = dict_sp->GetAsDictionary(); |
204 | if (dict) { |
205 | ReadLibpthreadOffsets(); |
206 | if (m_libpthread_offsets.IsValid()) { |
207 | dict->AddIntegerItem(key: "plo_pthread_tsd_base_offset" , |
208 | value: m_libpthread_offsets.plo_pthread_tsd_base_offset); |
209 | dict->AddIntegerItem( |
210 | key: "plo_pthread_tsd_base_address_offset" , |
211 | value: m_libpthread_offsets.plo_pthread_tsd_base_address_offset); |
212 | dict->AddIntegerItem(key: "plo_pthread_tsd_entry_size" , |
213 | value: m_libpthread_offsets.plo_pthread_tsd_entry_size); |
214 | } |
215 | |
216 | ReadLibdispatchTSDIndexes(); |
217 | if (m_libdispatch_tsd_indexes.IsValid()) { |
218 | dict->AddIntegerItem(key: "dti_queue_index" , |
219 | value: m_libdispatch_tsd_indexes.dti_queue_index); |
220 | dict->AddIntegerItem(key: "dti_voucher_index" , |
221 | value: m_libdispatch_tsd_indexes.dti_voucher_index); |
222 | dict->AddIntegerItem(key: "dti_qos_class_index" , |
223 | value: m_libdispatch_tsd_indexes.dti_qos_class_index); |
224 | } |
225 | } |
226 | } |
227 | |
228 | bool SystemRuntimeMacOSX::SafeToCallFunctionsOnThisThread(ThreadSP thread_sp) { |
229 | if (thread_sp && thread_sp->GetFrameWithConcreteFrameIndex(unwind_idx: 0)) { |
230 | const SymbolContext sym_ctx( |
231 | thread_sp->GetFrameWithConcreteFrameIndex(unwind_idx: 0)->GetSymbolContext( |
232 | resolve_scope: eSymbolContextSymbol)); |
233 | static ConstString g_select_symbol("__select" ); |
234 | if (sym_ctx.GetFunctionName() == g_select_symbol) { |
235 | return false; |
236 | } |
237 | } |
238 | return true; |
239 | } |
240 | |
241 | lldb::queue_id_t |
242 | SystemRuntimeMacOSX::GetQueueIDFromThreadQAddress(lldb::addr_t dispatch_qaddr) { |
243 | queue_id_t queue_id = LLDB_INVALID_QUEUE_ID; |
244 | |
245 | if (dispatch_qaddr == LLDB_INVALID_ADDRESS || dispatch_qaddr == 0) |
246 | return queue_id; |
247 | |
248 | ReadLibdispatchOffsets(); |
249 | if (m_libdispatch_offsets.IsValid()) { |
250 | // dispatch_qaddr is from a thread_info(THREAD_IDENTIFIER_INFO) call for a |
251 | // thread - deref it to get the address of the dispatch_queue_t structure |
252 | // for this thread's queue. |
253 | Status error; |
254 | uint64_t dispatch_queue_addr = |
255 | m_process->ReadPointerFromMemory(vm_addr: dispatch_qaddr, error); |
256 | if (error.Success()) { |
257 | addr_t serialnum_address = |
258 | dispatch_queue_addr + m_libdispatch_offsets.dqo_serialnum; |
259 | queue_id_t serialnum = m_process->ReadUnsignedIntegerFromMemory( |
260 | load_addr: serialnum_address, byte_size: m_libdispatch_offsets.dqo_serialnum_size, |
261 | LLDB_INVALID_QUEUE_ID, error); |
262 | if (error.Success()) { |
263 | queue_id = serialnum; |
264 | } |
265 | } |
266 | } |
267 | |
268 | return queue_id; |
269 | } |
270 | |
271 | void SystemRuntimeMacOSX::ReadLibdispatchOffsetsAddress() { |
272 | if (m_dispatch_queue_offsets_addr != LLDB_INVALID_ADDRESS) |
273 | return; |
274 | |
275 | static ConstString g_dispatch_queue_offsets_symbol_name( |
276 | "dispatch_queue_offsets" ); |
277 | const Symbol *dispatch_queue_offsets_symbol = nullptr; |
278 | |
279 | // libdispatch symbols were in libSystem.B.dylib up through Mac OS X 10.6 |
280 | // ("Snow Leopard") |
281 | ModuleSpec libSystem_module_spec(FileSpec("libSystem.B.dylib" )); |
282 | ModuleSP module_sp(m_process->GetTarget().GetImages().FindFirstModule( |
283 | module_spec: libSystem_module_spec)); |
284 | if (module_sp) |
285 | dispatch_queue_offsets_symbol = module_sp->FindFirstSymbolWithNameAndType( |
286 | name: g_dispatch_queue_offsets_symbol_name, symbol_type: eSymbolTypeData); |
287 | |
288 | // libdispatch symbols are in their own dylib as of Mac OS X 10.7 ("Lion") |
289 | // and later |
290 | if (dispatch_queue_offsets_symbol == nullptr) { |
291 | ModuleSpec libdispatch_module_spec(FileSpec("libdispatch.dylib" )); |
292 | module_sp = m_process->GetTarget().GetImages().FindFirstModule( |
293 | module_spec: libdispatch_module_spec); |
294 | if (module_sp) |
295 | dispatch_queue_offsets_symbol = module_sp->FindFirstSymbolWithNameAndType( |
296 | name: g_dispatch_queue_offsets_symbol_name, symbol_type: eSymbolTypeData); |
297 | } |
298 | if (dispatch_queue_offsets_symbol) |
299 | m_dispatch_queue_offsets_addr = |
300 | dispatch_queue_offsets_symbol->GetLoadAddress(target: &m_process->GetTarget()); |
301 | } |
302 | |
303 | void SystemRuntimeMacOSX::ReadLibdispatchOffsets() { |
304 | if (m_libdispatch_offsets.IsValid()) |
305 | return; |
306 | |
307 | ReadLibdispatchOffsetsAddress(); |
308 | |
309 | uint8_t memory_buffer[sizeof(struct LibdispatchOffsets)]; |
310 | DataExtractor data(memory_buffer, sizeof(memory_buffer), |
311 | m_process->GetByteOrder(), |
312 | m_process->GetAddressByteSize()); |
313 | |
314 | Status error; |
315 | if (m_process->ReadMemory(vm_addr: m_dispatch_queue_offsets_addr, buf: memory_buffer, |
316 | size: sizeof(memory_buffer), |
317 | error) == sizeof(memory_buffer)) { |
318 | lldb::offset_t data_offset = 0; |
319 | |
320 | // The struct LibdispatchOffsets is a series of uint16_t's - extract them |
321 | // all in one big go. |
322 | data.GetU16(offset_ptr: &data_offset, dst: &m_libdispatch_offsets.dqo_version, |
323 | count: sizeof(struct LibdispatchOffsets) / sizeof(uint16_t)); |
324 | } |
325 | } |
326 | |
327 | void SystemRuntimeMacOSX::ReadLibpthreadOffsetsAddress() { |
328 | if (m_libpthread_layout_offsets_addr != LLDB_INVALID_ADDRESS) |
329 | return; |
330 | |
331 | static ConstString g_libpthread_layout_offsets_symbol_name( |
332 | "pthread_layout_offsets" ); |
333 | const Symbol *libpthread_layout_offsets_symbol = nullptr; |
334 | |
335 | ModuleSpec libpthread_module_spec(FileSpec("libsystem_pthread.dylib" )); |
336 | ModuleSP module_sp(m_process->GetTarget().GetImages().FindFirstModule( |
337 | module_spec: libpthread_module_spec)); |
338 | if (module_sp) { |
339 | libpthread_layout_offsets_symbol = |
340 | module_sp->FindFirstSymbolWithNameAndType( |
341 | name: g_libpthread_layout_offsets_symbol_name, symbol_type: eSymbolTypeData); |
342 | if (libpthread_layout_offsets_symbol) { |
343 | m_libpthread_layout_offsets_addr = |
344 | libpthread_layout_offsets_symbol->GetLoadAddress( |
345 | target: &m_process->GetTarget()); |
346 | } |
347 | } |
348 | } |
349 | |
350 | void SystemRuntimeMacOSX::ReadLibpthreadOffsets() { |
351 | if (m_libpthread_offsets.IsValid()) |
352 | return; |
353 | |
354 | ReadLibpthreadOffsetsAddress(); |
355 | |
356 | if (m_libpthread_layout_offsets_addr != LLDB_INVALID_ADDRESS) { |
357 | uint8_t memory_buffer[sizeof(struct LibpthreadOffsets)]; |
358 | DataExtractor data(memory_buffer, sizeof(memory_buffer), |
359 | m_process->GetByteOrder(), |
360 | m_process->GetAddressByteSize()); |
361 | Status error; |
362 | if (m_process->ReadMemory(vm_addr: m_libpthread_layout_offsets_addr, buf: memory_buffer, |
363 | size: sizeof(memory_buffer), |
364 | error) == sizeof(memory_buffer)) { |
365 | lldb::offset_t data_offset = 0; |
366 | |
367 | // The struct LibpthreadOffsets is a series of uint16_t's - extract them |
368 | // all in one big go. |
369 | data.GetU16(offset_ptr: &data_offset, dst: &m_libpthread_offsets.plo_version, |
370 | count: sizeof(struct LibpthreadOffsets) / sizeof(uint16_t)); |
371 | } |
372 | } |
373 | } |
374 | |
375 | void SystemRuntimeMacOSX::ReadLibdispatchTSDIndexesAddress() { |
376 | if (m_dispatch_tsd_indexes_addr != LLDB_INVALID_ADDRESS) |
377 | return; |
378 | |
379 | static ConstString g_libdispatch_tsd_indexes_symbol_name( |
380 | "dispatch_tsd_indexes" ); |
381 | const Symbol *libdispatch_tsd_indexes_symbol = nullptr; |
382 | |
383 | ModuleSpec libpthread_module_spec(FileSpec("libdispatch.dylib" )); |
384 | ModuleSP module_sp(m_process->GetTarget().GetImages().FindFirstModule( |
385 | module_spec: libpthread_module_spec)); |
386 | if (module_sp) { |
387 | libdispatch_tsd_indexes_symbol = module_sp->FindFirstSymbolWithNameAndType( |
388 | name: g_libdispatch_tsd_indexes_symbol_name, symbol_type: eSymbolTypeData); |
389 | if (libdispatch_tsd_indexes_symbol) { |
390 | m_dispatch_tsd_indexes_addr = |
391 | libdispatch_tsd_indexes_symbol->GetLoadAddress( |
392 | target: &m_process->GetTarget()); |
393 | } |
394 | } |
395 | } |
396 | |
397 | void SystemRuntimeMacOSX::ReadLibdispatchTSDIndexes() { |
398 | if (m_libdispatch_tsd_indexes.IsValid()) |
399 | return; |
400 | |
401 | ReadLibdispatchTSDIndexesAddress(); |
402 | |
403 | if (m_dispatch_tsd_indexes_addr != LLDB_INVALID_ADDRESS) { |
404 | |
405 | // We don't need to check the version number right now, it will be at least 2, |
406 | // but keep this code around to fetch just the version # for the future where |
407 | // we need to fetch alternate versions of the struct. |
408 | #if 0 |
409 | uint16_t dti_version = 2; |
410 | Address dti_struct_addr; |
411 | if (m_process->GetTarget().ResolveLoadAddress (m_dispatch_tsd_indexes_addr, dti_struct_addr)) |
412 | { |
413 | Status error; |
414 | uint16_t version = m_process->GetTarget().ReadUnsignedIntegerFromMemory (dti_struct_addr, false, 2, UINT16_MAX, error); |
415 | if (error.Success() && dti_version != UINT16_MAX) |
416 | { |
417 | dti_version = version; |
418 | } |
419 | } |
420 | #endif |
421 | |
422 | TypeSystemClangSP scratch_ts_sp = |
423 | ScratchTypeSystemClang::GetForTarget(target&: m_process->GetTarget()); |
424 | if (m_dispatch_tsd_indexes_addr != LLDB_INVALID_ADDRESS) { |
425 | CompilerType uint16 = |
426 | scratch_ts_sp->GetBuiltinTypeForEncodingAndBitSize(encoding: eEncodingUint, bit_size: 16); |
427 | CompilerType dispatch_tsd_indexes_s = scratch_ts_sp->CreateRecordType( |
428 | decl_ctx: nullptr, owning_module: OptionalClangModuleID(), access_type: lldb::eAccessPublic, |
429 | name: "__lldb_dispatch_tsd_indexes_s" , |
430 | kind: llvm::to_underlying(E: clang::TagTypeKind::Struct), |
431 | language: lldb::eLanguageTypeC); |
432 | |
433 | TypeSystemClang::StartTagDeclarationDefinition(type: dispatch_tsd_indexes_s); |
434 | TypeSystemClang::AddFieldToRecordType(type: dispatch_tsd_indexes_s, |
435 | name: "dti_version" , field_type: uint16, |
436 | access: lldb::eAccessPublic, bitfield_bit_size: 0); |
437 | TypeSystemClang::AddFieldToRecordType(type: dispatch_tsd_indexes_s, |
438 | name: "dti_queue_index" , field_type: uint16, |
439 | access: lldb::eAccessPublic, bitfield_bit_size: 0); |
440 | TypeSystemClang::AddFieldToRecordType(type: dispatch_tsd_indexes_s, |
441 | name: "dti_voucher_index" , field_type: uint16, |
442 | access: lldb::eAccessPublic, bitfield_bit_size: 0); |
443 | TypeSystemClang::AddFieldToRecordType(type: dispatch_tsd_indexes_s, |
444 | name: "dti_qos_class_index" , field_type: uint16, |
445 | access: lldb::eAccessPublic, bitfield_bit_size: 0); |
446 | TypeSystemClang::CompleteTagDeclarationDefinition(type: dispatch_tsd_indexes_s); |
447 | |
448 | ProcessStructReader struct_reader(m_process, m_dispatch_tsd_indexes_addr, |
449 | dispatch_tsd_indexes_s); |
450 | |
451 | m_libdispatch_tsd_indexes.dti_version = |
452 | struct_reader.GetField<uint16_t>(name: "dti_version" ); |
453 | m_libdispatch_tsd_indexes.dti_queue_index = |
454 | struct_reader.GetField<uint16_t>(name: "dti_queue_index" ); |
455 | m_libdispatch_tsd_indexes.dti_voucher_index = |
456 | struct_reader.GetField<uint16_t>(name: "dti_voucher_index" ); |
457 | m_libdispatch_tsd_indexes.dti_qos_class_index = |
458 | struct_reader.GetField<uint16_t>(name: "dti_qos_class_index" ); |
459 | } |
460 | } |
461 | } |
462 | |
463 | ThreadSP SystemRuntimeMacOSX::GetExtendedBacktraceThread(ThreadSP real_thread, |
464 | ConstString type) { |
465 | ThreadSP originating_thread_sp; |
466 | if (BacktraceRecordingHeadersInitialized() && type == "libdispatch" ) { |
467 | Status error; |
468 | |
469 | // real_thread is either an actual, live thread (in which case we need to |
470 | // call into libBacktraceRecording to find its originator) or it is an |
471 | // extended backtrace itself, in which case we get the token from it and |
472 | // call into libBacktraceRecording to find the originator of that token. |
473 | |
474 | if (real_thread->GetExtendedBacktraceToken() != LLDB_INVALID_ADDRESS) { |
475 | originating_thread_sp = GetExtendedBacktraceFromItemRef( |
476 | item_ref: real_thread->GetExtendedBacktraceToken()); |
477 | } else { |
478 | ThreadSP cur_thread_sp( |
479 | m_process->GetThreadList().GetExpressionExecutionThread()); |
480 | AppleGetThreadItemInfoHandler::GetThreadItemInfoReturnInfo ret = |
481 | m_get_thread_item_info_handler.GetThreadItemInfo( |
482 | thread&: *cur_thread_sp.get(), thread_id: real_thread->GetID(), page_to_free: m_page_to_free, |
483 | page_to_free_size: m_page_to_free_size, error); |
484 | m_page_to_free = LLDB_INVALID_ADDRESS; |
485 | m_page_to_free_size = 0; |
486 | if (ret.item_buffer_ptr != 0 && |
487 | ret.item_buffer_ptr != LLDB_INVALID_ADDRESS && |
488 | ret.item_buffer_size > 0) { |
489 | DataBufferHeap data(ret.item_buffer_size, 0); |
490 | if (m_process->ReadMemory(vm_addr: ret.item_buffer_ptr, buf: data.GetBytes(), |
491 | size: ret.item_buffer_size, error) && |
492 | error.Success()) { |
493 | DataExtractor (data.GetBytes(), data.GetByteSize(), |
494 | m_process->GetByteOrder(), |
495 | m_process->GetAddressByteSize()); |
496 | ItemInfo item = ExtractItemInfoFromBuffer(extractor); |
497 | originating_thread_sp = std::make_shared<HistoryThread>( |
498 | args&: *m_process, args&: item.enqueuing_thread_id, args&: item.enqueuing_callstack); |
499 | originating_thread_sp->SetExtendedBacktraceToken( |
500 | item.item_that_enqueued_this); |
501 | originating_thread_sp->SetQueueName( |
502 | item.enqueuing_queue_label.c_str()); |
503 | originating_thread_sp->SetQueueID(item.enqueuing_queue_serialnum); |
504 | // originating_thread_sp->SetThreadName |
505 | // (item.enqueuing_thread_label.c_str()); |
506 | } |
507 | m_page_to_free = ret.item_buffer_ptr; |
508 | m_page_to_free_size = ret.item_buffer_size; |
509 | } |
510 | } |
511 | } else if (type == "Application Specific Backtrace" ) { |
512 | StructuredData::ObjectSP thread_extended_sp = |
513 | real_thread->GetExtendedInfo(); |
514 | |
515 | if (!thread_extended_sp) |
516 | return {}; |
517 | |
518 | StructuredData::Array *thread_extended_info = |
519 | thread_extended_sp->GetAsArray(); |
520 | |
521 | if (!thread_extended_info || !thread_extended_info->GetSize()) |
522 | return {}; |
523 | |
524 | std::vector<addr_t> app_specific_backtrace_pcs; |
525 | |
526 | auto = |
527 | [&app_specific_backtrace_pcs](StructuredData::Object *obj) -> bool { |
528 | if (!obj) |
529 | return false; |
530 | |
531 | StructuredData::Dictionary *dict = obj->GetAsDictionary(); |
532 | if (!dict) |
533 | return false; |
534 | |
535 | lldb::addr_t pc = LLDB_INVALID_ADDRESS; |
536 | if (!dict->GetValueForKeyAsInteger(key: "pc" , result&: pc)) |
537 | return false; |
538 | |
539 | app_specific_backtrace_pcs.push_back(x: pc); |
540 | |
541 | return pc != LLDB_INVALID_ADDRESS; |
542 | }; |
543 | |
544 | if (!thread_extended_info->ForEach(foreach_callback: extract_frame_pc)) |
545 | return {}; |
546 | |
547 | originating_thread_sp = |
548 | std::make_shared<HistoryThread>(args&: *m_process, args: real_thread->GetIndexID(), |
549 | args&: app_specific_backtrace_pcs, args: true); |
550 | originating_thread_sp->SetQueueName(type.AsCString()); |
551 | } |
552 | return originating_thread_sp; |
553 | } |
554 | |
555 | ThreadSP |
556 | SystemRuntimeMacOSX::GetExtendedBacktraceFromItemRef(lldb::addr_t item_ref) { |
557 | ThreadSP return_thread_sp; |
558 | |
559 | AppleGetItemInfoHandler::GetItemInfoReturnInfo ret; |
560 | ThreadSP cur_thread_sp( |
561 | m_process->GetThreadList().GetExpressionExecutionThread()); |
562 | Status error; |
563 | ret = m_get_item_info_handler.GetItemInfo(thread&: *cur_thread_sp.get(), item: item_ref, |
564 | page_to_free: m_page_to_free, page_to_free_size: m_page_to_free_size, |
565 | error); |
566 | m_page_to_free = LLDB_INVALID_ADDRESS; |
567 | m_page_to_free_size = 0; |
568 | if (ret.item_buffer_ptr != 0 && ret.item_buffer_ptr != LLDB_INVALID_ADDRESS && |
569 | ret.item_buffer_size > 0) { |
570 | DataBufferHeap data(ret.item_buffer_size, 0); |
571 | if (m_process->ReadMemory(vm_addr: ret.item_buffer_ptr, buf: data.GetBytes(), |
572 | size: ret.item_buffer_size, error) && |
573 | error.Success()) { |
574 | DataExtractor (data.GetBytes(), data.GetByteSize(), |
575 | m_process->GetByteOrder(), |
576 | m_process->GetAddressByteSize()); |
577 | ItemInfo item = ExtractItemInfoFromBuffer(extractor); |
578 | return_thread_sp = std::make_shared<HistoryThread>( |
579 | args&: *m_process, args&: item.enqueuing_thread_id, args&: item.enqueuing_callstack); |
580 | return_thread_sp->SetExtendedBacktraceToken(item.item_that_enqueued_this); |
581 | return_thread_sp->SetQueueName(item.enqueuing_queue_label.c_str()); |
582 | return_thread_sp->SetQueueID(item.enqueuing_queue_serialnum); |
583 | // return_thread_sp->SetThreadName |
584 | // (item.enqueuing_thread_label.c_str()); |
585 | |
586 | m_page_to_free = ret.item_buffer_ptr; |
587 | m_page_to_free_size = ret.item_buffer_size; |
588 | } |
589 | } |
590 | return return_thread_sp; |
591 | } |
592 | |
593 | ThreadSP |
594 | SystemRuntimeMacOSX::GetExtendedBacktraceForQueueItem(QueueItemSP queue_item_sp, |
595 | ConstString type) { |
596 | ThreadSP extended_thread_sp; |
597 | if (type != "libdispatch" ) |
598 | return extended_thread_sp; |
599 | |
600 | extended_thread_sp = std::make_shared<HistoryThread>( |
601 | args&: *m_process, args: queue_item_sp->GetEnqueueingThreadID(), |
602 | args&: queue_item_sp->GetEnqueueingBacktrace()); |
603 | extended_thread_sp->SetExtendedBacktraceToken( |
604 | queue_item_sp->GetItemThatEnqueuedThis()); |
605 | extended_thread_sp->SetQueueName(queue_item_sp->GetQueueLabel().c_str()); |
606 | extended_thread_sp->SetQueueID(queue_item_sp->GetEnqueueingQueueID()); |
607 | // extended_thread_sp->SetThreadName |
608 | // (queue_item_sp->GetThreadLabel().c_str()); |
609 | |
610 | return extended_thread_sp; |
611 | } |
612 | |
613 | /* Returns true if we were able to get the version / offset information |
614 | * out of libBacktraceRecording. false means we were unable to retrieve |
615 | * this; the queue_info_version field will be 0. |
616 | */ |
617 | |
618 | bool SystemRuntimeMacOSX::() { |
619 | if (m_lib_backtrace_recording_info.queue_info_version != 0) |
620 | return true; |
621 | |
622 | addr_t queue_info_version_address = LLDB_INVALID_ADDRESS; |
623 | addr_t queue_info_data_offset_address = LLDB_INVALID_ADDRESS; |
624 | addr_t item_info_version_address = LLDB_INVALID_ADDRESS; |
625 | addr_t item_info_data_offset_address = LLDB_INVALID_ADDRESS; |
626 | Target &target = m_process->GetTarget(); |
627 | |
628 | static ConstString introspection_dispatch_queue_info_version( |
629 | "__introspection_dispatch_queue_info_version" ); |
630 | SymbolContextList sc_list; |
631 | m_process->GetTarget().GetImages().FindSymbolsWithNameAndType( |
632 | name: introspection_dispatch_queue_info_version, symbol_type: eSymbolTypeData, sc_list); |
633 | if (!sc_list.IsEmpty()) { |
634 | SymbolContext sc; |
635 | sc_list.GetContextAtIndex(idx: 0, sc); |
636 | Address addr = sc.GetFunctionOrSymbolAddress(); |
637 | queue_info_version_address = addr.GetLoadAddress(target: &target); |
638 | } |
639 | sc_list.Clear(); |
640 | |
641 | static ConstString introspection_dispatch_queue_info_data_offset( |
642 | "__introspection_dispatch_queue_info_data_offset" ); |
643 | m_process->GetTarget().GetImages().FindSymbolsWithNameAndType( |
644 | name: introspection_dispatch_queue_info_data_offset, symbol_type: eSymbolTypeData, sc_list); |
645 | if (!sc_list.IsEmpty()) { |
646 | SymbolContext sc; |
647 | sc_list.GetContextAtIndex(idx: 0, sc); |
648 | Address addr = sc.GetFunctionOrSymbolAddress(); |
649 | queue_info_data_offset_address = addr.GetLoadAddress(target: &target); |
650 | } |
651 | sc_list.Clear(); |
652 | |
653 | static ConstString introspection_dispatch_item_info_version( |
654 | "__introspection_dispatch_item_info_version" ); |
655 | m_process->GetTarget().GetImages().FindSymbolsWithNameAndType( |
656 | name: introspection_dispatch_item_info_version, symbol_type: eSymbolTypeData, sc_list); |
657 | if (!sc_list.IsEmpty()) { |
658 | SymbolContext sc; |
659 | sc_list.GetContextAtIndex(idx: 0, sc); |
660 | Address addr = sc.GetFunctionOrSymbolAddress(); |
661 | item_info_version_address = addr.GetLoadAddress(target: &target); |
662 | } |
663 | sc_list.Clear(); |
664 | |
665 | static ConstString introspection_dispatch_item_info_data_offset( |
666 | "__introspection_dispatch_item_info_data_offset" ); |
667 | m_process->GetTarget().GetImages().FindSymbolsWithNameAndType( |
668 | name: introspection_dispatch_item_info_data_offset, symbol_type: eSymbolTypeData, sc_list); |
669 | if (!sc_list.IsEmpty()) { |
670 | SymbolContext sc; |
671 | sc_list.GetContextAtIndex(idx: 0, sc); |
672 | Address addr = sc.GetFunctionOrSymbolAddress(); |
673 | item_info_data_offset_address = addr.GetLoadAddress(target: &target); |
674 | } |
675 | |
676 | if (queue_info_version_address != LLDB_INVALID_ADDRESS && |
677 | queue_info_data_offset_address != LLDB_INVALID_ADDRESS && |
678 | item_info_version_address != LLDB_INVALID_ADDRESS && |
679 | item_info_data_offset_address != LLDB_INVALID_ADDRESS) { |
680 | Status error; |
681 | m_lib_backtrace_recording_info.queue_info_version = |
682 | m_process->ReadUnsignedIntegerFromMemory(load_addr: queue_info_version_address, byte_size: 2, |
683 | fail_value: 0, error); |
684 | if (error.Success()) { |
685 | m_lib_backtrace_recording_info.queue_info_data_offset = |
686 | m_process->ReadUnsignedIntegerFromMemory( |
687 | load_addr: queue_info_data_offset_address, byte_size: 2, fail_value: 0, error); |
688 | if (error.Success()) { |
689 | m_lib_backtrace_recording_info.item_info_version = |
690 | m_process->ReadUnsignedIntegerFromMemory(load_addr: item_info_version_address, |
691 | byte_size: 2, fail_value: 0, error); |
692 | if (error.Success()) { |
693 | m_lib_backtrace_recording_info.item_info_data_offset = |
694 | m_process->ReadUnsignedIntegerFromMemory( |
695 | load_addr: item_info_data_offset_address, byte_size: 2, fail_value: 0, error); |
696 | if (!error.Success()) { |
697 | m_lib_backtrace_recording_info.queue_info_version = 0; |
698 | } |
699 | } else { |
700 | m_lib_backtrace_recording_info.queue_info_version = 0; |
701 | } |
702 | } else { |
703 | m_lib_backtrace_recording_info.queue_info_version = 0; |
704 | } |
705 | } |
706 | } |
707 | |
708 | return m_lib_backtrace_recording_info.queue_info_version != 0; |
709 | } |
710 | |
711 | const std::vector<ConstString> & |
712 | SystemRuntimeMacOSX::GetExtendedBacktraceTypes() { |
713 | if (m_types.size() == 0) { |
714 | m_types.push_back(x: ConstString("libdispatch" )); |
715 | m_types.push_back(x: ConstString("Application Specific Backtrace" )); |
716 | // We could have pthread as another type in the future if we have a way of |
717 | // gathering that information & it's useful to distinguish between them. |
718 | } |
719 | return m_types; |
720 | } |
721 | |
722 | void SystemRuntimeMacOSX::PopulateQueueList( |
723 | lldb_private::QueueList &queue_list) { |
724 | if (BacktraceRecordingHeadersInitialized()) { |
725 | AppleGetQueuesHandler::GetQueuesReturnInfo queue_info_pointer; |
726 | ThreadSP cur_thread_sp( |
727 | m_process->GetThreadList().GetExpressionExecutionThread()); |
728 | if (cur_thread_sp) { |
729 | Status error; |
730 | queue_info_pointer = m_get_queues_handler.GetCurrentQueues( |
731 | thread&: *cur_thread_sp.get(), page_to_free: m_page_to_free, page_to_free_size: m_page_to_free_size, error); |
732 | m_page_to_free = LLDB_INVALID_ADDRESS; |
733 | m_page_to_free_size = 0; |
734 | if (error.Success()) { |
735 | |
736 | if (queue_info_pointer.count > 0 && |
737 | queue_info_pointer.queues_buffer_size > 0 && |
738 | queue_info_pointer.queues_buffer_ptr != 0 && |
739 | queue_info_pointer.queues_buffer_ptr != LLDB_INVALID_ADDRESS) { |
740 | PopulateQueuesUsingLibBTR(queues_buffer: queue_info_pointer.queues_buffer_ptr, |
741 | queues_buffer_size: queue_info_pointer.queues_buffer_size, |
742 | count: queue_info_pointer.count, queue_list); |
743 | } |
744 | } |
745 | } |
746 | } |
747 | |
748 | // We either didn't have libBacktraceRecording (and need to create the queues |
749 | // list based on threads) or we did get the queues list from |
750 | // libBacktraceRecording but some special queues may not be included in its |
751 | // information. This is needed because libBacktraceRecording will only list |
752 | // queues with pending or running items by default - but the magic com.apple |
753 | // .main-thread queue on thread 1 is always around. |
754 | |
755 | for (ThreadSP thread_sp : m_process->Threads()) { |
756 | if (thread_sp->GetAssociatedWithLibdispatchQueue() != eLazyBoolNo) { |
757 | if (thread_sp->GetQueueID() != LLDB_INVALID_QUEUE_ID) { |
758 | if (queue_list.FindQueueByID(qid: thread_sp->GetQueueID()).get() == |
759 | nullptr) { |
760 | QueueSP queue_sp(new Queue(m_process->shared_from_this(), |
761 | thread_sp->GetQueueID(), |
762 | thread_sp->GetQueueName())); |
763 | if (thread_sp->ThreadHasQueueInformation()) { |
764 | queue_sp->SetKind(thread_sp->GetQueueKind()); |
765 | queue_sp->SetLibdispatchQueueAddress( |
766 | thread_sp->GetQueueLibdispatchQueueAddress()); |
767 | queue_list.AddQueue(queue: queue_sp); |
768 | } else { |
769 | queue_sp->SetKind( |
770 | GetQueueKind(dispatch_queue_addr: thread_sp->GetQueueLibdispatchQueueAddress())); |
771 | queue_sp->SetLibdispatchQueueAddress( |
772 | thread_sp->GetQueueLibdispatchQueueAddress()); |
773 | queue_list.AddQueue(queue: queue_sp); |
774 | } |
775 | } |
776 | } |
777 | } |
778 | } |
779 | } |
780 | |
781 | // Returns either an array of introspection_dispatch_item_info_ref's for the |
782 | // pending items on a queue or an array introspection_dispatch_item_info_ref's |
783 | // and code addresses for the pending items on a queue. The information about |
784 | // each of these pending items then needs to be fetched individually by passing |
785 | // the ref to libBacktraceRecording. |
786 | |
787 | SystemRuntimeMacOSX::PendingItemsForQueue |
788 | SystemRuntimeMacOSX::GetPendingItemRefsForQueue(lldb::addr_t queue) { |
789 | PendingItemsForQueue pending_item_refs = {}; |
790 | AppleGetPendingItemsHandler::GetPendingItemsReturnInfo pending_items_pointer; |
791 | ThreadSP cur_thread_sp( |
792 | m_process->GetThreadList().GetExpressionExecutionThread()); |
793 | if (cur_thread_sp) { |
794 | Status error; |
795 | pending_items_pointer = m_get_pending_items_handler.GetPendingItems( |
796 | thread&: *cur_thread_sp.get(), queue, page_to_free: m_page_to_free, page_to_free_size: m_page_to_free_size, |
797 | error); |
798 | m_page_to_free = LLDB_INVALID_ADDRESS; |
799 | m_page_to_free_size = 0; |
800 | if (error.Success()) { |
801 | if (pending_items_pointer.count > 0 && |
802 | pending_items_pointer.items_buffer_size > 0 && |
803 | pending_items_pointer.items_buffer_ptr != 0 && |
804 | pending_items_pointer.items_buffer_ptr != LLDB_INVALID_ADDRESS) { |
805 | DataBufferHeap data(pending_items_pointer.items_buffer_size, 0); |
806 | if (m_process->ReadMemory( |
807 | vm_addr: pending_items_pointer.items_buffer_ptr, buf: data.GetBytes(), |
808 | size: pending_items_pointer.items_buffer_size, error)) { |
809 | DataExtractor (data.GetBytes(), data.GetByteSize(), |
810 | m_process->GetByteOrder(), |
811 | m_process->GetAddressByteSize()); |
812 | |
813 | // We either have an array of |
814 | // void* item_ref |
815 | // (old style) or we have a structure returned which looks like |
816 | // |
817 | // struct introspection_dispatch_pending_item_info_s { |
818 | // void *item_ref; |
819 | // void *function_or_block; |
820 | // }; |
821 | // |
822 | // struct introspection_dispatch_pending_items_array_s { |
823 | // uint32_t version; |
824 | // uint32_t size_of_item_info; |
825 | // introspection_dispatch_pending_item_info_s items[]; |
826 | // } |
827 | |
828 | offset_t offset = 0; |
829 | uint64_t i = 0; |
830 | uint32_t version = extractor.GetU32(offset_ptr: &offset); |
831 | if (version == 1) { |
832 | pending_item_refs.new_style = true; |
833 | uint32_t item_size = extractor.GetU32(offset_ptr: &offset); |
834 | uint32_t start_of_array_offset = offset; |
835 | while (offset < pending_items_pointer.items_buffer_size && |
836 | i < pending_items_pointer.count) { |
837 | offset = start_of_array_offset + (i * item_size); |
838 | ItemRefAndCodeAddress item; |
839 | item.item_ref = extractor.GetAddress(offset_ptr: &offset); |
840 | item.code_address = extractor.GetAddress(offset_ptr: &offset); |
841 | pending_item_refs.item_refs_and_code_addresses.push_back(x: item); |
842 | i++; |
843 | } |
844 | } else { |
845 | offset = 0; |
846 | pending_item_refs.new_style = false; |
847 | while (offset < pending_items_pointer.items_buffer_size && |
848 | i < pending_items_pointer.count) { |
849 | ItemRefAndCodeAddress item; |
850 | item.item_ref = extractor.GetAddress(offset_ptr: &offset); |
851 | item.code_address = LLDB_INVALID_ADDRESS; |
852 | pending_item_refs.item_refs_and_code_addresses.push_back(x: item); |
853 | i++; |
854 | } |
855 | } |
856 | } |
857 | m_page_to_free = pending_items_pointer.items_buffer_ptr; |
858 | m_page_to_free_size = pending_items_pointer.items_buffer_size; |
859 | } |
860 | } |
861 | } |
862 | return pending_item_refs; |
863 | } |
864 | |
865 | void SystemRuntimeMacOSX::PopulatePendingItemsForQueue(Queue *queue) { |
866 | if (BacktraceRecordingHeadersInitialized()) { |
867 | PendingItemsForQueue pending_item_refs = |
868 | GetPendingItemRefsForQueue(queue: queue->GetLibdispatchQueueAddress()); |
869 | for (ItemRefAndCodeAddress pending_item : |
870 | pending_item_refs.item_refs_and_code_addresses) { |
871 | Address addr; |
872 | m_process->GetTarget().ResolveLoadAddress(load_addr: pending_item.code_address, |
873 | so_addr&: addr); |
874 | QueueItemSP queue_item_sp(new QueueItem(queue->shared_from_this(), |
875 | m_process->shared_from_this(), |
876 | pending_item.item_ref, addr)); |
877 | queue->PushPendingQueueItem(item: queue_item_sp); |
878 | } |
879 | } |
880 | } |
881 | |
882 | void SystemRuntimeMacOSX::CompleteQueueItem(QueueItem *queue_item, |
883 | addr_t item_ref) { |
884 | AppleGetItemInfoHandler::GetItemInfoReturnInfo ret; |
885 | |
886 | ThreadSP cur_thread_sp( |
887 | m_process->GetThreadList().GetExpressionExecutionThread()); |
888 | Status error; |
889 | ret = m_get_item_info_handler.GetItemInfo(thread&: *cur_thread_sp.get(), item: item_ref, |
890 | page_to_free: m_page_to_free, page_to_free_size: m_page_to_free_size, |
891 | error); |
892 | m_page_to_free = LLDB_INVALID_ADDRESS; |
893 | m_page_to_free_size = 0; |
894 | if (ret.item_buffer_ptr != 0 && ret.item_buffer_ptr != LLDB_INVALID_ADDRESS && |
895 | ret.item_buffer_size > 0) { |
896 | DataBufferHeap data(ret.item_buffer_size, 0); |
897 | if (m_process->ReadMemory(vm_addr: ret.item_buffer_ptr, buf: data.GetBytes(), |
898 | size: ret.item_buffer_size, error) && |
899 | error.Success()) { |
900 | DataExtractor (data.GetBytes(), data.GetByteSize(), |
901 | m_process->GetByteOrder(), |
902 | m_process->GetAddressByteSize()); |
903 | ItemInfo item = ExtractItemInfoFromBuffer(extractor); |
904 | queue_item->SetItemThatEnqueuedThis(item.item_that_enqueued_this); |
905 | queue_item->SetEnqueueingThreadID(item.enqueuing_thread_id); |
906 | queue_item->SetEnqueueingQueueID(item.enqueuing_queue_serialnum); |
907 | queue_item->SetStopID(item.stop_id); |
908 | queue_item->SetEnqueueingBacktrace(item.enqueuing_callstack); |
909 | queue_item->SetThreadLabel(item.enqueuing_thread_label); |
910 | queue_item->SetQueueLabel(item.enqueuing_queue_label); |
911 | queue_item->SetTargetQueueLabel(item.target_queue_label); |
912 | } |
913 | m_page_to_free = ret.item_buffer_ptr; |
914 | m_page_to_free_size = ret.item_buffer_size; |
915 | } |
916 | } |
917 | |
918 | void SystemRuntimeMacOSX::PopulateQueuesUsingLibBTR( |
919 | lldb::addr_t queues_buffer, uint64_t queues_buffer_size, uint64_t count, |
920 | lldb_private::QueueList &queue_list) { |
921 | Status error; |
922 | DataBufferHeap data(queues_buffer_size, 0); |
923 | Log *log = GetLog(mask: LLDBLog::SystemRuntime); |
924 | if (m_process->ReadMemory(vm_addr: queues_buffer, buf: data.GetBytes(), size: queues_buffer_size, |
925 | error) == queues_buffer_size && |
926 | error.Success()) { |
927 | // We've read the information out of inferior memory; free it on the next |
928 | // call we make |
929 | m_page_to_free = queues_buffer; |
930 | m_page_to_free_size = queues_buffer_size; |
931 | |
932 | DataExtractor (data.GetBytes(), data.GetByteSize(), |
933 | m_process->GetByteOrder(), |
934 | m_process->GetAddressByteSize()); |
935 | offset_t offset = 0; |
936 | uint64_t queues_read = 0; |
937 | |
938 | // The information about the queues is stored in this format (v1): typedef |
939 | // struct introspection_dispatch_queue_info_s { |
940 | // uint32_t offset_to_next; |
941 | // dispatch_queue_t queue; |
942 | // uint64_t serialnum; // queue's serialnum in the process, as |
943 | // provided by libdispatch |
944 | // uint32_t running_work_items_count; |
945 | // uint32_t pending_work_items_count; |
946 | // |
947 | // char data[]; // Starting here, we have variable-length data: |
948 | // // char queue_label[]; |
949 | // } introspection_dispatch_queue_info_s; |
950 | |
951 | while (queues_read < count && offset < queues_buffer_size) { |
952 | offset_t start_of_this_item = offset; |
953 | |
954 | uint32_t offset_to_next = extractor.GetU32(offset_ptr: &offset); |
955 | |
956 | offset += 4; // Skip over the 4 bytes of reserved space |
957 | addr_t queue = extractor.GetAddress(offset_ptr: &offset); |
958 | uint64_t serialnum = extractor.GetU64(offset_ptr: &offset); |
959 | uint32_t running_work_items_count = extractor.GetU32(offset_ptr: &offset); |
960 | uint32_t pending_work_items_count = extractor.GetU32(offset_ptr: &offset); |
961 | |
962 | // Read the first field of the variable length data |
963 | offset = start_of_this_item + |
964 | m_lib_backtrace_recording_info.queue_info_data_offset; |
965 | const char *queue_label = extractor.GetCStr(offset_ptr: &offset); |
966 | if (queue_label == nullptr) |
967 | queue_label = "" ; |
968 | |
969 | offset_t start_of_next_item = start_of_this_item + offset_to_next; |
970 | offset = start_of_next_item; |
971 | |
972 | LLDB_LOGF(log, |
973 | "SystemRuntimeMacOSX::PopulateQueuesUsingLibBTR added " |
974 | "queue with dispatch_queue_t 0x%" PRIx64 |
975 | ", serial number 0x%" PRIx64 |
976 | ", running items %d, pending items %d, name '%s'" , |
977 | queue, serialnum, running_work_items_count, |
978 | pending_work_items_count, queue_label); |
979 | |
980 | QueueSP queue_sp( |
981 | new Queue(m_process->shared_from_this(), serialnum, queue_label)); |
982 | queue_sp->SetNumRunningWorkItems(running_work_items_count); |
983 | queue_sp->SetNumPendingWorkItems(pending_work_items_count); |
984 | queue_sp->SetLibdispatchQueueAddress(queue); |
985 | queue_sp->SetKind(GetQueueKind(dispatch_queue_addr: queue)); |
986 | queue_list.AddQueue(queue: queue_sp); |
987 | queues_read++; |
988 | } |
989 | } |
990 | } |
991 | |
992 | SystemRuntimeMacOSX::ItemInfo SystemRuntimeMacOSX::( |
993 | lldb_private::DataExtractor &) { |
994 | ItemInfo item; |
995 | |
996 | offset_t offset = 0; |
997 | |
998 | item.item_that_enqueued_this = extractor.GetAddress(offset_ptr: &offset); |
999 | item.function_or_block = extractor.GetAddress(offset_ptr: &offset); |
1000 | item.enqueuing_thread_id = extractor.GetU64(offset_ptr: &offset); |
1001 | item.enqueuing_queue_serialnum = extractor.GetU64(offset_ptr: &offset); |
1002 | item.target_queue_serialnum = extractor.GetU64(offset_ptr: &offset); |
1003 | item.enqueuing_callstack_frame_count = extractor.GetU32(offset_ptr: &offset); |
1004 | item.stop_id = extractor.GetU32(offset_ptr: &offset); |
1005 | |
1006 | offset = m_lib_backtrace_recording_info.item_info_data_offset; |
1007 | |
1008 | for (uint32_t i = 0; i < item.enqueuing_callstack_frame_count; i++) { |
1009 | item.enqueuing_callstack.push_back(x: extractor.GetAddress(offset_ptr: &offset)); |
1010 | } |
1011 | item.enqueuing_thread_label = extractor.GetCStr(offset_ptr: &offset); |
1012 | item.enqueuing_queue_label = extractor.GetCStr(offset_ptr: &offset); |
1013 | item.target_queue_label = extractor.GetCStr(offset_ptr: &offset); |
1014 | |
1015 | return item; |
1016 | } |
1017 | |
1018 | void SystemRuntimeMacOSX::Initialize() { |
1019 | PluginManager::RegisterPlugin( |
1020 | name: GetPluginNameStatic(), |
1021 | description: "System runtime plugin for Mac OS X native libraries." , create_callback: CreateInstance); |
1022 | } |
1023 | |
1024 | void SystemRuntimeMacOSX::Terminate() { |
1025 | PluginManager::UnregisterPlugin(create_callback: CreateInstance); |
1026 | } |
1027 | |