AutoBuffer

java.lang.Object
- water.AutoBuffer

```
public final class AutoBuffer
extends java.lang.Object
```
A ByteBuffer backed mixed Input/OutputStream class. Reads/writes empty/fill the ByteBuffer as needed. When it is empty/full it we go to the ByteChannel for more/less. Because DirectByteBuffers are expensive to make, we keep a few pooled.

Nested Class Summary

Nested Classes
Modifier and Type Class and Description

static class AutoBuffer.TCPIsUnreliableException

Nested Classes
Modifier and Type	Class and Description
`static class`	`AutoBuffer.TCPIsUnreliableException`

Field Summary

Fields
Modifier and Type	Field and Description
`int`	`_arys`
`java.nio.ByteBuffer`	`_bb`
`H2ONode`	`_h2o`
`byte`	`_persist`
`int`	`_size`
`long`	`_time_close_ms`
`long`	`_time_io_ns`
`long`	`_time_start_ms`
`int`	`_zeros`
`static int`	`BBSIZE`
`static int`	`MTU`
`static int`	`TCP_WRITE_ATTEMPTS`

Constructor Summary

Constructors
Constructor and Description
`AutoBuffer()` Write to an ever-expanding byte[].
`AutoBuffer(byte[] buf)` Read from a fixed byte[]; should not be closed.
`AutoBuffer(byte[] buf, int off)` Read from a fixed byte[]; should not be closed.
`AutoBuffer(java.nio.channels.DatagramChannel sock)`
`AutoBuffer(java.net.DatagramPacket pack)`
`AutoBuffer(java.nio.channels.FileChannel fc, boolean read, byte persist)`
`AutoBuffer(H2ONode h2o)`
`AutoBuffer(int len)` Write to a known sized byte[].
`AutoBuffer(java.nio.channels.SocketChannel sock)`

Method Summary

