Class TcpServerThread

java.lang.Object

org.h2.server.TcpServerThread

All Implemented Interfaces:

Runnable

public class TcpServerThread
extends Object
implements Runnable

One server thread is opened per client connection.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	TcpServerThread.CachedInputStream	An input stream with a position.

Field Summary

Fields

Modifier and Type	Field	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

Constructor Summary

Constructors

Constructor	Description
TcpServerThread(Socket socket, TcpServer server, int id)

Method Summary

Modifier and Type	Method	Description
(package private) void	cancelStatement(String targetSessionId, int statementId)	Cancel a running statement.
(package private) void	close()	Close a connection.
private void	closeSession()
private int	getState(int oldModificationId)
(package private) Thread	getThread()
private void	process()
void	run()
private void	sendError(Throwable t, boolean withStatus)
private void	sendRows(ResultInterface result, long count)
private void	setParameters(Command command)
(package private) void	setThread(Thread thread)
private void	trace(String s)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

transfer

protected final Transfer transfer

server

private final TcpServer server

session

private SessionLocal session

stop

private boolean stop

thread

private Thread thread

commit

private Command commit

cache

private final SmallMap cache

lobs

private final SmallLRUCache<Long, TcpServerThread.CachedInputStream> lobs

threadId

private final int threadId

clientVersion

private int clientVersion

sessionId

private String sessionId

lastRemoteSettingsId

private long lastRemoteSettingsId

Constructor Details

TcpServerThread

TcpServerThread(Socket socket,
 TcpServer server,
 int id)

Method Details

trace

private void trace(String s)

run

public void run()

Specified by:

run in interface Runnable

closeSession

private void closeSession()

close

void close()

Close a connection.

sendError

private void sendError(Throwable t,
 boolean withStatus)

setParameters

private void setParameters(Command command)
                    throws IOException

Throws:

IOException

process

private void process()
              throws IOException

Throws:

IOException

getState

private int getState(int oldModificationId)

sendRows

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

Throws:

IOException

setThread

void setThread(Thread thread)

getThread

Thread getThread()

cancelStatement

void cancelStatement(String targetSessionId,
 int statementId)

Cancel a running statement.

Parameters:

targetSessionId - the session id

statementId - the statement to cancel