Make signal queues per thread.

git-svn-id: svn://svn.savannah.nongnu.org/qemu/trunk@4635 c046a42c-6fe2-441c-8c8c-71466251a162
This commit is contained in:
pbrook 2008-05-31 16:11:38 +00:00
parent afd7cd92e8
commit 624f797905
4 changed files with 204 additions and 173 deletions

View File

@ -230,7 +230,7 @@ void cpu_loop(CPUX86State *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_SI_KERNEL; info.si_code = TARGET_SI_KERNEL;
info._sifields._sigfault._addr = 0; info._sifields._sigfault._addr = 0;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case EXCP0D_GPF: case EXCP0D_GPF:
/* XXX: potential problem if ABI32 */ /* XXX: potential problem if ABI32 */
@ -244,7 +244,7 @@ void cpu_loop(CPUX86State *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_SI_KERNEL; info.si_code = TARGET_SI_KERNEL;
info._sifields._sigfault._addr = 0; info._sifields._sigfault._addr = 0;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
break; break;
case EXCP0E_PAGE: case EXCP0E_PAGE:
@ -255,7 +255,7 @@ void cpu_loop(CPUX86State *env)
else else
info.si_code = TARGET_SEGV_ACCERR; info.si_code = TARGET_SEGV_ACCERR;
info._sifields._sigfault._addr = env->cr[2]; info._sifields._sigfault._addr = env->cr[2];
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case EXCP00_DIVZ: case EXCP00_DIVZ:
#ifndef TARGET_X86_64 #ifndef TARGET_X86_64
@ -269,7 +269,7 @@ void cpu_loop(CPUX86State *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_FPE_INTDIV; info.si_code = TARGET_FPE_INTDIV;
info._sifields._sigfault._addr = env->eip; info._sifields._sigfault._addr = env->eip;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
break; break;
case EXCP01_SSTP: case EXCP01_SSTP:
@ -289,7 +289,7 @@ void cpu_loop(CPUX86State *env)
info.si_code = TARGET_SI_KERNEL; info.si_code = TARGET_SI_KERNEL;
info._sifields._sigfault._addr = 0; info._sifields._sigfault._addr = 0;
} }
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
break; break;
case EXCP04_INTO: case EXCP04_INTO:
@ -304,7 +304,7 @@ void cpu_loop(CPUX86State *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_SI_KERNEL; info.si_code = TARGET_SI_KERNEL;
info._sifields._sigfault._addr = 0; info._sifields._sigfault._addr = 0;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
break; break;
case EXCP06_ILLOP: case EXCP06_ILLOP:
@ -312,7 +312,7 @@ void cpu_loop(CPUX86State *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_ILL_ILLOPN; info.si_code = TARGET_ILL_ILLOPN;
info._sifields._sigfault._addr = env->eip; info._sifields._sigfault._addr = env->eip;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case EXCP_INTERRUPT: case EXCP_INTERRUPT:
/* just indicate that signals should be handled asap */ /* just indicate that signals should be handled asap */
@ -327,7 +327,7 @@ void cpu_loop(CPUX86State *env)
info.si_signo = sig; info.si_signo = sig;
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_TRAP_BRKPT; info.si_code = TARGET_TRAP_BRKPT;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
} }
break; break;
@ -441,7 +441,7 @@ void cpu_loop(CPUARMState *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_ILL_ILLOPN; info.si_code = TARGET_ILL_ILLOPN;
info._sifields._sigfault._addr = env->regs[15]; info._sifields._sigfault._addr = env->regs[15];
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} else if (rc < 0) { /* FP exception */ } else if (rc < 0) { /* FP exception */
int arm_fpe=0; int arm_fpe=0;
@ -472,7 +472,7 @@ void cpu_loop(CPUARMState *env)
if (arm_fpe & BIT_IOC) info.si_code = TARGET_FPE_FLTINV; if (arm_fpe & BIT_IOC) info.si_code = TARGET_FPE_FLTINV;
info._sifields._sigfault._addr = env->regs[15]; info._sifields._sigfault._addr = env->regs[15];
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} else { } else {
env->regs[15] += 4; env->regs[15] += 4;
} }
@ -584,7 +584,7 @@ void cpu_loop(CPUARMState *env)
/* XXX: check env->error_code */ /* XXX: check env->error_code */
info.si_code = TARGET_SEGV_MAPERR; info.si_code = TARGET_SEGV_MAPERR;
info._sifields._sigfault._addr = addr; info._sifields._sigfault._addr = addr;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
break; break;
case EXCP_DEBUG: case EXCP_DEBUG:
@ -597,7 +597,7 @@ void cpu_loop(CPUARMState *env)
info.si_signo = sig; info.si_signo = sig;
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_TRAP_BRKPT; info.si_code = TARGET_TRAP_BRKPT;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
} }
break; break;
@ -780,7 +780,7 @@ void cpu_loop (CPUSPARCState *env)
/* XXX: check env->error_code */ /* XXX: check env->error_code */
info.si_code = TARGET_SEGV_MAPERR; info.si_code = TARGET_SEGV_MAPERR;
info._sifields._sigfault._addr = env->mmuregs[4]; info._sifields._sigfault._addr = env->mmuregs[4];
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
break; break;
#else #else
@ -801,7 +801,7 @@ void cpu_loop (CPUSPARCState *env)
info._sifields._sigfault._addr = env->dmmuregs[4]; info._sifields._sigfault._addr = env->dmmuregs[4];
else else
info._sifields._sigfault._addr = env->tsptr->tpc; info._sifields._sigfault._addr = env->tsptr->tpc;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
break; break;
#ifndef TARGET_ABI32 #ifndef TARGET_ABI32
@ -828,7 +828,7 @@ void cpu_loop (CPUSPARCState *env)
info.si_signo = sig; info.si_signo = sig;
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_TRAP_BRKPT; info.si_code = TARGET_TRAP_BRKPT;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
} }
break; break;
@ -949,7 +949,7 @@ void cpu_loop(CPUPPCState *env)
break; break;
} }
info._sifields._sigfault._addr = env->nip; info._sifields._sigfault._addr = env->nip;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case POWERPC_EXCP_ISI: /* Instruction storage exception */ case POWERPC_EXCP_ISI: /* Instruction storage exception */
EXCP_DUMP(env, "Invalid instruction fetch: 0x\n" ADDRX "\n", EXCP_DUMP(env, "Invalid instruction fetch: 0x\n" ADDRX "\n",
@ -977,7 +977,7 @@ void cpu_loop(CPUPPCState *env)
break; break;
} }
info._sifields._sigfault._addr = env->nip - 4; info._sifields._sigfault._addr = env->nip - 4;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case POWERPC_EXCP_EXTERNAL: /* External input */ case POWERPC_EXCP_EXTERNAL: /* External input */
cpu_abort(env, "External interrupt while in user mode. " cpu_abort(env, "External interrupt while in user mode. "
@ -990,7 +990,7 @@ void cpu_loop(CPUPPCState *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_BUS_ADRALN; info.si_code = TARGET_BUS_ADRALN;
info._sifields._sigfault._addr = env->nip - 4; info._sifields._sigfault._addr = env->nip - 4;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case POWERPC_EXCP_PROGRAM: /* Program exception */ case POWERPC_EXCP_PROGRAM: /* Program exception */
/* XXX: check this */ /* XXX: check this */
@ -1083,7 +1083,7 @@ void cpu_loop(CPUPPCState *env)
break; break;
} }
info._sifields._sigfault._addr = env->nip - 4; info._sifields._sigfault._addr = env->nip - 4;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case POWERPC_EXCP_FPU: /* Floating-point unavailable exception */ case POWERPC_EXCP_FPU: /* Floating-point unavailable exception */
EXCP_DUMP(env, "No floating point allowed\n"); EXCP_DUMP(env, "No floating point allowed\n");
@ -1091,7 +1091,7 @@ void cpu_loop(CPUPPCState *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_ILL_COPROC; info.si_code = TARGET_ILL_COPROC;
info._sifields._sigfault._addr = env->nip - 4; info._sifields._sigfault._addr = env->nip - 4;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case POWERPC_EXCP_SYSCALL: /* System call exception */ case POWERPC_EXCP_SYSCALL: /* System call exception */
cpu_abort(env, "Syscall exception while in user mode. " cpu_abort(env, "Syscall exception while in user mode. "
@ -1103,7 +1103,7 @@ void cpu_loop(CPUPPCState *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_ILL_COPROC; info.si_code = TARGET_ILL_COPROC;
info._sifields._sigfault._addr = env->nip - 4; info._sifields._sigfault._addr = env->nip - 4;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case POWERPC_EXCP_DECR: /* Decrementer exception */ case POWERPC_EXCP_DECR: /* Decrementer exception */
cpu_abort(env, "Decrementer interrupt while in user mode. " cpu_abort(env, "Decrementer interrupt while in user mode. "
@ -1135,7 +1135,7 @@ void cpu_loop(CPUPPCState *env)
info.si_signo = sig; info.si_signo = sig;
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_TRAP_BRKPT; info.si_code = TARGET_TRAP_BRKPT;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
} }
break; break;
@ -1145,7 +1145,7 @@ void cpu_loop(CPUPPCState *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_ILL_COPROC; info.si_code = TARGET_ILL_COPROC;
info._sifields._sigfault._addr = env->nip - 4; info._sifields._sigfault._addr = env->nip - 4;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case POWERPC_EXCP_EFPDI: /* Embedded floating-point data IRQ */ case POWERPC_EXCP_EFPDI: /* Embedded floating-point data IRQ */
cpu_abort(env, "Embedded floating-point data IRQ not handled\n"); cpu_abort(env, "Embedded floating-point data IRQ not handled\n");
@ -1209,7 +1209,7 @@ void cpu_loop(CPUPPCState *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_ILL_COPROC; info.si_code = TARGET_ILL_COPROC;
info._sifields._sigfault._addr = env->nip - 4; info._sifields._sigfault._addr = env->nip - 4;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case POWERPC_EXCP_PIT: /* Programmable interval timer IRQ */ case POWERPC_EXCP_PIT: /* Programmable interval timer IRQ */
cpu_abort(env, "Programable interval timer interrupt " cpu_abort(env, "Programable interval timer interrupt "
@ -1685,7 +1685,7 @@ void cpu_loop(CPUMIPSState *env)
info.si_signo = TARGET_SIGILL; info.si_signo = TARGET_SIGILL;
info.si_errno = 0; info.si_errno = 0;
info.si_code = 0; info.si_code = 0;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case EXCP_INTERRUPT: case EXCP_INTERRUPT:
/* just indicate that signals should be handled asap */ /* just indicate that signals should be handled asap */
@ -1700,7 +1700,7 @@ void cpu_loop(CPUMIPSState *env)
info.si_signo = sig; info.si_signo = sig;
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_TRAP_BRKPT; info.si_code = TARGET_TRAP_BRKPT;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
} }
break; break;
@ -1751,7 +1751,7 @@ void cpu_loop (CPUState *env)
info.si_signo = sig; info.si_signo = sig;
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_TRAP_BRKPT; info.si_code = TARGET_TRAP_BRKPT;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
} }
break; break;
@ -1761,7 +1761,7 @@ void cpu_loop (CPUState *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_SEGV_MAPERR; info.si_code = TARGET_SEGV_MAPERR;
info._sifields._sigfault._addr = env->tea; info._sifields._sigfault._addr = env->tea;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
default: default:
@ -1790,7 +1790,7 @@ void cpu_loop (CPUState *env)
/* XXX: check env->error_code */ /* XXX: check env->error_code */
info.si_code = TARGET_SEGV_MAPERR; info.si_code = TARGET_SEGV_MAPERR;
info._sifields._sigfault._addr = env->pregs[PR_EDA]; info._sifields._sigfault._addr = env->pregs[PR_EDA];
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
break; break;
case EXCP_INTERRUPT: case EXCP_INTERRUPT:
@ -1818,7 +1818,7 @@ void cpu_loop (CPUState *env)
info.si_signo = sig; info.si_signo = sig;
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_TRAP_BRKPT; info.si_code = TARGET_TRAP_BRKPT;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
} }
break; break;
@ -1869,7 +1869,7 @@ void cpu_loop(CPUM68KState *env)
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_ILL_ILLOPN; info.si_code = TARGET_ILL_ILLOPN;
info._sifields._sigfault._addr = env->pc; info._sifields._sigfault._addr = env->pc;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
break; break;
case EXCP_TRAP0: case EXCP_TRAP0:
{ {
@ -1896,7 +1896,7 @@ void cpu_loop(CPUM68KState *env)
/* XXX: check env->error_code */ /* XXX: check env->error_code */
info.si_code = TARGET_SEGV_MAPERR; info.si_code = TARGET_SEGV_MAPERR;
info._sifields._sigfault._addr = env->mmu.ar; info._sifields._sigfault._addr = env->mmu.ar;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
break; break;
case EXCP_DEBUG: case EXCP_DEBUG:
@ -1909,7 +1909,7 @@ void cpu_loop(CPUM68KState *env)
info.si_signo = sig; info.si_signo = sig;
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_TRAP_BRKPT; info.si_code = TARGET_TRAP_BRKPT;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
} }
break; break;
@ -2000,7 +2000,7 @@ void cpu_loop (CPUState *env)
info.si_signo = sig; info.si_signo = sig;
info.si_errno = 0; info.si_errno = 0;
info.si_code = TARGET_TRAP_BRKPT; info.si_code = TARGET_TRAP_BRKPT;
queue_signal(info.si_signo, &info); queue_signal(env, info.si_signo, &info);
} }
} }
break; break;
@ -2047,8 +2047,18 @@ void usage(void)
/* XXX: currently only used for async signals (see signal.c) */ /* XXX: currently only used for async signals (see signal.c) */
CPUState *global_env; CPUState *global_env;
/* used to free thread contexts */ void init_task_state(TaskState *ts)
TaskState *first_task_state; {
int i;
memset(ts, 0, sizeof(TaskState));
ts->used = 1;
ts->first_free = ts->sigqueue_table;
for (i = 0; i < MAX_SIGQUEUE_SIZE - 1; i++) {
ts->sigqueue_table[i].next = &ts->sigqueue_table[i + 1];
}
ts->sigqueue_table[i].next = NULL;
}
int main(int argc, char **argv) int main(int argc, char **argv)
{ {
@ -2246,9 +2256,9 @@ int main(int argc, char **argv)
/* build Task State */ /* build Task State */
memset(ts, 0, sizeof(TaskState)); memset(ts, 0, sizeof(TaskState));
env->opaque = ts; init_task_state(ts);
ts->used = 1;
ts->info = info; ts->info = info;
env->opaque = ts;
env->user_mode_only = 1; env->user_mode_only = 1;
#if defined(TARGET_I386) #if defined(TARGET_I386)

View File

@ -82,6 +82,20 @@ struct vm86_saved_state {
#include "nwfpe/fpa11.h" #include "nwfpe/fpa11.h"
#endif #endif
#define MAX_SIGQUEUE_SIZE 1024
struct sigqueue {
struct sigqueue *next;
target_siginfo_t info;
};
struct emulated_sigtable {
int pending; /* true if signal is pending */
struct sigqueue *first;
struct sigqueue info; /* in order to always have memory for the
first signal, we put it here */
};
/* NOTE: we force a big alignment so that the stack stored after is /* NOTE: we force a big alignment so that the stack stored after is
aligned too */ aligned too */
typedef struct TaskState { typedef struct TaskState {
@ -109,10 +123,16 @@ typedef struct TaskState {
#endif #endif
int used; /* non zero if used */ int used; /* non zero if used */
struct image_info *info; struct image_info *info;
struct emulated_sigtable sigtab[TARGET_NSIG];
struct sigqueue sigqueue_table[MAX_SIGQUEUE_SIZE]; /* siginfo queue */
struct sigqueue *first_free; /* first free siginfo queue entry */
int signal_pending; /* non zero if a signal may be pending */
uint8_t stack[0]; uint8_t stack[0];
} __attribute__((aligned(16))) TaskState; } __attribute__((aligned(16))) TaskState;
extern TaskState *first_task_state; void init_task_state(TaskState *ts);
extern const char *qemu_uname_release; extern const char *qemu_uname_release;
/* ??? See if we can avoid exposing so much of the loader internals. */ /* ??? See if we can avoid exposing so much of the loader internals. */
@ -182,9 +202,9 @@ void print_syscall_ret(int num, abi_long arg1);
extern int do_strace; extern int do_strace;
/* signal.c */ /* signal.c */
void process_pending_signals(void *cpu_env); void process_pending_signals(CPUState *cpu_env);
void signal_init(void); void signal_init(void);
int queue_signal(int sig, target_siginfo_t *info); int queue_signal(CPUState *env, int sig, target_siginfo_t *info);
void host_to_target_siginfo(target_siginfo_t *tinfo, const siginfo_t *info); void host_to_target_siginfo(target_siginfo_t *tinfo, const siginfo_t *info);
void target_to_host_siginfo(siginfo_t *info, const target_siginfo_t *tinfo); void target_to_host_siginfo(siginfo_t *info, const target_siginfo_t *tinfo);
int target_to_host_signal(int sig); int target_to_host_signal(int sig);

View File

@ -31,31 +31,13 @@
//#define DEBUG_SIGNAL //#define DEBUG_SIGNAL
#define MAX_SIGQUEUE_SIZE 1024
struct sigqueue {
struct sigqueue *next;
target_siginfo_t info;
};
struct emulated_sigaction {
struct target_sigaction sa;
int pending; /* true if signal is pending */
struct sigqueue *first;
struct sigqueue info; /* in order to always have memory for the
first signal, we put it here */
};
struct target_sigaltstack target_sigaltstack_used = { struct target_sigaltstack target_sigaltstack_used = {
.ss_sp = 0, .ss_sp = 0,
.ss_size = 0, .ss_size = 0,
.ss_flags = TARGET_SS_DISABLE, .ss_flags = TARGET_SS_DISABLE,
}; };
static struct emulated_sigaction sigact_table[TARGET_NSIG]; static struct target_sigaction sigact_table[TARGET_NSIG];
static struct sigqueue sigqueue_table[MAX_SIGQUEUE_SIZE]; /* siginfo queue */
static struct sigqueue *first_free; /* first free siginfo queue entry */
static int signal_pending; /* non zero if a signal may be pending */
static void host_signal_handler(int host_signum, siginfo_t *info, static void host_signal_handler(int host_signum, siginfo_t *info,
void *puc); void *puc);
@ -96,6 +78,12 @@ static uint8_t host_to_target_signal_table[65] = {
[SIGPWR] = TARGET_SIGPWR, [SIGPWR] = TARGET_SIGPWR,
[SIGSYS] = TARGET_SIGSYS, [SIGSYS] = TARGET_SIGSYS,
/* next signals stay the same */ /* next signals stay the same */
/* Nasty hack: Reverse SIGRTMIN and SIGRTMAX to avoid overlap with
host libpthread signals. This assumes noone actually uses SIGRTMAX :-/
To fix this properly we need to do manual signal delivery multiplexed
over a single host signal. */
[__SIGRTMIN] = __SIGRTMAX,
[__SIGRTMAX] = __SIGRTMIN,
}; };
static uint8_t target_to_host_signal_table[65]; static uint8_t target_to_host_signal_table[65];
@ -278,7 +266,9 @@ void target_to_host_siginfo(siginfo_t *info, const target_siginfo_t *tinfo)
void signal_init(void) void signal_init(void)
{ {
struct sigaction act; struct sigaction act;
struct sigaction oact;
int i, j; int i, j;
int host_sig;
/* generate signal conversion tables */ /* generate signal conversion tables */
for(i = 1; i <= 64; i++) { for(i = 1; i <= 64; i++) {
@ -292,36 +282,45 @@ void signal_init(void)
/* set all host signal handlers. ALL signals are blocked during /* set all host signal handlers. ALL signals are blocked during
the handlers to serialize them. */ the handlers to serialize them. */
memset(sigact_table, 0, sizeof(sigact_table));
sigfillset(&act.sa_mask); sigfillset(&act.sa_mask);
act.sa_flags = SA_SIGINFO; act.sa_flags = SA_SIGINFO;
act.sa_sigaction = host_signal_handler; act.sa_sigaction = host_signal_handler;
for(i = 1; i < NSIG; i++) { for(i = 1; i <= TARGET_NSIG; i++) {
sigaction(i, &act, NULL); host_sig = target_to_host_signal(i);
sigaction(host_sig, NULL, &oact);
if (oact.sa_sigaction == (void *)SIG_IGN) {
sigact_table[i - 1]._sa_handler = TARGET_SIG_IGN;
} else if (oact.sa_sigaction == (void *)SIG_DFL) {
sigact_table[i - 1]._sa_handler = TARGET_SIG_DFL;
}
/* If there's already a handler installed then something has
gone horribly wrong, so don't even try to handle that case. */
/* Install some handlers for our own use. */
if (host_sig == SIGSEGV || host_sig == SIGBUS) {
sigaction(host_sig, &act, NULL);
}
} }
memset(sigact_table, 0, sizeof(sigact_table));
first_free = &sigqueue_table[0];
for(i = 0; i < MAX_SIGQUEUE_SIZE - 1; i++)
sigqueue_table[i].next = &sigqueue_table[i + 1];
sigqueue_table[MAX_SIGQUEUE_SIZE - 1].next = NULL;
} }
/* signal queue handling */ /* signal queue handling */
static inline struct sigqueue *alloc_sigqueue(void) static inline struct sigqueue *alloc_sigqueue(CPUState *env)
{ {
struct sigqueue *q = first_free; TaskState *ts = env->opaque;
struct sigqueue *q = ts->first_free;
if (!q) if (!q)
return NULL; return NULL;
first_free = q->next; ts->first_free = q->next;
return q; return q;
} }
static inline void free_sigqueue(struct sigqueue *q) static inline void free_sigqueue(CPUState *env, struct sigqueue *q)
{ {
q->next = first_free; TaskState *ts = env->opaque;
first_free = q; q->next = ts->first_free;
ts->first_free = q;
} }
/* abort execution with signal */ /* abort execution with signal */
@ -347,9 +346,10 @@ void __attribute((noreturn)) force_sig(int sig)
/* queue a signal so that it will be send to the virtual CPU as soon /* queue a signal so that it will be send to the virtual CPU as soon
as possible */ as possible */
int queue_signal(int sig, target_siginfo_t *info) int queue_signal(CPUState *env, int sig, target_siginfo_t *info)
{ {
struct emulated_sigaction *k; TaskState *ts = env->opaque;
struct emulated_sigtable *k;
struct sigqueue *q, **pq; struct sigqueue *q, **pq;
abi_ulong handler; abi_ulong handler;
@ -357,8 +357,8 @@ int queue_signal(int sig, target_siginfo_t *info)
fprintf(stderr, "queue_signal: sig=%d\n", fprintf(stderr, "queue_signal: sig=%d\n",
sig); sig);
#endif #endif
k = &sigact_table[sig - 1]; k = &ts->sigtab[sig - 1];
handler = k->sa._sa_handler; handler = sigact_table[sig - 1]._sa_handler;
if (handler == TARGET_SIG_DFL) { if (handler == TARGET_SIG_DFL) {
/* default handler : ignore some signal. The other are fatal */ /* default handler : ignore some signal. The other are fatal */
if (sig != TARGET_SIGCHLD && if (sig != TARGET_SIGCHLD &&
@ -386,7 +386,7 @@ int queue_signal(int sig, target_siginfo_t *info)
/* first signal */ /* first signal */
q = &k->info; q = &k->info;
} else { } else {
q = alloc_sigqueue(); q = alloc_sigqueue(env);
if (!q) if (!q)
return -EAGAIN; return -EAGAIN;
while (*pq != NULL) while (*pq != NULL)
@ -398,7 +398,7 @@ int queue_signal(int sig, target_siginfo_t *info)
q->next = NULL; q->next = NULL;
k->pending = 1; k->pending = 1;
/* signal that a new signal is pending */ /* signal that a new signal is pending */
signal_pending = 1; ts->signal_pending = 1;
return 1; /* indicates that the signal was queued */ return 1; /* indicates that the signal was queued */
} }
} }
@ -424,7 +424,7 @@ static void host_signal_handler(int host_signum, siginfo_t *info,
fprintf(stderr, "qemu: got signal %d\n", sig); fprintf(stderr, "qemu: got signal %d\n", sig);
#endif #endif
host_to_target_siginfo_noswap(&tinfo, info); host_to_target_siginfo_noswap(&tinfo, info);
if (queue_signal(sig, &tinfo) == 1) { if (queue_signal(global_env, sig, &tinfo) == 1) {
/* interrupt the virtual CPU as soon as possible */ /* interrupt the virtual CPU as soon as possible */
cpu_interrupt(global_env, CPU_INTERRUPT_EXIT); cpu_interrupt(global_env, CPU_INTERRUPT_EXIT);
} }
@ -496,7 +496,7 @@ out:
int do_sigaction(int sig, const struct target_sigaction *act, int do_sigaction(int sig, const struct target_sigaction *act,
struct target_sigaction *oact) struct target_sigaction *oact)
{ {
struct emulated_sigaction *k; struct target_sigaction *k;
struct sigaction act1; struct sigaction act1;
int host_sig; int host_sig;
int ret = 0; int ret = 0;
@ -509,34 +509,35 @@ int do_sigaction(int sig, const struct target_sigaction *act,
sig, (int)act, (int)oact); sig, (int)act, (int)oact);
#endif #endif
if (oact) { if (oact) {
oact->_sa_handler = tswapl(k->sa._sa_handler); oact->_sa_handler = tswapl(k->_sa_handler);
oact->sa_flags = tswapl(k->sa.sa_flags); oact->sa_flags = tswapl(k->sa_flags);
#if !defined(TARGET_MIPS) #if !defined(TARGET_MIPS)
oact->sa_restorer = tswapl(k->sa.sa_restorer); oact->sa_restorer = tswapl(k->sa_restorer);
#endif #endif
oact->sa_mask = k->sa.sa_mask; oact->sa_mask = k->sa_mask;
} }
if (act) { if (act) {
k->sa._sa_handler = tswapl(act->_sa_handler); /* FIXME: This is not threadsafe. */
k->sa.sa_flags = tswapl(act->sa_flags); k->_sa_handler = tswapl(act->_sa_handler);
k->sa_flags = tswapl(act->sa_flags);
#if !defined(TARGET_MIPS) #if !defined(TARGET_MIPS)
k->sa.sa_restorer = tswapl(act->sa_restorer); k->sa_restorer = tswapl(act->sa_restorer);
#endif #endif
k->sa.sa_mask = act->sa_mask; k->sa_mask = act->sa_mask;
/* we update the host linux signal state */ /* we update the host linux signal state */
host_sig = target_to_host_signal(sig); host_sig = target_to_host_signal(sig);
if (host_sig != SIGSEGV && host_sig != SIGBUS) { if (host_sig != SIGSEGV && host_sig != SIGBUS) {
sigfillset(&act1.sa_mask); sigfillset(&act1.sa_mask);
act1.sa_flags = SA_SIGINFO; act1.sa_flags = SA_SIGINFO;
if (k->sa.sa_flags & TARGET_SA_RESTART) if (k->sa_flags & TARGET_SA_RESTART)
act1.sa_flags |= SA_RESTART; act1.sa_flags |= SA_RESTART;
/* NOTE: it is important to update the host kernel signal /* NOTE: it is important to update the host kernel signal
ignore state to avoid getting unexpected interrupted ignore state to avoid getting unexpected interrupted
syscalls */ syscalls */
if (k->sa._sa_handler == TARGET_SIG_IGN) { if (k->_sa_handler == TARGET_SIG_IGN) {
act1.sa_sigaction = (void *)SIG_IGN; act1.sa_sigaction = (void *)SIG_IGN;
} else if (k->sa._sa_handler == TARGET_SIG_DFL) { } else if (k->_sa_handler == TARGET_SIG_DFL) {
act1.sa_sigaction = (void *)SIG_DFL; act1.sa_sigaction = (void *)SIG_DFL;
} else { } else {
act1.sa_sigaction = host_signal_handler; act1.sa_sigaction = host_signal_handler;
@ -712,14 +713,14 @@ setup_sigcontext(struct target_sigcontext *sc, struct target_fpstate *fpstate,
*/ */
static inline abi_ulong static inline abi_ulong
get_sigframe(struct emulated_sigaction *ka, CPUX86State *env, size_t frame_size) get_sigframe(struct target_sigaction *ka, CPUX86State *env, size_t frame_size)
{ {
unsigned long esp; unsigned long esp;
/* Default to using normal stack */ /* Default to using normal stack */
esp = env->regs[R_ESP]; esp = env->regs[R_ESP];
/* This is the X/Open sanctioned signal stack switching. */ /* This is the X/Open sanctioned signal stack switching. */
if (ka->sa.sa_flags & TARGET_SA_ONSTACK) { if (ka->sa_flags & TARGET_SA_ONSTACK) {
if (sas_ss_flags(esp) == 0) if (sas_ss_flags(esp) == 0)
esp = target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size; esp = target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size;
} }
@ -727,15 +728,15 @@ get_sigframe(struct emulated_sigaction *ka, CPUX86State *env, size_t frame_size)
/* This is the legacy signal stack switching. */ /* This is the legacy signal stack switching. */
else else
if ((env->segs[R_SS].selector & 0xffff) != __USER_DS && if ((env->segs[R_SS].selector & 0xffff) != __USER_DS &&
!(ka->sa.sa_flags & TARGET_SA_RESTORER) && !(ka->sa_flags & TARGET_SA_RESTORER) &&
ka->sa.sa_restorer) { ka->sa_restorer) {
esp = (unsigned long) ka->sa.sa_restorer; esp = (unsigned long) ka->sa_restorer;
} }
return (esp - frame_size) & -8ul; return (esp - frame_size) & -8ul;
} }
/* compare linux/arch/i386/kernel/signal.c:setup_frame() */ /* compare linux/arch/i386/kernel/signal.c:setup_frame() */
static void setup_frame(int sig, struct emulated_sigaction *ka, static void setup_frame(int sig, struct target_sigaction *ka,
target_sigset_t *set, CPUX86State *env) target_sigset_t *set, CPUX86State *env)
{ {
abi_ulong frame_addr; abi_ulong frame_addr;
@ -764,8 +765,8 @@ static void setup_frame(int sig, struct emulated_sigaction *ka,
/* Set up to return from userspace. If provided, use a stub /* Set up to return from userspace. If provided, use a stub
already in userspace. */ already in userspace. */
if (ka->sa.sa_flags & TARGET_SA_RESTORER) { if (ka->sa_flags & TARGET_SA_RESTORER) {
err |= __put_user(ka->sa.sa_restorer, &frame->pretcode); err |= __put_user(ka->sa_restorer, &frame->pretcode);
} else { } else {
uint16_t val16; uint16_t val16;
abi_ulong retcode_addr; abi_ulong retcode_addr;
@ -784,7 +785,7 @@ static void setup_frame(int sig, struct emulated_sigaction *ka,
/* Set up registers for signal handler */ /* Set up registers for signal handler */
env->regs[R_ESP] = frame_addr; env->regs[R_ESP] = frame_addr;
env->eip = ka->sa._sa_handler; env->eip = ka->_sa_handler;
cpu_x86_load_seg(env, R_DS, __USER_DS); cpu_x86_load_seg(env, R_DS, __USER_DS);
cpu_x86_load_seg(env, R_ES, __USER_DS); cpu_x86_load_seg(env, R_ES, __USER_DS);
@ -799,12 +800,12 @@ static void setup_frame(int sig, struct emulated_sigaction *ka,
give_sigsegv: give_sigsegv:
unlock_user_struct(frame, frame_addr, 1); unlock_user_struct(frame, frame_addr, 1);
if (sig == TARGET_SIGSEGV) if (sig == TARGET_SIGSEGV)
ka->sa._sa_handler = TARGET_SIG_DFL; ka->_sa_handler = TARGET_SIG_DFL;
force_sig(TARGET_SIGSEGV /* , current */); force_sig(TARGET_SIGSEGV /* , current */);
} }
/* compare linux/arch/i386/kernel/signal.c:setup_rt_frame() */ /* compare linux/arch/i386/kernel/signal.c:setup_rt_frame() */
static void setup_rt_frame(int sig, struct emulated_sigaction *ka, static void setup_rt_frame(int sig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUX86State *env) target_sigset_t *set, CPUX86State *env)
{ {
@ -846,8 +847,8 @@ static void setup_rt_frame(int sig, struct emulated_sigaction *ka,
/* Set up to return from userspace. If provided, use a stub /* Set up to return from userspace. If provided, use a stub
already in userspace. */ already in userspace. */
if (ka->sa.sa_flags & TARGET_SA_RESTORER) { if (ka->sa_flags & TARGET_SA_RESTORER) {
err |= __put_user(ka->sa.sa_restorer, &frame->pretcode); err |= __put_user(ka->sa_restorer, &frame->pretcode);
} else { } else {
uint16_t val16; uint16_t val16;
addr = frame_addr + offsetof(struct rt_sigframe, retcode); addr = frame_addr + offsetof(struct rt_sigframe, retcode);
@ -864,7 +865,7 @@ static void setup_rt_frame(int sig, struct emulated_sigaction *ka,
/* Set up registers for signal handler */ /* Set up registers for signal handler */
env->regs[R_ESP] = frame_addr; env->regs[R_ESP] = frame_addr;
env->eip = ka->sa._sa_handler; env->eip = ka->_sa_handler;
cpu_x86_load_seg(env, R_DS, __USER_DS); cpu_x86_load_seg(env, R_DS, __USER_DS);
cpu_x86_load_seg(env, R_ES, __USER_DS); cpu_x86_load_seg(env, R_ES, __USER_DS);
@ -879,7 +880,7 @@ static void setup_rt_frame(int sig, struct emulated_sigaction *ka,
give_sigsegv: give_sigsegv:
unlock_user_struct(frame, frame_addr, 1); unlock_user_struct(frame, frame_addr, 1);
if (sig == TARGET_SIGSEGV) if (sig == TARGET_SIGSEGV)
ka->sa._sa_handler = TARGET_SIG_DFL; ka->_sa_handler = TARGET_SIG_DFL;
force_sig(TARGET_SIGSEGV /* , current */); force_sig(TARGET_SIGSEGV /* , current */);
} }
@ -1122,14 +1123,14 @@ setup_sigcontext(struct target_sigcontext *sc, /*struct _fpstate *fpstate,*/
} }
static inline abi_ulong static inline abi_ulong
get_sigframe(struct emulated_sigaction *ka, CPUState *regs, int framesize) get_sigframe(struct target_sigaction *ka, CPUState *regs, int framesize)
{ {
unsigned long sp = regs->regs[13]; unsigned long sp = regs->regs[13];
/* /*
* This is the X/Open sanctioned signal stack switching. * This is the X/Open sanctioned signal stack switching.
*/ */
if ((ka->sa.sa_flags & TARGET_SA_ONSTACK) && !sas_ss_flags(sp)) if ((ka->sa_flags & TARGET_SA_ONSTACK) && !sas_ss_flags(sp))
sp = target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size; sp = target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size;
/* /*
* ATPCS B01 mandates 8-byte alignment * ATPCS B01 mandates 8-byte alignment
@ -1138,19 +1139,19 @@ get_sigframe(struct emulated_sigaction *ka, CPUState *regs, int framesize)
} }
static int static int
setup_return(CPUState *env, struct emulated_sigaction *ka, setup_return(CPUState *env, struct target_sigaction *ka,
abi_ulong *rc, abi_ulong frame_addr, int usig, abi_ulong rc_addr) abi_ulong *rc, abi_ulong frame_addr, int usig, abi_ulong rc_addr)
{ {
abi_ulong handler = ka->sa._sa_handler; abi_ulong handler = ka->_sa_handler;
abi_ulong retcode; abi_ulong retcode;
int thumb = handler & 1; int thumb = handler & 1;
if (ka->sa.sa_flags & TARGET_SA_RESTORER) { if (ka->sa_flags & TARGET_SA_RESTORER) {
retcode = ka->sa.sa_restorer; retcode = ka->sa_restorer;
} else { } else {
unsigned int idx = thumb; unsigned int idx = thumb;
if (ka->sa.sa_flags & TARGET_SA_SIGINFO) if (ka->sa_flags & TARGET_SA_SIGINFO)
idx += 2; idx += 2;
if (__put_user(retcodes[idx], rc)) if (__put_user(retcodes[idx], rc))
@ -1200,7 +1201,7 @@ static void setup_sigframe_v2(struct target_ucontext_v2 *uc,
} }
/* compare linux/arch/arm/kernel/signal.c:setup_frame() */ /* compare linux/arch/arm/kernel/signal.c:setup_frame() */
static void setup_frame_v1(int usig, struct emulated_sigaction *ka, static void setup_frame_v1(int usig, struct target_sigaction *ka,
target_sigset_t *set, CPUState *regs) target_sigset_t *set, CPUState *regs)
{ {
struct sigframe_v1 *frame; struct sigframe_v1 *frame;
@ -1224,7 +1225,7 @@ end:
unlock_user_struct(frame, frame_addr, 1); unlock_user_struct(frame, frame_addr, 1);
} }
static void setup_frame_v2(int usig, struct emulated_sigaction *ka, static void setup_frame_v2(int usig, struct target_sigaction *ka,
target_sigset_t *set, CPUState *regs) target_sigset_t *set, CPUState *regs)
{ {
struct sigframe_v2 *frame; struct sigframe_v2 *frame;
@ -1241,7 +1242,7 @@ static void setup_frame_v2(int usig, struct emulated_sigaction *ka,
unlock_user_struct(frame, frame_addr, 1); unlock_user_struct(frame, frame_addr, 1);
} }
static void setup_frame(int usig, struct emulated_sigaction *ka, static void setup_frame(int usig, struct target_sigaction *ka,
target_sigset_t *set, CPUState *regs) target_sigset_t *set, CPUState *regs)
{ {
if (get_osversion() >= 0x020612) { if (get_osversion() >= 0x020612) {
@ -1252,7 +1253,7 @@ static void setup_frame(int usig, struct emulated_sigaction *ka,
} }
/* compare linux/arch/arm/kernel/signal.c:setup_rt_frame() */ /* compare linux/arch/arm/kernel/signal.c:setup_rt_frame() */
static void setup_rt_frame_v1(int usig, struct emulated_sigaction *ka, static void setup_rt_frame_v1(int usig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
@ -1296,7 +1297,7 @@ end:
unlock_user_struct(frame, frame_addr, 1); unlock_user_struct(frame, frame_addr, 1);
} }
static void setup_rt_frame_v2(int usig, struct emulated_sigaction *ka, static void setup_rt_frame_v2(int usig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
@ -1322,7 +1323,7 @@ static void setup_rt_frame_v2(int usig, struct emulated_sigaction *ka,
unlock_user_struct(frame, frame_addr, 1); unlock_user_struct(frame, frame_addr, 1);
} }
static void setup_rt_frame(int usig, struct emulated_sigaction *ka, static void setup_rt_frame(int usig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
@ -1650,7 +1651,7 @@ struct target_rt_signal_frame {
#define UREG_FP UREG_I6 #define UREG_FP UREG_I6
#define UREG_SP UREG_O6 #define UREG_SP UREG_O6
static inline abi_ulong get_sigframe(struct emulated_sigaction *sa, static inline abi_ulong get_sigframe(struct target_sigaction *sa,
CPUState *env, unsigned long framesize) CPUState *env, unsigned long framesize)
{ {
abi_ulong sp; abi_ulong sp;
@ -1658,7 +1659,7 @@ static inline abi_ulong get_sigframe(struct emulated_sigaction *sa,
sp = env->regwptr[UREG_FP]; sp = env->regwptr[UREG_FP];
/* This is the X/Open sanctioned signal stack switching. */ /* This is the X/Open sanctioned signal stack switching. */
if (sa->sa.sa_flags & TARGET_SA_ONSTACK) { if (sa->sa_flags & TARGET_SA_ONSTACK) {
if (!on_sig_stack(sp) if (!on_sig_stack(sp)
&& !((target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size) & 7)) && !((target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size) & 7))
sp = target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size; sp = target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size;
@ -1705,7 +1706,7 @@ setup_sigcontext(struct target_sigcontext *sc, /*struct _fpstate *fpstate,*/
#endif #endif
#define NF_ALIGNEDSZ (((sizeof(struct target_signal_frame) + 7) & (~7))) #define NF_ALIGNEDSZ (((sizeof(struct target_signal_frame) + 7) & (~7)))
static void setup_frame(int sig, struct emulated_sigaction *ka, static void setup_frame(int sig, struct target_sigaction *ka,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
abi_ulong sf_addr; abi_ulong sf_addr;
@ -1758,11 +1759,11 @@ static void setup_frame(int sig, struct emulated_sigaction *ka,
offsetof(struct target_signal_frame, info); offsetof(struct target_signal_frame, info);
/* 4. signal handler */ /* 4. signal handler */
env->pc = ka->sa._sa_handler; env->pc = ka->_sa_handler;
env->npc = (env->pc + 4); env->npc = (env->pc + 4);
/* 5. return to kernel instructions */ /* 5. return to kernel instructions */
if (ka->sa.sa_restorer) if (ka->sa_restorer)
env->regwptr[UREG_I7] = ka->sa.sa_restorer; env->regwptr[UREG_I7] = ka->sa_restorer;
else { else {
uint32_t val32; uint32_t val32;
@ -1834,7 +1835,7 @@ restore_fpu_state(CPUState *env, qemu_siginfo_fpu_t *fpu)
} }
static void setup_rt_frame(int sig, struct emulated_sigaction *ka, static void setup_rt_frame(int sig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
@ -2182,13 +2183,13 @@ void sparc64_get_context(CPUSPARCState *env)
# warning signal handling not implemented # warning signal handling not implemented
static void setup_frame(int sig, struct emulated_sigaction *ka, static void setup_frame(int sig, struct target_sigaction *ka,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
fprintf(stderr, "setup_frame: not implemented\n"); fprintf(stderr, "setup_frame: not implemented\n");
} }
static void setup_rt_frame(int sig, struct emulated_sigaction *ka, static void setup_rt_frame(int sig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
@ -2211,13 +2212,13 @@ long do_rt_sigreturn(CPUState *env)
# warning signal handling not implemented # warning signal handling not implemented
static void setup_frame(int sig, struct emulated_sigaction *ka, static void setup_frame(int sig, struct target_sigaction *ka,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
fprintf(stderr, "setup_frame: not implemented\n"); fprintf(stderr, "setup_frame: not implemented\n");
} }
static void setup_rt_frame(int sig, struct emulated_sigaction *ka, static void setup_rt_frame(int sig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
@ -2431,7 +2432,7 @@ restore_sigcontext(CPUState *regs, struct target_sigcontext *sc)
* Determine which stack to use.. * Determine which stack to use..
*/ */
static inline abi_ulong static inline abi_ulong
get_sigframe(struct emulated_sigaction *ka, CPUState *regs, size_t frame_size) get_sigframe(struct target_sigaction *ka, CPUState *regs, size_t frame_size)
{ {
unsigned long sp; unsigned long sp;
@ -2446,7 +2447,7 @@ get_sigframe(struct emulated_sigaction *ka, CPUState *regs, size_t frame_size)
sp -= 32; sp -= 32;
/* This is the X/Open sanctioned signal stack switching. */ /* This is the X/Open sanctioned signal stack switching. */
if ((ka->sa.sa_flags & TARGET_SA_ONSTACK) && (sas_ss_flags (sp) == 0)) { if ((ka->sa_flags & TARGET_SA_ONSTACK) && (sas_ss_flags (sp) == 0)) {
sp = target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size; sp = target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size;
} }
@ -2454,7 +2455,7 @@ get_sigframe(struct emulated_sigaction *ka, CPUState *regs, size_t frame_size)
} }
/* compare linux/arch/mips/kernel/signal.c:setup_frame() */ /* compare linux/arch/mips/kernel/signal.c:setup_frame() */
static void setup_frame(int sig, struct emulated_sigaction * ka, static void setup_frame(int sig, struct target_sigaction * ka,
target_sigset_t *set, CPUState *regs) target_sigset_t *set, CPUState *regs)
{ {
struct sigframe *frame; struct sigframe *frame;
@ -2493,7 +2494,7 @@ static void setup_frame(int sig, struct emulated_sigaction * ka,
/* The original kernel code sets CP0_EPC to the handler /* The original kernel code sets CP0_EPC to the handler
* since it returns to userland using eret * since it returns to userland using eret
* we cannot do this here, and we must set PC directly */ * we cannot do this here, and we must set PC directly */
regs->PC[regs->current_tc] = regs->gpr[regs->current_tc][25] = ka->sa._sa_handler; regs->PC[regs->current_tc] = regs->gpr[regs->current_tc][25] = ka->_sa_handler;
unlock_user_struct(frame, frame_addr, 1); unlock_user_struct(frame, frame_addr, 1);
return; return;
@ -2552,7 +2553,7 @@ badframe:
return 0; return 0;
} }
static void setup_rt_frame(int sig, struct emulated_sigaction *ka, static void setup_rt_frame(int sig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
@ -2620,10 +2621,10 @@ struct target_rt_sigframe
#define MOVW(n) (0x9300|((n)-2)) /* Move mem word at PC+n to R3 */ #define MOVW(n) (0x9300|((n)-2)) /* Move mem word at PC+n to R3 */
#define TRAP_NOARG 0xc310 /* Syscall w/no args (NR in R3) SH3/4 */ #define TRAP_NOARG 0xc310 /* Syscall w/no args (NR in R3) SH3/4 */
static abi_ulong get_sigframe(struct emulated_sigaction *ka, static abi_ulong get_sigframe(struct target_sigaction *ka,
unsigned long sp, size_t frame_size) unsigned long sp, size_t frame_size)
{ {
if ((ka->sa.sa_flags & TARGET_SA_ONSTACK) && (sas_ss_flags(sp) == 0)) { if ((ka->sa_flags & TARGET_SA_ONSTACK) && (sas_ss_flags(sp) == 0)) {
sp = target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size; sp = target_sigaltstack_used.ss_sp + target_sigaltstack_used.ss_size;
} }
@ -2682,7 +2683,7 @@ static int restore_sigcontext(struct CPUState *regs,
return err; return err;
} }
static void setup_frame(int sig, struct emulated_sigaction *ka, static void setup_frame(int sig, struct target_sigaction *ka,
target_sigset_t *set, CPUState *regs) target_sigset_t *set, CPUState *regs)
{ {
struct target_sigframe *frame; struct target_sigframe *frame;
@ -2705,8 +2706,8 @@ static void setup_frame(int sig, struct emulated_sigaction *ka,
/* Set up to return from userspace. If provided, use a stub /* Set up to return from userspace. If provided, use a stub
already in userspace. */ already in userspace. */
if (ka->sa.sa_flags & TARGET_SA_RESTORER) { if (ka->sa_flags & TARGET_SA_RESTORER) {
regs->pr = (unsigned long) ka->sa.sa_restorer; regs->pr = (unsigned long) ka->sa_restorer;
} else { } else {
/* Generate return code (system call to sigreturn) */ /* Generate return code (system call to sigreturn) */
err |= __put_user(MOVW(2), &frame->retcode[0]); err |= __put_user(MOVW(2), &frame->retcode[0]);
@ -2723,7 +2724,7 @@ static void setup_frame(int sig, struct emulated_sigaction *ka,
regs->gregs[4] = signal; /* Arg for signal handler */ regs->gregs[4] = signal; /* Arg for signal handler */
regs->gregs[5] = 0; regs->gregs[5] = 0;
regs->gregs[6] = (unsigned long) &frame->sc; regs->gregs[6] = (unsigned long) &frame->sc;
regs->pc = (unsigned long) ka->sa._sa_handler; regs->pc = (unsigned long) ka->_sa_handler;
unlock_user_struct(frame, frame_addr, 1); unlock_user_struct(frame, frame_addr, 1);
return; return;
@ -2733,7 +2734,7 @@ give_sigsegv:
force_sig(SIGSEGV); force_sig(SIGSEGV);
} }
static void setup_rt_frame(int sig, struct emulated_sigaction *ka, static void setup_rt_frame(int sig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUState *regs) target_sigset_t *set, CPUState *regs)
{ {
@ -2768,8 +2769,8 @@ static void setup_rt_frame(int sig, struct emulated_sigaction *ka,
/* Set up to return from userspace. If provided, use a stub /* Set up to return from userspace. If provided, use a stub
already in userspace. */ already in userspace. */
if (ka->sa.sa_flags & TARGET_SA_RESTORER) { if (ka->sa_flags & TARGET_SA_RESTORER) {
regs->pr = (unsigned long) ka->sa.sa_restorer; regs->pr = (unsigned long) ka->sa_restorer;
} else { } else {
/* Generate return code (system call to sigreturn) */ /* Generate return code (system call to sigreturn) */
err |= __put_user(MOVW(2), &frame->retcode[0]); err |= __put_user(MOVW(2), &frame->retcode[0]);
@ -2786,7 +2787,7 @@ static void setup_rt_frame(int sig, struct emulated_sigaction *ka,
regs->gregs[4] = signal; /* Arg for signal handler */ regs->gregs[4] = signal; /* Arg for signal handler */
regs->gregs[5] = (unsigned long) &frame->info; regs->gregs[5] = (unsigned long) &frame->info;
regs->gregs[6] = (unsigned long) &frame->uc; regs->gregs[6] = (unsigned long) &frame->uc;
regs->pc = (unsigned long) ka->sa._sa_handler; regs->pc = (unsigned long) ka->_sa_handler;
unlock_user_struct(frame, frame_addr, 1); unlock_user_struct(frame, frame_addr, 1);
return; return;
@ -2944,7 +2945,7 @@ static abi_ulong get_sigframe(CPUState *env, int framesize)
return sp - framesize; return sp - framesize;
} }
static void setup_frame(int sig, struct emulated_sigaction *ka, static void setup_frame(int sig, struct target_sigaction *ka,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
struct target_signal_frame *frame; struct target_signal_frame *frame;
@ -2983,7 +2984,7 @@ static void setup_frame(int sig, struct emulated_sigaction *ka,
/* Move the stack and setup the arguments for the handler. */ /* Move the stack and setup the arguments for the handler. */
env->regs[R_SP] = (uint32_t) frame; env->regs[R_SP] = (uint32_t) frame;
env->regs[10] = sig; env->regs[10] = sig;
env->pc = (unsigned long) ka->sa._sa_handler; env->pc = (unsigned long) ka->_sa_handler;
/* Link SRP so the guest returns through the trampoline. */ /* Link SRP so the guest returns through the trampoline. */
env->pregs[PR_SRP] = (uint32_t) &frame->retcode[0]; env->pregs[PR_SRP] = (uint32_t) &frame->retcode[0];
@ -2994,7 +2995,7 @@ static void setup_frame(int sig, struct emulated_sigaction *ka,
force_sig(TARGET_SIGSEGV); force_sig(TARGET_SIGSEGV);
} }
static void setup_rt_frame(int sig, struct emulated_sigaction *ka, static void setup_rt_frame(int sig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
@ -3043,13 +3044,13 @@ long do_rt_sigreturn(CPUState *env)
#else #else
static void setup_frame(int sig, struct emulated_sigaction *ka, static void setup_frame(int sig, struct target_sigaction *ka,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
fprintf(stderr, "setup_frame: not implemented\n"); fprintf(stderr, "setup_frame: not implemented\n");
} }
static void setup_rt_frame(int sig, struct emulated_sigaction *ka, static void setup_rt_frame(int sig, struct target_sigaction *ka,
target_siginfo_t *info, target_siginfo_t *info,
target_sigset_t *set, CPUState *env) target_sigset_t *set, CPUState *env)
{ {
@ -3070,26 +3071,29 @@ long do_rt_sigreturn(CPUState *env)
#endif #endif
void process_pending_signals(void *cpu_env) void process_pending_signals(CPUState *cpu_env)
{ {
int sig; int sig;
abi_ulong handler; abi_ulong handler;
sigset_t set, old_set; sigset_t set, old_set;
target_sigset_t target_old_set; target_sigset_t target_old_set;
struct emulated_sigaction *k; struct emulated_sigtable *k;
struct target_sigaction *sa;
struct sigqueue *q; struct sigqueue *q;
TaskState *ts = cpu_env->opaque;
if (!signal_pending) if (!ts->signal_pending)
return; return;
k = sigact_table; /* FIXME: This is not threadsafe. */
k = ts->sigtab;
for(sig = 1; sig <= TARGET_NSIG; sig++) { for(sig = 1; sig <= TARGET_NSIG; sig++) {
if (k->pending) if (k->pending)
goto handle_signal; goto handle_signal;
k++; k++;
} }
/* if no signal is pending, just return */ /* if no signal is pending, just return */
signal_pending = 0; ts->signal_pending = 0;
return; return;
handle_signal: handle_signal:
@ -3108,7 +3112,8 @@ void process_pending_signals(void *cpu_env)
abort(); abort();
} }
handler = k->sa._sa_handler; sa = &sigact_table[sig - 1];
handler = sa->_sa_handler;
if (handler == TARGET_SIG_DFL) { if (handler == TARGET_SIG_DFL) {
/* default handler : ignore some signal. The other are fatal */ /* default handler : ignore some signal. The other are fatal */
if (sig != TARGET_SIGCHLD && if (sig != TARGET_SIGCHLD &&
@ -3122,10 +3127,10 @@ void process_pending_signals(void *cpu_env)
force_sig(sig); force_sig(sig);
} else { } else {
/* compute the blocked signals during the handler execution */ /* compute the blocked signals during the handler execution */
target_to_host_sigset(&set, &k->sa.sa_mask); target_to_host_sigset(&set, &sa->sa_mask);
/* SA_NODEFER indicates that the current signal should not be /* SA_NODEFER indicates that the current signal should not be
blocked during the handler */ blocked during the handler */
if (!(k->sa.sa_flags & TARGET_SA_NODEFER)) if (!(sa->sa_flags & TARGET_SA_NODEFER))
sigaddset(&set, target_to_host_signal(sig)); sigaddset(&set, target_to_host_signal(sig));
/* block signals in the handler using Linux */ /* block signals in the handler using Linux */
@ -3143,13 +3148,13 @@ void process_pending_signals(void *cpu_env)
} }
#endif #endif
/* prepare the stack frame of the virtual CPU */ /* prepare the stack frame of the virtual CPU */
if (k->sa.sa_flags & TARGET_SA_SIGINFO) if (sa->sa_flags & TARGET_SA_SIGINFO)
setup_rt_frame(sig, k, &q->info, &target_old_set, cpu_env); setup_rt_frame(sig, sa, &q->info, &target_old_set, cpu_env);
else else
setup_frame(sig, k, &target_old_set, cpu_env); setup_frame(sig, sa, &target_old_set, cpu_env);
if (k->sa.sa_flags & TARGET_SA_RESETHAND) if (sa->sa_flags & TARGET_SA_RESETHAND)
k->sa._sa_handler = TARGET_SIG_DFL; sa->_sa_handler = TARGET_SIG_DFL;
} }
if (q != &k->info) if (q != &k->info)
free_sigqueue(q); free_sigqueue(cpu_env, q);
} }

View File

@ -2736,12 +2736,8 @@ int do_fork(CPUState *env, unsigned int flags, abi_ulong newsp)
} }
#endif #endif
ts = malloc(sizeof(TaskState) + NEW_STACK_SIZE); ts = malloc(sizeof(TaskState) + NEW_STACK_SIZE);
memset(ts, 0, sizeof(TaskState)); init_task_state(ts);
new_stack = ts->stack; new_stack = ts->stack;
ts->used = 1;
/* add in task state list */
ts->next = first_task_state;
first_task_state = ts;
/* we create a new CPU instance. */ /* we create a new CPU instance. */
new_env = cpu_copy(env); new_env = cpu_copy(env);
/* Init regs that differ from the parent. */ /* Init regs that differ from the parent. */