Skip to content

Commit

Permalink
Merge pull request #23536 from vespa-engine/bratseth/cleanup-09
Browse files Browse the repository at this point in the history
No functional changes
  • Loading branch information
freva authored Jul 25, 2022
2 parents 8a12e55 + 3a511e5 commit 36695ac
Show file tree
Hide file tree
Showing 4 changed files with 16 additions and 22 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -36,15 +36,14 @@
*/
public class CreatePositionZCurve extends Processor {

private boolean useV8GeoPositions = false;
private final SDDocumentType repo;

public CreatePositionZCurve(Schema schema, DeployLogger deployLogger, RankProfileRegistry rankProfileRegistry, QueryProfiles queryProfiles) {
super(schema, deployLogger, rankProfileRegistry, queryProfiles);
this.repo = schema.getDocument();
}

private boolean useV8GeoPositions = false;

@Override
public void process(boolean validate, boolean documentsOnly, ModelContext.Properties properties) {
this.useV8GeoPositions = properties.featureFlags().useV8GeoPositions();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,7 @@
import com.yahoo.vespa.model.PortAllocBridge;

/**
* Represents the Logserver. There is exactly one logserver in a Vespa
* system.
* Represents the Logserver. There is exactly one logserver in a Vespa system.
*
* @author gjoranv
* @author bjorncs
Expand Down Expand Up @@ -42,9 +41,7 @@ public String getStartupCommand() {
return "exec $ROOT/bin/vespa-logserver-start " + getMyJVMArgs() + " " + getJvmOptions();
}

/**
* @return the jvm args to be used by the logserver.
*/
/** Returns the jvm args to be used by the logserver. */
private String getMyJVMArgs() {
StringBuilder sb = new StringBuilder();
sb.append("--add-opens=java.base/java.io=ALL-UNNAMED");
Expand All @@ -57,9 +54,7 @@ private String getMyJVMArgs() {
return sb.toString();
}

/**
* Returns the desired base port for this service.
*/
/** Returns the desired base port for this service. */
public int getWantedPort() {
return 19080;
}
Expand All @@ -73,9 +68,7 @@ public boolean requiresWantedPort() {
return true; // TODO Support dynamic port allocation for logserver
}

/**
* @return the number of ports needed by the logserver.
*/
/** Returns the number of ports needed by the logserver. */
public int getPortCount() {
return 4;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1844,7 +1844,8 @@ private void toSlime(Cursor response, DeploymentId deploymentId, Deployment depl
response.setString("status", "complete");
else if (stepStatus.readyAt(instance.change()).map(controller.clock().instant()::isBefore).orElse(true))
response.setString("status", "pending");
else response.setString("status", "running");
else
response.setString("status", "running");
});
} else {
var deploymentRun = controller.jobController().last(deploymentId.applicationId(), JobType.deploymentTo(deploymentId.zoneId()));
Expand Down
17 changes: 9 additions & 8 deletions defaults/src/main/java/com/yahoo/vespa/defaults/Defaults.java
Original file line number Diff line number Diff line change
Expand Up @@ -78,8 +78,7 @@ static private int findPort(String varName, int defaultPort) {
try {
return Integer.parseInt(port.get());
} catch (NumberFormatException e) {
throw new IllegalArgumentException("must be an integer, was '" +
port.get() + "'");
throw new IllegalArgumentException("must be an integer, was '" + port.get() + "'");
}
}

Expand All @@ -97,9 +96,10 @@ static private int findWebServicePort(int defaultPort) {
}

/**
* Get the username to own directories, files and processes
* Get the username to own directories, files and processes.
*
* @return the vespa user name
**/
*/
public String vespaUser() { return vespaUser; }


Expand All @@ -108,8 +108,9 @@ static private int findWebServicePort(int defaultPort) {
* Detection of the hostname is now done before starting any Vespa
* programs and provided in the environment variable VESPA_HOSTNAME;
* if that variable isn't set a default of "localhost" is always returned.
*
* @return the vespa host name
**/
*/
public String vespaHostname() { return vespaHost; }

/**
Expand Down Expand Up @@ -159,13 +160,13 @@ public String underVespaHome(String path) {
*/
public int vespaPortBase() { return vespaPortBase; }

/** @return port number used by cloud config server (for its RPC protocol) */
/** Returns port number used by cloud config server (for its RPC protocol) */
public int vespaConfigServerRpcPort() { return vespaPortConfigServerRpc; }

/** @return port number used by cloud config server (REST api on HTTP) */
/** Returns port number used by cloud config server (REST api on HTTP) */
public int vespaConfigServerHttpPort() { return vespaPortConfigServerHttp; }

/** @return port number used by config proxy server (RPC protocol) */
/** Returns port number used by config proxy server (RPC protocol) */
public int vespaConfigProxyRpcPort() { return vespaPortConfigProxyRpc; }

/** Returns the defaults of this runtime environment */
Expand Down

0 comments on commit 36695ac

Please sign in to comment.