Commit ddd69607 by Loren J. Rittle Committed by Loren J. Rittle

pthread1.cc: New test.

	* testsuite/thread/pthread1.cc: New test.
	* testsuite/thread/pthread2.cc: New test adapted from libstdc++/5347.
	* testsuite/thread/pthread3.cc: Likewise.
	* testsuite/thread/pthread4.cc: New test adapted from
	http://gcc.gnu.org/ml/gcc-bugs/2002-01/msg00679.html
	* testsuite/thread/pthread5.cc: New test adapted from libstdc++/5464.
	* testsuite/thread/pthread6.cc: New test adapted from libstdc++/5444.

From-SVN: r49173
parent 619e2b84
2002-01-23 Loren Rittle <ljrittle@acm.org>
* testsuite/thread/pthread1.cc: New test.
* testsuite/thread/pthread2.cc: New test adapted from libstdc++/5347.
* testsuite/thread/pthread3.cc: Likewise.
* testsuite/thread/pthread4.cc: New test adapted from
http://gcc.gnu.org/ml/gcc-bugs/2002-01/msg00679.html
* testsuite/thread/pthread5.cc: New test adapted from libstdc++/5464.
* testsuite/thread/pthread6.cc: New test adapted from libstdc++/5444.
2002-01-23 Richard Henderson <rth@redhat.com> 2002-01-23 Richard Henderson <rth@redhat.com>
PR libstdc++/5198 PR libstdc++/5198
......
// 2002-01-23 Loren J. Rittle <rittle@labs.mot.com> <ljrittle@acm.org>
//
// Copyright (C) 2002 Free Software Foundation, Inc.
//
// This file is part of the GNU ISO C++ Library. This library is free
// software; you can redistribute it and/or modify it under the
// terms of the GNU General Public License as published by the
// Free Software Foundation; either version 2, or (at your option)
// any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License along
// with this library; see the file COPYING. If not, write to the Free
// Software Foundation, 59 Temple Place - Suite 330, Boston, MA 02111-1307,
// USA.
// { dg-do run { target *-*-freebsd* *-*-linux* *-*-solaris* } }
// { dg-options "-pthread" { target *-*-freebsd* *-*-linux* } }
// { dg-options "-pthreads" { target *-*-solaris* } }
// This multi-threading C++/STL/POSIX code adheres to rules outlined here:
// http://www.sgi.com/tech/stl/thread_safety.html
//
// It is believed to exercise the allocation code in a manner that
// should reveal memory leaks (and, under rare cases, race conditions,
// if the STL threading support is fubar'd).
#include <list>
// Do not include <pthread.h> explicitly; if threads are properly
// configured for the port, then it is picked up free from STL headers.
#if __GTHREADS
using namespace std;
const int thread_cycles = 10;
const int thread_pairs = 10;
const unsigned max_size = 100;
const int iters = 10000;
class task_queue
{
public:
task_queue ()
{
pthread_mutex_init (&fooLock, NULL);
pthread_cond_init (&fooCond, NULL);
}
~task_queue ()
{
pthread_mutex_destroy (&fooLock);
pthread_cond_destroy (&fooCond);
}
list<int> foo;
pthread_mutex_t fooLock;
// This code uses a special case that allows us to use just one
// condition variable - in general, don't use this idiom unless you
// know what you are doing. ;-)
pthread_cond_t fooCond;
};
void*
produce (void* t)
{
task_queue& tq = *(static_cast<task_queue*> (t));
int num = 0;
while (num < iters)
{
pthread_mutex_lock (&tq.fooLock);
while (tq.foo.size () >= max_size)
pthread_cond_wait (&tq.fooCond, &tq.fooLock);
tq.foo.push_back (num++);
pthread_cond_signal (&tq.fooCond);
pthread_mutex_unlock (&tq.fooLock);
}
return 0;
}
void*
consume (void* t)
{
task_queue& tq = *(static_cast<task_queue*> (t));
int num = 0;
while (num < iters)
{
pthread_mutex_lock (&tq.fooLock);
while (tq.foo.size () == 0)
pthread_cond_wait (&tq.fooCond, &tq.fooLock);
if (tq.foo.front () != num++)
abort ();
tq.foo.pop_front ();
pthread_cond_signal (&tq.fooCond);
pthread_mutex_unlock (&tq.fooLock);
}
return 0;
}
int
main (int argc, char** argv)
{
pthread_t prod[thread_pairs];
pthread_t cons[thread_pairs];
task_queue* tq[thread_pairs];
#if defined(__sun) && defined(__svr4__)
pthread_setconcurrency (thread_pairs * 2);
#endif
for (int j = 0; j < thread_cycles; j++)
{
for (int i = 0; i < thread_pairs; i++)
{
tq[i] = new task_queue;
pthread_create (&prod[i], NULL, produce, static_cast<void*> (tq[i]));
pthread_create (&cons[i], NULL, consume, static_cast<void*> (tq[i]));
}
for (int i = 0; i < thread_pairs; i++)
{
pthread_join (prod[i], NULL);
pthread_join (cons[i], NULL);
#if defined(__FreeBSD__)
// These lines are not required by POSIX since a successful
// join is suppose to detach as well...
pthread_detach (prod[i]);
pthread_detach (cons[i]);
// ...but they are according to the FreeBSD 4.X code base
// or else you get a memory leak.
#endif
delete tq[i];
}
}
return 0;
}
#else
int main (void) {}
#endif
// 2002-01-23 Loren J. Rittle <rittle@labs.mot.com> <ljrittle@acm.org>
// Adpated from libstdc++/5347 submitted by markus.breuer@materna.de
//
// Copyright (C) 2002 Free Software Foundation, Inc.
//
// This file is part of the GNU ISO C++ Library. This library is free
// software; you can redistribute it and/or modify it under the
// terms of the GNU General Public License as published by the
// Free Software Foundation; either version 2, or (at your option)
// any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License along
// with this library; see the file COPYING. If not, write to the Free
// Software Foundation, 59 Temple Place - Suite 330, Boston, MA 02111-1307,
// USA.
// { dg-do run { target *-*-freebsd* *-*-linux* *-*-solaris* } }
// { dg-options "-pthread" { target *-*-freebsd* *-*-linux* } }
// { dg-options "-pthreads" { target *-*-solaris* } }
#include <fstream>
// Do not include <pthread.h> explicitly; if threads are properly
// configured for the port, then it is picked up free from STL headers.
#if __GTHREADS
const int max_thread_count = 2;
const int max_loop_count = 1000000;
void*
thread_main (void *)
{
for (int i = 0; i < max_loop_count; i++)
{
std::ofstream* pos1 = new std::ofstream;
delete pos1;
}
return 0;
}
int
main()
{
pthread_t tid[max_thread_count];
#if defined(__sun) && defined(__svr4__)
pthread_setconcurrency (max_thread_count);
#endif
for (int i = 0; i < max_thread_count; i++)
pthread_create (&tid[i], NULL, thread_main, 0);
for (int i = 0; i < max_thread_count; i++)
pthread_join (tid[i], NULL);
return 0;
}
#else
int main (void) {}
#endif
// 2002-01-23 Loren J. Rittle <rittle@labs.mot.com> <ljrittle@acm.org>
// Adpated from libstdc++/5347 submitted by markus.breuer@materna.de
//
// Copyright (C) 2002 Free Software Foundation, Inc.
//
// This file is part of the GNU ISO C++ Library. This library is free
// software; you can redistribute it and/or modify it under the
// terms of the GNU General Public License as published by the
// Free Software Foundation; either version 2, or (at your option)
// any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License along
// with this library; see the file COPYING. If not, write to the Free
// Software Foundation, 59 Temple Place - Suite 330, Boston, MA 02111-1307,
// USA.
// { dg-do run { target *-*-freebsd* *-*-linux* *-*-solaris* } }
// { dg-options "-pthread" { target *-*-freebsd* *-*-linux* } }
// { dg-options "-pthreads" { target *-*-solaris* } }
#include <sstream>
// Do not include <pthread.h> explicitly; if threads are properly
// configured for the port, then it is picked up free from STL headers.
#if __GTHREADS
const int max_thread_count = 2;
const int max_loop_count = 1000000;
void*
thread_main (void *)
{
for (int i = 0; i < max_loop_count; i++)
std::ostringstream oss;
return 0;
}
int
main()
{
pthread_t tid[max_thread_count];
#if defined(__sun) && defined(__svr4__)
pthread_setconcurrency (max_thread_count);
#endif
for (int i = 0; i < max_thread_count; i++)
pthread_create (&tid[i], NULL, thread_main, 0);
for (int i = 0; i < max_thread_count; i++)
pthread_join (tid[i], NULL);
return 0;
}
#else
int main (void) {}
#endif
// 2002-01-23 Loren J. Rittle <rittle@labs.mot.com> <ljrittle@acm.org>
// Adapted from http://gcc.gnu.org/ml/gcc-bugs/2002-01/msg00679.html
// which was adapted from pthread1.cc by Mike Lu <MLu@dynamicsoft.com>
//
// Copyright (C) 2002 Free Software Foundation, Inc.
//
// This file is part of the GNU ISO C++ Library. This library is free
// software; you can redistribute it and/or modify it under the
// terms of the GNU General Public License as published by the
// Free Software Foundation; either version 2, or (at your option)
// any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License along
// with this library; see the file COPYING. If not, write to the Free
// Software Foundation, 59 Temple Place - Suite 330, Boston, MA 02111-1307,
// USA.
// { dg-do run { target *-*-freebsd* *-*-linux* *-*-solaris* } }
// { dg-options "-pthread" { target *-*-freebsd* *-*-linux* } }
// { dg-options "-pthreads" { target *-*-solaris* } }
#include <string>
#include <list>
// Do not include <pthread.h> explicitly; if threads are properly
// configured for the port, then it is picked up free from STL headers.
#if __GTHREADS
using namespace std;
static list<string> foo;
static pthread_mutex_t fooLock = PTHREAD_MUTEX_INITIALIZER;
static unsigned max_size = 10;
static int iters = 1000000;
void*
produce (void*)
{
for (int num = 0; num < iters; )
{
string str ("test string");
pthread_mutex_lock (&fooLock);
if (foo.size () < max_size)
{
foo.push_back (str);
num++;
}
pthread_mutex_unlock (&fooLock);
}
return 0;
}
void*
consume (void*)
{
for (int num = 0; num < iters; )
{
pthread_mutex_lock (&fooLock);
while (foo.size () > 0)
{
string str = foo.back ();
foo.pop_back ();
num++;
}
pthread_mutex_unlock (&fooLock);
}
return 0;
}
int
main (void)
{
#if defined(__sun) && defined(__svr4__)
pthread_setconcurrency (2);
#endif
pthread_t prod;
pthread_create (&prod, NULL, produce, NULL);
pthread_t cons;
pthread_create (&cons, NULL, consume, NULL);
pthread_join (prod, NULL);
pthread_join (cons, NULL);
return 0;
}
#else
int main (void) {}
#endif
// 2002-01-23 Loren J. Rittle <rittle@labs.mot.com> <ljrittle@acm.org>
// Adpated from libstdc++/5464 submitted by jjessel@amadeus.net
// Jean-Francois JESSEL (Amadeus SAS Development)
//
// Copyright (C) 2002 Free Software Foundation, Inc.
//
// This file is part of the GNU ISO C++ Library. This library is free
// software; you can redistribute it and/or modify it under the
// terms of the GNU General Public License as published by the
// Free Software Foundation; either version 2, or (at your option)
// any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License along
// with this library; see the file COPYING. If not, write to the Free
// Software Foundation, 59 Temple Place - Suite 330, Boston, MA 02111-1307,
// USA.
// { dg-do run { target *-*-freebsd* *-*-linux* *-*-solaris* } }
// { dg-options "-pthread" { target *-*-freebsd* *-*-linux* } }
// { dg-options "-pthreads" { target *-*-solaris* } }
#include <vector>
#include <list>
#include <string>
// Do not include <pthread.h> explicitly; if threads are properly
// configured for the port, then it is picked up free from STL headers.
#if __GTHREADS
using namespace std;
#define NTHREADS 8
#define LOOPS 20
struct tt_t
{
char buf[100];
int i;
};
void*
thread_function (void* arg)
{
int myid = *(int*) arg;
for (int i = 0; i < LOOPS; i++)
{
vector<tt_t> myvect1;
for (int j = 0; j < 2000; j++)
{
vector<tt_t> myvect2;
tt_t v;
v.i = j;
myvect1.push_back (v);
myvect2.push_back (v);
list<std::string *> mylist;
std::string string_array[4];
string_array[0] = "toto";
string_array[1] = "titi";
string_array[2] = "tata";
string_array[3] = "tutu";
for (int k = 0; k < 4; k++)
{
if (mylist.size ())
{
list<std::string *>::iterator aIt;
for (aIt = mylist.begin (); aIt != mylist.end (); ++aIt)
{
if ((*aIt) == &(string_array[k]))
abort ();
}
}
mylist.push_back (&(string_array[k]));
}
}
}
return arg;
}
int
main (int argc, char *argv[])
{
int worker;
pthread_t threads[NTHREADS];
int ids[NTHREADS];
void* status;
#if defined(__sun) && defined(__svr4__)
pthread_setconcurrency (NTHREADS);
#endif
pthread_attr_t tattr;
int ret = pthread_attr_init (&tattr);
ret = pthread_attr_setscope(&tattr, PTHREAD_SCOPE_SYSTEM);
for (worker = 0; worker < NTHREADS; worker++)
{
ids[worker] = worker;
if (pthread_create(&threads[worker], &tattr,
thread_function, &ids[worker]))
abort ();
}
for (worker = 0; worker < NTHREADS; worker++)
{
if (pthread_join(threads[worker], static_cast<void **>(&status)))
abort ();
if (*((int *)status) != worker)
abort ();
}
return (0);
}
#else
int main (void) {}
#endif
// 2002-01-23 Loren J. Rittle <rittle@labs.mot.com> <ljrittle@acm.org>
// Adpated from libstdc++/5444 submitted by markus.breuer@materna.de
//
// Copyright (C) 2002 Free Software Foundation, Inc.
//
// This file is part of the GNU ISO C++ Library. This library is free
// software; you can redistribute it and/or modify it under the
// terms of the GNU General Public License as published by the
// Free Software Foundation; either version 2, or (at your option)
// any later version.
//
// This library is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License along
// with this library; see the file COPYING. If not, write to the Free
// Software Foundation, 59 Temple Place - Suite 330, Boston, MA 02111-1307,
// USA.
// { dg-do run { target *-*-freebsd* *-*-linux* *-*-solaris* } }
// { dg-options "-pthread" { target *-*-freebsd* *-*-linux* } }
// { dg-options "-pthreads" { target *-*-solaris* } }
#include <string>
#include <map>
#include <vector>
// Do not include <pthread.h> explicitly; if threads are properly
// configured for the port, then it is picked up free from STL headers.
#if __GTHREADS
const int max_thread_count = 8;
const int loops = 100000;
const char* my_default = "Hallo Welt!";
const int upper_limit = 2500;
const int lower_limit = 1000;
typedef char charT;
typedef std::string String;
typedef String MyType;
void*
thread_main (void*)
{
typedef std::map<unsigned int,MyType> Map;
typedef Map::value_type Value_Pair;
Map myMap;
for (int loop = 0; loop < loops; loop++)
{
String& str = myMap[loop];
str.append (my_default);
myMap.insert (Value_Pair (loop, str));
if (myMap.size () > upper_limit)
{
while (myMap.size () > lower_limit)
{
Map::iterator it = myMap.begin ();
myMap.erase (it);
}
}
}
return 0;
}
int
main (void)
{
pthread_t tid[max_thread_count];
#if defined(__sun) && defined(__svr4__)
pthread_setconcurrency (max_thread_count);
#endif
for (int i = 0; i < max_thread_count; i++)
pthread_create (&tid[i], NULL, thread_main, 0);
for (int i = 0; i < max_thread_count; i++)
pthread_join (tid[i], NULL);
return 0;
}
#else
int main (void) {}
#endif
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment