src/timedate/timedated.c

   1 /* SPDX-License-Identifier: LGPL-2.1+ */
   2 /***
   3   This file is part of systemd.
   4
   5   Copyright 2011 Lennart Poettering
   6 ***/
   7
   8 #include <errno.h>
   9 #include <string.h>
  10 #include <unistd.h>
  11
  12 #include "sd-bus.h"
  13 #include "sd-event.h"
  14 #include "sd-messages.h"
  15
  16 #include "alloc-util.h"
  17 #include "bus-common-errors.h"
  18 #include "bus-error.h"
  19 #include "bus-util.h"
  20 #include "clock-util.h"
  21 #include "def.h"
  22 #include "fileio-label.h"
  23 #include "fs-util.h"
  24 #include "hashmap.h"
  25 #include "list.h"
  26 #include "path-util.h"
  27 #include "selinux-util.h"
  28 #include "string-util.h"
  29 #include "strv.h"
  30 #include "unit-def.h"
  31 #include "unit-name.h"
  32 #include "user-util.h"
  33 #include "util.h"
  34
  35 #define NULL_ADJTIME_UTC "0.0 0 0\n0\nUTC\n"
  36 #define NULL_ADJTIME_LOCAL "0.0 0 0\n0\nLOCAL\n"
  37
  38 typedef struct UnitStatusInfo {
  39         char *name;
  40         char *load_state;
  41         char *unit_file_state;
  42         char *active_state;
  43
  44         LIST_FIELDS(struct UnitStatusInfo, units);
  45 } UnitStatusInfo;
  46
  47 typedef struct Context {
  48         char *zone;
  49         bool local_rtc;
  50         Hashmap *polkit_registry;
  51
  52         LIST_HEAD(UnitStatusInfo, units);
  53 } Context;
  54
  55 static void unit_status_info_clear(UnitStatusInfo *p) {
  56         assert(p);
  57
  58         p->load_state = mfree(p->load_state);
  59         p->unit_file_state = mfree(p->unit_file_state);
  60         p->active_state = mfree(p->active_state);
  61 }
  62
  63 static void unit_status_info_free(UnitStatusInfo *p) {
  64         assert(p);
  65
  66         unit_status_info_clear(p);
  67         free(p->name);
  68         free(p);
  69 }
  70
  71 static void context_free(Context *c) {
  72         UnitStatusInfo *p;
  73
  74         assert(c);
  75
  76         free(c->zone);
  77         bus_verify_polkit_async_registry_free(c->polkit_registry);
  78
  79         while ((p = c->units)) {
  80                 LIST_REMOVE(units, c->units, p);
  81                 unit_status_info_free(p);
  82         }
  83 }
  84
  85 static int context_add_ntp_service(Context *c, const char *s) {
  86         UnitStatusInfo *u;
  87
  88         if (!unit_name_is_valid(s, UNIT_NAME_PLAIN))
  89                 return -EINVAL;
  90
  91         /* Do not add this if it is already listed */
  92         LIST_FOREACH(units, u, c->units)
  93                 if (streq(u->name, s))
  94                         return 0;
  95
  96         u = new0(UnitStatusInfo, 1);
  97         if (!u)
  98                 return -ENOMEM;
  99
 100         u->name = strdup(s);
 101         if (!u->name) {
 102                 free(u);
 103                 return -ENOMEM;
 104         }
 105
 106         LIST_APPEND(units, c->units, u);
 107
 108         return 0;
 109 }
 110
 111 static int context_parse_ntp_services(Context *c) {
 112         const char *env, *p;
 113         int r;
 114
 115         assert(c);
 116
 117         env = getenv("SYSTEMD_TIMEDATED_NTP_SERVICES");
 118         if (!env) {
 119                 r = context_add_ntp_service(c, "systemd-timesyncd.service");
 120                 if (r < 0)
 121                         log_warning_errno(r, "Failed to add NTP service \"systemd-timesyncd.service\", ignoring: %m");
 122
 123                 return 0;
 124         }
 125
 126         for (p = env;;) {
 127                 _cleanup_free_ char *word = NULL;
 128
 129                 r = extract_first_word(&p, &word, ":", 0);
 130                 if (r == 0)
 131                         break;
 132                 if (r == -ENOMEM)
 133                         return log_oom();
 134                 if (r < 0) {
 135                         log_error("Invalid syntax, ignoring: %s", env);
 136                         break;
 137                 }
 138
 139                 r = context_add_ntp_service(c, word);
 140                 if (r < 0)
 141                         log_warning_errno(r, "Failed to add NTP service \"%s\", ignoring: %m", word);
 142         }
 143
 144         return 0;
 145 }
 146
 147 static int context_ntp_service_is_active(Context *c) {
 148         UnitStatusInfo *info;
 149         int count = 0;
 150
 151         assert(c);
 152
 153         /* Call context_update_ntp_status() to update UnitStatusInfo before calling this. */
 154
 155         LIST_FOREACH(units, info, c->units)
 156                 count += streq_ptr(info->active_state, "active");
 157
 158         return count;
 159 }
 160
 161 static int context_ntp_service_is_enabled(Context *c) {
 162         UnitStatusInfo *info;
 163         int count = 0;
 164
 165         assert(c);
 166
 167         /* Call context_update_ntp_status() to update UnitStatusInfo before calling this. */
 168
 169         LIST_FOREACH(units, info, c->units)
 170                 count += STRPTR_IN_SET(info->unit_file_state, "enabled", "enabled-runtime");
 171
 172         return count;
 173 }
 174
 175 static int context_ntp_service_exists(Context *c) {
 176         UnitStatusInfo *info;
 177         int count = 0;
 178
 179         assert(c);
 180
 181         /* Call context_update_ntp_status() to update UnitStatusInfo before calling this. */
 182
 183         LIST_FOREACH(units, info, c->units)
 184                 count += streq_ptr(info->load_state, "loaded");
 185
 186         return count;
 187 }
 188
 189 static int context_read_data(Context *c) {
 190         _cleanup_free_ char *t = NULL;
 191         int r;
 192
 193         assert(c);
 194
 195         r = get_timezone(&t);
 196         if (r == -EINVAL)
 197                 log_warning_errno(r, "/etc/localtime should be a symbolic link to a time zone data file in /usr/share/zoneinfo/.");
 198         else if (r < 0)
 199                 log_warning_errno(r, "Failed to get target of /etc/localtime: %m");
 200
 201         free_and_replace(c->zone, t);
 202
 203         c->local_rtc = clock_is_localtime(NULL) > 0;
 204
 205         return 0;
 206 }
 207
 208 static int context_write_data_timezone(Context *c) {
 209         _cleanup_free_ char *p = NULL;
 210         int r = 0;
 211
 212         assert(c);
 213
 214         if (isempty(c->zone)) {
 215                 if (unlink("/etc/localtime") < 0 && errno != ENOENT)
 216                         r = -errno;
 217
 218                 return r;
 219         }
 220
 221         p = strappend("../usr/share/zoneinfo/", c->zone);
 222         if (!p)
 223                 return log_oom();
 224
 225         r = symlink_atomic(p, "/etc/localtime");
 226         if (r < 0)
 227                 return r;
 228
 229         return 0;
 230 }
 231
 232 static int context_write_data_local_rtc(Context *c) {
 233         int r;
 234         _cleanup_free_ char *s = NULL, *w = NULL;
 235
 236         assert(c);
 237
 238         r = read_full_file("/etc/adjtime", &s, NULL);
 239         if (r < 0) {
 240                 if (r != -ENOENT)
 241                         return r;
 242
 243                 if (!c->local_rtc)
 244                         return 0;
 245
 246                 w = strdup(NULL_ADJTIME_LOCAL);
 247                 if (!w)
 248                         return -ENOMEM;
 249         } else {
 250                 char *p;
 251                 const char *e = "\n"; /* default if there is less than 3 lines */
 252                 const char *prepend = "";
 253                 size_t a, b;
 254
 255                 p = strchrnul(s, '\n');
 256                 if (*p == '\0')
 257                         /* only one line, no \n terminator */
 258                         prepend = "\n0\n";
 259                 else if (p[1] == '\0') {
 260                         /* only one line, with \n terminator */
 261                         ++p;
 262                         prepend = "0\n";
 263                 } else {
 264                         p = strchr(p+1, '\n');
 265                         if (!p) {
 266                                 /* only two lines, no \n terminator */
 267                                 prepend = "\n";
 268                                 p = s + strlen(s);
 269                         } else {
 270                                 char *end;
 271                                 /* third line might have a \n terminator or not */
 272                                 p++;
 273                                 end = strchr(p, '\n');
 274                                 /* if we actually have a fourth line, use that as suffix "e", otherwise the default \n */
 275                                 if (end)
 276                                         e = end;
 277                         }
 278                 }
 279
 280                 a = p - s;
 281                 b = strlen(e);
 282
 283                 w = new(char, a + (c->local_rtc ? 5 : 3) + strlen(prepend) + b + 1);
 284                 if (!w)
 285                         return -ENOMEM;
 286
 287                 *(char*) mempcpy(stpcpy(stpcpy(mempcpy(w, s, a), prepend), c->local_rtc ? "LOCAL" : "UTC"), e, b) = 0;
 288
 289                 if (streq(w, NULL_ADJTIME_UTC)) {
 290                         if (unlink("/etc/adjtime") < 0)
 291                                 if (errno != ENOENT)
 292                                         return -errno;
 293
 294                         return 0;
 295                 }
 296         }
 297
 298         mac_selinux_init();
 299         return write_string_file_atomic_label("/etc/adjtime", w);
 300 }
 301
 302 static int context_update_ntp_status(Context *c, sd_bus *bus, sd_bus_message *m) {
 303         static const struct bus_properties_map map[] = {
 304                 { "LoadState",     "s", NULL, offsetof(UnitStatusInfo, load_state)      },
 305                 { "ActiveState",   "s", NULL, offsetof(UnitStatusInfo, active_state)    },
 306                 { "UnitFileState", "s", NULL, offsetof(UnitStatusInfo, unit_file_state) },
 307                 {}
 308         };
 309         static sd_bus_message *_m = NULL;
 310         UnitStatusInfo *u;
 311         int r;
 312
 313         assert(c);
 314         assert(bus);
 315
 316         /* Suppress multiple call of context_update_ntp_status() within single DBus transaction. */
 317         if (m && m == _m)
 318                 return 0;
 319
 320         _m = m;
 321
 322         LIST_FOREACH(units, u, c->units) {
 323                 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
 324                 _cleanup_free_ char *path = NULL;
 325
 326                 unit_status_info_clear(u);
 327
 328                 path = unit_dbus_path_from_name(u->name);
 329                 if (!path)
 330                         return -ENOMEM;
 331
 332                 r = bus_map_all_properties(
 333                                 bus,
 334                                 "org.freedesktop.systemd1",
 335                                 path,
 336                                 map,
 337                                 BUS_MAP_STRDUP,
 338                                 &error,
 339                                 NULL,
 340                                 u);
 341                 if (r < 0)
 342                         return log_error_errno(r, "Failed to get properties: %s", bus_error_message(&error, r));
 343         }
 344
 345         return 0;
 346 }
 347
 348 static int unit_start_or_stop(UnitStatusInfo *u, sd_bus *bus, sd_bus_error *error, bool start) {
 349         int r;
 350
 351         assert(u);
 352         assert(bus);
 353         assert(error);
 354
 355         /* Call context_update_ntp_status() to update UnitStatusInfo before calling this. */
 356
 357         if (streq(u->active_state, "active") == start)
 358                 return 0;
 359
 360         r = sd_bus_call_method(
 361                 bus,
 362                 "org.freedesktop.systemd1",
 363                 "/org/freedesktop/systemd1",
 364                 "org.freedesktop.systemd1.Manager",
 365                 start ? "StartUnit" : "StopUnit",
 366                 error,
 367                 NULL,
 368                 "ss",
 369                 u->name,
 370                 "replace");
 371         if (r < 0)
 372                 return r;
 373
 374         return 0;
 375 }
 376
 377 static int unit_enable_or_disable(UnitStatusInfo *u, sd_bus *bus, sd_bus_error *error, bool enable) {
 378         int r;
 379
 380         assert(u);
 381         assert(bus);
 382         assert(error);
 383
 384         /* Call context_update_ntp_status() to update UnitStatusInfo before calling this. */
 385
 386         if (streq(u->unit_file_state, "enabled") == enable)
 387                 return 0;
 388
 389         if (enable)
 390                 r = sd_bus_call_method(
 391                                 bus,
 392                                 "org.freedesktop.systemd1",
 393                                 "/org/freedesktop/systemd1",
 394                                 "org.freedesktop.systemd1.Manager",
 395                                 "EnableUnitFiles",
 396                                 error,
 397                                 NULL,
 398                                 "asbb", 1,
 399                                 u->name,
 400                                 false, true);
 401         else
 402                 r = sd_bus_call_method(
 403                                 bus,
 404                                 "org.freedesktop.systemd1",
 405                                 "/org/freedesktop/systemd1",
 406                                 "org.freedesktop.systemd1.Manager",
 407                                 "DisableUnitFiles",
 408                                 error,
 409                                 NULL,
 410                                 "asb", 1,
 411                                 u->name,
 412                                 false);
 413         if (r < 0)
 414                 return r;
 415
 416         r = sd_bus_call_method(
 417                         bus,
 418                         "org.freedesktop.systemd1",
 419                         "/org/freedesktop/systemd1",
 420                         "org.freedesktop.systemd1.Manager",
 421                         "Reload",
 422                         error,
 423                         NULL,
 424                         NULL);
 425          if (r < 0)
 426                  return r;
 427         return 0;
 428 }
 429
 430 static BUS_DEFINE_PROPERTY_GET_GLOBAL(property_get_time, "t", now(CLOCK_REALTIME));
 431 static BUS_DEFINE_PROPERTY_GET_GLOBAL(property_get_ntp_sync, "b", ntp_synced());
 432
 433 static int property_get_rtc_time(
 434                 sd_bus *bus,
 435                 const char *path,
 436                 const char *interface,
 437                 const char *property,
 438                 sd_bus_message *reply,
 439                 void *userdata,
 440                 sd_bus_error *error) {
 441
 442         struct tm tm;
 443         usec_t t;
 444         int r;
 445
 446         zero(tm);
 447         r = clock_get_hwclock(&tm);
 448         if (r == -EBUSY) {
 449                 log_warning("/dev/rtc is busy. Is somebody keeping it open continuously? That's not a good idea... Returning a bogus RTC timestamp.");
 450                 t = 0;
 451         } else if (r == -ENOENT) {
 452                 log_debug("/dev/rtc not found.");
 453                 t = 0; /* no RTC found */
 454         } else if (r < 0)
 455                 return sd_bus_error_set_errnof(error, r, "Failed to read RTC: %m");
 456         else
 457                 t = (usec_t) timegm(&tm) * USEC_PER_SEC;
 458
 459         return sd_bus_message_append(reply, "t", t);
 460 }
 461
 462 static int property_get_can_ntp(
 463                 sd_bus *bus,
 464                 const char *path,
 465                 const char *interface,
 466                 const char *property,
 467                 sd_bus_message *reply,
 468                 void *userdata,
 469                 sd_bus_error *error) {
 470
 471         Context *c = userdata;
 472         int r;
 473
 474         assert(c);
 475         assert(bus);
 476         assert(property);
 477         assert(reply);
 478         assert(error);
 479
 480         r = context_update_ntp_status(c, bus, reply);
 481         if (r < 0)
 482                 return r;
 483
 484         return sd_bus_message_append(reply, "b", context_ntp_service_exists(c) > 0);
 485 }
 486
 487 static int property_get_ntp(
 488                 sd_bus *bus,
 489                 const char *path,
 490                 const char *interface,
 491                 const char *property,
 492                 sd_bus_message *reply,
 493                 void *userdata,
 494                 sd_bus_error *error) {
 495
 496         Context *c = userdata;
 497         int r;
 498
 499         assert(c);
 500         assert(bus);
 501         assert(property);
 502         assert(reply);
 503         assert(error);
 504
 505         r = context_update_ntp_status(c, bus, reply);
 506         if (r < 0)
 507                 return r;
 508
 509         return sd_bus_message_append(reply, "b", context_ntp_service_is_active(c) > 0);
 510 }
 511
 512 static int method_set_timezone(sd_bus_message *m, void *userdata, sd_bus_error *error) {
 513         Context *c = userdata;
 514         int interactive, r;
 515         const char *z;
 516
 517         assert(m);
 518         assert(c);
 519
 520         r = sd_bus_message_read(m, "sb", &z, &interactive);
 521         if (r < 0)
 522                 return r;
 523
 524         if (!timezone_is_valid(z, LOG_DEBUG))
 525                 return sd_bus_error_setf(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid time zone '%s'", z);
 526
 527         if (streq_ptr(z, c->zone))
 528                 return sd_bus_reply_method_return(m, NULL);
 529
 530         r = bus_verify_polkit_async(
 531                         m,
 532                         CAP_SYS_TIME,
 533                         "org.freedesktop.timedate1.set-timezone",
 534                         NULL,
 535                         interactive,
 536                         UID_INVALID,
 537                         &c->polkit_registry,
 538                         error);
 539         if (r < 0)
 540                 return r;
 541         if (r == 0)
 542                 return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */
 543
 544         r = free_and_strdup(&c->zone, z);
 545         if (r < 0)
 546                 return r;
 547
 548         /* 1. Write new configuration file */
 549         r = context_write_data_timezone(c);
 550         if (r < 0) {
 551                 log_error_errno(r, "Failed to set time zone: %m");
 552                 return sd_bus_error_set_errnof(error, r, "Failed to set time zone: %m");
 553         }
 554
 555         /* 2. Make glibc notice the new timezone */
 556         tzset();
 557
 558         /* 3. Tell the kernel our timezone */
 559         r = clock_set_timezone(NULL);
 560         if (r < 0)
 561                 log_debug_errno(r, "Failed to tell kernel about timezone, ignoring: %m");
 562
 563         if (c->local_rtc) {
 564                 struct timespec ts;
 565                 struct tm *tm;
 566
 567                 /* 4. Sync RTC from system clock, with the new delta */
 568                 assert_se(clock_gettime(CLOCK_REALTIME, &ts) == 0);
 569                 assert_se(tm = localtime(&ts.tv_sec));
 570
 571                 r = clock_set_hwclock(tm);
 572                 if (r < 0)
 573                         log_debug_errno(r, "Failed to sync time to hardware clock, ignoring: %m");
 574         }
 575
 576         log_struct(LOG_INFO,
 577                    "MESSAGE_ID=" SD_MESSAGE_TIMEZONE_CHANGE_STR,
 578                    "TIMEZONE=%s", c->zone,
 579                    "TIMEZONE_SHORTNAME=%s", tzname[daylight],
 580                    "DAYLIGHT=%i", daylight,
 581                    LOG_MESSAGE("Changed time zone to '%s' (%s).", c->zone, tzname[daylight]));
 582
 583         (void) sd_bus_emit_properties_changed(sd_bus_message_get_bus(m), "/org/freedesktop/timedate1", "org.freedesktop.timedate1", "Timezone", NULL);
 584
 585         return sd_bus_reply_method_return(m, NULL);
 586 }
 587
 588 static int method_set_local_rtc(sd_bus_message *m, void *userdata, sd_bus_error *error) {
 589         int lrtc, fix_system, interactive;
 590         Context *c = userdata;
 591         struct timespec ts;
 592         int r;
 593
 594         assert(m);
 595         assert(c);
 596
 597         r = sd_bus_message_read(m, "bbb", &lrtc, &fix_system, &interactive);
 598         if (r < 0)
 599                 return r;
 600
 601         if (lrtc == c->local_rtc)
 602                 return sd_bus_reply_method_return(m, NULL);
 603
 604         r = bus_verify_polkit_async(
 605                         m,
 606                         CAP_SYS_TIME,
 607                         "org.freedesktop.timedate1.set-local-rtc",
 608                         NULL,
 609                         interactive,
 610                         UID_INVALID,
 611                         &c->polkit_registry,
 612                         error);
 613         if (r < 0)
 614                 return r;
 615         if (r == 0)
 616                 return 1;
 617
 618         c->local_rtc = lrtc;
 619
 620         /* 1. Write new configuration file */
 621         r = context_write_data_local_rtc(c);
 622         if (r < 0) {
 623                 log_error_errno(r, "Failed to set RTC to local/UTC: %m");
 624                 return sd_bus_error_set_errnof(error, r, "Failed to set RTC to local/UTC: %m");
 625         }
 626
 627         /* 2. Tell the kernel our timezone */
 628         r = clock_set_timezone(NULL);
 629         if (r < 0)
 630                 log_debug_errno(r, "Failed to tell kernel about timezone, ignoring: %m");
 631
 632         /* 3. Synchronize clocks */
 633         assert_se(clock_gettime(CLOCK_REALTIME, &ts) == 0);
 634
 635         if (fix_system) {
 636                 struct tm tm;
 637
 638                 /* Sync system clock from RTC; first, initialize the timezone fields of struct tm. */
 639                 if (c->local_rtc)
 640                         tm = *localtime(&ts.tv_sec);
 641                 else
 642                         tm = *gmtime(&ts.tv_sec);
 643
 644                 /* Override the main fields of struct tm, but not the timezone fields */
 645                 r = clock_get_hwclock(&tm);
 646                 if (r < 0)
 647                         log_debug_errno(r, "Failed to get hardware clock, ignoring: %m");
 648                 else {
 649                         /* And set the system clock with this */
 650                         if (c->local_rtc)
 651                                 ts.tv_sec = mktime(&tm);
 652                         else
 653                                 ts.tv_sec = timegm(&tm);
 654
 655                         if (clock_settime(CLOCK_REALTIME, &ts) < 0)
 656                                 log_debug_errno(errno, "Failed to update system clock, ignoring: %m");
 657                 }
 658
 659         } else {
 660                 struct tm *tm;
 661
 662                 /* Sync RTC from system clock */
 663                 if (c->local_rtc)
 664                         tm = localtime(&ts.tv_sec);
 665                 else
 666                         tm = gmtime(&ts.tv_sec);
 667
 668                 r = clock_set_hwclock(tm);
 669                 if (r < 0)
 670                         log_debug_errno(r, "Failed to sync time to hardware clock, ignoring: %m");
 671         }
 672
 673         log_info("RTC configured to %s time.", c->local_rtc ? "local" : "UTC");
 674
 675         (void) sd_bus_emit_properties_changed(sd_bus_message_get_bus(m), "/org/freedesktop/timedate1", "org.freedesktop.timedate1", "LocalRTC", NULL);
 676
 677         return sd_bus_reply_method_return(m, NULL);
 678 }
 679
 680 static int method_set_time(sd_bus_message *m, void *userdata, sd_bus_error *error) {
 681         sd_bus *bus = sd_bus_message_get_bus(m);
 682         int relative, interactive, r;
 683         Context *c = userdata;
 684         int64_t utc;
 685         struct timespec ts;
 686         usec_t start;
 687         struct tm* tm;
 688
 689         assert(m);
 690         assert(c);
 691
 692         r = context_update_ntp_status(c, bus, m);
 693         if (r < 0)
 694                 return sd_bus_error_set_errnof(error, r, "Failed to update context: %m");
 695
 696         if (context_ntp_service_is_active(c) > 0)
 697                 return sd_bus_error_set(error, BUS_ERROR_AUTOMATIC_TIME_SYNC_ENABLED, "Automatic time synchronization is enabled");
 698
 699         /* this only gets used if dbus does not provide a timestamp */
 700         start = now(CLOCK_MONOTONIC);
 701
 702         r = sd_bus_message_read(m, "xbb", &utc, &relative, &interactive);
 703         if (r < 0)
 704                 return r;
 705
 706         if (!relative && utc <= 0)
 707                 return sd_bus_error_set(error, SD_BUS_ERROR_INVALID_ARGS, "Invalid absolute time");
 708
 709         if (relative && utc == 0)
 710                 return sd_bus_reply_method_return(m, NULL);
 711
 712         if (relative) {
 713                 usec_t n, x;
 714
 715                 n = now(CLOCK_REALTIME);
 716                 x = n + utc;
 717
 718                 if ((utc > 0 && x < n) ||
 719                     (utc < 0 && x > n))
 720                         return sd_bus_error_set(error, SD_BUS_ERROR_INVALID_ARGS, "Time value overflow");
 721
 722                 timespec_store(&ts, x);
 723         } else
 724                 timespec_store(&ts, (usec_t) utc);
 725
 726         r = bus_verify_polkit_async(
 727                         m,
 728                         CAP_SYS_TIME,
 729                         "org.freedesktop.timedate1.set-time",
 730                         NULL,
 731                         interactive,
 732                         UID_INVALID,
 733                         &c->polkit_registry,
 734                         error);
 735         if (r < 0)
 736                 return r;
 737         if (r == 0)
 738                 return 1;
 739
 740         /* adjust ts for time spent in program */
 741         r = sd_bus_message_get_monotonic_usec(m, &start);
 742         /* when sd_bus_message_get_monotonic_usec() returns -ENODATA it does not modify &start */
 743         if (r < 0 && r != -ENODATA)
 744                 return r;
 745
 746         timespec_store(&ts, timespec_load(&ts) + (now(CLOCK_MONOTONIC) - start));
 747
 748         /* Set system clock */
 749         if (clock_settime(CLOCK_REALTIME, &ts) < 0) {
 750                 log_error_errno(errno, "Failed to set local time: %m");
 751                 return sd_bus_error_set_errnof(error, errno, "Failed to set local time: %m");
 752         }
 753
 754         /* Sync down to RTC */
 755         if (c->local_rtc)
 756                 tm = localtime(&ts.tv_sec);
 757         else
 758                 tm = gmtime(&ts.tv_sec);
 759
 760         r = clock_set_hwclock(tm);
 761         if (r < 0)
 762                 log_debug_errno(r, "Failed to update hardware clock, ignoring: %m");
 763
 764         log_struct(LOG_INFO,
 765                    "MESSAGE_ID=" SD_MESSAGE_TIME_CHANGE_STR,
 766                    "REALTIME="USEC_FMT, timespec_load(&ts),
 767                    LOG_MESSAGE("Changed local time to %s", ctime(&ts.tv_sec)));
 768
 769         return sd_bus_reply_method_return(m, NULL);
 770 }
 771
 772 static int method_set_ntp(sd_bus_message *m, void *userdata, sd_bus_error *error) {
 773         sd_bus *bus = sd_bus_message_get_bus(m);
 774         Context *c = userdata;
 775         UnitStatusInfo *u;
 776         int enable, interactive, q, r;
 777
 778         assert(m);
 779         assert(bus);
 780         assert(c);
 781
 782         r = sd_bus_message_read(m, "bb", &enable, &interactive);
 783         if (r < 0)
 784                 return r;
 785
 786         r = context_update_ntp_status(c, bus, m);
 787         if (r < 0)
 788                 return r;
 789
 790         if (context_ntp_service_exists(c) <= 0)
 791                 return sd_bus_error_set(error, BUS_ERROR_NO_NTP_SUPPORT, "NTP not supported");
 792
 793         r = bus_verify_polkit_async(
 794                         m,
 795                         CAP_SYS_TIME,
 796                         "org.freedesktop.timedate1.set-ntp",
 797                         NULL,
 798                         interactive,
 799                         UID_INVALID,
 800                         &c->polkit_registry,
 801                         error);
 802         if (r < 0)
 803                 return r;
 804         if (r == 0)
 805                 return 1;
 806
 807         if (!enable)
 808                 LIST_FOREACH(units, u, c->units) {
 809                         if (!streq(u->load_state, "loaded"))
 810                                 continue;
 811
 812                         q = unit_enable_or_disable(u, bus, error, enable);
 813                         if (q < 0)
 814                                 r = q;
 815
 816                         q = unit_start_or_stop(u, bus, error, enable);
 817                         if (q < 0)
 818                                 r = q;
 819                 }
 820
 821         else if (context_ntp_service_is_enabled(c) <= 0)
 822                 LIST_FOREACH(units, u, c->units) {
 823                         if (!streq(u->load_state, "loaded"))
 824                                 continue;
 825
 826                         r = unit_enable_or_disable(u, bus, error, enable);
 827                         if (r < 0)
 828                                 continue;
 829
 830                         r = unit_start_or_stop(u, bus, error, enable);
 831                         break;
 832                 }
 833
 834         else if (context_ntp_service_is_active(c) <= 0)
 835                 LIST_FOREACH(units, u, c->units) {
 836                         if (!streq(u->load_state, "loaded") ||
 837                             !streq(u->unit_file_state, "enabled"))
 838                                 continue;
 839
 840                         r = unit_start_or_stop(u, bus, error, enable);
 841                         break;
 842                 }
 843
 844         if (r < 0)
 845                 return r;
 846
 847         log_info("Set NTP to %sd", enable_disable(enable));
 848
 849         (void) sd_bus_emit_properties_changed(bus, "/org/freedesktop/timedate1", "org.freedesktop.timedate1", "NTP", NULL);
 850
 851         return sd_bus_reply_method_return(m, NULL);
 852 }
 853
 854 static const sd_bus_vtable timedate_vtable[] = {
 855         SD_BUS_VTABLE_START(0),
 856         SD_BUS_PROPERTY("Timezone", "s", NULL, offsetof(Context, zone), SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
 857         SD_BUS_PROPERTY("LocalRTC", "b", bus_property_get_bool, offsetof(Context, local_rtc), SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
 858         SD_BUS_PROPERTY("CanNTP", "b", property_get_can_ntp, 0, 0),
 859         SD_BUS_PROPERTY("NTP", "b", property_get_ntp, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
 860         SD_BUS_PROPERTY("NTPSynchronized", "b", property_get_ntp_sync, 0, 0),
 861         SD_BUS_PROPERTY("TimeUSec", "t", property_get_time, 0, 0),
 862         SD_BUS_PROPERTY("RTCTimeUSec", "t", property_get_rtc_time, 0, 0),
 863         SD_BUS_METHOD("SetTime", "xbb", NULL, method_set_time, SD_BUS_VTABLE_UNPRIVILEGED),
 864         SD_BUS_METHOD("SetTimezone", "sb", NULL, method_set_timezone, SD_BUS_VTABLE_UNPRIVILEGED),
 865         SD_BUS_METHOD("SetLocalRTC", "bbb", NULL, method_set_local_rtc, SD_BUS_VTABLE_UNPRIVILEGED),
 866         SD_BUS_METHOD("SetNTP", "bb", NULL, method_set_ntp, SD_BUS_VTABLE_UNPRIVILEGED),
 867         SD_BUS_VTABLE_END,
 868 };
 869
 870 static int connect_bus(Context *c, sd_event *event, sd_bus **_bus) {
 871         _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
 872         int r;
 873
 874         assert(c);
 875         assert(event);
 876         assert(_bus);
 877
 878         r = sd_bus_default_system(&bus);
 879         if (r < 0)
 880                 return log_error_errno(r, "Failed to get system bus connection: %m");
 881
 882         r = sd_bus_add_object_vtable(bus, NULL, "/org/freedesktop/timedate1", "org.freedesktop.timedate1", timedate_vtable, c);
 883         if (r < 0)
 884                 return log_error_errno(r, "Failed to register object: %m");
 885
 886         r = sd_bus_request_name_async(bus, NULL, "org.freedesktop.timedate1", 0, NULL, NULL);
 887         if (r < 0)
 888                 return log_error_errno(r, "Failed to request name: %m");
 889
 890         r = sd_bus_attach_event(bus, event, 0);
 891         if (r < 0)
 892                 return log_error_errno(r, "Failed to attach bus to event loop: %m");
 893
 894         *_bus = TAKE_PTR(bus);
 895
 896         return 0;
 897 }
 898
 899 int main(int argc, char *argv[]) {
 900         Context context = {};
 901         _cleanup_(sd_event_unrefp) sd_event *event = NULL;
 902         _cleanup_(sd_bus_flush_close_unrefp) sd_bus *bus = NULL;
 903         int r;
 904
 905         log_set_target(LOG_TARGET_AUTO);
 906         log_parse_environment();
 907         log_open();
 908
 909         umask(0022);
 910
 911         if (argc != 1) {
 912                 log_error("This program takes no arguments.");
 913                 r = -EINVAL;
 914                 goto finish;
 915         }
 916
 917         r = sd_event_default(&event);
 918         if (r < 0) {
 919                 log_error_errno(r, "Failed to allocate event loop: %m");
 920                 goto finish;
 921         }
 922
 923         sd_event_set_watchdog(event, true);
 924
 925         r = connect_bus(&context, event, &bus);
 926         if (r < 0)
 927                 goto finish;
 928
 929         (void) sd_bus_negotiate_timestamp(bus, true);
 930
 931         r = context_read_data(&context);
 932         if (r < 0) {
 933                 log_error_errno(r, "Failed to read time zone data: %m");
 934                 goto finish;
 935         }
 936
 937         r = context_parse_ntp_services(&context);
 938         if (r < 0)
 939                 goto finish;
 940
 941         r = bus_event_loop_with_idle(event, bus, "org.freedesktop.timedate1", DEFAULT_EXIT_USEC, NULL, NULL);
 942         if (r < 0) {
 943                 log_error_errno(r, "Failed to run event loop: %m");
 944                 goto finish;
 945         }
 946
 947 finish:
 948         context_free(&context);
 949
 950         return r < 0 ? EXIT_FAILURE : EXIT_SUCCESS;
 951 }