Skip to content
This repository has been archived by the owner on May 25, 2021. It is now read-only.

Commit

Permalink
Renamed LoadBalancerServerManager to be SingleServerManager
Browse files Browse the repository at this point in the history
  • Loading branch information
nathannis committed Jan 24, 2013
1 parent daaa3de commit 2b5cf70
Show file tree
Hide file tree
Showing 3 changed files with 9 additions and 9 deletions.
2 changes: 1 addition & 1 deletion src/Connections/ConnectionProvider.cs
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ public abstract class ConnectionProvider : IConnectionProvider
protected ConnectionProvider(IConnectionBuilder builder)
{
ConnectionBuilder = builder;
Servers = new LoadBalancerServerManager(builder);
Servers = new SingleServerManager(builder);
}

/// <summary>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -6,12 +6,12 @@

namespace FluentCassandra.Connections
{
public class LoadBalancerServerManager : IServerManager
public class SingleServerManager : IServerManager
{
private readonly object _lock = new object();
private Server _server;

public LoadBalancerServerManager(IConnectionBuilder builder)
public SingleServerManager(IConnectionBuilder builder)
{
_server = builder.Servers[0];
}
Expand Down Expand Up @@ -39,14 +39,14 @@ public void Add(Server server)
}
public void Remove(Server server)
{
throw new NotImplementedException ("LoadBalancerServerManager does not implement Remove(server)");
throw new NotImplementedException ("SingleServerManager does not implement Remove(server)");
}
#endregion
#region IEnumerable<Server> Members

public IEnumerator<Server> GetEnumerator()
{
throw new NotImplementedException ("LoadBalancerServerManager does not implement Enumerable(server)");
throw new NotImplementedException("SingleServerManager does not implement Enumerable(server)");
}

#endregion
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -4,21 +4,21 @@

namespace FluentCassandra.Connections.Tests
{
public class LoadBalancerServerManagerTests
public class SingleServerManagerTests
{
[Fact]
public void CanGetServerAfterError()
{
LoadBalancerServerManager target = new LoadBalancerServerManager(new ConnectionBuilder("Server=unit-test-1"));
SingleServerManager target = new SingleServerManager(new ConnectionBuilder("Server=unit-test-1"));

Server original = target.Next();

for (int i = 0; i < 10; i++)
{
Assert.True(target.HasNext, "LoadBalancerServerManager should always have another server available.");
Assert.True(target.HasNext, "SingleServerManager should always have another server available.");
Server next = target.Next();
Assert.True(original.ToString().Equals(next.ToString(), StringComparison.OrdinalIgnoreCase),
"LoadBalancerServerManager always returns the same server.");
"SingleServerManager always returns the same server.");
//mark the server as failing to set up the next test iteration.
target.ErrorOccurred(next);
}
Expand Down

0 comments on commit 2b5cf70

Please sign in to comment.