Modifier and Type	Class and Description
pack-priv static class	TcpServerThread.CachedInputStream An input stream with a position.

Modifier and Type	Field and Description
private final SmallMap	cache
private int	clientVersion
private Command	commit
private long	lastRemoteSettingsId
private final SmallLRUCache<Long, TcpServerThread.CachedInputStream>	lobs
private final TcpServer	server
private SessionLocal	session
private String	sessionId
private boolean	stop
private Thread	thread
private final int	threadId
protected final Transfer	transfer

Access	Constructor and Description
pack-priv	TcpServerThread(Socket socket, TcpServer server, int id)

Method Summary

Modifier and Type	Method and Description
pack-priv void	cancelStatement(String the session id targetSessionId, int the statement to cancel statementId) Cancel a running statement.
pack-priv void	close() Close a connection.
private void	closeSession()
private int	getState(int oldModificationId)
pack-priv Thread	getThread()
private void	process()
private Object	readGeneratedKeysRequest()
public void	run() Implements java.lang.Runnable.run. Runs this operation.
private void	sendError(Throwable t, boolean withStatus)
private void	sendGeneratedKeys(ResultInterface generatedKeys)
private void	sendRows(ResultInterface result, long count)
private void	sendSQLException(SQLException e)
private void	setParameters(Command command)
pack-priv void	setThread(Thread thread)
private void	trace(String s)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

cache	back to summary
private final SmallMap cache

clientVersion	back to summary
private int clientVersion

commit	back to summary
private Command commit

lastRemoteSettingsId	back to summary
private long lastRemoteSettingsId

lobs	back to summary
private final SmallLRUCache<Long, TcpServerThread.CachedInputStream> lobs

server	back to summary
private final TcpServer server

session	back to summary
private SessionLocal session

sessionId	back to summary
private String sessionId

stop	back to summary
private boolean stop

thread	back to summary
private Thread thread

threadId	back to summary
private final int threadId

transfer	back to summary
protected final Transfer transfer

Constructor Detail

TcpServerThread	back to summary
pack-priv TcpServerThread(Socket socket, TcpServer server, int id)

Method Detail

cancelStatement	back to summary
pack-priv void cancelStatement(String targetSessionId, int statementId) Cancel a running statement. Parameters targetSessionId:String the session id statementId:int the statement to cancel

cancelStatement

back to summary

pack-priv void cancelStatement(String targetSessionId, int statementId)

Cancel a running statement.

Parameters

targetSessionId:String: the session id
statementId:int: the statement to cancel

close	back to summary
pack-priv void close() Close a connection.

closeSession	back to summary
private void closeSession()

getState	back to summary
private int getState(int oldModificationId)

getThread	back to summary
pack-priv Thread getThread()

process	back to summary
private void process() throws IOException

readGeneratedKeysRequest	back to summary
private Object readGeneratedKeysRequest() throws IOException

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

sendError	back to summary
private void sendError(Throwable t, boolean withStatus)

sendGeneratedKeys	back to summary
private void sendGeneratedKeys(ResultInterface generatedKeys) throws IOException

sendRows	back to summary
private void sendRows(ResultInterface result, long count) throws IOException

sendSQLException	back to summary
private void sendSQLException(SQLException e) throws IOException

setParameters	back to summary
private void setParameters(Command command) throws IOException

setThread	back to summary
pack-priv void setThread(Thread thread)

trace	back to summary
private void trace(String s)

org.h2.server back to summary

pack-priv Class TcpServerThread.CachedInputStream

Class Inheritance

extends FilterInputStream

java.lang.Object
java.io.InputStream
java.io.FilterInputStream
org.h2.server.TcpServerThread.CachedInputStream

An input stream with a position.

Field Summary

Modifier and Type	Field and Description
private static final ByteArrayInputStream	DUMMY
private long	pos

Inherited from java.io.FilterInputStream:: in

Constructor Summary

Access	Constructor and Description
pack-priv	CachedInputStream(InputStream in)

Method Summary

