zookeeper-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From an...@apache.org
Subject [44/51] [partial] zookeeper git commit: ZOOKEEPER-3032: MAVEN MIGRATION - move java server, client
Date Fri, 05 Oct 2018 12:26:37 GMT
http://git-wip-us.apache.org/repos/asf/zookeeper/blob/faa7cec7/src/java/main/org/apache/zookeeper/Shell.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/Shell.java b/src/java/main/org/apache/zookeeper/Shell.java
deleted file mode 100644
index db322de..0000000
--- a/src/java/main/org/apache/zookeeper/Shell.java
+++ /dev/null
@@ -1,480 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/* This file copied from Hadoop's security branch,
-  * with the following changes:
-  * 1. package changed from org.apache.hadoop.util to
-  *    org.apache.zookeeper.
-  * 2. Usage of Hadoop's Configuration class removed since
-  *    it is not available in Zookeeper: instead, system properties
-  *    are used.
-  * 3. The deprecated getUlimitMemoryCommand() method removed since
-  *    it is not needed.
-  */
-
-
-package org.apache.zookeeper;
-
-import java.io.BufferedReader;
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.util.Map;
-import java.util.Timer;
-import java.util.TimerTask;
-import java.util.concurrent.atomic.AtomicBoolean;
-
-import org.apache.zookeeper.common.Time;
-import org.apache.zookeeper.server.ExitCode;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * A base class for running a Unix command.
- *
- * <code>Shell</code> can be used to run unix commands like <code>du</code> or
- * <code>df</code>. It also offers facilities to gate commands by 
- * time-intervals.
- */
-abstract public class Shell {
-  
-    private static final Logger LOG = LoggerFactory.getLogger(Shell.class);
-  
-  /** a Unix command to get the current user's name */
-  public final static String USER_NAME_COMMAND = "whoami";
-  /** a Unix command to get the current user's groups list */
-  public static String[] getGroupsCommand() {
-    return new String[]{"bash", "-c", "groups"};
-  }
-  /** a Unix command to get a given user's groups list */
-  public static String[] getGroupsForUserCommand(final String user) {
-    //'groups username' command return is non-consistent across different unixes
-    return new String [] {"bash", "-c", "id -Gn " + user};
-  }
-  /** a Unix command to set permission */
-  public static final String SET_PERMISSION_COMMAND = "chmod";
-  /** a Unix command to set owner */
-  public static final String SET_OWNER_COMMAND = "chown";
-  public static final String SET_GROUP_COMMAND = "chgrp";
-  /** Return a Unix command to get permission information. */
-  public static String[] getGET_PERMISSION_COMMAND() {
-    //force /bin/ls, except on windows.
-    return new String[] {(WINDOWS ? "ls" : "/bin/ls"), "-ld"};
-  }
-
-  /**Time after which the executing script would be timedout*/
-  protected long timeOutInterval = 0L;
-  /** If or not script timed out*/
-  private AtomicBoolean timedOut;
-
-  /** a Unix command to get ulimit of a process. */
-  public static final String ULIMIT_COMMAND = "ulimit";
-  
-  /** 
-   * Get the Unix command for setting the maximum virtual memory available
-   * to a given child process. This is only relevant when we are forking a
-   * process from within the Mapper or the Reducer implementations.
-   * Also see Hadoop Pipes and Hadoop Streaming.
-   * 
-   * It also checks to ensure that we are running on a *nix platform else 
-   * (e.g. in Cygwin/Windows) it returns <code>null</code>.
-   * @param memoryLimit virtual memory limit
-   * @return a <code>String[]</code> with the ulimit command arguments or 
-   *         <code>null</code> if we are running on a non *nix platform or
-   *         if the limit is unspecified.
-   */
-  public static String[] getUlimitMemoryCommand(int memoryLimit) {
-    // ulimit isn't supported on Windows
-    if (WINDOWS) {
-      return null;
-    }
-    
-    return new String[] {ULIMIT_COMMAND, "-v", String.valueOf(memoryLimit)};
-  }
-
-  /** Set to true on Windows platforms */
-  public static final boolean WINDOWS /* borrowed from Path.WINDOWS */
-                = System.getProperty("os.name").startsWith("Windows");
-  
-  private long    interval;   // refresh interval in msec
-  private long    lastTime;   // last time the command was performed
-  private Map<String, String> environment; // env for the command execution
-  private File dir;
-  private Process process; // sub process used to execute the command
-  private int exitCode;
-
-  /**If or not script finished executing*/
-  private volatile AtomicBoolean completed;
-  
-  public Shell() {
-    this(0L);
-  }
-  
-  /**
-   * @param interval the minimum duration to wait before re-executing the 
-   *        command.
-   */
-  public Shell( long interval ) {
-    this.interval = interval;
-    this.lastTime = (interval<0) ? 0 : -interval;
-  }
-  
-  /** set the environment for the command 
-   * @param env Mapping of environment variables
-   */
-  protected void setEnvironment(Map<String, String> env) {
-    this.environment = env;
-  }
-
-  /** set the working directory 
-   * @param dir The directory where the command would be executed
-   */
-  protected void setWorkingDirectory(File dir) {
-    this.dir = dir;
-  }
-
-  /** check to see if a command needs to be executed and execute if needed */
-  protected void run() throws IOException {
-    if (lastTime + interval > Time.currentElapsedTime())
-      return;
-    exitCode = ExitCode.EXECUTION_FINISHED.getValue(); // reset for next run
-    runCommand();
-  }
-
-  /** Run a command */
-  private void runCommand() throws IOException { 
-    ProcessBuilder builder = new ProcessBuilder(getExecString());
-    Timer timeOutTimer = null;
-    ShellTimeoutTimerTask timeoutTimerTask = null;
-    timedOut = new AtomicBoolean(false);
-    completed = new AtomicBoolean(false);
-    
-    if (environment != null) {
-      builder.environment().putAll(this.environment);
-    }
-    if (dir != null) {
-      builder.directory(this.dir);
-    }
-    
-    process = builder.start();
-    if (timeOutInterval > 0) {
-      timeOutTimer = new Timer();
-      timeoutTimerTask = new ShellTimeoutTimerTask(
-          this);
-      //One time scheduling.
-      timeOutTimer.schedule(timeoutTimerTask, timeOutInterval);
-    }
-    final BufferedReader errReader = 
-            new BufferedReader(new InputStreamReader(process
-                                                     .getErrorStream()));
-    BufferedReader inReader = 
-            new BufferedReader(new InputStreamReader(process
-                                                     .getInputStream()));
-    final StringBuffer errMsg = new StringBuffer();
-    
-    // read error and input streams as this would free up the buffers
-    // free the error stream buffer
-    Thread errThread = new Thread() {
-      @Override
-      public void run() {
-        try {
-          String line = errReader.readLine();
-          while((line != null) && !isInterrupted()) {
-            errMsg.append(line);
-            errMsg.append(System.getProperty("line.separator"));
-            line = errReader.readLine();
-          }
-        } catch(IOException ioe) {
-          LOG.warn("Error reading the error stream", ioe);
-        }
-      }
-    };
-    try {
-      errThread.start();
-    } catch (IllegalStateException ise) { }
-    try {
-      parseExecResult(inReader); // parse the output
-      // clear the input stream buffer
-      String line = inReader.readLine();
-      while(line != null) { 
-        line = inReader.readLine();
-      }
-      // wait for the process to finish and check the exit code
-      exitCode  = process.waitFor();
-      try {
-        // make sure that the error thread exits
-        errThread.join();
-      } catch (InterruptedException ie) {
-        LOG.warn("Interrupted while reading the error stream", ie);
-      }
-      completed.set(true);
-      //the timeout thread handling
-      //taken care in finally block
-      if (exitCode != ExitCode.EXECUTION_FINISHED.getValue()) {
-        throw new ExitCodeException(exitCode, errMsg.toString());
-      }
-    } catch (InterruptedException ie) {
-      throw new IOException(ie.toString());
-    } finally {
-      if ((timeOutTimer!=null) && !timedOut.get()) {
-        timeOutTimer.cancel();
-      }
-      // close the input stream
-      try {
-        inReader.close();
-      } catch (IOException ioe) {
-        LOG.warn("Error while closing the input stream", ioe);
-      }
-      if (!completed.get()) {
-        errThread.interrupt();
-      }
-      try {
-        errReader.close();
-      } catch (IOException ioe) {
-        LOG.warn("Error while closing the error stream", ioe);
-      }
-      process.destroy();
-      lastTime = Time.currentElapsedTime();
-    }
-  }
-
-  /** return an array containing the command name & its parameters */ 
-  protected abstract String[] getExecString();
-  
-  /** Parse the execution result */
-  protected abstract void parseExecResult(BufferedReader lines)
-  throws IOException;
-
-  /** get the current sub-process executing the given command 
-   * @return process executing the command
-   */
-  public Process getProcess() {
-    return process;
-  }
-
-  /** get the exit code 
-   * @return the exit code of the process
-   */
-  public int getExitCode() {
-    return exitCode;
-  }
-
-  /**
-   * This is an IOException with exit code added.
-   */
-  @SuppressWarnings("serial")
-  public static class ExitCodeException extends IOException {
-    int exitCode;
-    
-    public ExitCodeException(int exitCode, String message) {
-      super(message);
-      this.exitCode = exitCode;
-    }
-    
-    public int getExitCode() {
-      return exitCode;
-    }
-  }
-  
-  /**
-   * A simple shell command executor.
-   * 
-   * <code>ShellCommandExecutor</code>should be used in cases where the output 
-   * of the command needs no explicit parsing and where the command, working 
-   * directory and the environment remains unchanged. The output of the command 
-   * is stored as-is and is expected to be small.
-   */
-  public static class ShellCommandExecutor extends Shell {
-    
-    private String[] command;
-    private StringBuffer output;
-    
-    
-    public ShellCommandExecutor(String[] execString) {
-      this(execString, null);
-    }
-    
-    public ShellCommandExecutor(String[] execString, File dir) {
-      this(execString, dir, null);
-    }
-   
-    public ShellCommandExecutor(String[] execString, File dir, 
-                                 Map<String, String> env) {
-      this(execString, dir, env , 0L);
-    }
-
-    /**
-     * Create a new instance of the ShellCommandExecutor to execute a command.
-     * 
-     * @param execString The command to execute with arguments
-     * @param dir If not-null, specifies the directory which should be set
-     *            as the current working directory for the command.
-     *            If null, the current working directory is not modified.
-     * @param env If not-null, environment of the command will include the
-     *            key-value pairs specified in the map. If null, the current
-     *            environment is not modified.
-     * @param timeout Specifies the time in milliseconds, after which the
-     *                command will be killed and the status marked as timedout.
-     *                If 0, the command will not be timed out. 
-     */
-    public ShellCommandExecutor(String[] execString, File dir, 
-        Map<String, String> env, long timeout) {
-      command = execString.clone();
-      if (dir != null) {
-        setWorkingDirectory(dir);
-      }
-      if (env != null) {
-        setEnvironment(env);
-      }
-      timeOutInterval = timeout;
-    }
-        
-
-    /** Execute the shell command. */
-    public void execute() throws IOException {
-      this.run();    
-    }
-
-    protected String[] getExecString() {
-      return command;
-    }
-
-    protected void parseExecResult(BufferedReader lines) throws IOException {
-      output = new StringBuffer();
-      char[] buf = new char[512];
-      int nRead;
-      while ( (nRead = lines.read(buf, 0, buf.length)) > 0 ) {
-        output.append(buf, 0, nRead);
-      }
-    }
-    
-    /** Get the output of the shell command.*/
-    public String getOutput() {
-      return (output == null) ? "" : output.toString();
-    }
-
-    /**
-     * Returns the commands of this instance.
-     * Arguments with spaces in are presented with quotes round; other
-     * arguments are presented raw
-     *
-     * @return a string representation of the object.
-     */
-    public String toString() {
-      StringBuilder builder = new StringBuilder();
-      String[] args = getExecString();
-      for (String s : args) {
-        if (s.indexOf(' ') >= 0) {
-          builder.append('"').append(s).append('"');
-        } else {
-          builder.append(s);
-        }
-        builder.append(' ');
-      }
-      return builder.toString();
-    }
-  }
-  
-  /**
-   * To check if the passed script to shell command executor timed out or
-   * not.
-   * 
-   * @return if the script timed out.
-   */
-  public boolean isTimedOut() {
-    return timedOut.get();
-  }
-  
-  /**
-   * Set if the command has timed out.
-   * 
-   */
-  private void setTimedOut() {
-    this.timedOut.set(true);
-  }
-  
-  /** 
-   * Static method to execute a shell command. 
-   * Covers most of the simple cases without requiring the user to implement  
-   * the <code>Shell</code> interface.
-   * @param cmd shell command to execute.
-   * @return the output of the executed command.
-   */
-  public static String execCommand(String ... cmd) throws IOException {
-    return execCommand(null, cmd, 0L);
-  }
-  
-  /** 
-   * Static method to execute a shell command. 
-   * Covers most of the simple cases without requiring the user to implement  
-   * the <code>Shell</code> interface.
-   * @param env the map of environment key=value
-   * @param cmd shell command to execute.
-   * @param timeout time in milliseconds after which script should be marked timeout
-   * @return the output of the executed command.o
-   */
-  
-  public static String execCommand(Map<String, String> env, String[] cmd,
-      long timeout) throws IOException {
-    ShellCommandExecutor exec = new ShellCommandExecutor(cmd, null, env, 
-                                                          timeout);
-    exec.execute();
-    return exec.getOutput();
-  }
-
-  /** 
-   * Static method to execute a shell command. 
-   * Covers most of the simple cases without requiring the user to implement  
-   * the <code>Shell</code> interface.
-   * @param env the map of environment key=value
-   * @param cmd shell command to execute.
-   * @return the output of the executed command.
-   */
-  public static String execCommand(Map<String,String> env, String ... cmd) 
-  throws IOException {
-    return execCommand(env, cmd, 0L);
-  }
-  
-  /**
-   * Timer which is used to timeout scripts spawned off by shell.
-   */
-  private static class ShellTimeoutTimerTask extends TimerTask {
-
-    private Shell shell;
-
-    public ShellTimeoutTimerTask(Shell shell) {
-      this.shell = shell;
-    }
-
-    @Override
-    public void run() {
-      Process p = shell.getProcess();
-      try {
-        p.exitValue();
-      } catch (Exception e) {
-        //Process has not terminated.
-        //So check if it has completed 
-        //if not just destroy it.
-        if (p != null && !shell.completed.get()) {
-          shell.setTimedOut();
-          p.destroy();
-        }
-      }
-    }
-  }
-}

