Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(107)

Unified Diff: chromeos/dbus/upstart_client.cc

Issue 2475343002: Add UpstartClient (Closed)
Patch Set: Created UpstartClient and moved StartService there Created 4 years, 1 month ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« chromeos/dbus/fake_upstart_client.h ('K') | « chromeos/dbus/upstart_client.h ('k') | no next file » | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: chromeos/dbus/upstart_client.cc
diff --git a/chromeos/dbus/upstart_client.cc b/chromeos/dbus/upstart_client.cc
new file mode 100644
index 0000000000000000000000000000000000000000..bea34feb23f8392d498bdba7ad061e881f18a631
--- /dev/null
+++ b/chromeos/dbus/upstart_client.cc
@@ -0,0 +1,75 @@
+// Copyright (c) 2016 The Chromium Authors. All rights reserved.
+// Use of this source code is governed by a BSD-style license that can be
+// found in the LICENSE file.
+#include "chromeos/dbus/upstart_client.h"
+
+#include "base/bind.h"
+#include "base/memory/weak_ptr.h"
+#include "dbus/bus.h"
+#include "dbus/message.h"
+#include "dbus/object_proxy.h"
+
+namespace chromeos {
+
+namespace {
+
+const char kUpstartServiceName[] = "com.ubuntu.Upstart";
+const char kUpstartJobInterface[] = "com.ubuntu.Upstart0_6.Job";
+const char kUpstartStartMethod[] = "Start";
+
+const char kUpstartAuthPolicyPath[] = "/com/ubuntu/Upstart/jobs/authpolicyd";
+
+class UpstartClientImpl : public UpstartClient {
+ public:
+ UpstartClientImpl() : weak_ptr_factory_(this) {}
+
+ ~UpstartClientImpl() override {}
+
+ // UpstartClient override.
+ void StartAuthPolicyService() override {
+ dbus::ObjectPath objectPath(kUpstartAuthPolicyPath);
+ dbus::ObjectProxy* proxy =
hashimoto 2016/11/08 20:23:58 Please make proxy_ a member of this class to be co
Roman Sorokin (ftl) 2016/11/09 14:03:30 Hmm, what is the right way to do that? Since this
hashimoto 2016/11/11 03:46:57 Ah, it seems this method is tricky. Where can I lo
hashimoto 2016/11/11 05:30:20 FYI, another possible approach is to let the sessi
Roman Sorokin (ftl) 2016/11/14 13:54:19 The problem is we need to start it from Chrome any
Roman Sorokin (ftl) 2016/11/14 13:54:19 I looked here: http://upstart.ubuntu.com/cookbook/
hashimoto 2016/11/14 22:09:40 Thank you for giving me a pointer!
+ bus_->GetObjectProxy(kUpstartServiceName, objectPath);
+ dbus::MethodCall method_call(kUpstartJobInterface, kUpstartStartMethod);
+ dbus::MessageWriter writer(&method_call);
+ dbus::MessageWriter sub_writer(nullptr);
+ writer.OpenArray("s", &sub_writer);
+ writer.CloseContainer(&sub_writer);
hashimoto 2016/11/08 20:23:59 suggestion: How about writer.AppendArrayOfStrings(
Roman Sorokin (ftl) 2016/11/09 14:03:30 Done.
+ writer.AppendBool(false); // No waiting for response.
hashimoto 2016/11/08 20:23:58 IIUC this parameter changes the timing when the re
Roman Sorokin (ftl) 2016/11/09 14:03:30 I checked both options, but response is null in bo
hashimoto 2016/11/11 03:46:58 IIUC, without waiting, it results in ignoring erro
Roman Sorokin (ftl) 2016/11/14 13:53:15 Done.
+ proxy->CallMethod(&method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
+ base::Bind(&UpstartClientImpl::HandleUpstartCallback,
+ weak_ptr_factory_.GetWeakPtr()));
+ }
+
+ protected:
+ void Init(dbus::Bus* bus) override { bus_ = bus; }
+
+ private:
+ void HandleUpstartCallback(dbus::Response* response) {
hashimoto 2016/11/08 20:23:58 HandleUpstartCallback sounds ambiguous as basicall
Roman Sorokin (ftl) 2016/11/09 14:03:30 Done.
+ if (!response) {
+ LOG(ERROR) << "Failed to signal Upstart, response is null";
+ return;
hashimoto 2016/11/08 20:23:58 nit: This line is redundant. Probably you should
Roman Sorokin (ftl) 2016/11/09 14:03:30 Done.
+ }
+ }
+
+ dbus::Bus* bus_ = nullptr;
+
+ // Note: This should remain the last member so it'll be destroyed and
+ // invalidate its weak pointers before any other members are destroyed.
+ base::WeakPtrFactory<UpstartClientImpl> weak_ptr_factory_;
+
+ DISALLOW_COPY_AND_ASSIGN(UpstartClientImpl);
+};
+
+} // namespace
+
+UpstartClient::UpstartClient() {}
+
+UpstartClient::~UpstartClient() {}
+
+// static
+UpstartClient* UpstartClient::Create() {
+ return new UpstartClientImpl();
+}
+
+} // namespace chromeos
« chromeos/dbus/fake_upstart_client.h ('K') | « chromeos/dbus/upstart_client.h ('k') | no next file » | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698