[rygel] core: Check item status after container update

[Jens Georg <jensgeorg src gnome org>]

commit 229b7d064ad347f925c5099808788a89dc429833
Author: Jens Georg <mail jensge org>
Date:   Tue Oct 18 13:50:15 2011 +0200

    core: Check item status after container update
    
    Don't just assume the next container update was caused by the last HTTP
    POST and actually check the place_holder state of the item in question.

 src/rygel/rygel-http-post.vala    |   82 +++++++++++++++++++++++++------------
 src/rygel/rygel-item-creator.vala |   23 +++++-----
 2 files changed, 66 insertions(+), 39 deletions(-)
---
diff --git a/src/rygel/rygel-http-post.vala b/src/rygel/rygel-http-post.vala
index c1bad97..c00ecc5 100644
--- a/src/rygel/rygel-http-post.vala
+++ b/src/rygel/rygel-http-post.vala
@@ -97,6 +97,60 @@ internal class Rygel.HTTPPost : HTTPRequest {
         this.finalize_post ();
     }
 
+    /**
+     * Waits for an item with @id to change its state to non-placeholder under
+     * @container, but at most @timeout seconds.
+     *
+     * @param container The container to watch for changes
+     * @param id The child id to look for
+     * @param timeout Seconds to wait befor cancelling
+     */
+    private async void wait_for_item (MediaContainer container,
+                                      string         id,
+                                      uint           timeout) {
+        MediaItem item = null;
+
+        while (item == null || item.place_holder) {
+            try {
+                item = (yield container.find_object (id,
+                                                     this.cancellable))
+                                                     as MediaItem;
+            } catch (Error error) {
+                // Handle
+                break;
+            }
+
+            if (item.place_holder) {
+                uint timeout_id = 0;
+                timeout = Timeout.add_seconds (30, () => {
+                    debug ("Timeout on waiting for 'updated' signal on '%s'.",
+                           container.id);
+                    timeout_id = 0;
+                    this.wait_for_item.callback ();
+
+                    return false;
+                });
+
+                var update_id = container.container_updated.connect (() => {
+                    debug ("Finished waiting for update signal from container '%s'",
+                           container.id);
+
+                        wait_for_item.callback ();
+                });
+
+                yield;
+
+                container.disconnect (update_id);
+
+                if (timeout_id != 0) {
+                    Source.remove (timeout);
+                } else {
+                    break;
+                }
+            }
+        }
+    }
+
     private async void finalize_post () {
         try {
             this.stream.close (this.cancellable);
@@ -114,25 +168,6 @@ internal class Rygel.HTTPPost : HTTPRequest {
                this.item.parent.id,
                this.item.id);
 
-        var id = this.item.parent.container_updated.connect ((container) => {
-            debug ("Finished waiting for update signal from container '%s'",
-                   this.item.parent.id);
-
-            finalize_post.callback ();
-        });
-
-        uint timeout_id = 0;
-        timeout_id = Timeout.add_seconds (30, () => {
-            debug ("Timeout while waiting for 'updated' signal on '%s'.",
-                   this.item.parent.id);
-            this.item.parent.disconnect (id);
-            timeout_id = 0;
-
-            finalize_post.callback ();
-
-            return false;
-        });
-
         try {
             this.dotfile.move (this.file,
                                FileCopyFlags.NONE,
@@ -143,8 +178,6 @@ internal class Rygel.HTTPPost : HTTPRequest {
                      this.dotfile.get_uri (),
                      move_error.message);
 
-            Source.remove (timeout_id);
-            this.item.parent.disconnect (id);
             this.server.unpause_message (this.msg);
             this.end (KnownStatusCode.INTERNAL_SERVER_ERROR);
             this.handle_continue ();
@@ -152,12 +185,7 @@ internal class Rygel.HTTPPost : HTTPRequest {
             return;
         }
 
-        yield;
-
-        this.item.parent.disconnect (id);
-        if (timeout_id != 0) {
-            Source.remove (timeout_id);
-        }
+        yield wait_for_item (this.item.parent, this.item.id, 30);
 
         this.server.unpause_message (this.msg);
         this.end (KnownStatusCode.OK);
diff --git a/src/rygel/rygel-item-creator.vala b/src/rygel/rygel-item-creator.vala
index 5b9939c..aa24d7d 100644
--- a/src/rygel/rygel-item-creator.vala
+++ b/src/rygel/rygel-item-creator.vala
@@ -410,6 +410,17 @@ internal class Rygel.ItemCreator: GLib.Object, Rygel.StateMachine {
         MediaItem item = null;
 
         while (item == null) {
+            try {
+                item = (yield container.find_object (this.item.id,
+                                                     this.cancellable))
+                       as MediaItem;
+            } catch (Error error) {
+                warning ("Error from container '%s' on trying to find newly " +
+                         "added child item '%s' in it",
+                         container.id,
+                         this.item.id);
+            }
+
             if (item == null) {
                 var id = container.container_updated.connect ((container) => {
                     this.wait_for_item.callback ();
@@ -429,18 +440,6 @@ internal class Rygel.ItemCreator: GLib.Object, Rygel.StateMachine {
 
                 container.disconnect (id);
 
-                try {
-                    item = (yield container.find_object (this.item.id,
-                                                         this.cancellable))
-                                        as MediaItem;
-                } catch (Error error) {
-                    warning ("Error from container '%s' on trying to find newly " +
-                            "added child item '%s' in it",
-                            container.id,
-                            this.item.id);
-                }
-
-
                 if (timeout != 0) {
                     Source.remove (timeout);
                 } else {