Methods
Modifier and Type	Method and Description
`byte[]`	`buf()`
`byte[]`	`bufClose()`
`AutoBuffer`	`clearForWriting()`
`int`	`close()`
`int`	`close(boolean expect_tcp, boolean failed)`
`AutoBuffer`	`copyArrayFrom(int offset, AutoBuffer ab, int abOff, int len)`
`void`	`drainClose()`
`boolean`	`eof()`
`AutoBuffer`	`flipForReading()`
`<T extends Iced> T`	`get()`
`<T extends Freezable> T`	`get(java.lang.Class<T> t)`
`int`	`get1()`
`int`	`get1(int off)`
`char`	`get2()`
`char`	`get2(int off)`
`int`	`get3()`
`int`	`get4()`
`int`	`get4(int off)`
`float`	`get4f()`
`float`	`get4f(int off)`
`long`	`get8()`
`long`	`get8(int off)`
`double`	`get8d()`
`double`	`get8d(int off)`
`<T extends Freezable> T[]`	`getA(java.lang.Class<T> tc)`
`byte[]`	`getA1()`
`byte[]`	`getA1(int len)`
`short[]`	`getA2()`
`int[]`	`getA4()`
`float[]`	`getA4f()`
`long[]`	`getA8()`
`double[]`	`getA8d()`
`<T extends Iced> T[][]`	`getAA(java.lang.Class<T> tc)`
`byte[][]`	`getAA1()`
`short[][]`	`getAA2()`
`int[][]`	`getAA4()`
`float[][]`	`getAA4f()`
`long[][]`	`getAA8()`
`double[][]`	`getAA8d()`
`<T extends Iced> T[][][]`	`getAAA(java.lang.Class<T> tc)`
`int[][][]`	`getAAA4()`
`long[][][]`	`getAAA8()`
`double[][][]`	`getAAA8d()`
`java.lang.String[][]`	`getAAStr()`
`java.lang.String[]`	`getAStr()`
`int`	`getCtrl()`
`int`	`getFlag()`
`int`	`getInt()`
`int`	`getPort()`
`java.lang.String`	`getStr()`
`java.lang.String`	`getStr(int off, int len)`
`int`	`getTask()`
`boolean`	`getZ()`
`long`	`getZA()`
`int`	`limit()`
`int`	`peek1()`
`int`	`position()`
`void`	`position(int pos)`
`void`	`positionWithResize(int value)`
`AutoBuffer`	`put(Freezable f)`
`AutoBuffer`	`put(Iced f)`
`AutoBuffer`	`put1(int b)`
`AutoBuffer`	`put1(int off, int v)`
`AutoBuffer`	`put2(char c)`
`AutoBuffer`	`put2(int off, char v)`
`AutoBuffer`	`put2(int off, short v)`
`AutoBuffer`	`put2(short s)`
`AutoBuffer`	`put3(int x)`
`AutoBuffer`	`put4(int i)`
`AutoBuffer`	`put4(int off, int v)`
`AutoBuffer`	`put4f(float f)`
`AutoBuffer`	`put4f(int off, float v)`
`AutoBuffer`	`put8(int off, long v)`
`AutoBuffer`	`put8(long l)`
`AutoBuffer`	`put8d(double d)`
`AutoBuffer`	`put8d(int off, double v)`
`AutoBuffer`	`putA(Freezable[] fs)`
`AutoBuffer`	`putA(Iced[] fs)`
`AutoBuffer`	`putA1(byte[] ary)`
`AutoBuffer`	`putA1(byte[] ary, int length)`
`AutoBuffer`	`putA1(byte[] ary, int sofar, int length)`
`AutoBuffer`	`putA2(short[] ary)`
`AutoBuffer`	`putA4(int[] ary)`
`AutoBuffer`	`putA4f(float[] ary)`
`AutoBuffer`	`putA8(long[] ary)`
`AutoBuffer`	`putA8d(double[] ary)`
`AutoBuffer`	`putAA(Iced[][] fs)`
`AutoBuffer`	`putAA1(byte[][] ary)`
`AutoBuffer`	`putAA2(short[][] ary)`
`AutoBuffer`	`putAA4(int[][] ary)`
`AutoBuffer`	`putAA4f(float[][] ary)`
`AutoBuffer`	`putAA8(long[][] ary)`
`AutoBuffer`	`putAA8d(double[][] ary)`
`AutoBuffer`	`putAAA(Iced[][][] fs)`
`AutoBuffer`	`putAAA4(int[][][] ary)`
`AutoBuffer`	`putAAA8(long[][][] ary)`
`AutoBuffer`	`putAAA8d(double[][][] ary)`
`AutoBuffer`	`putAAStr(java.lang.String[][] fs)`
`AutoBuffer`	`putAStr(java.lang.String[] fs)`
`AutoBuffer`	`putEnum(java.lang.Enum x)`
`AutoBuffer`	`putEnumJSON(java.lang.Enum e)`
`AutoBuffer`	`putEnumJSON(java.lang.String name, java.lang.Enum e)`
`AutoBuffer`	`putInt(int x)`
`AutoBuffer`	`putJSON(Iced ice)`
`AutoBuffer`	`putJSON(java.lang.String name, Iced f)`
`AutoBuffer`	`putJSON1(byte b)`
`AutoBuffer`	`putJSON4(int i)`
`AutoBuffer`	`putJSON4(java.lang.String name, int i)`
`AutoBuffer`	`putJSON4f(float f)`
`AutoBuffer`	`putJSON4f(java.lang.String name, float f)`
`AutoBuffer`	`putJSON8(long l)`
`AutoBuffer`	`putJSON8(java.lang.String name, long l)`
`AutoBuffer`	`putJSON8d(double d)`
`AutoBuffer`	`putJSON8d(java.lang.String name, double d)`
`AutoBuffer`	`putJSONA(Iced[] fs)`
`AutoBuffer`	`putJSONA(java.lang.String name, Iced[] f)`
`AutoBuffer`	`putJSONA1(byte[] ary)`
`AutoBuffer`	`putJSONA4(int[] a)`
`AutoBuffer`	`putJSONA4(java.lang.String name, int[] a)`
`AutoBuffer`	`putJSONA4f(float[] a)`
`AutoBuffer`	`putJSONA4f(java.lang.String name, float[] a)`
`AutoBuffer`	`putJSONA8(long[] ary)`
`AutoBuffer`	`putJSONA8(java.lang.String name, long[] ary)`
`AutoBuffer`	`putJSONA8d(double[] a)`
`AutoBuffer`	`putJSONA8d(java.lang.String name, double[] a)`
`AutoBuffer`	`putJSONAA(Iced[][] fs)`
`AutoBuffer`	`putJSONAA(java.lang.String name, Iced[][] f)`
`AutoBuffer`	`putJSONAA1(byte[][] ary)`
`AutoBuffer`	`putJSONAA1(java.lang.String name, byte[][] ary)`
`AutoBuffer`	`putJSONAA4(java.lang.String name, int[][] a)`
`AutoBuffer`	`putJSONAA4f(java.lang.String name, float[][] a)`
`AutoBuffer`	`putJSONAA8(long[][] ary)`
`AutoBuffer`	`putJSONAA8(java.lang.String name, long[][] ary)`
`AutoBuffer`	`putJSONAA8d(double[][] a)`
`AutoBuffer`	`putJSONAA8d(java.lang.String name, double[][] a)`
`AutoBuffer`	`putJSONAAA8(long[][][] ary)`
`AutoBuffer`	`putJSONAAA8(java.lang.String name, long[][][] ary)`
`AutoBuffer`	`putJSONAAA8d(double[][][] a)`
`AutoBuffer`	`putJSONAAA8d(java.lang.String name, double[][][] a)`
`AutoBuffer`	`putJSONAAStr(java.lang.String name, java.lang.String[][] a)`
`AutoBuffer`	`putJSONAStr(java.lang.String[] fs)`
`AutoBuffer`	`putJSONAStr(java.lang.String name, java.lang.String[] fs)`
`AutoBuffer`	`putJSONStr(java.lang.String s)`
`AutoBuffer`	`putJSONStr(java.lang.String name, java.lang.String value)`
`AutoBuffer`	`putJSONZ(java.lang.String name, boolean value)`
`AutoBuffer`	`putNULL()`
`AutoBuffer`	`putStr(java.lang.String s)`
`AutoBuffer`	`putStr2(java.lang.String s)`
`AutoBuffer`	`putTask(int ctrl, int tasknum)`
`AutoBuffer`	`putTask(UDP.udp type, int tasknum)`
`AutoBuffer`	`putUdp(UDP.udp type)`
`AutoBuffer`	`putZ(boolean b)`
`long`	`putZA(java.lang.Object[] A)`
`int`	`read(byte[] buf, int off, int len)`
`int`	`remaining()`
`void`	`shift(int source, int target, int length)`
`java.lang.String`	`toString()`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