http://git-wip-us.apache.org/repos/asf/zookeeper/blob/faa7cec7/src/java/main/org/apache/zookeeper/StatsTrack.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/StatsTrack.java b/src/java/main/org/apache/zookeeper/StatsTrack.java
deleted file mode 100644
index 623c6d4..0000000
--- a/src/java/main/org/apache/zookeeper/StatsTrack.java
+++ /dev/null
@@ -1,101 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.zookeeper;
-
-/**
- * a class that represents the stats associated with quotas
- */
-public class StatsTrack {
-    private int count;
-    private long bytes;
-    private String countStr = "count";
-    private String byteStr = "bytes";
-
-    /**
-     * a default constructor for
-     * stats
-     */
-    public StatsTrack() {
-        this(null);
-    }
-    /**
-     * the stat string should be of the form count=int,bytes=long
-     * if stats is called with null the count and bytes are initialized
-     * to -1.
-     * @param stats the stat string to be intialized with
-     */
-    public StatsTrack(String stats) {
-        if (stats == null) {
-            stats = "count=-1,bytes=-1";
-        }
-        String[] split = stats.split(",");
-        if (split.length != 2) {
-            throw new IllegalArgumentException("invalid string " + stats);
-        }
-        count = Integer.parseInt(split[0].split("=")[1]);
-        bytes = Long.parseLong(split[1].split("=")[1]);
-    }
-
-
-    /**
-     * get the count of nodes allowed as part of quota
-     *
-     * @return the count as part of this string
-     */
-    public int getCount() {
-        return this.count;
-    }
-
-    /**
-     * set the count for this stat tracker.
-     *
-     * @param count
-     *            the count to set with
-     */
-    public void setCount(int count) {
-        this.count = count;
-    }
-
-    /**
-     * get the count of bytes allowed as part of quota
-     *
-     * @return the bytes as part of this string
-     */
-    public long getBytes() {
-        return this.bytes;
-    }
-
-    /**
-     * set teh bytes for this stat tracker.
-     *
-     * @param bytes
-     *            the bytes to set with
-     */
-    public void setBytes(long bytes) {
-        this.bytes = bytes;
-    }
-
-    @Override
-    /*
-     * returns the string that maps to this stat tracking.
-     */
-    public String toString() {
-        return countStr + "=" + count + "," + byteStr + "=" + bytes;
-    }
-}

