Skip to content

Commit

Permalink
NCBC-275: Modify Nunit tests to allow for execution in single node e…
Browse files Browse the repository at this point in the history 
…nvironment.

Change-Id: Ib4a95b1f70f7d248fa0bfbff22ebb7199a3187d7
Reviewed-on: http://review.couchbase.org/26997
Reviewed-by: Mordechai Nunberg <mnunberg@haskalah.org>
Reviewed-by: Saakshi Manocha <saakshi.manocha@globallogic.com>
Tested-by: Saakshi Manocha <saakshi.manocha@globallogic.com>
  • Loading branch information
@saakshimanocha
saakshimanocha committed Jul 2, 2013
1 parent 2dc8a63 commit 6d90d82
Show file tree
Hide file tree
Showing 2 changed files with 51 additions and 21 deletions.
70 changes: 50 additions & 20 deletions src/Couchbase.Tests/CouchbaseClientObserveTests.cs
View file
Expand Up @@ -54,9 +54,15 @@ public void When_Storing_A_New_Key_Observe_Will_Succeed_With_Master_Persistence_
[Test]
public void When_Storing_A_New_Key_Observe_Will_Succeed_With_Multi_Node_Persistence()
{
var kv = KeyValueUtils.GenerateKeyAndValue("observe");
var storeResult = _Client.ExecuteStore(StoreMode.Set, kv.Item1, kv.Item2, PersistTo.Two);
StoreAssertPass(storeResult);
var availableNodesCount = getWorkingNodes().Count();
if (availableNodesCount > 1)
{
var kv = KeyValueUtils.GenerateKeyAndValue("observe");
var storeResult = _Client.ExecuteStore(StoreMode.Set, kv.Item1, kv.Item2, PersistTo.Two);
StoreAssertPass(storeResult);
}
else
Assert.Ignore("This test requires more than one node in the cluster");
}

/// <summary>
Expand All @@ -68,9 +74,15 @@ public void When_Storing_A_New_Key_Observe_Will_Succeed_With_Multi_Node_Persiste
[Test]
public void When_Storing_A_New_Key_Observe_Will_Succeed_With_Multi_Node_Persistence_And_Single_Node_Replication()
{
var kv = KeyValueUtils.GenerateKeyAndValue("observe");
var storeResult = _Client.ExecuteStore(StoreMode.Set, kv.Item1, kv.Item2, PersistTo.Two, ReplicateTo.One);
StoreAssertPass(storeResult);
var availableNodesCount = getWorkingNodes().Count();
if (availableNodesCount > 1)
{
var kv = KeyValueUtils.GenerateKeyAndValue("observe");
var storeResult = _Client.ExecuteStore(StoreMode.Set, kv.Item1, kv.Item2, PersistTo.Two, ReplicateTo.One);
StoreAssertPass(storeResult);
}
else
Assert.Ignore("This test requires more than one node in the cluster");
}

/// <summary>
Expand Down Expand Up @@ -107,9 +119,15 @@ public void When_Storing_A_New_Key_Observe_Will_Succeed_With_Single_Node_Replica
[Test]
public void When_Storing_A_New_Key_Observe_Will_Succeed_With_Multi_Node_Replication()
{
var kv = KeyValueUtils.GenerateKeyAndValue("observe");
var storeResult = _Client.ExecuteStore(StoreMode.Set, kv.Item1, kv.Item2, ReplicateTo.Two);
StoreAssertPass(storeResult);
var availableNodesCount = getWorkingNodes().Count();
if (availableNodesCount > 1)
{
var kv = KeyValueUtils.GenerateKeyAndValue("observe");
var storeResult = _Client.ExecuteStore(StoreMode.Set, kv.Item1, kv.Item2, ReplicateTo.Two);
StoreAssertPass(storeResult);
}
else
Assert.Ignore("This test requires more than one node in the cluster");
}

/// <summary>
Expand Down Expand Up @@ -197,9 +215,15 @@ public void When_Storing_A_New_Key_Observe_Will_Fail_With_Persistence_More_Than_
[Test]
public void When_Storing_A_New_Key_Observe_Will_Fail_When_Cluster_Has_Too_Few_Nodes_For_Replication()
{
var kv = KeyValueUtils.GenerateKeyAndValue("observe");
var storeResult = _Client.ExecuteStore(StoreMode.Set, kv.Item1, kv.Item2, ReplicateTo.Three);
Assert.That(storeResult.Success, Is.False);
var availableNodesCount = getWorkingNodes().Count();
if (availableNodesCount > 1)
{
var kv = KeyValueUtils.GenerateKeyAndValue("observe");
var storeResult = _Client.ExecuteStore(StoreMode.Set, kv.Item1, kv.Item2, ReplicateTo.Three);
Assert.That(storeResult.Success, Is.False);
}
else
Assert.Ignore("This test requires more than one node in the cluster");
}

/// <summary>
Expand Down Expand Up @@ -318,17 +342,23 @@ public void When_Observing_A_Removed_Key_Operation_Is_Successful_With_Replicatio
[Test]
public void When_Observing_A_Removed_Key_Operation_Is_Successful_With_Multi_Node_Persistence()
{
var key = GetUniqueKey("observe");
var value = GetRandomString();
var availableNodesCount = getWorkingNodes().Count();
if (availableNodesCount > 1)
{
var key = GetUniqueKey("observe");
var value = GetRandomString();

var storeResult = _Client.ExecuteStore(StoreMode.Set, key, PersistTo.One, ReplicateTo.Two);
StoreAssertPass(storeResult);
var storeResult = _Client.ExecuteStore(StoreMode.Set, key, PersistTo.One, ReplicateTo.Two);
StoreAssertPass(storeResult);

var removeResult = _Client.ExecuteRemove(key, PersistTo.Two);
Assert.That(removeResult.Success, Is.True);
var removeResult = _Client.ExecuteRemove(key, PersistTo.Two);
Assert.That(removeResult.Success, Is.True);

var getResult = _Client.ExecuteGet(key);
GetAssertFail(getResult);
var getResult = _Client.ExecuteGet(key);
GetAssertFail(getResult);
}
else
Assert.Ignore("This test requires more than one node in the cluster");
}

[Test]
Expand Down
2 changes: 1 addition & 1 deletion src/Couchbase.Tests/Factories/CouchbaseClientFactory.cs
View file
Expand Up @@ -13,7 +13,7 @@ public static ICouchbaseClient CreateCouchbaseClient()
{
if (_client == null)
{
_client = new CouchbaseClient();
_client = new CouchbaseClient("couchbase");
}

return _client;
Expand Down

0 comments on commit 6d90d82

Please sign in to comment.