| // Copyright 2013 The ChromiumOS Authors |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include "lorgnette/daemon.h" |
| |
| #include <sysexits.h> |
| |
| #include <string> |
| #include <utility> |
| |
| #include <base/functional/bind.h> |
| #include <base/logging.h> |
| #include <base/run_loop.h> |
| #include <base/task/single_thread_task_runner.h> |
| #include <base/time/time.h> |
| #include <chromeos/dbus/service_constants.h> |
| |
| #include "lorgnette/dbus_service_adaptor.h" |
| #include "lorgnette/sane_client.h" |
| #include "lorgnette/sane_client_impl.h" |
| #include "lorgnette/usb/libusb_wrapper.h" |
| #include "lorgnette/usb/libusb_wrapper_impl.h" |
| |
| using std::string; |
| |
| namespace lorgnette { |
| |
| // static |
| const char Daemon::kScanGroupName[] = "scanner"; |
| const char Daemon::kScanUserName[] = "saned"; |
| |
| namespace { |
| |
| constexpr base::TimeDelta kMaxDiscoverySessionTime = base::Minutes(60); |
| constexpr base::TimeDelta kTimeoutCheckInterval = base::Seconds(2); |
| |
| } // namespace |
| |
| Daemon::Daemon(base::OnceClosure startup_callback) |
| : DBusServiceDaemon(kManagerServiceName, "/ObjectManager"), |
| startup_callback_(std::move(startup_callback)) {} |
| |
| Daemon::~Daemon() {} |
| |
| int Daemon::OnInit() { |
| int return_code = brillo::DBusServiceDaemon::OnInit(); |
| if (return_code != EX_OK) { |
| return return_code; |
| } |
| |
| PostponeShutdown(kNormalShutdownTimeout); |
| |
| // Signal that we've acquired all resources. |
| std::move(startup_callback_).Run(); |
| return EX_OK; |
| } |
| |
| void Daemon::RegisterDBusObjectsAsync( |
| brillo::dbus_utils::AsyncEventSequencer* sequencer) { |
| sane_client_ = SaneClientImpl::Create(); |
| libusb_ = LibusbWrapperImpl::Create(); |
| auto manager = |
| std::make_unique<Manager>(base::BindRepeating(&Daemon::PostponeShutdown, |
| weak_factory_.GetWeakPtr()), |
| sane_client_.get()); |
| device_tracker_.reset(new DeviceTracker(sane_client_.get(), libusb_.get())); |
| dbus_service_.reset( |
| new DBusServiceAdaptor(std::move(manager), device_tracker_.get(), |
| base::BindRepeating(&Daemon::OnDebugChanged, |
| weak_factory_.GetWeakPtr()))); |
| dbus_service_->RegisterAsync(object_manager_.get(), sequencer); |
| } |
| |
| void Daemon::OnShutdown(int* return_code) { |
| LOG(INFO) << "Shutting down"; |
| dbus_service_.reset(); |
| brillo::DBusServiceDaemon::OnShutdown(return_code); |
| } |
| |
| void Daemon::OnTimeout() { |
| if (device_tracker_->NumActiveDiscoverySessions() > 0) { |
| base::TimeDelta idle_time = |
| base::Time::Now() - device_tracker_->LastDiscoverySessionActivity(); |
| if (idle_time < kMaxDiscoverySessionTime) { |
| PostponeShutdown(kTimeoutCheckInterval); |
| return; |
| } |
| } |
| |
| LOG(INFO) << "Exiting after timeout"; |
| Quit(); |
| } |
| |
| void Daemon::OnDebugChanged() { |
| LOG(INFO) << "Exiting after debug config changed."; |
| Quit(); |
| } |
| |
| void Daemon::PostponeShutdown(base::TimeDelta delay) { |
| shutdown_callback_.Reset( |
| base::BindOnce(&Daemon::OnTimeout, weak_factory_.GetWeakPtr())); |
| base::SingleThreadTaskRunner::GetCurrentDefault()->PostDelayedTask( |
| FROM_HERE, shutdown_callback_.callback(), delay); |
| } |
| |
| } // namespace lorgnette |