* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/
-#define _GNU_SOURCE
#include "test_urcu_hash.h"
enum test_hash {
static enum test_hash test_choice = TEST_HASH_RW;
+static
void (*get_sigusr1_cb(void))(int)
{
return test_hash_cb[test_choice].sigusr1;
}
+static
void (*get_sigusr2_cb(void))(int)
{
return test_hash_cb[test_choice].sigusr2;
}
+static
void *(*get_thr_reader_cb(void))(void *)
{
return test_hash_cb[test_choice].thr_reader;
}
+static
void *(*get_thr_writer_cb(void))(void *)
{
return test_hash_cb[test_choice].thr_writer;
}
+static
int (*get_populate_hash_cb(void))(void)
{
return test_hash_cb[test_choice].populate_hash;
return 1;
}
+static
void *thr_count(void *arg)
{
printf_verbose("thread_begin %s, tid %lu\n",
printf("deleted %lu nodes.\n", count);
}
+static
void show_usage(int argc, char **argv)
{
printf("Usage : %s nr_readers nr_writers duration (s) <OPTIONS>\n",
unsigned long count;
long approx_before, approx_after;
int i, a, ret, err, mainret = 0;
+ unsigned int i_thr;
struct sigaction act;
unsigned int remain;
unsigned int nr_readers_created = 0, nr_writers_created = 0;
mainret = 1;
goto end;
}
-
+
err = sscanf(argv[3], "%lu", &duration);
if (err != 1) {
show_usage(argc, argv);
goto end_close_pipe;
}
- for (i = 0; i < nr_readers; i++) {
- err = pthread_create(&tid_reader[i],
+ for (i_thr = 0; i_thr < nr_readers; i_thr++) {
+ err = pthread_create(&tid_reader[i_thr],
NULL, get_thr_reader_cb(),
- &count_reader[i]);
+ &count_reader[i_thr]);
if (err != 0) {
errno = err;
mainret = 1;
}
nr_readers_created++;
}
- for (i = 0; i < nr_writers; i++) {
- err = pthread_create(&tid_writer[i],
+ for (i_thr = 0; i_thr < nr_writers; i_thr++) {
+ err = pthread_create(&tid_writer[i_thr],
NULL, get_thr_writer_cb(),
- &count_writer[i]);
+ &count_writer[i_thr]);
if (err != 0) {
errno = err;
mainret = 1;
test_stop = 1;
end_pthread_join:
- for (i = 0; i < nr_readers_created; i++) {
- err = pthread_join(tid_reader[i], &tret);
+ for (i_thr = 0; i_thr < nr_readers_created; i_thr++) {
+ err = pthread_join(tid_reader[i_thr], &tret);
if (err != 0) {
errno = err;
mainret = 1;
perror("pthread_join");
}
- tot_reads += count_reader[i];
+ tot_reads += count_reader[i_thr];
}
- for (i = 0; i < nr_writers_created; i++) {
- err = pthread_join(tid_writer[i], &tret);
+ for (i_thr = 0; i_thr < nr_writers_created; i_thr++) {
+ err = pthread_join(tid_writer[i_thr], &tret);
if (err != 0) {
errno = err;
mainret = 1;
perror("pthread_join");
}
- tot_writes += count_writer[i].update_ops;
- tot_add += count_writer[i].add;
- tot_add_exist += count_writer[i].add_exist;
- tot_remove += count_writer[i].remove;
+ tot_writes += count_writer[i_thr].update_ops;
+ tot_add += count_writer[i_thr].add;
+ tot_add_exist += count_writer[i_thr].add_exist;
+ tot_remove += count_writer[i_thr].remove;
}
/* teardown counter thread */
}
{
char msg[1] = { 0x42 };
- ssize_t ret;
+ ssize_t sret;
do {
- ret = write(count_pipe[1], msg, 1); /* wakeup thread */
- } while (ret == -1L && errno == EINTR);
+ sret = write(count_pipe[1], msg, 1); /* wakeup thread */
+ } while (sret == -1L && errno == EINTR);
}
err = pthread_join(tid_count, &tret);
if (err != 0) {