diff options
26 files changed, 82 insertions, 34 deletions
diff --git a/application/src/test/java/com/yahoo/application/container/docprocs/MockDispatchDocproc.java b/application/src/test/java/com/yahoo/application/container/docprocs/MockDispatchDocproc.java index d91522ee5ed..9e8e1a87c0a 100644 --- a/application/src/test/java/com/yahoo/application/container/docprocs/MockDispatchDocproc.java +++ b/application/src/test/java/com/yahoo/application/container/docprocs/MockDispatchDocproc.java @@ -54,7 +54,7 @@ public class MockDispatchDocproc extends DocumentProcessor { return new RequestDispatch() { @Override protected Request newRequest() { - return new MbusRequest(currentContainer, uri, message.setRoute(route)).setServerRequest(false); + return new MbusRequest(currentContainer, uri, message.setRoute(route), false); } }; } diff --git a/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerCluster.java b/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerCluster.java index d05650b10b5..69bcd4b87bb 100755 --- a/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerCluster.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/container/ContainerCluster.java @@ -555,6 +555,7 @@ public abstract class ContainerCluster<CONTAINER extends Container> public void getConfig(ClusterInfoConfig.Builder builder) { builder.clusterId(name); builder.nodeCount(containers.size()); + containers.forEach(c -> builder.nodeIndices(c.index())); for (Service service : getDescendantServices()) { builder.services.add(new ClusterInfoConfig.Services.Builder() diff --git a/config-model/src/test/java/com/yahoo/vespa/model/container/ContainerClusterTest.java b/config-model/src/test/java/com/yahoo/vespa/model/container/ContainerClusterTest.java index 7b5efad9647..6f575ef7ea3 100755 --- a/config-model/src/test/java/com/yahoo/vespa/model/container/ContainerClusterTest.java +++ b/config-model/src/test/java/com/yahoo/vespa/model/container/ContainerClusterTest.java @@ -56,6 +56,7 @@ public class ContainerClusterTest { ClusterInfoConfig config = getClusterInfoConfig(cluster); assertEquals("name", config.clusterId()); assertEquals(2, config.nodeCount()); + assertEquals(List.of(0, 0), config.nodeIndices()); // both containers are created with index 0 assertEquals(2, config.services().size()); Iterator<ClusterInfoConfig.Services> iterator = config.services().iterator(); diff --git a/configdefinitions/src/vespa/cluster-info.def b/configdefinitions/src/vespa/cluster-info.def index f5e94ad61b3..05ab2cd1613 100644 --- a/configdefinitions/src/vespa/cluster-info.def +++ b/configdefinitions/src/vespa/cluster-info.def @@ -5,6 +5,7 @@ namespace=cloud.config # clusterId is same as clustername in model clusterId string nodeCount int +nodeIndices[] int services[].index int default=-1 services[].hostname string default="(nohostname)" diff --git a/container-core/src/main/java/com/yahoo/jdisc/http/HttpRequest.java b/container-core/src/main/java/com/yahoo/jdisc/http/HttpRequest.java index 0b5e9ddde58..8fb711c34ed 100644 --- a/container-core/src/main/java/com/yahoo/jdisc/http/HttpRequest.java +++ b/container-core/src/main/java/com/yahoo/jdisc/http/HttpRequest.java @@ -52,7 +52,7 @@ public class HttpRequest extends Request implements ServletOrJdiscHttpRequest { private final String str; - private Version(String str) { + Version(String str) { this.str = str; } @@ -96,7 +96,7 @@ public class HttpRequest extends Request implements ServletOrJdiscHttpRequest { } else { this.connectedAt = creationTime(TimeUnit.MILLISECONDS); } - } catch (RuntimeException e) { + } catch (Throwable e) { release(); throw e; } @@ -110,7 +110,7 @@ public class HttpRequest extends Request implements ServletOrJdiscHttpRequest { this.remoteAddress = null; this.parameters.putAll(getUriQueryParameters(uri)); this.connectedAt = creationTime(TimeUnit.MILLISECONDS); - } catch (RuntimeException e) { + } catch (Throwable e) { release(); throw e; } diff --git a/container-core/src/main/java/com/yahoo/jdisc/http/filter/DiscFilterRequest.java b/container-core/src/main/java/com/yahoo/jdisc/http/filter/DiscFilterRequest.java index 72068bd2dd5..6ed82319544 100644 --- a/container-core/src/main/java/com/yahoo/jdisc/http/filter/DiscFilterRequest.java +++ b/container-core/src/main/java/com/yahoo/jdisc/http/filter/DiscFilterRequest.java @@ -65,6 +65,7 @@ public abstract class DiscFilterRequest { return parent.getUri(); } + @Deprecated public abstract void setUri(URI uri); public HttpRequest getParentRequest() { @@ -313,6 +314,7 @@ public abstract class DiscFilterRequest { return getUri().getScheme(); } + @Deprecated public void setScheme(String scheme, boolean isSecure) { String uri = getUri().toString(); String arr [] = uri.split("://"); diff --git a/container-core/src/main/java/com/yahoo/jdisc/http/filter/JdiscFilterRequest.java b/container-core/src/main/java/com/yahoo/jdisc/http/filter/JdiscFilterRequest.java index f8d9e6b2642..d61644b65e7 100644 --- a/container-core/src/main/java/com/yahoo/jdisc/http/filter/JdiscFilterRequest.java +++ b/container-core/src/main/java/com/yahoo/jdisc/http/filter/JdiscFilterRequest.java @@ -33,6 +33,7 @@ public class JdiscFilterRequest extends DiscFilterRequest { return parent; } + @Deprecated public void setUri(URI uri) { parent.setUri(uri); } diff --git a/container-core/src/main/java/com/yahoo/jdisc/http/filter/ServletFilterRequest.java b/container-core/src/main/java/com/yahoo/jdisc/http/filter/ServletFilterRequest.java index f06f9e256ff..4cf3cdde650 100644 --- a/container-core/src/main/java/com/yahoo/jdisc/http/filter/ServletFilterRequest.java +++ b/container-core/src/main/java/com/yahoo/jdisc/http/filter/ServletFilterRequest.java @@ -32,6 +32,7 @@ class ServletFilterRequest extends DiscFilterRequest { return parent; } + @Deprecated public void setUri(URI uri) { parent.setUri(uri); } diff --git a/container-core/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java b/container-core/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java index 6b206116de8..0b7e27b9598 100644 --- a/container-core/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java +++ b/container-core/src/main/java/com/yahoo/jdisc/http/server/jetty/HttpRequestDispatch.java @@ -197,6 +197,7 @@ class HttpRequestDispatch { requestContentChannel = requestHandler.handleRequest(jdiscRequest, servletResponseController.responseHandler); } + //TODO If the below method throws requestContentChannel will not be close and there is a reference leak ServletInputStream servletInputStream = jettyRequest.getInputStream(); ServletRequestReader servletRequestReader = new ServletRequestReader(servletInputStream, @@ -204,6 +205,9 @@ class HttpRequestDispatch { jDiscContext.janitor, metricReporter); + //TODO If the below method throws servletRequestReader will not complete and + // requestContentChannel will not be closed and there is a reference leak + // Ditto for the servletInputStream servletInputStream.setReadListener(servletRequestReader); return servletRequestReader; } diff --git a/container-core/src/test/java/com/yahoo/jdisc/http/HttpRequestTestCase.java b/container-core/src/test/java/com/yahoo/jdisc/http/HttpRequestTestCase.java index a3cb31d5ecb..43fc67cfabe 100644 --- a/container-core/src/test/java/com/yahoo/jdisc/http/HttpRequestTestCase.java +++ b/container-core/src/test/java/com/yahoo/jdisc/http/HttpRequestTestCase.java @@ -73,6 +73,7 @@ public class HttpRequestTestCase { } @Test + @SuppressWarnings("deprecation") public void requireThatAccessorsWork() { URI uri = URI.create("http://localhost/path?foo=bar&foo=baz&cox=69"); InetSocketAddress address = new InetSocketAddress("remotehost", 69); diff --git a/container-core/src/test/java/com/yahoo/jdisc/http/filter/DiscFilterRequestTest.java b/container-core/src/test/java/com/yahoo/jdisc/http/filter/DiscFilterRequestTest.java index 1c05a3f3db2..606060bc6b4 100644 --- a/container-core/src/test/java/com/yahoo/jdisc/http/filter/DiscFilterRequestTest.java +++ b/container-core/src/test/java/com/yahoo/jdisc/http/filter/DiscFilterRequestTest.java @@ -263,6 +263,7 @@ public class DiscFilterRequestTest { } @Test + @SuppressWarnings("deprecation") public void testSetScheme() throws Exception { URI uri = URI.create("https://example.yahoo.com:8080/test"); HttpRequest httpReq = newRequest(uri, HttpRequest.Method.GET, HttpRequest.Version.HTTP_1_1); @@ -274,6 +275,7 @@ public class DiscFilterRequestTest { } @Test + @SuppressWarnings("deprecation") public void testGetServerPort() throws Exception { URI uri = URI.create("http://example.yahoo.com/test"); HttpRequest httpReq = newRequest(uri, HttpRequest.Method.GET, HttpRequest.Version.HTTP_1_1); @@ -286,6 +288,7 @@ public class DiscFilterRequestTest { } @Test + @SuppressWarnings("deprecation") public void testIsSecure() throws Exception { URI uri = URI.create("http://example.yahoo.com/test"); HttpRequest httpReq = newRequest(uri, HttpRequest.Method.GET, HttpRequest.Version.HTTP_1_1); diff --git a/container-core/src/test/java/com/yahoo/jdisc/http/filter/ServletFilterRequestTest.java b/container-core/src/test/java/com/yahoo/jdisc/http/filter/ServletFilterRequestTest.java index ed4c9b66068..896f441aa6f 100644 --- a/container-core/src/test/java/com/yahoo/jdisc/http/filter/ServletFilterRequestTest.java +++ b/container-core/src/test/java/com/yahoo/jdisc/http/filter/ServletFilterRequestTest.java @@ -86,6 +86,7 @@ public class ServletFilterRequestTest { } @Test + @SuppressWarnings("deprecation") public void uri_can_be_set() throws Exception { URI newUri = new URI("http", null, host, port + 1, path, paramName + "=" + paramValue, null); filterRequest.setUri(newUri); diff --git a/container-disc/src/main/java/com/yahoo/container/jdisc/SystemInfoProvider.java b/container-disc/src/main/java/com/yahoo/container/jdisc/SystemInfoProvider.java index de9e20c3c6d..b64a085764d 100644 --- a/container-disc/src/main/java/com/yahoo/container/jdisc/SystemInfoProvider.java +++ b/container-disc/src/main/java/com/yahoo/container/jdisc/SystemInfoProvider.java @@ -26,7 +26,7 @@ public class SystemInfoProvider extends AbstractComponent implements Provider<Sy @Inject public SystemInfoProvider(ConfigserverConfig csConfig, QrConfig qrConfig, ClusterInfoConfig ciConfig) { this.instance = new SystemInfo(new Zone(Environment.valueOf(csConfig.environment()), csConfig.region()), - new Cluster(ciConfig.nodeCount()), + new Cluster(ciConfig.nodeCount(), ciConfig.nodeIndices()), new Node(qrConfig.nodeIndex())); } diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java index a0bedd678eb..1adad51a052 100644 --- a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java +++ b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/MbusRequest.java @@ -15,7 +15,10 @@ public class MbusRequest extends Request { private final Message message; public MbusRequest(CurrentContainer current, URI uri, Message msg) { - super(current, uri); + this(current, uri, msg, true); + } + public MbusRequest(CurrentContainer current, URI uri, Message msg, boolean isServerRequest) { + super(current, uri, isServerRequest); this.message = validateMessage(msg); } diff --git a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/test/ClientTestDriver.java b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/test/ClientTestDriver.java index ea0ed7eadc8..34b4d47b0b4 100644 --- a/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/test/ClientTestDriver.java +++ b/container-messagebus/src/main/java/com/yahoo/messagebus/jdisc/test/ClientTestDriver.java @@ -7,7 +7,12 @@ import com.yahoo.jdisc.ResourceReference; import com.yahoo.jdisc.application.ContainerBuilder; import com.yahoo.jdisc.handler.ResponseHandler; import com.yahoo.jdisc.test.TestDriver; -import com.yahoo.messagebus.*; +import com.yahoo.messagebus.Message; +import com.yahoo.messagebus.MessageBusParams; +import com.yahoo.messagebus.Protocol; +import com.yahoo.messagebus.Reply; +import com.yahoo.messagebus.SourceSession; +import com.yahoo.messagebus.SourceSessionParams; import com.yahoo.messagebus.jdisc.MbusClient; import com.yahoo.messagebus.jdisc.MbusRequest; import com.yahoo.messagebus.network.rpc.RPCNetworkParams; diff --git a/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/ClientThreadingTestCase.java b/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/ClientThreadingTestCase.java index 62a9a864781..1ccf0b43bf3 100644 --- a/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/ClientThreadingTestCase.java +++ b/container-messagebus/src/test/java/com/yahoo/messagebus/jdisc/ClientThreadingTestCase.java @@ -98,10 +98,8 @@ public class ClientThreadingTestCase { driver.activateContainer(builder); delegate.start(); } - void send(final Message msg, final ResponseHandler handler) { - final MbusRequest request = new MbusRequest(driver, URI.create("mbus://remote/"), msg); - request.setServerRequest(false); + final MbusRequest request = new MbusRequest(driver, URI.create("mbus://remote/"), msg, false); request.connect(handler).close(null); request.release(); } diff --git a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/ReindexingTriggererTest.java b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/ReindexingTriggererTest.java index 3c22ee3f4c3..b600cd7819d 100644 --- a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/ReindexingTriggererTest.java +++ b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/maintenance/ReindexingTriggererTest.java @@ -43,7 +43,8 @@ public class ReindexingTriggererTest { } now = now.plus(interval); } - assertEquals("Should be in window of opportunity exactly four times each period", 4, triggered); + // Summer/winter time :'( + assertTrue("Should be in window of opportunity three to five times each period", 3 <= triggered && triggered <= 5); } @Test diff --git a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/restapi/ApplicationRequestToDiscFilterRequestWrapper.java b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/restapi/ApplicationRequestToDiscFilterRequestWrapper.java index 7cc00f1ad52..df1590bd2ee 100644 --- a/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/restapi/ApplicationRequestToDiscFilterRequestWrapper.java +++ b/controller-server/src/test/java/com/yahoo/vespa/hosted/controller/restapi/ApplicationRequestToDiscFilterRequestWrapper.java @@ -114,6 +114,7 @@ public class ApplicationRequestToDiscFilterRequestWrapper extends DiscFilterRequ } @Override + @Deprecated public void setUri(URI uri) { throw new UnsupportedOperationException(); } diff --git a/flags/src/main/java/com/yahoo/vespa/flags/Flags.java b/flags/src/main/java/com/yahoo/vespa/flags/Flags.java index 249d193ebf1..f9d56d518ca 100644 --- a/flags/src/main/java/com/yahoo/vespa/flags/Flags.java +++ b/flags/src/main/java/com/yahoo/vespa/flags/Flags.java @@ -44,6 +44,12 @@ public class Flags { private static volatile TreeMap<FlagId, FlagDefinition> flags = new TreeMap<>(); + public static final UnboundBooleanFlag FORCE_DISK_ENCRYPTION = defineFeatureFlag( + "force-disk-encryption", true, + List.of("hakonhall"), "2021-10-01", "2021-11-01", + "Enable new conditions for when to encrypt disk.", + "Takes effect on next host admin tick."); + public static final UnboundDoubleFlag DEFAULT_TERM_WISE_LIMIT = defineDoubleFlag( "default-term-wise-limit", 1.0, List.of("baldersheim"), "2020-12-02", "2022-01-01", diff --git a/hosted-zone-api/abi-spec.json b/hosted-zone-api/abi-spec.json index e3b68d09135..00b776922d4 100644 --- a/hosted-zone-api/abi-spec.json +++ b/hosted-zone-api/abi-spec.json @@ -6,8 +6,9 @@ "public" ], "methods": [ - "public void <init>(int)", - "public int size()" + "public void <init>(int, java.util.List)", + "public int size()", + "public java.util.List indices()" ], "fields": [] }, diff --git a/hosted-zone-api/src/main/java/ai/vespa/cloud/Cluster.java b/hosted-zone-api/src/main/java/ai/vespa/cloud/Cluster.java index 6e064b09d7a..5db68b9d5b3 100644 --- a/hosted-zone-api/src/main/java/ai/vespa/cloud/Cluster.java +++ b/hosted-zone-api/src/main/java/ai/vespa/cloud/Cluster.java @@ -1,5 +1,8 @@ package ai.vespa.cloud; +import java.util.Collections; +import java.util.List; + /** * The properties of a cluster of nodes. * @@ -8,12 +11,19 @@ package ai.vespa.cloud; public class Cluster { private final int size; + private final List<Integer> indices; - public Cluster(int size) { + public Cluster(int size, List<Integer> indices) { this.size = size; + this.indices = Collections.unmodifiableList(indices); } /** Returns the number of nodes in this cluster. */ public int size() { return size; } + /** Returns a list of node indices in this cluster. */ + public List<Integer> indices() { + return indices; + } + } diff --git a/hosted-zone-api/src/test/java/ai/vespa/cloud/SystemInfoTest.java b/hosted-zone-api/src/test/java/ai/vespa/cloud/SystemInfoTest.java index 6bdb38eb735..85e17527110 100644 --- a/hosted-zone-api/src/test/java/ai/vespa/cloud/SystemInfoTest.java +++ b/hosted-zone-api/src/test/java/ai/vespa/cloud/SystemInfoTest.java @@ -3,6 +3,8 @@ package ai.vespa.cloud; import org.junit.Test; +import java.util.List; + import static org.junit.Assert.assertEquals; import static org.junit.Assert.fail; @@ -14,7 +16,7 @@ public class SystemInfoTest { @Test public void testSystemInfo() { Zone zone = new Zone(Environment.dev, "us-west-1"); - Cluster cluster = new Cluster(1); + Cluster cluster = new Cluster(1, List.of()); Node node = new Node(0); SystemInfo info = new SystemInfo(zone, cluster, node); @@ -54,8 +56,10 @@ public class SystemInfoTest { @Test public void testCluster() { int size = 1; - Cluster cluster = new Cluster(size); + var indices = List.of(1); + Cluster cluster = new Cluster(size, indices); assertEquals(size, cluster.size()); + assertEquals(indices, cluster.indices()); } @Test diff --git a/jdisc_core/src/main/java/com/yahoo/jdisc/Request.java b/jdisc_core/src/main/java/com/yahoo/jdisc/Request.java index 895ddb30a6d..e2cde8e806c 100644 --- a/jdisc_core/src/main/java/com/yahoo/jdisc/Request.java +++ b/jdisc_core/src/main/java/com/yahoo/jdisc/Request.java @@ -45,9 +45,9 @@ public class Request extends AbstractResource { private volatile boolean cancel = false; private BindingMatch<RequestHandler> bindingMatch; private TimeoutManager timeoutManager; - private boolean serverRequest; + private boolean serverRequest; // TODO could be final, only used in tests private Long timeout; - private URI uri; + private URI uri; // TODO Could be made final, public enum RequestType { READ, WRITE, MONITORING @@ -79,12 +79,16 @@ public class Request extends AbstractResource { * @param uri The identifier of this request. */ public Request(CurrentContainer current, URI uri) { - container = current.newReference(uri); + this(current, uri, true); + } + + public Request(CurrentContainer current, URI uri, boolean isServerRequest) { parent = null; parentReference = null; - creationTime = container.currentTimeMillis(); - serverRequest = true; + serverRequest = isServerRequest; setUri(uri); + container = current.newReference(uri); + creationTime = container.currentTimeMillis(); } /** @@ -113,11 +117,11 @@ public class Request extends AbstractResource { */ public Request(Request parent, URI uri) { this.parent = parent; - this.parentReference = this.parent.refer(); container = null; creationTime = parent.container().currentTimeMillis(); serverRequest = false; setUri(uri); + parentReference = this.parent.refer(); } /** Returns the {@link Container} for which this Request was created */ @@ -142,6 +146,7 @@ public class Request extends AbstractResource { * @return this, to allow chaining * @see #getUri() */ + @Deprecated public Request setUri(URI uri) { this.uri = uri.normalize(); return this; @@ -166,6 +171,7 @@ public class Request extends AbstractResource { * @return this, to allow chaining * @see #isServerRequest() */ + @Deprecated public Request setServerRequest(boolean serverRequest) { this.serverRequest = serverRequest; return this; diff --git a/jdisc_core/src/test/java/com/yahoo/jdisc/RequestTestCase.java b/jdisc_core/src/test/java/com/yahoo/jdisc/RequestTestCase.java index ab92f5fdcca..e85d34b9982 100644 --- a/jdisc_core/src/test/java/com/yahoo/jdisc/RequestTestCase.java +++ b/jdisc_core/src/test/java/com/yahoo/jdisc/RequestTestCase.java @@ -34,6 +34,7 @@ import static org.junit.Assert.fail; public class RequestTestCase { @Test + @SuppressWarnings("deprecation") public void requireThatAccessorsWork() throws BindingSetNotFoundException { MyTimer timer = new MyTimer(); timer.currentTime = 69; @@ -249,6 +250,7 @@ public class RequestTestCase { assertTrue(driver.close()); } + @SuppressWarnings("deprecation") private static void assertUri(CurrentContainer container, String requestUri, String expectedUri) { Request serverReq = new Request(container, URI.create(requestUri)); assertEquals(expectedUri, serverReq.getUri().toString()); diff --git a/jdisc_core/src/test/java/com/yahoo/jdisc/core/ContainerSnapshotTestCase.java b/jdisc_core/src/test/java/com/yahoo/jdisc/core/ContainerSnapshotTestCase.java index 0ea1040306c..ac2efafbba5 100644 --- a/jdisc_core/src/test/java/com/yahoo/jdisc/core/ContainerSnapshotTestCase.java +++ b/jdisc_core/src/test/java/com/yahoo/jdisc/core/ContainerSnapshotTestCase.java @@ -42,8 +42,7 @@ public class ContainerSnapshotTestCase { assertNotNull(request.getBindingMatch()); request.release(); - request = new Request(driver, URI.create("http://foo/")); - request.setServerRequest(false); + request = new Request(driver, URI.create("http://foo/"), false); assertNull(request.container().resolveHandler(request)); assertNull(request.getBindingMatch()); request.release(); @@ -53,8 +52,7 @@ public class ContainerSnapshotTestCase { assertNull(request.getBindingMatch()); request.release(); - request = new Request(driver, URI.create("http://bar/")); - request.setServerRequest(false); + request = new Request(driver, URI.create("http://bar/"), false); assertNull(request.container().resolveHandler(request)); assertNull(request.getBindingMatch()); request.release(); @@ -74,8 +72,7 @@ public class ContainerSnapshotTestCase { assertNull(request.getBindingMatch()); request.release(); - request = new Request(driver, URI.create("http://foo/")); - request.setServerRequest(false); + request = new Request(driver, URI.create("http://foo/"), false); assertNotNull(request.container().resolveHandler(request)); assertNotNull(request.getBindingMatch()); request.release(); @@ -85,8 +82,7 @@ public class ContainerSnapshotTestCase { assertNull(request.getBindingMatch()); request.release(); - request = new Request(driver, URI.create("http://bar/")); - request.setServerRequest(false); + request = new Request(driver, URI.create("http://bar/"), false); assertNull(request.container().resolveHandler(request)); assertNull(request.getBindingMatch()); request.release(); @@ -100,9 +96,7 @@ public class ContainerSnapshotTestCase { ContainerBuilder builder = driver.newContainerBuilder(); builder.clientBindings().bind("http://host/path", MyRequestHandler.newInstance()); driver.activateContainer(builder); - Request request = new Request(driver, URI.create("http://host/path")); - assertNull(request.container().resolveHandler(request)); - request.setServerRequest(false); + Request request = new Request(driver, URI.create("http://host/path"), false); assertNotNull(request.container().resolveHandler(request)); request.release(); assertTrue(driver.close()); diff --git a/model-integration/src/main/java/ai/vespa/rankingexpression/importer/tensorflow/TensorFlowImporter.java b/model-integration/src/main/java/ai/vespa/rankingexpression/importer/tensorflow/TensorFlowImporter.java index 402c6562cc4..0e307992143 100644 --- a/model-integration/src/main/java/ai/vespa/rankingexpression/importer/tensorflow/TensorFlowImporter.java +++ b/model-integration/src/main/java/ai/vespa/rankingexpression/importer/tensorflow/TensorFlowImporter.java @@ -102,7 +102,8 @@ public class TensorFlowImporter extends ModelImporter { private Pair<Integer, String> convertToOnnx(String savedModel, String output, int opset) throws IOException { ProcessExecuter executer = new ProcessExecuter(); - String job = "vespa-convert-tf2onnx --saved-model " + savedModel + " --output " + output + " --opset " + opset; + String job = "vespa-convert-tf2onnx --saved-model " + savedModel + " --output " + output + " --opset " + opset + + " --use-graph-names"; // for backward compatibility with tf2onnx versions < 1.9.1 return executer.exec(job); } |