Class VolumeDefinitions

core/src/main/java/io/questdb/VolumeDefinitions.java:37–160

import org.jetbrains.annotations.TestOnly;

public class VolumeDefinitions implements Mutable {
    private static final char SEPARATOR = ',';
    private final LowerCaseCharSequenceObjHashMap<String> aliasToVolumeRoot = new LowerCaseCharSequenceObjHashMap<>(4);
    private int hi;
    private int limit;
    private int lo;

    @TestOnly
    @Override
    public void clear() {
        aliasToVolumeRoot.clear();
        lo = hi = limit = 0;
    }

    public void forEach(LowerCaseCharSequenceObjHashMap.CharSequenceObjConsumer<String> action) {
        aliasToVolumeRoot.forEach(action);
    }

    public VolumeDefinitions of(@Nullable CharSequence definitions, @NotNull Path path, @NotNull String root) throws ServerConfigurationException {
        if (definitions != null) {
            // 'any-case-alias' -> 'absolute path to volume' (quotes are optional)
            aliasToVolumeRoot.clear();
            limit = definitions.length();
            lo = 0;
            int separatorCount = 0;
            String alias = null;
            for (int i = 0; i < limit; i++) {
                char c = definitions.charAt(i);
                if (c == '-' && i + 1 < limit && definitions.charAt(i + 1) == '>') { // found arrow
                    if (alias != null) {
                        throw new ServerConfigurationException("invalid syntax, missing volume path at offset " + lo);
                    }
                    alias = Chars.toString(popToken(definitions, i, false));
                    lo = ++i + 1; // move over '>'
                } else if (SEPARATOR == c) {
                    if (alias == null) {
                        throw new ServerConfigurationException("invalid syntax, missing alias at offset " + lo);
                    }
                    addVolumeDefinition(alias, popToken(definitions, i, false), path, root);
                    alias = null;
                    lo = i + 1;
                    separatorCount++;
                }
            }
            finishVolumeDefinitions(alias, popToken(definitions, limit, true), path, root, separatorCount);
        }
        return this;
    }

    public @Nullable CharSequence resolveAlias(@NotNull CharSequence alias) {
        return aliasToVolumeRoot.get(alias);
    }

    public @Nullable CharSequence resolvePath(@NotNull CharSequence path) {
        for (int i = 0, n = aliasToVolumeRoot.keys().size(); i < n; i++) {
            final CharSequence candidateAlias = aliasToVolumeRoot.keys().get(i);
            final CharSequence candidatePath = aliasToVolumeRoot.get(candidateAlias);
            if (Chars.equals(candidatePath, path)) {