def async_break(self):
def async_break_send():
with _SendLockCtx:
sent_break_complete = False
global SEND_BREAK_COMPLETE
if SEND_BREAK_COMPLETE == True or SEND_BREAK_COMPLETE == self.id:
# multiple threads could be sending this...
SEND_BREAK_COMPLETE = False
sent_break_complete = True
write_bytes(conn, ASBR)
write_int(conn, self.id)
if sent_break_complete:
# if we have threads which have not broken yet capture their frame list and
# send it now. If they block we'll send an updated (and possibly more accurate - if
# there are any thread locals) list of frames.
update_all_thread_stacks(self)
self.stepping = STEPPING_NONE
self.block(async_break_send)
评论列表
文章目录