blob: 06874c07571645b48aa694f1af0e2153af46fda4 [file] [log] [blame]
/* Test cancellation of a door_return call. */
#include <assert.h>
#include <door.h>
#include <errno.h>
#include <pthread.h>
#include <signal.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/lwp.h>
#include <unistd.h>
static volatile lwpid_t server_lwpid = 0;
static void server_procedure(void *cookie, char *argp, size_t arg_size,
door_desc_t *dp, uint_t n_desc)
{
assert(0);
}
static void *my_server_thread(void *arg)
{
server_lwpid = _lwp_self();
door_return(NULL, 0, NULL, 0);
return NULL;
}
static void create_door_thread(door_info_t *info)
{
static int called = 0;
pthread_t thread;
int res;
/* Allow to create only one server door thread. */
assert(!called);
called = 1;
res = pthread_create(&thread, NULL, my_server_thread, NULL);
if (res) {
errno = res;
perror("pthread_create");
exit(1);
}
}
static void signal_handler(int signo, siginfo_t *info, void *uc)
{
const char str[] = "Signal caught.\n";
size_t len = sizeof(str) - 1;
ssize_t res;
res = write(STDOUT_FILENO, str, len);
assert(res == len);
}
int main(void)
{
int res = 1;
int did = -1;
struct sigaction sa;
sa.sa_sigaction = signal_handler;
sa.sa_flags = SA_RESTART;
if (sigfillset(&sa.sa_mask)) {
perror("sigfillset");
return 1;
}
if (sigaction(SIGINT, &sa, NULL)) {
perror("sigaction");
return 1;
}
door_server_create(create_door_thread);
if ((did = door_create(server_procedure, NULL, 0)) < 0) {
perror("door_create");
return 1;
}
/* Let the server thread to run. */
sleep(2);
/* Send a signal to the server thread that should be already created and
blocked in door_return. */
if (_lwp_kill(server_lwpid, SIGINT)) {
perror("_lwp_kill");
goto out;
}
/* Let the other thread to run. */
sleep(2);
res = 0;
out:
if (did >= 0 && door_revoke(did))
perror("door_revoke");
return res;
}