Modifier and Type	Method and Description
public long	getPos()
public int	read(byte[] the buffer into which the data is read. buff, int the start offset in array `b` at which the data is written. off, int the maximum number of bytes to read. len) Overrides java.io.FilterInputStream.read. Reads up to `len` bytes of data from this input stream into an array of bytes.
public int	read() Overrides java.io.FilterInputStream.read. Reads the next byte of data from the input stream.
public long	skip(long the number of bytes to be skipped. n) Overrides java.io.FilterInputStream.skip. Skips over and discards `n` bytes of data from the input stream.

Inherited from java.io.FilterInputStream:: available close mark markSupported read reset

Field Detail

DUMMY	back to summary
private static final ByteArrayInputStream DUMMY

pos	back to summary
private long pos

Constructor Detail

CachedInputStream	back to summary
pack-priv CachedInputStream(InputStream in)

Method Detail

getPos	back to summary
public long getPos()

read back to summary

read	back to summary
public int read(byte[] buff, int off, int len) throws IOException Overrides java.io.FilterInputStream.read. Doc from java.io.FilterInputStream.read. Reads up to `len` bytes of data from this input stream into an array of bytes. If `len` is not zero, the method blocks until some input is available; otherwise, no bytes are read and `0` is returned. Parameters buff:byte[] the buffer into which the data is read. off:int the start offset in array `b` at which the data is written. len:int the maximum number of bytes to read. Returns:int the total number of bytes read into the buffer, or `-1` if there is no more data because the end of the stream has been reached. Annotations @Override Exceptions IOException: if an I/O error occurs.

public int read(byte[] buff, int off, int len) throws IOException

Overrides java.io.FilterInputStream.read.

Doc from java.io.FilterInputStream.read.

Reads up to len bytes of data from this input stream into an array of bytes. If len is not zero, the method blocks until some input is available; otherwise, no bytes are read and 0 is returned.

Parameters

buff:byte[]: the buffer into which the data is read.
off:int: the start offset in array b at which the data is written.
len:int: the maximum number of bytes to read.

Returns:int

the total number of bytes read into the buffer, or -1 if there is no more data because the end of the stream has been reached.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs.

read back to summary

read	back to summary
public int read() throws IOException Overrides java.io.FilterInputStream.read. Doc from java.io.FilterInputStream.read. Reads the next byte of data from the input stream. The value byte is returned as an `int` in the range `0` to `255`. If no byte is available because the end of the stream has been reached, the value `-1` is returned. This method blocks until input data is available, the end of the stream is detected, or an exception is thrown. Returns:int the next byte of data, or `-1` if the end of the stream is reached. Annotations @Override Exceptions IOException: if an I/O error occurs.

public int read() throws IOException

Overrides java.io.FilterInputStream.read.

Doc from java.io.FilterInputStream.read.

Reads the next byte of data from the input stream. The value byte is returned as an int in the range 0 to 255. If no byte is available because the end of the stream has been reached, the value -1 is returned. This method blocks until input data is available, the end of the stream is detected, or an exception is thrown.

Returns:int

the next byte of data, or -1 if the end of the stream is reached.

Annotations

@Override

Exceptions

IOException:: if an I/O error occurs.

skip back to summary

skip	back to summary
public long skip(long n) throws IOException Overrides java.io.FilterInputStream.skip. Doc from java.io.FilterInputStream.skip. Skips over and discards `n` bytes of data from the input stream. The `skip` method may, for a variety of reasons, end up skipping over some smaller number of bytes, possibly `0`. The actual number of bytes skipped is returned. Parameters n:long the number of bytes to be skipped. Returns:long the actual number of bytes skipped. Annotations @Override Exceptions IOException: if `in.skip(n)` throws an IOException.

public long skip(long n) throws IOException

Overrides java.io.FilterInputStream.skip.

Doc from java.io.FilterInputStream.skip.

Skips over and discards n bytes of data from the input stream. The skip method may, for a variety of reasons, end up skipping over some smaller number of bytes, possibly 0. The actual number of bytes skipped is returned.

Parameters

n:long: the number of bytes to be skipped.

Returns:long

the actual number of bytes skipped.

Annotations

@Override

Exceptions

IOException:: if in.skip(n) throws an IOException.

public Class TcpServerThread

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv Class TcpServerThread.CachedInputStream

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail