001: /*
002: * JBoss, Home of Professional Open Source.
003: * Copyright 2006, Red Hat Middleware LLC, and individual contributors
004: * as indicated by the @author tags. See the copyright.txt file in the
005: * distribution for a full listing of individual contributors.
006: *
007: * This is free software; you can redistribute it and/or modify it
008: * under the terms of the GNU Lesser General Public License as
009: * published by the Free Software Foundation; either version 2.1 of
010: * the License, or (at your option) any later version.
011: *
012: * This software is distributed in the hope that it will be useful,
013: * but WITHOUT ANY WARRANTY; without even the implied warranty of
014: * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
015: * Lesser General Public License for more details.
016: *
017: * You should have received a copy of the GNU Lesser General Public
018: * License along with this software; if not, write to the Free
019: * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
020: * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
021: */
022: package org.jboss.invocation.pooled.interfaces;
023:
024: import java.io.ObjectInputStream;
025: import java.io.ObjectOutputStream;
026:
027: import java.io.ByteArrayInputStream;
028: import java.io.ByteArrayOutputStream;
029: import java.io.IOException;
030: import java.io.ObjectInput;
031: import java.io.ObjectOutput;
032: import java.util.Arrays;
033:
034: /**
035: * A simple replacement for the RMI MarshalledObject that uses the thread
036: * context class loader for resolving classes and proxies. This currently does
037: * not support class annotations and dynamic class loading.
038: *
039: * @author Scott.Stark@jboss.org
040: * @version $Revision: 57209 $
041: */
042: public class PooledMarshalledValue implements java.io.Externalizable {
043: /** Serial Version Identifier. */
044: private static final long serialVersionUID = -1265347772036749711L;
045:
046: /**
047: * The serialized form of the value. If <code>serializedForm</code> is
048: * <code>null</code> then the object marshalled was a <code>null</code>
049: * reference.
050: */
051: private byte[] serializedForm;
052:
053: /**
054: * The RMI MarshalledObject hash of the serializedForm array
055: */
056: private int hashCode;
057:
058: /**
059: * Exposed for externalization.
060: */
061: public PooledMarshalledValue() {
062: super ();
063: }
064:
065: public PooledMarshalledValue(Object obj) throws IOException {
066: ByteArrayOutputStream baos = new ByteArrayOutputStream();
067: ObjectOutputStream mvos = new OptimizedObjectOutputStream(baos);
068: mvos.writeObject(obj);
069: mvos.flush();
070: serializedForm = baos.toByteArray();
071: mvos.close();
072: // Use the java.rmi.MarshalledObject hash code calculation
073: int hash = 0;
074: for (int i = 0; i < serializedForm.length; i++) {
075: hash = 31 * hash + serializedForm[i];
076: }
077:
078: hashCode = hash;
079: }
080:
081: public Object get() throws IOException, ClassNotFoundException {
082: if (serializedForm == null)
083: return null;
084:
085: ByteArrayInputStream bais = new ByteArrayInputStream(
086: serializedForm);
087: ObjectInputStream mvis = new OptimizedObjectInputStream(bais);
088: Object retValue = mvis.readObject();
089: mvis.close();
090: return retValue;
091: }
092:
093: public byte[] toByteArray() {
094: return serializedForm;
095: }
096:
097: public int size() {
098: int size = serializedForm != null ? serializedForm.length : 0;
099: return size;
100: }
101:
102: /**
103: * Return a hash code for the serialized form of the value.
104: *
105: * @return the serialized form value hash.
106: */
107: public int hashCode() {
108: return hashCode;
109: }
110:
111: public boolean equals(Object obj) {
112: if (this == obj)
113: return true;
114:
115: boolean equals = false;
116: if (obj instanceof PooledMarshalledValue) {
117: PooledMarshalledValue mv = (PooledMarshalledValue) obj;
118: if (serializedForm == mv.serializedForm) {
119: equals = true;
120: } else {
121: equals = Arrays.equals(serializedForm,
122: mv.serializedForm);
123: }
124: }
125: return equals;
126: }
127:
128: /**
129: * The object implements the readExternal method to restore its
130: * contents by calling the methods of DataInput for primitive
131: * types and readObject for objects, strings and arrays. The
132: * readExternal method must read the values in the same sequence
133: * and with the same types as were written by writeExternal.
134: *
135: * @param in the stream to read data from in order to restore the object
136: *
137: * @throws IOException if I/O errors occur
138: * @throws ClassNotFoundException If the class for an object being
139: * restored cannot be found.
140: */
141: public void readExternal(ObjectInput in) throws IOException,
142: ClassNotFoundException {
143: int length = in.readInt();
144: serializedForm = null;
145: if (length > 0) {
146: serializedForm = new byte[length];
147: in.readFully(serializedForm);
148: }
149: hashCode = in.readInt();
150: }
151:
152: /**
153: * The object implements the writeExternal method to save its contents
154: * by calling the methods of DataOutput for its primitive values or
155: * calling the writeObject method of ObjectOutput for objects, strings,
156: * and arrays.
157: *
158: * @serialData Overriding methods should use this tag to describe
159: * the data layout of this Externalizable object.
160: * List the sequence of element types and, if possible,
161: * relate the element to a public/protected field and/or
162: * method of this Externalizable class.
163: *
164: * @param out the stream to write the object to
165: *
166: * @throws IOException Includes any I/O exceptions that may occur
167: */
168: public void writeExternal(ObjectOutput out) throws IOException {
169: int length = serializedForm != null ? serializedForm.length : 0;
170: out.writeInt(length);
171: if (length > 0) {
172: out.write(serializedForm);
173: }
174: out.writeInt(hashCode);
175: }
176: }
|