hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

backup pid && tid of pthread before stop

Browse Source
This commit is contained in:
obdev
2023-03-15 07:11:01 +00:00
committed by ob-robot
parent f5057f146f
commit cb4c4572e6
2 changed files with 16 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
deps/oblib/src/lib/thread/thread.cpp vendored
View File

@ -58,7 +58,9 @@ Thread::Thread(Runnable runnable, int64_t stack_size)
#endif #endif
stack_size_(stack_size), stack_size_(stack_size),
stop_(true), stop_(true),
join_concurrency_(0) join_concurrency_(0),
pid_before_stop_(0),
tid_before_stop_(0)
{} {}
Thread::~Thread() Thread::~Thread()
@ -127,6 +129,17 @@ int Thread::start(Runnable runnable)
void Thread::stop() void Thread::stop()
{ {
#ifndef OB_USE_ASAN
if (!stop_ && stack_addr_ != NULL) {
int tid_offset = 720;
int pid_offset = 724;
int len = (char*)stack_addr_ + stack_size_ - (char*)pth_;
if (len >= (max(tid_offset, pid_offset) + sizeof(pid_t))) {
tid_before_stop_ = *(pid_t*)((char*)pth_ + tid_offset);
pid_before_stop_ = *(pid_t*)((char*)pth_ + pid_offset);
}
}
#endif
stop_ = true; stop_ = true;
} }

2
deps/oblib/src/lib/thread/thread.h vendored
View File

@ -81,6 +81,8 @@ private:
int64_t stack_size_; int64_t stack_size_;
bool stop_; bool stop_;
int64_t join_concurrency_; int64_t join_concurrency_;
pid_t pid_before_stop_;
pid_t tid_before_stop_;
}; };
OB_INLINE pid_t Thread::get_pid() const OB_INLINE pid_t Thread::get_pid() const