// Copyright 2020 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 <assert.h>
|
#include <fcntl.h>
|
#include <stdio.h>
|
#include <stdlib.h>
|
#include <string>
|
#include <unistd.h>
|
#include <glib.h>
|
#include <dbus-c++/dbus.h>
|
|
#include "json-c/json.h"
|
#include "storage_manager.h"
|
#include "storage_manager_proxy.h"
|
#include "dbus_connection.h"
|
#include "libipcpro_log_control.h"
|
|
extern int ipc_pro_log_ctl;
|
|
#define STORAGEMANAGER_DBUSSEND(FUNC) \
|
char *ret = NULL; \
|
DBusStorageManager* storage_manage_proxy_ = NULL; \
|
dbus_mutex_lock(); \
|
try { \
|
DBus::Connection conn = get_dbus_conn(); \
|
storage_manage_proxy_ = new DBusStorageManager(conn, STORAGEMANAGER_PATH, STORAGEMANAGER, STORAGEMANAGER_INTERFACE); \
|
auto config = storage_manage_proxy_->FUNC(json); \
|
ret = g_strdup(config.c_str()); \
|
delete storage_manage_proxy_; \
|
} catch (DBus::Error err) { \
|
ipc_pro_log_ctl && printf("DBus::Error - %s\n", err.what()); \
|
if (storage_manage_proxy_) { \
|
delete storage_manage_proxy_; \
|
} \
|
} \
|
dbus_mutex_unlock(); \
|
return ret;
|
|
char *dbus_storage_manager_diskformat(char *json)
|
{
|
STORAGEMANAGER_DBUSSEND(DiskFormat);
|
}
|
|
char *dbus_storage_manager_get_media_path(char *json)
|
{
|
STORAGEMANAGER_DBUSSEND(GetMediaPath);
|
}
|
|
char *dbus_storage_manager_get_disks_status(char *json)
|
{
|
STORAGEMANAGER_DBUSSEND(GetDisksStatus);
|
}
|
|
char *dbus_storage_manager_get_filelist(char *json)
|
{
|
STORAGEMANAGER_DBUSSEND(GetFileList);
|
}
|
|
char *dbus_storage_manager_media_storage_stop_notify(char *json)
|
{
|
STORAGEMANAGER_DBUSSEND(MediaStorageStopNotify);
|
}
|
|
extern "C" char *storage_manager_diskformat(char *mountpath, char *type)
|
{
|
char *ret;
|
json_object *j_cfg = json_object_new_object();
|
|
json_object_object_add(j_cfg, "sMountPath", json_object_new_string(mountpath));
|
json_object_object_add(j_cfg, "sType", json_object_new_string(type));
|
|
ret = dbus_storage_manager_diskformat((char *)json_object_to_json_string(j_cfg));
|
|
json_object_put(j_cfg);
|
|
return ret;
|
}
|
|
extern "C" char *storage_manager_get_media_path(void)
|
{
|
return dbus_storage_manager_get_media_path((char *)"");
|
}
|
|
extern "C" char *storage_manager_get_disks_status(char *mountpath)
|
{
|
char *ret = NULL;
|
json_object *j_cfg = json_object_new_object();
|
|
json_object_object_add(j_cfg, "sMountPath", json_object_new_string(mountpath));
|
|
ret = dbus_storage_manager_get_disks_status((char *)json_object_to_json_string(j_cfg));
|
|
json_object_put(j_cfg);
|
|
return ret;
|
}
|
|
extern "C" char *storage_manager_get_filelist_id(int rootid, int pathid, int order, char *limit)
|
{
|
char *ret;
|
json_object *j_cfg = json_object_new_object();
|
|
json_object_object_add(j_cfg, "rootid", json_object_new_int(rootid));
|
json_object_object_add(j_cfg, "pathid", json_object_new_int(pathid));
|
json_object_object_add(j_cfg, "order", json_object_new_int(order));
|
if (limit)
|
json_object_object_add(j_cfg, "limit", json_object_new_string(limit));
|
|
ret = dbus_storage_manager_get_filelist((char *)json_object_to_json_string(j_cfg));
|
|
json_object_put(j_cfg);
|
|
return ret;
|
}
|
|
extern "C" char *storage_manager_get_filelist_path(char *path, int *StartTime, int *EndTime, int order, char *limit)
|
{
|
char *ret;
|
json_object *j_cfg = json_object_new_object();
|
|
json_object_object_add(j_cfg, "path", json_object_new_string(path));
|
json_object_object_add(j_cfg, "order", json_object_new_int(order));
|
if (StartTime)
|
json_object_object_add(j_cfg, "starttime", json_object_new_int(*StartTime));
|
if (EndTime)
|
json_object_object_add(j_cfg, "endtime", json_object_new_int(*EndTime));
|
if (limit)
|
json_object_object_add(j_cfg, "limit", json_object_new_string(limit));
|
|
ret = dbus_storage_manager_get_filelist((char *)json_object_to_json_string(j_cfg));
|
|
json_object_put(j_cfg);
|
|
return ret;
|
}
|
|
extern "C" char *storage_storage_manager_media_storage_stop_notify(char *server_name)
|
{
|
char *ret;
|
|
json_object *j_cfg = json_object_new_object();
|
|
json_object_object_add(j_cfg, "server", json_object_new_string(server_name));
|
|
ret = dbus_storage_manager_media_storage_stop_notify((char *)json_object_to_json_string(j_cfg));
|
|
json_object_put(j_cfg);
|
|
return ret;
|
}
|
