1 // Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.
2 
3 using System;
4 using System.Collections.Generic;
5 using System.Diagnostics;
6 using System.Reactive.Concurrency;
7 using System.Threading;
8 using Microsoft.Reactive.Testing;
9 #if NUNIT
10 using NUnit.Framework;
11 using TestClassAttribute = NUnit.Framework.TestFixtureAttribute;
12 using TestMethodAttribute = NUnit.Framework.TestAttribute;
13 using TestInitializeAttribute = NUnit.Framework.SetUpAttribute;
14 #else
15 using Microsoft.VisualStudio.TestTools.UnitTesting;
16 #endif
17 
18 namespace ReactiveTests.Tests
19 {
20     [TestClass]
21     public class VirtualSchedulerTest
22     {
23         class VirtualSchedulerTestScheduler : VirtualTimeScheduler<string, char>
24         {
VirtualSchedulerTestScheduler()25             public VirtualSchedulerTestScheduler()
26             {
27             }
28 
VirtualSchedulerTestScheduler(string initialClock, IComparer<string> comparer)29             public VirtualSchedulerTestScheduler(string initialClock, IComparer<string> comparer)
30                 : base(initialClock, comparer)
31             {
32             }
33 
Add(string absolute, char relative)34             protected override string Add(string absolute, char relative)
35             {
36                 return (absolute ?? string.Empty) + relative;
37             }
38 
ToDateTimeOffset(string absolute)39             protected override DateTimeOffset ToDateTimeOffset(string absolute)
40             {
41                 return new DateTimeOffset((absolute ?? string.Empty).Length, TimeSpan.Zero);
42             }
43 
ToRelative(TimeSpan timeSpan)44             protected override char ToRelative(TimeSpan timeSpan)
45             {
46                 return (char)(timeSpan.Ticks % char.MaxValue);
47             }
48         }
49 
50         [TestMethod]
Virtual_Now()51         public void Virtual_Now()
52         {
53             var res = new VirtualSchedulerTestScheduler().Now - DateTime.Now;
54             Assert.IsTrue(res.Seconds < 1);
55         }
56 
57         [TestMethod]
Virtual_ScheduleAction()58         public void Virtual_ScheduleAction()
59         {
60             var id = Thread.CurrentThread.ManagedThreadId;
61             var ran = false;
62             var scheduler = new VirtualSchedulerTestScheduler();
63             scheduler.Schedule(() => { Assert.AreEqual(id, Thread.CurrentThread.ManagedThreadId); ran = true; });
64             scheduler.Start();
65             Assert.IsTrue(ran);
66         }
67 
68         [TestMethod]
Virtual_ScheduleActionError()69         public void Virtual_ScheduleActionError()
70         {
71             var ex = new Exception();
72 
73             try
74             {
75                 var scheduler = new VirtualSchedulerTestScheduler();
76                 scheduler.Schedule(() => { throw ex; });
77                 scheduler.Start();
78                 Assert.Fail();
79             }
80             catch (Exception e)
81             {
82                 Assert.AreSame(e, ex);
83             }
84         }
85 
86         [TestMethod]
Virtual_InitialAndComparer_Now()87         public void Virtual_InitialAndComparer_Now()
88         {
89             var s = new VirtualSchedulerTestScheduler("Bar", Comparer<string>.Default);
90             Assert.AreEqual(3, s.Now.Ticks);
91         }
92 
93         [TestMethod]
Virtual_ArgumentChecking()94         public void Virtual_ArgumentChecking()
95         {
96             ReactiveAssert.Throws<ArgumentNullException>(() => new VirtualSchedulerTestScheduler("", null));
97             ReactiveAssert.Throws<ArgumentNullException>(() => new VirtualSchedulerTestScheduler().ScheduleRelative(0, 'a', null));
98             ReactiveAssert.Throws<ArgumentNullException>(() => new VirtualSchedulerTestScheduler().ScheduleAbsolute(0, "", null));
99             ReactiveAssert.Throws<ArgumentNullException>(() => new VirtualSchedulerTestScheduler().Schedule(0, default(Func<IScheduler, int, IDisposable>)));
100             ReactiveAssert.Throws<ArgumentNullException>(() => new VirtualSchedulerTestScheduler().Schedule(0, TimeSpan.Zero, default(Func<IScheduler, int, IDisposable>)));
101             ReactiveAssert.Throws<ArgumentNullException>(() => new VirtualSchedulerTestScheduler().Schedule(0, DateTimeOffset.UtcNow, default(Func<IScheduler, int, IDisposable>)));
102 
103             ReactiveAssert.Throws<ArgumentNullException>(() => VirtualTimeSchedulerExtensions.ScheduleAbsolute(default(VirtualSchedulerTestScheduler), "", () => {}));
104             ReactiveAssert.Throws<ArgumentNullException>(() => VirtualTimeSchedulerExtensions.ScheduleAbsolute(new VirtualSchedulerTestScheduler(), "", default(Action)));
105             ReactiveAssert.Throws<ArgumentNullException>(() => VirtualTimeSchedulerExtensions.ScheduleRelative(default(VirtualSchedulerTestScheduler), 'a', () => { }));
106             ReactiveAssert.Throws<ArgumentNullException>(() => VirtualTimeSchedulerExtensions.ScheduleRelative(new VirtualSchedulerTestScheduler(), 'a', default(Action)));
107         }
108 
109         [TestMethod]
Historical_ArgumentChecking()110         public void Historical_ArgumentChecking()
111         {
112             ReactiveAssert.Throws<ArgumentNullException>(() => new HistoricalScheduler(DateTime.Now, default(IComparer<DateTimeOffset>)));
113             ReactiveAssert.Throws<ArgumentNullException>(() => new HistoricalScheduler().ScheduleAbsolute(42, DateTime.Now, default(Func<IScheduler, int, IDisposable>)));
114             ReactiveAssert.Throws<ArgumentNullException>(() => new HistoricalScheduler().ScheduleRelative(42, TimeSpan.FromSeconds(1), default(Func<IScheduler, int, IDisposable>)));
115         }
116 
117 #if !SILVERLIGHT
118         [TestMethod]
119         [Ignore]
Virtual_ScheduleActionDue()120         public void Virtual_ScheduleActionDue()
121         {
122             var id = Thread.CurrentThread.ManagedThreadId;
123             var ran = false;
124             var sw = new Stopwatch();
125             sw.Start();
126             var scheduler = new VirtualSchedulerTestScheduler();
127             scheduler.Schedule(TimeSpan.FromSeconds(0.2), () => { sw.Stop(); Assert.AreEqual(id, Thread.CurrentThread.ManagedThreadId); ran = true; });
128             scheduler.Start();
129             Assert.IsTrue(ran, "ran");
130             Assert.IsTrue(sw.ElapsedMilliseconds > 180, "due " + sw.ElapsedMilliseconds);
131         }
132 #endif
133     }
134 }
135