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