mvcp protocol support embedded from melted project

[melted_gui] / src / player.c

diff --git a/src/player.c b/src/player.c
new file mode 100644 (file)
index 0000000..bd456b6
--- /dev/null
+++ b/src/player.c
@@ -0,0 +1,134 @@
+/*
+ * player.h -- GTK+ 2 melted gui
+ * Copyright (C) 2012 Maksym Veremeyenko <verem@m1stereo.tv>
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 2 of the License, or
+ * (at your option) any later version.
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software Foundation,
+ * Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+ */
+#ifndef _GNU_SOURCE
+#define _GNU_SOURCE
+#endif
+
+#ifdef HAVE_CONFIG_H
+#  include <config.h>
+#endif
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <gtk/gtk.h>
+#include <gdk/gdkkeysyms.h>
+#include <pthread.h>
+
+#include <mvcp/mvcp.h>
+#include <mvcp/mvcp_remote.h>
+
+#include "player.h"
+
+static void* player_thread_proc(void* data)
+{
+    int r;
+    int playlist_start_prev = 0;
+//    OmPlrStatus st_curr, st_prev;
+    player_t* player = (player_t*)data;
+
+    g_warning("omnplay_thread_proc\n");
+
+//    memset(&st_curr, 0, sizeof(OmPlrStatus));
+//    memset(&st_prev, 0, sizeof(OmPlrStatus));
+
+    /* connect */
+    pthread_mutex_lock(&player->app->players.lock);
+//    r = OmPlrOpen(player->host, player->name, (OmPlrHandle*)&player->handle);
+    pthread_mutex_unlock(&player->app->players.lock);
+    if(r)
+    {
+//        g_warning("ERROR: OmPlrOpen(%s, %s) failed with 0x%.8X\n",
+//            player->host, player->name, r);
+
+        return (void*)r;
+    };
+
+    /* setup to do not reconnect */
+    pthread_mutex_lock(&player->app->players.lock);
+//    OmPlrSetRetryOpen((OmPlrHandle)player->handle, 0);
+    pthread_mutex_unlock(&player->app->players.lock);
+
+    /* setup directory */
+//    if(player->app->players.path[0])
+    {
+        pthread_mutex_lock(&player->app->players.lock);
+//        r = OmPlrClipSetDirectory((OmPlrHandle)player->handle, player->app->players.path);
+        pthread_mutex_unlock(&player->app->players.lock);
+
+        if(r)
+        {
+//            g_warning("ERROR: OmPlrClipSetDirectory(%s) failed with 0x%.8X\n",
+//                player->app->players.path, r);
+
+            pthread_mutex_lock(&player->app->players.lock);
+//            OmPlrClose((OmPlrHandle)player->handle);
+            pthread_mutex_unlock(&player->app->players.lock);
+
+            return (void*)r;
+        };
+    };
+
+    /* endless loop */
+    for(r = 0 ; !player->app->f_exit && !r;)
+    {
+        /* sleep */
+#ifdef _WIN32
+        Sleep(100);
+#else
+        usleep(100000);
+#endif
+
+        /* get status */
+        pthread_mutex_lock(&player->app->players.lock);
+//        st_curr.size = sizeof(OmPlrStatus);
+//        r = OmPlrGetPlayerStatus((OmPlrHandle)player->handle, &st_curr);
+        pthread_mutex_unlock(&player->app->players.lock);
+
+        if(r)
+            g_warning("ERROR: OmPlrGetPlayerStatus failed with 0x%.8X\n", r);
+        else
+        {
+//            omnplay_update_status(player, &st_prev , &st_curr, &playlist_start_prev);
+//            playlist_start_prev = player->playlist_start;
+//            memcmp(&st_curr, &st_prev, sizeof(OmPlrStatus));
+        };
+    };
+
+    pthread_mutex_lock(&player->app->players.lock);
+//    OmPlrClose((OmPlrHandle)player->handle);
+    pthread_mutex_unlock(&player->app->players.lock);
+
+    return NULL;
+};
+
+
+void player_run(instance_t* app, int idx)
+{
+    mvcp_parser parser = mvcp_parser_init_remote(app->players.host, 5250);
+    mvcp command = mvcp_init(parser);
+
+    app->players.item[idx].thread = g_thread_create(
+        player_thread_proc, &app->players.item[idx], TRUE, NULL);
+};
+
+void player_stop(instance_t* app, int idx)
+{
+    g_thread_join(app->players.item[idx].thread);
+};