http://git-wip-us.apache.org/repos/asf/zookeeper/blob/faa7cec7/src/java/main/org/apache/zookeeper/Testable.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/Testable.java b/src/java/main/org/apache/zookeeper/Testable.java
deleted file mode 100644
index b38d2c3..0000000
--- a/src/java/main/org/apache/zookeeper/Testable.java
+++ /dev/null
@@ -1,29 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.zookeeper;
-
-/**
- * Abstraction that exposes various methods useful for testing ZooKeeper
- */
-public interface Testable {
-    /**
-     * Cause the ZooKeeper instance to behave as if the session expired
-     */
-    void injectSessionExpiration();
-}

http://git-wip-us.apache.org/repos/asf/zookeeper/blob/faa7cec7/src/java/main/org/apache/zookeeper/Transaction.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/Transaction.java b/src/java/main/org/apache/zookeeper/Transaction.java
deleted file mode 100644
index d8f0e01..0000000
--- a/src/java/main/org/apache/zookeeper/Transaction.java
+++ /dev/null
@@ -1,70 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.zookeeper;
-
-import org.apache.yetus.audience.InterfaceAudience;
-import org.apache.zookeeper.AsyncCallback.MultiCallback;
-import org.apache.zookeeper.data.ACL;
-import java.util.ArrayList;
-import java.util.List;
-
-/**
- * Provides a builder style interface for doing multiple updates.  This is
- * really just a thin layer on top of Zookeeper.multi().
- *
- * @since 3.4.0
- *
- */
-@InterfaceAudience.Public
-public class Transaction {
-    private ZooKeeper zk;
-    private List<Op> ops = new ArrayList<Op>();
-
-    protected Transaction(ZooKeeper zk) {
-        this.zk = zk;
-    }
-
-    public Transaction create(final String path, byte data[], List<ACL> acl,
-                              CreateMode createMode) {
-        ops.add(Op.create(path, data, acl, createMode.toFlag()));
-        return this;
-    }
-
-    public Transaction delete(final String path, int version) {
-        ops.add(Op.delete(path, version));
-        return this;
-    }
-
-    public Transaction check(String path, int version) {
-        ops.add(Op.check(path, version));
-        return this;
-    }
-
-    public Transaction setData(final String path, byte data[], int version) {
-        ops.add(Op.setData(path, data, version));
-        return this;
-    }
-
-    public List<OpResult> commit() throws InterruptedException, KeeperException {
-        return zk.multi(ops);
-    }
-
-    public void commit(MultiCallback cb, Object ctx) {
-        zk.multi(ops, cb, ctx);
-    }
-}

