alluxio.network.thrift

Class SocketTrackingTServerSocket

java.lang.Object

org.apache.thrift.transport.TServerTransport

org.apache.thrift.transport.TServerSocket

alluxio.network.thrift.SocketTrackingTServerSocket

All Implemented Interfaces:

Closeable, AutoCloseable

public class SocketTrackingTServerSocket
extends org.apache.thrift.transport.TServerSocket

Extension of TServerSocket which tracks all accepted sockets and closes them when the server socket is closed.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.thrift.transport.TServerSocket

org.apache.thrift.transport.TServerSocket.ServerSocketTransportArgs

Nested classes/interfaces inherited from class org.apache.thrift.transport.TServerTransport

org.apache.thrift.transport.TServerTransport.AbstractServerTransportArgs<T extends org.apache.thrift.transport.TServerTransport.AbstractServerTransportArgs<T>>

Constructor Summary

Constructors

Constructor and Description
SocketTrackingTServerSocket(org.apache.thrift.transport.TServerSocket.ServerSocketTransportArgs args)

Method Summary

Modifier and Type	Method and Description
org.apache.thrift.transport.TSocket	acceptImpl()
void	close()

Methods inherited from class org.apache.thrift.transport.TServerSocket

getServerSocket, interrupt, listen

Methods inherited from class org.apache.thrift.transport.TServerTransport

accept

Methods inherited from class java.lang.Object

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

Constructor Detail

SocketTrackingTServerSocket

public SocketTrackingTServerSocket(org.apache.thrift.transport.TServerSocket.ServerSocketTransportArgs args)
                            throws org.apache.thrift.transport.TTransportException

Parameters:

args - the arguments for creating the server socket

Throws:

org.apache.thrift.transport.TTransportException

Method Detail

acceptImpl

public org.apache.thrift.transport.TSocket acceptImpl()
                                               throws org.apache.thrift.transport.TTransportException

Overrides:

acceptImpl in class org.apache.thrift.transport.TServerSocket

Throws:

org.apache.thrift.transport.TTransportException

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class org.apache.thrift.transport.TServerSocket