Skip to content

Commit

Permalink
Merge pull request naver#31 from jam2in/wooseok/refac-remove-dup-tests
Browse files Browse the repository at this point in the history 
Delete duplicated test codes
  • Loading branch information
Wooseok Son authored Sep 20, 2016
2 parents 4c3d199 + a08de91 commit 0c20d5c
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 243 deletions.
61 changes: 0 additions & 61 deletions src/test/manual/net/spy/memcached/bulkoperation/BopInsertBulkMultipleTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -95,67 +95,6 @@ public void testInsertAndGet() {
}
}

public void testInsertAndGetUsingSingleClient() {
String key = "MyBopKey333";
String value = "MyValue";

int bkeySize = 500;
Map<Long, Object> bkeys = new TreeMap<Long, Object>();
for (int i = 0; i < bkeySize; i++) {
bkeys.put((long) i, value);
}

try {
// REMOVE
mc.asyncBopDelete(key, 0, 4000, ElementFlagFilter.DO_NOT_FILTER, 0,
true);

// SET
Future<Map<Integer, CollectionOperationStatus>> future = mc
.asyncBopPipedInsertBulk(key, bkeys,
new CollectionAttributes());
try {
Map<Integer, CollectionOperationStatus> errorList = future.get(
20000L, TimeUnit.MILLISECONDS);

Assert.assertTrue("Error list is not empty.",
errorList.isEmpty());
} catch (TimeoutException e) {
future.cancel(true);
e.printStackTrace();
}

// GET
int errorCount = 0;
for (Entry<Long, Object> entry : bkeys.entrySet()) {
Future<Map<Long, Element<Object>>> f = mc.asyncBopGet(key,
entry.getKey(), ElementFlagFilter.DO_NOT_FILTER, false,
false);
Map<Long, Element<Object>> map = null;
try {
map = f.get();
} catch (Exception e) {
f.cancel(true);
e.printStackTrace();
}
Object value2 = map.entrySet().iterator().next().getValue()
.getValue();
if (!value.equals(value2)) {
errorCount++;
}
}
Assert.assertEquals("Error count is greater than 0.", 0, errorCount);

// REMOVE
for (Entry<Long, Object> entry : bkeys.entrySet()) {
mc.asyncBopDelete(key, entry.getKey(),
ElementFlagFilter.DO_NOT_FILTER, true).get();
}
} catch (Exception e) {
e.printStackTrace();
Assert.fail();
}
}

public void testErrorCount() {
String key = "MyBopKeyErrorCount";
Expand Down
62 changes: 0 additions & 62 deletions src/test/manual/net/spy/memcached/bulkoperation/BulkSetTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -180,66 +180,4 @@ public void testInsertAndGet() {
Assert.fail();
}
}

public void testInsertAndGetUsingSingleClient() {
String value = "MyValue";

int TEST_COUNT = 64;

try {
// SET null key
try {
mc.asyncSetBulk(null, 60, value);
} catch (Exception e) {
assertEquals("Key list is null.", e.getMessage());
}

for (int keySize = 1; keySize < TEST_COUNT; keySize++) {
// generate key
String[] keys = new String[keySize];
for (int i = 0; i < keys.length; i++) {
keys[i] = "MyKey" + i;
}

// REMOVE
for (String key : keys) {
mc.delete(key);
}

// SET
Future<Map<String, CollectionOperationStatus>> future = mc
.asyncSetBulk(Arrays.asList(keys), 60, value);

Map<String, CollectionOperationStatus> errorList;
try {
errorList = future.get(20000L, TimeUnit.MILLISECONDS);
Assert.assertTrue("Error list is not empty.",
errorList.isEmpty());
} catch (TimeoutException e) {
future.cancel(true);
e.printStackTrace();
}

// GET
int errorCount = 0;
for (String key : keys) {
String v = (String) mc.get(key);
if (!value.equals(v)) {
errorCount++;
}
}

Assert.assertEquals("Error count is greater than 0.", 0,
errorCount);

// REMOVE
for (String key : keys) {
mc.delete(key);
}
}
} catch (Exception e) {
e.printStackTrace();
Assert.fail();
}
}
}
58 changes: 0 additions & 58 deletions src/test/manual/net/spy/memcached/bulkoperation/LopInsertBulkMultipleValueTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -100,64 +100,6 @@ public void testInsertAndGet() {
}
}