http://git-wip-us.apache.org/repos/asf/zookeeper/blob/faa7cec7/src/java/main/org/apache/zookeeper/Version.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/Version.java b/src/java/main/org/apache/zookeeper/Version.java
deleted file mode 100644
index 8ac3d9b..0000000
--- a/src/java/main/org/apache/zookeeper/Version.java
+++ /dev/null
@@ -1,92 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.zookeeper;
-
-import org.apache.zookeeper.server.ExitCode;
-
-public class Version implements org.apache.zookeeper.version.Info {
-
-    /*
-     * Since the SVN to Git port this field doesn't return the revision anymore
-     * TODO: remove this method and associated field declaration in VerGen
-     * @see {@link #getHashRevision()}
-     * @return the default value -1
-     */
-    @Deprecated
-    public static int getRevision() {
-        return REVISION;
-    }
-
-    public static String getRevisionHash() {
-        return REVISION_HASH;
-    }
-
-    public static String getBuildDate() {
-        return BUILD_DATE;
-    }
-
-    public static String getVersion() {
-        return MAJOR + "." + MINOR + "." + MICRO
-            + (QUALIFIER == null ? "" : "-" + QUALIFIER);
-    }
-
-    public static String getVersionRevision() {
-        return getVersion() + "-" + getRevisionHash();
-    }
-
-    public static String getFullVersion() {
-        return getVersionRevision() + ", built on " + getBuildDate();
-    }
-
-    public static void printUsage() {
-        System.out
-                .print("Usage:\tjava -cp ... org.apache.zookeeper.Version "
-                        + "[--full | --short | --revision],\n\tPrints --full version "
-                        + "info if no arg specified.");
-        System.exit(ExitCode.UNEXPECTED_ERROR.getValue());
-    }
-
-    /**
-     * Prints the current version, revision and build date to the standard out.
-     * 
-     * @param args
-     *            <ul>
-     *            <li> --short - prints a short version string "1.2.3"
-     *            <li> --revision - prints a short version string with the SVN
-     *            repository revision "1.2.3-94"
-     *            <li> --full - prints the revision and the build date
-     *            </ul>
-     */
-    public static void main(String[] args) {
-        if (args.length > 1) {
-            printUsage();
-        }
-        if (args.length == 0 || (args.length == 1 && args[0].equals("--full"))) {
-            System.out.println(getFullVersion());
-            System.exit(ExitCode.EXECUTION_FINISHED.getValue());
-        }
-        if (args[0].equals("--short"))
-            System.out.println(getVersion());
-        else if (args[0].equals("--revision"))
-            System.out.println(getVersionRevision());
-        else
-            printUsage();
-        System.exit(ExitCode.EXECUTION_FINISHED.getValue());
-    }
-}

