X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Freadahead%2Freadahead-collect.c;h=643a5a8ceaa560d8f87b58dca802a3c12fa750a2;hb=e62d8c3944745ed276e6d4f33153009860e5cfc5;hp=5d22949a12d1491985068fef3f77bd61864b976d;hpb=94243ef299425d6c7089a7a05c48c9bb8f6cf3da;p=elogind.git diff --git a/src/readahead/readahead-collect.c b/src/readahead/readahead-collect.c index 5d22949a1..643a5a8ce 100644 --- a/src/readahead/readahead-collect.c +++ b/src/readahead/readahead-collect.c @@ -68,7 +68,7 @@ */ static ReadaheadShared *shared = NULL; -static struct timespec starttime; +static usec_t starttime; /* Avoid collisions with the NULL pointer */ #define SECTOR_TO_PTR(s) ULONG_TO_PTR((s)+1) @@ -260,7 +260,7 @@ static int collect(const char *root) { goto finish; } - clock_gettime(CLOCK_MONOTONIC, &starttime); + starttime = now(CLOCK_MONOTONIC); /* If there's no pack file yet we lower the kernel readahead * so that mincore() is accurate. If there is a pack file @@ -284,13 +284,16 @@ static int collect(const char *root) { goto finish; } - if (!(files = hashmap_new(string_hash_func, string_compare_func))) { + files = hashmap_new(string_hash_func, string_compare_func); + if (!files) { log_error("Failed to allocate set."); r = -ENOMEM; goto finish; } - if ((fanotify_fd = fanotify_init(FAN_CLOEXEC|FAN_NONBLOCK, O_RDONLY|O_LARGEFILE|O_CLOEXEC|O_NOATIME)) < 0) { + fanotify_fd = fanotify_init(FAN_CLOEXEC|FAN_NONBLOCK, + O_RDONLY|O_LARGEFILE|O_CLOEXEC|O_NOATIME); + if (fanotify_fd < 0) { log_error("Failed to create fanotify object: %m"); r = -errno; goto finish; @@ -302,7 +305,8 @@ static int collect(const char *root) { goto finish; } - if ((inotify_fd = open_inotify()) < 0) { + inotify_fd = open_inotify(); + if (inotify_fd < 0) { r = inotify_fd; goto finish; } @@ -459,19 +463,27 @@ static int collect(const char *root) { free(p); else { unsigned long ul; - struct timespec ts; + usec_t entrytime; struct item *entry; entry = new0(struct item, 1); + if (!entry) { + r = log_oom(); + goto finish; + } ul = fd_first_block(m->fd); - clock_gettime(CLOCK_MONOTONIC, &ts); + entrytime = now(CLOCK_MONOTONIC); entry->block = ul; entry->path = strdup(p); - entry->bin = round((ts.tv_sec - starttime.tv_sec + - ((ts.tv_nsec - starttime.tv_nsec) / 1000000000.0)) / 2.0); + if (!entry->path) { + free(entry); + r = log_oom(); + goto finish; + } + entry->bin = (entrytime - starttime) / 2000000; if ((k = hashmap_put(files, p, entry)) < 0) { log_warning("set_put() failed: %s", strerror(-k));