Modifier and Type	Class and Description
private class	TCPTransport.AcceptLoop Worker for accepting connections from a server socket.
private class	TCPTransport.ConnectionHandler Services messages on accepted connection

Field Summary

Modifier and Type	Field and Description
private final Map<TCPEndpoint, Reference<TCPChannel>>	channelTable table mapping endpoints to channels
private static final AtomicInteger	connectionCount total connections handled
private static final int	connectionReadTimeout number of milliseconds in accepted-connection timeout.
private static final ExecutorService	connectionThreadPool thread pool for connection handlers
pack-priv static final RMISocketFactory	defaultSocketFactory
private final LinkedList<TCPEndpoint>	epList endpoints for this transport
private int	exportCount number of objects exported on this transport
private static final int	maxConnectionThreads maximum number of connection handler threads
private static final AccessControlContext	NOPERMS_ACC References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element. an AccessControlContext with no permissions
private ServerSocket	server server socket for this transport
pack-priv static final Log	tcpLog
private static final ThreadLocal<TCPTransport.ConnectionHandler>	threadConnectionHandler client host for the current thread's connection
private static final long	threadKeepAliveTime keep alive time for idle connection handler threads

Access	Constructor and Description
pack-priv	TCPTransport(LinkedList<TCPEndpoint> epList) Constructs a TCPTransport.

Method Summary

Modifier and Type	Method and Description
protected void	checkAcceptPermission(AccessControlContext acc) Implements abstract sun.rmi.transport.Transport.checkAcceptPermission. References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element. Verify that the current access control context has permission to accept the connection being dispatched by the current thread.
private static void	closeSocket(Socket sock) close socket and eat exception
private static AccessControlContext	createNopermsAcc() References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element.
private void	decrementExportCount() Decrements the count of exported objects, closing the current server socket if the count reaches zero.
public void	exportObject(Target target) Overrides sun.rmi.transport.Transport.exportObject. Export the object so that it can accept incoming calls.
public void	free(Endpoint ep) Implements abstract sun.rmi.transport.Transport.free. Removes the Channel that generates connections to the endpoint ep.
public TCPChannel	Returns: the channel or null if the transport cannot generate connections to this endpoint getChannel(Endpoint the endpoint to which connections will be generated. ep) Implements abstract sun.rmi.transport.Transport.getChannel. Returns a Channel that generates connections to the endpoint ep.
public static String	getClientHost() Returns the client host for the current thread's connection.
private TCPEndpoint	getEndpoint()
pack-priv void	handleMessages(Connection conn, boolean persistent) handleMessages decodes transport operations and handles messages appropriately.
private void	listen() Listen on transport's endpoint.
public void	shedConnectionCaches() Closes all cached connections in every channel subordinated to this transport.
protected synchronized void	targetUnexported() Overrides sun.rmi.transport.Transport.targetUnexported. Invoked when an object that was exported on this transport has become unexported, either by being garbage collected or by being explicitly unexported.

Inherited from sun.rmi.transport.Transport:: serviceCall

Field Detail

channelTable	back to summary
private final Map<TCPEndpoint, Reference<TCPChannel>> channelTable table mapping endpoints to channels

connectionCount	back to summary
private static final AtomicInteger connectionCount total connections handled

connectionReadTimeout	back to summary
private static final int connectionReadTimeout number of milliseconds in accepted-connection timeout. Warning this should be greater than 15 seconds (the client-side timeout), and defaults to 2 hours. The maximum representable value is slightly more than 24 days and 20 hours. Annotations @SuppressWarnings:removal

connectionThreadPool	back to summary
private static final ExecutorService connectionThreadPool thread pool for connection handlers

defaultSocketFactory	back to summary
pack-priv static final RMISocketFactory defaultSocketFactory

epList	back to summary
private final LinkedList<TCPEndpoint> epList endpoints for this transport

exportCount	back to summary
private int exportCount number of objects exported on this transport

maxConnectionThreads	back to summary
private static final int maxConnectionThreads maximum number of connection handler threads Annotations @SuppressWarnings:removal

NOPERMS_ACC	back to summary
private static final AccessControlContext NOPERMS_ACC References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information. an AccessControlContext with no permissions Annotations @SuppressWarnings:removal

server	back to summary
private ServerSocket server server socket for this transport

tcpLog	back to summary
pack-priv static final Log tcpLog Annotations @SuppressWarnings:removal

threadConnectionHandler	back to summary
private static final ThreadLocal<TCPTransport.ConnectionHandler> threadConnectionHandler client host for the current thread's connection

threadKeepAliveTime	back to summary
private static final long threadKeepAliveTime keep alive time for idle connection handler threads Annotations @SuppressWarnings:removal