http://git-wip-us.apache.org/repos/asf/zookeeper/blob/faa7cec7/src/java/main/org/apache/zookeeper/WatchDeregistration.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/WatchDeregistration.java b/src/java/main/org/apache/zookeeper/WatchDeregistration.java
deleted file mode 100644
index 7c91f1c..0000000
--- a/src/java/main/org/apache/zookeeper/WatchDeregistration.java
+++ /dev/null
@@ -1,70 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.zookeeper;
-
-import java.util.Map;
-import java.util.Set;
-
-import org.apache.zookeeper.Watcher.WatcherType;
-import org.apache.zookeeper.Watcher.Event.EventType;
-import org.apache.zookeeper.ZooKeeper.ZKWatchManager;
-
-/**
- * Handles the special case of removing watches which has registered for a
- * client path
- */
-public class WatchDeregistration {
-
-    private final String clientPath;
-    private final Watcher watcher;
-    private final WatcherType watcherType;
-    private final boolean local;
-    private final ZKWatchManager zkManager;
-
-    public WatchDeregistration(String clientPath, Watcher watcher,
-            WatcherType watcherType, boolean local, ZKWatchManager zkManager) {
-        this.clientPath = clientPath;
-        this.watcher = watcher;
-        this.watcherType = watcherType;
-        this.local = local;
-        this.zkManager = zkManager;
-    }
-
-    /**
-     * Unregistering watcher that was added on path.
-     * 
-     * @param rc
-     *            the result code of the operation that attempted to remove
-     *            watch on the path.
-     */
-    public Map<EventType, Set<Watcher>> unregister(int rc)
-            throws KeeperException {
-        return zkManager.removeWatcher(clientPath, watcher, watcherType, local,
-                rc);
-    }
-
-    /**
-     * Returns client path which has specified for unregistering its watcher
-     * 
-     * @return client path
-     */
-    public String getClientPath() {
-        return clientPath;
-    }
-}

http://git-wip-us.apache.org/repos/asf/zookeeper/blob/faa7cec7/src/java/main/org/apache/zookeeper/WatchedEvent.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/WatchedEvent.java b/src/java/main/org/apache/zookeeper/WatchedEvent.java
deleted file mode 100644
index 851fc6c..0000000
--- a/src/java/main/org/apache/zookeeper/WatchedEvent.java
+++ /dev/null
@@ -1,81 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.zookeeper;
-
-import org.apache.yetus.audience.InterfaceAudience;
-import org.apache.zookeeper.proto.WatcherEvent;
-import org.apache.zookeeper.Watcher.Event.EventType;
-import org.apache.zookeeper.Watcher.Event.KeeperState;
-
-/**
- *  A WatchedEvent represents a change on the ZooKeeper that a Watcher
- *  is able to respond to.  The WatchedEvent includes exactly what happened,
- *  the current state of the ZooKeeper, and the path of the znode that
- *  was involved in the event.
- */
-@InterfaceAudience.Public
-public class WatchedEvent {
-    final private KeeperState keeperState;
-    final private EventType eventType;
-    private String path;
-    
-    /**
-     * Create a WatchedEvent with specified type, state and path
-     */
-    public WatchedEvent(EventType eventType, KeeperState keeperState, String path) {
-        this.keeperState = keeperState;
-        this.eventType = eventType;
-        this.path = path;
-    }
-    
-    /**
-     * Convert a WatcherEvent sent over the wire into a full-fledged WatcherEvent
-     */
-    public WatchedEvent(WatcherEvent eventMessage) {
-        keeperState = KeeperState.fromInt(eventMessage.getState());
-        eventType = EventType.fromInt(eventMessage.getType());
-        path = eventMessage.getPath();
-    }
-    
-    public KeeperState getState() {
-        return keeperState;
-    }
-    
-    public EventType getType() {
-        return eventType;
-    }
-    
-    public String getPath() {
-        return path;
-    }
-
-    @Override
-    public String toString() {
-        return "WatchedEvent state:" + keeperState
-            + " type:" + eventType + " path:" + path;
-    }
-
-    /**
-     *  Convert WatchedEvent to type that can be sent over network
-     */
-    public WatcherEvent getWrapper() {
-        return new WatcherEvent(eventType.getIntValue(), 
-                                keeperState.getIntValue(), 
-                                path);
-    }
-}

