src/shared/util.c

   1 /*-*- Mode: C; c-basic-offset: 8; indent-tabs-mode: nil -*-*/
   2
   3 /***
   4   This file is part of systemd.
   5
   6   Copyright 2010 Lennart Poettering
   7
   8   systemd is free software; you can redistribute it and/or modify it
   9   under the terms of the GNU Lesser General Public License as published by
  10   the Free Software Foundation; either version 2.1 of the License, or
  11   (at your option) any later version.
  12
  13   systemd is distributed in the hope that it will be useful, but
  14   WITHOUT ANY WARRANTY; without even the implied warranty of
  15   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  16   Lesser General Public License for more details.
  17
  18   You should have received a copy of the GNU Lesser General Public License
  19   along with systemd; If not, see <http://www.gnu.org/licenses/>.
  20 ***/
  21
  22 #include <assert.h>
  23 #include <string.h>
  24 #include <unistd.h>
  25 #include <errno.h>
  26 #include <stdlib.h>
  27 #include <signal.h>
  28 #include <stdio.h>
  29 #include <syslog.h>
  30 #include <sched.h>
  31 #include <sys/resource.h>
  32 #include <linux/sched.h>
  33 #include <sys/types.h>
  34 #include <sys/stat.h>
  35 #include <fcntl.h>
  36 #include <dirent.h>
  37 #include <sys/ioctl.h>
  38 #include <linux/vt.h>
  39 #include <linux/tiocl.h>
  40 #include <termios.h>
  41 #include <stdarg.h>
  42 #include <sys/inotify.h>
  43 #include <sys/poll.h>
  44 #include <libgen.h>
  45 #include <ctype.h>
  46 #include <sys/prctl.h>
  47 #include <sys/utsname.h>
  48 #include <pwd.h>
  49 #include <netinet/ip.h>
  50 #include <linux/kd.h>
  51 #include <dlfcn.h>
  52 #include <sys/wait.h>
  53 #include <sys/time.h>
  54 #include <glob.h>
  55 #include <grp.h>
  56 #include <sys/mman.h>
  57 #include <sys/vfs.h>
  58 #include <linux/magic.h>
  59 #include <limits.h>
  60 #include <langinfo.h>
  61 #include <locale.h>
  62
  63 #include "macro.h"
  64 #include "util.h"
  65 #include "ioprio.h"
  66 #include "missing.h"
  67 #include "log.h"
  68 #include "strv.h"
  69 #include "label.h"
  70 #include "path-util.h"
  71 #include "exit-status.h"
  72 #include "hashmap.h"
  73 #include "env-util.h"
  74
  75 int saved_argc = 0;
  76 char **saved_argv = NULL;
  77
  78 static volatile unsigned cached_columns = 0;
  79 static volatile unsigned cached_lines = 0;
  80
  81 size_t page_size(void) {
  82         static __thread size_t pgsz = 0;
  83         long r;
  84
  85         if (_likely_(pgsz > 0))
  86                 return pgsz;
  87
  88         r = sysconf(_SC_PAGESIZE);
  89         assert(r > 0);
  90
  91         pgsz = (size_t) r;
  92         return pgsz;
  93 }
  94
  95 bool streq_ptr(const char *a, const char *b) {
  96
  97         /* Like streq(), but tries to make sense of NULL pointers */
  98
  99         if (a && b)
 100                 return streq(a, b);
 101
 102         if (!a && !b)
 103                 return true;
 104
 105         return false;
 106 }
 107
 108 char* endswith(const char *s, const char *postfix) {
 109         size_t sl, pl;
 110
 111         assert(s);
 112         assert(postfix);
 113
 114         sl = strlen(s);
 115         pl = strlen(postfix);
 116
 117         if (pl == 0)
 118                 return (char*) s + sl;
 119
 120         if (sl < pl)
 121                 return NULL;
 122
 123         if (memcmp(s + sl - pl, postfix, pl) != 0)
 124                 return NULL;
 125
 126         return (char*) s + sl - pl;
 127 }
 128
 129 char* startswith(const char *s, const char *prefix) {
 130         const char *a, *b;
 131
 132         assert(s);
 133         assert(prefix);
 134
 135         a = s, b = prefix;
 136         for (;;) {
 137                 if (*b == 0)
 138                         return (char*) a;
 139                 if (*a != *b)
 140                         return NULL;
 141
 142                 a++, b++;
 143         }
 144 }
 145
 146 char* startswith_no_case(const char *s, const char *prefix) {
 147         const char *a, *b;
 148
 149         assert(s);
 150         assert(prefix);
 151
 152         a = s, b = prefix;
 153         for (;;) {
 154                 if (*b == 0)
 155                         return (char*) a;
 156                 if (tolower(*a) != tolower(*b))
 157                         return NULL;
 158
 159                 a++, b++;
 160         }
 161 }
 162
 163 bool first_word(const char *s, const char *word) {
 164         size_t sl, wl;
 165
 166         assert(s);
 167         assert(word);
 168
 169         sl = strlen(s);
 170         wl = strlen(word);
 171
 172         if (sl < wl)
 173                 return false;
 174
 175         if (wl == 0)
 176                 return true;
 177
 178         if (memcmp(s, word, wl) != 0)
 179                 return false;
 180
 181         return s[wl] == 0 ||
 182                 strchr(WHITESPACE, s[wl]);
 183 }
 184
 185 int close_nointr(int fd) {
 186         int r;
 187
 188         assert(fd >= 0);
 189         r = close(fd);
 190
 191         /* Just ignore EINTR; a retry loop is the wrong
 192          * thing to do on Linux.
 193          *
 194          * http://lkml.indiana.edu/hypermail/linux/kernel/0509.1/0877.html
 195          * https://bugzilla.gnome.org/show_bug.cgi?id=682819
 196          * http://utcc.utoronto.ca/~cks/space/blog/unix/CloseEINTR
 197          * https://sites.google.com/site/michaelsafyan/software-engineering/checkforeintrwheninvokingclosethinkagain
 198          */
 199         if (_unlikely_(r < 0 && errno == EINTR))
 200                 return 0;
 201         else if (r >= 0)
 202                 return r;
 203         else
 204                 return -errno;
 205 }
 206
 207 void close_nointr_nofail(int fd) {
 208         int saved_errno = errno;
 209
 210         /* like close_nointr() but cannot fail, and guarantees errno
 211          * is unchanged */
 212
 213         assert_se(close_nointr(fd) == 0);
 214
 215         errno = saved_errno;
 216 }
 217
 218 void close_many(const int fds[], unsigned n_fd) {
 219         unsigned i;
 220
 221         for (i = 0; i < n_fd; i++)
 222                 close_nointr_nofail(fds[i]);
 223 }
 224
 225 int parse_boolean(const char *v) {
 226         assert(v);
 227
 228         if (streq(v, "1") || v[0] == 'y' || v[0] == 'Y' || v[0] == 't' || v[0] == 'T' || strcaseeq(v, "on"))
 229                 return 1;
 230         else if (streq(v, "0") || v[0] == 'n' || v[0] == 'N' || v[0] == 'f' || v[0] == 'F' || strcaseeq(v, "off"))
 231                 return 0;
 232
 233         return -EINVAL;
 234 }
 235
 236 int parse_pid(const char *s, pid_t* ret_pid) {
 237         unsigned long ul = 0;
 238         pid_t pid;
 239         int r;
 240
 241         assert(s);
 242         assert(ret_pid);
 243
 244         r = safe_atolu(s, &ul);
 245         if (r < 0)
 246                 return r;
 247
 248         pid = (pid_t) ul;
 249
 250         if ((unsigned long) pid != ul)
 251                 return -ERANGE;
 252
 253         if (pid <= 0)
 254                 return -ERANGE;
 255
 256         *ret_pid = pid;
 257         return 0;
 258 }
 259
 260 int parse_uid(const char *s, uid_t* ret_uid) {
 261         unsigned long ul = 0;
 262         uid_t uid;
 263         int r;
 264
 265         assert(s);
 266         assert(ret_uid);
 267
 268         r = safe_atolu(s, &ul);
 269         if (r < 0)
 270                 return r;
 271
 272         uid = (uid_t) ul;
 273
 274         if ((unsigned long) uid != ul)
 275                 return -ERANGE;
 276
 277         *ret_uid = uid;
 278         return 0;
 279 }
 280
 281 int safe_atou(const char *s, unsigned *ret_u) {
 282         char *x = NULL;
 283         unsigned long l;
 284
 285         assert(s);
 286         assert(ret_u);
 287
 288         errno = 0;
 289         l = strtoul(s, &x, 0);
 290
 291         if (!x || x == s || *x || errno)
 292                 return errno ? -errno : -EINVAL;
 293
 294         if ((unsigned long) (unsigned) l != l)
 295                 return -ERANGE;
 296
 297         *ret_u = (unsigned) l;
 298         return 0;
 299 }
 300
 301 int safe_atoi(const char *s, int *ret_i) {
 302         char *x = NULL;
 303         long l;
 304
 305         assert(s);
 306         assert(ret_i);
 307
 308         errno = 0;
 309         l = strtol(s, &x, 0);
 310
 311         if (!x || x == s || *x || errno)
 312                 return errno ? -errno : -EINVAL;
 313
 314         if ((long) (int) l != l)
 315                 return -ERANGE;
 316
 317         *ret_i = (int) l;
 318         return 0;
 319 }
 320
 321 int safe_atollu(const char *s, long long unsigned *ret_llu) {
 322         char *x = NULL;
 323         unsigned long long l;
 324
 325         assert(s);
 326         assert(ret_llu);
 327
 328         errno = 0;
 329         l = strtoull(s, &x, 0);
 330
 331         if (!x || x == s || *x || errno)
 332                 return errno ? -errno : -EINVAL;
 333
 334         *ret_llu = l;
 335         return 0;
 336 }
 337
 338 int safe_atolli(const char *s, long long int *ret_lli) {
 339         char *x = NULL;
 340         long long l;
 341
 342         assert(s);
 343         assert(ret_lli);
 344
 345         errno = 0;
 346         l = strtoll(s, &x, 0);
 347
 348         if (!x || x == s || *x || errno)
 349                 return errno ? -errno : -EINVAL;
 350
 351         *ret_lli = l;
 352         return 0;
 353 }
 354
 355 /* Split a string into words. */
 356 char *split(const char *c, size_t *l, const char *separator, char **state) {
 357         char *current;
 358
 359         current = *state ? *state : (char*) c;
 360
 361         if (!*current || *c == 0)
 362                 return NULL;
 363
 364         current += strspn(current, separator);
 365         *l = strcspn(current, separator);
 366         *state = current+*l;
 367
 368         return (char*) current;
 369 }
 370
 371 /* Split a string into words, but consider strings enclosed in '' and
 372  * "" as words even if they include spaces. */
 373 char *split_quoted(const char *c, size_t *l, char **state) {
 374         char *current, *e;
 375         bool escaped = false;
 376
 377         current = *state ? *state : (char*) c;
 378
 379         if (!*current || *c == 0)
 380                 return NULL;
 381
 382         current += strspn(current, WHITESPACE);
 383
 384         if (*current == '\'') {
 385                 current ++;
 386
 387                 for (e = current; *e; e++) {
 388                         if (escaped)
 389                                 escaped = false;
 390                         else if (*e == '\\')
 391                                 escaped = true;
 392                         else if (*e == '\'')
 393                                 break;
 394                 }
 395
 396                 *l = e-current;
 397                 *state = *e == 0 ? e : e+1;
 398         } else if (*current == '\"') {
 399                 current ++;
 400
 401                 for (e = current; *e; e++) {
 402                         if (escaped)
 403                                 escaped = false;
 404                         else if (*e == '\\')
 405                                 escaped = true;
 406                         else if (*e == '\"')
 407                                 break;
 408                 }
 409
 410                 *l = e-current;
 411                 *state = *e == 0 ? e : e+1;
 412         } else {
 413                 for (e = current; *e; e++) {
 414                         if (escaped)
 415                                 escaped = false;
 416                         else if (*e == '\\')
 417                                 escaped = true;
 418                         else if (strchr(WHITESPACE, *e))
 419                                 break;
 420                 }
 421                 *l = e-current;
 422                 *state = e;
 423         }
 424
 425         return (char*) current;
 426 }
 427
 428 int get_parent_of_pid(pid_t pid, pid_t *_ppid) {
 429         int r;
 430         _cleanup_fclose_ FILE *f = NULL;
 431         char fn[PATH_MAX], line[LINE_MAX], *p;
 432         long unsigned ppid;
 433
 434         assert(pid > 0);
 435         assert(_ppid);
 436
 437         assert_se(snprintf(fn, sizeof(fn)-1, "/proc/%lu/stat", (unsigned long) pid) < (int) (sizeof(fn)-1));
 438         char_array_0(fn);
 439
 440         f = fopen(fn, "re");
 441         if (!f)
 442                 return -errno;
 443
 444         if (!fgets(line, sizeof(line), f)) {
 445                 r = feof(f) ? -EIO : -errno;
 446                 return r;
 447         }
 448
 449         /* Let's skip the pid and comm fields. The latter is enclosed
 450          * in () but does not escape any () in its value, so let's
 451          * skip over it manually */
 452
 453         p = strrchr(line, ')');
 454         if (!p)
 455                 return -EIO;
 456
 457         p++;
 458
 459         if (sscanf(p, " "
 460                    "%*c "  /* state */
 461                    "%lu ", /* ppid */
 462                    &ppid) != 1)
 463                 return -EIO;
 464
 465         if ((long unsigned) (pid_t) ppid != ppid)
 466                 return -ERANGE;
 467
 468         *_ppid = (pid_t) ppid;
 469
 470         return 0;
 471 }
 472
 473 int get_starttime_of_pid(pid_t pid, unsigned long long *st) {
 474         _cleanup_fclose_ FILE *f = NULL;
 475         char fn[PATH_MAX], line[LINE_MAX], *p;
 476
 477         assert(pid > 0);
 478         assert(st);
 479
 480         assert_se(snprintf(fn, sizeof(fn)-1, "/proc/%lu/stat", (unsigned long) pid) < (int) (sizeof(fn)-1));
 481         char_array_0(fn);
 482
 483         f = fopen(fn, "re");
 484         if (!f)
 485                 return -errno;
 486
 487         if (!fgets(line, sizeof(line), f)) {
 488                 if (ferror(f))
 489                         return -errno;
 490
 491                 return -EIO;
 492         }
 493
 494         /* Let's skip the pid and comm fields. The latter is enclosed
 495          * in () but does not escape any () in its value, so let's
 496          * skip over it manually */
 497
 498         p = strrchr(line, ')');
 499         if (!p)
 500                 return -EIO;
 501
 502         p++;
 503
 504         if (sscanf(p, " "
 505                    "%*c "  /* state */
 506                    "%*d "  /* ppid */
 507                    "%*d "  /* pgrp */
 508                    "%*d "  /* session */
 509                    "%*d "  /* tty_nr */
 510                    "%*d "  /* tpgid */
 511                    "%*u "  /* flags */
 512                    "%*u "  /* minflt */
 513                    "%*u "  /* cminflt */
 514                    "%*u "  /* majflt */
 515                    "%*u "  /* cmajflt */
 516                    "%*u "  /* utime */
 517                    "%*u "  /* stime */
 518                    "%*d "  /* cutime */
 519                    "%*d "  /* cstime */
 520                    "%*d "  /* priority */
 521                    "%*d "  /* nice */
 522                    "%*d "  /* num_threads */
 523                    "%*d "  /* itrealvalue */
 524                    "%llu "  /* starttime */,
 525                    st) != 1)
 526                 return -EIO;
 527
 528         return 0;
 529 }
 530
 531 int write_one_line_file(const char *fn, const char *line) {
 532         _cleanup_fclose_ FILE *f = NULL;
 533
 534         assert(fn);
 535         assert(line);
 536
 537         f = fopen(fn, "we");
 538         if (!f)
 539                 return -errno;
 540
 541         errno = 0;
 542         if (fputs(line, f) < 0)
 543                 return errno ? -errno : -EIO;
 544
 545         if (!endswith(line, "\n"))
 546                 fputc('\n', f);
 547
 548         fflush(f);
 549
 550         if (ferror(f))
 551                 return errno ? -errno : -EIO;
 552
 553         return 0;
 554 }
 555
 556 int fchmod_umask(int fd, mode_t m) {
 557         mode_t u;
 558         int r;
 559
 560         u = umask(0777);
 561         r = fchmod(fd, m & (~u)) < 0 ? -errno : 0;
 562         umask(u);
 563
 564         return r;
 565 }
 566
 567 int write_one_line_file_atomic(const char *fn, const char *line) {
 568         _cleanup_fclose_ FILE *f = NULL;
 569         _cleanup_free_ char *p = NULL;
 570         int r;
 571
 572         assert(fn);
 573         assert(line);
 574
 575         r = fopen_temporary(fn, &f, &p);
 576         if (r < 0)
 577                 return r;
 578
 579         fchmod_umask(fileno(f), 0644);
 580
 581         errno = 0;
 582         if (fputs(line, f) < 0) {
 583                 r = -errno;
 584                 goto finish;
 585         }
 586
 587         if (!endswith(line, "\n"))
 588                 fputc('\n', f);
 589
 590         fflush(f);
 591
 592         if (ferror(f))
 593                 r = errno ? -errno : -EIO;
 594         else {
 595                 if (rename(p, fn) < 0)
 596                         r = -errno;
 597                 else
 598                         r = 0;
 599         }
 600
 601 finish:
 602         if (r < 0)
 603                 unlink(p);
 604
 605         return r;
 606 }
 607
 608 int read_one_line_file(const char *fn, char **line) {
 609         _cleanup_fclose_ FILE *f = NULL;
 610         char t[LINE_MAX], *c;
 611
 612         assert(fn);
 613         assert(line);
 614
 615         f = fopen(fn, "re");
 616         if (!f)
 617                 return -errno;
 618
 619         if (!fgets(t, sizeof(t), f)) {
 620
 621                 if (ferror(f))
 622                         return errno ? -errno : -EIO;
 623
 624                 t[0] = 0;
 625         }
 626
 627         c = strdup(t);
 628         if (!c)
 629                 return -ENOMEM;
 630         truncate_nl(c);
 631
 632         *line = c;
 633         return 0;
 634 }
 635
 636 int read_full_file(const char *fn, char **contents, size_t *size) {
 637         _cleanup_fclose_ FILE *f = NULL;
 638         size_t n, l;
 639         _cleanup_free_ char *buf = NULL;
 640         struct stat st;
 641
 642         assert(fn);
 643         assert(contents);
 644
 645         f = fopen(fn, "re");
 646         if (!f)
 647                 return -errno;
 648
 649         if (fstat(fileno(f), &st) < 0)
 650                 return -errno;
 651
 652         /* Safety check */
 653         if (st.st_size > 4*1024*1024)
 654                 return -E2BIG;
 655
 656         n = st.st_size > 0 ? st.st_size : LINE_MAX;
 657         l = 0;
 658
 659         for (;;) {
 660                 char *t;
 661                 size_t k;
 662
 663                 t = realloc(buf, n+1);
 664                 if (!t)
 665                         return -ENOMEM;
 666
 667                 buf = t;
 668                 k = fread(buf + l, 1, n - l, f);
 669
 670                 if (k <= 0) {
 671                         if (ferror(f))
 672                                 return -errno;
 673
 674                         break;
 675                 }
 676
 677                 l += k;
 678                 n *= 2;
 679
 680                 /* Safety check */
 681                 if (n > 4*1024*1024)
 682                         return -E2BIG;
 683         }
 684
 685         buf[l] = 0;
 686         *contents = buf;
 687         buf = NULL;
 688
 689         if (size)
 690                 *size = l;
 691
 692         return 0;
 693 }
 694
 695 int parse_env_file(
 696                 const char *fname,
 697                 const char *separator, ...) {
 698
 699         int r = 0;
 700         char *contents = NULL, *p;
 701
 702         assert(fname);
 703         assert(separator);
 704
 705         if ((r = read_full_file(fname, &contents, NULL)) < 0)
 706                 return r;
 707
 708         p = contents;
 709         for (;;) {
 710                 const char *key = NULL;
 711
 712                 p += strspn(p, separator);
 713                 p += strspn(p, WHITESPACE);
 714
 715                 if (!*p)
 716                         break;
 717
 718                 if (!strchr(COMMENTS, *p)) {
 719                         va_list ap;
 720                         char **value;
 721
 722                         va_start(ap, separator);
 723                         while ((key = va_arg(ap, char *))) {
 724                                 size_t n;
 725                                 char *v;
 726
 727                                 value = va_arg(ap, char **);
 728
 729                                 n = strlen(key);
 730                                 if (!strneq(p, key, n) ||
 731                                     p[n] != '=')
 732                                         continue;
 733
 734                                 p += n + 1;
 735                                 n = strcspn(p, separator);
 736
 737                                 if (n >= 2 &&
 738                                     strchr(QUOTES, p[0]) &&
 739                                     p[n-1] == p[0])
 740                                         v = strndup(p+1, n-2);
 741                                 else
 742                                         v = strndup(p, n);
 743
 744                                 if (!v) {
 745                                         r = -ENOMEM;
 746                                         va_end(ap);
 747                                         goto fail;
 748                                 }
 749
 750                                 if (v[0] == '\0') {
 751                                         /* return empty value strings as NULL */
 752                                         free(v);
 753                                         v = NULL;
 754                                 }
 755
 756                                 free(*value);
 757                                 *value = v;
 758
 759                                 p += n;
 760
 761                                 r ++;
 762                                 break;
 763                         }
 764                         va_end(ap);
 765                 }
 766
 767                 if (!key)
 768                         p += strcspn(p, separator);
 769         }
 770
 771 fail:
 772         free(contents);
 773         return r;
 774 }
 775
 776 int load_env_file(const char *fname, char ***rl) {
 777
 778         _cleanup_fclose_ FILE *f;
 779         _cleanup_strv_free_ char **m = NULL;
 780         _cleanup_free_ char *c = NULL;
 781
 782         assert(fname);
 783         assert(rl);
 784
 785         /* This reads an environment file, but will not complain about
 786          * any invalid assignments, that needs to be done by the
 787          * caller */
 788
 789         f = fopen(fname, "re");
 790         if (!f)
 791                 return -errno;
 792
 793         while (!feof(f)) {
 794                 char l[LINE_MAX], *p, *cs, *b;
 795
 796                 if (!fgets(l, sizeof(l), f)) {
 797                         if (ferror(f))
 798                                 return -errno;
 799
 800                         /* The previous line was a continuation line?
 801                          * Let's process it now, before we leave the
 802                          * loop */
 803                         if (c)
 804                                 goto process;
 805
 806                         break;
 807                 }
 808
 809                 /* Is this a continuation line? If so, just append
 810                  * this to c, and go to next line right-away */
 811                 cs = endswith(l, "\\\n");
 812                 if (cs) {
 813                         *cs = '\0';
 814                         b = strappend(c, l);
 815                         if (!b)
 816                                 return -ENOMEM;
 817
 818                         free(c);
 819                         c = b;
 820                         continue;
 821                 }
 822
 823                 /* If the previous line was a continuation line,
 824                  * append the current line to it */
 825                 if (c) {
 826                         b = strappend(c, l);
 827                         if (!b)
 828                                 return -ENOMEM;
 829
 830                         free(c);
 831                         c = b;
 832                 }
 833
 834         process:
 835                 p = strstrip(c ? c : l);
 836
 837                 if (*p && !strchr(COMMENTS, *p)) {
 838                         _cleanup_free_ char *u;
 839                         int k;
 840
 841                         u = normalize_env_assignment(p);
 842                         if (!u)
 843                                 return -ENOMEM;
 844
 845                         k = strv_extend(&m, u);
 846                         if (k < 0)
 847                                 return -ENOMEM;
 848                 }
 849
 850                 free(c);
 851                 c = NULL;
 852         }
 853
 854         *rl = m;
 855         m = NULL;
 856
 857         return 0;
 858 }
 859
 860 int write_env_file(const char *fname, char **l) {
 861         char **i, *p;
 862         FILE *f;
 863         int r;
 864
 865         r = fopen_temporary(fname, &f, &p);
 866         if (r < 0)
 867                 return r;
 868
 869         fchmod_umask(fileno(f), 0644);
 870
 871         errno = 0;
 872         STRV_FOREACH(i, l) {
 873                 fputs(*i, f);
 874                 fputc('\n', f);
 875         }
 876
 877         fflush(f);
 878
 879         if (ferror(f)) {
 880                 if (errno != 0)
 881                         r = -errno;
 882                 else
 883                         r = -EIO;
 884         } else {
 885                 if (rename(p, fname) < 0)
 886                         r = -errno;
 887                 else
 888                         r = 0;
 889         }
 890
 891         if (r < 0)
 892                 unlink(p);
 893
 894         fclose(f);
 895         free(p);
 896
 897         return r;
 898 }
 899
 900 char *truncate_nl(char *s) {
 901         assert(s);
 902
 903         s[strcspn(s, NEWLINE)] = 0;
 904         return s;
 905 }
 906
 907 int get_process_comm(pid_t pid, char **name) {
 908         int r;
 909
 910         assert(name);
 911
 912         if (pid == 0)
 913                 r = read_one_line_file("/proc/self/comm", name);
 914         else {
 915                 char *p;
 916                 if (asprintf(&p, "/proc/%lu/comm", (unsigned long) pid) < 0)
 917                         return -ENOMEM;
 918
 919                 r = read_one_line_file(p, name);
 920                 free(p);
 921         }
 922
 923         return r;
 924 }
 925
 926 int get_process_cmdline(pid_t pid, size_t max_length, bool comm_fallback, char **line) {
 927         char *r = NULL, *k;
 928         int c;
 929         FILE *f;
 930
 931         assert(line);
 932
 933         if (pid == 0)
 934                 f = fopen("/proc/self/cmdline", "re");
 935         else {
 936                 char *p;
 937                 if (asprintf(&p, "/proc/%lu/cmdline", (unsigned long) pid) < 0)
 938                         return -ENOMEM;
 939
 940                 f = fopen(p, "re");
 941                 free(p);
 942         }
 943
 944         if (!f)
 945                 return -errno;
 946         if (max_length == 0) {
 947                 size_t len = 1;
 948                 while ((c = getc(f)) != EOF) {
 949                         k = realloc(r, len+1);
 950                         if (k == NULL) {
 951                                 free(r);
 952                                 fclose(f);
 953                                 return -ENOMEM;
 954                         }
 955                         r = k;
 956                         r[len-1] = isprint(c) ? c : ' ';
 957                         r[len] = 0;
 958                         len++;
 959                 }
 960         } else {
 961                 bool space = false;
 962                 size_t left;
 963                 r = new(char, max_length);
 964                 if (!r) {
 965                         fclose(f);
 966                         return -ENOMEM;
 967                 }
 968
 969                 k = r;
 970                 left = max_length;
 971                 while ((c = getc(f)) != EOF) {
 972
 973                         if (isprint(c)) {
 974                                 if (space) {
 975                                         if (left <= 4)
 976                                                 break;
 977
 978                                         *(k++) = ' ';
 979                                         left--;
 980                                         space = false;
 981                                 }
 982
 983                                 if (left <= 4)
 984                                         break;
 985
 986                                 *(k++) = (char) c;
 987                                 left--;
 988                         }  else
 989                                 space = true;
 990                 }
 991
 992                 if (left <= 4) {
 993                         size_t n = MIN(left-1, 3U);
 994                         memcpy(k, "...", n);
 995                         k[n] = 0;
 996                 } else
 997                         *k = 0;
 998         }
 999
1000         fclose(f);
1001
1002         /* Kernel threads have no argv[] */
1003         if (r == NULL || r[0] == 0) {
1004                 char *t;
1005                 int h;
1006
1007                 free(r);
1008
1009                 if (!comm_fallback)
1010                         return -ENOENT;
1011
1012                 h = get_process_comm(pid, &t);
1013                 if (h < 0)
1014                         return h;
1015
1016                 r = strjoin("[", t, "]", NULL);
1017                 free(t);
1018
1019                 if (!r)
1020                         return -ENOMEM;
1021         }
1022
1023         *line = r;
1024         return 0;
1025 }
1026
1027 int is_kernel_thread(pid_t pid) {
1028         char *p;
1029         size_t count;
1030         char c;
1031         bool eof;
1032         FILE *f;
1033
1034         if (pid == 0)
1035                 return 0;
1036
1037         if (asprintf(&p, "/proc/%lu/cmdline", (unsigned long) pid) < 0)
1038                 return -ENOMEM;
1039
1040         f = fopen(p, "re");
1041         free(p);
1042
1043         if (!f)
1044                 return -errno;
1045
1046         count = fread(&c, 1, 1, f);
1047         eof = feof(f);
1048         fclose(f);
1049
1050         /* Kernel threads have an empty cmdline */
1051
1052         if (count <= 0)
1053                 return eof ? 1 : -errno;
1054
1055         return 0;
1056 }
1057
1058 int get_process_exe(pid_t pid, char **name) {
1059         int r;
1060
1061         assert(name);
1062
1063         if (pid == 0)
1064                 r = readlink_malloc("/proc/self/exe", name);
1065         else {
1066                 char *p;
1067                 if (asprintf(&p, "/proc/%lu/exe", (unsigned long) pid) < 0)
1068                         return -ENOMEM;
1069
1070                 r = readlink_malloc(p, name);
1071                 free(p);
1072         }
1073
1074         return r;
1075 }
1076
1077 static int get_process_id(pid_t pid, const char *field, uid_t *uid) {
1078         _cleanup_fclose_ FILE *f = NULL;
1079         _cleanup_free_ char *p = NULL;
1080
1081         assert(field);
1082         assert(uid);
1083
1084         if (pid == 0)
1085                 return getuid();
1086
1087         if (asprintf(&p, "/proc/%lu/status", (unsigned long) pid) < 0)
1088                 return -ENOMEM;
1089
1090         f = fopen(p, "re");
1091         if (!f)
1092                 return -errno;
1093
1094         FOREACH_LINE(f, line, return -errno) {
1095                 char *l;
1096
1097                 l = strstrip(line);
1098
1099                 if (startswith(l, field)) {
1100                         l += strlen(field);
1101                         l += strspn(l, WHITESPACE);
1102
1103                         l[strcspn(l, WHITESPACE)] = 0;
1104
1105                         return parse_uid(l, uid);
1106                 }
1107         }
1108
1109         return -EIO;
1110 }
1111
1112 int get_process_uid(pid_t pid, uid_t *uid) {
1113         return get_process_id(pid, "Uid:", uid);
1114 }
1115
1116 int get_process_gid(pid_t pid, gid_t *gid) {
1117         return get_process_id(pid, "Gid:", gid);
1118 }
1119
1120 char *strnappend(const char *s, const char *suffix, size_t b) {
1121         size_t a;
1122         char *r;
1123
1124         if (!s && !suffix)
1125                 return strdup("");
1126
1127         if (!s)
1128                 return strndup(suffix, b);
1129
1130         if (!suffix)
1131                 return strdup(s);
1132
1133         assert(s);
1134         assert(suffix);
1135
1136         a = strlen(s);
1137         if (b > ((size_t) -1) - a)
1138                 return NULL;
1139
1140         r = new(char, a+b+1);
1141         if (!r)
1142                 return NULL;
1143
1144         memcpy(r, s, a);
1145         memcpy(r+a, suffix, b);
1146         r[a+b] = 0;
1147
1148         return r;
1149 }
1150
1151 char *strappend(const char *s, const char *suffix) {
1152         return strnappend(s, suffix, suffix ? strlen(suffix) : 0);
1153 }
1154
1155 int readlink_malloc(const char *p, char **r) {
1156         size_t l = 100;
1157
1158         assert(p);
1159         assert(r);
1160
1161         for (;;) {
1162                 char *c;
1163                 ssize_t n;
1164
1165                 if (!(c = new(char, l)))
1166                         return -ENOMEM;
1167
1168                 if ((n = readlink(p, c, l-1)) < 0) {
1169                         int ret = -errno;
1170                         free(c);
1171                         return ret;
1172                 }
1173
1174                 if ((size_t) n < l-1) {
1175                         c[n] = 0;
1176                         *r = c;
1177                         return 0;
1178                 }
1179
1180                 free(c);
1181                 l *= 2;
1182         }
1183 }
1184
1185 int readlink_and_make_absolute(const char *p, char **r) {
1186         char *target, *k;
1187         int j;
1188
1189         assert(p);
1190         assert(r);
1191
1192         if ((j = readlink_malloc(p, &target)) < 0)
1193                 return j;
1194
1195         k = file_in_same_dir(p, target);
1196         free(target);
1197
1198         if (!k)
1199                 return -ENOMEM;
1200
1201         *r = k;
1202         return 0;
1203 }
1204
1205 int readlink_and_canonicalize(const char *p, char **r) {
1206         char *t, *s;
1207         int j;
1208
1209         assert(p);
1210         assert(r);
1211
1212         j = readlink_and_make_absolute(p, &t);
1213         if (j < 0)
1214                 return j;
1215
1216         s = canonicalize_file_name(t);
1217         if (s) {
1218                 free(t);
1219                 *r = s;
1220         } else
1221                 *r = t;
1222
1223         path_kill_slashes(*r);
1224
1225         return 0;
1226 }
1227
1228 int reset_all_signal_handlers(void) {
1229         int sig;
1230
1231         for (sig = 1; sig < _NSIG; sig++) {
1232                 struct sigaction sa;
1233
1234                 if (sig == SIGKILL || sig == SIGSTOP)
1235                         continue;
1236
1237                 zero(sa);
1238                 sa.sa_handler = SIG_DFL;
1239                 sa.sa_flags = SA_RESTART;
1240
1241                 /* On Linux the first two RT signals are reserved by
1242                  * glibc, and sigaction() will return EINVAL for them. */
1243                 if ((sigaction(sig, &sa, NULL) < 0))
1244                         if (errno != EINVAL)
1245                                 return -errno;
1246         }
1247
1248         return 0;
1249 }
1250
1251 char *strstrip(char *s) {
1252         char *e;
1253
1254         /* Drops trailing whitespace. Modifies the string in
1255          * place. Returns pointer to first non-space character */
1256
1257         s += strspn(s, WHITESPACE);
1258
1259         for (e = strchr(s, 0); e > s; e --)
1260                 if (!strchr(WHITESPACE, e[-1]))
1261                         break;
1262
1263         *e = 0;
1264
1265         return s;
1266 }
1267
1268 char *delete_chars(char *s, const char *bad) {
1269         char *f, *t;
1270
1271         /* Drops all whitespace, regardless where in the string */
1272
1273         for (f = s, t = s; *f; f++) {
1274                 if (strchr(bad, *f))
1275                         continue;
1276
1277                 *(t++) = *f;
1278         }
1279
1280         *t = 0;
1281
1282         return s;
1283 }
1284
1285 bool in_charset(const char *s, const char* charset) {
1286         const char *i;
1287
1288         assert(s);
1289         assert(charset);
1290
1291         for (i = s; *i; i++)
1292                 if (!strchr(charset, *i))
1293                         return false;
1294
1295         return true;
1296 }
1297
1298 char *file_in_same_dir(const char *path, const char *filename) {
1299         char *e, *r;
1300         size_t k;
1301
1302         assert(path);
1303         assert(filename);
1304
1305         /* This removes the last component of path and appends
1306          * filename, unless the latter is absolute anyway or the
1307          * former isn't */
1308
1309         if (path_is_absolute(filename))
1310                 return strdup(filename);
1311
1312         if (!(e = strrchr(path, '/')))
1313                 return strdup(filename);
1314
1315         k = strlen(filename);
1316         if (!(r = new(char, e-path+1+k+1)))
1317                 return NULL;
1318
1319         memcpy(r, path, e-path+1);
1320         memcpy(r+(e-path)+1, filename, k+1);
1321
1322         return r;
1323 }
1324
1325 int rmdir_parents(const char *path, const char *stop) {
1326         size_t l;
1327         int r = 0;
1328
1329         assert(path);
1330         assert(stop);
1331
1332         l = strlen(path);
1333
1334         /* Skip trailing slashes */
1335         while (l > 0 && path[l-1] == '/')
1336                 l--;
1337
1338         while (l > 0) {
1339                 char *t;
1340
1341                 /* Skip last component */
1342                 while (l > 0 && path[l-1] != '/')
1343                         l--;
1344
1345                 /* Skip trailing slashes */
1346                 while (l > 0 && path[l-1] == '/')
1347                         l--;
1348
1349                 if (l <= 0)
1350                         break;
1351
1352                 if (!(t = strndup(path, l)))
1353                         return -ENOMEM;
1354
1355                 if (path_startswith(stop, t)) {
1356                         free(t);
1357                         return 0;
1358                 }
1359
1360                 r = rmdir(t);
1361                 free(t);
1362
1363                 if (r < 0)
1364                         if (errno != ENOENT)
1365                                 return -errno;
1366         }
1367
1368         return 0;
1369 }
1370
1371
1372 char hexchar(int x) {
1373         static const char table[16] = "0123456789abcdef";
1374
1375         return table[x & 15];
1376 }
1377
1378 int unhexchar(char c) {
1379
1380         if (c >= '0' && c <= '9')
1381                 return c - '0';
1382
1383         if (c >= 'a' && c <= 'f')
1384                 return c - 'a' + 10;
1385
1386         if (c >= 'A' && c <= 'F')
1387                 return c - 'A' + 10;
1388
1389         return -1;
1390 }
1391
1392 char octchar(int x) {
1393         return '0' + (x & 7);
1394 }
1395
1396 int unoctchar(char c) {
1397
1398         if (c >= '0' && c <= '7')
1399                 return c - '0';
1400
1401         return -1;
1402 }
1403
1404 char decchar(int x) {
1405         return '0' + (x % 10);
1406 }
1407
1408 int undecchar(char c) {
1409
1410         if (c >= '0' && c <= '9')
1411                 return c - '0';
1412
1413         return -1;
1414 }
1415
1416 char *cescape(const char *s) {
1417         char *r, *t;
1418         const char *f;
1419
1420         assert(s);
1421
1422         /* Does C style string escaping. */
1423
1424         r = new(char, strlen(s)*4 + 1);
1425         if (!r)
1426                 return NULL;
1427
1428         for (f = s, t = r; *f; f++)
1429
1430                 switch (*f) {
1431
1432                 case '\a':
1433                         *(t++) = '\\';
1434                         *(t++) = 'a';
1435                         break;
1436                 case '\b':
1437                         *(t++) = '\\';
1438                         *(t++) = 'b';
1439                         break;
1440                 case '\f':
1441                         *(t++) = '\\';
1442                         *(t++) = 'f';
1443                         break;
1444                 case '\n':
1445                         *(t++) = '\\';
1446                         *(t++) = 'n';
1447                         break;
1448                 case '\r':
1449                         *(t++) = '\\';
1450                         *(t++) = 'r';
1451                         break;
1452                 case '\t':
1453                         *(t++) = '\\';
1454                         *(t++) = 't';
1455                         break;
1456                 case '\v':
1457                         *(t++) = '\\';
1458                         *(t++) = 'v';
1459                         break;
1460                 case '\\':
1461                         *(t++) = '\\';
1462                         *(t++) = '\\';
1463                         break;
1464                 case '"':
1465                         *(t++) = '\\';
1466                         *(t++) = '"';
1467                         break;
1468                 case '\'':
1469                         *(t++) = '\\';
1470                         *(t++) = '\'';
1471                         break;
1472
1473                 default:
1474                         /* For special chars we prefer octal over
1475                          * hexadecimal encoding, simply because glib's
1476                          * g_strescape() does the same */
1477                         if ((*f < ' ') || (*f >= 127)) {
1478                                 *(t++) = '\\';
1479                                 *(t++) = octchar((unsigned char) *f >> 6);
1480                                 *(t++) = octchar((unsigned char) *f >> 3);
1481                                 *(t++) = octchar((unsigned char) *f);
1482                         } else
1483                                 *(t++) = *f;
1484                         break;
1485                 }
1486
1487         *t = 0;
1488
1489         return r;
1490 }
1491
1492 char *cunescape_length_with_prefix(const char *s, size_t length, const char *prefix) {
1493         char *r, *t;
1494         const char *f;
1495         size_t pl;
1496
1497         assert(s);
1498
1499         /* Undoes C style string escaping, and optionally prefixes it. */
1500
1501         pl = prefix ? strlen(prefix) : 0;
1502
1503         r = new(char, pl+length+1);
1504         if (!r)
1505                 return r;
1506
1507         if (prefix)
1508                 memcpy(r, prefix, pl);
1509
1510         for (f = s, t = r + pl; f < s + length; f++) {
1511
1512                 if (*f != '\\') {
1513                         *(t++) = *f;
1514                         continue;
1515                 }
1516
1517                 f++;
1518
1519                 switch (*f) {
1520
1521                 case 'a':
1522                         *(t++) = '\a';
1523                         break;
1524                 case 'b':
1525                         *(t++) = '\b';
1526                         break;
1527                 case 'f':
1528                         *(t++) = '\f';
1529                         break;
1530                 case 'n':
1531                         *(t++) = '\n';
1532                         break;
1533                 case 'r':
1534                         *(t++) = '\r';
1535                         break;
1536                 case 't':
1537                         *(t++) = '\t';
1538                         break;
1539                 case 'v':
1540                         *(t++) = '\v';
1541                         break;
1542                 case '\\':
1543                         *(t++) = '\\';
1544                         break;
1545                 case '"':
1546                         *(t++) = '"';
1547                         break;
1548                 case '\'':
1549                         *(t++) = '\'';
1550                         break;
1551
1552                 case 's':
1553                         /* This is an extension of the XDG syntax files */
1554                         *(t++) = ' ';
1555                         break;
1556
1557                 case 'x': {
1558                         /* hexadecimal encoding */
1559                         int a, b;
1560
1561                         a = unhexchar(f[1]);
1562                         b = unhexchar(f[2]);
1563
1564                         if (a < 0 || b < 0) {
1565                                 /* Invalid escape code, let's take it literal then */
1566                                 *(t++) = '\\';
1567                                 *(t++) = 'x';
1568                         } else {
1569                                 *(t++) = (char) ((a << 4) | b);
1570                                 f += 2;
1571                         }
1572
1573                         break;
1574                 }
1575
1576                 case '0':
1577                 case '1':
1578                 case '2':
1579                 case '3':
1580                 case '4':
1581                 case '5':
1582                 case '6':
1583                 case '7': {
1584                         /* octal encoding */
1585                         int a, b, c;
1586
1587                         a = unoctchar(f[0]);
1588                         b = unoctchar(f[1]);
1589                         c = unoctchar(f[2]);
1590
1591                         if (a < 0 || b < 0 || c < 0) {
1592                                 /* Invalid escape code, let's take it literal then */
1593                                 *(t++) = '\\';
1594                                 *(t++) = f[0];
1595                         } else {
1596                                 *(t++) = (char) ((a << 6) | (b << 3) | c);
1597                                 f += 2;
1598                         }
1599
1600                         break;
1601                 }
1602
1603                 case 0:
1604                         /* premature end of string.*/
1605                         *(t++) = '\\';
1606                         goto finish;
1607
1608                 default:
1609                         /* Invalid escape code, let's take it literal then */
1610                         *(t++) = '\\';
1611                         *(t++) = *f;
1612                         break;
1613                 }
1614         }
1615
1616 finish:
1617         *t = 0;
1618         return r;
1619 }
1620
1621 char *cunescape_length(const char *s, size_t length) {
1622         return cunescape_length_with_prefix(s, length, NULL);
1623 }
1624
1625 char *cunescape(const char *s) {
1626         assert(s);
1627
1628         return cunescape_length(s, strlen(s));
1629 }
1630
1631 char *xescape(const char *s, const char *bad) {
1632         char *r, *t;
1633         const char *f;
1634
1635         /* Escapes all chars in bad, in addition to \ and all special
1636          * chars, in \xFF style escaping. May be reversed with
1637          * cunescape. */
1638
1639         r = new(char, strlen(s) * 4 + 1);
1640         if (!r)
1641                 return NULL;
1642
1643         for (f = s, t = r; *f; f++) {
1644
1645                 if ((*f < ' ') || (*f >= 127) ||
1646                     (*f == '\\') || strchr(bad, *f)) {
1647                         *(t++) = '\\';
1648                         *(t++) = 'x';
1649                         *(t++) = hexchar(*f >> 4);
1650                         *(t++) = hexchar(*f);
1651                 } else
1652                         *(t++) = *f;
1653         }
1654
1655         *t = 0;
1656
1657         return r;
1658 }
1659
1660 char *bus_path_escape(const char *s) {
1661         char *r, *t;
1662         const char *f;
1663
1664         assert(s);
1665
1666         /* Escapes all chars that D-Bus' object path cannot deal
1667          * with. Can be reverse with bus_path_unescape() */
1668
1669         if (!(r = new(char, strlen(s)*3+1)))
1670                 return NULL;
1671
1672         for (f = s, t = r; *f; f++) {
1673
1674                 if (!(*f >= 'A' && *f <= 'Z') &&
1675                     !(*f >= 'a' && *f <= 'z') &&
1676                     !(*f >= '0' && *f <= '9')) {
1677                         *(t++) = '_';
1678                         *(t++) = hexchar(*f >> 4);
1679                         *(t++) = hexchar(*f);
1680                 } else
1681                         *(t++) = *f;
1682         }
1683
1684         *t = 0;
1685
1686         return r;
1687 }
1688
1689 char *bus_path_unescape(const char *f) {
1690         char *r, *t;
1691
1692         assert(f);
1693
1694         if (!(r = strdup(f)))
1695                 return NULL;
1696
1697         for (t = r; *f; f++) {
1698
1699                 if (*f == '_') {
1700                         int a, b;
1701
1702                         if ((a = unhexchar(f[1])) < 0 ||
1703                             (b = unhexchar(f[2])) < 0) {
1704                                 /* Invalid escape code, let's take it literal then */
1705                                 *(t++) = '_';
1706                         } else {
1707                                 *(t++) = (char) ((a << 4) | b);
1708                                 f += 2;
1709                         }
1710                 } else
1711                         *(t++) = *f;
1712         }
1713
1714         *t = 0;
1715
1716         return r;
1717 }
1718
1719 char *ascii_strlower(char *t) {
1720         char *p;
1721
1722         assert(t);
1723
1724         for (p = t; *p; p++)
1725                 if (*p >= 'A' && *p <= 'Z')
1726                         *p = *p - 'A' + 'a';
1727
1728         return t;
1729 }
1730
1731 static bool ignore_file_allow_backup(const char *filename) {
1732         assert(filename);
1733
1734         return
1735                 filename[0] == '.' ||
1736                 streq(filename, "lost+found") ||
1737                 streq(filename, "aquota.user") ||
1738                 streq(filename, "aquota.group") ||
1739                 endswith(filename, ".rpmnew") ||
1740                 endswith(filename, ".rpmsave") ||
1741                 endswith(filename, ".rpmorig") ||
1742                 endswith(filename, ".dpkg-old") ||
1743                 endswith(filename, ".dpkg-new") ||
1744                 endswith(filename, ".swp");
1745 }
1746
1747 bool ignore_file(const char *filename) {
1748         assert(filename);
1749
1750         if (endswith(filename, "~"))
1751                 return false;
1752
1753         return ignore_file_allow_backup(filename);
1754 }
1755
1756 int fd_nonblock(int fd, bool nonblock) {
1757         int flags;
1758
1759         assert(fd >= 0);
1760
1761         if ((flags = fcntl(fd, F_GETFL, 0)) < 0)
1762                 return -errno;
1763
1764         if (nonblock)
1765                 flags |= O_NONBLOCK;
1766         else
1767                 flags &= ~O_NONBLOCK;
1768
1769         if (fcntl(fd, F_SETFL, flags) < 0)
1770                 return -errno;
1771
1772         return 0;
1773 }
1774
1775 int fd_cloexec(int fd, bool cloexec) {
1776         int flags;
1777
1778         assert(fd >= 0);
1779
1780         if ((flags = fcntl(fd, F_GETFD, 0)) < 0)
1781                 return -errno;
1782
1783         if (cloexec)
1784                 flags |= FD_CLOEXEC;
1785         else
1786                 flags &= ~FD_CLOEXEC;
1787
1788         if (fcntl(fd, F_SETFD, flags) < 0)
1789                 return -errno;
1790
1791         return 0;
1792 }
1793
1794 static bool fd_in_set(int fd, const int fdset[], unsigned n_fdset) {
1795         unsigned i;
1796
1797         assert(n_fdset == 0 || fdset);
1798
1799         for (i = 0; i < n_fdset; i++)
1800                 if (fdset[i] == fd)
1801                         return true;
1802
1803         return false;
1804 }
1805
1806 int close_all_fds(const int except[], unsigned n_except) {
1807         DIR *d;
1808         struct dirent *de;
1809         int r = 0;
1810
1811         assert(n_except == 0 || except);
1812
1813         d = opendir("/proc/self/fd");
1814         if (!d) {
1815                 int fd;
1816                 struct rlimit rl;
1817
1818                 /* When /proc isn't available (for example in chroots)
1819                  * the fallback is brute forcing through the fd
1820                  * table */
1821
1822                 assert_se(getrlimit(RLIMIT_NOFILE, &rl) >= 0);
1823                 for (fd = 3; fd < (int) rl.rlim_max; fd ++) {
1824
1825                         if (fd_in_set(fd, except, n_except))
1826                                 continue;
1827
1828                         if (close_nointr(fd) < 0)
1829                                 if (errno != EBADF && r == 0)
1830                                         r = -errno;
1831                 }
1832
1833                 return r;
1834         }
1835
1836         while ((de = readdir(d))) {
1837                 int fd = -1;
1838
1839                 if (ignore_file(de->d_name))
1840                         continue;
1841
1842                 if (safe_atoi(de->d_name, &fd) < 0)
1843                         /* Let's better ignore this, just in case */
1844                         continue;
1845
1846                 if (fd < 3)
1847                         continue;
1848
1849                 if (fd == dirfd(d))
1850                         continue;
1851
1852                 if (fd_in_set(fd, except, n_except))
1853                         continue;
1854
1855                 if (close_nointr(fd) < 0) {
1856                         /* Valgrind has its own FD and doesn't want to have it closed */
1857                         if (errno != EBADF && r == 0)
1858                                 r = -errno;
1859                 }
1860         }
1861
1862         closedir(d);
1863         return r;
1864 }
1865
1866 bool chars_intersect(const char *a, const char *b) {
1867         const char *p;
1868
1869         /* Returns true if any of the chars in a are in b. */
1870         for (p = a; *p; p++)
1871                 if (strchr(b, *p))
1872                         return true;
1873
1874         return false;
1875 }
1876
1877 bool fstype_is_network(const char *fstype) {
1878         static const char table[] =
1879                 "cifs\0"
1880                 "smbfs\0"
1881                 "ncpfs\0"
1882                 "nfs\0"
1883                 "nfs4\0"
1884                 "gfs\0"
1885                 "gfs2\0";
1886
1887         return nulstr_contains(table, fstype);
1888 }
1889
1890 int chvt(int vt) {
1891         _cleanup_close_ int fd;
1892
1893         fd = open_terminal("/dev/tty0", O_RDWR|O_NOCTTY|O_CLOEXEC);
1894         if (fd < 0)
1895                 return -errno;
1896
1897         if (vt < 0) {
1898                 int tiocl[2] = {
1899                         TIOCL_GETKMSGREDIRECT,
1900                         0
1901                 };
1902
1903                 if (ioctl(fd, TIOCLINUX, tiocl) < 0)
1904                         return -errno;
1905
1906                 vt = tiocl[0] <= 0 ? 1 : tiocl[0];
1907         }
1908
1909         if (ioctl(fd, VT_ACTIVATE, vt) < 0)
1910                 return -errno;
1911
1912         return 0;
1913 }
1914
1915 int read_one_char(FILE *f, char *ret, usec_t t, bool *need_nl) {
1916         struct termios old_termios, new_termios;
1917         char c;
1918         char line[LINE_MAX];
1919
1920         assert(f);
1921         assert(ret);
1922
1923         if (tcgetattr(fileno(f), &old_termios) >= 0) {
1924                 new_termios = old_termios;
1925
1926                 new_termios.c_lflag &= ~ICANON;
1927                 new_termios.c_cc[VMIN] = 1;
1928                 new_termios.c_cc[VTIME] = 0;
1929
1930                 if (tcsetattr(fileno(f), TCSADRAIN, &new_termios) >= 0) {
1931                         size_t k;
1932
1933                         if (t != (usec_t) -1) {
1934                                 if (fd_wait_for_event(fileno(f), POLLIN, t) <= 0) {
1935                                         tcsetattr(fileno(f), TCSADRAIN, &old_termios);
1936                                         return -ETIMEDOUT;
1937                                 }
1938                         }
1939
1940                         k = fread(&c, 1, 1, f);
1941
1942                         tcsetattr(fileno(f), TCSADRAIN, &old_termios);
1943
1944                         if (k <= 0)
1945                                 return -EIO;
1946
1947                         if (need_nl)
1948                                 *need_nl = c != '\n';
1949
1950                         *ret = c;
1951                         return 0;
1952                 }
1953         }
1954
1955         if (t != (usec_t) -1)
1956                 if (fd_wait_for_event(fileno(f), POLLIN, t) <= 0)
1957                         return -ETIMEDOUT;
1958
1959         if (!fgets(line, sizeof(line), f))
1960                 return -EIO;
1961
1962         truncate_nl(line);
1963
1964         if (strlen(line) != 1)
1965                 return -EBADMSG;
1966
1967         if (need_nl)
1968                 *need_nl = false;
1969
1970         *ret = line[0];
1971         return 0;
1972 }
1973
1974 int ask(char *ret, const char *replies, const char *text, ...) {
1975
1976         assert(ret);
1977         assert(replies);
1978         assert(text);
1979
1980         for (;;) {
1981                 va_list ap;
1982                 char c;
1983                 int r;
1984                 bool need_nl = true;
1985
1986                 if (on_tty())
1987                         fputs(ANSI_HIGHLIGHT_ON, stdout);
1988
1989                 va_start(ap, text);
1990                 vprintf(text, ap);
1991                 va_end(ap);
1992
1993                 if (on_tty())
1994                         fputs(ANSI_HIGHLIGHT_OFF, stdout);
1995
1996                 fflush(stdout);
1997
1998                 r = read_one_char(stdin, &c, (usec_t) -1, &need_nl);
1999                 if (r < 0) {
2000
2001                         if (r == -EBADMSG) {
2002                                 puts("Bad input, please try again.");
2003                                 continue;
2004                         }
2005
2006                         putchar('\n');
2007                         return r;
2008                 }
2009
2010                 if (need_nl)
2011                         putchar('\n');
2012
2013                 if (strchr(replies, c)) {
2014                         *ret = c;
2015                         return 0;
2016                 }
2017
2018                 puts("Read unexpected character, please try again.");
2019         }
2020 }
2021
2022 int reset_terminal_fd(int fd, bool switch_to_text) {
2023         struct termios termios;
2024         int r = 0;
2025
2026         /* Set terminal to some sane defaults */
2027
2028         assert(fd >= 0);
2029
2030         /* We leave locked terminal attributes untouched, so that
2031          * Plymouth may set whatever it wants to set, and we don't
2032          * interfere with that. */
2033
2034         /* Disable exclusive mode, just in case */
2035         ioctl(fd, TIOCNXCL);
2036
2037         /* Switch to text mode */
2038         if (switch_to_text)
2039                 ioctl(fd, KDSETMODE, KD_TEXT);
2040
2041         /* Enable console unicode mode */
2042         ioctl(fd, KDSKBMODE, K_UNICODE);
2043
2044         if (tcgetattr(fd, &termios) < 0) {
2045                 r = -errno;
2046                 goto finish;
2047         }
2048
2049         /* We only reset the stuff that matters to the software. How
2050          * hardware is set up we don't touch assuming that somebody
2051          * else will do that for us */
2052
2053         termios.c_iflag &= ~(IGNBRK | BRKINT | ISTRIP | INLCR | IGNCR | IUCLC);
2054         termios.c_iflag |= ICRNL | IMAXBEL | IUTF8;
2055         termios.c_oflag |= ONLCR;
2056         termios.c_cflag |= CREAD;
2057         termios.c_lflag = ISIG | ICANON | IEXTEN | ECHO | ECHOE | ECHOK | ECHOCTL | ECHOPRT | ECHOKE;
2058
2059         termios.c_cc[VINTR]    =   03;  /* ^C */
2060         termios.c_cc[VQUIT]    =  034;  /* ^\ */
2061         termios.c_cc[VERASE]   = 0177;
2062         termios.c_cc[VKILL]    =  025;  /* ^X */
2063         termios.c_cc[VEOF]     =   04;  /* ^D */
2064         termios.c_cc[VSTART]   =  021;  /* ^Q */
2065         termios.c_cc[VSTOP]    =  023;  /* ^S */
2066         termios.c_cc[VSUSP]    =  032;  /* ^Z */
2067         termios.c_cc[VLNEXT]   =  026;  /* ^V */
2068         termios.c_cc[VWERASE]  =  027;  /* ^W */
2069         termios.c_cc[VREPRINT] =  022;  /* ^R */
2070         termios.c_cc[VEOL]     =    0;
2071         termios.c_cc[VEOL2]    =    0;
2072
2073         termios.c_cc[VTIME]  = 0;
2074         termios.c_cc[VMIN]   = 1;
2075
2076         if (tcsetattr(fd, TCSANOW, &termios) < 0)
2077                 r = -errno;
2078
2079 finish:
2080         /* Just in case, flush all crap out */
2081         tcflush(fd, TCIOFLUSH);
2082
2083         return r;
2084 }
2085
2086 int reset_terminal(const char *name) {
2087         int fd, r;
2088
2089         fd = open_terminal(name, O_RDWR|O_NOCTTY|O_CLOEXEC);
2090         if (fd < 0)
2091                 return fd;
2092
2093         r = reset_terminal_fd(fd, true);
2094         close_nointr_nofail(fd);
2095
2096         return r;
2097 }
2098
2099 int open_terminal(const char *name, int mode) {
2100         int fd, r;
2101         unsigned c = 0;
2102
2103         /*
2104          * If a TTY is in the process of being closed opening it might
2105          * cause EIO. This is horribly awful, but unlikely to be
2106          * changed in the kernel. Hence we work around this problem by
2107          * retrying a couple of times.
2108          *
2109          * https://bugs.launchpad.net/ubuntu/+source/linux/+bug/554172/comments/245
2110          */
2111
2112         for (;;) {
2113                 fd = open(name, mode);
2114                 if (fd >= 0)
2115                         break;
2116
2117                 if (errno != EIO)
2118                         return -errno;
2119
2120                 /* Max 1s in total */
2121                 if (c >= 20)
2122                         return -errno;
2123
2124                 usleep(50 * USEC_PER_MSEC);
2125                 c++;
2126         }
2127
2128         if (fd < 0)
2129                 return -errno;
2130
2131         r = isatty(fd);
2132         if (r < 0) {
2133                 close_nointr_nofail(fd);
2134                 return -errno;
2135         }
2136
2137         if (!r) {
2138                 close_nointr_nofail(fd);
2139                 return -ENOTTY;
2140         }
2141
2142         return fd;
2143 }
2144
2145 int flush_fd(int fd) {
2146         struct pollfd pollfd;
2147
2148         zero(pollfd);
2149         pollfd.fd = fd;
2150         pollfd.events = POLLIN;
2151
2152         for (;;) {
2153                 char buf[LINE_MAX];
2154                 ssize_t l;
2155                 int r;
2156
2157                 if ((r = poll(&pollfd, 1, 0)) < 0) {
2158
2159                         if (errno == EINTR)
2160                                 continue;
2161
2162                         return -errno;
2163                 }
2164
2165                 if (r == 0)
2166                         return 0;
2167
2168                 if ((l = read(fd, buf, sizeof(buf))) < 0) {
2169
2170                         if (errno == EINTR)
2171                                 continue;
2172
2173                         if (errno == EAGAIN)
2174                                 return 0;
2175
2176                         return -errno;
2177                 }
2178
2179                 if (l <= 0)
2180                         return 0;
2181         }
2182 }
2183
2184 int acquire_terminal(
2185                 const char *name,
2186                 bool fail,
2187                 bool force,
2188                 bool ignore_tiocstty_eperm,
2189                 usec_t timeout) {
2190
2191         int fd = -1, notify = -1, r = 0, wd = -1;
2192         usec_t ts = 0;
2193         struct sigaction sa_old, sa_new;
2194
2195         assert(name);
2196
2197         /* We use inotify to be notified when the tty is closed. We
2198          * create the watch before checking if we can actually acquire
2199          * it, so that we don't lose any event.
2200          *
2201          * Note: strictly speaking this actually watches for the
2202          * device being closed, it does *not* really watch whether a
2203          * tty loses its controlling process. However, unless some
2204          * rogue process uses TIOCNOTTY on /dev/tty *after* closing
2205          * its tty otherwise this will not become a problem. As long
2206          * as the administrator makes sure not configure any service
2207          * on the same tty as an untrusted user this should not be a
2208          * problem. (Which he probably should not do anyway.) */
2209
2210         if (timeout != (usec_t) -1)
2211                 ts = now(CLOCK_MONOTONIC);
2212
2213         if (!fail && !force) {
2214                 notify = inotify_init1(IN_CLOEXEC | (timeout != (usec_t) -1 ? IN_NONBLOCK : 0));
2215                 if (notify < 0) {
2216                         r = -errno;
2217                         goto fail;
2218                 }
2219
2220                 wd = inotify_add_watch(notify, name, IN_CLOSE);
2221                 if (wd < 0) {
2222                         r = -errno;
2223                         goto fail;
2224                 }
2225         }
2226
2227         for (;;) {
2228                 if (notify >= 0) {
2229                         r = flush_fd(notify);
2230                         if (r < 0)
2231                                 goto fail;
2232                 }
2233
2234                 /* We pass here O_NOCTTY only so that we can check the return
2235                  * value TIOCSCTTY and have a reliable way to figure out if we
2236                  * successfully became the controlling process of the tty */
2237                 fd = open_terminal(name, O_RDWR|O_NOCTTY|O_CLOEXEC);
2238                 if (fd < 0)
2239                         return fd;
2240
2241                 /* Temporarily ignore SIGHUP, so that we don't get SIGHUP'ed
2242                  * if we already own the tty. */
2243                 zero(sa_new);
2244                 sa_new.sa_handler = SIG_IGN;
2245                 sa_new.sa_flags = SA_RESTART;
2246                 assert_se(sigaction(SIGHUP, &sa_new, &sa_old) == 0);
2247
2248                 /* First, try to get the tty */
2249                 if (ioctl(fd, TIOCSCTTY, force) < 0)
2250                         r = -errno;
2251
2252                 assert_se(sigaction(SIGHUP, &sa_old, NULL) == 0);
2253
2254                 /* Sometimes it makes sense to ignore TIOCSCTTY
2255                  * returning EPERM, i.e. when very likely we already
2256                  * are have this controlling terminal. */
2257                 if (r < 0 && r == -EPERM && ignore_tiocstty_eperm)
2258                         r = 0;
2259
2260                 if (r < 0 && (force || fail || r != -EPERM)) {
2261                         goto fail;
2262                 }
2263
2264                 if (r >= 0)
2265                         break;
2266
2267                 assert(!fail);
2268                 assert(!force);
2269                 assert(notify >= 0);
2270
2271                 for (;;) {
2272                         uint8_t inotify_buffer[sizeof(struct inotify_event) + FILENAME_MAX];
2273                         ssize_t l;
2274                         struct inotify_event *e;
2275
2276                         if (timeout != (usec_t) -1) {
2277                                 usec_t n;
2278
2279                                 n = now(CLOCK_MONOTONIC);
2280                                 if (ts + timeout < n) {
2281                                         r = -ETIMEDOUT;
2282                                         goto fail;
2283                                 }
2284
2285                                 r = fd_wait_for_event(fd, POLLIN, ts + timeout - n);
2286                                 if (r < 0)
2287                                         goto fail;
2288
2289                                 if (r == 0) {
2290                                         r = -ETIMEDOUT;
2291                                         goto fail;
2292                                 }
2293                         }
2294
2295                         l = read(notify, inotify_buffer, sizeof(inotify_buffer));
2296                         if (l < 0) {
2297
2298                                 if (errno == EINTR || errno == EAGAIN)
2299                                         continue;
2300
2301                                 r = -errno;
2302                                 goto fail;
2303                         }
2304
2305                         e = (struct inotify_event*) inotify_buffer;
2306
2307                         while (l > 0) {
2308                                 size_t step;
2309
2310                                 if (e->wd != wd || !(e->mask & IN_CLOSE)) {
2311                                         r = -EIO;
2312                                         goto fail;
2313                                 }
2314
2315                                 step = sizeof(struct inotify_event) + e->len;
2316                                 assert(step <= (size_t) l);
2317
2318                                 e = (struct inotify_event*) ((uint8_t*) e + step);
2319                                 l -= step;
2320                         }
2321
2322                         break;
2323                 }
2324
2325                 /* We close the tty fd here since if the old session
2326                  * ended our handle will be dead. It's important that
2327                  * we do this after sleeping, so that we don't enter
2328                  * an endless loop. */
2329                 close_nointr_nofail(fd);
2330         }
2331
2332         if (notify >= 0)
2333                 close_nointr_nofail(notify);
2334
2335         r = reset_terminal_fd(fd, true);
2336         if (r < 0)
2337                 log_warning("Failed to reset terminal: %s", strerror(-r));
2338
2339         return fd;
2340
2341 fail:
2342         if (fd >= 0)
2343                 close_nointr_nofail(fd);
2344
2345         if (notify >= 0)
2346                 close_nointr_nofail(notify);
2347
2348         return r;
2349 }
2350
2351 int release_terminal(void) {
2352         int r = 0, fd;
2353         struct sigaction sa_old, sa_new;
2354
2355         if ((fd = open("/dev/tty", O_RDWR|O_NOCTTY|O_NDELAY|O_CLOEXEC)) < 0)
2356                 return -errno;
2357
2358         /* Temporarily ignore SIGHUP, so that we don't get SIGHUP'ed
2359          * by our own TIOCNOTTY */
2360
2361         zero(sa_new);
2362         sa_new.sa_handler = SIG_IGN;
2363         sa_new.sa_flags = SA_RESTART;
2364         assert_se(sigaction(SIGHUP, &sa_new, &sa_old) == 0);
2365
2366         if (ioctl(fd, TIOCNOTTY) < 0)
2367                 r = -errno;
2368
2369         assert_se(sigaction(SIGHUP, &sa_old, NULL) == 0);
2370
2371         close_nointr_nofail(fd);
2372         return r;
2373 }
2374
2375 int sigaction_many(const struct sigaction *sa, ...) {
2376         va_list ap;
2377         int r = 0, sig;
2378
2379         va_start(ap, sa);
2380         while ((sig = va_arg(ap, int)) > 0)
2381                 if (sigaction(sig, sa, NULL) < 0)
2382                         r = -errno;
2383         va_end(ap);
2384
2385         return r;
2386 }
2387
2388 int ignore_signals(int sig, ...) {
2389         struct sigaction sa;
2390         va_list ap;
2391         int r = 0;
2392
2393         zero(sa);
2394         sa.sa_handler = SIG_IGN;
2395         sa.sa_flags = SA_RESTART;
2396
2397         if (sigaction(sig, &sa, NULL) < 0)
2398                 r = -errno;
2399
2400         va_start(ap, sig);
2401         while ((sig = va_arg(ap, int)) > 0)
2402                 if (sigaction(sig, &sa, NULL) < 0)
2403                         r = -errno;
2404         va_end(ap);
2405
2406         return r;
2407 }
2408
2409 int default_signals(int sig, ...) {
2410         struct sigaction sa;
2411         va_list ap;
2412         int r = 0;
2413
2414         zero(sa);
2415         sa.sa_handler = SIG_DFL;
2416         sa.sa_flags = SA_RESTART;
2417
2418         if (sigaction(sig, &sa, NULL) < 0)
2419                 r = -errno;
2420
2421         va_start(ap, sig);
2422         while ((sig = va_arg(ap, int)) > 0)
2423                 if (sigaction(sig, &sa, NULL) < 0)
2424                         r = -errno;
2425         va_end(ap);
2426
2427         return r;
2428 }
2429
2430 int close_pipe(int p[]) {
2431         int a = 0, b = 0;
2432
2433         assert(p);
2434
2435         if (p[0] >= 0) {
2436                 a = close_nointr(p[0]);
2437                 p[0] = -1;
2438         }
2439
2440         if (p[1] >= 0) {
2441                 b = close_nointr(p[1]);
2442                 p[1] = -1;
2443         }
2444
2445         return a < 0 ? a : b;
2446 }
2447
2448 ssize_t loop_read(int fd, void *buf, size_t nbytes, bool do_poll) {
2449         uint8_t *p;
2450         ssize_t n = 0;
2451
2452         assert(fd >= 0);
2453         assert(buf);
2454
2455         p = buf;
2456
2457         while (nbytes > 0) {
2458                 ssize_t k;
2459
2460                 if ((k = read(fd, p, nbytes)) <= 0) {
2461
2462                         if (k < 0 && errno == EINTR)
2463                                 continue;
2464
2465                         if (k < 0 && errno == EAGAIN && do_poll) {
2466                                 struct pollfd pollfd;
2467
2468                                 zero(pollfd);
2469                                 pollfd.fd = fd;
2470                                 pollfd.events = POLLIN;
2471
2472                                 if (poll(&pollfd, 1, -1) < 0) {
2473                                         if (errno == EINTR)
2474                                                 continue;
2475
2476                                         return n > 0 ? n : -errno;
2477                                 }
2478
2479                                 if (pollfd.revents != POLLIN)
2480                                         return n > 0 ? n : -EIO;
2481
2482                                 continue;
2483                         }
2484
2485                         return n > 0 ? n : (k < 0 ? -errno : 0);
2486                 }
2487
2488                 p += k;
2489                 nbytes -= k;
2490                 n += k;
2491         }
2492
2493         return n;
2494 }
2495
2496 ssize_t loop_write(int fd, const void *buf, size_t nbytes, bool do_poll) {
2497         const uint8_t *p;
2498         ssize_t n = 0;
2499
2500         assert(fd >= 0);
2501         assert(buf);
2502
2503         p = buf;
2504
2505         while (nbytes > 0) {
2506                 ssize_t k;
2507
2508                 k = write(fd, p, nbytes);
2509                 if (k <= 0) {
2510
2511                         if (k < 0 && errno == EINTR)
2512                                 continue;
2513
2514                         if (k < 0 && errno == EAGAIN && do_poll) {
2515                                 struct pollfd pollfd;
2516
2517                                 zero(pollfd);
2518                                 pollfd.fd = fd;
2519                                 pollfd.events = POLLOUT;
2520
2521                                 if (poll(&pollfd, 1, -1) < 0) {
2522                                         if (errno == EINTR)
2523                                                 continue;
2524
2525                                         return n > 0 ? n : -errno;
2526                                 }
2527
2528                                 if (pollfd.revents != POLLOUT)
2529                                         return n > 0 ? n : -EIO;
2530
2531                                 continue;
2532                         }
2533
2534                         return n > 0 ? n : (k < 0 ? -errno : 0);
2535                 }
2536
2537                 p += k;
2538                 nbytes -= k;
2539                 n += k;
2540         }
2541
2542         return n;
2543 }
2544
2545 int parse_bytes(const char *t, off_t *bytes) {
2546         static const struct {
2547                 const char *suffix;
2548                 off_t factor;
2549         } table[] = {
2550                 { "B", 1 },
2551                 { "K", 1024ULL },
2552                 { "M", 1024ULL*1024ULL },
2553                 { "G", 1024ULL*1024ULL*1024ULL },
2554                 { "T", 1024ULL*1024ULL*1024ULL*1024ULL },
2555                 { "P", 1024ULL*1024ULL*1024ULL*1024ULL*1024ULL },
2556                 { "E", 1024ULL*1024ULL*1024ULL*1024ULL*1024ULL*1024ULL },
2557                 { "", 1 },
2558         };
2559
2560         const char *p;
2561         off_t r = 0;
2562
2563         assert(t);
2564         assert(bytes);
2565
2566         p = t;
2567         do {
2568                 long long l;
2569                 char *e;
2570                 unsigned i;
2571
2572                 errno = 0;
2573                 l = strtoll(p, &e, 10);
2574
2575                 if (errno != 0)
2576                         return -errno;
2577
2578                 if (l < 0)
2579                         return -ERANGE;
2580
2581                 if (e == p)
2582                         return -EINVAL;
2583
2584                 e += strspn(e, WHITESPACE);
2585
2586                 for (i = 0; i < ELEMENTSOF(table); i++)
2587                         if (startswith(e, table[i].suffix)) {
2588                                 r += (off_t) l * table[i].factor;
2589                                 p = e + strlen(table[i].suffix);
2590                                 break;
2591                         }
2592
2593                 if (i >= ELEMENTSOF(table))
2594                         return -EINVAL;
2595
2596         } while (*p != 0);
2597
2598         *bytes = r;
2599
2600         return 0;
2601 }
2602
2603 int make_stdio(int fd) {
2604         int r, s, t;
2605
2606         assert(fd >= 0);
2607
2608         r = dup3(fd, STDIN_FILENO, 0);
2609         s = dup3(fd, STDOUT_FILENO, 0);
2610         t = dup3(fd, STDERR_FILENO, 0);
2611
2612         if (fd >= 3)
2613                 close_nointr_nofail(fd);
2614
2615         if (r < 0 || s < 0 || t < 0)
2616                 return -errno;
2617
2618         /* We rely here that the new fd has O_CLOEXEC not set */
2619
2620         return 0;
2621 }
2622
2623 int make_null_stdio(void) {
2624         int null_fd;
2625
2626         null_fd = open("/dev/null", O_RDWR|O_NOCTTY);
2627         if (null_fd < 0)
2628                 return -errno;
2629
2630         return make_stdio(null_fd);
2631 }
2632
2633 bool is_device_path(const char *path) {
2634
2635         /* Returns true on paths that refer to a device, either in
2636          * sysfs or in /dev */
2637
2638         return
2639                 path_startswith(path, "/dev/") ||
2640                 path_startswith(path, "/sys/");
2641 }
2642
2643 int dir_is_empty(const char *path) {
2644         _cleanup_closedir_ DIR *d;
2645         int r;
2646
2647         d = opendir(path);
2648         if (!d)
2649                 return -errno;
2650
2651         for (;;) {
2652                 struct dirent *de;
2653                 union dirent_storage buf;
2654
2655                 r = readdir_r(d, &buf.de, &de);
2656                 if (r > 0)
2657                         return -r;
2658
2659                 if (!de)
2660                         return 1;
2661
2662                 if (!ignore_file(de->d_name))
2663                         return 0;
2664         }
2665 }
2666
2667 unsigned long long random_ull(void) {
2668         _cleanup_close_ int fd;
2669         uint64_t ull;
2670         ssize_t r;
2671
2672         fd = open("/dev/urandom", O_RDONLY|O_CLOEXEC|O_NOCTTY);
2673         if (fd < 0)
2674                 goto fallback;
2675
2676         r = loop_read(fd, &ull, sizeof(ull), true);
2677         if (r != sizeof(ull))
2678                 goto fallback;
2679
2680         return ull;
2681
2682 fallback:
2683         return random() * RAND_MAX + random();
2684 }
2685
2686 void rename_process(const char name[8]) {
2687         assert(name);
2688
2689         /* This is a like a poor man's setproctitle(). It changes the
2690          * comm field, argv[0], and also the glibc's internally used
2691          * name of the process. For the first one a limit of 16 chars
2692          * applies, to the second one usually one of 10 (i.e. length
2693          * of "/sbin/init"), to the third one one of 7 (i.e. length of
2694          * "systemd"). If you pass a longer string it will be
2695          * truncated */
2696
2697         prctl(PR_SET_NAME, name);
2698
2699         if (program_invocation_name)
2700                 strncpy(program_invocation_name, name, strlen(program_invocation_name));
2701
2702         if (saved_argc > 0) {
2703                 int i;
2704
2705                 if (saved_argv[0])
2706                         strncpy(saved_argv[0], name, strlen(saved_argv[0]));
2707
2708                 for (i = 1; i < saved_argc; i++) {
2709                         if (!saved_argv[i])
2710                                 break;
2711
2712                         memset(saved_argv[i], 0, strlen(saved_argv[i]));
2713                 }
2714         }
2715 }
2716
2717 void sigset_add_many(sigset_t *ss, ...) {
2718         va_list ap;
2719         int sig;
2720
2721         assert(ss);
2722
2723         va_start(ap, ss);
2724         while ((sig = va_arg(ap, int)) > 0)
2725                 assert_se(sigaddset(ss, sig) == 0);
2726         va_end(ap);
2727 }
2728
2729 char* gethostname_malloc(void) {
2730         struct utsname u;
2731
2732         assert_se(uname(&u) >= 0);
2733
2734         if (!isempty(u.nodename) && !streq(u.nodename, "(none)"))
2735                 return strdup(u.nodename);
2736
2737         return strdup(u.sysname);
2738 }
2739
2740 bool hostname_is_set(void) {
2741         struct utsname u;
2742
2743         assert_se(uname(&u) >= 0);
2744
2745         return !isempty(u.nodename) && !streq(u.nodename, "(none)");
2746 }
2747
2748 static char *lookup_uid(uid_t uid) {
2749         long bufsize;
2750         char *name;
2751         _cleanup_free_ char *buf = NULL;
2752         struct passwd pwbuf, *pw = NULL;
2753
2754         /* Shortcut things to avoid NSS lookups */
2755         if (uid == 0)
2756                 return strdup("root");
2757
2758         bufsize = sysconf(_SC_GETPW_R_SIZE_MAX);
2759         if (bufsize <= 0)
2760                 bufsize = 4096;
2761
2762         buf = malloc(bufsize);
2763         if (!buf)
2764                 return NULL;
2765
2766         if (getpwuid_r(uid, &pwbuf, buf, bufsize, &pw) == 0 && pw)
2767                 return strdup(pw->pw_name);
2768
2769         if (asprintf(&name, "%lu", (unsigned long) uid) < 0)
2770                 return NULL;
2771
2772         return name;
2773 }
2774
2775 char* getlogname_malloc(void) {
2776         uid_t uid;
2777         struct stat st;
2778
2779         if (isatty(STDIN_FILENO) && fstat(STDIN_FILENO, &st) >= 0)
2780                 uid = st.st_uid;
2781         else
2782                 uid = getuid();
2783
2784         return lookup_uid(uid);
2785 }
2786
2787 char *getusername_malloc(void) {
2788         const char *e;
2789
2790         e = getenv("USER");
2791         if (e)
2792                 return strdup(e);
2793
2794         return lookup_uid(getuid());
2795 }
2796
2797 int getttyname_malloc(int fd, char **r) {
2798         char path[PATH_MAX], *c;
2799         int k;
2800
2801         assert(r);
2802
2803         k = ttyname_r(fd, path, sizeof(path));
2804         if (k != 0)
2805                 return -k;
2806
2807         char_array_0(path);
2808
2809         c = strdup(startswith(path, "/dev/") ? path + 5 : path);
2810         if (!c)
2811                 return -ENOMEM;
2812
2813         *r = c;
2814         return 0;
2815 }
2816
2817 int getttyname_harder(int fd, char **r) {
2818         int k;
2819         char *s;
2820
2821         k = getttyname_malloc(fd, &s);
2822         if (k < 0)
2823                 return k;
2824
2825         if (streq(s, "tty")) {
2826                 free(s);
2827                 return get_ctty(0, NULL, r);
2828         }
2829
2830         *r = s;
2831         return 0;
2832 }
2833
2834 int get_ctty_devnr(pid_t pid, dev_t *d) {
2835         int k;
2836         char line[LINE_MAX], *p, *fn;
2837         unsigned long ttynr;
2838         FILE *f;
2839
2840         if (asprintf(&fn, "/proc/%lu/stat", (unsigned long) (pid <= 0 ? getpid() : pid)) < 0)
2841                 return -ENOMEM;
2842
2843         f = fopen(fn, "re");
2844         free(fn);
2845         if (!f)
2846                 return -errno;
2847
2848         if (!fgets(line, sizeof(line), f)) {
2849                 k = feof(f) ? -EIO : -errno;
2850                 fclose(f);
2851                 return k;
2852         }
2853
2854         fclose(f);
2855
2856         p = strrchr(line, ')');
2857         if (!p)
2858                 return -EIO;
2859
2860         p++;
2861
2862         if (sscanf(p, " "
2863                    "%*c "  /* state */
2864                    "%*d "  /* ppid */
2865                    "%*d "  /* pgrp */
2866                    "%*d "  /* session */
2867                    "%lu ", /* ttynr */
2868                    &ttynr) != 1)
2869                 return -EIO;
2870
2871         if (major(ttynr) == 0 && minor(ttynr) == 0)
2872                 return -ENOENT;
2873
2874         *d = (dev_t) ttynr;
2875         return 0;
2876 }
2877
2878 int get_ctty(pid_t pid, dev_t *_devnr, char **r) {
2879         int k;
2880         char fn[PATH_MAX], *s, *b, *p;
2881         dev_t devnr;
2882
2883         assert(r);
2884
2885         k = get_ctty_devnr(pid, &devnr);
2886         if (k < 0)
2887                 return k;
2888
2889         snprintf(fn, sizeof(fn), "/dev/char/%u:%u", major(devnr), minor(devnr));
2890         char_array_0(fn);
2891
2892         k = readlink_malloc(fn, &s);
2893         if (k < 0) {
2894
2895                 if (k != -ENOENT)
2896                         return k;
2897
2898                 /* This is an ugly hack */
2899                 if (major(devnr) == 136) {
2900                         if (asprintf(&b, "pts/%lu", (unsigned long) minor(devnr)) < 0)
2901                                 return -ENOMEM;
2902
2903                         *r = b;
2904                         if (_devnr)
2905                                 *_devnr = devnr;
2906
2907                         return 0;
2908                 }
2909
2910                 /* Probably something like the ptys which have no
2911                  * symlink in /dev/char. Let's return something
2912                  * vaguely useful. */
2913
2914                 b = strdup(fn + 5);
2915                 if (!b)
2916                         return -ENOMEM;
2917
2918                 *r = b;
2919                 if (_devnr)
2920                         *_devnr = devnr;
2921
2922                 return 0;
2923         }
2924
2925         if (startswith(s, "/dev/"))
2926                 p = s + 5;
2927         else if (startswith(s, "../"))
2928                 p = s + 3;
2929         else
2930                 p = s;
2931
2932         b = strdup(p);
2933         free(s);
2934
2935         if (!b)
2936                 return -ENOMEM;
2937
2938         *r = b;
2939         if (_devnr)
2940                 *_devnr = devnr;
2941
2942         return 0;
2943 }
2944
2945 int rm_rf_children_dangerous(int fd, bool only_dirs, bool honour_sticky, struct stat *root_dev) {
2946         DIR *d;
2947         int ret = 0;
2948
2949         assert(fd >= 0);
2950
2951         /* This returns the first error we run into, but nevertheless
2952          * tries to go on. This closes the passed fd. */
2953
2954         d = fdopendir(fd);
2955         if (!d) {
2956                 close_nointr_nofail(fd);
2957
2958                 return errno == ENOENT ? 0 : -errno;
2959         }
2960
2961         for (;;) {
2962                 struct dirent *de;
2963                 union dirent_storage buf;
2964                 bool is_dir, keep_around;
2965                 struct stat st;
2966                 int r;
2967
2968                 r = readdir_r(d, &buf.de, &de);
2969                 if (r != 0 && ret == 0) {
2970                         ret = -r;
2971                         break;
2972                 }
2973
2974                 if (!de)
2975                         break;
2976
2977                 if (streq(de->d_name, ".") || streq(de->d_name, ".."))
2978                         continue;
2979
2980                 if (de->d_type == DT_UNKNOWN ||
2981                     honour_sticky ||
2982                     (de->d_type == DT_DIR && root_dev)) {
2983                         if (fstatat(fd, de->d_name, &st, AT_SYMLINK_NOFOLLOW) < 0) {
2984                                 if (ret == 0 && errno != ENOENT)
2985                                         ret = -errno;
2986                                 continue;
2987                         }
2988
2989                         is_dir = S_ISDIR(st.st_mode);
2990                         keep_around =
2991                                 honour_sticky &&
2992                                 (st.st_uid == 0 || st.st_uid == getuid()) &&
2993                                 (st.st_mode & S_ISVTX);
2994                 } else {
2995                         is_dir = de->d_type == DT_DIR;
2996                         keep_around = false;
2997                 }
2998
2999                 if (is_dir) {
3000                         int subdir_fd;
3001
3002                         /* if root_dev is set, remove subdirectories only, if device is same as dir */
3003                         if (root_dev && st.st_dev != root_dev->st_dev)
3004                                 continue;
3005
3006                         subdir_fd = openat(fd, de->d_name,
3007                                            O_RDONLY|O_NONBLOCK|O_DIRECTORY|O_CLOEXEC|O_NOFOLLOW|O_NOATIME);
3008                         if (subdir_fd < 0) {
3009                                 if (ret == 0 && errno != ENOENT)
3010                                         ret = -errno;
3011                                 continue;
3012                         }
3013
3014                         r = rm_rf_children_dangerous(subdir_fd, only_dirs, honour_sticky, root_dev);
3015                         if (r < 0 && ret == 0)
3016                                 ret = r;
3017
3018                         if (!keep_around)
3019                                 if (unlinkat(fd, de->d_name, AT_REMOVEDIR) < 0) {
3020                                         if (ret == 0 && errno != ENOENT)
3021                                                 ret = -errno;
3022                                 }
3023
3024                 } else if (!only_dirs && !keep_around) {
3025
3026                         if (unlinkat(fd, de->d_name, 0) < 0) {
3027                                 if (ret == 0 && errno != ENOENT)
3028                                         ret = -errno;
3029                         }
3030                 }
3031         }
3032
3033         closedir(d);
3034
3035         return ret;
3036 }
3037
3038 static int is_temporary_fs(struct statfs *s) {
3039         assert(s);
3040         return s->f_type == TMPFS_MAGIC ||
3041                 (long)s->f_type == (long)RAMFS_MAGIC;
3042 }
3043
3044 int rm_rf_children(int fd, bool only_dirs, bool honour_sticky, struct stat *root_dev) {
3045         struct statfs s;
3046
3047         assert(fd >= 0);
3048
3049         if (fstatfs(fd, &s) < 0) {
3050                 close_nointr_nofail(fd);
3051                 return -errno;
3052         }
3053
3054         /* We refuse to clean disk file systems with this call. This
3055          * is extra paranoia just to be sure we never ever remove
3056          * non-state data */
3057         if (!is_temporary_fs(&s)) {
3058                 log_error("Attempted to remove disk file system, and we can't allow that.");
3059                 close_nointr_nofail(fd);
3060                 return -EPERM;
3061         }
3062
3063         return rm_rf_children_dangerous(fd, only_dirs, honour_sticky, root_dev);
3064 }
3065
3066 static int rm_rf_internal(const char *path, bool only_dirs, bool delete_root, bool honour_sticky, bool dangerous) {
3067         int fd, r;
3068         struct statfs s;
3069
3070         assert(path);
3071
3072         /* We refuse to clean the root file system with this
3073          * call. This is extra paranoia to never cause a really
3074          * seriously broken system. */
3075         if (path_equal(path, "/")) {
3076                 log_error("Attempted to remove entire root file system, and we can't allow that.");
3077                 return -EPERM;
3078         }
3079
3080         fd = open(path, O_RDONLY|O_NONBLOCK|O_DIRECTORY|O_CLOEXEC|O_NOFOLLOW|O_NOATIME);
3081         if (fd < 0) {
3082
3083                 if (errno != ENOTDIR)
3084                         return -errno;
3085
3086                 if (!dangerous) {
3087                         if (statfs(path, &s) < 0)
3088                                 return -errno;
3089
3090                         if (!is_temporary_fs(&s)) {
3091                                 log_error("Attempted to remove disk file system, and we can't allow that.");
3092                                 return -EPERM;
3093                         }
3094                 }
3095
3096                 if (delete_root && !only_dirs)
3097                         if (unlink(path) < 0 && errno != ENOENT)
3098                                 return -errno;
3099
3100                 return 0;
3101         }
3102
3103         if (!dangerous) {
3104                 if (fstatfs(fd, &s) < 0) {
3105                         close_nointr_nofail(fd);
3106                         return -errno;
3107                 }
3108
3109                 if (!is_temporary_fs(&s)) {
3110                         log_error("Attempted to remove disk file system, and we can't allow that.");
3111                         close_nointr_nofail(fd);
3112                         return -EPERM;
3113                 }
3114         }
3115
3116         r = rm_rf_children_dangerous(fd, only_dirs, honour_sticky, NULL);
3117         if (delete_root) {
3118
3119                 if (honour_sticky && file_is_priv_sticky(path) > 0)
3120                         return r;
3121
3122                 if (rmdir(path) < 0 && errno != ENOENT) {
3123                         if (r == 0)
3124                                 r = -errno;
3125                 }
3126         }
3127
3128         return r;
3129 }
3130
3131 int rm_rf(const char *path, bool only_dirs, bool delete_root, bool honour_sticky) {
3132         return rm_rf_internal(path, only_dirs, delete_root, honour_sticky, false);
3133 }
3134
3135 int rm_rf_dangerous(const char *path, bool only_dirs, bool delete_root, bool honour_sticky) {
3136         return rm_rf_internal(path, only_dirs, delete_root, honour_sticky, true);
3137 }
3138
3139 int chmod_and_chown(const char *path, mode_t mode, uid_t uid, gid_t gid) {
3140         assert(path);
3141
3142         /* Under the assumption that we are running privileged we
3143          * first change the access mode and only then hand out
3144          * ownership to avoid a window where access is too open. */
3145
3146         if (mode != (mode_t) -1)
3147                 if (chmod(path, mode) < 0)
3148                         return -errno;
3149
3150         if (uid != (uid_t) -1 || gid != (gid_t) -1)
3151                 if (chown(path, uid, gid) < 0)
3152                         return -errno;
3153
3154         return 0;
3155 }
3156
3157 int fchmod_and_fchown(int fd, mode_t mode, uid_t uid, gid_t gid) {
3158         assert(fd >= 0);
3159
3160         /* Under the assumption that we are running privileged we
3161          * first change the access mode and only then hand out
3162          * ownership to avoid a window where access is too open. */
3163
3164         if (fchmod(fd, mode) < 0)
3165                 return -errno;
3166
3167         if (fchown(fd, uid, gid) < 0)
3168                 return -errno;
3169
3170         return 0;
3171 }
3172
3173 cpu_set_t* cpu_set_malloc(unsigned *ncpus) {
3174         cpu_set_t *r;
3175         unsigned n = 1024;
3176
3177         /* Allocates the cpuset in the right size */
3178
3179         for (;;) {
3180                 if (!(r = CPU_ALLOC(n)))
3181                         return NULL;
3182
3183                 if (sched_getaffinity(0, CPU_ALLOC_SIZE(n), r) >= 0) {
3184                         CPU_ZERO_S(CPU_ALLOC_SIZE(n), r);
3185
3186                         if (ncpus)
3187                                 *ncpus = n;
3188
3189                         return r;
3190                 }
3191
3192                 CPU_FREE(r);
3193
3194                 if (errno != EINVAL)
3195                         return NULL;
3196
3197                 n *= 2;
3198         }
3199 }
3200
3201 int status_vprintf(const char *status, bool ellipse, const char *format, va_list ap) {
3202         static const char status_indent[] = "         "; /* "[" STATUS "] " */
3203         _cleanup_free_ char *s = NULL;
3204         _cleanup_close_ int fd = -1;
3205         struct iovec iovec[5];
3206         int n = 0;
3207
3208         assert(format);
3209
3210         /* This is independent of logging, as status messages are
3211          * optional and go exclusively to the console. */
3212
3213         if (vasprintf(&s, format, ap) < 0)
3214                 return log_oom();
3215
3216         fd = open_terminal("/dev/console", O_WRONLY|O_NOCTTY|O_CLOEXEC);
3217         if (fd < 0)
3218                 return fd;
3219
3220         if (ellipse) {
3221                 char *e;
3222                 size_t emax, sl;
3223                 int c;
3224
3225                 c = fd_columns(fd);
3226                 if (c <= 0)
3227                         c = 80;
3228
3229                 sl = status ? sizeof(status_indent)-1 : 0;
3230
3231                 emax = c - sl - 1;
3232                 if (emax < 3)
3233                         emax = 3;
3234
3235                 e = ellipsize(s, emax, 75);
3236                 if (e) {
3237                         free(s);
3238                         s = e;
3239                 }
3240         }
3241
3242         zero(iovec);
3243
3244         if (status) {
3245                 if (!isempty(status)) {
3246                         IOVEC_SET_STRING(iovec[n++], "[");
3247                         IOVEC_SET_STRING(iovec[n++], status);
3248                         IOVEC_SET_STRING(iovec[n++], "] ");
3249                 } else
3250                         IOVEC_SET_STRING(iovec[n++], status_indent);
3251         }
3252
3253         IOVEC_SET_STRING(iovec[n++], s);
3254         IOVEC_SET_STRING(iovec[n++], "\n");
3255
3256         if (writev(fd, iovec, n) < 0)
3257                 return -errno;
3258
3259         return 0;
3260 }
3261
3262 int status_printf(const char *status, bool ellipse, const char *format, ...) {
3263         va_list ap;
3264         int r;
3265
3266         assert(format);
3267
3268         va_start(ap, format);
3269         r = status_vprintf(status, ellipse, format, ap);
3270         va_end(ap);
3271
3272         return r;
3273 }
3274
3275 int status_welcome(void) {
3276         int r;
3277         _cleanup_free_ char *pretty_name = NULL, *ansi_color = NULL;
3278
3279         r = parse_env_file("/etc/os-release", NEWLINE,
3280                            "PRETTY_NAME", &pretty_name,
3281                            "ANSI_COLOR", &ansi_color,
3282                            NULL);
3283         if (r < 0 && r != -ENOENT)
3284                 log_warning("Failed to read /etc/os-release: %s", strerror(-r));
3285
3286         return status_printf(NULL, false,
3287                              "\nWelcome to \x1B[%sm%s\x1B[0m!\n",
3288                              isempty(ansi_color) ? "1" : ansi_color,
3289                              isempty(pretty_name) ? "Linux" : pretty_name);
3290 }
3291
3292 char *replace_env(const char *format, char **env) {
3293         enum {
3294                 WORD,
3295                 CURLY,
3296                 VARIABLE
3297         } state = WORD;
3298
3299         const char *e, *word = format;
3300         char *r = NULL, *k;
3301
3302         assert(format);
3303
3304         for (e = format; *e; e ++) {
3305
3306                 switch (state) {
3307
3308                 case WORD:
3309                         if (*e == '$')
3310                                 state = CURLY;
3311                         break;
3312
3313                 case CURLY:
3314                         if (*e == '{') {
3315                                 if (!(k = strnappend(r, word, e-word-1)))
3316                                         goto fail;
3317
3318                                 free(r);
3319                                 r = k;
3320
3321                                 word = e-1;
3322                                 state = VARIABLE;
3323
3324                         } else if (*e == '$') {
3325                                 if (!(k = strnappend(r, word, e-word)))
3326                                         goto fail;
3327
3328                                 free(r);
3329                                 r = k;
3330
3331                                 word = e+1;
3332                                 state = WORD;
3333                         } else
3334                                 state = WORD;
3335                         break;
3336
3337                 case VARIABLE:
3338                         if (*e == '}') {
3339                                 const char *t;
3340
3341                                 t = strempty(strv_env_get_n(env, word+2, e-word-2));
3342
3343                                 k = strappend(r, t);
3344                                 if (!k)
3345                                         goto fail;
3346
3347                                 free(r);
3348                                 r = k;
3349
3350                                 word = e+1;
3351                                 state = WORD;
3352                         }
3353                         break;
3354                 }
3355         }
3356
3357         if (!(k = strnappend(r, word, e-word)))
3358                 goto fail;
3359
3360         free(r);
3361         return k;
3362
3363 fail:
3364         free(r);
3365         return NULL;
3366 }
3367
3368 char **replace_env_argv(char **argv, char **env) {
3369         char **r, **i;
3370         unsigned k = 0, l = 0;
3371
3372         l = strv_length(argv);
3373
3374         if (!(r = new(char*, l+1)))
3375                 return NULL;
3376
3377         STRV_FOREACH(i, argv) {
3378
3379                 /* If $FOO appears as single word, replace it by the split up variable */
3380                 if ((*i)[0] == '$' && (*i)[1] != '{') {
3381                         char *e;
3382                         char **w, **m;
3383                         unsigned q;
3384
3385                         e = strv_env_get(env, *i+1);
3386                         if (e) {
3387
3388                                 if (!(m = strv_split_quoted(e))) {
3389                                         r[k] = NULL;
3390                                         strv_free(r);
3391                                         return NULL;
3392                                 }
3393                         } else
3394                                 m = NULL;
3395
3396                         q = strv_length(m);
3397                         l = l + q - 1;
3398
3399                         if (!(w = realloc(r, sizeof(char*) * (l+1)))) {
3400                                 r[k] = NULL;
3401                                 strv_free(r);
3402                                 strv_free(m);
3403                                 return NULL;
3404                         }
3405
3406                         r = w;
3407                         if (m) {
3408                                 memcpy(r + k, m, q * sizeof(char*));
3409                                 free(m);
3410                         }
3411
3412                         k += q;
3413                         continue;
3414                 }
3415
3416                 /* If ${FOO} appears as part of a word, replace it by the variable as-is */
3417                 if (!(r[k++] = replace_env(*i, env))) {
3418                         strv_free(r);
3419                         return NULL;
3420                 }
3421         }
3422
3423         r[k] = NULL;
3424         return r;
3425 }
3426
3427 int fd_columns(int fd) {
3428         struct winsize ws;
3429         zero(ws);
3430
3431         if (ioctl(fd, TIOCGWINSZ, &ws) < 0)
3432                 return -errno;
3433
3434         if (ws.ws_col <= 0)
3435                 return -EIO;
3436
3437         return ws.ws_col;
3438 }
3439
3440 unsigned columns(void) {
3441         const char *e;
3442         int c;
3443
3444         if (_likely_(cached_columns > 0))
3445                 return cached_columns;
3446
3447         c = 0;
3448         e = getenv("COLUMNS");
3449         if (e)
3450                 safe_atoi(e, &c);
3451
3452         if (c <= 0)
3453                 c = fd_columns(STDOUT_FILENO);
3454
3455         if (c <= 0)
3456                 c = 80;
3457
3458         cached_columns = c;
3459         return c;
3460 }
3461
3462 int fd_lines(int fd) {
3463         struct winsize ws;
3464         zero(ws);
3465
3466         if (ioctl(fd, TIOCGWINSZ, &ws) < 0)
3467                 return -errno;
3468
3469         if (ws.ws_row <= 0)
3470                 return -EIO;
3471
3472         return ws.ws_row;
3473 }
3474
3475 unsigned lines(void) {
3476         const char *e;
3477         unsigned l;
3478
3479         if (_likely_(cached_lines > 0))
3480                 return cached_lines;
3481
3482         l = 0;
3483         e = getenv("LINES");
3484         if (e)
3485                 safe_atou(e, &l);
3486
3487         if (l <= 0)
3488                 l = fd_lines(STDOUT_FILENO);
3489
3490         if (l <= 0)
3491                 l = 24;
3492
3493         cached_lines = l;
3494         return cached_lines;
3495 }
3496
3497 /* intended to be used as a SIGWINCH sighandler */
3498 void columns_lines_cache_reset(int signum) {
3499         cached_columns = 0;
3500         cached_lines = 0;
3501 }
3502
3503 bool on_tty(void) {
3504         static int cached_on_tty = -1;
3505
3506         if (_unlikely_(cached_on_tty < 0))
3507                 cached_on_tty = isatty(STDOUT_FILENO) > 0;
3508
3509         return cached_on_tty;
3510 }
3511
3512 int running_in_chroot(void) {
3513         struct stat a, b;
3514
3515         zero(a);
3516         zero(b);
3517
3518         /* Only works as root */
3519
3520         if (stat("/proc/1/root", &a) < 0)
3521                 return -errno;
3522
3523         if (stat("/", &b) < 0)
3524                 return -errno;
3525
3526         return
3527                 a.st_dev != b.st_dev ||
3528                 a.st_ino != b.st_ino;
3529 }
3530
3531 char *ellipsize_mem(const char *s, size_t old_length, size_t new_length, unsigned percent) {
3532         size_t x;
3533         char *r;
3534
3535         assert(s);
3536         assert(percent <= 100);
3537         assert(new_length >= 3);
3538
3539         if (old_length <= 3 || old_length <= new_length)
3540                 return strndup(s, old_length);
3541
3542         r = new0(char, new_length+1);
3543         if (!r)
3544                 return r;
3545
3546         x = (new_length * percent) / 100;
3547
3548         if (x > new_length - 3)
3549                 x = new_length - 3;
3550
3551         memcpy(r, s, x);
3552         r[x] = '.';
3553         r[x+1] = '.';
3554         r[x+2] = '.';
3555         memcpy(r + x + 3,
3556                s + old_length - (new_length - x - 3),
3557                new_length - x - 3);
3558
3559         return r;
3560 }
3561
3562 char *ellipsize(const char *s, size_t length, unsigned percent) {
3563         return ellipsize_mem(s, strlen(s), length, percent);
3564 }
3565
3566 int touch(const char *path) {
3567         int fd;
3568
3569         assert(path);
3570
3571         /* This just opens the file for writing, ensuring it
3572          * exists. It doesn't call utimensat() the way /usr/bin/touch
3573          * does it. */
3574
3575         fd = open(path, O_WRONLY|O_CREAT|O_CLOEXEC|O_NOCTTY, 0644);
3576         if (fd < 0)
3577                 return -errno;
3578
3579         close_nointr_nofail(fd);
3580         return 0;
3581 }
3582
3583 char *unquote(const char *s, const char* quotes) {
3584         size_t l;
3585         assert(s);
3586
3587         /* This is rather stupid, simply removes the heading and
3588          * trailing quotes if there is one. Doesn't care about
3589          * escaping or anything. We should make this smarter one
3590          * day...*/
3591
3592         l = strlen(s);
3593         if (l < 2)
3594                 return strdup(s);
3595
3596         if (strchr(quotes, s[0]) && s[l-1] == s[0])
3597                 return strndup(s+1, l-2);
3598
3599         return strdup(s);
3600 }
3601
3602 char *normalize_env_assignment(const char *s) {
3603         _cleanup_free_ char *name = NULL, *value = NULL, *p = NULL;
3604         char *eq, *r;
3605
3606         eq = strchr(s, '=');
3607         if (!eq) {
3608                 char *t;
3609
3610                 r = strdup(s);
3611                 if (!r)
3612                         return NULL;
3613
3614                 t = strstrip(r);
3615                 if (t == r)
3616                         return r;
3617
3618                 memmove(r, t, strlen(t) + 1);
3619                 return r;
3620         }
3621
3622         name = strndup(s, eq - s);
3623         if (!name)
3624                 return NULL;
3625
3626         p = strdup(eq + 1);
3627         if (!p)
3628                 return NULL;
3629
3630         value = unquote(strstrip(p), QUOTES);
3631         if (!value)
3632                 return NULL;
3633
3634         if (asprintf(&r, "%s=%s", strstrip(name), value) < 0)
3635                 r = NULL;
3636
3637         return r;
3638 }
3639
3640 int wait_for_terminate(pid_t pid, siginfo_t *status) {
3641         siginfo_t dummy;
3642
3643         assert(pid >= 1);
3644
3645         if (!status)
3646                 status = &dummy;
3647
3648         for (;;) {
3649                 zero(*status);
3650
3651                 if (waitid(P_PID, pid, status, WEXITED) < 0) {
3652
3653                         if (errno == EINTR)
3654                                 continue;
3655
3656                         return -errno;
3657                 }
3658
3659                 return 0;
3660         }
3661 }
3662
3663 int wait_for_terminate_and_warn(const char *name, pid_t pid) {
3664         int r;
3665         siginfo_t status;
3666
3667         assert(name);
3668         assert(pid > 1);
3669
3670         r = wait_for_terminate(pid, &status);
3671         if (r < 0) {
3672                 log_warning("Failed to wait for %s: %s", name, strerror(-r));
3673                 return r;
3674         }
3675
3676         if (status.si_code == CLD_EXITED) {
3677                 if (status.si_status != 0) {
3678                         log_warning("%s failed with error code %i.", name, status.si_status);
3679                         return status.si_status;
3680                 }
3681
3682                 log_debug("%s succeeded.", name);
3683                 return 0;
3684
3685         } else if (status.si_code == CLD_KILLED ||
3686                    status.si_code == CLD_DUMPED) {
3687
3688                 log_warning("%s terminated by signal %s.", name, signal_to_string(status.si_status));
3689                 return -EPROTO;
3690         }
3691
3692         log_warning("%s failed due to unknown reason.", name);
3693         return -EPROTO;
3694 }
3695
3696 _noreturn_ void freeze(void) {
3697
3698         /* Make sure nobody waits for us on a socket anymore */
3699         close_all_fds(NULL, 0);
3700
3701         sync();
3702
3703         for (;;)
3704                 pause();
3705 }
3706
3707 bool null_or_empty(struct stat *st) {
3708         assert(st);
3709
3710         if (S_ISREG(st->st_mode) && st->st_size <= 0)
3711                 return true;
3712
3713         if (S_ISCHR(st->st_mode) || S_ISBLK(st->st_mode))
3714                 return true;
3715
3716         return false;
3717 }
3718
3719 int null_or_empty_path(const char *fn) {
3720         struct stat st;
3721
3722         assert(fn);
3723
3724         if (stat(fn, &st) < 0)
3725                 return -errno;
3726
3727         return null_or_empty(&st);
3728 }
3729
3730 DIR *xopendirat(int fd, const char *name, int flags) {
3731         int nfd;
3732         DIR *d;
3733
3734         nfd = openat(fd, name, O_RDONLY|O_NONBLOCK|O_DIRECTORY|O_CLOEXEC|flags);
3735         if (nfd < 0)
3736                 return NULL;
3737
3738         d = fdopendir(nfd);
3739         if (!d) {
3740                 close_nointr_nofail(nfd);
3741                 return NULL;
3742         }
3743
3744         return d;
3745 }
3746
3747 int signal_from_string_try_harder(const char *s) {
3748         int signo;
3749         assert(s);
3750
3751         signo = signal_from_string(s);
3752         if (signo <= 0)
3753                 if (startswith(s, "SIG"))
3754                         return signal_from_string(s+3);
3755
3756         return signo;
3757 }
3758
3759 static char *tag_to_udev_node(const char *tagvalue, const char *by) {
3760         char *dn, *t, *u;
3761         int r;
3762
3763         /* FIXME: to follow udev's logic 100% we need to leave valid
3764          * UTF8 chars unescaped */
3765
3766         u = unquote(tagvalue, "\"\'");
3767         if (u == NULL)
3768                 return NULL;
3769
3770         t = xescape(u, "/ ");
3771         free(u);
3772
3773         if (t == NULL)
3774                 return NULL;
3775
3776         r = asprintf(&dn, "/dev/disk/by-%s/%s", by, t);
3777         free(t);
3778
3779         if (r < 0)
3780                 return NULL;
3781
3782         return dn;
3783 }
3784
3785 char *fstab_node_to_udev_node(const char *p) {
3786         assert(p);
3787
3788         if (startswith(p, "LABEL="))
3789                 return tag_to_udev_node(p+6, "label");
3790
3791         if (startswith(p, "UUID="))
3792                 return tag_to_udev_node(p+5, "uuid");
3793
3794         if (startswith(p, "PARTUUID="))
3795                 return tag_to_udev_node(p+9, "partuuid");
3796
3797         if (startswith(p, "PARTLABEL="))
3798                 return tag_to_udev_node(p+10, "partlabel");
3799
3800         return strdup(p);
3801 }
3802
3803 bool tty_is_vc(const char *tty) {
3804         assert(tty);
3805
3806         if (startswith(tty, "/dev/"))
3807                 tty += 5;
3808
3809         return vtnr_from_tty(tty) >= 0;
3810 }
3811
3812 bool tty_is_console(const char *tty) {
3813         assert(tty);
3814
3815         if (startswith(tty, "/dev/"))
3816                 tty += 5;
3817
3818         return streq(tty, "console");
3819 }
3820
3821 int vtnr_from_tty(const char *tty) {
3822         int i, r;
3823
3824         assert(tty);
3825
3826         if (startswith(tty, "/dev/"))
3827                 tty += 5;
3828
3829         if (!startswith(tty, "tty") )
3830                 return -EINVAL;
3831
3832         if (tty[3] < '0' || tty[3] > '9')
3833                 return -EINVAL;
3834
3835         r = safe_atoi(tty+3, &i);
3836         if (r < 0)
3837                 return r;
3838
3839         if (i < 0 || i > 63)
3840                 return -EINVAL;
3841
3842         return i;
3843 }
3844
3845 bool tty_is_vc_resolve(const char *tty) {
3846         char *active = NULL;
3847         bool b;
3848
3849         assert(tty);
3850
3851         if (startswith(tty, "/dev/"))
3852                 tty += 5;
3853
3854         /* Resolve where /dev/console is pointing to, if /sys is
3855          * actually ours (i.e. not read-only-mounted which is a sign
3856          * for container setups) */
3857         if (streq(tty, "console") && path_is_read_only_fs("/sys") <= 0)
3858                 if (read_one_line_file("/sys/class/tty/console/active", &active) >= 0) {
3859                         /* If multiple log outputs are configured the
3860                          * last one is what /dev/console points to */
3861                         tty = strrchr(active, ' ');
3862                         if (tty)
3863                                 tty++;
3864                         else
3865                                 tty = active;
3866                 }
3867
3868         b = tty_is_vc(tty);
3869         free(active);
3870
3871         return b;
3872 }
3873
3874 const char *default_term_for_tty(const char *tty) {
3875         assert(tty);
3876
3877         return tty_is_vc_resolve(tty) ? "TERM=linux" : "TERM=vt102";
3878 }
3879
3880 bool dirent_is_file(const struct dirent *de) {
3881         assert(de);
3882
3883         if (ignore_file(de->d_name))
3884                 return false;
3885
3886         if (de->d_type != DT_REG &&
3887             de->d_type != DT_LNK &&
3888             de->d_type != DT_UNKNOWN)
3889                 return false;
3890
3891         return true;
3892 }
3893
3894 bool dirent_is_file_with_suffix(const struct dirent *de, const char *suffix) {
3895         assert(de);
3896
3897         if (de->d_type != DT_REG &&
3898             de->d_type != DT_LNK &&
3899             de->d_type != DT_UNKNOWN)
3900                 return false;
3901
3902         if (ignore_file_allow_backup(de->d_name))
3903                 return false;
3904
3905         return endswith(de->d_name, suffix);
3906 }
3907
3908 void execute_directory(const char *directory, DIR *d, char *argv[]) {
3909         DIR *_d = NULL;
3910         struct dirent *de;
3911         Hashmap *pids = NULL;
3912
3913         assert(directory);
3914
3915         /* Executes all binaries in a directory in parallel and waits
3916          * until all they all finished. */
3917
3918         if (!d) {
3919                 if (!(_d = opendir(directory))) {
3920
3921                         if (errno == ENOENT)
3922                                 return;
3923
3924                         log_error("Failed to enumerate directory %s: %m", directory);
3925                         return;
3926                 }
3927
3928                 d = _d;
3929         }
3930
3931         if (!(pids = hashmap_new(trivial_hash_func, trivial_compare_func))) {
3932                 log_error("Failed to allocate set.");
3933                 goto finish;
3934         }
3935
3936         while ((de = readdir(d))) {
3937                 char *path;
3938                 pid_t pid;
3939                 int k;
3940
3941                 if (!dirent_is_file(de))
3942                         continue;
3943
3944                 if (asprintf(&path, "%s/%s", directory, de->d_name) < 0) {
3945                         log_oom();
3946                         continue;
3947                 }
3948
3949                 if ((pid = fork()) < 0) {
3950                         log_error("Failed to fork: %m");
3951                         free(path);
3952                         continue;
3953                 }
3954
3955                 if (pid == 0) {
3956                         char *_argv[2];
3957                         /* Child */
3958
3959                         if (!argv) {
3960                                 _argv[0] = path;
3961                                 _argv[1] = NULL;
3962                                 argv = _argv;
3963                         } else
3964                                 argv[0] = path;
3965
3966                         execv(path, argv);