TCP_WRITE_ATTEMPTS
```
public static final int TCP_WRITE_ATTEMPTS
```
See Also:
Constant Field Values

_bb
```
public java.nio.ByteBuffer _bb
```

_h2o
```
public final H2ONode _h2o
```

_size
```
public int _size
```

_zeros
```
public int _zeros
```

_arys
```
public int _arys
```

_time_start_ms
```
public long _time_start_ms
```

_time_close_ms
```
public long _time_close_ms
```

_time_io_ns
```
public long _time_io_ns
```

_persist
```
public final byte _persist
```

MTU
```
public static final int MTU
```
See Also:
Constant Field Values

BBSIZE
```
public static final int BBSIZE
```
See Also:
Constant Field Values

Constructor Detail

AutoBuffer

public AutoBuffer(java.nio.channels.DatagramChannel sock)
           throws java.io.IOException

Throws:: java.io.IOException

AutoBuffer

public AutoBuffer(java.nio.channels.SocketChannel sock)
           throws java.io.IOException

Throws:: java.io.IOException

AutoBuffer
```
public AutoBuffer(H2ONode h2o)
```

AutoBuffer

public AutoBuffer(java.nio.channels.FileChannel fc,
          boolean read,
          byte persist)

AutoBuffer

public AutoBuffer(java.net.DatagramPacket pack)

