Loading logd/LogTimes.cpp +16 −5 Original line number Diff line number Diff line Loading @@ -46,15 +46,26 @@ LogTimeEntry::LogTimeEntry(LogReader &reader, SocketClient *client, { } void LogTimeEntry::startReader_Locked(void) { pthread_attr_t attr; threadRunning = true; if (pthread_create(&mThread, NULL, LogTimeEntry::threadStart, this)) { if (!pthread_attr_init(&attr)) { if (!pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED)) { if (!pthread_create(&mThread, &attr, LogTimeEntry::threadStart, this)) { pthread_attr_destroy(&attr); return; } } pthread_attr_destroy(&attr); } threadRunning = false; if (mClient) { mClient->decRef(); } decRef_Locked(); } } void LogTimeEntry::threadStop(void *obj) { LogTimeEntry *me = reinterpret_cast<LogTimeEntry *>(obj); Loading Loading
logd/LogTimes.cpp +16 −5 Original line number Diff line number Diff line Loading @@ -46,15 +46,26 @@ LogTimeEntry::LogTimeEntry(LogReader &reader, SocketClient *client, { } void LogTimeEntry::startReader_Locked(void) { pthread_attr_t attr; threadRunning = true; if (pthread_create(&mThread, NULL, LogTimeEntry::threadStart, this)) { if (!pthread_attr_init(&attr)) { if (!pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED)) { if (!pthread_create(&mThread, &attr, LogTimeEntry::threadStart, this)) { pthread_attr_destroy(&attr); return; } } pthread_attr_destroy(&attr); } threadRunning = false; if (mClient) { mClient->decRef(); } decRef_Locked(); } } void LogTimeEntry::threadStop(void *obj) { LogTimeEntry *me = reinterpret_cast<LogTimeEntry *>(obj); Loading