summaryrefslogtreecommitdiff
path: root/tests/PipelineTest.cs
diff options
context:
space:
mode:
Diffstat (limited to 'tests/PipelineTest.cs')
-rw-r--r--tests/PipelineTest.cs259
1 files changed, 129 insertions, 130 deletions
diff --git a/tests/PipelineTest.cs b/tests/PipelineTest.cs
index 860aeaf..40ebabf 100644
--- a/tests/PipelineTest.cs
+++ b/tests/PipelineTest.cs
@@ -9,140 +9,139 @@
using System;
using NUnit.Framework;
-
using Gst;
using Gst.CorePlugins;
[TestFixture]
public class PipelineTest
{
- [TestFixtureSetUp]
- public void Init()
- {
- Application.Init();
- }
-
- [Test]
- public void TestAsyncStateChangeEmpty()
- {
- Pipeline pipeline = new Pipeline(String.Empty);
- Assert.IsNotNull(pipeline, "Could not create pipeline");
-
- Assert.AreEqual(((Element)pipeline).SetState(State.Playing), StateChangeReturn.Success);
- }
-
- [Test]
- public void TestAsyncStateChangeFakeReady()
- {
- Pipeline pipeline = new Pipeline(String.Empty);
- Element src = ElementFactory.Make("fakesrc", null);
- Element sink = ElementFactory.Make("fakesink", null);
-
- Bin bin = (Bin) pipeline;
- bin.Add(src, sink);
- src.Link(sink);
-
- Assert.AreEqual(((Element)pipeline).SetState(State.Ready), StateChangeReturn.Success);
- }
-
- [Test]
- public void TestAsyncStateChangeFake()
- {
- bool done = false;
- Pipeline pipeline = new Pipeline(String.Empty);
- Assert.IsNotNull(pipeline, "Could not create pipeline");
-
- Element src = ElementFactory.Make("fakesrc", null);
- Element sink = ElementFactory.Make("fakesink", null);
-
- Bin bin = (Bin) pipeline;
- bin.Add(src, sink);
- src.Link(sink);
-
- Bus bus = pipeline.Bus;
-
- Assert.AreEqual(((Element) pipeline).SetState(State.Playing), StateChangeReturn.Async);
-
- while(!done) {
- State old, newState, pending;
- Message message = bus.Poll(MessageType.StateChanged, -1);
- if(message != null) {
- message.ParseStateChanged(out old, out newState, out pending);
- //Console.WriteLine("state change from {0} to {1}", old, newState);
- if(message.Src == (Gst.Object) pipeline && newState == State.Playing)
- done = true;
- }
- }
-
- Assert.AreEqual(((Element)pipeline).SetState(State.Null), StateChangeReturn.Success);
- }
-
- Element pipeline;
- GLib.MainLoop loop;
-
- bool MessageReceived(Bus bus, Message message) {
- MessageType type = message.Type;
-
- switch(type)
- {
- case MessageType.StateChanged:
- {
- State old, newState, pending;
- message.ParseStateChanged(out old, out newState, out pending);
- if(message.Src == (Gst.Object) pipeline && newState == State.Playing) {
- loop.Quit();
- }
- break;
- }
- case MessageType.Error:
- break;
- default: break;
- }
- return true;
- }
- [Test]
- [Ignore("This test does not terminate")]
- public void TestBus()
- {
- pipeline = new Pipeline(String.Empty);
- Assert.IsNotNull(pipeline, "Could not create pipeline");
-
- Element src = ElementFactory.Make("fakesrc", null);
- Assert.IsNotNull(src, "Could not create fakesrc");
- Element sink = ElementFactory.Make("fakesink", null);
- Assert.IsNotNull(sink, "Could not create fakesink");
-
- Bin bin = (Bin) pipeline;
- bin.Add(src, sink);
- Assert.IsTrue(src.Link(sink), "Could not link between src and sink");
-
- Assert.AreEqual(pipeline.SetState(State.Playing), StateChangeReturn.Async);
-
- loop = new GLib.MainLoop();
- loop.Run();
-
- Assert.AreEqual(pipeline.SetState(State.Null), StateChangeReturn.Success);
- State current, pending;
- Assert.AreEqual(pipeline.GetState(out current, out pending, Clock.TimeNone), StateChangeReturn.Success);
- Assert.AreEqual(current, State.Null, "state is not NULL but " + current);
- }
-
- [Test]
- public void TestBaseTime() {
- Element pipeline = ElementFactory.Make("pipeline", "pipeline");
- FakeSrc fakesrc = FakeSrc.Make("fakesrc");
- FakeSink fakesink = FakeSink.Make("fakesink");
-
- Assert.IsNotNull(pipeline, "Could not create pipeline");
- Assert.IsNotNull(fakesrc, "Could not create fakesrc");
- Assert.IsNotNull(fakesink, "Could not create fakesink");
-
- fakesrc.IsLive = true;
-
- Bin bin = (Bin) pipeline;
- bin.Add(fakesrc, fakesink);
- Assert.IsTrue(fakesrc.Link(fakesink));
-
- Pad sink = fakesink.GetPad("sink");
- }
+ [TestFixtureSetUp]
+ public void Init()
+ {
+ Application.Init();
+ }
+
+ [Test]
+ public void TestAsyncStateChangeEmpty()
+ {
+ Pipeline pipeline = new Pipeline(String.Empty);
+ Assert.IsNotNull(pipeline, "Could not create pipeline");
+
+ Assert.AreEqual(((Element)pipeline).SetState(State.Playing), StateChangeReturn.Success);
+ }
+
+ [Test]
+ public void TestAsyncStateChangeFakeReady()
+ {
+ Pipeline pipeline = new Pipeline(String.Empty);
+ Element src = ElementFactory.Make("fakesrc", null);
+ Element sink = ElementFactory.Make("fakesink", null);
+
+ Bin bin = (Bin) pipeline;
+ bin.Add(src, sink);
+ src.Link(sink);
+
+ Assert.AreEqual(((Element)pipeline).SetState(State.Ready), StateChangeReturn.Success);
+ }
+
+ [Test]
+ public void TestAsyncStateChangeFake()
+ {
+ bool done = false;
+ Pipeline pipeline = new Pipeline(String.Empty);
+ Assert.IsNotNull(pipeline, "Could not create pipeline");
+
+ Element src = ElementFactory.Make("fakesrc", null);
+ Element sink = ElementFactory.Make("fakesink", null);
+
+ Bin bin = (Bin) pipeline;
+ bin.Add(src, sink);
+ src.Link(sink);
+
+ Bus bus = pipeline.Bus;
+
+ Assert.AreEqual(((Element) pipeline).SetState(State.Playing), StateChangeReturn.Async);
+
+ while(!done) {
+ State old, newState, pending;
+ Message message = bus.Poll(MessageType.StateChanged, -1);
+ if(message != null) {
+ message.ParseStateChanged(out old, out newState, out pending);
+ //Console.WriteLine("state change from {0} to {1}", old, newState);
+ if(message.Src == (Gst.Object) pipeline && newState == State.Playing)
+ done = true;
+ }
+ }
+
+ Assert.AreEqual(((Element)pipeline).SetState(State.Null), StateChangeReturn.Success);
+ }
+
+ Element pipeline;
+ GLib.MainLoop loop;
+
+ bool MessageReceived(Bus bus, Message message) {
+ MessageType type = message.Type;
+
+ switch(type)
+ {
+ case MessageType.StateChanged:
+ {
+ State old, newState, pending;
+ message.ParseStateChanged(out old, out newState, out pending);
+ if(message.Src == (Gst.Object) pipeline && newState == State.Playing) {
+ loop.Quit();
+ }
+ break;
+ }
+ case MessageType.Error:
+ break;
+ default: break;
+ }
+ return true;
+ }
+ [Test]
+ [Ignore("This test does not terminate")]
+ public void TestBus()
+ {
+ pipeline = new Pipeline(String.Empty);
+ Assert.IsNotNull(pipeline, "Could not create pipeline");
+
+ Element src = ElementFactory.Make("fakesrc", null);
+ Assert.IsNotNull(src, "Could not create fakesrc");
+ Element sink = ElementFactory.Make("fakesink", null);
+ Assert.IsNotNull(sink, "Could not create fakesink");
+
+ Bin bin = (Bin) pipeline;
+ bin.Add(src, sink);
+ Assert.IsTrue(src.Link(sink), "Could not link between src and sink");
+
+ Assert.AreEqual(pipeline.SetState(State.Playing), StateChangeReturn.Async);
+
+ loop = new GLib.MainLoop();
+ loop.Run();
+
+ Assert.AreEqual(pipeline.SetState(State.Null), StateChangeReturn.Success);
+ State current, pending;
+ Assert.AreEqual(pipeline.GetState(out current, out pending, Clock.TimeNone), StateChangeReturn.Success);
+ Assert.AreEqual(current, State.Null, "state is not NULL but " + current);
+ }
+
+ [Test]
+ public void TestBaseTime() {
+ Element pipeline = ElementFactory.Make("pipeline", "pipeline");
+ FakeSrc fakesrc = FakeSrc.Make("fakesrc");
+ FakeSink fakesink = FakeSink.Make("fakesink");
+
+ Assert.IsNotNull(pipeline, "Could not create pipeline");
+ Assert.IsNotNull(fakesrc, "Could not create fakesrc");
+ Assert.IsNotNull(fakesink, "Could not create fakesink");
+
+ fakesrc.IsLive = true;
+
+ Bin bin = (Bin) pipeline;
+ bin.Add(fakesrc, fakesink);
+ Assert.IsTrue(fakesrc.Link(fakesink));
+
+ Pad sink = fakesink.GetStaticPad("sink");
+ }
}
generated by cgit v1.2.3 (git 2.39.1) at 2024-04-28 14:01:19 +0000