AutoBuffer
```
public AutoBuffer(byte[] buf)
```
Read from a fixed byte[]; should not be closed.

AutoBuffer
```
public AutoBuffer(byte[] buf,
          int off)
```
Read from a fixed byte[]; should not be closed.

AutoBuffer
```
public AutoBuffer()
```
Write to an ever-expanding byte[]. Instead of calling close(), call buf() to retrieve the final byte[].

AutoBuffer
```
public AutoBuffer(int len)
```
Write to a known sized byte[]. Instead of calling close(), call bufClose() to retrieve the final byte[].

Method Detail

toString
```
public java.lang.String toString()
```
Overrides:

toString in class java.lang.Object

close
```
public final int close()
```

close

public final int close(boolean expect_tcp,
        boolean failed)

drainClose
```
public void drainClose()
```

remaining
```
public int remaining()
```

position
```
public int position()
```

position
```
public void position(int pos)
```

limit
```
public int limit()
```

positionWithResize

public void positionWithResize(int value)

buf
```
public final byte[] buf()
```

bufClose
```
public final byte[] bufClose()
```

eof
```
public final boolean eof()
```

clearForWriting
```
public AutoBuffer clearForWriting()
```

flipForReading
```
public AutoBuffer flipForReading()
```

peek1
```
public int peek1()
```

getStr

public java.lang.String getStr(int off,
                      int len)

getZ
```
public boolean getZ()
```

get1
```
public int get1()
```

get2
```
public char get2()
```

get4
```
public int get4()
```

get4f
```
public float get4f()
```

get8
```
public long get8()
```

get8d
```
public double get8d()
```

get3
```
public int get3()
```

put3
```
public AutoBuffer put3(int x)
```

get1
```
public int get1(int off)
```

get2
```
public char get2(int off)
```

get4
```
public int get4(int off)
```

get4f
```
public float get4f(int off)
```

get8
```
public long get8(int off)
```

get8d
```
public double get8d(int off)
```

put1

public AutoBuffer put1(int off,
              int v)

put2

public AutoBuffer put2(int off,
              char v)

put2

public AutoBuffer put2(int off,
              short v)

put4

public AutoBuffer put4(int off,
              int v)

put4f

public AutoBuffer put4f(int off,
               float v)

put8

public AutoBuffer put8(int off,
              long v)

put8d

public AutoBuffer put8d(int off,
               double v)

putZ
```
public AutoBuffer putZ(boolean b)
```

put1
```
public AutoBuffer put1(int b)
```

put2
```
public AutoBuffer put2(char c)
```

put2
```
public AutoBuffer put2(short s)
```

put4
```
public AutoBuffer put4(int i)
```

put4f
```
public AutoBuffer put4f(float f)
```

put8
```
public AutoBuffer put8(long l)
```

put8d
```
public AutoBuffer put8d(double d)
```

put
```
public AutoBuffer put(Freezable f)
```

put
```
public AutoBuffer put(Iced f)
```

putInt
```
public AutoBuffer putInt(int x)
```

getInt
```
public int getInt()
```

putZA

public long putZA(java.lang.Object[] A)

getZA
```
public long getZA()
```

putA
```
public AutoBuffer putA(Iced[] fs)
```

putAA
```
public AutoBuffer putAA(Iced[][] fs)
```

putAAA

public AutoBuffer putAAA(Iced[][][] fs)

putA

public AutoBuffer putA(Freezable[] fs)

get

public <T extends Freezable> T get(java.lang.Class<T> t)

get
```
public <T extends Iced> T get()
```

getA

public <T extends Freezable> T[] getA(java.lang.Class<T> tc)

getAA

public <T extends Iced> T[][] getAA(java.lang.Class<T> tc)

getAAA

public <T extends Iced> T[][][] getAAA(java.lang.Class<T> tc)

putAStr

public AutoBuffer putAStr(java.lang.String[] fs)

getAStr
```
public java.lang.String[] getAStr()
```

