2 * Copyright (c) 2004 Marcel Moolenaar
3 * Copyright (c) 2005 David Xu
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
10 * 1. Redistributions of source code must retain the above copyright
11 * notice, this list of conditions and the following disclaimer.
12 * 2. Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
16 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
20 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
21 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
22 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
23 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
25 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27 * $DragonFly: src/lib/libthread_db/libthread_xu.c,v 1.3 2005/05/07 10:08:08 davidxu Exp $
30 #include <sys/cdefs.h>
32 #include <proc_service.h>
36 #include <machine/tls.h>
37 #include <sys/types.h>
38 #include <sys/ptrace.h>
40 #include <thread_db.h>
43 #include "thread_db_int.h"
49 psaddr_t libthread_xu_debug_addr
;
50 psaddr_t thread_active_threads_addr
;
51 psaddr_t thread_bp_create_addr
;
52 psaddr_t thread_bp_death_addr
;
53 psaddr_t thread_event_mask_addr
;
54 psaddr_t thread_keytable_addr
;
55 psaddr_t thread_last_event_addr
;
56 psaddr_t thread_list_addr
;
58 int thread_off_attr_flags
;
60 int thread_off_event_buf
;
61 int thread_off_event_mask
;
62 int thread_off_key_allocated
;
63 int thread_off_key_destructor
;
64 int thread_off_linkmap
;
66 int thread_off_report_events
;
70 int thread_off_tlsindex
;
72 int thread_state_running
;
73 int thread_state_zoombie
;
76 #define P2T(c) ps2td(c)
78 static int pt_validate(const td_thrhandle_t
*th
);
95 return TD_NOLIBTHREAD
;
110 pt_ta_new(struct ps_prochandle
*ph
, td_thragent_t
**pta
)
112 #define LOOKUP_SYM(proc, sym, addr) \
113 ret = ps_pglobal_lookup(proc, NULL, sym, addr); \
115 TDBG("can not find symbol: %s\n", sym); \
116 ret = TD_NOLIBTHREAD; \
120 #define LOOKUP_VAL(proc, sym, val) \
121 ret = ps_pglobal_lookup(proc, NULL, sym, &vaddr);\
123 TDBG("can not find symbol: %s\n", sym); \
124 ret = TD_NOLIBTHREAD; \
127 ret = ps_pread(proc, vaddr, val, sizeof(int)); \
129 TDBG("can not read value of %s\n", sym);\
130 ret = TD_NOLIBTHREAD; \
141 ta
= malloc(sizeof(td_thragent_t
));
147 LOOKUP_SYM(ph
, "_libthread_xu_debug", &ta
->libthread_xu_debug_addr
);
148 LOOKUP_SYM(ph
, "_thread_active_threads",&ta
->thread_active_threads_addr
);
149 LOOKUP_SYM(ph
, "_thread_bp_create", &ta
->thread_bp_create_addr
);
150 LOOKUP_SYM(ph
, "_thread_bp_death", &ta
->thread_bp_death_addr
);
151 LOOKUP_SYM(ph
, "_thread_event_mask", &ta
->thread_event_mask_addr
);
152 LOOKUP_SYM(ph
, "_thread_keytable", &ta
->thread_keytable_addr
);
153 LOOKUP_SYM(ph
, "_thread_last_event", &ta
->thread_last_event_addr
);
154 LOOKUP_SYM(ph
, "_thread_list", &ta
->thread_list_addr
);
155 LOOKUP_VAL(ph
, "_thread_max_keys", &ta
->thread_max_keys
);
156 LOOKUP_VAL(ph
, "_thread_off_attr_flags", &ta
->thread_off_attr_flags
);
157 LOOKUP_VAL(ph
, "_thread_off_event_buf", &ta
->thread_off_event_buf
);
158 LOOKUP_VAL(ph
, "_thread_off_event_mask", &ta
->thread_off_event_mask
);
159 LOOKUP_VAL(ph
, "_thread_off_key_allocated", &ta
->thread_off_key_allocated
);
160 LOOKUP_VAL(ph
, "_thread_off_key_destructor", &ta
->thread_off_key_destructor
);
161 LOOKUP_VAL(ph
, "_thread_off_next", &ta
->thread_off_next
);
162 LOOKUP_VAL(ph
, "_thread_off_report_events", &ta
->thread_off_report_events
);
163 LOOKUP_VAL(ph
, "_thread_off_state", &ta
->thread_off_state
);
164 LOOKUP_VAL(ph
, "_thread_off_tcb", &ta
->thread_off_tcb
);
165 LOOKUP_VAL(ph
, "_thread_off_tid", &ta
->thread_off_tid
);
166 LOOKUP_VAL(ph
, "_thread_size_key", &ta
->thread_size_key
);
167 LOOKUP_VAL(ph
, "_thread_state_running", &ta
->thread_state_running
);
168 LOOKUP_VAL(ph
, "_thread_state_zoombie", &ta
->thread_state_zoombie
);
170 ta
->thread_off_linkmap
= offsetof(Obj_Entry
, linkmap
);
171 ta
->thread_off_tlsindex
= offsetof(Obj_Entry
, tlsindex
);
172 ta
->thread_off_dtv
= offsetof(struct tls_tcb
, tcb_dtv
);
176 * If this fails it probably means we're debugging a core file and
179 ps_pwrite(ph
, ta
->libthread_xu_debug_addr
, &dbg
, sizeof(int));
189 pt_ta_delete(td_thragent_t
*ta
)
197 * Error returns from this write are not really a problem;
198 * the process doesn't exist any more.
200 ps_pwrite(ta
->ph
, ta
->libthread_xu_debug_addr
, &dbg
, sizeof(int));
206 pt_ta_map_id2thr(const td_thragent_t
*ta
, thread_t id
, td_thrhandle_t
*th
)
209 TAILQ_HEAD(, pthread
) thread_list
;
218 ret
= ps_pread(ta
->ph
, ta
->thread_list_addr
, &thread_list
,
219 sizeof(thread_list
));
222 /* Iterate through thread list to find pthread */
223 pt
= (psaddr_t
)thread_list
.tqh_first
;
225 ret
= ps_pread(ta
->ph
, pt
+ ta
->thread_off_tid
,
231 /* get next thread */
232 ret
= ps_pread(ta
->ph
,
233 pt
+ ta
->thread_off_next
,
247 pt_ta_map_lwp2thr(const td_thragent_t
*ta
, lwpid_t lwp
, td_thrhandle_t
*th
)
249 return (pt_ta_map_id2thr(ta
, lwp
, th
));
253 pt_ta_thr_iter(const td_thragent_t
*ta
,
254 td_thr_iter_f
*callback
, void *cbdata_p
,
255 td_thr_state_e state
, int ti_pri
,
256 sigset_t
*ti_sigmask_p
,
257 unsigned int ti_user_flags
)
259 TAILQ_HEAD(, pthread
) thread_list
;
267 ret
= ps_pread(ta
->ph
, ta
->thread_list_addr
, &thread_list
,
268 sizeof(thread_list
));
271 pt
= (psaddr_t
)thread_list
.tqh_first
;
273 ret
= ps_pread(ta
->ph
, pt
+ ta
->thread_off_tid
, &lwp
,
277 if (lwp
!= 0 && lwp
!= TERMINATED
) {
279 th
.th_tid
= (thread_t
)lwp
;
281 if ((*callback
)(&th
, cbdata_p
))
284 /* get next thread */
285 ret
= ps_pread(ta
->ph
, pt
+ ta
->thread_off_next
, &pt
,
294 pt_ta_tsd_iter(const td_thragent_t
*ta
, td_key_iter_f
*ki
, void *arg
)
298 int i
, ret
, allocated
;
302 keytable
= malloc(ta
->thread_max_keys
* ta
->thread_size_key
);
303 if (keytable
== NULL
)
305 ret
= ps_pread(ta
->ph
, (psaddr_t
)ta
->thread_keytable_addr
, keytable
,
306 ta
->thread_max_keys
* ta
->thread_size_key
);
311 for (i
= 0; i
< ta
->thread_max_keys
; i
++) {
312 allocated
= *(int *)(keytable
+ i
* ta
->thread_size_key
+
313 ta
->thread_off_key_allocated
);
314 destructor
= *(void **)(keytable
+ i
* ta
->thread_size_key
+
315 ta
->thread_off_key_destructor
);
317 ret
= (ki
)(i
, destructor
, arg
);
329 pt_ta_event_addr(const td_thragent_t
*ta
, td_event_e event
, td_notify_t
*ptr
)
336 ptr
->type
= NOTIFY_BPT
;
337 ptr
->u
.bptaddr
= ta
->thread_bp_create_addr
;
340 ptr
->type
= NOTIFY_BPT
;
341 ptr
->u
.bptaddr
= ta
->thread_bp_death_addr
;
349 pt_ta_set_event(const td_thragent_t
*ta
, td_thr_events_t
*events
)
351 td_thr_events_t mask
;
355 ret
= ps_pread(ta
->ph
, ta
->thread_event_mask_addr
, &mask
,
360 ret
= ps_pwrite(ta
->ph
, ta
->thread_event_mask_addr
, &mask
,
366 pt_ta_clear_event(const td_thragent_t
*ta
, td_thr_events_t
*events
)
368 td_thr_events_t mask
;
372 ret
= ps_pread(ta
->ph
, ta
->thread_event_mask_addr
, &mask
,
377 ret
= ps_pwrite(ta
->ph
, ta
->thread_event_mask_addr
, &mask
,
383 pt_ta_event_getmsg(const td_thragent_t
*ta
, td_event_msg_t
*msg
)
385 static td_thrhandle_t handle
;
387 psaddr_t pt
, pt_temp
;
394 ret
= ps_pread(ta
->ph
, ta
->thread_last_event_addr
, &pt
, sizeof(pt
));
400 * Take the event pointer, at the time, libthr only reports event
401 * once a time, so it is not a link list.
404 ps_pwrite(ta
->ph
, ta
->thread_last_event_addr
, &pt_temp
, sizeof(pt_temp
));
406 /* Read event info */
407 ret
= ps_pread(ta
->ph
, pt
+ ta
->thread_off_event_buf
, msg
, sizeof(*msg
));
414 ps_pwrite(ta
->ph
, pt
+ ta
->thread_off_event_buf
, &tmp
, sizeof(tmp
));
416 pt
= (psaddr_t
)msg
->th_p
;
417 ret
= ps_pread(ta
->ph
, pt
+ ta
->thread_off_tid
, &lwp
, sizeof(lwp
));
422 handle
.th_thread
= pt
;
428 pt_dbsuspend(const td_thrhandle_t
*th
, int suspend
)
430 td_thragent_t
*ta
= (td_thragent_t
*)th
->th_ta
;
435 ret
= pt_validate(th
);
440 ret
= ps_lstop(ta
->ph
, th
->th_tid
);
442 ret
= ps_lcontinue(ta
->ph
, th
->th_tid
);
447 pt_thr_dbresume(const td_thrhandle_t
*th
)
451 return pt_dbsuspend(th
, 0);
455 pt_thr_dbsuspend(const td_thrhandle_t
*th
)
459 return pt_dbsuspend(th
, 1);
463 pt_thr_validate(const td_thrhandle_t
*th
)
470 ret
= pt_ta_map_id2thr(th
->th_ta
, th
->th_tid
, &temp
);
475 pt_thr_get_info(const td_thrhandle_t
*th
, td_thrinfo_t
*info
)
477 const td_thragent_t
*ta
= th
->th_ta
;
483 ret
= pt_validate(th
);
486 ret
= ps_pread(ta
->ph
, th
->th_thread
+ ta
->thread_off_state
,
487 &state
, sizeof(state
));
490 ret
= ps_pread(ta
->ph
, th
->th_thread
+ ta
->thread_off_report_events
,
491 &info
->ti_traceme
, sizeof(int));
494 ret
= ps_pread(ta
->ph
, th
->th_thread
+ ta
->thread_off_event_mask
,
495 &info
->ti_events
, sizeof(td_thr_events_t
));
498 ret
= ps_pread(ta
->ph
, th
->th_thread
+ ta
->thread_off_tcb
,
499 &info
->ti_tls
, sizeof(void *));
500 info
->ti_lid
= th
->th_tid
;
501 info
->ti_tid
= th
->th_tid
;
502 info
->ti_thread
= th
->th_thread
;
503 info
->ti_ta_p
= th
->th_ta
;
504 if (state
== ta
->thread_state_running
)
505 info
->ti_state
= TD_THR_RUN
;
506 else if (state
== ta
->thread_state_zoombie
)
507 info
->ti_state
= TD_THR_ZOMBIE
;
509 info
->ti_state
= TD_THR_SLEEP
;
510 info
->ti_type
= TD_THR_USER
;
515 pt_thr_getfpregs(const td_thrhandle_t
*th
, prfpregset_t
*fpregs
)
517 const td_thragent_t
*ta
= th
->th_ta
;
522 ret
= pt_validate(th
);
526 ret
= ps_lgetfpregs(ta
->ph
, th
->th_tid
, fpregs
);
531 pt_thr_getgregs(const td_thrhandle_t
*th
, prgregset_t gregs
)
533 const td_thragent_t
*ta
= th
->th_ta
;
538 ret
= pt_validate(th
);
542 ret
= ps_lgetregs(ta
->ph
, th
->th_tid
, gregs
);
547 pt_thr_setfpregs(const td_thrhandle_t
*th
, const prfpregset_t
*fpregs
)
549 const td_thragent_t
*ta
= th
->th_ta
;
554 ret
= pt_validate(th
);
558 ret
= ps_lsetfpregs(ta
->ph
, th
->th_tid
, fpregs
);
563 pt_thr_setgregs(const td_thrhandle_t
*th
, const prgregset_t gregs
)
565 const td_thragent_t
*ta
= th
->th_ta
;
570 ret
= pt_validate(th
);
574 ret
= ps_lsetregs(ta
->ph
, th
->th_tid
, gregs
);
579 pt_thr_event_enable(const td_thrhandle_t
*th
, int en
)
581 const td_thragent_t
*ta
= th
->th_ta
;
585 ret
= ps_pwrite(ta
->ph
, th
->th_thread
+ ta
->thread_off_report_events
,
591 pt_thr_set_event(const td_thrhandle_t
*th
, td_thr_events_t
*setp
)
593 const td_thragent_t
*ta
= th
->th_ta
;
594 td_thr_events_t mask
;
598 ret
= ps_pread(ta
->ph
, th
->th_thread
+ ta
->thread_off_event_mask
,
599 &mask
, sizeof(mask
));
601 ret
= ps_pwrite(ta
->ph
, th
->th_thread
+ ta
->thread_off_event_mask
,
602 &mask
, sizeof(mask
));
607 pt_thr_clear_event(const td_thrhandle_t
*th
, td_thr_events_t
*setp
)
609 const td_thragent_t
*ta
= th
->th_ta
;
610 td_thr_events_t mask
;
614 ret
= ps_pread(ta
->ph
, th
->th_thread
+ ta
->thread_off_event_mask
,
615 &mask
, sizeof(mask
));
617 ret
= ps_pwrite(ta
->ph
, th
->th_thread
+ ta
->thread_off_event_mask
,
618 &mask
, sizeof(mask
));
623 pt_thr_event_getmsg(const td_thrhandle_t
*th
, td_event_msg_t
*msg
)
625 static td_thrhandle_t handle
;
626 td_thragent_t
*ta
= (td_thragent_t
*)th
->th_ta
;
627 psaddr_t pt
, pt_temp
;
634 ret
= ps_pread(ta
->ph
, ta
->thread_last_event_addr
, &pt_temp
, sizeof(pt_temp
));
638 ret
= ps_pread(ta
->ph
, pt
+ ta
->thread_off_event_buf
, msg
, sizeof(*msg
));
644 * Take the event pointer, at the time, libthr only reports event
645 * once a time, so it is not a link list.
649 ps_pwrite(ta
->ph
, ta
->thread_last_event_addr
, &pt_temp
, sizeof(pt_temp
));
653 ps_pwrite(ta
->ph
, pt
+ ta
->thread_off_event_buf
, &tmp
, sizeof(tmp
));
655 pt
= (psaddr_t
)msg
->th_p
;
656 ret
= ps_pread(ta
->ph
, pt
+ ta
->thread_off_tid
, &lwp
, sizeof(lwp
));
661 handle
.th_thread
= pt
;
667 pt_validate(const td_thrhandle_t
*th
)
670 if (th
->th_tid
== 0 || th
->th_thread
== NULL
)
676 pt_thr_tls_get_addr(const td_thrhandle_t
*th
, void *_linkmap
, size_t offset
,
680 const td_thragent_t
*ta
= th
->th_ta
;
681 psaddr_t tcb_addr
, *dtv_addr
, tcb_tp
;
684 /* linkmap is a member of Obj_Entry */
685 obj_entry
= (char *)_linkmap
- ta
->thread_off_linkmap
;
687 /* get tlsindex of the object file */
688 ret
= ps_pread(ta
->ph
,
689 obj_entry
+ ta
->thread_off_tlsindex
,
690 &tls_index
, sizeof(tls_index
));
695 ret
= ps_pread(ta
->ph
, th
->th_thread
+ ta
->thread_off_tcb
,
696 &tcb_addr
, sizeof(tcb_addr
));
700 /* get dtv array address */
701 ret
= ps_pread(ta
->ph
, tcb_addr
+ ta
->thread_off_dtv
,
702 &dtv_addr
, sizeof(dtv_addr
));
705 /* now get the object's tls block base address */
706 ret
= ps_pread(ta
->ph
, &dtv_addr
[tls_index
+1], address
,
715 struct ta_ops libthread_xu_ops
= {
717 .to_ta_clear_event
= pt_ta_clear_event
,
718 .to_ta_delete
= pt_ta_delete
,
719 .to_ta_event_addr
= pt_ta_event_addr
,
720 .to_ta_event_getmsg
= pt_ta_event_getmsg
,
721 .to_ta_map_id2thr
= pt_ta_map_id2thr
,
722 .to_ta_map_lwp2thr
= pt_ta_map_lwp2thr
,
723 .to_ta_new
= pt_ta_new
,
724 .to_ta_set_event
= pt_ta_set_event
,
725 .to_ta_thr_iter
= pt_ta_thr_iter
,
726 .to_ta_tsd_iter
= pt_ta_tsd_iter
,
727 .to_thr_clear_event
= pt_thr_clear_event
,
728 .to_thr_dbresume
= pt_thr_dbresume
,
729 .to_thr_dbsuspend
= pt_thr_dbsuspend
,
730 .to_thr_event_enable
= pt_thr_event_enable
,
731 .to_thr_event_getmsg
= pt_thr_event_getmsg
,
732 .to_thr_get_info
= pt_thr_get_info
,
733 .to_thr_getfpregs
= pt_thr_getfpregs
,
734 .to_thr_getgregs
= pt_thr_getgregs
,
735 .to_thr_set_event
= pt_thr_set_event
,
736 .to_thr_setfpregs
= pt_thr_setfpregs
,
737 .to_thr_setgregs
= pt_thr_setgregs
,
738 .to_thr_validate
= pt_thr_validate
,
739 .to_thr_tls_get_addr
= pt_thr_tls_get_addr
,