http://git-wip-us.apache.org/repos/asf/zookeeper/blob/faa7cec7/src/java/main/org/apache/zookeeper/Watcher.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/Watcher.java b/src/java/main/org/apache/zookeeper/Watcher.java
deleted file mode 100644
index 245978a..0000000
--- a/src/java/main/org/apache/zookeeper/Watcher.java
+++ /dev/null
@@ -1,201 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.zookeeper;
-
-import org.apache.yetus.audience.InterfaceAudience;
-
-/**
- * This interface specifies the public interface an event handler class must
- * implement. A ZooKeeper client will get various events from the ZooKeeper
- * server it connects to. An application using such a client handles these
- * events by registering a callback object with the client. The callback object
- * is expected to be an instance of a class that implements Watcher interface.
- * 
- */
-@InterfaceAudience.Public
-public interface Watcher {
-
-    /**
-     * This interface defines the possible states an Event may represent
-     */
-    @InterfaceAudience.Public
-    public interface Event {
-        /**
-         * Enumeration of states the ZooKeeper may be at the event
-         */
-        @InterfaceAudience.Public
-        public enum KeeperState {
-            /** Unused, this state is never generated by the server */
-            @Deprecated
-            Unknown (-1),
-
-            /** The client is in the disconnected state - it is not connected
-             * to any server in the ensemble. */
-            Disconnected (0),
-
-            /** Unused, this state is never generated by the server */
-            @Deprecated
-            NoSyncConnected (1),
-
-            /** The client is in the connected state - it is connected
-             * to a server in the ensemble (one of the servers specified
-             * in the host connection parameter during ZooKeeper client
-             * creation). */
-            SyncConnected (3),
-
-            /**
-             * Auth failed state
-             */
-            AuthFailed (4),
-
-            /**
-             * The client is connected to a read-only server, that is the
-             * server which is not currently connected to the majority.
-             * The only operations allowed after receiving this state is
-             * read operations.
-             * This state is generated for read-only clients only since
-             * read/write clients aren't allowed to connect to r/o servers.
-             */
-            ConnectedReadOnly (5),
-
-            /**
-              * SaslAuthenticated: used to notify clients that they are SASL-authenticated,
-              * so that they can perform Zookeeper actions with their SASL-authorized permissions.
-              */
-            SaslAuthenticated(6),
-
-            /** The serving cluster has expired this session. The ZooKeeper
-             * client connection (the session) is no longer valid. You must
-             * create a new client connection (instantiate a new ZooKeeper
-             * instance) if you with to access the ensemble. */
-            Expired (-112),
-            
-            /** 
-             * The client has been closed. This state is never generated by
-             * the server, but is generated locally when a client calls
-             * {@link ZooKeeper#close()} or {@link ZooKeeper#close(int)}
-             */
-            Closed (7);
-
-            private final int intValue;     // Integer representation of value
-                                            // for sending over wire
-
-            KeeperState(int intValue) {
-                this.intValue = intValue;
-            }
-
-            public int getIntValue() {
-                return intValue;
-            }
-
-            public static KeeperState fromInt(int intValue) {
-                switch(intValue) {
-                    case   -1: return KeeperState.Unknown;
-                    case    0: return KeeperState.Disconnected;
-                    case    1: return KeeperState.NoSyncConnected;
-                    case    3: return KeeperState.SyncConnected;
-                    case    4: return KeeperState.AuthFailed;
-                    case    5: return KeeperState.ConnectedReadOnly;
-                    case    6: return KeeperState.SaslAuthenticated;
-                    case -112: return KeeperState.Expired;
-                    case   7: return KeeperState.Closed;
-
-                    default:
-                        throw new RuntimeException("Invalid integer value for conversion to KeeperState");
-                }
-            }
-        }
-
-        /**
-         * Enumeration of types of events that may occur on the ZooKeeper
-         */
-        @InterfaceAudience.Public
-        public enum EventType {
-            None (-1),
-            NodeCreated (1),
-            NodeDeleted (2),
-            NodeDataChanged (3),
-            NodeChildrenChanged (4),
-            DataWatchRemoved (5),
-            ChildWatchRemoved (6);
-
-            private final int intValue;     // Integer representation of value
-                                            // for sending over wire
-
-            EventType(int intValue) {
-                this.intValue = intValue;
-            }
-
-            public int getIntValue() {
-                return intValue;
-            }
-
-            public static EventType fromInt(int intValue) {
-                switch(intValue) {
-                    case -1: return EventType.None;
-                    case  1: return EventType.NodeCreated;
-                    case  2: return EventType.NodeDeleted;
-                    case  3: return EventType.NodeDataChanged;
-                    case  4: return EventType.NodeChildrenChanged;
-                    case  5: return EventType.DataWatchRemoved;
-                    case  6: return EventType.ChildWatchRemoved;
-
-                    default:
-                        throw new RuntimeException("Invalid integer value for conversion to EventType");
-                }
-            }           
-        }
-    }
-
-    /**
-     * Enumeration of types of watchers
-     */
-    @InterfaceAudience.Public
-    public enum WatcherType {
-        Children(1), Data(2), Any(3);
-
-        // Integer representation of value
-        private final int intValue;
-
-        private WatcherType(int intValue) {
-            this.intValue = intValue;
-        }
-
-        public int getIntValue() {
-            return intValue;
-        }
-
-        public static WatcherType fromInt(int intValue) {
-            switch (intValue) {
-            case 1:
-                return WatcherType.Children;
-            case 2:
-                return WatcherType.Data;
-            case 3:
-                return WatcherType.Any;
-
-            default:
-                throw new RuntimeException(
-                        "Invalid integer value for conversion to WatcherType");
-            }
-        }
-    }
-
-    abstract public void process(WatchedEvent event);
-}