TCPTransport	back to summary
pack-priv TCPTransport(LinkedList<TCPEndpoint> epList) Constructs a TCPTransport.

Method Detail

checkAcceptPermission back to summary

checkAcceptPermission	back to summary
protected void checkAcceptPermission(AccessControlContext acc) Implements abstract sun.rmi.transport.Transport.checkAcceptPermission. References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information. Verify that the current access control context has permission to accept the connection being dispatched by the current thread.

protected void checkAcceptPermission(AccessControlContext acc)

Implements abstract sun.rmi.transport.Transport.checkAcceptPermission.

References Deprecated

AccessControlContext is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Verify that the current access control context has permission to accept the connection being dispatched by the current thread.

closeSocket	back to summary
private static void closeSocket(Socket sock) close socket and eat exception

createNopermsAcc	back to summary
private static AccessControlContext createNopermsAcc() References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information. Annotations @SuppressWarnings:removal

decrementExportCount	back to summary
private void decrementExportCount() Decrements the count of exported objects, closing the current server socket if the count reaches zero.

exportObject	back to summary
public void exportObject(Target target) throws RemoteException Overrides sun.rmi.transport.Transport.exportObject. Export the object so that it can accept incoming calls.

exportObject

back to summary

public void exportObject(Target target) throws RemoteException

Overrides sun.rmi.transport.Transport.exportObject.

Export the object so that it can accept incoming calls.

free	back to summary
public void free(Endpoint ep) Implements abstract sun.rmi.transport.Transport.free. Removes the Channel that generates connections to the endpoint ep.

free

back to summary

public void free(Endpoint ep)

Implements abstract sun.rmi.transport.Transport.free.

Removes the Channel that generates connections to the endpoint ep.

getChannel	back to summary
public TCPChannel getChannel(Endpoint ep) Implements abstract sun.rmi.transport.Transport.getChannel. Returns a Channel that generates connections to the endpoint ep. A Channel is an object that creates and manages connections of a particular type to some particular address space. Parameters ep:Endpoint the endpoint to which connections will be generated. Returns:TCPChannel the channel or null if the transport cannot generate connections to this endpoint

getChannel

back to summary

public TCPChannel getChannel(Endpoint ep)

Implements abstract sun.rmi.transport.Transport.getChannel.

Returns a Channel that generates connections to the endpoint ep. A Channel is an object that creates and manages connections of a particular type to some particular address space.

Parameters

ep:Endpoint: the endpoint to which connections will be generated.

Returns:TCPChannel

the channel or null if the transport cannot generate connections to this endpoint

getClientHost	back to summary
public static String getClientHost() throws ServerNotActiveException Returns the client host for the current thread's connection. Throws ServerNotActiveException if no connection is active for this thread.

getEndpoint	back to summary
private TCPEndpoint getEndpoint()

handleMessages	back to summary
pack-priv void handleMessages(Connection conn, boolean persistent) handleMessages decodes transport operations and handles messages appropriately. If an exception occurs during message handling, the socket is closed.

listen	back to summary
private void listen() throws RemoteException Listen on transport's endpoint.

shedConnectionCaches	back to summary
public void shedConnectionCaches() Closes all cached connections in every channel subordinated to this transport. Currently, this only closes outgoing connections.

targetUnexported	back to summary
protected synchronized void targetUnexported() Overrides sun.rmi.transport.Transport.targetUnexported. Doc from sun.rmi.transport.Transport.targetUnexported. Invoked when an object that was exported on this transport has become unexported, either by being garbage collected or by being explicitly unexported.

targetUnexported

back to summary

protected synchronized void targetUnexported()

Overrides sun.rmi.transport.Transport.targetUnexported.

Doc from sun.rmi.transport.Transport.targetUnexported.

Invoked when an object that was exported on this transport has become unexported, either by being garbage collected or by being explicitly unexported.

sun.rmi.transport.tcp back to summary

private Class TCPTransport.AcceptLoop

Class Inheritance

extends Object
implements Runnable

java.lang.Object
sun.rmi.transport.tcp.TCPTransport.AcceptLoop

All Implemented Interfaces

java.lang.Runnable

Worker for accepting connections from a server socket.

Field Summary

Modifier and Type	Field and Description
private long	lastExceptionTime
private int	recentExceptionCount
private final ServerSocket	serverSocket

Constructor Summary

Access	Constructor and Description
pack-priv	AcceptLoop(ServerSocket serverSocket)

Method Summary

Modifier and Type	Method and Description
private boolean	continueAfterAcceptFailure(Throwable t) Returns true if the accept loop should continue after the specified exception has been caught, or false if the accept loop should terminate (closing the server socket).
private void	executeAcceptLoop() Accepts connections from the server socket and executes handlers for them in the thread pool.
public void	run() Implements java.lang.Runnable.run. Runs this operation.
private void	throttleLoopOnException() Throttles the accept loop after an exception has been caught: if a burst of 10 exceptions in 5 seconds occurs, then wait for 10 seconds to curb busy CPU usage.

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

