123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118 |
- #include "thread_dbP.h"
- #include <assert.h>
- td_err_e
- td_thr_event_getmsg (const td_thrhandle_t *th, td_event_msg_t *msg)
- {
- td_err_e err;
- psaddr_t eventbuf, eventnum, eventdata;
- psaddr_t thp, prevp;
- void *copy = NULL;
- LOG ("td_thr_event_getmsg");
-
- err = DB_GET_FIELD_ADDRESS (eventbuf, th->th_ta_p, th->th_unique, pthread,
- eventbuf, 0);
- if (err == TD_OK)
- err = DB_GET_STRUCT (copy, th->th_ta_p, eventbuf, td_eventbuf_t);
- if (err != TD_OK)
- return err;
-
- err = DB_GET_FIELD_LOCAL (eventnum, th->th_ta_p, copy,
- td_eventbuf_t, eventnum, 0);
- if (err != TD_OK)
- return err;
- if ((int) (uintptr_t) eventnum == TD_EVENT_NONE)
-
- return TD_NOMSG;
-
- err = DB_GET_FIELD_LOCAL (eventdata, th->th_ta_p, copy,
- td_eventbuf_t, eventdata, 0);
- if (err != TD_OK)
- return err;
- msg->msg.data = (uintptr_t) eventdata;
- msg->event = (uintptr_t) eventnum;
- msg->th_p = th;
-
- memset (copy, 0, th->th_ta_p->ta_sizeof_td_eventbuf_t);
- err = DB_PUT_STRUCT (th->th_ta_p, eventbuf, td_eventbuf_t, copy);
- if (err != TD_OK)
- return err;
-
- err = DB_GET_SYMBOL (prevp, th->th_ta_p, __nptl_last_event);
- if (err != TD_OK)
- return err;
- err = DB_GET_VALUE (thp, th->th_ta_p, __nptl_last_event, 0);
- if (err != TD_OK)
- return err;
- while (thp != 0)
- {
- psaddr_t next;
- err = DB_GET_FIELD (next, th->th_ta_p, th->th_unique, pthread,
- nextevent, 0);
- if (err != TD_OK)
- return err;
- if (next == thp)
- return TD_DBERR;
- if (thp == th->th_unique)
- {
-
- psaddr_t next_nextp;
- err = DB_GET_FIELD_ADDRESS (next_nextp, th->th_ta_p, next, pthread,
- nextevent, 0);
- assert (err == TD_OK);
- if (prevp == next_nextp)
- return TD_DBERR;
- err = _td_store_value (th->th_ta_p,
- th->th_ta_p->ta_var___nptl_last_event, -1,
- 0, prevp, next);
- if (err != TD_OK)
- return err;
-
- return DB_PUT_FIELD (th->th_ta_p, thp, pthread, nextevent, 0, 0);
- }
- err = DB_GET_FIELD_ADDRESS (prevp, th->th_ta_p, thp, pthread,
- nextevent, 0);
- assert (err == TD_OK);
- thp = next;
- }
-
- return TD_DBERR;
- }
|