add player EOF detection

[uwplayer.git] / application / player.c

diff --git a/application/player.c b/application/player.c
index b34ea7b..dbaca58 100644 (file)
--- a/application/player.c
+++ b/application/player.c
@@ -101,6 +101,17 @@ static int prepare_player(Player *player, char *log_arg, char *ipc_arg) {
     return 0;
 }
 
+static void* wait_for_process(void *data) {
+    Player *player = data;
+    int status = 0;
+    waitpid(player->process, &status, 0);
+
+    //player->isactive = FALSE;
+    player->status = status;
+    
+    return NULL;
+}
+
 static int start_player_process(Player *player, MainWindow *win) {
     char log_arg[STR_BUFSIZE];
     char ipc_arg[STR_BUFSIZE];
@@ -146,6 +157,11 @@ static int start_player_process(Player *player, MainWindow *win) {
     player->process = player_pid;
     player->isactive = TRUE;
     
+    pthread_t tid;
+    if(pthread_create(&tid, NULL, wait_for_process, player)) {
+        perror("pthread_create");
+    }
+    
     return 0;
 }
 
@@ -230,6 +246,7 @@ static void* start_player(void *data) {
         PlayerDestroy(player);
         return NULL;
     }
+    close(player->log);
      
     if(connect_to_ipc(player)) {
         PlayerDestroy(player);
@@ -249,29 +266,17 @@ static void* start_player(void *data) {
 }
 
 static void player_io(Player *p) {
-    int flags = fcntl(p->log, F_GETFL, 0);
-    fcntl(p->log, F_SETFL, flags | O_NONBLOCK);
-    
     struct pollfd fds[2];
-    fds[0].fd = p->log;
+    fds[0].fd = p->ipc;
     fds[0].events = POLLIN;
     fds[0].revents = 0;
-    fds[1].fd = p->ipc;
-    fds[1].events = POLLIN;
-    fds[1].revents = 0;
-    
     JSONParser *js = json_parser_new();
     
     char buf[PLAYER_IN_BUFSIZE];
-    while(poll(fds, 2, PLAYER_POLL_TIMEOUT)) {
+    while(p->isactive && poll(fds, 2, PLAYER_POLL_TIMEOUT)) {
         if(fds[0].revents == POLLIN) {
-            // clean up fifo
-            read(fds[0].fd, buf, PLAYER_IN_BUFSIZE);
-        }
-        
-        if(fds[1].revents == POLLIN) {
             ssize_t r;
-            if((r = read(fds[1].fd, buf, PLAYER_IN_BUFSIZE)) <= 0) {
+            if((r = read(fds[0].fd, buf, PLAYER_IN_BUFSIZE)) <= 0) {
                 break;
             }
             //fwrite(buf, 1, r, stdout);
@@ -294,6 +299,10 @@ static void player_io(Player *p) {
         char *cmd = "{ \"command\": [\"get_property\", \"playback-time\"], request_id=\"" REQ_ID_PLAYBACK_TIME "\" }\n";
         //write(p->ipc, cmd, strlen(cmd));
     }
+    
+    
+    printf("PlayerEnd: %s\n", strerror(errno));
+    fflush(stdout);
 }
 
 
@@ -357,11 +366,19 @@ static void handle_json_rpc_reqid(Player *player, JSONValue *v, int reqid) {
 
 static void handle_json_rpc_event(Player *p, JSONValue *v, JSONValue *event) {
     if(!json_strcmp(event, "property-change")) {
-        printf("property change\n");
+        JSONValue *name = json_obj_get(&v->value.object, "name");
+        JSONValue *data = json_obj_get(&v->value.object, "data");
+        if(!json_strcmp(name, "eof-reached")) {
+            if(data && data->type == JSON_LITERAL && data->value.literal.literal == JSON_TRUE) {
+                PlayerEOF(p);
+            }
+        }
     } else if(!json_strcmp(event, "playback-restart")) {
         char *cmd = "{ \"command\": [\"observe_property\", 1, \"playback-time\"] }\n"
+                    "{ \"command\": [\"observe_property\", 1, \"eof-reached\"] }\n"
                     "{ \"command\": [\"get_property\", \"width\"], request_id=\"" REQ_ID_WIDTH "\" }\n"
-                    "{ \"command\": [\"get_property\", \"height\"], request_id=\"" REQ_ID_HEIGHT "\" }\n";
+                    "{ \"command\": [\"get_property\", \"height\"], request_id=\"" REQ_ID_HEIGHT "\" }\n"
+                    "{ \"command\": [\"set_property\", \"keep-open\", true] }\n";
         write(p->ipc, cmd, strlen(cmd));
     }
 }
@@ -440,7 +457,13 @@ static void json_print(JSONValue *value, char *name, int indent) {
             break;
         }
         case JSON_LITERAL: {
-            printf("%s\n", "literal\n");
+            char *lit = "NULL";
+            switch(value->value.literal.literal) {
+                case JSON_NULL: break;
+                case JSON_TRUE: lit = "true"; break;
+                case JSON_FALSE: lit = "false"; break;
+            }
+            printf("%s\n", lit);
             break;
         }
     }
@@ -450,3 +473,7 @@ static void json_print(JSONValue *value, char *name, int indent) {
     }
 }
 
+void PlayerEOF(Player *p) {
+    char *cmd = "{ \"command\": [\"set_property\", \"playback-time\", 0] }\n";
+    write(p->ipc, cmd, strlen(cmd));
+}