tk/Ocelot
1
0
Fork 0
mirror of https://github.com/nsnail/Ocelot.git synced 2025-04-22 06:22:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

still trying to get these stable

Browse Source
This commit is contained in:
Tom Pallister 2018-05-05 16:31:40 +01:00
parent b536a88dca
commit 5ed8257a58
1 changed files with 24 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
test/Ocelot.IntegrationTests/RaftTests.cs
View File

@ -46,20 +46,6 @@ namespace Ocelot.IntegrationTests
_threads = new List<Thread>(); _threads = new List<Thread>();
} }
public void Dispose()
{
foreach (var builder in _builders)
{
builder?.Dispose();
}
foreach (var peer in _peers.Peers)
{
File.Delete(peer.HostAndPort.Replace("/","").Replace(":",""));
File.Delete($"{peer.HostAndPort.Replace("/","").Replace(":","")}.db");
}
}
[Fact] [Fact]
public void should_persist_command_to_five_servers() public void should_persist_command_to_five_servers()
{ {
@ -417,10 +403,33 @@ namespace Ocelot.IntegrationTests
foreach (var peer in _peers.Peers) foreach (var peer in _peers.Peers)
{ {
File.Delete(peer.HostAndPort.Replace("/", "").Replace(":", ""));
File.Delete($"{peer.HostAndPort.Replace("/", "").Replace(":", "")}.db");
var thread = new Thread(() => GivenAServerIsRunning(peer.HostAndPort)); var thread = new Thread(() => GivenAServerIsRunning(peer.HostAndPort));
thread.Start(); thread.Start();
_threads.Add(thread); _threads.Add(thread);
} }
} }
public void Dispose()
{
foreach (var builder in _builders)
{
builder?.Dispose();
}
foreach (var peer in _peers.Peers)
{
try
{
File.Delete(peer.HostAndPort.Replace("/", "").Replace(":", ""));
File.Delete($"{peer.HostAndPort.Replace("/", "").Replace(":", "")}.db");
}
catch (Exception e)
{
Console.WriteLine(e);
}
}
}
} }
} }