On Mon, Mar 10, 2025 at 11:49:39PM +0100, Aurelien Jarno wrote:
> I also noticed it failed the same way on arm64.
Thanks for confirming!
> > > Please tell me if you would like me to do more experiments.
> >
> > If you have time, yes, that's very useful. I'll also try to have a
> > closer look at your testcase, but it already seems relatively small.
>
> I am not sure I understand everything yet, but it seems that building
> pari with -fexceptions is a good workaround for the issue.
Alas, this would break the ABI of the libpari,
and I still get failure with -fexceptions: instead of crashes, the program
terminate without printing Done:
%for i in `seq 1 100`; do (set -e; echo -n "$i " && sid ./pthread1) || break;
done
1 Done!
2 3 4 5 6 Done!
7 8 Done!
9 10 11 12 13 Done!
14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 Done!
29 30 31 Done!
32 33 34 Done!
35 36 37 38 39 40 Done!
41 42 43 44 45 46 Done!
47 48 49 50 51 52 53 Done!
54 55 56 57 58 59 60 61 62 63 64 65 ^C%
I join a simplified test-case.
Cheers,
--
Bill. <ballo...@debian.org>
Imagine a large red swirl here.
/* Copyright (C) 2013 The PARI group.
This file is part of the PARI/GP package.
PARI/GP 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 of the License, or (at your option) any later
version. It is distributed in the hope that it will be useful, but WITHOUT
ANY WARRANTY WHATSOEVER.
Check the License for details. You should have received a copy of it, along
with the package; see the file 'COPYING'. If not, write to the Free Software
Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */
#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
struct mt_state
{
long workid;
};
struct mt_queue
{
long workid;
};
struct mt_pstate
{
pthread_t *th;
void **pth;
struct mt_queue *mq;
long n;
};
static void
mt_queue_cleanup(void *arg)
{
(void) arg;
}
static void*
mt_queue_run(void *arg)
{
pthread_cleanup_push(mt_queue_cleanup,NULL);
for(;;)
{
pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS,NULL);
for(long u=1; u<10000; u++);
pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED,NULL);
}
pthread_cleanup_pop(1);
return NULL;
}
void
mt_queue_start_lim(long lim)
{
struct mt_pstate *mt =
(struct mt_pstate*) malloc(sizeof(struct mt_pstate));
long i;
mt->mq = (struct mt_queue *) malloc(sizeof(*mt->mq)*lim);
mt->th = (pthread_t *) malloc(sizeof(*mt->th)*lim);
mt->pth = (void **) malloc(sizeof(*mt->pth)*lim);
mt->n = lim;
for (i=0;i<lim;i++)
{
struct mt_queue *mq = mt->mq+i;
mt->pth[i] = (void*)mq;
}
for (i=0;i<lim;i++)
pthread_create(&mt->th[i],NULL, &mt_queue_run, (void*)mt->pth[i]);
for (i=0; i<lim; i++)
pthread_cancel(mt->th[i]);
for (i=0; i<lim; i++)
pthread_join(mt->th[i],NULL);
}
int
main(void)
{
long k;
for (k = 1; k<1000; k++)
mt_queue_start_lim(8);
printf("Done!\n");
}
