Merge "Fix possible leak in pthread_detach."
This commit is contained in:
		@@ -27,10 +27,12 @@
 | 
			
		||||
 */
 | 
			
		||||
 | 
			
		||||
#include <errno.h>
 | 
			
		||||
#include <pthread.h>
 | 
			
		||||
 | 
			
		||||
#include "pthread_accessor.h"
 | 
			
		||||
 | 
			
		||||
int pthread_detach(pthread_t t) {
 | 
			
		||||
  {
 | 
			
		||||
    pthread_accessor thread(t);
 | 
			
		||||
    if (thread.get() == NULL) {
 | 
			
		||||
      return ESRCH;
 | 
			
		||||
@@ -44,12 +46,13 @@ int pthread_detach(pthread_t t) {
 | 
			
		||||
      return 0; // Already being joined; silently do nothing, like glibc.
 | 
			
		||||
    }
 | 
			
		||||
 | 
			
		||||
  if (thread->tid == 0) {
 | 
			
		||||
    // Already exited; clean up.
 | 
			
		||||
    _pthread_internal_remove_locked(thread.get(), true);
 | 
			
		||||
    return 0;
 | 
			
		||||
  }
 | 
			
		||||
 | 
			
		||||
    // If the thread has not exited, we can detach it safely.
 | 
			
		||||
    if ((thread->attr.flags & PTHREAD_ATTR_FLAG_ZOMBIE) == 0) {
 | 
			
		||||
      thread->attr.flags |= PTHREAD_ATTR_FLAG_DETACHED;
 | 
			
		||||
      return 0;
 | 
			
		||||
    }
 | 
			
		||||
  }
 | 
			
		||||
 | 
			
		||||
  // The thread is in zombie state, use pthread_join to clean it up.
 | 
			
		||||
  return pthread_join(t, NULL);
 | 
			
		||||
}
 | 
			
		||||
 
 | 
			
		||||
@@ -99,6 +99,9 @@ void pthread_exit(void* return_value) {
 | 
			
		||||
    // pthread_internal_t is freed below with stack, not here.
 | 
			
		||||
    _pthread_internal_remove_locked(thread, false);
 | 
			
		||||
    free_mapped_space = true;
 | 
			
		||||
  } else {
 | 
			
		||||
    // Mark the thread as exiting without freeing pthread_internal_t.
 | 
			
		||||
    thread->attr.flags |= PTHREAD_ATTR_FLAG_ZOMBIE;
 | 
			
		||||
  }
 | 
			
		||||
  pthread_mutex_unlock(&g_thread_list_lock);
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
@@ -38,6 +38,9 @@
 | 
			
		||||
/* Has the thread been joined by another thread? */
 | 
			
		||||
#define PTHREAD_ATTR_FLAG_JOINED 0x00000002
 | 
			
		||||
 | 
			
		||||
/* Did the thread exit without freeing pthread_internal_t? */
 | 
			
		||||
#define PTHREAD_ATTR_FLAG_ZOMBIE 0x00000004
 | 
			
		||||
 | 
			
		||||
/* Is this the main thread? */
 | 
			
		||||
#define PTHREAD_ATTR_FLAG_MAIN_THREAD 0x80000000
 | 
			
		||||
 | 
			
		||||
 
 | 
			
		||||
@@ -431,7 +431,7 @@ TEST(pthread, pthread_detach__no_such_thread) {
 | 
			
		||||
  ASSERT_EQ(ESRCH, pthread_detach(dead_thread));
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
TEST(pthread, pthread_detach__leak) {
 | 
			
		||||
TEST(pthread, pthread_detach_no_leak) {
 | 
			
		||||
  size_t initial_bytes = 0;
 | 
			
		||||
  // Run this loop more than once since the first loop causes some memory
 | 
			
		||||
  // to be allocated permenantly. Run an extra loop to help catch any subtle
 | 
			
		||||
@@ -464,9 +464,7 @@ TEST(pthread, pthread_detach__leak) {
 | 
			
		||||
  size_t final_bytes = mallinfo().uordblks;
 | 
			
		||||
  int leaked_bytes = (final_bytes - initial_bytes);
 | 
			
		||||
 | 
			
		||||
  // User code (like this test) doesn't know how large pthread_internal_t is.
 | 
			
		||||
  // We can be pretty sure it's more than 128 bytes.
 | 
			
		||||
  ASSERT_LT(leaked_bytes, 32 /*threads*/ * 128 /*bytes*/);
 | 
			
		||||
  ASSERT_EQ(0, leaked_bytes);
 | 
			
		||||
}
 | 
			
		||||
 | 
			
		||||
TEST(pthread, pthread_getcpuclockid__clock_gettime) {
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user