// https://syzkaller.appspot.com/bug?id=b7f47b0e7250ea0af4ffab28d62cf36f6a70f502 // autogenerated by syzkaller (https://github.com/google/syzkaller) #define _GNU_SOURCE #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #include #ifndef __NR_close_range #define __NR_close_range 436 #endif #ifndef __NR_io_uring_setup #define __NR_io_uring_setup 425 #endif static unsigned long long procid; static void sleep_ms(uint64_t ms) { usleep(ms * 1000); } static uint64_t current_time_ms(void) { struct timespec ts; if (clock_gettime(CLOCK_MONOTONIC, &ts)) exit(1); return (uint64_t)ts.tv_sec * 1000 + (uint64_t)ts.tv_nsec / 1000000; } static void thread_start(void* (*fn)(void*), void* arg) { pthread_t th; pthread_attr_t attr; pthread_attr_init(&attr); pthread_attr_setstacksize(&attr, 128 << 10); int i = 0; for (; i < 100; i++) { if (pthread_create(&th, &attr, fn, arg) == 0) { pthread_attr_destroy(&attr); return; } if (errno == EAGAIN) { usleep(50); continue; } break; } exit(1); } typedef struct { int state; } event_t; static void event_init(event_t* ev) { ev->state = 0; } static void event_reset(event_t* ev) { ev->state = 0; } static void event_set(event_t* ev) { if (ev->state) exit(1); __atomic_store_n(&ev->state, 1, __ATOMIC_RELEASE); syscall(SYS_futex, &ev->state, FUTEX_WAKE | FUTEX_PRIVATE_FLAG, 1000000); } static void event_wait(event_t* ev) { while (!__atomic_load_n(&ev->state, __ATOMIC_ACQUIRE)) syscall(SYS_futex, &ev->state, FUTEX_WAIT | FUTEX_PRIVATE_FLAG, 0, 0); } static int event_isset(event_t* ev) { return __atomic_load_n(&ev->state, __ATOMIC_ACQUIRE); } static int event_timedwait(event_t* ev, uint64_t timeout) { uint64_t start = current_time_ms(); uint64_t now = start; for (;;) { uint64_t remain = timeout - (now - start); struct timespec ts; ts.tv_sec = remain / 1000; ts.tv_nsec = (remain % 1000) * 1000 * 1000; syscall(SYS_futex, &ev->state, FUTEX_WAIT | FUTEX_PRIVATE_FLAG, 0, &ts); if (__atomic_load_n(&ev->state, __ATOMIC_ACQUIRE)) return 1; now = current_time_ms(); if (now - start > timeout) return 0; } } static bool write_file(const char* file, const char* what, ...) { char buf[1024]; va_list args; va_start(args, what); vsnprintf(buf, sizeof(buf), what, args); va_end(args); buf[sizeof(buf) - 1] = 0; int len = strlen(buf); int fd = open(file, O_WRONLY | O_CLOEXEC); if (fd == -1) return false; if (write(fd, buf, len) != len) { int err = errno; close(fd); errno = err; return false; } close(fd); return true; } struct nlmsg { char* pos; int nesting; struct nlattr* nested[8]; char buf[4096]; }; static void netlink_init(struct nlmsg* nlmsg, int typ, int flags, const void* data, int size) { memset(nlmsg, 0, sizeof(*nlmsg)); struct nlmsghdr* hdr = (struct nlmsghdr*)nlmsg->buf; hdr->nlmsg_type = typ; hdr->nlmsg_flags = NLM_F_REQUEST | NLM_F_ACK | flags; memcpy(hdr + 1, data, size); nlmsg->pos = (char*)(hdr + 1) + NLMSG_ALIGN(size); } static void netlink_attr(struct nlmsg* nlmsg, int typ, const void* data, int size) { struct nlattr* attr = (struct nlattr*)nlmsg->pos; attr->nla_len = sizeof(*attr) + size; attr->nla_type = typ; if (size > 0) memcpy(attr + 1, data, size); nlmsg->pos += NLMSG_ALIGN(attr->nla_len); } static void netlink_nest(struct nlmsg* nlmsg, int typ) { struct nlattr* attr = (struct nlattr*)nlmsg->pos; attr->nla_type = typ; nlmsg->pos += sizeof(*attr); nlmsg->nested[nlmsg->nesting++] = attr; } static void netlink_done(struct nlmsg* nlmsg) { struct nlattr* attr = nlmsg->nested[--nlmsg->nesting]; attr->nla_len = nlmsg->pos - (char*)attr; } static int netlink_send_ext(struct nlmsg* nlmsg, int sock, uint16_t reply_type, int* reply_len, bool dofail) { if (nlmsg->pos > nlmsg->buf + sizeof(nlmsg->buf) || nlmsg->nesting) exit(1); struct nlmsghdr* hdr = (struct nlmsghdr*)nlmsg->buf; hdr->nlmsg_len = nlmsg->pos - nlmsg->buf; struct sockaddr_nl addr; memset(&addr, 0, sizeof(addr)); addr.nl_family = AF_NETLINK; ssize_t n = sendto(sock, nlmsg->buf, hdr->nlmsg_len, 0, (struct sockaddr*)&addr, sizeof(addr)); if (n != (ssize_t)hdr->nlmsg_len) { if (dofail) exit(1); return -1; } n = recv(sock, nlmsg->buf, sizeof(nlmsg->buf), 0); if (reply_len) *reply_len = 0; if (n < 0) { if (dofail) exit(1); return -1; } if (n < (ssize_t)sizeof(struct nlmsghdr)) { errno = EINVAL; if (dofail) exit(1); return -1; } if (hdr->nlmsg_type == NLMSG_DONE) return 0; if (reply_len && hdr->nlmsg_type == reply_type) { *reply_len = n; return 0; } if (n < (ssize_t)(sizeof(struct nlmsghdr) + sizeof(struct nlmsgerr))) { errno = EINVAL; if (dofail) exit(1); return -1; } if (hdr->nlmsg_type != NLMSG_ERROR) { errno = EINVAL; if (dofail) exit(1); return -1; } errno = -((struct nlmsgerr*)(hdr + 1))->error; return -errno; } static int netlink_send(struct nlmsg* nlmsg, int sock) { return netlink_send_ext(nlmsg, sock, 0, NULL, true); } static int netlink_query_family_id(struct nlmsg* nlmsg, int sock, const char* family_name, bool dofail) { struct genlmsghdr genlhdr; memset(&genlhdr, 0, sizeof(genlhdr)); genlhdr.cmd = CTRL_CMD_GETFAMILY; netlink_init(nlmsg, GENL_ID_CTRL, 0, &genlhdr, sizeof(genlhdr)); netlink_attr(nlmsg, CTRL_ATTR_FAMILY_NAME, family_name, strnlen(family_name, GENL_NAMSIZ - 1) + 1); int n = 0; int err = netlink_send_ext(nlmsg, sock, GENL_ID_CTRL, &n, dofail); if (err < 0) { return -1; } uint16_t id = 0; struct nlattr* attr = (struct nlattr*)(nlmsg->buf + NLMSG_HDRLEN + NLMSG_ALIGN(sizeof(genlhdr))); for (; (char*)attr < nlmsg->buf + n; attr = (struct nlattr*)((char*)attr + NLMSG_ALIGN(attr->nla_len))) { if (attr->nla_type == CTRL_ATTR_FAMILY_ID) { id = *(uint16_t*)(attr + 1); break; } } if (!id) { errno = EINVAL; return -1; } recv(sock, nlmsg->buf, sizeof(nlmsg->buf), 0); return id; } static unsigned int queue_count = 2; static void netlink_add_device_impl(struct nlmsg* nlmsg, const char* type, const char* name, bool up) { struct ifinfomsg hdr; memset(&hdr, 0, sizeof(hdr)); if (up) hdr.ifi_flags = hdr.ifi_change = IFF_UP; netlink_init(nlmsg, RTM_NEWLINK, NLM_F_EXCL | NLM_F_CREATE, &hdr, sizeof(hdr)); if (name) netlink_attr(nlmsg, IFLA_IFNAME, name, strlen(name)); netlink_attr(nlmsg, IFLA_NUM_TX_QUEUES, &queue_count, sizeof(queue_count)); netlink_attr(nlmsg, IFLA_NUM_RX_QUEUES, &queue_count, sizeof(queue_count)); netlink_nest(nlmsg, IFLA_LINKINFO); netlink_attr(nlmsg, IFLA_INFO_KIND, type, strlen(type)); } static void netlink_device_change(struct nlmsg* nlmsg, int sock, const char* name, bool up, const char* master, const void* mac, int macsize, const char* new_name) { struct ifinfomsg hdr; memset(&hdr, 0, sizeof(hdr)); if (up) hdr.ifi_flags = hdr.ifi_change = IFF_UP; hdr.ifi_index = if_nametoindex(name); netlink_init(nlmsg, RTM_NEWLINK, 0, &hdr, sizeof(hdr)); if (new_name) netlink_attr(nlmsg, IFLA_IFNAME, new_name, strlen(new_name)); if (master) { int ifindex = if_nametoindex(master); netlink_attr(nlmsg, IFLA_MASTER, &ifindex, sizeof(ifindex)); } if (macsize) netlink_attr(nlmsg, IFLA_ADDRESS, mac, macsize); int err = netlink_send(nlmsg, sock); if (err < 0) { } } static struct nlmsg nlmsg; static long syz_genetlink_get_family_id(volatile long name, volatile long sock_arg) { int fd = sock_arg; if (fd < 0) { fd = socket(AF_NETLINK, SOCK_RAW, NETLINK_GENERIC); if (fd == -1) { return -1; } } struct nlmsg nlmsg_tmp; int ret = netlink_query_family_id(&nlmsg_tmp, fd, (char*)name, false); if ((int)sock_arg < 0) close(fd); if (ret < 0) { return -1; } return ret; } static void kill_and_wait(int pid, int* status) { kill(-pid, SIGKILL); kill(pid, SIGKILL); for (int i = 0; i < 100; i++) { if (waitpid(-1, status, WNOHANG | __WALL) == pid) return; usleep(1000); } DIR* dir = opendir("/sys/fs/fuse/connections"); if (dir) { for (;;) { struct dirent* ent = readdir(dir); if (!ent) break; if (strcmp(ent->d_name, ".") == 0 || strcmp(ent->d_name, "..") == 0) continue; char abort[300]; snprintf(abort, sizeof(abort), "/sys/fs/fuse/connections/%s/abort", ent->d_name); int fd = open(abort, O_WRONLY); if (fd == -1) { continue; } if (write(fd, abort, 1) < 0) { } close(fd); } closedir(dir); } else { } while (waitpid(-1, status, __WALL) != pid) { } } static void setup_test() { prctl(PR_SET_PDEATHSIG, SIGKILL, 0, 0, 0); setpgrp(); write_file("/proc/self/oom_score_adj", "1000"); } #define NL802154_CMD_SET_SHORT_ADDR 11 #define NL802154_ATTR_IFINDEX 3 #define NL802154_ATTR_SHORT_ADDR 10 static const char* setup_802154() { const char* error = NULL; int sock_generic = -1; int sock_route = socket(AF_NETLINK, SOCK_RAW, NETLINK_ROUTE); if (sock_route == -1) { error = "socket(AF_NETLINK, SOCK_RAW, NETLINK_ROUTE) failed"; goto fail; } sock_generic = socket(AF_NETLINK, SOCK_RAW, NETLINK_GENERIC); if (sock_generic == -1) { error = "socket(AF_NETLINK, SOCK_RAW, NETLINK_GENERIC) failed"; goto fail; } { int nl802154_family_id = netlink_query_family_id(&nlmsg, sock_generic, "nl802154", true); if (nl802154_family_id < 0) { error = "netlink_query_family_id failed"; goto fail; } for (int i = 0; i < 2; i++) { char devname[] = "wpan0"; devname[strlen(devname) - 1] += i; uint64_t hwaddr = 0xaaaaaaaaaaaa0002 + (i << 8); uint16_t shortaddr = 0xaaa0 + i; int ifindex = if_nametoindex(devname); struct genlmsghdr genlhdr; memset(&genlhdr, 0, sizeof(genlhdr)); genlhdr.cmd = NL802154_CMD_SET_SHORT_ADDR; netlink_init(&nlmsg, nl802154_family_id, 0, &genlhdr, sizeof(genlhdr)); netlink_attr(&nlmsg, NL802154_ATTR_IFINDEX, &ifindex, sizeof(ifindex)); netlink_attr(&nlmsg, NL802154_ATTR_SHORT_ADDR, &shortaddr, sizeof(shortaddr)); if (netlink_send(&nlmsg, sock_generic) < 0) { error = "NL802154_CMD_SET_SHORT_ADDR failed"; goto fail; } netlink_device_change(&nlmsg, sock_route, devname, true, 0, &hwaddr, sizeof(hwaddr), 0); if (i == 0) { netlink_add_device_impl(&nlmsg, "lowpan", "lowpan0", false); netlink_done(&nlmsg); netlink_attr(&nlmsg, IFLA_LINK, &ifindex, sizeof(ifindex)); if (netlink_send(&nlmsg, sock_route) < 0) { error = "netlink: adding device lowpan0 type lowpan link wpan0"; goto fail; } } } } fail: close(sock_route); close(sock_generic); return error; } struct thread_t { int created, call; event_t ready, done; }; static struct thread_t threads[16]; static void execute_call(int call); static int running; static void* thr(void* arg) { struct thread_t* th = (struct thread_t*)arg; for (;;) { event_wait(&th->ready); event_reset(&th->ready); execute_call(th->call); __atomic_fetch_sub(&running, 1, __ATOMIC_RELAXED); event_set(&th->done); } return 0; } static void execute_one(void) { if (write(1, "executing program\n", sizeof("executing program\n") - 1)) { } int i, call, thread; for (call = 0; call < 19; call++) { for (thread = 0; thread < (int)(sizeof(threads) / sizeof(threads[0])); thread++) { struct thread_t* th = &threads[thread]; if (!th->created) { th->created = 1; event_init(&th->ready); event_init(&th->done); event_set(&th->done); thread_start(thr, th); } if (!event_isset(&th->done)) continue; event_reset(&th->done); th->call = call; __atomic_fetch_add(&running, 1, __ATOMIC_RELAXED); event_set(&th->ready); event_timedwait(&th->done, 50); break; } } for (i = 0; i < 100 && __atomic_load_n(&running, __ATOMIC_RELAXED); i++) sleep_ms(1); } static void execute_one(void); #define WAIT_FLAGS __WALL static void loop(void) { int iter = 0; for (;; iter++) { int pid = fork(); if (pid < 0) exit(1); if (pid == 0) { setup_test(); execute_one(); exit(0); } int status = 0; uint64_t start = current_time_ms(); for (;;) { sleep_ms(10); if (waitpid(-1, &status, WNOHANG | WAIT_FLAGS) == pid) break; if (current_time_ms() - start < 5000) continue; kill_and_wait(pid, &status); break; } } } void execute_call(int call) { switch (call) { case 0: // mmap$auto arguments: [ // addr: intptr = 0x0 (8 bytes) // len: intptr = 0x20009 (8 bytes) // prot: intptr = 0xdf (8 bytes) // flags: intptr = 0xeb1 (8 bytes) // fd: fd (resource) // off: intptr = 0x8000 (8 bytes) // ] syscall(__NR_mmap, /*addr=*/0ul, /*len=*/0x20009ul, /*prot=*/0xdful, /*flags=*/0xeb1ul, /*fd=*/0xa5, /*off=*/0x8000ul); break; case 1: // close_range$auto arguments: [ // fd: fd (resource) // max_fd: fd (resource) // flags: int32 = 0x0 (4 bytes) // ] syscall(__NR_close_range, /*fd=*/0, /*max_fd=*/5, /*flags=*/0); break; case 2: // openat$auto_kernfs_file_fops_kernfs_internal arguments: [ // fd: const = 0xffffffffffffff9c (8 bytes) // file: ptr[in, buffer] { // buffer: {2f 73 79 73 2f 64 65 76 69 63 65 73 2f 76 69 72 74 75 61 6c // 2f 6e 65 74 2f 73 69 74 30 2f 73 74 61 74 69 73 74 69 63 73 2f 74 78 // 5f 63 6f 6d 70 72 65 73 73 65 64 00} (length 0x37) // } // flags: open_flags = 0xe00 (4 bytes) // mode: const = 0x0 (2 bytes) // ] // returns fd_kernfs_file_fops_kernfs_internal memcpy((void*)0x200000000040, "/sys/devices/virtual/net/sit0/statistics/tx_compressed\000", 55); syscall(__NR_openat, /*fd=*/0xffffffffffffff9cul, /*file=*/0x200000000040ul, /*flags=O_TRUNC|O_NONBLOCK|O_APPEND*/ 0xe00, /*mode=*/0); break; case 3: // openat$auto_nsim_dev_trap_fa_cookie_fops_dev arguments: [ // fd: const = 0xffffffffffffff9c (8 bytes) // file: nil // flags: open_flags = 0x2202 (4 bytes) // mode: const = 0x0 (2 bytes) // ] // returns fd_nsim_dev_trap_fa_cookie_fops_dev syscall(__NR_openat, /*fd=*/0xffffffffffffff9cul, /*file=*/0ul, /*flags=O_TRUNC|FASYNC|O_RDWR*/ 0x2202, /*mode=*/0); break; case 4: // openat$auto_vmwgfx_driver_fops_vmwgfx_drv arguments: [ // fd: const = 0xffffffffffffff9c (8 bytes) // file: nil // flags: open_flags = 0x80 (4 bytes) // mode: const = 0x0 (2 bytes) // ] // returns fd_vmwgfx_driver_fops_vmwgfx_drv syscall(__NR_openat, /*fd=*/0xffffffffffffff9cul, /*file=*/0ul, /*flags=O_EXCL*/ 0x80, /*mode=*/0); break; case 5: // openat$auto_cgwb_debug_stats_fops_ arguments: [ // fd: const = 0xffffffffffffff9c (8 bytes) // file: ptr[in, buffer] { // buffer: {2f 73 79 73 2f 6b 65 72 6e 65 6c 2f 64 65 62 75 67 2f 62 64 // 69 2f 31 3a 37 2f 77 62 5f 73 74 61 74 73 00} (length 0x23) // } // flags: open_flags = 0x2080 (4 bytes) // mode: const = 0x0 (2 bytes) // ] // returns fd_cgwb_debug_stats_fops_ memcpy((void*)0x200000000000, "/sys/kernel/debug/bdi/1:7/wb_stats\000", 35); syscall(__NR_openat, /*fd=*/0xffffffffffffff9cul, /*file=*/0x200000000000ul, /*flags=O_EXCL|FASYNC*/ 0x2080, /*mode=*/0); break; case 6: // close_range$auto arguments: [ // fd: fd (resource) // max_fd: fd (resource) // flags: int32 = 0x0 (4 bytes) // ] syscall(__NR_close_range, /*fd=*/2, /*max_fd=*/8, /*flags=*/0); break; case 7: // ioctl$auto_KVM_CREATE_VM arguments: [ // fd: fd_kvm_chardev_ops_kvm_main (resource) // cmd: const = 0xae01 (4 bytes) // arg: const = 0x0 (8 bytes) // ] // returns fd syscall(__NR_ioctl, /*fd=*/(intptr_t)-1, /*cmd=*/0xae01, /*arg=*/0ul); break; case 8: // mmap$auto arguments: [ // addr: intptr = 0x0 (8 bytes) // len: intptr = 0x810004 (8 bytes) // prot: intptr = 0xffb (8 bytes) // flags: intptr = 0x8000000008011 (8 bytes) // fd: fd (resource) // off: intptr = 0x8000 (8 bytes) // ] syscall(__NR_mmap, /*addr=*/0ul, /*len=*/0x810004ul, /*prot=*/0xffbul, /*flags=*/0x8000000008011ul, /*fd=*/3, /*off=*/0x8000ul); break; case 9: // close_range$auto arguments: [ // fd: fd (resource) // max_fd: fd (resource) // flags: int32 = 0x0 (4 bytes) // ] syscall(__NR_close_range, /*fd=*/2, /*max_fd=*/8, /*flags=*/0); break; case 10: // io_uring_setup$auto arguments: [ // entries: int32 = 0x6 (4 bytes) // params: nil // ] // returns fd syscall(__NR_io_uring_setup, /*entries=*/6, /*params=*/0ul); break; case 11: // mmap$auto arguments: [ // addr: intptr = 0x0 (8 bytes) // len: intptr = 0x2020009 (8 bytes) // prot: intptr = 0x3 (8 bytes) // flags: intptr = 0xeb1 (8 bytes) // fd: fd (resource) // off: intptr = 0x8000 (8 bytes) // ] syscall(__NR_mmap, /*addr=*/0ul, /*len=*/0x2020009ul, /*prot=*/3ul, /*flags=*/0xeb1ul, /*fd=*/(intptr_t)-1, /*off=*/0x8000ul); break; case 12: // socketpair$auto arguments: [ // family: int32 = 0x1e (4 bytes) // type: int32 = 0x1 (4 bytes) // protocol: int32 = 0x8000000000000000 (4 bytes) // usockvec: nil // ] // returns fd syscall(__NR_socketpair, /*family=*/0x1e, /*type=*/1, /*protocol=*/0, /*usockvec=*/0ul); break; case 13: // socket arguments: [ // domain: socket_domain = 0x11 (8 bytes) // type: socket_type = 0xa (8 bytes) // proto: int32 = 0x300 (4 bytes) // ] // returns sock syscall(__NR_socket, /*domain=AF_PACKET*/ 0x11ul, /*type=SOCK_PACKET*/ 0xaul, /*proto=*/0x300); break; case 14: // sendmmsg$auto arguments: [ // fd: fd (resource) // mmsg: nil // vlen: int32 = 0x9a6 (4 bytes) // flags: int32 = 0xa (4 bytes) // ] syscall(__NR_sendmmsg, /*fd=*/4, /*mmsg=*/0ul, /*vlen=*/0x9a6, /*flags=*/0xa); break; case 15: // setsockopt$auto arguments: [ // fd: fd (resource) // level: int32 = 0x1 (4 bytes) // optname: int32 = 0x21 (4 bytes) // optval: nil // optlen: int32 = 0x9 (4 bytes) // ] syscall(__NR_setsockopt, /*fd=*/3, /*level=*/1, /*optname=*/0x21, /*optval=*/0ul, /*optlen=*/9); break; case 16: // syz_genetlink_get_family_id$auto_ipvs arguments: [ // name: nil // fd: sock_nl_generic (resource) // ] // returns genl_ipvs_family_id$auto syz_genetlink_get_family_id(/*name=*/0, /*fd=*/-1); break; case 17: // socket arguments: [ // domain: socket_domain = 0x11 (8 bytes) // type: socket_type = 0x3 (8 bytes) // proto: int32 = 0x9 (4 bytes) // ] // returns sock syscall(__NR_socket, /*domain=AF_PACKET*/ 0x11ul, /*type=SOCK_RAW*/ 3ul, /*proto=*/9); break; case 18: // capset$auto arguments: [ // header: nil // data: nil // ] syscall(__NR_capset, /*header=*/0ul, /*data=*/0ul); break; } } int main(void) { syscall(__NR_mmap, /*addr=*/0x1ffffffff000ul, /*len=*/0x1000, /*prot=*/0ul, /*flags=MAP_FIXED|MAP_ANONYMOUS|MAP_PRIVATE*/ 0x32ul, /*fd=*/(intptr_t)-1, /*offset=*/0ul); syscall(__NR_mmap, /*addr=*/0x200000000000ul, /*len=*/0x1000000, /*prot=PROT_WRITE|PROT_READ|PROT_EXEC*/ 7ul, /*flags=MAP_FIXED|MAP_ANONYMOUS|MAP_PRIVATE*/ 0x32ul, /*fd=*/(intptr_t)-1, /*offset=*/0ul); syscall(__NR_mmap, /*addr=*/0x200001000000ul, /*len=*/0x1000, /*prot=*/0ul, /*flags=MAP_FIXED|MAP_ANONYMOUS|MAP_PRIVATE*/ 0x32ul, /*fd=*/(intptr_t)-1, /*offset=*/0ul); const char* reason; (void)reason; if ((reason = setup_802154())) { fprintf(stderr, "reproducer setup failed: 802154 injection: %s\n", reason); exit(1); } for (procid = 0; procid < 4; procid++) { if (fork() == 0) { loop(); } } sleep(1000000); return 0; }