1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
|
// Copyright 2023 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#ifdef UNSAFE_BUFFERS_BUILD
// TODO(crbug.com/390223051): Remove C-library calls to fix the errors.
#pragma allow_unsafe_libc_calls
#endif
#include "chrome/updater/ipc/update_service_dialer.h"
#include <sys/socket.h>
#include <sys/un.h>
#include <cstdio>
#include <optional>
#include "base/files/file_path.h"
#include "base/files/file_util.h"
#include "base/logging.h"
#include "base/process/launch.h"
#include "chrome/updater/constants.h"
#include "chrome/updater/linux/ipc_constants.h"
#include "chrome/updater/updater_scope.h"
#include "chrome/updater/util/util.h"
namespace updater {
// Start the update service by connecting to its activation socket. This will
// cause systemd to launch the service as the appropriate user.
bool DialUpdateService(UpdaterScope scope) {
base::FilePath activation_socket_path = GetActivationSocketPath(scope);
if (!base::PathExists(activation_socket_path)) {
// If there's no activation socket present, abandon dialing.
return false;
}
base::ScopedFD sock_fd(socket(AF_UNIX, SOCK_STREAM, 0));
if (!sock_fd.is_valid()) {
VPLOG(1) << "Could not create socket";
return false;
}
struct sockaddr_un remote;
remote.sun_family = AF_UNIX;
snprintf(remote.sun_path, sizeof(remote.sun_path), "%s",
activation_socket_path.AsUTF8Unsafe().c_str());
int len = strlen(remote.sun_path) + sizeof(remote.sun_family);
if (connect(sock_fd.get(), (struct sockaddr*)&remote, len) == -1) {
VPLOG(1) << "Could not connect to activation socket";
return false;
}
return true;
}
bool DialUpdateInternalService(UpdaterScope scope) {
std::optional<base::FilePath> updater = GetUpdaterExecutablePath(scope);
if (updater) {
base::CommandLine command(*updater);
command.AppendSwitch(kServerSwitch);
command.AppendSwitchUTF8(kServerServiceSwitch,
kServerUpdateServiceInternalSwitchValue);
if (scope == UpdaterScope::kSystem) {
command.AppendSwitch(kSystemSwitch);
}
base::LaunchProcess(command, {});
}
return true;
}
} // namespace updater
|
