activemq-client/src/main/java/org/apache/activemq/openwire/v1/BaseDataStreamMarshaller.java [204:523]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v3/BaseDataStreamMarshaller.java [204:523]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-client/src/main/java/org/apache/activemq/openwire/v9/BaseDataStreamMarshaller.java [203:522]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v2/BaseDataStreamMarshaller.java [204:523]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-client/src/main/java/org/apache/activemq/openwire/v12/BaseDataStreamMarshaller.java [203:522]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v8/BaseDataStreamMarshaller.java [203:522]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-client/src/main/java/org/apache/activemq/openwire/v11/BaseDataStreamMarshaller.java [203:522]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v5/BaseDataStreamMarshaller.java [204:523]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v7/BaseDataStreamMarshaller.java [203:522]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v6/BaseDataStreamMarshaller.java [204:523]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-openwire-legacy/src/main/java/org/apache/activemq/openwire/v4/BaseDataStreamMarshaller.java [204:523]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - activemq-client/src/main/java/org/apache/activemq/openwire/v10/BaseDataStreamMarshaller.java [203:522]: - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - } catch (IOException e) { throw e; } catch (Throwable e) { } } o.setStackTrace(ss); } else { short size = dataIn.readShort(); for (int i = 0; i < size; i++) { tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); tightUnmarshalString(dataIn, bs); dataIn.readInt(); } } o.initCause(tightUnmarsalThrowable(wireFormat, dataIn, bs)); } return o; } else { return null; } } private Throwable createThrowable(String className, String message) { try { Class clazz = Class.forName(className, false, BaseDataStreamMarshaller.class.getClassLoader()); Constructor constructor = clazz.getConstructor(new Class[] {String.class}); return (Throwable)constructor.newInstance(new Object[] {message}); } catch (Throwable e) { return new Throwable(className + ": " + message); } } protected int tightMarshalThrowable1(OpenWireFormat wireFormat, Throwable o, BooleanStream bs) throws IOException { if (o == null) { bs.writeBoolean(false); return 0; } else { int rc = 0; bs.writeBoolean(true); rc += tightMarshalString1(o.getClass().getName(), bs); rc += tightMarshalString1(o.getMessage(), bs); if (wireFormat.isStackTraceEnabled()) { rc += 2; StackTraceElement[] stackTrace = o.getStackTrace(); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; rc += tightMarshalString1(element.getClassName(), bs); rc += tightMarshalString1(element.getMethodName(), bs); rc += tightMarshalString1(element.getFileName(), bs); rc += 4; } rc += tightMarshalThrowable1(wireFormat, o.getCause(), bs); } return rc; } } protected void tightMarshalThrowable2(OpenWireFormat wireFormat, Throwable o, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { tightMarshalString2(o.getClass().getName(), dataOut, bs); tightMarshalString2(o.getMessage(), dataOut, bs); if (wireFormat.isStackTraceEnabled()) { StackTraceElement[] stackTrace = o.getStackTrace(); dataOut.writeShort(stackTrace.length); for (int i = 0; i < stackTrace.length; i++) { StackTraceElement element = stackTrace[i]; tightMarshalString2(element.getClassName(), dataOut, bs); tightMarshalString2(element.getMethodName(), dataOut, bs); tightMarshalString2(element.getFileName(), dataOut, bs); dataOut.writeInt(element.getLineNumber()); } tightMarshalThrowable2(wireFormat, o.getCause(), dataOut, bs); } } } @SuppressWarnings("deprecation") protected String tightUnmarshalString(DataInput dataIn, BooleanStream bs) throws IOException { if (bs.readBoolean()) { if (bs.readBoolean()) { int size = dataIn.readShort(); byte data[] = new byte[size]; dataIn.readFully(data); // Yes deprecated, but we know what we are doing. // This allows us to create a String from a ASCII byte array. (no UTF-8 decoding) return new String(data, 0); } else { return dataIn.readUTF(); } } else { return null; } } protected int tightMarshalString1(String value, BooleanStream bs) throws IOException { bs.writeBoolean(value != null); if (value != null) { int strlen = value.length(); int utflen = 0; char[] charr = new char[strlen]; int c = 0; boolean isOnlyAscii = true; value.getChars(0, strlen, charr, 0); for (int i = 0; i < strlen; i++) { c = charr[i]; if ((c >= 0x0001) && (c <= 0x007F)) { utflen++; } else if (c > 0x07FF) { utflen += 3; isOnlyAscii = false; } else { isOnlyAscii = false; utflen += 2; } } if (utflen >= Short.MAX_VALUE) { throw new IOException("Encountered a String value that is too long to encode."); } bs.writeBoolean(isOnlyAscii); return utflen + 2; } else { return 0; } } protected void tightMarshalString2(String value, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { // If we verified it only holds ascii values if (bs.readBoolean()) { dataOut.writeShort(value.length()); dataOut.writeBytes(value); } else { dataOut.writeUTF(value); } } } protected int tightMarshalObjectArray1(OpenWireFormat wireFormat, DataStructure[] objects, BooleanStream bs) throws IOException { if (objects != null) { int rc = 0; bs.writeBoolean(true); rc += 2; for (int i = 0; i < objects.length; i++) { rc += tightMarshalNestedObject1(wireFormat, objects[i], bs); } return rc; } else { bs.writeBoolean(false); return 0; } } protected void tightMarshalObjectArray2(OpenWireFormat wireFormat, DataStructure[] objects, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeShort(objects.length); for (int i = 0; i < objects.length; i++) { tightMarshalNestedObject2(wireFormat, objects[i], dataOut, bs); } } } protected int tightMarshalConstByteArray1(byte[] data, BooleanStream bs, int i) throws IOException { return i; } protected void tightMarshalConstByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs, int i) throws IOException { dataOut.write(data, 0, i); } protected byte[] tightUnmarshalConstByteArray(DataInput dataIn, BooleanStream bs, int i) throws IOException { byte data[] = new byte[i]; dataIn.readFully(data); return data; } protected int tightMarshalByteArray1(byte[] data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.length + 4; } else { return 0; } } protected void tightMarshalByteArray2(byte[] data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.length); dataOut.write(data); } } protected byte[] tightUnmarshalByteArray(DataInput dataIn, BooleanStream bs) throws IOException { byte rc[] = null; if (bs.readBoolean()) { int size = dataIn.readInt(); rc = new byte[size]; dataIn.readFully(rc); } return rc; } protected int tightMarshalByteSequence1(ByteSequence data, BooleanStream bs) throws IOException { bs.writeBoolean(data != null); if (data != null) { return data.getLength() + 4; } else { return 0; } } protected void tightMarshalByteSequence2(ByteSequence data, DataOutput dataOut, BooleanStream bs) throws IOException { if (bs.readBoolean()) { dataOut.writeInt(data.getLength()); dataOut.write(data.getData(), data.getOffset(), data.getLength()); } } protected ByteSequence tightUnmarshalByteSequence(DataInput dataIn, BooleanStream bs) throws IOException { ByteSequence rc = null; if (bs.readBoolean()) { int size = dataIn.readInt(); byte[] t = new byte[size]; dataIn.readFully(t); return new ByteSequence(t, 0, size); } return rc; } // // The loose marshaling logic // public void looseMarshal(OpenWireFormat wireFormat, Object o, DataOutput dataOut) throws IOException { } public void looseUnmarshal(OpenWireFormat wireFormat, Object o, DataInput dataIn) throws IOException { } public void looseMarshalLong(OpenWireFormat wireFormat, long o, DataOutput dataOut) throws IOException { dataOut.writeLong(o); } public long looseUnmarshalLong(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return dataIn.readLong(); } protected DataStructure looseUnmarsalNestedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { return wireFormat.looseUnmarshalNestedObject(dataIn); } protected void looseMarshalNestedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { wireFormat.looseMarshalNestedObject(o, dataOut); } protected DataStructure looseUnmarsalCachedObject(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (wireFormat.isCacheEnabled()) { if (dataIn.readBoolean()) { short index = dataIn.readShort(); DataStructure object = wireFormat.looseUnmarshalNestedObject(dataIn); wireFormat.setInUnmarshallCache(index, object); return object; } else { short index = dataIn.readShort(); return wireFormat.getFromUnmarshallCache(index); } } else { return wireFormat.looseUnmarshalNestedObject(dataIn); } } protected void looseMarshalCachedObject(OpenWireFormat wireFormat, DataStructure o, DataOutput dataOut) throws IOException { if (wireFormat.isCacheEnabled()) { Short index = wireFormat.getMarshallCacheIndex(o); dataOut.writeBoolean(index == null); if (index == null) { index = wireFormat.addToMarshallCache(o); dataOut.writeShort(index.shortValue()); wireFormat.looseMarshalNestedObject(o, dataOut); } else { dataOut.writeShort(index.shortValue()); } } else { wireFormat.looseMarshalNestedObject(o, dataOut); } } protected Throwable looseUnmarsalThrowable(OpenWireFormat wireFormat, DataInput dataIn) throws IOException { if (dataIn.readBoolean()) { String clazz = looseUnmarshalString(dataIn); String message = looseUnmarshalString(dataIn); Throwable o = createThrowable(clazz, message); if (wireFormat.isStackTraceEnabled()) { if (STACK_TRACE_ELEMENT_CONSTRUCTOR != null) { StackTraceElement ss[] = new StackTraceElement[dataIn.readShort()]; for (int i = 0; i < ss.length; i++) { try { ss[i] = (StackTraceElement)STACK_TRACE_ELEMENT_CONSTRUCTOR .newInstance(new Object[] {looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), looseUnmarshalString(dataIn), - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -