diff options
Diffstat (limited to 'binding/mediaplayer-manager.c')
| -rw-r--r-- | binding/mediaplayer-manager.c | 296 |
1 files changed, 0 insertions, 296 deletions
diff --git a/binding/mediaplayer-manager.c b/binding/mediaplayer-manager.c deleted file mode 100644 index ca46587..0000000 --- a/binding/mediaplayer-manager.c +++ /dev/null @@ -1,296 +0,0 @@ -/* - * Copyright 2017 Konsulko Group - * - * Based on bluetooth-manager.c - * Copyright 2016 ALPS ELECTRIC CO., LTD. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include <unistd.h> -#include <sys/types.h> -#include <sys/stat.h> - -#include <pthread.h> -#include <glib.h> -#include <gio/gio.h> -#include <glib-object.h> -#include <sqlite3.h> - -#include "mediaplayer-manager.h" - -static Binding_RegisterCallback_t g_RegisterCallback = { 0 }; -static stMediaPlayerManage MediaPlayerManage = { 0 }; - -/* ------ LOCAL FUNCTIONS --------- */ -void ListLock() { - g_mutex_lock(&(MediaPlayerManage.m)); -} - -void ListUnlock() { - g_mutex_unlock(&(MediaPlayerManage.m)); -} - -void DebugTraceSendMsg(int level, gchar* message) -{ -#ifdef LOCAL_PRINT_DEBUG - switch (level) - { - case DT_LEVEL_ERROR: - g_print("[E]"); - break; - - case DT_LEVEL_WARNING: - g_print("[W]"); - break; - - case DT_LEVEL_NOTICE: - g_print("[N]"); - break; - - case DT_LEVEL_INFO: - g_print("[I]"); - break; - - case DT_LEVEL_DEBUG: - g_print("[D]"); - break; - - default: - g_print("[-]"); - break; - } - - g_print("%s",message); -#endif - - if (message) { - g_free(message); - } - -} - -GList* media_local_scan(GList *list) -{ - gchar *path = g_strconcat(g_get_home_dir(), "/", "Music", NULL); - gchar *tmp = NULL; - GDir *dir; - - dir = g_dir_open(path, 0, NULL); - if (dir == NULL) - { - LOGE("Cannot open media path %s\n", path); - return list; - } - - while ((tmp = (gchar *) g_dir_read_name(dir)) != NULL) - { - list = g_list_append(list, g_strdup_printf("file://%s/%s", path, tmp)); - } - - g_free(path); - g_dir_close(dir); - - return list; -} - -GList* media_lightmediascanner_scan(void) -{ - sqlite3 *conn; - sqlite3_stmt *res; - GList *list = NULL; - const char *tail; - const gchar *db_path; - int ret = 0; - - db_path = scanner1_get_data_base_path(MediaPlayerManage.lms_proxy); - - ret = sqlite3_open(db_path, &conn); - if (ret) { - LOGE("Cannot open SQLITE database: '%s'\n", db_path); - return NULL; - } - - ret = sqlite3_prepare_v2(conn, SQL_QUERY, strlen(SQL_QUERY) + 1, &res, &tail); - if (ret) { - LOGE("Cannot execute query '%s'\n", SQL_QUERY); - return NULL; - } - - while (sqlite3_step(res) == SQLITE_ROW) { - struct stat buf; - const char *path = (const char *) sqlite3_column_text(res, 0); - - ret = stat(path, &buf); - if (ret) - continue; - - list = g_list_append(list, g_strdup_printf("file://%s", path)); - } - - sqlite3_finalize(res); - - return list; -} - - -static void -on_interface_proxy_properties_changed (GDBusProxy *proxy, - GVariant *changed_properties, - const gchar* const *invalidated_properties) -{ - GVariantIter iter; - const gchar *key; - GVariant *subValue; - const gchar *pInterface; - GList *list; - - pInterface = g_dbus_proxy_get_interface_name (proxy); - - if (0 != g_strcmp0(pInterface, LIGHTMEDIASCANNER_INTERFACE)) - return; - - g_variant_iter_init (&iter, changed_properties); - while (g_variant_iter_next (&iter, "{&sv}", &key, &subValue)) - { - gboolean val; - if (0 == g_strcmp0(key,"IsScanning")) { - g_variant_get(subValue, "b", &val); - if (val == TRUE) - return; - } else if (0 == g_strcmp0(key, "WriteLocked")) { - g_variant_get(subValue, "b", &val); - if (val == TRUE) - return; - } - } - - ListLock(); - - list = media_lightmediascanner_scan(); - - if (list != NULL && g_RegisterCallback.binding_device_added) - g_RegisterCallback.binding_device_added(list); - - g_list_free_full(list, g_free); - - ListUnlock(); -} - -static int MediaPlayerDBusInit(void) -{ - GError *error = NULL; - - MediaPlayerManage.lms_proxy = scanner1_proxy_new_for_bus_sync( - G_BUS_TYPE_SESSION, G_DBUS_PROXY_FLAGS_NONE, LIGHTMEDIASCANNER_SERVICE, - LIGHTMEDIASCANNER_PATH, NULL, &error); - - if (MediaPlayerManage.lms_proxy == NULL) { - LOGE("Create LightMediaScanner Proxy failed\n"); - return -1; - } - - g_signal_connect (MediaPlayerManage.lms_proxy, - "g-properties-changed", - G_CALLBACK (on_interface_proxy_properties_changed), - NULL); - - return 0; -} - -static void *media_event_loop_thread(void *unused) -{ - GMainLoop *loop = g_main_loop_new(NULL, FALSE); - int ret; - - ret = MediaPlayerDBusInit(); - if (ret == 0) { - LOGD("g_main_loop_run\n"); - g_main_loop_run(loop); - } - - g_main_loop_unref(loop); - - return NULL; -} - -void -unmount_cb (GFileMonitor *mon, - GFile *file, - GFile *other_file, - GFileMonitorEvent event, - gpointer udata) -{ - gchar *path = g_file_get_path(file); - gchar *uri = g_strconcat("file://", path, NULL); - g_free(path); - - ListLock(); - - if (g_RegisterCallback.binding_device_removed && - event == G_FILE_MONITOR_EVENT_DELETED) { - g_RegisterCallback.binding_device_removed(uri); - } - - ListUnlock(); - g_free(uri); -} - -/* - * Create MediaPlayer Manager Thread - * Note: mediaplayer-api should do MediaPlayerManagerInit() before any other - * API calls - * Returns: 0 - success or error conditions - */ -int MediaPlayerManagerInit() { - pthread_t thread_id; - GFile *file; - GFileMonitor *mon; - - g_mutex_init(&(MediaPlayerManage.m)); - - file = g_file_new_for_path("/media"); - g_assert(file != NULL); - - mon = g_file_monitor (file, G_FILE_MONITOR_NONE, NULL, NULL); - g_assert(mon != NULL); - g_signal_connect (mon, "changed", G_CALLBACK(unmount_cb), NULL); - - pthread_create(&thread_id, NULL, media_event_loop_thread, NULL); - - return 0; -} - -/* - * Register MediaPlayer Manager Callback functions - */ -void BindingAPIRegister(const Binding_RegisterCallback_t* pstRegisterCallback) -{ - if (NULL != pstRegisterCallback) - { - if (NULL != pstRegisterCallback->binding_device_added) - { - g_RegisterCallback.binding_device_added = - pstRegisterCallback->binding_device_added; - } - - if (NULL != pstRegisterCallback->binding_device_removed) - { - g_RegisterCallback.binding_device_removed = - pstRegisterCallback->binding_device_removed; - } - } -} |