Package org.h2.server
Class TcpServerThread
java.lang.Object
org.h2.server.TcpServerThread
- All Implemented Interfaces:
Runnable
One server thread is opened per client connection.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static class
An input stream with a position. -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final SmallMap
private int
private Command
private long
private final SmallLRUCache
<Long, TcpServerThread.CachedInputStream> private final TcpServer
private SessionLocal
private String
private boolean
private Thread
private final int
protected final Transfer
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescription(package private) void
cancelStatement
(String targetSessionId, int statementId) Cancel a running statement.(package private) void
close()
Close a connection.private void
private int
getState
(int oldModificationId) (package private) Thread
private void
process()
void
run()
private void
private void
sendRows
(ResultInterface result, long count) private void
setParameters
(Command command) (package private) void
private void
-
Field Details
-
transfer
-
server
-
session
-
stop
private boolean stop -
thread
-
commit
-
cache
-
lobs
-
threadId
private final int threadId -
clientVersion
private int clientVersion -
sessionId
-
lastRemoteSettingsId
private long lastRemoteSettingsId
-
-
Constructor Details
-
TcpServerThread
-
-
Method Details
-
trace
-
run
public void run() -
closeSession
private void closeSession() -
close
void close()Close a connection. -
sendError
-
setParameters
- Throws:
IOException
-
process
- Throws:
IOException
-
getState
private int getState(int oldModificationId) -
sendRows
- Throws:
IOException
-
setThread
-
getThread
Thread getThread() -
cancelStatement
Cancel a running statement.- Parameters:
targetSessionId
- the session idstatementId
- the statement to cancel
-