http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/Delta.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/Delta.java b/geode-core/src/main/java/org/apache/geode/Delta.java index de3ef98..a474981 100755 --- a/geode-core/src/main/java/org/apache/geode/Delta.java +++ b/geode-core/src/main/java/org/apache/geode/Delta.java @@ -1,18 +1,16 @@ /* - * 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 + * 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 + * 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. + * 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.geode; @@ -22,12 +20,11 @@ import java.io.IOException; /** - * This interface defines a contract between the application and GemFire that - * allows GemFire to determine whether an application object contains a delta, - * allows GemFire to extract the delta from an application object, and generate - * a new application object by applying a delta to an existing application - * object. The difference in object state is contained in the {@link DataOutput} - * and {@link DataInput} parameters. + * This interface defines a contract between the application and GemFire that allows GemFire to + * determine whether an application object contains a delta, allows GemFire to extract the delta + * from an application object, and generate a new application object by applying a delta to an + * existing application object. The difference in object state is contained in the + * {@link DataOutput} and {@link DataInput} parameters. * * @since GemFire 6.1 * @@ -40,10 +37,9 @@ public interface Delta { boolean hasDelta(); /** - * This method is invoked on an application object at the delta sender, if - * GemFire determines the presence of a delta by calling - * {@link Delta#hasDelta()} on the object. The delta is written to the - * {@link DataOutput} object provided by GemFire. + * This method is invoked on an application object at the delta sender, if GemFire determines the + * presence of a delta by calling {@link Delta#hasDelta()} on the object. The delta is written to + * the {@link DataOutput} object provided by GemFire. * * Any delta state should be reset in this method. * @@ -53,11 +49,10 @@ public interface Delta { /** - * This method is invoked on an existing application object when an update is - * received as a delta. This method throws an {@link InvalidDeltaException} - * when the delta in the {@link DataInput} cannot be applied to the object. - * GemFire automatically handles an {@link InvalidDeltaException} by - * reattempting the update by sending the full application object. + * This method is invoked on an existing application object when an update is received as a delta. + * This method throws an {@link InvalidDeltaException} when the delta in the {@link DataInput} + * cannot be applied to the object. GemFire automatically handles an {@link InvalidDeltaException} + * by reattempting the update by sending the full application object. * * @throws IOException * @throws InvalidDeltaException
http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/DeltaSerializationException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/DeltaSerializationException.java b/geode-core/src/main/java/org/apache/geode/DeltaSerializationException.java index dfe2faf..5e55a6c 100644 --- a/geode-core/src/main/java/org/apache/geode/DeltaSerializationException.java +++ b/geode-core/src/main/java/org/apache/geode/DeltaSerializationException.java @@ -1,18 +1,16 @@ /* - * 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 + * 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 + * 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. + * 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. */ /** * @@ -21,8 +19,8 @@ package org.apache.geode; /** * This exception wraps any checked exception encountered during invocation of - * {@link Delta#fromDelta(java.io.DataInput)} or - * {@link Delta#toDelta(java.io.DataOutput)} in GemFire. + * {@link Delta#fromDelta(java.io.DataInput)} or {@link Delta#toDelta(java.io.DataOutput)} in + * GemFire. * * @since GemFire 6.5 */ @@ -31,8 +29,7 @@ public class DeltaSerializationException extends RuntimeException { /** * Default constructor */ - public DeltaSerializationException() { - } + public DeltaSerializationException() {} /** * @param message http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/ForcedDisconnectException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/ForcedDisconnectException.java b/geode-core/src/main/java/org/apache/geode/ForcedDisconnectException.java index cd3b90f..0ecc750 100755 --- a/geode-core/src/main/java/org/apache/geode/ForcedDisconnectException.java +++ b/geode-core/src/main/java/org/apache/geode/ForcedDisconnectException.java @@ -1,32 +1,29 @@ /* - * 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 + * 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 + * 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. + * 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.geode; /** - * An <code>ForcedDisconnectException</code> is thrown when a GemFire - * application is removed from the distributed system due to membership - * constraints such as network partition detection. + * An <code>ForcedDisconnectException</code> is thrown when a GemFire application is removed from + * the distributed system due to membership constraints such as network partition detection. * * @since GemFire 5.7 */ public class ForcedDisconnectException extends CancelException { -private static final long serialVersionUID = 4977003259880566257L; + private static final long serialVersionUID = 4977003259880566257L; - ////////////////////// Constructors ////////////////////// + ////////////////////// Constructors ////////////////////// /** * Creates a new <code>SystemConnectException</code>. @@ -34,7 +31,7 @@ private static final long serialVersionUID = 4977003259880566257L; public ForcedDisconnectException(String message) { super(message); } - + public ForcedDisconnectException(String message, Throwable cause) { super(message, cause); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/GemFireCacheException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/GemFireCacheException.java b/geode-core/src/main/java/org/apache/geode/GemFireCacheException.java index 7f06d05..ecfb9b0 100644 --- a/geode-core/src/main/java/org/apache/geode/GemFireCacheException.java +++ b/geode-core/src/main/java/org/apache/geode/GemFireCacheException.java @@ -1,33 +1,29 @@ /* - * 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 + * 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 + * 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. + * 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.geode; import org.apache.geode.cache.CacheException; /** - * An <code>GemFireCacheException</code> is used to wrap a - * {@link CacheException}. This is needed in contexts that can - * not throw the cache exception directly because of it being - * a typed exception. + * An <code>GemFireCacheException</code> is used to wrap a {@link CacheException}. This is needed in + * contexts that can not throw the cache exception directly because of it being a typed exception. */ public class GemFireCacheException extends GemFireException { -private static final long serialVersionUID = -2844020916351682908L; + private static final long serialVersionUID = -2844020916351682908L; - ////////////////////// Constructors ////////////////////// + ////////////////////// Constructors ////////////////////// /** * Creates a new <code>GemFireCacheException</code>. @@ -35,16 +31,18 @@ private static final long serialVersionUID = -2844020916351682908L; public GemFireCacheException(String message, CacheException ex) { super(message, ex); } + /** * Creates a new <code>GemFireCacheException</code>. */ public GemFireCacheException(CacheException ex) { super(ex); } + /** * Gets the wrapped {@link CacheException} */ public CacheException getCacheException() { - return (CacheException)getCause(); + return (CacheException) getCause(); } } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/GemFireCheckedException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/GemFireCheckedException.java b/geode-core/src/main/java/org/apache/geode/GemFireCheckedException.java index c1db7d6..8d6f702 100644 --- a/geode-core/src/main/java/org/apache/geode/GemFireCheckedException.java +++ b/geode-core/src/main/java/org/apache/geode/GemFireCheckedException.java @@ -1,35 +1,32 @@ /* - * 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 + * 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 + * 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. + * 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.geode; /** - * This is the abstract superclass of exceptions that are thrown and - * declared. + * This is the abstract superclass of exceptions that are thrown and declared. * <p> - * This class ought to be called <em>GemFireException</em>, but that name - * is reserved for an older class that extends {@link java.lang.RuntimeException}. + * This class ought to be called <em>GemFireException</em>, but that name is reserved for an older + * class that extends {@link java.lang.RuntimeException}. * * @see org.apache.geode.GemFireException * @since GemFire 5.1 */ public abstract class GemFireCheckedException extends Exception { - ////////////////////// Constructors ////////////////////// + ////////////////////// Constructors ////////////////////// /** * Creates a new <code>GemFireException</code> with no detailed message. @@ -39,52 +36,50 @@ public abstract class GemFireCheckedException extends Exception { } /** - * Creates a new <code>GemFireCheckedException</code> with the given detail - * message. + * Creates a new <code>GemFireCheckedException</code> with the given detail message. */ public GemFireCheckedException(String message) { super(message); } /** - * Creates a new <code>GemFireException</code> with the given detail - * message and cause. + * Creates a new <code>GemFireException</code> with the given detail message and cause. */ public GemFireCheckedException(String message, Throwable cause) { super(message); this.initCause(cause); } - + /** - * Creates a new <code>GemFireCheckedException</code> with the given cause and - * no detail message + * Creates a new <code>GemFireCheckedException</code> with the given cause and no detail message */ public GemFireCheckedException(Throwable cause) { super(); this.initCause(cause); } - //////////////////// Instance Methods //////////////////// + //////////////////// Instance Methods //////////////////// /** - * Returns the root cause of this <code>GemFireCheckedException</code> or - * <code>null</code> if the cause is nonexistent or unknown. + * Returns the root cause of this <code>GemFireCheckedException</code> or <code>null</code> if the + * cause is nonexistent or unknown. */ public Throwable getRootCause() { - if ( this.getCause() == null ) return null; - Throwable root = this.getCause(); - while ( root != null ) { -// if ( ! ( root instanceof GemFireCheckedException )) { -// break; -// } -// GemFireCheckedException tmp = (GemFireCheckedException) root; - if ( root.getCause() == null ) { - break; - } else { - root = root.getCause(); - } + if (this.getCause() == null) + return null; + Throwable root = this.getCause(); + while (root != null) { + // if ( ! ( root instanceof GemFireCheckedException )) { + // break; + // } + // GemFireCheckedException tmp = (GemFireCheckedException) root; + if (root.getCause() == null) { + break; + } else { + root = root.getCause(); } - return root; + } + return root; } - + } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/GemFireConfigException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/GemFireConfigException.java b/geode-core/src/main/java/org/apache/geode/GemFireConfigException.java index 7063bce..f7a5ddb 100644 --- a/geode-core/src/main/java/org/apache/geode/GemFireConfigException.java +++ b/geode-core/src/main/java/org/apache/geode/GemFireConfigException.java @@ -1,30 +1,28 @@ /* - * 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 + * 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 + * 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. + * 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.geode; /** - * A <code>GemFireConfigException</code> is used for failures - * while processing a GemFire configuration XML file. + * A <code>GemFireConfigException</code> is used for failures while processing a GemFire + * configuration XML file. */ public class GemFireConfigException extends GemFireException { -private static final long serialVersionUID = 7791789785331120991L; + private static final long serialVersionUID = 7791789785331120991L; - ////////////////////// Constructors ////////////////////// + ////////////////////// Constructors ////////////////////// /** * Creates a new <code>GemFireConfigException</code>. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/GemFireException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/GemFireException.java b/geode-core/src/main/java/org/apache/geode/GemFireException.java index e25dd0c..02bf025 100644 --- a/geode-core/src/main/java/org/apache/geode/GemFireException.java +++ b/geode-core/src/main/java/org/apache/geode/GemFireException.java @@ -1,44 +1,42 @@ /* - * 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 + * 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 + * 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. + * 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.geode; /** - * This is the abstract superclass of exceptions that are thrown to - * indicate incorrect usage of GemFire. + * This is the abstract superclass of exceptions that are thrown to indicate incorrect usage of + * GemFire. * - * Since these exceptions are unchecked, this class really - * <em>ought</em> to be called <code>GemFireRuntimeException</code>; - * however, the current name is retained for compatibility's sake. + * Since these exceptions are unchecked, this class really <em>ought</em> to be called + * <code>GemFireRuntimeException</code>; however, the current name is retained for compatibility's + * sake. * * @see org.apache.geode.GemFireCheckedException * @see org.apache.geode.cache.CacheRuntimeException */ // Implementation note: This class is abstract so that we are forced -// to have more specific exception types. We want to avoid using +// to have more specific exception types. We want to avoid using // GemFireException to describe an arbitrary error condition (think // GsError). public abstract class GemFireException extends RuntimeException { public static final long serialVersionUID = -6972360779789402295L; /** The cause of this <code>GemFireException</code> */ -// private Throwable cause; + // private Throwable cause; - ////////////////////// Constructors ////////////////////// + ////////////////////// Constructors ////////////////////// /** * Creates a new <code>GemFireException</code> with no detailed message. @@ -48,102 +46,99 @@ public abstract class GemFireException extends RuntimeException { } /** - * Creates a new <code>GemFireException</code> with the given detail - * message. + * Creates a new <code>GemFireException</code> with the given detail message. */ public GemFireException(String message) { super(message); } /** - * Creates a new <code>GemFireException</code> with the given detail - * message and cause. + * Creates a new <code>GemFireException</code> with the given detail message and cause. */ public GemFireException(String message, Throwable cause) { super(message, cause); -// this.cause = cause; + // this.cause = cause; } - + /** - * Creates a new <code>GemFireException</code> with the given cause and - * no detail message + * Creates a new <code>GemFireException</code> with the given cause and no detail message */ public GemFireException(Throwable cause) { super(cause); -// this.cause = cause; + // this.cause = cause; } - //////////////////// Instance Methods //////////////////// + //////////////////// Instance Methods //////////////////// /** - * Returns the cause of this <code>GemFireException</code> or - * <code>null</code> if the cause is nonexistent or unknown. + * Returns the cause of this <code>GemFireException</code> or <code>null</code> if the cause is + * nonexistent or unknown. */ -// public Throwable getCause() { -// return this.cause; -// } + // public Throwable getCause() { + // return this.cause; + // } /** - * Returns the root cause of this <code>GemFireException</code> or - * <code>null</code> if the cause is nonexistent or unknown. + * Returns the root cause of this <code>GemFireException</code> or <code>null</code> if the cause + * is nonexistent or unknown. */ public Throwable getRootCause() { - if ( this.getCause() == null ) { + if (this.getCause() == null) { return null; } Throwable root = this.getCause(); - while ( root.getCause() != null ) { + while (root.getCause() != null) { root = root.getCause(); } return root; } - -// public void printStackTrace() { -// super.printStackTrace(); -// if (this.cause != null) { -// System.err.println("Caused by:"); -// this.cause.printStackTrace(); -// } -// } - -// public void printStackTrace(java.io.PrintWriter pw) { -// super.printStackTrace(pw); -// -// if (this.cause != null) { -// pw.println("Caused by:"); -// this.cause.printStackTrace(pw); -// } -// } -// -// public String getMessage() { -// if (this.cause != null) { -// String ourMsg = super.getMessage(); -// if (ourMsg == null || ourMsg.length() == 0) { -// //ourMsg = super.toString(); //causes inifinite recursion -// ourMsg = ""; -// } -// StringBuffer sb = new StringBuffer(ourMsg); -// sb.append(" Caused by: "); -// String causeMsg = this.cause.getMessage(); -// if (causeMsg == null || causeMsg.length() == 0) { -// causeMsg = this.cause.toString(); -// } -// sb.append(causeMsg); -// return sb.toString(); -// } else { -// return super.getMessage(); -// } -// } + + // public void printStackTrace() { + // super.printStackTrace(); + // if (this.cause != null) { + // System.err.println("Caused by:"); + // this.cause.printStackTrace(); + // } + // } + + // public void printStackTrace(java.io.PrintWriter pw) { + // super.printStackTrace(pw); + // + // if (this.cause != null) { + // pw.println("Caused by:"); + // this.cause.printStackTrace(pw); + // } + // } + // + // public String getMessage() { + // if (this.cause != null) { + // String ourMsg = super.getMessage(); + // if (ourMsg == null || ourMsg.length() == 0) { + // //ourMsg = super.toString(); //causes inifinite recursion + // ourMsg = ""; + // } + // StringBuffer sb = new StringBuffer(ourMsg); + // sb.append(" Caused by: "); + // String causeMsg = this.cause.getMessage(); + // if (causeMsg == null || causeMsg.length() == 0) { + // causeMsg = this.cause.toString(); + // } + // sb.append(causeMsg); + // return sb.toString(); + // } else { + // return super.getMessage(); + // } + // } /** * Represent the receiver as well as the cause */ -// public String toString() { -// String result = super.toString(); -// if (cause != null) { -// result = result + ", caused by " + cause.toString(); -// } -// return result; -// } + // public String toString() { + // String result = super.toString(); + // if (cause != null) { + // result = result + ", caused by " + cause.toString(); + // } + // return result; + // } } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/GemFireIOException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/GemFireIOException.java b/geode-core/src/main/java/org/apache/geode/GemFireIOException.java index 583777c..2b5167d 100644 --- a/geode-core/src/main/java/org/apache/geode/GemFireIOException.java +++ b/geode-core/src/main/java/org/apache/geode/GemFireIOException.java @@ -1,32 +1,30 @@ /* - * 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 + * 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 + * 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. + * 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.geode; /** - * A <code>GemFireIOException</code> is thrown when a - * GemFire operation failure is caused by an <code>IOException</code>. + * A <code>GemFireIOException</code> is thrown when a GemFire operation failure is caused by an + * <code>IOException</code>. * * */ public class GemFireIOException extends GemFireException { -private static final long serialVersionUID = 5694009444435264497L; + private static final long serialVersionUID = 5694009444435264497L; - ////////////////////// Constructors ////////////////////// + ////////////////////// Constructors ////////////////////// /** * Creates a new <code>GemFireIOException</code>. @@ -34,6 +32,7 @@ private static final long serialVersionUID = 5694009444435264497L; public GemFireIOException(String message, Throwable cause) { super(message, cause); } + public GemFireIOException(String message) { super(message); } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/GemFireRethrowable.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/GemFireRethrowable.java b/geode-core/src/main/java/org/apache/geode/GemFireRethrowable.java index a6ea18a..724f6da 100644 --- a/geode-core/src/main/java/org/apache/geode/GemFireRethrowable.java +++ b/geode-core/src/main/java/org/apache/geode/GemFireRethrowable.java @@ -1,29 +1,26 @@ /* - * 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 + * 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 + * 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. + * 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.geode; /** - * This error is used by GemFire for internal purposes. - * It does not indicate an error condition. - * For this reason it is named "Rethrowable" instead of the standard "Error". - * It was made an <code>Error</code> to make it easier for user code that typically would - * catch <code>Exception</code> to not accidently catch this exception. - * <p> Note: if user code catches this error (or its subclasses) then it <em>must</em> - * be rethrown. + * This error is used by GemFire for internal purposes. It does not indicate an error condition. For + * this reason it is named "Rethrowable" instead of the standard "Error". It was made an + * <code>Error</code> to make it easier for user code that typically would catch + * <code>Exception</code> to not accidently catch this exception. + * <p> + * Note: if user code catches this error (or its subclasses) then it <em>must</em> be rethrown. * * @since GemFire 5.7 */ @@ -33,11 +30,11 @@ public class GemFireRethrowable extends Error { /** * Create a GemFireRethrowable. */ - public GemFireRethrowable() { - } + public GemFireRethrowable() {} /** * Create a GemFireRethrowable with the specified message. + * * @param message */ public GemFireRethrowable(String message) { http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/IncompatibleSystemException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/IncompatibleSystemException.java b/geode-core/src/main/java/org/apache/geode/IncompatibleSystemException.java index 997feb3..bbb4616 100644 --- a/geode-core/src/main/java/org/apache/geode/IncompatibleSystemException.java +++ b/geode-core/src/main/java/org/apache/geode/IncompatibleSystemException.java @@ -1,33 +1,30 @@ /* - * 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 + * 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 + * 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. + * 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.geode; /** - * An <code>IncompatibleSystemException</code> is thrown when a - * new GemFire process tries to connect to an - * existing distributed system and its version is not the same as - * that of the distributed system. In this case the new member is - * not allowed to connect to the distributed system. - * <p>As of GemFire 5.0 this exception should be named IncompatibleDistributedSystemException + * An <code>IncompatibleSystemException</code> is thrown when a new GemFire process tries to connect + * to an existing distributed system and its version is not the same as that of the distributed + * system. In this case the new member is not allowed to connect to the distributed system. + * <p> + * As of GemFire 5.0 this exception should be named IncompatibleDistributedSystemException */ public class IncompatibleSystemException extends GemFireException { -private static final long serialVersionUID = -6852188720149734350L; + private static final long serialVersionUID = -6852188720149734350L; - ////////////////////// Constructors ////////////////////// + ////////////////////// Constructors ////////////////////// /** * Creates a new <code>IncompatibleSystemException</code>. http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/Instantiator.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/Instantiator.java b/geode-core/src/main/java/org/apache/geode/Instantiator.java index 00eb598..e4da556 100644 --- a/geode-core/src/main/java/org/apache/geode/Instantiator.java +++ b/geode-core/src/main/java/org/apache/geode/Instantiator.java @@ -1,18 +1,16 @@ /* - * 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 + * 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 + * 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. + * 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.geode; @@ -22,19 +20,16 @@ import org.apache.geode.internal.cache.tier.sockets.ClientProxyMembershipID; import org.apache.geode.internal.i18n.LocalizedStrings; /** - * <code>Instantiator</code> allows classes that implement {@link - * DataSerializable} to be registered with the data serialization - * framework. Knowledge of <code>DataSerializable</code> classes - * allows the framework to optimize how instances of those classes are - * data serialized. + * <code>Instantiator</code> allows classes that implement {@link DataSerializable} to be registered + * with the data serialization framework. Knowledge of <code>DataSerializable</code> classes allows + * the framework to optimize how instances of those classes are data serialized. * * <P> * - * Ordinarily, when a <code>DataSerializable</code> object is written - * using {@link DataSerializer#writeObject(Object, java.io.DataOutput)}, a special marker class id - * is written to the stream followed by the class name of the - * <code>DataSerializable</code> object. After the marker class id is - * read by {@link DataSerializer#readObject} it performs the following + * Ordinarily, when a <code>DataSerializable</code> object is written using + * {@link DataSerializer#writeObject(Object, java.io.DataOutput)}, a special marker class id is + * written to the stream followed by the class name of the <code>DataSerializable</code> object. + * After the marker class id is read by {@link DataSerializer#readObject} it performs the following * operations, * * <OL> @@ -45,34 +40,27 @@ import org.apache.geode.internal.i18n.LocalizedStrings; * * <LI>An instance of the class is created using reflection</LI> * - * <LI>{@link DataSerializable#fromData} is invoked on the - * newly-created object</LI> + * <LI>{@link DataSerializable#fromData} is invoked on the newly-created object</LI> * * </OL> * - * However, if a <code>DataSerializable</code> class is {@linkplain - * #register(Instantiator) registered} with the data serialization framework and - * assigned a unique class id, an important optimization can be - * performed that avoid the expense of using reflection to instantiate - * the <code>DataSerializable</code> class. When the object is - * written using {@link DataSerializer#writeObject(Object, java.io.DataOutput)}, the object's - * registered class id is written to the stream. Consequently, when - * the data is read from the stream, the {@link #newInstance} method - * of the appropriate <code>Instantiator</code> instance is invoked to - * create an "empty" instance of the <code>DataSerializable</code> - * instead of using reflection to create the new instance. + * However, if a <code>DataSerializable</code> class is {@linkplain #register(Instantiator) + * registered} with the data serialization framework and assigned a unique class id, an important + * optimization can be performed that avoid the expense of using reflection to instantiate the + * <code>DataSerializable</code> class. When the object is written using + * {@link DataSerializer#writeObject(Object, java.io.DataOutput)}, the object's registered class id + * is written to the stream. Consequently, when the data is read from the stream, the + * {@link #newInstance} method of the appropriate <code>Instantiator</code> instance is invoked to + * create an "empty" instance of the <code>DataSerializable</code> instead of using reflection to + * create the new instance. * * <P> * - * Commonly, a <code>DataSerializable</code> class will register - * itself with the <code>Instantiator</code> in a static initializer - * as shown in the below example code. + * Commonly, a <code>DataSerializable</code> class will register itself with the + * <code>Instantiator</code> in a static initializer as shown in the below example code. * - * <!-- - * The source code for the CompanySerializer class resides in - * tests/com/examples/ds/User.java - * Please keep the below code snippet in sync with that file. - * --> + * <!-- The source code for the CompanySerializer class resides in tests/com/examples/ds/User.java + * Please keep the below code snippet in sync with that file. --> * * <PRE> public class User implements DataSerializable { @@ -113,202 +101,175 @@ public class User implements DataSerializable { } * </PRE> * - * <code>Instantiator</code>s may be distributed to other members of - * the distributed system when they are registered. Consider the - * following scenario in which VM1 and VM2 are members of the same - * distributed system. Both VMs define the sameRegion and VM2's - * region replicates the contents of VM1's using replication. - * VM1 puts an instance of the above <code>User</code> class into the - * region. The act of instantiating <code>User</code> will load the - * <code>User</code> class and invoke its static initializer, thus - * registering the <code>Instantiator</code> with the data - * serialization framework. Because the region is a replicate, the - * <code>User</code> will be data serialized and sent to VM2. - * However, when VM2 attempts to data deserialize the - * <code>User</code>, its <code>Instantiator</code> will not - * necessarily be registered because <code>User</code>'s static - * initializer may not have been invoked yet. As a result, an - * exception would be logged while deserializing the <code>User</code> - * and the replicate would not appear to have the new value. So, in - * order to ensure that the <code>Instantiator</code> is registered in - * VM2, the data serialization framework distributes a message to each - * member when an <code>Instantiator</code> is {@linkplain #register(Instantiator) - * registered}. <p>Note that the framework does not require that an - * <code>Instantiator</code> be {@link java.io.Serializable}, but it - * does require that it provide - * a {@linkplain #Instantiator(Class, int) - * two-argument constructor}. + * <code>Instantiator</code>s may be distributed to other members of the distributed system when + * they are registered. Consider the following scenario in which VM1 and VM2 are members of the same + * distributed system. Both VMs define the sameRegion and VM2's region replicates the contents of + * VM1's using replication. VM1 puts an instance of the above <code>User</code> class into the + * region. The act of instantiating <code>User</code> will load the <code>User</code> class and + * invoke its static initializer, thus registering the <code>Instantiator</code> with the data + * serialization framework. Because the region is a replicate, the <code>User</code> will be data + * serialized and sent to VM2. However, when VM2 attempts to data deserialize the <code>User</code>, + * its <code>Instantiator</code> will not necessarily be registered because <code>User</code>'s + * static initializer may not have been invoked yet. As a result, an exception would be logged while + * deserializing the <code>User</code> and the replicate would not appear to have the new value. So, + * in order to ensure that the <code>Instantiator</code> is registered in VM2, the data + * serialization framework distributes a message to each member when an <code>Instantiator</code> is + * {@linkplain #register(Instantiator) registered}. + * <p> + * Note that the framework does not require that an <code>Instantiator</code> be + * {@link java.io.Serializable}, but it does require that it provide a + * {@linkplain #Instantiator(Class, int) two-argument constructor}. * * @see #register(Instantiator) * @see #newInstance * - * @since GemFire 3.5 */ + * @since GemFire 3.5 + */ public abstract class Instantiator { - /** The class associated with this instantiator. Used mainly for - * debugging purposes and error messages. */ + /** + * The class associated with this instantiator. Used mainly for debugging purposes and error + * messages. + */ private Class<? extends DataSerializable> clazz; /** The id of this <code>Instantiator</code> */ private int id; - + /** The eventId of this <code>Instantiator</code> */ private EventID eventId; - + /** The originator of this <code>Instantiator</code> */ private ClientProxyMembershipID context; - /////////////////////// Static Methods /////////////////////// + /////////////////////// Static Methods /////////////////////// /** - * Registers a <code>DataSerializable</code> class with the data - * serialization framework. This method is usually invoked from the - * static initializer of a class that implements - * <code>DataSerializable</code>. + * Registers a <code>DataSerializable</code> class with the data serialization framework. This + * method is usually invoked from the static initializer of a class that implements + * <code>DataSerializable</code>. * - * @param instantiator - * An <code>Instantiator</code> whose {@link #newInstance} - * method is invoked when an object is data deserialized. + * @param instantiator An <code>Instantiator</code> whose {@link #newInstance} method is invoked + * when an object is data deserialized. * - * @throws IllegalStateException - * If class <code>c</code> is - * already registered with a different class id, or another - * class has already been registered with id - * <code>classId</code> - * @throws NullPointerException - * If <code>instantiator</code> is <code>null</code>. + * @throws IllegalStateException If class <code>c</code> is already registered with a different + * class id, or another class has already been registered with id <code>classId</code> + * @throws NullPointerException If <code>instantiator</code> is <code>null</code>. */ public static synchronized void register(Instantiator instantiator) { InternalInstantiator.register(instantiator, true); } /** - * Registers a <code>DataSerializable</code> class with the data - * serialization framework. This method is usually invoked from the - * static initializer of a class that implements - * <code>DataSerializable</code>. + * Registers a <code>DataSerializable</code> class with the data serialization framework. This + * method is usually invoked from the static initializer of a class that implements + * <code>DataSerializable</code>. * - * @param instantiator - * An <code>Instantiator</code> whose {@link #newInstance} - * method is invoked when an object is data deserialized. + * @param instantiator An <code>Instantiator</code> whose {@link #newInstance} method is invoked + * when an object is data deserialized. * - * @param distribute - * True if the registered <code>Instantiator</code> has to be - * distributed to other members of the distributed system. - * Note that if distribute is set to false it may still be distributed - * in some cases. + * @param distribute True if the registered <code>Instantiator</code> has to be distributed to + * other members of the distributed system. Note that if distribute is set to false it may + * still be distributed in some cases. * - * @throws IllegalArgumentException - * If class <code>c</code> is - * already registered with a different class id, or another - * class has already been registered with id - * <code>classId</code> - * @throws NullPointerException - * If <code>instantiator</code> is <code>null</code>. + * @throws IllegalArgumentException If class <code>c</code> is already registered with a different + * class id, or another class has already been registered with id <code>classId</code> + * @throws NullPointerException If <code>instantiator</code> is <code>null</code>. * @deprecated as of 9.0 use {@link Instantiator#register(Instantiator)} instead */ - public static synchronized void register(Instantiator instantiator, - boolean distribute) { + public static synchronized void register(Instantiator instantiator, boolean distribute) { InternalInstantiator.register(instantiator, distribute); } - //////////////////////// Constructors //////////////////////// + //////////////////////// Constructors //////////////////////// /** - * Creates a new <code>Instantiator</code> that instantiates a given - * class. + * Creates a new <code>Instantiator</code> that instantiates a given class. * - * @param c - * The <code>DataSerializable</code> class to register. This - * class must have a static initializer that registers this - * <code>Instantiator</code>. - * @param classId - * A unique id for class <code>c</code>. The - * <code>classId</code> must not be zero. + * @param c The <code>DataSerializable</code> class to register. This class must have a static + * initializer that registers this <code>Instantiator</code>. + * @param classId A unique id for class <code>c</code>. The <code>classId</code> must not be zero. * This has been an <code>int</code> since dsPhase1. * - * @throws IllegalArgumentException - * If <code>c</code> does not implement - * <code>DataSerializable</code>, <code>classId</code> is - * less than or equal to zero. - * @throws NullPointerException - * If <code>c</code> is <code>null</code> + * @throws IllegalArgumentException If <code>c</code> does not implement + * <code>DataSerializable</code>, <code>classId</code> is less than or equal to zero. + * @throws NullPointerException If <code>c</code> is <code>null</code> */ public Instantiator(Class<? extends DataSerializable> c, int classId) { if (c == null) { - throw new NullPointerException(LocalizedStrings.Instantiator_CANNOT_REGISTER_A_NULL_CLASS.toLocalizedString()); + throw new NullPointerException( + LocalizedStrings.Instantiator_CANNOT_REGISTER_A_NULL_CLASS.toLocalizedString()); } if (!DataSerializable.class.isAssignableFrom(c)) { - throw new IllegalArgumentException(LocalizedStrings.Instantiator_CLASS_0_DOES_NOT_IMPLEMENT_DATASERIALIZABLE.toLocalizedString(c.getName())); + throw new IllegalArgumentException( + LocalizedStrings.Instantiator_CLASS_0_DOES_NOT_IMPLEMENT_DATASERIALIZABLE + .toLocalizedString(c.getName())); } if (classId == 0) { - throw new IllegalArgumentException(LocalizedStrings.Instantiator_CLASS_ID_0_MUST_NOT_BE_0.toLocalizedString(Integer.valueOf(classId))); + throw new IllegalArgumentException(LocalizedStrings.Instantiator_CLASS_ID_0_MUST_NOT_BE_0 + .toLocalizedString(Integer.valueOf(classId))); } this.clazz = c; this.id = classId; } - - ////////////////////// Instance Methods ////////////////////// + + ////////////////////// Instance Methods ////////////////////// /** - * Creates a new "empty" instance of a <Code>DataSerializable</code> - * class whose state will be filled in by invoking its {@link - * DataSerializable#fromData fromData} method. + * Creates a new "empty" instance of a <Code>DataSerializable</code> class whose state will be + * filled in by invoking its {@link DataSerializable#fromData fromData} method. * * @see DataSerializer#readObject */ public abstract DataSerializable newInstance(); /** - * Returns the <code>DataSerializable</code> class that is - * instantiated by this <code>Instantiator</code>. + * Returns the <code>DataSerializable</code> class that is instantiated by this + * <code>Instantiator</code>. */ public final Class<? extends DataSerializable> getInstantiatedClass() { return this.clazz; } /** - * Returns the unique <code>id</code> of this - * <code>Instantiator</code>. + * Returns the unique <code>id</code> of this <code>Instantiator</code>. */ public final int getId() { return this.id; } + /** - * sets the unique <code>eventId</code> of this - * <code>Instantiator</code>. For internal use only. + * sets the unique <code>eventId</code> of this <code>Instantiator</code>. For internal use only. */ - public final void setEventId(Object/*EventID*/ eventId) { - this.eventId = (EventID)eventId; + public final void setEventId(Object/* EventID */ eventId) { + this.eventId = (EventID) eventId; } - + /** - * Returns the unique <code>eventId</code> of this - * <code>Instantiator</code>. For internal use only. + * Returns the unique <code>eventId</code> of this <code>Instantiator</code>. For internal use + * only. */ - public final Object/*EventID*/ getEventId() { + public final Object/* EventID */ getEventId() { return this.eventId; } - + /** - * sets the context of this - * <code>Instantiator</code>. For internal use only. + * sets the context of this <code>Instantiator</code>. For internal use only. */ - public final void setContext(Object/*ClientProxyMembershipID*/ context) { - this.context = (ClientProxyMembershipID)context; + public final void setContext(Object/* ClientProxyMembershipID */ context) { + this.context = (ClientProxyMembershipID) context; } - + /** - * Returns the context of this - * <code>Instantiator</code>. For internal use only. + * Returns the context of this <code>Instantiator</code>. For internal use only. */ - public final Object/*ClientProxyMembershipID*/ getContext() { + public final Object/* ClientProxyMembershipID */ getContext() { return this.context; } - - + + } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/InternalGemFireError.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/InternalGemFireError.java b/geode-core/src/main/java/org/apache/geode/InternalGemFireError.java index 39fe1ea..653cad1 100644 --- a/geode-core/src/main/java/org/apache/geode/InternalGemFireError.java +++ b/geode-core/src/main/java/org/apache/geode/InternalGemFireError.java @@ -1,18 +1,16 @@ /* - * 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 + * 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 + * 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. + * 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. */ /** * @@ -22,8 +20,8 @@ package org.apache.geode; /** * Indicates that serious error has occurred within the GemFire system. * - * This is similar to {@link AssertionError}, but these errors are always - * enabled in a GemFire system. + * This is similar to {@link AssertionError}, but these errors are always enabled in a GemFire + * system. * * @since GemFire 5.5 * @see AssertionError @@ -61,93 +59,86 @@ public class InternalGemFireError extends Error { } /** - * Constructs an AssertionError with its detail message derived - * from the specified object, which is converted to a string as - * defined in <i>The Java Language Specification, Second - * Edition</i>, Section 15.18.1.1. - *<p> - * If the specified object is an instance of <tt>Throwable</tt>, it - * becomes the <i>cause</i> of the newly constructed assertion error. + * Constructs an AssertionError with its detail message derived from the specified object, which + * is converted to a string as defined in <i>The Java Language Specification, Second Edition</i>, + * Section 15.18.1.1. + * <p> + * If the specified object is an instance of <tt>Throwable</tt>, it becomes the <i>cause</i> of + * the newly constructed assertion error. * * @param detailMessage value to be used in constructing detail message - * @see Throwable#getCause() + * @see Throwable#getCause() */ public InternalGemFireError(Object detailMessage) { - this("" + detailMessage); - if (detailMessage instanceof Throwable) - initCause((Throwable) detailMessage); + this("" + detailMessage); + if (detailMessage instanceof Throwable) + initCause((Throwable) detailMessage); } /** - * Constructs an AssertionError with its detail message derived - * from the specified <code>boolean</code>, which is converted to - * a string as defined in <i>The Java Language Specification, - * Second Edition</i>, Section 15.18.1.1. + * Constructs an AssertionError with its detail message derived from the specified + * <code>boolean</code>, which is converted to a string as defined in <i>The Java Language + * Specification, Second Edition</i>, Section 15.18.1.1. * * @param detailMessage value to be used in constructing detail message */ public InternalGemFireError(boolean detailMessage) { - this("" + detailMessage); + this("" + detailMessage); } /** - * Constructs an AssertionError with its detail message derived - * from the specified <code>char</code>, which is converted to a - * string as defined in <i>The Java Language Specification, Second - * Edition</i>, Section 15.18.1.1. + * Constructs an AssertionError with its detail message derived from the specified + * <code>char</code>, which is converted to a string as defined in <i>The Java Language + * Specification, Second Edition</i>, Section 15.18.1.1. * * @param detailMessage value to be used in constructing detail message */ public InternalGemFireError(char detailMessage) { - this("" + detailMessage); + this("" + detailMessage); } /** - * Constructs an AssertionError with its detail message derived - * from the specified <code>int</code>, which is converted to a - * string as defined in <i>The Java Language Specification, Second - * Edition</i>, Section 15.18.1.1. + * Constructs an AssertionError with its detail message derived from the specified + * <code>int</code>, which is converted to a string as defined in <i>The Java Language + * Specification, Second Edition</i>, Section 15.18.1.1. * * @param detailMessage value to be used in constructing detail message */ public InternalGemFireError(int detailMessage) { - this("" + detailMessage); + this("" + detailMessage); } /** - * Constructs an AssertionError with its detail message derived - * from the specified <code>long</code>, which is converted to a - * string as defined in <i>The Java Language Specification, Second - * Edition</i>, Section 15.18.1.1. + * Constructs an AssertionError with its detail message derived from the specified + * <code>long</code>, which is converted to a string as defined in <i>The Java Language + * Specification, Second Edition</i>, Section 15.18.1.1. * * @param detailMessage value to be used in constructing detail message */ public InternalGemFireError(long detailMessage) { - this("" + detailMessage); + this("" + detailMessage); } /** - * Constructs an AssertionError with its detail message derived - * from the specified <code>float</code>, which is converted to a - * string as defined in <i>The Java Language Specification, Second - * Edition</i>, Section 15.18.1.1. + * Constructs an AssertionError with its detail message derived from the specified + * <code>float</code>, which is converted to a string as defined in <i>The Java Language + * Specification, Second Edition</i>, Section 15.18.1.1. * * @param detailMessage value to be used in constructing detail message */ public InternalGemFireError(float detailMessage) { - this("" + detailMessage); + this("" + detailMessage); } /** - * Constructs an AssertionError with its detail message derived - * from the specified <code>double</code>, which is converted to a - * string as defined in <i>The Java Language Specification, Second - * Edition</i>, Section 15.18.1.1. + * Constructs an AssertionError with its detail message derived from the specified + * <code>double</code>, which is converted to a string as defined in <i>The Java Language + * Specification, Second Edition</i>, Section 15.18.1.1. * * @param detailMessage value to be used in constructing detail message */ public InternalGemFireError(double detailMessage) { - this("" + detailMessage); + this("" + detailMessage); } } http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/InternalGemFireException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/InternalGemFireException.java b/geode-core/src/main/java/org/apache/geode/InternalGemFireException.java index a2362f8..6cd067d 100644 --- a/geode-core/src/main/java/org/apache/geode/InternalGemFireException.java +++ b/geode-core/src/main/java/org/apache/geode/InternalGemFireException.java @@ -1,34 +1,30 @@ /* - * 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 + * 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 + * 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. + * 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.geode; /** - * An <code>InternalGemFireException</code> is thrown when - * a low level, internal, operation fails due to no fault of - * the user. The message often contains an operating system - * error code. + * An <code>InternalGemFireException</code> is thrown when a low level, internal, operation fails + * due to no fault of the user. The message often contains an operating system error code. * * */ public class InternalGemFireException extends GemFireException { -private static final long serialVersionUID = -6912843691545178619L; + private static final long serialVersionUID = -6912843691545178619L; - ////////////////////// Constructors ////////////////////// + ////////////////////// Constructors ////////////////////// public InternalGemFireException() { super(); @@ -46,8 +42,7 @@ private static final long serialVersionUID = -6912843691545178619L; } /** - * Creates a new <code>InternalGemFireException</code> that was - * caused by a given exception + * Creates a new <code>InternalGemFireException</code> that was caused by a given exception */ public InternalGemFireException(String message, Throwable thr) { super(message, thr); http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/InvalidDeltaException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/InvalidDeltaException.java b/geode-core/src/main/java/org/apache/geode/InvalidDeltaException.java index 10d2d48..bb75455 100755 --- a/geode-core/src/main/java/org/apache/geode/InvalidDeltaException.java +++ b/geode-core/src/main/java/org/apache/geode/InvalidDeltaException.java @@ -1,42 +1,39 @@ /* - * 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 + * 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 + * 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. + * 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.geode; import java.io.DataInput; /** - * An <code>InvalidDeltaException</code> is thrown when a delta cannot be - * successfully applied by the receiving peer/client. The class implementing - * {@link Delta} may also choose to throw this in - * {@link Delta#fromDelta(DataInput in)}. GemFire, on encountering this - * exception distributes the full application object. + * An <code>InvalidDeltaException</code> is thrown when a delta cannot be successfully applied by + * the receiving peer/client. The class implementing {@link Delta} may also choose to throw this in + * {@link Delta#fromDelta(DataInput in)}. GemFire, on encountering this exception distributes the + * full application object. * * @since GemFire 6.1 */ public class InvalidDeltaException extends GemFireException { /** - * Creates a new <code>InvalidDeltaException</code>. + * Creates a new <code>InvalidDeltaException</code>. */ - public InvalidDeltaException() { - } + public InvalidDeltaException() {} /** - * Creates a new <code>InvalidDeltaException</code>. + * Creates a new <code>InvalidDeltaException</code>. + * * @param msg String explaining the exception */ public InvalidDeltaException(String msg) { @@ -44,7 +41,8 @@ public class InvalidDeltaException extends GemFireException { } /** - * Creates a new <code>InvalidDeltaException</code>. + * Creates a new <code>InvalidDeltaException</code>. + * * @param e Throwable */ public InvalidDeltaException(Throwable e) { @@ -52,7 +50,8 @@ public class InvalidDeltaException extends GemFireException { } /** - * Creates a new <code>InvalidDeltaException</code>. + * Creates a new <code>InvalidDeltaException</code>. + * * @param msg String explaining the exception * @param e Throwable */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/InvalidValueException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/InvalidValueException.java b/geode-core/src/main/java/org/apache/geode/InvalidValueException.java index e323431..455879f 100644 --- a/geode-core/src/main/java/org/apache/geode/InvalidValueException.java +++ b/geode-core/src/main/java/org/apache/geode/InvalidValueException.java @@ -1,31 +1,28 @@ /* - * 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 + * 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 + * 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. + * 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.geode; /** - * An <code>InvalidValueException</code> is thrown when an attempt is - * made to set a configuration attribute to an invalid value is made. - * Values are considered invalid when they are - * not compatible with the attribute's type. + * An <code>InvalidValueException</code> is thrown when an attempt is made to set a configuration + * attribute to an invalid value is made. Values are considered invalid when they are not compatible + * with the attribute's type. */ public class InvalidValueException extends GemFireException { -private static final long serialVersionUID = 6186767885369527709L; + private static final long serialVersionUID = 6186767885369527709L; - ////////////////////// Constructors ////////////////////// + ////////////////////// Constructors ////////////////////// /** * Creates a new <code>InvalidValueException</code>. @@ -33,6 +30,7 @@ private static final long serialVersionUID = 6186767885369527709L; public InvalidValueException(String message) { super(message); } + /** * Creates a new <code>InvalidValueException</code>. */ http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/InvalidVersionException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/InvalidVersionException.java b/geode-core/src/main/java/org/apache/geode/InvalidVersionException.java index 54813b3..40e29bc 100644 --- a/geode-core/src/main/java/org/apache/geode/InvalidVersionException.java +++ b/geode-core/src/main/java/org/apache/geode/InvalidVersionException.java @@ -1,18 +1,16 @@ /* - * 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 + * 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 + * 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. + * 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.geode; http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/8bf39571/geode-core/src/main/java/org/apache/geode/LicenseException.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/org/apache/geode/LicenseException.java b/geode-core/src/main/java/org/apache/geode/LicenseException.java index 96f07af..c98d367 100644 --- a/geode-core/src/main/java/org/apache/geode/LicenseException.java +++ b/geode-core/src/main/java/org/apache/geode/LicenseException.java @@ -1,33 +1,30 @@ /* - * 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 + * 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 + * 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. + * 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.geode; /** - * A <code>LicenseException</code> is thrown when - * the license check fails. + * A <code>LicenseException</code> is thrown when the license check fails. * * @deprecated Licensing is not supported as of 8.0. */ @Deprecated public class LicenseException extends GemFireException { -private static final long serialVersionUID = -1178557127300465801L; + private static final long serialVersionUID = -1178557127300465801L; - ////////////////////// Constructors ////////////////////// + ////////////////////// Constructors ////////////////////// /** * Creates a new <code>LicenseException</code>. @@ -37,16 +34,14 @@ private static final long serialVersionUID = -1178557127300465801L; } /** - * Creates a new <code>LicenseException</code> that was - * caused by a given exception + * Creates a new <code>LicenseException</code> that was caused by a given exception */ public LicenseException(String message, Throwable thr) { super(message, thr); } /** - * Creates a new <code>LicenseException</code> that was - * caused by a given exception + * Creates a new <code>LicenseException</code> that was caused by a given exception */ public LicenseException(Throwable thr) { super(thr.getMessage(), thr);