|
|
|
@ -136,7 +136,7 @@ table_init(void)
|
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
ck_epoch_init(&epoch_ht);
|
|
|
|
|
ck_epoch_register(&epoch_ht, &epoch_wr);
|
|
|
|
|
ck_epoch_register(&epoch_ht, &epoch_wr, NULL);
|
|
|
|
|
common_srand48((long int)time(NULL));
|
|
|
|
|
if (ck_ht_init(&ht, CK_HT_MODE_DIRECT, hash_function, &my_allocator, 8, common_lrand48()) == false) {
|
|
|
|
|
perror("ck_ht_init");
|
|
|
|
@ -221,7 +221,7 @@ ht_reader(void *unused)
|
|
|
|
|
perror("WARNING: Failed to affine thread");
|
|
|
|
|
|
|
|
|
|
s = j = a = 0;
|
|
|
|
|
ck_epoch_register(&epoch_ht, &epoch_record);
|
|
|
|
|
ck_epoch_register(&epoch_ht, &epoch_record, NULL);
|
|
|
|
|
for (;;) {
|
|
|
|
|
j++;
|
|
|
|
|
ck_epoch_begin(&epoch_record, NULL);
|
|
|
|
@ -412,8 +412,8 @@ main(int argc, char *argv[])
|
|
|
|
|
ck_epoch_record_t epoch_temporary = epoch_wr;
|
|
|
|
|
ck_epoch_synchronize(&epoch_wr);
|
|
|
|
|
|
|
|
|
|
fprintf(stderr, " '- Summary: %u pending, %u peak, %lu reclamations -> "
|
|
|
|
|
"%u pending, %u peak, %lu reclamations\n\n",
|
|
|
|
|
fprintf(stderr, " '- Summary: %u pending, %u peak, %u reclamations -> "
|
|
|
|
|
"%u pending, %u peak, %u reclamations\n\n",
|
|
|
|
|
epoch_temporary.n_pending, epoch_temporary.n_peak, epoch_temporary.n_dispatch,
|
|
|
|
|
epoch_wr.n_pending, epoch_wr.n_peak, epoch_wr.n_dispatch);
|
|
|
|
|
|
|
|
|
@ -537,8 +537,8 @@ main(int argc, char *argv[])
|
|
|
|
|
epoch_temporary = epoch_wr;
|
|
|
|
|
ck_epoch_synchronize(&epoch_wr);
|
|
|
|
|
|
|
|
|
|
fprintf(stderr, " '- Summary: %u pending, %u peak, %lu reclamations -> "
|
|
|
|
|
"%u pending, %u peak, %lu reclamations\n\n",
|
|
|
|
|
fprintf(stderr, " '- Summary: %u pending, %u peak, %u reclamations -> "
|
|
|
|
|
"%u pending, %u peak, %u reclamations\n\n",
|
|
|
|
|
epoch_temporary.n_pending, epoch_temporary.n_peak, epoch_temporary.n_dispatch,
|
|
|
|
|
epoch_wr.n_pending, epoch_wr.n_peak, epoch_wr.n_dispatch);
|
|
|
|
|
return 0;
|
|
|
|
|