|
Packit |
b5b901 |
/* Copyright Joyent, Inc. and other Node contributors. All rights reserved.
|
|
Packit |
b5b901 |
* Permission is hereby granted, free of charge, to any person obtaining a copy
|
|
Packit |
b5b901 |
* of this software and associated documentation files (the "Software"), to
|
|
Packit |
b5b901 |
* deal in the Software without restriction, including without limitation the
|
|
Packit |
b5b901 |
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or
|
|
Packit |
b5b901 |
* sell copies of the Software, and to permit persons to whom the Software is
|
|
Packit |
b5b901 |
* furnished to do so, subject to the following conditions:
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* The above copyright notice and this permission notice shall be included in
|
|
Packit |
b5b901 |
* all copies or substantial portions of the Software.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
|
|
Packit |
b5b901 |
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
|
|
Packit |
b5b901 |
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
|
|
Packit |
b5b901 |
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
|
|
Packit |
b5b901 |
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
|
|
Packit |
b5b901 |
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS
|
|
Packit |
b5b901 |
* IN THE SOFTWARE.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* We lean on the fact that POLL{IN,OUT,ERR,HUP} correspond with their
|
|
Packit |
b5b901 |
* EPOLL* counterparts. We use the POLL* variants in this file because that
|
|
Packit |
b5b901 |
* is what libuv uses elsewhere.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include "uv.h"
|
|
Packit |
b5b901 |
#include "internal.h"
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
#include <inttypes.h>
|
|
Packit |
b5b901 |
#include <stdint.h>
|
|
Packit |
b5b901 |
#include <stdio.h>
|
|
Packit |
b5b901 |
#include <stdlib.h>
|
|
Packit |
b5b901 |
#include <string.h>
|
|
Packit |
b5b901 |
#include <assert.h>
|
|
Packit |
b5b901 |
#include <errno.h>
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#include <net/if.h>
|
|
Packit |
b5b901 |
#include <sys/epoll.h>
|
|
Packit |
b5b901 |
#include <sys/param.h>
|
|
Packit |
b5b901 |
#include <sys/prctl.h>
|
|
Packit |
b5b901 |
#include <sys/sysinfo.h>
|
|
Packit |
b5b901 |
#include <unistd.h>
|
|
Packit |
b5b901 |
#include <fcntl.h>
|
|
Packit |
b5b901 |
#include <time.h>
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#define HAVE_IFADDRS_H 1
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifdef __UCLIBC__
|
|
Packit |
b5b901 |
# if __UCLIBC_MAJOR__ < 0 && __UCLIBC_MINOR__ < 9 && __UCLIBC_SUBLEVEL__ < 32
|
|
Packit |
b5b901 |
# undef HAVE_IFADDRS_H
|
|
Packit |
b5b901 |
# endif
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#ifdef HAVE_IFADDRS_H
|
|
Packit |
b5b901 |
# if defined(__ANDROID__)
|
|
Packit |
b5b901 |
# include "uv/android-ifaddrs.h"
|
|
Packit |
b5b901 |
# else
|
|
Packit |
b5b901 |
# include <ifaddrs.h>
|
|
Packit |
b5b901 |
# endif
|
|
Packit |
b5b901 |
# include <sys/socket.h>
|
|
Packit |
b5b901 |
# include <net/ethernet.h>
|
|
Packit |
b5b901 |
# include <netpacket/packet.h>
|
|
Packit |
b5b901 |
#endif /* HAVE_IFADDRS_H */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Available from 2.6.32 onwards. */
|
|
Packit |
b5b901 |
#ifndef CLOCK_MONOTONIC_COARSE
|
|
Packit |
b5b901 |
# define CLOCK_MONOTONIC_COARSE 6
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* This is rather annoying: CLOCK_BOOTTIME lives in <linux/time.h> but we can't
|
|
Packit |
b5b901 |
* include that file because it conflicts with <time.h>. We'll just have to
|
|
Packit |
b5b901 |
* define it ourselves.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
#ifndef CLOCK_BOOTTIME
|
|
Packit |
b5b901 |
# define CLOCK_BOOTTIME 7
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static int read_models(unsigned int numcpus, uv_cpu_info_t* ci);
|
|
Packit |
b5b901 |
static int read_times(FILE* statfile_fp,
|
|
Packit |
b5b901 |
unsigned int numcpus,
|
|
Packit |
b5b901 |
uv_cpu_info_t* ci);
|
|
Packit |
b5b901 |
static void read_speeds(unsigned int numcpus, uv_cpu_info_t* ci);
|
|
Packit Service |
e08953 |
static uint64_t read_cpufreq(unsigned int cpunum);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv__platform_loop_init(uv_loop_t* loop) {
|
|
Packit |
b5b901 |
int fd;
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
/* It was reported that EPOLL_CLOEXEC is not defined on Android API < 21,
|
|
Packit Service |
e08953 |
* a.k.a. Lollipop. Since EPOLL_CLOEXEC is an alias for O_CLOEXEC on all
|
|
Packit Service |
e08953 |
* architectures, we just use that instead.
|
|
Packit Service |
e08953 |
*/
|
|
Packit Service |
e08953 |
#if defined(__ANDROID_API__) && __ANDROID_API__ < 21
|
|
Packit Service |
e08953 |
fd = -1;
|
|
Packit Service |
e08953 |
errno = ENOSYS;
|
|
Packit Service |
e08953 |
#else
|
|
Packit Service |
e08953 |
fd = epoll_create1(O_CLOEXEC);
|
|
Packit Service |
e08953 |
#endif
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* epoll_create1() can fail either because it's not implemented (old kernel)
|
|
Packit Service |
e08953 |
* or because it doesn't understand the O_CLOEXEC flag.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (fd == -1 && (errno == ENOSYS || errno == EINVAL)) {
|
|
Packit |
b5b901 |
fd = epoll_create(256);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (fd != -1)
|
|
Packit |
b5b901 |
uv__cloexec(fd, 1);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
loop->backend_fd = fd;
|
|
Packit |
b5b901 |
loop->inotify_fd = -1;
|
|
Packit |
b5b901 |
loop->inotify_watchers = NULL;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (fd == -1)
|
|
Packit |
b5b901 |
return UV__ERR(errno);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv__io_fork(uv_loop_t* loop) {
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
void* old_watchers;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
old_watchers = loop->inotify_watchers;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv__close(loop->backend_fd);
|
|
Packit |
b5b901 |
loop->backend_fd = -1;
|
|
Packit |
b5b901 |
uv__platform_loop_delete(loop);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = uv__platform_loop_init(loop);
|
|
Packit |
b5b901 |
if (err)
|
|
Packit |
b5b901 |
return err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return uv__inotify_fork(loop, old_watchers);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv__platform_loop_delete(uv_loop_t* loop) {
|
|
Packit |
b5b901 |
if (loop->inotify_fd == -1) return;
|
|
Packit |
b5b901 |
uv__io_stop(loop, &loop->inotify_read_watcher, POLLIN);
|
|
Packit |
b5b901 |
uv__close(loop->inotify_fd);
|
|
Packit |
b5b901 |
loop->inotify_fd = -1;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv__platform_invalidate_fd(uv_loop_t* loop, int fd) {
|
|
Packit |
b5b901 |
struct epoll_event* events;
|
|
Packit |
b5b901 |
struct epoll_event dummy;
|
|
Packit |
b5b901 |
uintptr_t i;
|
|
Packit |
b5b901 |
uintptr_t nfds;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
assert(loop->watchers != NULL);
|
|
Packit Service |
e08953 |
assert(fd >= 0);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
events = (struct epoll_event*) loop->watchers[loop->nwatchers];
|
|
Packit |
b5b901 |
nfds = (uintptr_t) loop->watchers[loop->nwatchers + 1];
|
|
Packit |
b5b901 |
if (events != NULL)
|
|
Packit |
b5b901 |
/* Invalidate events with same file descriptor */
|
|
Packit |
b5b901 |
for (i = 0; i < nfds; i++)
|
|
Packit |
b5b901 |
if (events[i].data.fd == fd)
|
|
Packit |
b5b901 |
events[i].data.fd = -1;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Remove the file descriptor from the epoll.
|
|
Packit |
b5b901 |
* This avoids a problem where the same file description remains open
|
|
Packit |
b5b901 |
* in another process, causing repeated junk epoll events.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* We pass in a dummy epoll_event, to work around a bug in old kernels.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (loop->backend_fd >= 0) {
|
|
Packit |
b5b901 |
/* Work around a bug in kernels 3.10 to 3.19 where passing a struct that
|
|
Packit |
b5b901 |
* has the EPOLLWAKEUP flag set generates spurious audit syslog warnings.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
memset(&dummy, 0, sizeof(dummy));
|
|
Packit |
b5b901 |
epoll_ctl(loop->backend_fd, EPOLL_CTL_DEL, fd, &dummy);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv__io_check_fd(uv_loop_t* loop, int fd) {
|
|
Packit |
b5b901 |
struct epoll_event e;
|
|
Packit |
b5b901 |
int rc;
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
memset(&e, 0, sizeof(e));
|
|
Packit |
b5b901 |
e.events = POLLIN;
|
|
Packit |
b5b901 |
e.data.fd = -1;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
rc = 0;
|
|
Packit |
b5b901 |
if (epoll_ctl(loop->backend_fd, EPOLL_CTL_ADD, fd, &e))
|
|
Packit |
b5b901 |
if (errno != EEXIST)
|
|
Packit |
b5b901 |
rc = UV__ERR(errno);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (rc == 0)
|
|
Packit |
b5b901 |
if (epoll_ctl(loop->backend_fd, EPOLL_CTL_DEL, fd, &e))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return rc;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv__io_poll(uv_loop_t* loop, int timeout) {
|
|
Packit |
b5b901 |
/* A bug in kernels < 2.6.37 makes timeouts larger than ~30 minutes
|
|
Packit |
b5b901 |
* effectively infinite on 32 bits architectures. To avoid blocking
|
|
Packit |
b5b901 |
* indefinitely, we cap the timeout and poll again if necessary.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* Note that "30 minutes" is a simplification because it depends on
|
|
Packit |
b5b901 |
* the value of CONFIG_HZ. The magic constant assumes CONFIG_HZ=1200,
|
|
Packit |
b5b901 |
* that being the largest value I have seen in the wild (and only once.)
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
static const int max_safe_timeout = 1789569;
|
|
Packit Service |
e08953 |
static int no_epoll_pwait;
|
|
Packit Service |
e08953 |
static int no_epoll_wait;
|
|
Packit |
b5b901 |
struct epoll_event events[1024];
|
|
Packit |
b5b901 |
struct epoll_event* pe;
|
|
Packit |
b5b901 |
struct epoll_event e;
|
|
Packit |
b5b901 |
int real_timeout;
|
|
Packit |
b5b901 |
QUEUE* q;
|
|
Packit |
b5b901 |
uv__io_t* w;
|
|
Packit |
b5b901 |
sigset_t sigset;
|
|
Packit Service |
e08953 |
uint64_t sigmask;
|
|
Packit |
b5b901 |
uint64_t base;
|
|
Packit |
b5b901 |
int have_signals;
|
|
Packit |
b5b901 |
int nevents;
|
|
Packit |
b5b901 |
int count;
|
|
Packit |
b5b901 |
int nfds;
|
|
Packit |
b5b901 |
int fd;
|
|
Packit |
b5b901 |
int op;
|
|
Packit |
b5b901 |
int i;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (loop->nfds == 0) {
|
|
Packit |
b5b901 |
assert(QUEUE_EMPTY(&loop->watcher_queue));
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
memset(&e, 0, sizeof(e));
|
|
Packit Service |
e08953 |
|
|
Packit |
b5b901 |
while (!QUEUE_EMPTY(&loop->watcher_queue)) {
|
|
Packit |
b5b901 |
q = QUEUE_HEAD(&loop->watcher_queue);
|
|
Packit |
b5b901 |
QUEUE_REMOVE(q);
|
|
Packit |
b5b901 |
QUEUE_INIT(q);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
w = QUEUE_DATA(q, uv__io_t, watcher_queue);
|
|
Packit |
b5b901 |
assert(w->pevents != 0);
|
|
Packit |
b5b901 |
assert(w->fd >= 0);
|
|
Packit |
b5b901 |
assert(w->fd < (int) loop->nwatchers);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
e.events = w->pevents;
|
|
Packit |
b5b901 |
e.data.fd = w->fd;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (w->events == 0)
|
|
Packit |
b5b901 |
op = EPOLL_CTL_ADD;
|
|
Packit |
b5b901 |
else
|
|
Packit |
b5b901 |
op = EPOLL_CTL_MOD;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* XXX Future optimization: do EPOLL_CTL_MOD lazily if we stop watching
|
|
Packit |
b5b901 |
* events, skip the syscall and squelch the events after epoll_wait().
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (epoll_ctl(loop->backend_fd, op, w->fd, &e)) {
|
|
Packit |
b5b901 |
if (errno != EEXIST)
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
assert(op == EPOLL_CTL_ADD);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* We've reactivated a file descriptor that's been watched before. */
|
|
Packit |
b5b901 |
if (epoll_ctl(loop->backend_fd, EPOLL_CTL_MOD, w->fd, &e))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
w->events = w->pevents;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
sigmask = 0;
|
|
Packit |
b5b901 |
if (loop->flags & UV_LOOP_BLOCK_SIGPROF) {
|
|
Packit |
b5b901 |
sigemptyset(&sigset);
|
|
Packit |
b5b901 |
sigaddset(&sigset, SIGPROF);
|
|
Packit Service |
e08953 |
sigmask |= 1 << (SIGPROF - 1);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
assert(timeout >= -1);
|
|
Packit |
b5b901 |
base = loop->time;
|
|
Packit |
b5b901 |
count = 48; /* Benchmarks suggest this gives the best throughput. */
|
|
Packit |
b5b901 |
real_timeout = timeout;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
for (;;) {
|
|
Packit |
b5b901 |
/* See the comment for max_safe_timeout for an explanation of why
|
|
Packit |
b5b901 |
* this is necessary. Executive summary: kernel bug workaround.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (sizeof(int32_t) == sizeof(long) && timeout >= max_safe_timeout)
|
|
Packit |
b5b901 |
timeout = max_safe_timeout;
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
if (sigmask != 0 && no_epoll_pwait != 0)
|
|
Packit Service |
e08953 |
if (pthread_sigmask(SIG_BLOCK, &sigset, NULL))
|
|
Packit Service |
e08953 |
abort();
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (no_epoll_wait != 0 || (sigmask != 0 && no_epoll_pwait == 0)) {
|
|
Packit Service |
e08953 |
#if defined(__ANDROID_API__) && __ANDROID_API__ < 21
|
|
Packit Service |
e08953 |
nfds = -1;
|
|
Packit Service |
e08953 |
errno = ENOSYS;
|
|
Packit Service |
e08953 |
#else
|
|
Packit Service |
e08953 |
nfds = epoll_pwait(loop->backend_fd,
|
|
Packit Service |
e08953 |
events,
|
|
Packit Service |
e08953 |
ARRAY_SIZE(events),
|
|
Packit Service |
e08953 |
timeout,
|
|
Packit Service |
e08953 |
&sigset);
|
|
Packit Service |
e08953 |
#endif
|
|
Packit Service |
e08953 |
if (nfds == -1 && errno == ENOSYS)
|
|
Packit Service |
e08953 |
no_epoll_pwait = 1;
|
|
Packit Service |
e08953 |
} else {
|
|
Packit Service |
e08953 |
nfds = epoll_wait(loop->backend_fd,
|
|
Packit Service |
e08953 |
events,
|
|
Packit Service |
e08953 |
ARRAY_SIZE(events),
|
|
Packit Service |
e08953 |
timeout);
|
|
Packit Service |
e08953 |
if (nfds == -1 && errno == ENOSYS)
|
|
Packit Service |
e08953 |
no_epoll_wait = 1;
|
|
Packit Service |
e08953 |
}
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (sigmask != 0 && no_epoll_pwait != 0)
|
|
Packit Service |
e08953 |
if (pthread_sigmask(SIG_UNBLOCK, &sigset, NULL))
|
|
Packit Service |
e08953 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Update loop->time unconditionally. It's tempting to skip the update when
|
|
Packit |
b5b901 |
* timeout == 0 (i.e. non-blocking poll) but there is no guarantee that the
|
|
Packit |
b5b901 |
* operating system didn't reschedule our process while in the syscall.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
SAVE_ERRNO(uv__update_time(loop));
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (nfds == 0) {
|
|
Packit |
b5b901 |
assert(timeout != -1);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (timeout == 0)
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* We may have been inside the system call for longer than |timeout|
|
|
Packit |
b5b901 |
* milliseconds so we need to update the timestamp to avoid drift.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
goto update_timeout;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (nfds == -1) {
|
|
Packit Service |
e08953 |
if (errno == ENOSYS) {
|
|
Packit Service |
e08953 |
/* epoll_wait() or epoll_pwait() failed, try the other system call. */
|
|
Packit Service |
e08953 |
assert(no_epoll_wait == 0 || no_epoll_pwait == 0);
|
|
Packit Service |
e08953 |
continue;
|
|
Packit Service |
e08953 |
}
|
|
Packit Service |
e08953 |
|
|
Packit |
b5b901 |
if (errno != EINTR)
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (timeout == -1)
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (timeout == 0)
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Interrupted by a signal. Update timeout and poll again. */
|
|
Packit |
b5b901 |
goto update_timeout;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
have_signals = 0;
|
|
Packit |
b5b901 |
nevents = 0;
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
{
|
|
Packit Service |
e08953 |
/* Squelch a -Waddress-of-packed-member warning with gcc >= 9. */
|
|
Packit Service |
e08953 |
union {
|
|
Packit Service |
e08953 |
struct epoll_event* events;
|
|
Packit Service |
e08953 |
uv__io_t* watchers;
|
|
Packit Service |
e08953 |
} x;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
x.events = events;
|
|
Packit Service |
e08953 |
assert(loop->watchers != NULL);
|
|
Packit Service |
e08953 |
loop->watchers[loop->nwatchers] = x.watchers;
|
|
Packit Service |
e08953 |
loop->watchers[loop->nwatchers + 1] = (void*) (uintptr_t) nfds;
|
|
Packit Service |
e08953 |
}
|
|
Packit Service |
e08953 |
|
|
Packit |
b5b901 |
for (i = 0; i < nfds; i++) {
|
|
Packit |
b5b901 |
pe = events + i;
|
|
Packit |
b5b901 |
fd = pe->data.fd;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Skip invalidated events, see uv__platform_invalidate_fd */
|
|
Packit |
b5b901 |
if (fd == -1)
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
assert(fd >= 0);
|
|
Packit |
b5b901 |
assert((unsigned) fd < loop->nwatchers);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
w = loop->watchers[fd];
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (w == NULL) {
|
|
Packit |
b5b901 |
/* File descriptor that we've stopped watching, disarm it.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* Ignore all errors because we may be racing with another thread
|
|
Packit |
b5b901 |
* when the file descriptor is closed.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
epoll_ctl(loop->backend_fd, EPOLL_CTL_DEL, fd, pe);
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Give users only events they're interested in. Prevents spurious
|
|
Packit |
b5b901 |
* callbacks when previous callback invocation in this loop has stopped
|
|
Packit |
b5b901 |
* the current watcher. Also, filters out events that users has not
|
|
Packit |
b5b901 |
* requested us to watch.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
pe->events &= w->pevents | POLLERR | POLLHUP;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Work around an epoll quirk where it sometimes reports just the
|
|
Packit |
b5b901 |
* EPOLLERR or EPOLLHUP event. In order to force the event loop to
|
|
Packit |
b5b901 |
* move forward, we merge in the read/write events that the watcher
|
|
Packit |
b5b901 |
* is interested in; uv__read() and uv__write() will then deal with
|
|
Packit |
b5b901 |
* the error or hangup in the usual fashion.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* Note to self: happens when epoll reports EPOLLIN|EPOLLHUP, the user
|
|
Packit |
b5b901 |
* reads the available data, calls uv_read_stop(), then sometime later
|
|
Packit |
b5b901 |
* calls uv_read_start() again. By then, libuv has forgotten about the
|
|
Packit |
b5b901 |
* hangup and the kernel won't report EPOLLIN again because there's
|
|
Packit |
b5b901 |
* nothing left to read. If anything, libuv is to blame here. The
|
|
Packit |
b5b901 |
* current hack is just a quick bandaid; to properly fix it, libuv
|
|
Packit |
b5b901 |
* needs to remember the error/hangup event. We should get that for
|
|
Packit |
b5b901 |
* free when we switch over to edge-triggered I/O.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (pe->events == POLLERR || pe->events == POLLHUP)
|
|
Packit |
b5b901 |
pe->events |=
|
|
Packit |
b5b901 |
w->pevents & (POLLIN | POLLOUT | UV__POLLRDHUP | UV__POLLPRI);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (pe->events != 0) {
|
|
Packit |
b5b901 |
/* Run signal watchers last. This also affects child process watchers
|
|
Packit |
b5b901 |
* because those are implemented in terms of signal watchers.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (w == &loop->signal_io_watcher)
|
|
Packit |
b5b901 |
have_signals = 1;
|
|
Packit |
b5b901 |
else
|
|
Packit |
b5b901 |
w->cb(loop, w, pe->events);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
nevents++;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (have_signals != 0)
|
|
Packit |
b5b901 |
loop->signal_io_watcher.cb(loop, &loop->signal_io_watcher, POLLIN);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
loop->watchers[loop->nwatchers] = NULL;
|
|
Packit |
b5b901 |
loop->watchers[loop->nwatchers + 1] = NULL;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (have_signals != 0)
|
|
Packit |
b5b901 |
return; /* Event loop should cycle now so don't poll again. */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (nevents != 0) {
|
|
Packit |
b5b901 |
if (nfds == ARRAY_SIZE(events) && --count != 0) {
|
|
Packit |
b5b901 |
/* Poll for more events but don't block this time. */
|
|
Packit |
b5b901 |
timeout = 0;
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (timeout == 0)
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (timeout == -1)
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
update_timeout:
|
|
Packit |
b5b901 |
assert(timeout > 0);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
real_timeout -= (loop->time - base);
|
|
Packit |
b5b901 |
if (real_timeout <= 0)
|
|
Packit |
b5b901 |
return;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
timeout = real_timeout;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uint64_t uv__hrtime(uv_clocktype_t type) {
|
|
Packit |
b5b901 |
static clock_t fast_clock_id = -1;
|
|
Packit |
b5b901 |
struct timespec t;
|
|
Packit |
b5b901 |
clock_t clock_id;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Prefer CLOCK_MONOTONIC_COARSE if available but only when it has
|
|
Packit |
b5b901 |
* millisecond granularity or better. CLOCK_MONOTONIC_COARSE is
|
|
Packit |
b5b901 |
* serviced entirely from the vDSO, whereas CLOCK_MONOTONIC may
|
|
Packit |
b5b901 |
* decide to make a costly system call.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
/* TODO(bnoordhuis) Use CLOCK_MONOTONIC_COARSE for UV_CLOCK_PRECISE
|
|
Packit |
b5b901 |
* when it has microsecond granularity or better (unlikely).
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (type == UV_CLOCK_FAST && fast_clock_id == -1) {
|
|
Packit |
b5b901 |
if (clock_getres(CLOCK_MONOTONIC_COARSE, &t) == 0 &&
|
|
Packit |
b5b901 |
t.tv_nsec <= 1 * 1000 * 1000) {
|
|
Packit |
b5b901 |
fast_clock_id = CLOCK_MONOTONIC_COARSE;
|
|
Packit |
b5b901 |
} else {
|
|
Packit |
b5b901 |
fast_clock_id = CLOCK_MONOTONIC;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
clock_id = CLOCK_MONOTONIC;
|
|
Packit |
b5b901 |
if (type == UV_CLOCK_FAST)
|
|
Packit |
b5b901 |
clock_id = fast_clock_id;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (clock_gettime(clock_id, &t))
|
|
Packit |
b5b901 |
return 0; /* Not really possible. */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return t.tv_sec * (uint64_t) 1e9 + t.tv_nsec;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_resident_set_memory(size_t* rss) {
|
|
Packit |
b5b901 |
char buf[1024];
|
|
Packit |
b5b901 |
const char* s;
|
|
Packit |
b5b901 |
ssize_t n;
|
|
Packit |
b5b901 |
long val;
|
|
Packit |
b5b901 |
int fd;
|
|
Packit |
b5b901 |
int i;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
do
|
|
Packit |
b5b901 |
fd = open("/proc/self/stat", O_RDONLY);
|
|
Packit |
b5b901 |
while (fd == -1 && errno == EINTR);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (fd == -1)
|
|
Packit |
b5b901 |
return UV__ERR(errno);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
do
|
|
Packit |
b5b901 |
n = read(fd, buf, sizeof(buf) - 1);
|
|
Packit |
b5b901 |
while (n == -1 && errno == EINTR);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv__close(fd);
|
|
Packit |
b5b901 |
if (n == -1)
|
|
Packit |
b5b901 |
return UV__ERR(errno);
|
|
Packit |
b5b901 |
buf[n] = '\0';
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
s = strchr(buf, ' ');
|
|
Packit |
b5b901 |
if (s == NULL)
|
|
Packit |
b5b901 |
goto err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
s += 1;
|
|
Packit |
b5b901 |
if (*s != '(')
|
|
Packit |
b5b901 |
goto err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
s = strchr(s, ')');
|
|
Packit |
b5b901 |
if (s == NULL)
|
|
Packit |
b5b901 |
goto err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
for (i = 1; i <= 22; i++) {
|
|
Packit |
b5b901 |
s = strchr(s + 1, ' ');
|
|
Packit |
b5b901 |
if (s == NULL)
|
|
Packit |
b5b901 |
goto err;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
errno = 0;
|
|
Packit |
b5b901 |
val = strtol(s, NULL, 10);
|
|
Packit |
b5b901 |
if (errno != 0)
|
|
Packit |
b5b901 |
goto err;
|
|
Packit |
b5b901 |
if (val < 0)
|
|
Packit |
b5b901 |
goto err;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
*rss = val * getpagesize();
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err:
|
|
Packit |
b5b901 |
return UV_EINVAL;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_uptime(double* uptime) {
|
|
Packit |
b5b901 |
static volatile int no_clock_boottime;
|
|
Packit |
b5b901 |
struct timespec now;
|
|
Packit |
b5b901 |
int r;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Try CLOCK_BOOTTIME first, fall back to CLOCK_MONOTONIC if not available
|
|
Packit |
b5b901 |
* (pre-2.6.39 kernels). CLOCK_MONOTONIC doesn't increase when the system
|
|
Packit |
b5b901 |
* is suspended.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (no_clock_boottime) {
|
|
Packit |
b5b901 |
retry: r = clock_gettime(CLOCK_MONOTONIC, &now;;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
else if ((r = clock_gettime(CLOCK_BOOTTIME, &now)) && errno == EINVAL) {
|
|
Packit |
b5b901 |
no_clock_boottime = 1;
|
|
Packit |
b5b901 |
goto retry;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (r)
|
|
Packit |
b5b901 |
return UV__ERR(errno);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
*uptime = now.tv_sec;
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static int uv__cpu_num(FILE* statfile_fp, unsigned int* numcpus) {
|
|
Packit |
b5b901 |
unsigned int num;
|
|
Packit |
b5b901 |
char buf[1024];
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (!fgets(buf, sizeof(buf), statfile_fp))
|
|
Packit |
b5b901 |
return UV_EIO;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
num = 0;
|
|
Packit |
b5b901 |
while (fgets(buf, sizeof(buf), statfile_fp)) {
|
|
Packit |
b5b901 |
if (strncmp(buf, "cpu", 3))
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
num++;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (num == 0)
|
|
Packit |
b5b901 |
return UV_EIO;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
*numcpus = num;
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
int uv_cpu_info(uv_cpu_info_t** cpu_infos, int* count) {
|
|
Packit |
b5b901 |
unsigned int numcpus;
|
|
Packit |
b5b901 |
uv_cpu_info_t* ci;
|
|
Packit |
b5b901 |
int err;
|
|
Packit |
b5b901 |
FILE* statfile_fp;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
*cpu_infos = NULL;
|
|
Packit |
b5b901 |
*count = 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
statfile_fp = uv__open_file("/proc/stat");
|
|
Packit |
b5b901 |
if (statfile_fp == NULL)
|
|
Packit |
b5b901 |
return UV__ERR(errno);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = uv__cpu_num(statfile_fp, &numcpus);
|
|
Packit |
b5b901 |
if (err < 0)
|
|
Packit |
b5b901 |
goto out;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = UV_ENOMEM;
|
|
Packit |
b5b901 |
ci = uv__calloc(numcpus, sizeof(*ci));
|
|
Packit |
b5b901 |
if (ci == NULL)
|
|
Packit |
b5b901 |
goto out;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
err = read_models(numcpus, ci);
|
|
Packit |
b5b901 |
if (err == 0)
|
|
Packit |
b5b901 |
err = read_times(statfile_fp, numcpus, ci);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (err) {
|
|
Packit |
b5b901 |
uv_free_cpu_info(ci, numcpus);
|
|
Packit |
b5b901 |
goto out;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* read_models() on x86 also reads the CPU speed from /proc/cpuinfo.
|
|
Packit |
b5b901 |
* We don't check for errors here. Worst case, the field is left zero.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (ci[0].speed == 0)
|
|
Packit |
b5b901 |
read_speeds(numcpus, ci);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
*cpu_infos = ci;
|
|
Packit |
b5b901 |
*count = numcpus;
|
|
Packit |
b5b901 |
err = 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
out:
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (fclose(statfile_fp))
|
|
Packit |
b5b901 |
if (errno != EINTR && errno != EINPROGRESS)
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return err;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static void read_speeds(unsigned int numcpus, uv_cpu_info_t* ci) {
|
|
Packit |
b5b901 |
unsigned int num;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
for (num = 0; num < numcpus; num++)
|
|
Packit |
b5b901 |
ci[num].speed = read_cpufreq(num) / 1000;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Also reads the CPU frequency on x86. The other architectures only have
|
|
Packit |
b5b901 |
* a BogoMIPS field, which may not be very accurate.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* Note: Simply returns on error, uv_cpu_info() takes care of the cleanup.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
static int read_models(unsigned int numcpus, uv_cpu_info_t* ci) {
|
|
Packit |
b5b901 |
static const char model_marker[] = "model name\t: ";
|
|
Packit |
b5b901 |
static const char speed_marker[] = "cpu MHz\t\t: ";
|
|
Packit |
b5b901 |
const char* inferred_model;
|
|
Packit |
b5b901 |
unsigned int model_idx;
|
|
Packit |
b5b901 |
unsigned int speed_idx;
|
|
Packit |
b5b901 |
char buf[1024];
|
|
Packit |
b5b901 |
char* model;
|
|
Packit |
b5b901 |
FILE* fp;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Most are unused on non-ARM, non-MIPS and non-x86 architectures. */
|
|
Packit |
b5b901 |
(void) &model_marker;
|
|
Packit |
b5b901 |
(void) &speed_marker;
|
|
Packit |
b5b901 |
(void) &speed_idx;
|
|
Packit |
b5b901 |
(void) &model;
|
|
Packit |
b5b901 |
(void) &buf;
|
|
Packit |
b5b901 |
(void) &fp;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
model_idx = 0;
|
|
Packit |
b5b901 |
speed_idx = 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
#if defined(__arm__) || \
|
|
Packit |
b5b901 |
defined(__i386__) || \
|
|
Packit |
b5b901 |
defined(__mips__) || \
|
|
Packit |
b5b901 |
defined(__x86_64__)
|
|
Packit |
b5b901 |
fp = uv__open_file("/proc/cpuinfo");
|
|
Packit |
b5b901 |
if (fp == NULL)
|
|
Packit |
b5b901 |
return UV__ERR(errno);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
while (fgets(buf, sizeof(buf), fp)) {
|
|
Packit |
b5b901 |
if (model_idx < numcpus) {
|
|
Packit |
b5b901 |
if (strncmp(buf, model_marker, sizeof(model_marker) - 1) == 0) {
|
|
Packit |
b5b901 |
model = buf + sizeof(model_marker) - 1;
|
|
Packit |
b5b901 |
model = uv__strndup(model, strlen(model) - 1); /* Strip newline. */
|
|
Packit |
b5b901 |
if (model == NULL) {
|
|
Packit |
b5b901 |
fclose(fp);
|
|
Packit |
b5b901 |
return UV_ENOMEM;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
ci[model_idx++].model = model;
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
#if defined(__arm__) || defined(__mips__)
|
|
Packit |
b5b901 |
if (model_idx < numcpus) {
|
|
Packit |
b5b901 |
#if defined(__arm__)
|
|
Packit |
b5b901 |
/* Fallback for pre-3.8 kernels. */
|
|
Packit |
b5b901 |
static const char model_marker[] = "Processor\t: ";
|
|
Packit |
b5b901 |
#else /* defined(__mips__) */
|
|
Packit |
b5b901 |
static const char model_marker[] = "cpu model\t\t: ";
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
if (strncmp(buf, model_marker, sizeof(model_marker) - 1) == 0) {
|
|
Packit |
b5b901 |
model = buf + sizeof(model_marker) - 1;
|
|
Packit |
b5b901 |
model = uv__strndup(model, strlen(model) - 1); /* Strip newline. */
|
|
Packit |
b5b901 |
if (model == NULL) {
|
|
Packit |
b5b901 |
fclose(fp);
|
|
Packit |
b5b901 |
return UV_ENOMEM;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
ci[model_idx++].model = model;
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
#else /* !__arm__ && !__mips__ */
|
|
Packit |
b5b901 |
if (speed_idx < numcpus) {
|
|
Packit |
b5b901 |
if (strncmp(buf, speed_marker, sizeof(speed_marker) - 1) == 0) {
|
|
Packit |
b5b901 |
ci[speed_idx++].speed = atoi(buf + sizeof(speed_marker) - 1);
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
#endif /* __arm__ || __mips__ */
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
fclose(fp);
|
|
Packit |
b5b901 |
#endif /* __arm__ || __i386__ || __mips__ || __x86_64__ */
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Now we want to make sure that all the models contain *something* because
|
|
Packit |
b5b901 |
* it's not safe to leave them as null. Copy the last entry unless there
|
|
Packit |
b5b901 |
* isn't one, in that case we simply put "unknown" into everything.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
inferred_model = "unknown";
|
|
Packit |
b5b901 |
if (model_idx > 0)
|
|
Packit |
b5b901 |
inferred_model = ci[model_idx - 1].model;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
while (model_idx < numcpus) {
|
|
Packit |
b5b901 |
model = uv__strndup(inferred_model, strlen(inferred_model));
|
|
Packit |
b5b901 |
if (model == NULL)
|
|
Packit |
b5b901 |
return UV_ENOMEM;
|
|
Packit |
b5b901 |
ci[model_idx++].model = model;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static int read_times(FILE* statfile_fp,
|
|
Packit |
b5b901 |
unsigned int numcpus,
|
|
Packit |
b5b901 |
uv_cpu_info_t* ci) {
|
|
Packit |
b5b901 |
struct uv_cpu_times_s ts;
|
|
Packit Service |
e08953 |
unsigned int ticks;
|
|
Packit Service |
e08953 |
unsigned int multiplier;
|
|
Packit Service |
e08953 |
uint64_t user;
|
|
Packit Service |
e08953 |
uint64_t nice;
|
|
Packit Service |
e08953 |
uint64_t sys;
|
|
Packit Service |
e08953 |
uint64_t idle;
|
|
Packit Service |
e08953 |
uint64_t dummy;
|
|
Packit Service |
e08953 |
uint64_t irq;
|
|
Packit Service |
e08953 |
uint64_t num;
|
|
Packit Service |
e08953 |
uint64_t len;
|
|
Packit |
b5b901 |
char buf[1024];
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
ticks = (unsigned int)sysconf(_SC_CLK_TCK);
|
|
Packit Service |
e08953 |
multiplier = ((uint64_t)1000L / ticks);
|
|
Packit Service |
e08953 |
assert(ticks != (unsigned int) -1);
|
|
Packit Service |
e08953 |
assert(ticks != 0);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
rewind(statfile_fp);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (!fgets(buf, sizeof(buf), statfile_fp))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
num = 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
while (fgets(buf, sizeof(buf), statfile_fp)) {
|
|
Packit |
b5b901 |
if (num >= numcpus)
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (strncmp(buf, "cpu", 3))
|
|
Packit |
b5b901 |
break;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* skip "cpu<num> " marker */
|
|
Packit |
b5b901 |
{
|
|
Packit |
b5b901 |
unsigned int n;
|
|
Packit |
b5b901 |
int r = sscanf(buf, "cpu%u ", &n);
|
|
Packit |
b5b901 |
assert(r == 1);
|
|
Packit |
b5b901 |
(void) r; /* silence build warning */
|
|
Packit |
b5b901 |
for (len = sizeof("cpu0"); n /= 10; len++);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Line contains user, nice, system, idle, iowait, irq, softirq, steal,
|
|
Packit |
b5b901 |
* guest, guest_nice but we're only interested in the first four + irq.
|
|
Packit |
b5b901 |
*
|
|
Packit |
b5b901 |
* Don't use %*s to skip fields or %ll to read straight into the uint64_t
|
|
Packit |
b5b901 |
* fields, they're not allowed in C89 mode.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (6 != sscanf(buf + len,
|
|
Packit Service |
e08953 |
"%" PRIu64 " %" PRIu64 " %" PRIu64
|
|
Packit Service |
e08953 |
"%" PRIu64 " %" PRIu64 " %" PRIu64,
|
|
Packit |
b5b901 |
&user,
|
|
Packit |
b5b901 |
&nice,
|
|
Packit |
b5b901 |
&sys,
|
|
Packit |
b5b901 |
&idle,
|
|
Packit |
b5b901 |
&dummy,
|
|
Packit |
b5b901 |
&irq))
|
|
Packit |
b5b901 |
abort();
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
ts.user = user * multiplier;
|
|
Packit Service |
e08953 |
ts.nice = nice * multiplier;
|
|
Packit Service |
e08953 |
ts.sys = sys * multiplier;
|
|
Packit Service |
e08953 |
ts.idle = idle * multiplier;
|
|
Packit Service |
e08953 |
ts.irq = irq * multiplier;
|
|
Packit |
b5b901 |
ci[num++].cpu_times = ts;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
assert(num == numcpus);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
static uint64_t read_cpufreq(unsigned int cpunum) {
|
|
Packit Service |
e08953 |
uint64_t val;
|
|
Packit |
b5b901 |
char buf[1024];
|
|
Packit |
b5b901 |
FILE* fp;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
snprintf(buf,
|
|
Packit |
b5b901 |
sizeof(buf),
|
|
Packit |
b5b901 |
"/sys/devices/system/cpu/cpu%u/cpufreq/scaling_cur_freq",
|
|
Packit |
b5b901 |
cpunum);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
fp = uv__open_file(buf);
|
|
Packit |
b5b901 |
if (fp == NULL)
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
if (fscanf(fp, "%" PRIu64, &val) != 1)
|
|
Packit |
b5b901 |
val = 0;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
fclose(fp);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return val;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
static int uv__ifaddr_exclude(struct ifaddrs *ent, int exclude_type) {
|
|
Packit |
b5b901 |
if (!((ent->ifa_flags & IFF_UP) && (ent->ifa_flags & IFF_RUNNING)))
|
|
Packit |
b5b901 |
return 1;
|
|
Packit |
b5b901 |
if (ent->ifa_addr == NULL)
|
|
Packit |
b5b901 |
return 1;
|
|
Packit |
b5b901 |
/*
|
|
Packit |
b5b901 |
* On Linux getifaddrs returns information related to the raw underlying
|
|
Packit |
b5b901 |
* devices. We're not interested in this information yet.
|
|
Packit |
b5b901 |
*/
|
|
Packit |
b5b901 |
if (ent->ifa_addr->sa_family == PF_PACKET)
|
|
Packit |
b5b901 |
return exclude_type;
|
|
Packit |
b5b901 |
return !exclude_type;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
int uv_interface_addresses(uv_interface_address_t** addresses, int* count) {
|
|
Packit |
b5b901 |
#ifndef HAVE_IFADDRS_H
|
|
Packit Service |
e08953 |
*count = 0;
|
|
Packit Service |
e08953 |
*addresses = NULL;
|
|
Packit |
b5b901 |
return UV_ENOSYS;
|
|
Packit |
b5b901 |
#else
|
|
Packit |
b5b901 |
struct ifaddrs *addrs, *ent;
|
|
Packit |
b5b901 |
uv_interface_address_t* address;
|
|
Packit |
b5b901 |
int i;
|
|
Packit |
b5b901 |
struct sockaddr_ll *sll;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
*count = 0;
|
|
Packit |
b5b901 |
*addresses = NULL;
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
if (getifaddrs(&addrs))
|
|
Packit Service |
e08953 |
return UV__ERR(errno);
|
|
Packit Service |
e08953 |
|
|
Packit |
b5b901 |
/* Count the number of interfaces */
|
|
Packit |
b5b901 |
for (ent = addrs; ent != NULL; ent = ent->ifa_next) {
|
|
Packit |
b5b901 |
if (uv__ifaddr_exclude(ent, UV__EXCLUDE_IFADDR))
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
(*count)++;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
if (*count == 0) {
|
|
Packit Service |
e08953 |
freeifaddrs(addrs);
|
|
Packit |
b5b901 |
return 0;
|
|
Packit Service |
e08953 |
}
|
|
Packit |
b5b901 |
|
|
Packit Service |
e08953 |
/* Make sure the memory is initiallized to zero using calloc() */
|
|
Packit Service |
e08953 |
*addresses = uv__calloc(*count, sizeof(**addresses));
|
|
Packit |
b5b901 |
if (!(*addresses)) {
|
|
Packit |
b5b901 |
freeifaddrs(addrs);
|
|
Packit |
b5b901 |
return UV_ENOMEM;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
address = *addresses;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
for (ent = addrs; ent != NULL; ent = ent->ifa_next) {
|
|
Packit |
b5b901 |
if (uv__ifaddr_exclude(ent, UV__EXCLUDE_IFADDR))
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
address->name = uv__strdup(ent->ifa_name);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (ent->ifa_addr->sa_family == AF_INET6) {
|
|
Packit |
b5b901 |
address->address.address6 = *((struct sockaddr_in6*) ent->ifa_addr);
|
|
Packit |
b5b901 |
} else {
|
|
Packit |
b5b901 |
address->address.address4 = *((struct sockaddr_in*) ent->ifa_addr);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
if (ent->ifa_netmask->sa_family == AF_INET6) {
|
|
Packit |
b5b901 |
address->netmask.netmask6 = *((struct sockaddr_in6*) ent->ifa_netmask);
|
|
Packit |
b5b901 |
} else {
|
|
Packit |
b5b901 |
address->netmask.netmask4 = *((struct sockaddr_in*) ent->ifa_netmask);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
address->is_internal = !!(ent->ifa_flags & IFF_LOOPBACK);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
address++;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
/* Fill in physical addresses for each interface */
|
|
Packit |
b5b901 |
for (ent = addrs; ent != NULL; ent = ent->ifa_next) {
|
|
Packit |
b5b901 |
if (uv__ifaddr_exclude(ent, UV__EXCLUDE_IFPHYS))
|
|
Packit |
b5b901 |
continue;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
address = *addresses;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
for (i = 0; i < (*count); i++) {
|
|
Packit Service |
e08953 |
size_t namelen = strlen(ent->ifa_name);
|
|
Packit Service |
e08953 |
/* Alias interface share the same physical address */
|
|
Packit Service |
e08953 |
if (strncmp(address->name, ent->ifa_name, namelen) == 0 &&
|
|
Packit Service |
e08953 |
(address->name[namelen] == 0 || address->name[namelen] == ':')) {
|
|
Packit |
b5b901 |
sll = (struct sockaddr_ll*)ent->ifa_addr;
|
|
Packit |
b5b901 |
memcpy(address->phys_addr, sll->sll_addr, sizeof(address->phys_addr));
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
address++;
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
freeifaddrs(addrs);
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
return 0;
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv_free_interface_addresses(uv_interface_address_t* addresses,
|
|
Packit |
b5b901 |
int count) {
|
|
Packit |
b5b901 |
int i;
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
for (i = 0; i < count; i++) {
|
|
Packit |
b5b901 |
uv__free(addresses[i].name);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
uv__free(addresses);
|
|
Packit |
b5b901 |
}
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
|
|
Packit |
b5b901 |
void uv__set_process_title(const char* title) {
|
|
Packit |
b5b901 |
#if defined(PR_SET_NAME)
|
|
Packit |
b5b901 |
prctl(PR_SET_NAME, title); /* Only copies first 16 characters. */
|
|
Packit |
b5b901 |
#endif
|
|
Packit |
b5b901 |
}
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
static uint64_t uv__read_proc_meminfo(const char* what) {
|
|
Packit Service |
e08953 |
uint64_t rc;
|
|
Packit Service |
e08953 |
ssize_t n;
|
|
Packit Service |
e08953 |
char* p;
|
|
Packit Service |
e08953 |
int fd;
|
|
Packit Service |
e08953 |
char buf[4096]; /* Large enough to hold all of /proc/meminfo. */
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
rc = 0;
|
|
Packit Service |
e08953 |
fd = uv__open_cloexec("/proc/meminfo", O_RDONLY);
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (fd < 0)
|
|
Packit Service |
e08953 |
return 0;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
n = read(fd, buf, sizeof(buf) - 1);
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (n <= 0)
|
|
Packit Service |
e08953 |
goto out;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
buf[n] = '\0';
|
|
Packit Service |
e08953 |
p = strstr(buf, what);
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (p == NULL)
|
|
Packit Service |
e08953 |
goto out;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
p += strlen(what);
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (1 != sscanf(p, "%" PRIu64 " kB", &rc))
|
|
Packit Service |
e08953 |
goto out;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
rc *= 1024;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
out:
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (uv__close_nocheckstdio(fd))
|
|
Packit Service |
e08953 |
abort();
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
return rc;
|
|
Packit Service |
e08953 |
}
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
uint64_t uv_get_free_memory(void) {
|
|
Packit Service |
e08953 |
struct sysinfo info;
|
|
Packit Service |
e08953 |
uint64_t rc;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
rc = uv__read_proc_meminfo("MemFree:");
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (rc != 0)
|
|
Packit Service |
e08953 |
return rc;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (0 == sysinfo(&info))
|
|
Packit Service |
e08953 |
return (uint64_t) info.freeram * info.mem_unit;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
return 0;
|
|
Packit Service |
e08953 |
}
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
uint64_t uv_get_total_memory(void) {
|
|
Packit Service |
e08953 |
struct sysinfo info;
|
|
Packit Service |
e08953 |
uint64_t rc;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
rc = uv__read_proc_meminfo("MemTotal:");
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (rc != 0)
|
|
Packit Service |
e08953 |
return rc;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (0 == sysinfo(&info))
|
|
Packit Service |
e08953 |
return (uint64_t) info.totalram * info.mem_unit;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
return 0;
|
|
Packit Service |
e08953 |
}
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
static uint64_t uv__read_cgroups_uint64(const char* cgroup, const char* param) {
|
|
Packit Service |
e08953 |
char filename[256];
|
|
Packit Service |
e08953 |
uint64_t rc;
|
|
Packit Service |
e08953 |
int fd;
|
|
Packit Service |
e08953 |
ssize_t n;
|
|
Packit Service |
e08953 |
char buf[32]; /* Large enough to hold an encoded uint64_t. */
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
snprintf(filename, 256, "/sys/fs/cgroup/%s/%s", cgroup, param);
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
rc = 0;
|
|
Packit Service |
e08953 |
fd = uv__open_cloexec(filename, O_RDONLY);
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (fd < 0)
|
|
Packit Service |
e08953 |
return 0;
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
n = read(fd, buf, sizeof(buf) - 1);
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (n > 0) {
|
|
Packit Service |
e08953 |
buf[n] = '\0';
|
|
Packit Service |
e08953 |
sscanf(buf, "%" PRIu64, &rc);
|
|
Packit Service |
e08953 |
}
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
if (uv__close_nocheckstdio(fd))
|
|
Packit Service |
e08953 |
abort();
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
return rc;
|
|
Packit Service |
e08953 |
}
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
|
|
Packit Service |
e08953 |
uint64_t uv_get_constrained_memory(void) {
|
|
Packit Service |
e08953 |
/*
|
|
Packit Service |
e08953 |
* This might return 0 if there was a problem getting the memory limit from
|
|
Packit Service |
e08953 |
* cgroups. This is OK because a return value of 0 signifies that the memory
|
|
Packit Service |
e08953 |
* limit is unknown.
|
|
Packit Service |
e08953 |
*/
|
|
Packit Service |
e08953 |
return uv__read_cgroups_uint64("memory", "memory.limit_in_bytes");
|
|
Packit Service |
e08953 |
}
|