http://git-wip-us.apache.org/repos/asf/zookeeper/blob/faa7cec7/src/java/main/org/apache/zookeeper/ZKUtil.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/ZKUtil.java b/src/java/main/org/apache/zookeeper/ZKUtil.java
deleted file mode 100644
index a6abf2f..0000000
--- a/src/java/main/org/apache/zookeeper/ZKUtil.java
+++ /dev/null
@@ -1,171 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.zookeeper;
-
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.Deque;
-import java.util.LinkedList;
-import java.util.List;
-
-import org.apache.zookeeper.AsyncCallback.StringCallback;
-import org.apache.zookeeper.AsyncCallback.VoidCallback;
-import org.apache.zookeeper.KeeperException.Code;
-import org.apache.zookeeper.common.PathUtils;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class ZKUtil {
-    private static final Logger LOG = LoggerFactory.getLogger(ZKUtil.class);
-    /**
-     * Recursively delete the node with the given path.
-     * <p>
-     * Important: All versions, of all nodes, under the given node are deleted.
-     * <p>
-     * If there is an error with deleting one of the sub-nodes in the tree,
-     * this operation would abort and would be the responsibility of the app to handle the same.
-     *
-     * See {@link #delete(String, int)} for more details.
-     *
-     * @throws IllegalArgumentException if an invalid path is specified
-     */
-    public static void deleteRecursive(ZooKeeper zk, final String pathRoot)
-        throws InterruptedException, KeeperException
-    {
-        PathUtils.validatePath(pathRoot);
-
-        List<String> tree = listSubTreeBFS(zk, pathRoot);
-        LOG.debug("Deleting " + tree);
-        LOG.debug("Deleting " + tree.size() + " subnodes ");
-        for (int i = tree.size() - 1; i >= 0 ; --i) {
-            //Delete the leaves first and eventually get rid of the root
-            zk.delete(tree.get(i), -1); //Delete all versions of the node with -1.
-        }
-    }
-
-
-    /**
-     * Recursively delete the node with the given path. (async version).
-     *
-     * <p>
-     * Important: All versions, of all nodes, under the given node are deleted.
-     * <p>
-     * If there is an error with deleting one of the sub-nodes in the tree,
-     * this operation would abort and would be the responsibility of the app to handle the same.
-     * <p>
-     * @param zk the zookeeper handle
-     * @param pathRoot the path to be deleted
-     * @param cb call back method
-     * @param ctx the context the callback method is called with
-     * @throws IllegalArgumentException if an invalid path is specified
-     */
-    public static void deleteRecursive(ZooKeeper zk, final String pathRoot, VoidCallback cb,
-        Object ctx)
-        throws InterruptedException, KeeperException
-    {
-        PathUtils.validatePath(pathRoot);
-
-        List<String> tree = listSubTreeBFS(zk, pathRoot);
-        LOG.debug("Deleting " + tree);
-        LOG.debug("Deleting " + tree.size() + " subnodes ");
-        for (int i = tree.size() - 1; i >= 0 ; --i) {
-            //Delete the leaves first and eventually get rid of the root
-            zk.delete(tree.get(i), -1, cb, ctx); //Delete all versions of the node with -1.
-        }
-    }
-
-    /**
-     * BFS Traversal of the system under pathRoot, with the entries in the list, in the
-     * same order as that of the traversal.
-     * <p>
-     * <b>Important:</b> This is <i>not an atomic snapshot</i> of the tree ever, but the
-     *  state as it exists across multiple RPCs from zkClient to the ensemble.
-     * For practical purposes, it is suggested to bring the clients to the ensemble
-     * down (i.e. prevent writes to pathRoot) to 'simulate' a snapshot behavior.
-     *
-     * @param zk the zookeeper handle
-     * @param pathRoot The znode path, for which the entire subtree needs to be listed.
-     * @throws InterruptedException
-     * @throws KeeperException
-     */
-    public static List<String> listSubTreeBFS(ZooKeeper zk, final String pathRoot) throws
-        KeeperException, InterruptedException {
-        Deque<String> queue = new LinkedList<String>();
-        List<String> tree = new ArrayList<String>();
-        queue.add(pathRoot);
-        tree.add(pathRoot);
-        while (true) {
-            String node = queue.pollFirst();
-            if (node == null) {
-                break;
-            }
-            List<String> children = zk.getChildren(node, false);
-            for (final String child : children) {
-                final String childPath = node + "/" + child;
-                queue.add(childPath);
-                tree.add(childPath);
-            }
-        }
-        return tree;
-    }
-
-    /**
-     * Visits the subtree with root as given path and calls the passed callback with each znode
-     * found during the search. It performs a depth-first, pre-order traversal of the tree.
-     * <p>
-     * <b>Important:</b> This is <i>not an atomic snapshot</i> of the tree ever, but the
-     * state as it exists across multiple RPCs from zkClient to the ensemble.
-     * For practical purposes, it is suggested to bring the clients to the ensemble
-     * down (i.e. prevent writes to pathRoot) to 'simulate' a snapshot behavior.
-     */
-    public static void visitSubTreeDFS(ZooKeeper zk, final String path, boolean watch,
-        StringCallback cb) throws KeeperException, InterruptedException {
-        PathUtils.validatePath(path);
-
-        zk.getData(path, watch, null);
-        cb.processResult(Code.OK.intValue(), path, null, path);
-        visitSubTreeDFSHelper(zk, path, watch, cb);
-    }
-
-    @SuppressWarnings("unchecked")
-    private static void visitSubTreeDFSHelper(ZooKeeper zk, final String path,
-        boolean watch, StringCallback cb)
-            throws KeeperException, InterruptedException {
-        // we've already validated, therefore if the path is of length 1 it's the root
-        final boolean isRoot = path.length() == 1;
-        try {
-            List<String> children = zk.getChildren(path, watch, null);
-            Collections.sort(children);
-
-            for (String child : children) {
-                String childPath = (isRoot ? path : path + "/") + child;
-                cb.processResult(Code.OK.intValue(), childPath, null, child);
-            }
-
-            for (String child : children) {
-                String childPath = (isRoot ? path : path + "/") + child;
-                visitSubTreeDFSHelper(zk, childPath, watch, cb);
-            }
-        }
-        catch (KeeperException.NoNodeException e) {
-            // Handle race condition where a node is listed
-            // but gets deleted before it can be queried
-            return; // ignore
-        }
-    }
-}
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/zookeeper/blob/faa7cec7/src/java/main/org/apache/zookeeper/ZooDefs.java
----------------------------------------------------------------------
diff --git a/src/java/main/org/apache/zookeeper/ZooDefs.java b/src/java/main/org/apache/zookeeper/ZooDefs.java
deleted file mode 100644
index f685e32..0000000
--- a/src/java/main/org/apache/zookeeper/ZooDefs.java
+++ /dev/null
@@ -1,141 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.zookeeper;
-
-import java.util.ArrayList;
-import java.util.Collections;
-
-import org.apache.yetus.audience.InterfaceAudience;
-import org.apache.zookeeper.data.ACL;
-import org.apache.zookeeper.data.Id;
-
-@InterfaceAudience.Public
-public class ZooDefs {
-   
-   final public static String CONFIG_NODE = "/zookeeper/config";
-
-   @InterfaceAudience.Public
-    public interface OpCode {
-        public final int notification = 0;
-
-        public final int create = 1;
-
-        public final int delete = 2;
-
-        public final int exists = 3;
-
-        public final int getData = 4;
-
-        public final int setData = 5;
-
-        public final int getACL = 6;
-
-        public final int setACL = 7;
-
-        public final int getChildren = 8;
-
-        public final int sync = 9;
-
-        public final int ping = 11;
-
-        public final int getChildren2 = 12;
-
-        public final int check = 13;
-
-        public final int multi = 14;
-        
-        public final int create2 = 15;
-
-        public final int reconfig = 16;
-
-        public final int checkWatches = 17;
-
-        public final int removeWatches = 18;
-
-        public final int createContainer = 19;
-
-        public final int deleteContainer = 20;
-
-        public final int createTTL = 21;
-
-        public final int auth = 100;
-
-        public final int setWatches = 101;
-
-        public final int sasl = 102;
-
-        public final int createSession = -10;
-
-        public final int closeSession = -11;
-
-        public final int error = -1;
-    }
-
-    @InterfaceAudience.Public
-    public interface Perms {
-        int READ = 1 << 0;
-
-        int WRITE = 1 << 1;
-
-        int CREATE = 1 << 2;
-
-        int DELETE = 1 << 3;
-
-        int ADMIN = 1 << 4;
-
-        int ALL = READ | WRITE | CREATE | DELETE | ADMIN;
-    }
-
-    @InterfaceAudience.Public
-    public interface Ids {
-        /**
-         * This Id represents anyone.
-         */
-        public final Id ANYONE_ID_UNSAFE = new Id("world", "anyone");
-
-        /**
-         * This Id is only usable to set ACLs. It will get substituted with the
-         * Id's the client authenticated with.
-         */
-        public final Id AUTH_IDS = new Id("auth", "");
-
-        /**
-         * This is a completely open ACL .
-         */
-        public final ArrayList<ACL> OPEN_ACL_UNSAFE = new ArrayList<ACL>(
-                Collections.singletonList(new ACL(Perms.ALL, ANYONE_ID_UNSAFE)));
-
-        /**
-         * This ACL gives the creators authentication id's all permissions.
-         */
-        public final ArrayList<ACL> CREATOR_ALL_ACL = new ArrayList<ACL>(
-                Collections.singletonList(new ACL(Perms.ALL, AUTH_IDS)));
-
-        /**
-         * This ACL gives the world the ability to read.
-         */
-        public final ArrayList<ACL> READ_ACL_UNSAFE = new ArrayList<ACL>(
-                Collections
-                        .singletonList(new ACL(Perms.READ, ANYONE_ID_UNSAFE)));
-    }
-
-    final public static String[] opNames = { "notification", "create",
-            "delete", "exists", "getData", "setData", "getACL", "setACL",
-            "getChildren", "getChildren2", "getMaxChildren", "setMaxChildren", "ping", "reconfig", "getConfig" };
-}


Mime
View raw message