putAAStr

public AutoBuffer putAAStr(java.lang.String[][] fs)

getAAStr

public java.lang.String[][] getAAStr()

read

public int read(byte[] buf,
       int off,
       int len)

getCtrl
```
public int getCtrl()
```

getPort
```
public int getPort()
```

getTask
```
public int getTask()
```

getFlag
```
public int getFlag()
```

putUdp

public AutoBuffer putUdp(UDP.udp type)

putTask

public AutoBuffer putTask(UDP.udp type,
                 int tasknum)

putTask

public AutoBuffer putTask(int ctrl,
                 int tasknum)

getA1
```
public byte[] getA1()
```

getA1
```
public byte[] getA1(int len)
```

getA2
```
public short[] getA2()
```

getA4
```
public int[] getA4()
```

getA4f
```
public float[] getA4f()
```

getA8
```
public long[] getA8()
```

getA8d
```
public double[] getA8d()
```

getAA1
```
public byte[][] getAA1()
```

getAA2
```
public short[][] getAA2()
```

getAA4
```
public int[][] getAA4()
```

getAA4f
```
public float[][] getAA4f()
```

getAA8
```
public long[][] getAA8()
```

getAA8d
```
public double[][] getAA8d()
```

getAAA4
```
public int[][][] getAAA4()
```

getAAA8
```
public long[][][] getAAA8()
```

getAAA8d
```
public double[][][] getAAA8d()
```

getStr
```
public java.lang.String getStr()
```

putA1
```
public AutoBuffer putA1(byte[] ary)
```

putA1

public AutoBuffer putA1(byte[] ary,
               int length)

putA1

public AutoBuffer putA1(byte[] ary,
               int sofar,
               int length)

putA2
```
public AutoBuffer putA2(short[] ary)
```

putA4
```
public AutoBuffer putA4(int[] ary)
```

putA8
```
public AutoBuffer putA8(long[] ary)
```

putA4f

public AutoBuffer putA4f(float[] ary)

putA8d

public AutoBuffer putA8d(double[] ary)

putAA1

public AutoBuffer putAA1(byte[][] ary)

putAA2

public AutoBuffer putAA2(short[][] ary)

putAA4

public AutoBuffer putAA4(int[][] ary)

putAA4f

public AutoBuffer putAA4f(float[][] ary)

putAA8

public AutoBuffer putAA8(long[][] ary)

putAA8d

public AutoBuffer putAA8d(double[][] ary)

putAAA4

public AutoBuffer putAAA4(int[][][] ary)

putAAA8

public AutoBuffer putAAA8(long[][][] ary)

putAAA8d

public AutoBuffer putAAA8d(double[][][] ary)

putStr

public AutoBuffer putStr(java.lang.String s)

putEnum

public AutoBuffer putEnum(java.lang.Enum x)

copyArrayFrom

public AutoBuffer copyArrayFrom(int offset,
                       AutoBuffer ab,
                       int abOff,
                       int len)

shift

public void shift(int source,
         int target,
         int length)

putStr2

public AutoBuffer putStr2(java.lang.String s)

putNULL
```
public AutoBuffer putNULL()
```

putJSONStr

public AutoBuffer putJSONStr(java.lang.String s)

putJSONStr

public AutoBuffer putJSONStr(java.lang.String name,
                    java.lang.String value)

putJSONAStr

public AutoBuffer putJSONAStr(java.lang.String name,
                     java.lang.String[] fs)

putJSONAStr

public AutoBuffer putJSONAStr(java.lang.String[] fs)

putJSONAAStr

public AutoBuffer putJSONAAStr(java.lang.String name,
                      java.lang.String[][] a)

putJSON
```
public AutoBuffer putJSON(Iced ice)
```

putJSONA

public AutoBuffer putJSONA(Iced[] fs)

putJSONAA

public AutoBuffer putJSONAA(Iced[][] fs)

putJSONZ

public AutoBuffer putJSONZ(java.lang.String name,
                  boolean value)

putJSON1
```
public AutoBuffer putJSON1(byte b)
```

