[rygel] tests: No need to keep module in tests dir

[Zeeshan Ali Khattak <zeeshanak src gnome org>]

commit 1e21d51cf291f3c55caf22a9ff9f5981aac0fa50
Author: Zeeshan Ali (Khattak) <zeeshanak gnome org>
Date:   Fri Mar 25 01:50:54 2011 +0200

    tests: No need to keep module in tests dir
    
    Only keep symlink to the module in tests dir.

 tests/rygel-http-gst-response.vala |  270 +-----------------------------------
 1 files changed, 1 insertions(+), 269 deletions(-)
---
diff --git a/tests/rygel-http-gst-response.vala b/tests/rygel-http-gst-response.vala
deleted file mode 100644
index 6581084..0000000
--- a/tests/rygel-http-gst-response.vala
+++ /dev/null
@@ -1,269 +0,0 @@
-/*
- * Copyright (C) 2008 Zeeshan Ali (Khattak) <zeeshanak gnome org>.
- * Copyright (C) 2008 Nokia Corporation.
- *
- * Author: Zeeshan Ali (Khattak) <zeeshanak gnome org>
- *                               <zeeshan ali nokia com>
- *
- * This file is part of Rygel.
- *
- * Rygel is free software; you can redistribute it and/or modify
- * it under the terms of the GNU Lesser General Public License as published by
- * the Free Software Foundation; either version 2 of the License, or
- * (at your option) any later version.
- *
- * Rygel 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 Lesser General Public License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public License
- * along with this program; if not, write to the Free Software Foundation,
- * Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
- */
-
-using GUPnP;
-using Gst;
-
-internal class Rygel.HTTPGstResponse : Rygel.HTTPResponse {
-    private const string SINK_NAME = "fakesink";
-    // High and low threshold for number of buffered chunks
-    private const uint MAX_BUFFERED_CHUNKS = 32;
-    private const uint MIN_BUFFERED_CHUNKS = 4;
-
-    private Pipeline pipeline;
-
-    private HTTPSeek time_range;
-
-    private int64 buffered;
-    private bool out_of_sync;
-
-    public HTTPGstResponse (Soup.Server  server,
-                         Soup.Message msg,
-                         string       name,
-                         Element      src,
-                         HTTPSeek?    time_range,
-                         Cancellable? cancellable) throws Error {
-        base (server, msg, false, cancellable);
-
-        this.msg.response_headers.set_encoding (Soup.Encoding.EOF);
-
-        this.prepare_pipeline (name, src);
-        this.time_range = time_range;
-
-        this.buffered = 0;
-        this.out_of_sync = false;
-    }
-
-    public override async void run () {
-        this.msg.wrote_chunk.connect (this.on_wrote_chunk);
-
-        // Only bother attempting to seek if the offset is greater than zero.
-        if (this.time_range != null && this.time_range.start > 0) {
-            this.pipeline.set_state (State.PAUSED);
-        } else {
-            this.pipeline.set_state (State.PLAYING);
-        }
-
-        this.run_continue = run.callback;
-
-        yield;
-    }
-
-    public override void end (bool aborted, uint status) {
-        this.pipeline.set_state (State.NULL);
-        this.msg.wrote_chunk.disconnect (this.on_wrote_chunk);
-
-        if (!aborted) {
-            this.msg.response_body.complete ();
-            this.server.unpause_message (this.msg);
-        }
-
-        base.end (aborted, status);
-    }
-
-    private void prepare_pipeline (string name,
-                                   Element src) throws Error {
-        dynamic Element sink = ElementFactory.make ("fakesink", SINK_NAME);
-
-        if (sink == null) {
-            // 'fakesink' should not be translated
-            throw new GstError.MISSING_PLUGIN (_("Plugin 'fakesink' missing"));
-        }
-
-        sink.signal_handoffs = true;
-        sink.handoff.connect (this.on_new_buffer);
-
-        this.pipeline = new Pipeline (name);
-        assert (this.pipeline != null);
-
-        this.pipeline.add_many (src, sink);
-
-        if (src.numpads == 0) {
-            // Seems source uses dynamic pads, link when pad available
-            src.pad_added.connect (this.src_pad_added);
-        } else {
-            // static pads? easy!
-            if (!src.link (sink)) {
-                throw new GstError.LINK (_("Failed to link %s to %s"),
-                                         src.name,
-                                         sink.name);
-            }
-        }
-
-        // Bus handler
-        var bus = this.pipeline.get_bus ();
-        bus.add_watch (bus_handler);
-    }
-
-    private void src_pad_added (Element src,
-                                Pad     src_pad) {
-        var caps = src_pad.get_caps ();
-
-        var sink = this.pipeline.get_by_name (SINK_NAME);
-        Pad sink_pad;
-
-        dynamic Element depay = GstUtils.get_rtp_depayloader (caps);
-        if (depay != null) {
-            this.pipeline.add (depay);
-            if (!depay.link (sink)) {
-                critical (_("Failed to link %s to %s"),
-                          depay.name,
-                          sink.name);
-                this.end (false, Soup.KnownStatusCode.NONE);
-                return;
-            }
-
-            sink_pad = depay.get_compatible_pad (src_pad, caps);
-        } else {
-            sink_pad = sink.get_compatible_pad (src_pad, caps);
-        }
-
-        if (src_pad.link (sink_pad) != PadLinkReturn.OK) {
-            critical (_("Failed to link pad %s to %s"),
-                      src_pad.name,
-                      sink_pad.name);
-            this.end (false, Soup.KnownStatusCode.NONE);
-            return;
-        }
-
-        if (depay != null) {
-            depay.sync_state_with_parent ();
-        }
-    }
-
-    private void on_new_buffer (Element sink,
-                                Buffer  buffer,
-                                Pad     pad) {
-        Idle.add_full (Priority.HIGH_IDLE,
-                       () => {
-            if (this.cancellable.is_cancelled ()) {
-                return false;
-            }
-
-            this.push_data (buffer.data);
-            this.buffered++;
-
-            if (this.buffered > MAX_BUFFERED_CHUNKS) {
-                // Client is either not reading (Paused) or not fast enough
-                this.pipeline.set_state (State.PAUSED);
-                this.out_of_sync = true;
-            }
-
-            return false;
-        });
-    }
-
-    private void on_wrote_chunk (Soup.Message msg) {
-        this.buffered--;
-
-        if (out_of_sync && this.buffered < MIN_BUFFERED_CHUNKS) {
-            this.pipeline.set_state (State.PLAYING);
-            this.out_of_sync = false;
-        }
-    }
-
-    private bool bus_handler (Gst.Bus     bus,
-                              Gst.Message message) {
-        bool ret = true;
-
-        if (message.type == MessageType.EOS) {
-            ret = false;
-        } else if (message.type == MessageType.STATE_CHANGED) {
-            if (message.src != this.pipeline) {
-                return true;
-            }
-
-            if (this.time_range != null && this.time_range.start > 0) {
-                State old_state;
-                State new_state;
-
-                message.parse_state_changed (out old_state,
-                                             out new_state,
-                                             null);
-
-                if (old_state == State.READY && new_state == State.PAUSED) {
-                    if (this.seek ()) {
-                        this.pipeline.set_state (State.PLAYING);
-                    }
-                }
-            }
-        } else {
-            GLib.Error err;
-            string err_msg;
-
-            if (message.type == MessageType.ERROR) {
-                message.parse_error (out err, out err_msg);
-                critical (_("Error from pipeline %s: %s"),
-                          this.pipeline.name,
-                          err_msg);
-
-                ret = false;
-            } else if (message.type == MessageType.WARNING) {
-                message.parse_warning (out err, out err_msg);
-                warning (_("Warning from pipeline %s: %s"),
-                         this.pipeline.name,
-                         err_msg);
-            }
-        }
-
-        if (!ret) {
-                Idle.add_full (Priority.HIGH_IDLE,
-                               () => {
-                    this.end (false, Soup.KnownStatusCode.NONE);
-
-                    return false;
-                });
-        }
-
-        return ret;
-    }
-
-    private bool seek () {
-        Gst.SeekType stop_type;
-
-        if (this.time_range.stop > 0) {
-            stop_type = Gst.SeekType.SET;
-        } else {
-            stop_type = Gst.SeekType.NONE;
-        }
-
-        if (!this.pipeline.seek (1.0,
-                                 Format.TIME,
-                                 SeekFlags.FLUSH,
-                                 Gst.SeekType.SET,
-                                 this.time_range.start,
-                                 stop_type,
-                                 this.time_range.stop)) {
-            warning (_("Failed to seek to offset %lld"), this.time_range.start);
-
-            this.end (false,
-                      Soup.KnownStatusCode.REQUESTED_RANGE_NOT_SATISFIABLE);
-
-            return false;
-        }
-
-        return true;
-    }
-}
-
diff --git a/tests/rygel-http-gst-response.vala b/tests/rygel-http-gst-response.vala
new file mode 120000
index 0000000..77ea668
--- /dev/null
+++ b/tests/rygel-http-gst-response.vala
@@ -0,0 +1 @@
+../src/rygel/rygel-http-gst-response.vala
\ No newline at end of file