summaryrefslogtreecommitdiffstats
path: root/documentapi
diff options
context:
space:
mode:
authorArne H Juul <arnej@yahooinc.com>2021-12-16 09:06:16 +0000
committerArne H Juul <arnej@yahooinc.com>2021-12-16 14:43:44 +0000
commit9a4a247b44beed310a9bb2441ad1feb1610aaf06 (patch)
treea19f82c45eea1f074863344c450a61bcca0ffd6a /documentapi
parenta5cf6509a0838a9d1a80fc08215556285758e07b (diff)
destroy more frames
Diffstat (limited to 'documentapi')
-rwxr-xr-xdocumentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestCase.java12
1 files changed, 12 insertions, 0 deletions
diff --git a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestCase.java b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestCase.java
index 4c41edb4dd3..07456870977 100755
--- a/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestCase.java
+++ b/documentapi/src/test/java/com/yahoo/documentapi/messagebus/protocol/test/PolicyTestCase.java
@@ -150,6 +150,7 @@ public class PolicyTestCase {
setupExternPolicy(frame, slobrok, "foo/bar");
frame.assertSelect(null);
slobrok.stop();
+ frame.destroy();
}
@Test
@@ -367,6 +368,9 @@ public class PolicyTestCase {
assertNotNull(barFrame.getReceptor().getReply(TIMEOUT));
assertNotNull(fooFrame.getReceptor().getReply(TIMEOUT));
+
+ fooFrame.destroy();
+ barFrame.destroy();
}
@Test
@@ -391,6 +395,7 @@ public class PolicyTestCase {
assertNotNull(reply);
assertEquals(DocumentProtocol.REPLY_GETDOCUMENT, reply.getType());
assertEquals(123456L, ((GetDocumentReply)reply).getLastModified());
+ frame.destroy();
}
private String getDocumentRouteSelectorRawConfig() {
@@ -413,6 +418,7 @@ public class PolicyTestCase {
frame.setMessage(createRemove("id:ns:other::1"));
frame.assertSelect(Arrays.asList("other-route"));
+ frame.destroy();
}
@Test
@@ -424,6 +430,7 @@ public class PolicyTestCase {
frame.setMessage(createGet("id:ns:other::1"));
frame.assertSelect(Arrays.asList("other-route"));
+ frame.destroy();
}
private PolicyTestFrame createFrameWithTwoRoutes() {
@@ -543,6 +550,8 @@ public class PolicyTestCase {
assertNotNull(barFrame.getReceptor().getReply(TIMEOUT));
assertNotNull(fooFrame.getReceptor().getReply(TIMEOUT));
+ fooFrame.destroy();
+ barFrame.destroy();
}
@Test
@@ -659,6 +668,7 @@ public class PolicyTestCase {
frame.setHop(new HopSpec("test", "[LoadBalancer:cluster=docproc/cluster.default;session=chain.default]"));
assertSelect(frame, 1, Arrays.asList(frame.getNetwork().getConnectionSpec() + "/chain.default"));
+ frame.destroy();
}
@Test
@@ -727,6 +737,8 @@ public class PolicyTestCase {
assertNotNull(barFrame.getReceptor().getReply(TIMEOUT));
assertNotNull(fooFrame.getReceptor().getReply(TIMEOUT));
+ fooFrame.destroy();
+ barFrame.destroy();
}
/**