commit c2e8ff5ae69840781c8853fa7a911baefdf62a0a
author Mark Slee <mcslee@apache.org> Fri Sep 22 16:57:38 2006 +0000
committer Mark Slee <mcslee@apache.org> Fri Sep 22 16:57:38 2006 +0000
tree 650eb0f10e7b24c9c8a44b430f71bd6330de084c
parent 20c70a67be9dc7bb9ae54e3c52f14f36d75913f0

Fix potential multithreading protocol issue in Thrift Java


git-svn-id: https://svn.apache.org/repos/asf/incubator/thrift/trunk@664802 13f79535-47bb-0310-9956-ffa450edef68

lib/java/src/protocol/TBinaryProtocol.java

diff --git a/lib/java/src/protocol/TBinaryProtocol.java b/lib/java/src/protocol/TBinaryProtocol.java
index 4d6c345..61bac08 100644
--- a/lib/java/src/protocol/TBinaryProtocol.java
+++ b/lib/java/src/protocol/TBinaryProtocol.java
@@ -60,21 +60,21 @@
     writeByte(out, b ? (byte)1 : (byte)0);
   }
 
-  byte[] bout = new byte[1];
   public void writeByte(TTransport out, byte b) throws TException {
+    byte[] bout = new byte[1];
     bout[0] = b;
     out.write(bout, 0, 1);
   }
 
-  byte[] i16out = new byte[2];
   public void writeI16(TTransport out, short i16) throws TException {
+    byte[] i16out = new byte[2];
     i16out[0] = (byte)(0xff & (i16 >> 8));
     i16out[1] = (byte)(0xff & (i16));
     out.write(i16out, 0, 2);
   }
 
-  byte[] i32out = new byte[4];
   public void writeI32(TTransport out, int i32) throws TException {
+    byte[] i32out = new byte[4];
     i32out[0] = (byte)(0xff & (i32 >> 24));
     i32out[1] = (byte)(0xff & (i32 >> 16));
     i32out[2] = (byte)(0xff & (i32 >> 8));
@@ -82,8 +82,8 @@
     out.write(i32out, 0, 4);
   }
 
-  byte[] i64out = new byte[8];
   public void writeI64(TTransport out, long i64) throws TException {
+    byte[] i64out = new byte[8];
     i64out[0] = (byte)(0xff & (i64 >> 56));
     i64out[1] = (byte)(0xff & (i64 >> 48));
     i64out[2] = (byte)(0xff & (i64 >> 40));
@@ -168,14 +168,14 @@
     return (readByte(in) == 1);
   }
 
-  byte[] bin = new byte[1];
   public byte readByte(TTransport in) throws TException {
+    byte[] bin = new byte[1];
     in.readAll(bin, 0, 1);
     return bin[0];
   }
 
-  byte[] i16rd = new byte[2];
   public short readI16(TTransport in) throws TException {
+    byte[] i16rd = new byte[2];
     in.readAll(i16rd, 0, 2);
     return
       (short)
@@ -183,8 +183,8 @@
        ((i16rd[1] & 0xff)));
   }
 
-  byte[] i32rd = new byte[4];
   public int readI32(TTransport in) throws TException {
+    byte[] i32rd = new byte[4];
     in.readAll(i32rd, 0, 4);
     return
       ((i32rd[0] & 0xff) << 24) |
@@ -193,8 +193,8 @@
       ((i32rd[3] & 0xff));
   }
  
-  byte[] i64rd = new byte[8];
   public long readI64(TTransport in) throws TException {
+    byte[] i64rd = new byte[8];
     in.readAll(i64rd, 0, 8);
     return
       ((long)(i64rd[0] & 0xff) << 56) |