[Bug libstdc++/22309] mt allocator doesn't pthread_key_delete it's keys

[jakub at redhat dot com]

------- Additional Comments From jakub at redhat dot com  2005-07-14 13:37 -------
Another patch here: <http://gcc.gnu.org/ml/gcc-patches/2005-07/msg00993.html>

To test whether _M_get_thread_id/_M_initialize/_M_destroy_thread_key works
I was using following testcase under debugger:

#include <pthread.h>
#include <unistd.h>
#include <memory>
#include <ext/mt_allocator.h>

using __gnu_cxx::__pool;
using __gnu_cxx::__common_pool_policy;
using __gnu_cxx::__per_type_pool_policy;
typedef __common_pool_policy<__pool, true> cpolicy_type;
typedef __per_type_pool_policy<char, __pool, true> tpolicy_type;
typedef __per_type_pool_policy<unsigned char, __pool, true> upolicy_type;
typedef __gnu_cxx::__mt_alloc<char, cpolicy_type> callocator_type;
typedef __gnu_cxx::__mt_alloc<char, tpolicy_type> tallocator_type;
typedef __gnu_cxx::__mt_alloc<char, upolicy_type> uallocator_type;
typedef __gnu_cxx::__pool_base::_Tune tune_type;
callocator_type ca;
tallocator_type ta;
uallocator_type ua;

void *tf(void *arg)
{
  callocator_type::pointer p1 = ca.allocate(128);
  callocator_type::pointer p2 = ca.allocate(5128);
  ca.deallocate(p1, 128);
  ca.deallocate(p2, 5128);
  int idx = (int) (long) arg;
  if (idx & 1)
    sleep (1);
  else
    sleep (1024);
  return NULL;
}

void *tf2(void *arg)
{
  tallocator_type::pointer p1 = ta.allocate(128);
  tallocator_type::pointer p2 = ta.allocate(5128);
  ta.deallocate(p1, 128);
  ta.deallocate(p2, 5128);
  int idx = (int) (long) arg;
  if (idx & 1)
    sleep (1);
  else
    sleep (1024);
  return NULL;
}

void *tf3(void *arg)
{
  uallocator_type::pointer p1 = ua.allocate(128);
  uallocator_type::pointer p2 = ua.allocate(5128);
  ua.deallocate(p1, 128);
  ua.deallocate(p2, 5128);
  int idx = (int) (long) arg;
  if (idx & 1)
    sleep (1);
  else
    sleep (1024);
  return NULL;
}

int main()
{
  tune_type t_opt(16, 5120, 32, 5120, 20, 10, false);
  ca._M_set_options(t_opt);

  pthread_t th[48];
  for (int i = 0; i < 16; ++i)
    pthread_create (&th[i], NULL, tf, (void *) (long) i);

  callocator_type::pointer p1 = ca.allocate(128);
  callocator_type::pointer p2 = ca.allocate(5128);
  ca.deallocate(p1, 128);
  ca.deallocate(p2, 5128);

  sleep (3);

  tune_type t_opt2(16, 5120, 32, 5120, 36, 10, false);
  ta._M_set_options(t_opt2);

  for (int i = 16; i < 32; ++i)
    pthread_create (&th[i], NULL, tf2, (void *) (long) i);

  tallocator_type::pointer p3 = ta.allocate(128);
  tallocator_type::pointer p4 = ta.allocate(5128);
  ta.deallocate(p3, 128);
  ta.deallocate(p4, 5128);

  sleep (3);

  tune_type t_opt3(16, 5120, 32, 5120, 52, 10, false);
  ua._M_set_options(t_opt3);

  for (int i = 32; i < 48; ++i)
    pthread_create (&th[i], NULL, tf3, (void *) (long) i);

  uallocator_type::pointer p5 = ua.allocate(128);
  uallocator_type::pointer p6 = ua.allocate(5128);
  ua.deallocate(p5, 128);
  ua.deallocate(p6, 5128);

  sleep (3);

  return 0;
}


-- 


http://gcc.gnu.org/bugzilla/show_bug.cgi?id=22309