Skip to content

Commit

Permalink
Add build.yml fix range cache
Browse files Browse the repository at this point in the history
  • Loading branch information
vharseko committed Mar 19, 2024
1 parent ef18313 commit 75eb1ac
Showing 1 changed file with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -67,14 +67,14 @@ protected AsyncLocalConnectorInfoManager getConnectorInfoManager() throws Except
@Test
public void testAddConnectorBundle() throws Exception {
ConnectorFrameworkFactory frameworkFactory = new ConnectorFrameworkFactory();
final ReferenceCountedObject<ConnectorFramework>.Reference connectorFramework =
final ReferenceCountedObject<ConnectorFramework>.Reference connectorFramework2 =
frameworkFactory.acquire();

Promise<ConnectorInfo, RuntimeException> failedPromise;
Promise<ConnectorInfo, RuntimeException> failedRangePromise;

try {
AsyncLocalConnectorInfoManager manager = connectorFramework.get().getLocalManager();
AsyncLocalConnectorInfoManager manager = connectorFramework2.get().getLocalManager();

failedPromise =
manager.findConnectorInfoAsync(new ConnectorKey("NOK", "NOK", "1.5.0.0"));
Expand Down Expand Up @@ -117,7 +117,7 @@ public void handleException(RuntimeException error) {
}
});
} finally {
connectorFramework.release();
connectorFramework2.release();
}
Assert.assertNotNull(failedPromise);
Assert.assertTrue(failedPromise.isDone());
Expand Down Expand Up @@ -146,12 +146,12 @@ public void handleResult(ConnectorInfo result) {

@Test
public void testConnectorBundleRange() throws Exception {
ConnectorFrameworkFactory frameworkFactory = getConnectorFrameworkFactory();//new ConnectorFrameworkFactory();
final ReferenceCountedObject<ConnectorFramework>.Reference connectorFramework =
ConnectorFrameworkFactory frameworkFactory = new ConnectorFrameworkFactory();
final ReferenceCountedObject<ConnectorFramework>.Reference connectorFramework2 =
frameworkFactory.acquire();

try {
AsyncLocalConnectorInfoManager manager = connectorFramework.get().getLocalManager();
AsyncLocalConnectorInfoManager manager = connectorFramework2.get().getLocalManager();

File testBundlesDir = getTestBundlesDir();
URL bundle10 = IOUtil.makeURL(testBundlesDir, "testbundlev10");
Expand Down Expand Up @@ -217,7 +217,7 @@ public void handleException(RuntimeException error) {
});

} finally {
connectorFramework.release();
connectorFramework2.release();
}
}

Expand Down

0 comments on commit 75eb1ac

Please sign in to comment.