util/oslib-posix.c

   1 /*
   2  * os-posix-lib.c
   3  *
   4  * Copyright (c) 2003-2008 Fabrice Bellard
   5  * Copyright (c) 2010 Red Hat, Inc.
   6  *
   7  * QEMU library functions on POSIX which are shared between QEMU and
   8  * the QEMU tools.
   9  *
  10  * Permission is hereby granted, free of charge, to any person obtaining a copy
  11  * of this software and associated documentation files (the "Software"), to deal
  12  * in the Software without restriction, including without limitation the rights
  13  * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
  14  * copies of the Software, and to permit persons to whom the Software is
  15  * furnished to do so, subject to the following conditions:
  16  *
  17  * The above copyright notice and this permission notice shall be included in
  18  * all copies or substantial portions of the Software.
  19  *
  20  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
  21  * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
  22  * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
  23  * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
  24  * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
  25  * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
  26  * THE SOFTWARE.
  27  */
  28
  29 #include "qemu/osdep.h"
  30 #include <termios.h>
  31
  32 #include <glib/gprintf.h>
  33
  34 #include "sysemu/sysemu.h"
  35 #include "trace.h"
  36 #include "qapi/error.h"
  37 #include "qemu/sockets.h"
  38 #include <libgen.h>
  39 #include <sys/signal.h>
  40 #include "qemu/cutils.h"
  41
  42 #ifdef CONFIG_LINUX
  43 #include <sys/syscall.h>
  44 #endif
  45
  46 #ifdef __FreeBSD__
  47 #include <sys/sysctl.h>
  48 #include <sys/user.h>
  49 #include <libutil.h>
  50 #endif
  51
  52 #ifdef __NetBSD__
  53 #include <sys/sysctl.h>
  54 #endif
  55
  56 #include "qemu/mmap-alloc.h"
  57
  58 #ifdef CONFIG_DEBUG_STACK_USAGE
  59 #include "qemu/error-report.h"
  60 #endif
  61
  62 #define MAX_MEM_PREALLOC_THREAD_COUNT 16
  63
  64 struct MemsetThread {
  65     char *addr;
  66     size_t numpages;
  67     size_t hpagesize;
  68     QemuThread pgthread;
  69     sigjmp_buf env;
  70 };
  71 typedef struct MemsetThread MemsetThread;
  72
  73 static MemsetThread *memset_thread;
  74 static int memset_num_threads;
  75 static bool memset_thread_failed;
  76
  77 int qemu_get_thread_id(void)
  78 {
  79 #if defined(__linux__)
  80     return syscall(SYS_gettid);
  81 #else
  82     return getpid();
  83 #endif
  84 }
  85
  86 int qemu_daemon(int nochdir, int noclose)
  87 {
  88     return daemon(nochdir, noclose);
  89 }
  90
  91 bool qemu_write_pidfile(const char *path, Error **errp)
  92 {
  93     int fd;
  94     char pidstr[32];
  95
  96     while (1) {
  97         struct stat a, b;
  98         struct flock lock = {
  99             .l_type = F_WRLCK,
 100             .l_whence = SEEK_SET,
 101             .l_len = 0,
 102         };
 103
 104         fd = qemu_open(path, O_CREAT | O_WRONLY, S_IRUSR | S_IWUSR);
 105         if (fd == -1) {
 106             error_setg_errno(errp, errno, "Cannot open pid file");
 107             return false;
 108         }
 109
 110         if (fstat(fd, &b) < 0) {
 111             error_setg_errno(errp, errno, "Cannot stat file");
 112             goto fail_close;
 113         }
 114
 115         if (fcntl(fd, F_SETLK, &lock)) {
 116             error_setg_errno(errp, errno, "Cannot lock pid file");
 117             goto fail_close;
 118         }
 119
 120         /*
 121          * Now make sure the path we locked is the same one that now
 122          * exists on the filesystem.
 123          */
 124         if (stat(path, &a) < 0) {
 125             /*
 126              * PID file disappeared, someone else must be racing with
 127              * us, so try again.
 128              */
 129             close(fd);
 130             continue;
 131         }
 132
 133         if (a.st_ino == b.st_ino) {
 134             break;
 135         }
 136
 137         /*
 138          * PID file was recreated, someone else must be racing with
 139          * us, so try again.
 140          */
 141         close(fd);
 142     }
 143
 144     if (ftruncate(fd, 0) < 0) {
 145         error_setg_errno(errp, errno, "Failed to truncate pid file");
 146         goto fail_unlink;
 147     }
 148
 149     snprintf(pidstr, sizeof(pidstr), FMT_pid "\n", getpid());
 150     if (write(fd, pidstr, strlen(pidstr)) != strlen(pidstr)) {
 151         error_setg(errp, "Failed to write pid file");
 152         goto fail_unlink;
 153     }
 154
 155     return true;
 156
 157 fail_unlink:
 158     unlink(path);
 159 fail_close:
 160     close(fd);
 161     return false;
 162 }
 163
 164 void *qemu_oom_check(void *ptr)
 165 {
 166     if (ptr == NULL) {
 167         fprintf(stderr, "Failed to allocate memory: %s\n", strerror(errno));
 168         abort();
 169     }
 170     return ptr;
 171 }
 172
 173 void *qemu_try_memalign(size_t alignment, size_t size)
 174 {
 175     void *ptr;
 176
 177     if (alignment < sizeof(void*)) {
 178         alignment = sizeof(void*);
 179     }
 180
 181 #if defined(CONFIG_POSIX_MEMALIGN)
 182     int ret;
 183     ret = posix_memalign(&ptr, alignment, size);
 184     if (ret != 0) {
 185         errno = ret;
 186         ptr = NULL;
 187     }
 188 #elif defined(CONFIG_BSD)
 189     ptr = valloc(size);
 190 #else
 191     ptr = memalign(alignment, size);
 192 #endif
 193     trace_qemu_memalign(alignment, size, ptr);
 194     return ptr;
 195 }
 196
 197 void *qemu_memalign(size_t alignment, size_t size)
 198 {
 199     return qemu_oom_check(qemu_try_memalign(alignment, size));
 200 }
 201
 202 /* alloc shared memory pages */
 203 void *qemu_anon_ram_alloc(size_t size, uint64_t *alignment, bool shared)
 204 {
 205     size_t align = QEMU_VMALLOC_ALIGN;
 206     void *ptr = qemu_ram_mmap(-1, size, align, shared);
 207
 208     if (ptr == MAP_FAILED) {
 209         return NULL;
 210     }
 211
 212     if (alignment) {
 213         *alignment = align;
 214     }
 215
 216     trace_qemu_anon_ram_alloc(size, ptr);
 217     return ptr;
 218 }
 219
 220 void qemu_vfree(void *ptr)
 221 {
 222     trace_qemu_vfree(ptr);
 223     free(ptr);
 224 }
 225
 226 void qemu_anon_ram_free(void *ptr, size_t size)
 227 {
 228     trace_qemu_anon_ram_free(ptr, size);
 229     qemu_ram_munmap(-1, ptr, size);
 230 }
 231
 232 void qemu_set_block(int fd)
 233 {
 234     int f;
 235     f = fcntl(fd, F_GETFL);
 236     assert(f != -1);
 237     f = fcntl(fd, F_SETFL, f & ~O_NONBLOCK);
 238     assert(f != -1);
 239 }
 240
 241 void qemu_set_nonblock(int fd)
 242 {
 243     int f;
 244     f = fcntl(fd, F_GETFL);
 245     assert(f != -1);
 246     f = fcntl(fd, F_SETFL, f | O_NONBLOCK);
 247     assert(f != -1);
 248 }
 249
 250 int socket_set_fast_reuse(int fd)
 251 {
 252     int val = 1, ret;
 253
 254     ret = setsockopt(fd, SOL_SOCKET, SO_REUSEADDR,
 255                      (const char *)&val, sizeof(val));
 256
 257     assert(ret == 0);
 258
 259     return ret;
 260 }
 261
 262 void qemu_set_cloexec(int fd)
 263 {
 264     int f;
 265     f = fcntl(fd, F_GETFD);
 266     assert(f != -1);
 267     f = fcntl(fd, F_SETFD, f | FD_CLOEXEC);
 268     assert(f != -1);
 269 }
 270
 271 /*
 272  * Creates a pipe with FD_CLOEXEC set on both file descriptors
 273  */
 274 int qemu_pipe(int pipefd[2])
 275 {
 276     int ret;
 277
 278 #ifdef CONFIG_PIPE2
 279     ret = pipe2(pipefd, O_CLOEXEC);
 280     if (ret != -1 || errno != ENOSYS) {
 281         return ret;
 282     }
 283 #endif
 284     ret = pipe(pipefd);
 285     if (ret == 0) {
 286         qemu_set_cloexec(pipefd[0]);
 287         qemu_set_cloexec(pipefd[1]);
 288     }
 289
 290     return ret;
 291 }
 292
 293 char *
 294 qemu_get_local_state_pathname(const char *relative_pathname)
 295 {
 296     return g_strdup_printf("%s/%s", CONFIG_QEMU_LOCALSTATEDIR,
 297                            relative_pathname);
 298 }
 299
 300 void qemu_set_tty_echo(int fd, bool echo)
 301 {
 302     struct termios tty;
 303
 304     tcgetattr(fd, &tty);
 305
 306     if (echo) {
 307         tty.c_lflag |= ECHO | ECHONL | ICANON | IEXTEN;
 308     } else {
 309         tty.c_lflag &= ~(ECHO | ECHONL | ICANON | IEXTEN);
 310     }
 311
 312     tcsetattr(fd, TCSANOW, &tty);
 313 }
 314
 315 static char exec_dir[PATH_MAX];
 316
 317 void qemu_init_exec_dir(const char *argv0)
 318 {
 319     char *dir;
 320     char *p = NULL;
 321     char buf[PATH_MAX];
 322
 323     assert(!exec_dir[0]);
 324
 325 #if defined(__linux__)
 326     {
 327         int len;
 328         len = readlink("/proc/self/exe", buf, sizeof(buf) - 1);
 329         if (len > 0) {
 330             buf[len] = 0;
 331             p = buf;
 332         }
 333     }
 334 #elif defined(__FreeBSD__) \
 335       || (defined(__NetBSD__) && defined(KERN_PROC_PATHNAME))
 336     {
 337 #if defined(__FreeBSD__)
 338         static int mib[4] = {CTL_KERN, KERN_PROC, KERN_PROC_PATHNAME, -1};
 339 #else
 340         static int mib[4] = {CTL_KERN, KERN_PROC_ARGS, -1, KERN_PROC_PATHNAME};
 341 #endif
 342         size_t len = sizeof(buf) - 1;
 343
 344         *buf = '\0';
 345         if (!sysctl(mib, ARRAY_SIZE(mib), buf, &len, NULL, 0) &&
 346             *buf) {
 347             buf[sizeof(buf) - 1] = '\0';
 348             p = buf;
 349         }
 350     }
 351 #endif
 352     /* If we don't have any way of figuring out the actual executable
 353        location then try argv[0].  */
 354     if (!p) {
 355         if (!argv0) {
 356             return;
 357         }
 358         p = realpath(argv0, buf);
 359         if (!p) {
 360             return;
 361         }
 362     }
 363     dir = g_path_get_dirname(p);
 364
 365     pstrcpy(exec_dir, sizeof(exec_dir), dir);
 366
 367     g_free(dir);
 368 }
 369
 370 char *qemu_get_exec_dir(void)
 371 {
 372     return g_strdup(exec_dir);
 373 }
 374
 375 static void sigbus_handler(int signal)
 376 {
 377     int i;
 378     if (memset_thread) {
 379         for (i = 0; i < memset_num_threads; i++) {
 380             if (qemu_thread_is_self(&memset_thread[i].pgthread)) {
 381                 siglongjmp(memset_thread[i].env, 1);
 382             }
 383         }
 384     }
 385 }
 386
 387 static void *do_touch_pages(void *arg)
 388 {
 389     MemsetThread *memset_args = (MemsetThread *)arg;
 390     sigset_t set, oldset;
 391
 392     /* unblock SIGBUS */
 393     sigemptyset(&set);
 394     sigaddset(&set, SIGBUS);
 395     pthread_sigmask(SIG_UNBLOCK, &set, &oldset);
 396
 397     if (sigsetjmp(memset_args->env, 1)) {
 398         memset_thread_failed = true;
 399     } else {
 400         char *addr = memset_args->addr;
 401         size_t numpages = memset_args->numpages;
 402         size_t hpagesize = memset_args->hpagesize;
 403         size_t i;
 404         for (i = 0; i < numpages; i++) {
 405             /*
 406              * Read & write back the same value, so we don't
 407              * corrupt existing user/app data that might be
 408              * stored.
 409              *
 410              * 'volatile' to stop compiler optimizing this away
 411              * to a no-op
 412              *
 413              * TODO: get a better solution from kernel so we
 414              * don't need to write at all so we don't cause
 415              * wear on the storage backing the region...
 416              */
 417             *(volatile char *)addr = *addr;
 418             addr += hpagesize;
 419         }
 420     }
 421     pthread_sigmask(SIG_SETMASK, &oldset, NULL);
 422     return NULL;
 423 }
 424
 425 static inline int get_memset_num_threads(int smp_cpus)
 426 {
 427     long host_procs = sysconf(_SC_NPROCESSORS_ONLN);
 428     int ret = 1;
 429
 430     if (host_procs > 0) {
 431         ret = MIN(MIN(host_procs, MAX_MEM_PREALLOC_THREAD_COUNT), smp_cpus);
 432     }
 433     /* In case sysconf() fails, we fall back to single threaded */
 434     return ret;
 435 }
 436
 437 static bool touch_all_pages(char *area, size_t hpagesize, size_t numpages,
 438                             int smp_cpus)
 439 {
 440     size_t numpages_per_thread;
 441     size_t size_per_thread;
 442     char *addr = area;
 443     int i = 0;
 444
 445     memset_thread_failed = false;
 446     memset_num_threads = get_memset_num_threads(smp_cpus);
 447     memset_thread = g_new0(MemsetThread, memset_num_threads);
 448     numpages_per_thread = (numpages / memset_num_threads);
 449     size_per_thread = (hpagesize * numpages_per_thread);
 450     for (i = 0; i < memset_num_threads; i++) {
 451         memset_thread[i].addr = addr;
 452         memset_thread[i].numpages = (i == (memset_num_threads - 1)) ?
 453                                     numpages : numpages_per_thread;
 454         memset_thread[i].hpagesize = hpagesize;
 455         qemu_thread_create(&memset_thread[i].pgthread, "touch_pages",
 456                            do_touch_pages, &memset_thread[i],
 457                            QEMU_THREAD_JOINABLE);
 458         addr += size_per_thread;
 459         numpages -= numpages_per_thread;
 460     }
 461     for (i = 0; i < memset_num_threads; i++) {
 462         qemu_thread_join(&memset_thread[i].pgthread);
 463     }
 464     g_free(memset_thread);
 465     memset_thread = NULL;
 466
 467     return memset_thread_failed;
 468 }
 469
 470 void os_mem_prealloc(int fd, char *area, size_t memory, int smp_cpus,
 471                      Error **errp)
 472 {
 473     int ret;
 474     struct sigaction act, oldact;
 475     size_t hpagesize = qemu_fd_getpagesize(fd);
 476     size_t numpages = DIV_ROUND_UP(memory, hpagesize);
 477
 478     memset(&act, 0, sizeof(act));
 479     act.sa_handler = &sigbus_handler;
 480     act.sa_flags = 0;
 481
 482     ret = sigaction(SIGBUS, &act, &oldact);
 483     if (ret) {
 484         error_setg_errno(errp, errno,
 485             "os_mem_prealloc: failed to install signal handler");
 486         return;
 487     }
 488
 489     /* touch pages simultaneously */
 490     if (touch_all_pages(area, hpagesize, numpages, smp_cpus)) {
 491         error_setg(errp, "os_mem_prealloc: Insufficient free host memory "
 492             "pages available to allocate guest RAM");
 493     }
 494
 495     ret = sigaction(SIGBUS, &oldact, NULL);
 496     if (ret) {
 497         /* Terminate QEMU since it can't recover from error */
 498         perror("os_mem_prealloc: failed to reinstall signal handler");
 499         exit(1);
 500     }
 501 }
 502
 503 uint64_t qemu_get_pmem_size(const char *filename, Error **errp)
 504 {
 505     struct stat st;
 506
 507     if (stat(filename, &st) < 0) {
 508         error_setg(errp, "unable to stat pmem file \"%s\"", filename);
 509         return 0;
 510     }
 511
 512 #if defined(__linux__)
 513     /* Special handling for devdax character devices */
 514     if (S_ISCHR(st.st_mode)) {
 515         char *subsystem_path = NULL;
 516         char *subsystem = NULL;
 517         char *size_path = NULL;
 518         char *size_str = NULL;
 519         uint64_t ret = 0;
 520
 521         subsystem_path = g_strdup_printf("/sys/dev/char/%d:%d/subsystem",
 522                                          major(st.st_rdev), minor(st.st_rdev));
 523         subsystem = g_file_read_link(subsystem_path, NULL);
 524         if (!subsystem) {
 525             error_setg(errp, "unable to read subsystem for pmem file \"%s\"",
 526                        filename);
 527             goto devdax_err;
 528         }
 529
 530         if (!g_str_has_suffix(subsystem, "/dax")) {
 531             error_setg(errp, "pmem file \"%s\" is not a dax device", filename);
 532             goto devdax_err;
 533         }
 534
 535         size_path = g_strdup_printf("/sys/dev/char/%d:%d/size",
 536                                     major(st.st_rdev), minor(st.st_rdev));
 537         if (!g_file_get_contents(size_path, &size_str, NULL, NULL)) {
 538             error_setg(errp, "unable to read size for pmem file \"%s\"",
 539                        size_path);
 540             goto devdax_err;
 541         }
 542
 543         ret = g_ascii_strtoull(size_str, NULL, 0);
 544
 545 devdax_err:
 546         g_free(size_str);
 547         g_free(size_path);
 548         g_free(subsystem);
 549         g_free(subsystem_path);
 550         return ret;
 551     }
 552 #endif /* defined(__linux__) */
 553
 554     return st.st_size;
 555 }
 556
 557 char *qemu_get_pid_name(pid_t pid)
 558 {
 559     char *name = NULL;
 560
 561 #if defined(__FreeBSD__)
 562     /* BSDs don't have /proc, but they provide a nice substitute */
 563     struct kinfo_proc *proc = kinfo_getproc(pid);
 564
 565     if (proc) {
 566         name = g_strdup(proc->ki_comm);
 567         free(proc);
 568     }
 569 #else
 570     /* Assume a system with reasonable procfs */
 571     char *pid_path;
 572     size_t len;
 573
 574     pid_path = g_strdup_printf("/proc/%d/cmdline", pid);
 575     g_file_get_contents(pid_path, &name, &len, NULL);
 576     g_free(pid_path);
 577 #endif
 578
 579     return name;
 580 }
 581
 582
 583 pid_t qemu_fork(Error **errp)
 584 {
 585     sigset_t oldmask, newmask;
 586     struct sigaction sig_action;
 587     int saved_errno;
 588     pid_t pid;
 589
 590     /*
 591      * Need to block signals now, so that child process can safely
 592      * kill off caller's signal handlers without a race.
 593      */
 594     sigfillset(&newmask);
 595     if (pthread_sigmask(SIG_SETMASK, &newmask, &oldmask) != 0) {
 596         error_setg_errno(errp, errno,
 597                          "cannot block signals");
 598         return -1;
 599     }
 600
 601     pid = fork();
 602     saved_errno = errno;
 603
 604     if (pid < 0) {
 605         /* attempt to restore signal mask, but ignore failure, to
 606          * avoid obscuring the fork failure */
 607         (void)pthread_sigmask(SIG_SETMASK, &oldmask, NULL);
 608         error_setg_errno(errp, saved_errno,
 609                          "cannot fork child process");
 610         errno = saved_errno;
 611         return -1;
 612     } else if (pid) {
 613         /* parent process */
 614
 615         /* Restore our original signal mask now that the child is
 616          * safely running. Only documented failures are EFAULT (not
 617          * possible, since we are using just-grabbed mask) or EINVAL
 618          * (not possible, since we are using correct arguments).  */
 619         (void)pthread_sigmask(SIG_SETMASK, &oldmask, NULL);
 620     } else {
 621         /* child process */
 622         size_t i;
 623
 624         /* Clear out all signal handlers from parent so nothing
 625          * unexpected can happen in our child once we unblock
 626          * signals */
 627         sig_action.sa_handler = SIG_DFL;
 628         sig_action.sa_flags = 0;
 629         sigemptyset(&sig_action.sa_mask);
 630
 631         for (i = 1; i < NSIG; i++) {
 632             /* Only possible errors are EFAULT or EINVAL The former
 633              * won't happen, the latter we expect, so no need to check
 634              * return value */
 635             (void)sigaction(i, &sig_action, NULL);
 636         }
 637
 638         /* Unmask all signals in child, since we've no idea what the
 639          * caller's done with their signal mask and don't want to
 640          * propagate that to children */
 641         sigemptyset(&newmask);
 642         if (pthread_sigmask(SIG_SETMASK, &newmask, NULL) != 0) {
 643             Error *local_err = NULL;
 644             error_setg_errno(&local_err, errno,
 645                              "cannot unblock signals");
 646             error_report_err(local_err);
 647             _exit(1);
 648         }
 649     }
 650     return pid;
 651 }
 652
 653 void *qemu_alloc_stack(size_t *sz)
 654 {
 655     void *ptr, *guardpage;
 656     int flags;
 657 #ifdef CONFIG_DEBUG_STACK_USAGE
 658     void *ptr2;
 659 #endif
 660     size_t pagesz = getpagesize();
 661 #ifdef _SC_THREAD_STACK_MIN
 662     /* avoid stacks smaller than _SC_THREAD_STACK_MIN */
 663     long min_stack_sz = sysconf(_SC_THREAD_STACK_MIN);
 664     *sz = MAX(MAX(min_stack_sz, 0), *sz);
 665 #endif
 666     /* adjust stack size to a multiple of the page size */
 667     *sz = ROUND_UP(*sz, pagesz);
 668     /* allocate one extra page for the guard page */
 669     *sz += pagesz;
 670
 671     flags = MAP_PRIVATE | MAP_ANONYMOUS;
 672 #if defined(MAP_STACK) && defined(__OpenBSD__)
 673     /* Only enable MAP_STACK on OpenBSD. Other OS's such as
 674      * Linux/FreeBSD/NetBSD have a flag with the same name
 675      * but have differing functionality. OpenBSD will SEGV
 676      * if it spots execution with a stack pointer pointing
 677      * at memory that was not allocated with MAP_STACK.
 678      */
 679     flags |= MAP_STACK;
 680 #endif
 681
 682     ptr = mmap(NULL, *sz, PROT_READ | PROT_WRITE, flags, -1, 0);
 683     if (ptr == MAP_FAILED) {
 684         perror("failed to allocate memory for stack");
 685         abort();
 686     }
 687
 688 #if defined(HOST_IA64)
 689     /* separate register stack */
 690     guardpage = ptr + (((*sz - pagesz) / 2) & ~pagesz);
 691 #elif defined(HOST_HPPA)
 692     /* stack grows up */
 693     guardpage = ptr + *sz - pagesz;
 694 #else
 695     /* stack grows down */
 696     guardpage = ptr;
 697 #endif
 698     if (mprotect(guardpage, pagesz, PROT_NONE) != 0) {
 699         perror("failed to set up stack guard page");
 700         abort();
 701     }
 702
 703 #ifdef CONFIG_DEBUG_STACK_USAGE
 704     for (ptr2 = ptr + pagesz; ptr2 < ptr + *sz; ptr2 += sizeof(uint32_t)) {
 705         *(uint32_t *)ptr2 = 0xdeadbeaf;
 706     }
 707 #endif
 708
 709     return ptr;
 710 }
 711
 712 #ifdef CONFIG_DEBUG_STACK_USAGE
 713 static __thread unsigned int max_stack_usage;
 714 #endif
 715
 716 void qemu_free_stack(void *stack, size_t sz)
 717 {
 718 #ifdef CONFIG_DEBUG_STACK_USAGE
 719     unsigned int usage;
 720     void *ptr;
 721
 722     for (ptr = stack + getpagesize(); ptr < stack + sz;
 723          ptr += sizeof(uint32_t)) {
 724         if (*(uint32_t *)ptr != 0xdeadbeaf) {
 725             break;
 726         }
 727     }
 728     usage = sz - (uintptr_t) (ptr - stack);
 729     if (usage > max_stack_usage) {
 730         error_report("thread %d max stack usage increased from %u to %u",
 731                      qemu_get_thread_id(), max_stack_usage, usage);
 732         max_stack_usage = usage;
 733     }
 734 #endif
 735
 736     munmap(stack, sz);
 737 }
 738
 739 void sigaction_invoke(struct sigaction *action,
 740                       struct qemu_signalfd_siginfo *info)
 741 {
 742     siginfo_t si = {};
 743     si.si_signo = info->ssi_signo;
 744     si.si_errno = info->ssi_errno;
 745     si.si_code = info->ssi_code;
 746
 747     /* Convert the minimal set of fields defined by POSIX.
 748      * Positive si_code values are reserved for kernel-generated
 749      * signals, where the valid siginfo fields are determined by
 750      * the signal number.  But according to POSIX, it is unspecified
 751      * whether SI_USER and SI_QUEUE have values less than or equal to
 752      * zero.
 753      */
 754     if (info->ssi_code == SI_USER || info->ssi_code == SI_QUEUE ||
 755         info->ssi_code <= 0) {
 756         /* SIGTERM, etc.  */
 757         si.si_pid = info->ssi_pid;
 758         si.si_uid = info->ssi_uid;
 759     } else if (info->ssi_signo == SIGILL || info->ssi_signo == SIGFPE ||
 760                info->ssi_signo == SIGSEGV || info->ssi_signo == SIGBUS) {
 761         si.si_addr = (void *)(uintptr_t)info->ssi_addr;
 762     } else if (info->ssi_signo == SIGCHLD) {
 763         si.si_pid = info->ssi_pid;
 764         si.si_status = info->ssi_status;
 765         si.si_uid = info->ssi_uid;
 766     }
 767     action->sa_sigaction(info->ssi_signo, &si, NULL);
 768 }