class DBTCPConnector.MyPort
extends java.lang.Object
| Modifier and Type | Field and Description |
|---|---|
private java.lang.ThreadLocal<DBTCPConnector.PinnedRequestStatus> |
pinnedRequestStatusThreadLocal |
| Constructor and Description |
|---|
MyPort() |
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
done(DBPort port) |
(package private) void |
error(DBPort port,
java.lang.Throwable t)
call this method when there is an IOException or other low level error on port.
|
(package private) DBPort |
get(boolean keep,
ReadPreference readPref,
ServerAddress hostNeeded) |
private DBPort |
getConnection(ServerSelector serverSelector) |
(package private) DBPort |
getPinnedRequestPortForThread() |
(package private) DBTCPConnector.PinnedRequestStatus |
getPinnedRequestStatusForThread() |
private boolean |
portIsAPrimary(DBPort pinnedRequestPort) |
(package private) void |
requestDone() |
(package private) void |
requestEnsureConnection() |
(package private) void |
requestStart() |
(package private) void |
setPinnedRequestPortForThread(DBPort port) |
(package private) boolean |
threadHasPinnedRequest() |
private final java.lang.ThreadLocal<DBTCPConnector.PinnedRequestStatus> pinnedRequestStatusThreadLocal
DBPort get(boolean keep, ReadPreference readPref, ServerAddress hostNeeded)
private boolean portIsAPrimary(DBPort pinnedRequestPort)
void done(DBPort port)
void error(DBPort port, java.lang.Throwable t)
port - t - void requestEnsureConnection()
private DBPort getConnection(ServerSelector serverSelector)
void requestStart()
void requestDone()
DBTCPConnector.PinnedRequestStatus getPinnedRequestStatusForThread()
boolean threadHasPinnedRequest()
DBPort getPinnedRequestPortForThread()
void setPinnedRequestPortForThread(DBPort port)