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

Side by Side Diff: chromeos/dbus/session_manager_client.cc

Issue 2397863003: Move free disk space check to session_manager. (Closed)
Patch Set: Address comments. Created 4 years, 2 months 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 unified diff | Download patch
OLDNEW
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "chromeos/dbus/session_manager_client.h" 5 #include "chromeos/dbus/session_manager_client.h"
6 6
7 #include <stddef.h> 7 #include <stddef.h>
8 #include <stdint.h> 8 #include <stdint.h>
9 9
10 #include <memory> 10 #include <memory>
(...skipping 292 matching lines...) Expand 10 before | Expand all | Expand 10 after
303 login_manager::kSessionManagerCheckArcAvailability); 303 login_manager::kSessionManagerCheckArcAvailability);
304 304
305 session_manager_proxy_->CallMethod( 305 session_manager_proxy_->CallMethod(
306 &method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT, 306 &method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
307 base::Bind(&SessionManagerClientImpl::OnCheckArcAvailability, 307 base::Bind(&SessionManagerClientImpl::OnCheckArcAvailability,
308 weak_ptr_factory_.GetWeakPtr(), callback)); 308 weak_ptr_factory_.GetWeakPtr(), callback));
309 } 309 }
310 310
311 void StartArcInstance(const cryptohome::Identification& cryptohome_id, 311 void StartArcInstance(const cryptohome::Identification& cryptohome_id,
312 bool disable_boot_completed_broadcast, 312 bool disable_boot_completed_broadcast,
313 const ArcCallback& callback) override { 313 const StartArcInstanceCallback& callback) override {
314 dbus::MethodCall method_call( 314 dbus::MethodCall method_call(
315 login_manager::kSessionManagerInterface, 315 login_manager::kSessionManagerInterface,
316 login_manager::kSessionManagerStartArcInstance); 316 login_manager::kSessionManagerStartArcInstance);
317 dbus::MessageWriter writer(&method_call); 317 dbus::MessageWriter writer(&method_call);
318 writer.AppendString(cryptohome_id.id()); 318 writer.AppendString(cryptohome_id.id());
319 writer.AppendBool(disable_boot_completed_broadcast); 319 writer.AppendBool(disable_boot_completed_broadcast);
320 session_manager_proxy_->CallMethod( 320 session_manager_proxy_->CallMethodWithErrorCallback(
321 &method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT, 321 &method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
322 base::Bind(&SessionManagerClientImpl::OnArcMethod, 322 base::Bind(&SessionManagerClientImpl::OnStartArcInstanceSucceeded,
323 weak_ptr_factory_.GetWeakPtr(), 323 weak_ptr_factory_.GetWeakPtr(), callback),
324 login_manager::kSessionManagerStartArcInstance, callback)); 324 base::Bind(&SessionManagerClientImpl::OnStartArcInstanceFailed,
325 weak_ptr_factory_.GetWeakPtr(), callback));
325 } 326 }
326 327
327 void StopArcInstance(const ArcCallback& callback) override { 328 void StopArcInstance(const ArcCallback& callback) override {
328 dbus::MethodCall method_call(login_manager::kSessionManagerInterface, 329 dbus::MethodCall method_call(login_manager::kSessionManagerInterface,
329 login_manager::kSessionManagerStopArcInstance); 330 login_manager::kSessionManagerStopArcInstance);
330 session_manager_proxy_->CallMethod( 331 session_manager_proxy_->CallMethod(
331 &method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT, 332 &method_call, dbus::ObjectProxy::TIMEOUT_USE_DEFAULT,
332 base::Bind(&SessionManagerClientImpl::OnArcMethod, 333 base::Bind(&SessionManagerClientImpl::OnArcMethod,
333 weak_ptr_factory_.GetWeakPtr(), 334 weak_ptr_factory_.GetWeakPtr(),
334 login_manager::kSessionManagerStopArcInstance, callback)); 335 login_manager::kSessionManagerStopArcInstance, callback));
(...skipping 380 matching lines...) Expand 10 before | Expand all | Expand 10 after
715 if (!response) { 716 if (!response) {
716 LOG(ERROR) << "Failed to call " << method_name; 717 LOG(ERROR) << "Failed to call " << method_name;
717 } else { 718 } else {
718 success = true; 719 success = true;
719 } 720 }
720 721
721 if (!callback.is_null()) 722 if (!callback.is_null())
722 callback.Run(success); 723 callback.Run(success);
723 } 724 }
724 725
726 void OnStartArcInstanceSucceeded(const StartArcInstanceCallback& callback,
727 dbus::Response* response) {
728 if (!callback.is_null())
729 callback.Run(true, "" /* no error */);
730 }
731
732 void OnStartArcInstanceFailed(const StartArcInstanceCallback& callback,
733 dbus::ErrorResponse* response) {
734 LOG(ERROR) << "Failed to call StartArcInstance: "
735 << (response ? response->ToString() : "(null)");
736 if (!callback.is_null())
737 callback.Run(false, response ? response->GetErrorName() : "");
738 }
739
725 dbus::ObjectProxy* session_manager_proxy_; 740 dbus::ObjectProxy* session_manager_proxy_;
726 std::unique_ptr<BlockingMethodCaller> blocking_method_caller_; 741 std::unique_ptr<BlockingMethodCaller> blocking_method_caller_;
727 base::ObserverList<Observer> observers_; 742 base::ObserverList<Observer> observers_;
728 743
729 // Most recent screen-lock state received from session_manager. 744 // Most recent screen-lock state received from session_manager.
730 bool screen_is_locked_; 745 bool screen_is_locked_;
731 746
732 // Note: This should remain the last member so it'll be destroyed and 747 // Note: This should remain the last member so it'll be destroyed and
733 // invalidate its weak pointers before any other members are destroyed. 748 // invalidate its weak pointers before any other members are destroyed.
734 base::WeakPtrFactory<SessionManagerClientImpl> weak_ptr_factory_; 749 base::WeakPtrFactory<SessionManagerClientImpl> weak_ptr_factory_;
(...skipping 156 matching lines...) Expand 10 before | Expand all | Expand 10 after
891 if (!callback.is_null()) 906 if (!callback.is_null())
892 callback.Run(state_keys); 907 callback.Run(state_keys);
893 } 908 }
894 909
895 void CheckArcAvailability(const ArcCallback& callback) override { 910 void CheckArcAvailability(const ArcCallback& callback) override {
896 callback.Run(false); 911 callback.Run(false);
897 } 912 }
898 913
899 void StartArcInstance(const cryptohome::Identification& cryptohome_id, 914 void StartArcInstance(const cryptohome::Identification& cryptohome_id,
900 bool disable_boot_completed_broadcast, 915 bool disable_boot_completed_broadcast,
901 const ArcCallback& callback) override { 916 const StartArcInstanceCallback& callback) override {
902 callback.Run(false); 917 callback.Run(false, "");
903 } 918 }
904 919
905 void PrioritizeArcInstance(const ArcCallback& callback) override { 920 void PrioritizeArcInstance(const ArcCallback& callback) override {
906 callback.Run(false); 921 callback.Run(false);
907 } 922 }
908 923
909 void EmitArcBooted() override {} 924 void EmitArcBooted() override {}
910 925
911 void StopArcInstance(const ArcCallback& callback) override { 926 void StopArcInstance(const ArcCallback& callback) override {
912 callback.Run(false); 927 callback.Run(false);
(...skipping 26 matching lines...) Expand all
939 954
940 SessionManagerClient* SessionManagerClient::Create( 955 SessionManagerClient* SessionManagerClient::Create(
941 DBusClientImplementationType type) { 956 DBusClientImplementationType type) {
942 if (type == REAL_DBUS_CLIENT_IMPLEMENTATION) 957 if (type == REAL_DBUS_CLIENT_IMPLEMENTATION)
943 return new SessionManagerClientImpl(); 958 return new SessionManagerClientImpl();
944 DCHECK_EQ(FAKE_DBUS_CLIENT_IMPLEMENTATION, type); 959 DCHECK_EQ(FAKE_DBUS_CLIENT_IMPLEMENTATION, type);
945 return new SessionManagerClientStubImpl(); 960 return new SessionManagerClientStubImpl();
946 } 961 }
947 962
948 } // namespace chromeos 963 } // namespace chromeos
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698