// Copyright 2019 Fuzhou Rockchip Electronics Co., Ltd. All rights reserved.
|
// Use of this source code is governed by a BSD-style license that can be
|
// found in the LICENSE file.
|
|
#include <sys/prctl.h>
|
|
#include "dbus_server.h"
|
#include "logger/log.h"
|
|
#ifdef LOG_TAG
|
#undef LOG_TAG
|
#endif
|
#define LOG_TAG "dbus_server.cpp"
|
|
namespace rockchip {
|
namespace aiserver {
|
|
DBusServer::DBusServer(bool session, bool need_dbserver)
|
: session_(session), need_dbserver_(need_dbserver) {
|
LOG_DEBUG("dbus server setup\n");
|
|
media_control_.reset(new DBusMediaControl());
|
}
|
|
DBusServer::~DBusServer() {
|
UnRegisterMediaControl();
|
media_control_.reset(nullptr);
|
}
|
|
static void *ServerProcess(void *arg) {
|
char thread_name[40];
|
snprintf(thread_name, sizeof(thread_name), "DBusServer");
|
prctl(PR_SET_NAME, thread_name);
|
DBus::default_dispatcher->enter();
|
return nullptr;
|
}
|
|
void DBusServer::start(void) {
|
LOG_DEBUG("dbus server start\n");
|
service_thread_.reset(new Thread(ServerProcess, this));
|
service_thread_->set_status(kThreadRunning);
|
}
|
|
void DBusServer::stop(void) {
|
DBus::default_dispatcher->leave();
|
service_thread_->set_status(kThreadStopping);
|
media_control_.reset();
|
|
LOG_DEBUG("dbus server stop\n");
|
}
|
|
ThreadStatus DBusServer::status(void) {
|
if (service_thread_)
|
return service_thread_->status();
|
else
|
return kThreadRunning;
|
}
|
|
int DBusServer::RegisterMediaControl(RTGraphListener *listener) {
|
DbusDispatcher(100);
|
DBus::Connection conn =
|
session_ ? DBus::Connection::SessionBus() : DBus::Connection::SystemBus();
|
conn.request_name(MEDIA_CONTROL_BUS_NAME);
|
|
|
media_control_->listenMediaCtrl(conn, listener);
|
return 0;
|
}
|
|
int DBusServer::UnRegisterMediaControl() {
|
return 0;
|
}
|
|
} // namespace aiserver
|
} // namespace rockchip
|
