/
niceSOFT
/
systemd
Обзор
Документация
Войти
/
niceSOFT
/
systemd
Код
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
main
src/basic/fiber-ops.c
51 строка
1 KB
Daan De Meyer
sd-future: make src/basic blocking helpers fiber-aware
21 май 2026, 12:55
21 май 2026, 12:55
7bc793e
Код
Авторство
О чём код?
/* SPDX-License-Identifier: LGPL-2.1-or-later */ #include <poll.h> #include <threads.h> #include <unistd.h> #include "errno-util.h" #include "fiber-ops.h" static thread_local const FiberOps *fiber_ops = NULL; bool fiber_ops_is_set(void) { return fiber_ops != NULL; } void fiber_ops_set(const FiberOps *ops) { fiber_ops = ops; } int fiber_ops_ppoll(struct pollfd *fds, size_t n_fds, const struct timespec *timeout, const sigset_t *sigmask) { if (fiber_ops) return fiber_ops->ppoll(fds, n_fds, timeout, sigmask); return RET_NERRNO(ppoll(fds, n_fds, timeout, sigmask)); } ssize_t fiber_ops_read(int fd, void *buf, size_t count) { if (fiber_ops) return fiber_ops->read(fd, buf, count); ssize_t n = read(fd, buf, count); return n < 0 ? -errno : n; } ssize_t fiber_ops_write(int fd, const void *buf, size_t count) { if (fiber_ops) return fiber_ops->write(fd, buf, count); return RET_NERRNO(write(fd, buf, count)); } sd_future* fiber_ops_timeout(uint64_t timeout) { assert(fiber_ops); return fiber_ops->timeout(timeout); } sd_future* fiber_ops_cancel_wait_unref(sd_future *f) { assert(fiber_ops); return fiber_ops->cancel_wait_unref(f); }