putJSONA1

public AutoBuffer putJSONA1(byte[] ary)

putJSONAA1

public AutoBuffer putJSONAA1(byte[][] ary)

putJSONAA1

public AutoBuffer putJSONAA1(java.lang.String name,
                    byte[][] ary)

putJSON8
```
public AutoBuffer putJSON8(long l)
```

putJSONA8

public AutoBuffer putJSONA8(long[] ary)

putJSONAA8

public AutoBuffer putJSONAA8(long[][] ary)

putJSONAAA8

public AutoBuffer putJSONAAA8(long[][][] ary)

putEnumJSON

public AutoBuffer putEnumJSON(java.lang.Enum e)

putJSON

public AutoBuffer putJSON(java.lang.String name,
                 Iced f)

putJSONA

public AutoBuffer putJSONA(java.lang.String name,
                  Iced[] f)

putJSONAA

public AutoBuffer putJSONAA(java.lang.String name,
                   Iced[][] f)

putJSON8

public AutoBuffer putJSON8(java.lang.String name,
                  long l)

putEnumJSON

public AutoBuffer putEnumJSON(java.lang.String name,
                     java.lang.Enum e)

putJSONA8

public AutoBuffer putJSONA8(java.lang.String name,
                   long[] ary)

putJSONAA8

public AutoBuffer putJSONAA8(java.lang.String name,
                    long[][] ary)

putJSONAAA8

public AutoBuffer putJSONAAA8(java.lang.String name,
                     long[][][] ary)

putJSON4
```
public AutoBuffer putJSON4(int i)
```

putJSON4

public AutoBuffer putJSON4(java.lang.String name,
                  int i)

putJSONA4
```
public AutoBuffer putJSONA4(int[] a)
```

putJSONA4

public AutoBuffer putJSONA4(java.lang.String name,
                   int[] a)

putJSONAA4

public AutoBuffer putJSONAA4(java.lang.String name,
                    int[][] a)

putJSON4f
```
public AutoBuffer putJSON4f(float f)
```

putJSON4f

public AutoBuffer putJSON4f(java.lang.String name,
                   float f)

putJSONA4f

public AutoBuffer putJSONA4f(float[] a)

putJSONA4f

public AutoBuffer putJSONA4f(java.lang.String name,
                    float[] a)

putJSONAA4f

public AutoBuffer putJSONAA4f(java.lang.String name,
                     float[][] a)

putJSON8d

public AutoBuffer putJSON8d(double d)

putJSON8d

public AutoBuffer putJSON8d(java.lang.String name,
                   double d)

putJSONA8d

public AutoBuffer putJSONA8d(double[] a)

putJSONA8d

public AutoBuffer putJSONA8d(java.lang.String name,
                    double[] a)

putJSONAA8d

public AutoBuffer putJSONAA8d(java.lang.String name,
                     double[][] a)

putJSONAA8d

public AutoBuffer putJSONAA8d(double[][] a)

putJSONAAA8d

public AutoBuffer putJSONAAA8d(java.lang.String name,
                      double[][][] a)

putJSONAAA8d

public AutoBuffer putJSONAAA8d(double[][][] a)

Class AutoBuffer

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

TCP_WRITE_ATTEMPTS

_bb

_h2o

_size

_zeros

_arys

_time_start_ms

_time_close_ms

_time_io_ns

_persist

MTU

BBSIZE

Constructor Detail

AutoBuffer

AutoBuffer

AutoBuffer

AutoBuffer

AutoBuffer

AutoBuffer

AutoBuffer

AutoBuffer

AutoBuffer

Method Detail

toString

close

close

drainClose

remaining

position

position

limit

positionWithResize

buf

bufClose

eof

clearForWriting

flipForReading

peek1

getStr

getZ

get1

get2

get4

get4f

get8

get8d

get3

put3

get1

get2

get4

get4f

get8

get8d

put1

put2

put2

put4

put4f

put8

put8d

putZ

put1

put2

put2

put4

put4f

put8

put8d

put

put

putInt

getInt