Field Detail

lastExceptionTime	back to summary
private long lastExceptionTime

recentExceptionCount	back to summary
private int recentExceptionCount

serverSocket	back to summary
private final ServerSocket serverSocket

Constructor Detail

AcceptLoop	back to summary
pack-priv AcceptLoop(ServerSocket serverSocket)

Method Detail

continueAfterAcceptFailure	back to summary
private boolean continueAfterAcceptFailure(Throwable t) Returns true if the accept loop should continue after the specified exception has been caught, or false if the accept loop should terminate (closing the server socket). If there is an RMIFailureHandler, this method returns the result of passing the specified exception to it; otherwise, this method always returns true, after sleeping to throttle the accept loop if necessary.

continueAfterAcceptFailure

back to summary

private boolean continueAfterAcceptFailure(Throwable t)

Returns true if the accept loop should continue after the specified exception has been caught, or false if the accept loop should terminate (closing the server socket). If there is an RMIFailureHandler, this method returns the result of passing the specified exception to it; otherwise, this method always returns true, after sleeping to throttle the accept loop if necessary.

executeAcceptLoop	back to summary
private void executeAcceptLoop() Accepts connections from the server socket and executes handlers for them in the thread pool.

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

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

throttleLoopOnException	back to summary
private void throttleLoopOnException() Throttles the accept loop after an exception has been caught: if a burst of 10 exceptions in 5 seconds occurs, then wait for 10 seconds to curb busy CPU usage.

sun.rmi.transport.tcp back to summary

private Class TCPTransport.ConnectionHandler

Class Inheritance

extends Object
implements Runnable

java.lang.Object
sun.rmi.transport.tcp.TCPTransport.ConnectionHandler

All Implemented Interfaces

java.lang.Runnable

Services messages on accepted connection

Field Summary

Modifier and Type	Field and Description
private Map<AccessControlContext, Reference<AccessControlContext>>	authCache cache of accept-authorized AccessControlContexts
private SecurityManager	cacheSecurityManager References Deprecated `SecurityManager` is deprecated or references (maybe indirectly) at least one deprecated element. security manager which authorized contexts in authCache
private AccessControlContext	okContext References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element. most recently accept-authorized AccessControlContext
private static final int	POST int value of "POST" in ASCII (Java's specified data formats make this once-reviled tactic again socially acceptable)
private String	remoteHost
private Socket	socket

Constructor Summary

Access	Constructor and Description
pack-priv	ConnectionHandler(Socket socket, String remoteHost)

Method Summary

Modifier and Type	Method and Description
pack-priv void	checkAcceptPermission(SecurityManager sm, AccessControlContext acc) References Deprecated `SecurityManager` and `AccessControlContext` are deprecated or reference (maybe indirectly) at least one deprecated element. Verify that the given AccessControlContext has permission to accept this connection.
pack-priv String	getClientHost()
public void	run() Implements java.lang.Runnable.run. Runs this operation.
private void	run0()

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

Field Detail

authCache	back to summary
private Map<AccessControlContext, Reference<AccessControlContext>> authCache cache of accept-authorized AccessControlContexts Annotations @SuppressWarnings:removal

cacheSecurityManager	back to summary
private SecurityManager cacheSecurityManager References Deprecated `SecurityManager` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information. security manager which authorized contexts in authCache Annotations @SuppressWarnings:removal

okContext	back to summary
private AccessControlContext okContext References Deprecated `AccessControlContext` is deprecated or references (maybe indirectly) at least one deprecated element. See corresponding docs for further information. most recently accept-authorized AccessControlContext Annotations @SuppressWarnings:removal

POST	back to summary
private static final int POST int value of "POST" in ASCII (Java's specified data formats make this once-reviled tactic again socially acceptable)

remoteHost	back to summary
private String remoteHost

socket	back to summary
private Socket socket

Constructor Detail

ConnectionHandler	back to summary
pack-priv ConnectionHandler(Socket socket, String remoteHost)

Method Detail

checkAcceptPermission back to summary

pack-priv void checkAcceptPermission(SecurityManager sm, AccessControlContext acc)

References Deprecated

SecurityManager and AccessControlContext are deprecated or reference (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Verify that the given AccessControlContext has permission to accept this connection.

Annotations

@SuppressWarnings:removal

getClientHost	back to summary
pack-priv String getClientHost()

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@SuppressWarnings:removal

run0	back to summary
private void run0() Annotations @SuppressWarnings:fallthrough

public Class TCPTransport

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class TCPTransport.AcceptLoop

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class TCPTransport.ConnectionHandler

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail