aboutsummaryrefslogtreecommitdiffstats
path: root/util/system/thread.cpp
diff options
context:
space:
mode:
authoryazevnul <yazevnul@yandex-team.ru>2022-02-10 16:46:48 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:48 +0300
commit9abfb1a53b7f7b791444d1378e645d8fad9b06ed (patch)
tree49e222ea1c5804306084bb3ae065bb702625360f /util/system/thread.cpp
parent8cbc307de0221f84c80c42dcbe07d40727537e2c (diff)
downloadydb-9abfb1a53b7f7b791444d1378e645d8fad9b06ed.tar.gz
Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/system/thread.cpp')
-rw-r--r--util/system/thread.cpp60
1 files changed, 30 insertions, 30 deletions
diff --git a/util/system/thread.cpp b/util/system/thread.cpp
index f51bc31d1d..6236746c2d 100644
--- a/util/system/thread.cpp
+++ b/util/system/thread.cpp
@@ -128,9 +128,9 @@ namespace {
//do not do this, kids, at home
P_->Ref();
#if _WIN32_WINNT < 0x0502
- Handle = reinterpret_cast<HANDLE>(::_beginthreadex(nullptr, (unsigned)StackSize(*P_), Proxy, (void*)P_.Get(), 0, &ThreadId));
+ Handle = reinterpret_cast<HANDLE>(::_beginthreadex(nullptr, (unsigned)StackSize(*P_), Proxy, (void*)P_.Get(), 0, &ThreadId));
#else
- Handle = reinterpret_cast<HANDLE>(::_beginthreadex(nullptr, (unsigned)StackSize(*P_), Proxy, (void*)P_.Get(), 0, nullptr));
+ Handle = reinterpret_cast<HANDLE>(::_beginthreadex(nullptr, (unsigned)StackSize(*P_), Proxy, (void*)P_.Get(), 0, nullptr));
#endif
if (!Handle) {
@@ -163,7 +163,7 @@ namespace {
public:
inline TPosixThread(const TParams& params)
: P_(new TParams(params))
- , H_()
+ , H_()
{
static_assert(sizeof(H_) == sizeof(TId), "expect sizeof(H_) == sizeof(TId)");
}
@@ -173,7 +173,7 @@ namespace {
}
inline void* Join() {
- void* tec = nullptr;
+ void* tec = nullptr;
PCHECK(pthread_join(H_, &tec), "can not join thread");
return tec;
@@ -188,7 +188,7 @@ namespace {
}
inline void Start() {
- pthread_attr_t* pattrs = nullptr;
+ pthread_attr_t* pattrs = nullptr;
pthread_attr_t attrs;
if (P_->StackSize > 0) {
@@ -302,7 +302,7 @@ void* TThread::Join() {
return ret;
}
- return nullptr;
+ return nullptr;
}
void TThread::Detach() {
@@ -363,8 +363,8 @@ namespace {
}
}
-ISimpleThread::ISimpleThread(size_t stackSize)
- : TThread(TParams(ThreadProcWrapper<ISimpleThread>, reinterpret_cast<void*>(this), stackSize))
+ISimpleThread::ISimpleThread(size_t stackSize)
+ : TThread(TParams(ThreadProcWrapper<ISimpleThread>, reinterpret_cast<void*>(this), stackSize))
{
}
@@ -470,36 +470,36 @@ void TThread::SetCurrentThreadName(const char* name) {
}
TString TThread::CurrentThreadName() {
-#if defined(_freebsd_)
+#if defined(_freebsd_)
// TODO: check pthread_get_name_np API availability
-#elif defined(_linux_)
- // > The buffer should allow space for up to 16 bytes; the returned string will be
- // > null-terminated.
- // via `man prctl`
- char name[16];
- memset(name, 0, sizeof(name));
- Y_VERIFY(prctl(PR_GET_NAME, name, 0, 0, 0) == 0, "pctl failed: %s", strerror(errno));
- return name;
-#elif defined(_darwin_)
- // available on Mac OS 10.6+
- const auto thread = pthread_self();
- char name[256];
- memset(name, 0, sizeof(name));
- Y_VERIFY(pthread_getname_np(thread, name, sizeof(name)) == 0, "pthread_getname_np failed: %s", strerror(errno));
- return name;
+#elif defined(_linux_)
+ // > The buffer should allow space for up to 16 bytes; the returned string will be
+ // > null-terminated.
+ // via `man prctl`
+ char name[16];
+ memset(name, 0, sizeof(name));
+ Y_VERIFY(prctl(PR_GET_NAME, name, 0, 0, 0) == 0, "pctl failed: %s", strerror(errno));
+ return name;
+#elif defined(_darwin_)
+ // available on Mac OS 10.6+
+ const auto thread = pthread_self();
+ char name[256];
+ memset(name, 0, sizeof(name));
+ Y_VERIFY(pthread_getname_np(thread, name, sizeof(name)) == 0, "pthread_getname_np failed: %s", strerror(errno));
+ return name;
#elif defined(_win_)
auto api = Singleton<TWinThreadDescrAPI>();
if (api->HasAPI()) {
return api->GetDescr();
}
return {};
-#else
+#else
// no idea
-#endif // OS
-
- return {};
-}
-
+#endif // OS
+
+ return {};
+}
+
bool TThread::CanGetCurrentThreadName() {
#if defined(_linux_) || defined(_darwin_)
return true;