summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2021-07-02 15:05:06 +0200
committerHarald Musum <musum@verizonmedia.com>2021-07-02 15:05:06 +0200
commitd95667e7f97fd67fbfa5bccc09222aff139539cc (patch)
tree8c7e7ef40e0df025ba351de397152cc524e8f8ba
parent130e036704c2e46717cffc56a0af3ddcbef932ac (diff)
Remove code for rewriting nodes with / in name
Remove code, not used anymore (was used for config files in zookeeper many years ago)
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/zookeeper/ConfigCurator.java33
1 files changed, 10 insertions, 23 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/zookeeper/ConfigCurator.java b/configserver/src/main/java/com/yahoo/vespa/config/server/zookeeper/ConfigCurator.java
index 5bfa06a29dd..38c97ba9e7a 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/zookeeper/ConfigCurator.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/zookeeper/ConfigCurator.java
@@ -14,14 +14,13 @@ import java.util.logging.Level;
* and knows about how config content is mapped to node names and stored.
* <p>
* Usage details:
- * Config ids are stored as foo#bar#c0 instead of foo/bar/c0, for simplicity.
* Keep the amount of domain-specific logic here to a minimum.
* Data for one application x is stored on this form:
* /config/v2/tenants/x/sessions/y/defconfigs
* /config/v2/tenants/x/sessions/y/userapp
* <p>
* The user application structure is exactly the same as in the user's app dir during deploy.
- * The current live app id (for example y) is stored in the node //config/v2/tenants/x/applications/&lt;application-id&gt;
+ * The current active session for an application is stored in the node /config/v2/tenants/x/applications/&lt;application-id&gt;
* It is updated outside this class, typically in config server when activating config
*
* @author Vegard Havdal
@@ -93,7 +92,7 @@ public class ConfigCurator {
}
}
- /** Returns the data at a path and node. Replaces / by # in node names. */
+ /** Returns the data at a path and node. */
public String getData(String path, String node) {
return getData(createFullPath(path, node));
}
@@ -142,16 +141,16 @@ public class ConfigCurator {
createRecurse(path);
}
- /** Creates a Zookeeper node synchronously. Replaces / by # in node names. */
+ /** Creates a Zookeeper node. */
public void createNode(String path, String node) {
createNode(createFullPath(path, node));
}
private String createFullPath(String path, String node) {
- return path + "/" + toConfigserverName(node);
+ return path + (node.startsWith("/") ? node : "/" + node);
}
- /** Sets data at a given path and name. Replaces / by # in node names. Creates the node if it doesn't exist */
+ /** Sets data at a given path and name. Creates the node if it doesn't exist */
public void putData(String path, String node, String data) {
putData(path, node, Utf8.toBytes(data));
}
@@ -168,7 +167,7 @@ public class ConfigCurator {
}
}
- /** Sets data at a given path and name. Replaces / by # in node names. Creates the node if it doesn't exist */
+ /** Sets data at a given path and name. Creates the node if it doesn't exist */
private void putData(String path, String node, byte[] data) {
putData(createFullPath(path, node), data);
}
@@ -188,17 +187,6 @@ public class ConfigCurator {
}
/**
- * Replaces / with # in the given node.
- *
- * @param node a zookeeper node name
- * @return a config server node name
- */
- private String toConfigserverName(String node) {
- if (node.startsWith("/")) node = node.substring(1);
- return node.replaceAll("/", "#");
- }
-
- /**
* Lists thh children at the given path.
*
* @return the local names of the children at this path, or an empty list (never null) if none.
@@ -240,11 +228,10 @@ public class ConfigCurator {
curator.framework().checkExists().forPath("/dummy");
}
catch (Exception e) {
- log.log(Level.SEVERE, "Unable to connect to ZooKeeper on " + curator.connectionSpec() +
- ". Please verify that VESPA_CONFIGSERVERS points to the correct configserver(s) " +
- "on all config server nodes and are the same config server(s) as in services.xml, " +
- "and that they are started. " +
- "Check the log(s) for config server errors. Aborting.", e);
+ log.log(Level.SEVERE, "Unable to connect to ZooKeeper on " + curator.connectionSpec() + "." +
+ " Please verify that VESPA_CONFIGSERVERS points to the correct config servers" +
+ " on all config server nodes and are the same config servers as in services.xml" +
+ " and that they are running. Check vespa log for config server errors. Aborting.", e);
}
}