public void testInsertAndGetUsingSingleClient() {
String value = "MyValue";

int valueCount = 500;
Object[] valueList = new Object[valueCount];
for (int i = 0; i < valueList.length; i++) {
valueList[i] = "MyValue";
}

try {
// REMOVE
mc.delete(key).get();

// SET
Future<Map<Integer, CollectionOperationStatus>> future = mc
.asyncLopPipedInsertBulk(key, 0, Arrays.asList(valueList),
new CollectionAttributes());
try {
Map<Integer, CollectionOperationStatus> errorList = future.get(
20000L, TimeUnit.MILLISECONDS);
Assert.assertTrue(errorList.isEmpty());
} catch (TimeoutException e) {
future.cancel(true);
e.printStackTrace();
}

// GET
int errorCount = 0;
List<Object> list = null;
Future<List<Object>> f = mc.asyncLopGet(key, 0, valueCount, false,
false);
try {
list = f.get();
} catch (Exception e) {
f.cancel(true);
e.printStackTrace();
}

Assert.assertNotNull("List is null.", list);
Assert.assertTrue("Cached list is empty.", !list.isEmpty());
Assert.assertEquals(valueCount, list.size());

for (Object o : list) {
if (!value.equals(o)) {
errorCount++;
}
}
Assert.assertEquals(valueCount, list.size());
Assert.assertEquals(0, errorCount);

// REMOVE
mc.asyncLopDelete(key, 0, 4000, true).get();
} catch (Exception e) {
e.printStackTrace();
Assert.fail();
}
}

public void testErrorCount() {
int valueCount = 1200;
Object[] valueList = new Object[valueCount];
Expand Down
62 changes: 0 additions & 62 deletions src/test/manual/net/spy/memcached/bulkoperation/SopInsertBulkMultipleValueTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -93,68 +93,6 @@ public void testInsertAndGet() {
}
}

public void testInsertAndGetSingleClient() {
String key = "testInsertAndGetSingleClient";
String prefix = "MyValue";
int valueCount = mc.getMaxPipedItemCount();
Object[] valueList = new Object[valueCount];
for (int i = 0; i < valueList.length; i++) {
valueList[i] = String.format("%s%d", prefix, i);
}

try {
// REMOVE
for (Object v : valueList) {
mc.asyncSopDelete(key, v, true).get();
}

// SET
Future<Map<Integer, CollectionOperationStatus>> future = mc
.asyncSopPipedInsertBulk(key, Arrays.asList(valueList),
new CollectionAttributes());
try {
Map<Integer, CollectionOperationStatus> errorList = future.get(
20000L, TimeUnit.MILLISECONDS);
Assert.assertTrue(errorList.isEmpty());
} catch (TimeoutException e) {
future.cancel(true);
e.printStackTrace();
}

// GET
int errorCount = 0;
Future<Set<Object>> f = mc.asyncSopGet(key, valueCount, false,
false);
Set<Object> list = null;
try {
list = f.get(10000L, TimeUnit.MILLISECONDS);
} catch (Exception e) {
f.cancel(true);
e.printStackTrace();
}

Assert.assertNotNull("Cached list is null.", list);
Assert.assertTrue("Cached list is empty.", !list.isEmpty());

for (Object o : list) {
if (!((String) o).startsWith(prefix)) {
errorCount++;
}
}

Assert.assertEquals(valueCount, list.size());
Assert.assertEquals(0, errorCount);

// REMOVE
for (Object v : valueList) {
mc.asyncSopDelete(key, v, true).get();
}
} catch (Exception e) {
e.printStackTrace();
Assert.fail();
}
}

public void testErrorCount() {
String key = "testErrorCount";
int valueCount = 1200;
Expand Down

0 comments on commit 0c20d5c

Please sign in to comment.