|
Push Down Method protected closeConnection(connection Connection) : void from class org.apache.hadoop.hbase.ipc.RpcServer to protected closeConnection(connection Connection) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method public getListenerAddress() : InetSocketAddress from class org.apache.hadoop.hbase.ipc.RpcServer to public getListenerAddress() : InetSocketAddress from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method protected processRequest(buf ByteBuff) : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to protected processRequest(buf ByteBuff) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method private setupResponse(response ByteArrayOutputStream, call Call, t Throwable, error String) : void from class org.apache.hadoop.hbase.ipc.RpcServer to private setupResponse(response ByteArrayOutputStream, call Call, t Throwable, error String) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method private processConnectionHeader(buf ByteBuff) : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private processConnectionHeader(buf ByteBuff) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method public setLastContact(lastContact long) : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to public setLastContact(lastContact long) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method private saslReadAndProcess(saslToken ByteBuff) : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private saslReadAndProcess(saslToken ByteBuff) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method protected incRpcCount() : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to protected incRpcCount() : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method private isIdle() : boolean from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private isIdle() : boolean from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method protected getConnection(channel SocketChannel, time long) : Connection from class org.apache.hadoop.hbase.ipc.RpcServer to protected getConnection(channel SocketChannel, time long) : Connection from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method private channelIO(readCh ReadableByteChannel, writeCh WritableByteChannel, buf ByteBuffer) : int from class org.apache.hadoop.hbase.ipc.RpcServer to protected channelIO(readCh ReadableByteChannel, writeCh WritableByteChannel, buf ByteBuffer) : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method private doBadPreambleHandling(msg String, e Exception) : int from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private doBadPreambleHandling(msg String, e Exception) : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method public readAndProcess() : int from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to public readAndProcess() : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method private read4Bytes() : int from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private read4Bytes() : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method private doRawSaslReply(status SaslStatus, rv Writable, errorClass String, error String) : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private doRawSaslReply(status SaslStatus, rv Writable, errorClass String, error String) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method protected channelRead(channel ReadableByteChannel, buffer ByteBuffer) : int from class org.apache.hadoop.hbase.ipc.RpcServer to protected channelRead(channel ReadableByteChannel, buffer ByteBuffer) : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method private authorizeConnection() : boolean from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private authorizeConnection() : boolean from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method private readPreamble() : int from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private readPreamble() : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method public getLastContact() : long from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to public getLastContact() : long from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method private disposeSasl() : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private disposeSasl() : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method public start() : void from class org.apache.hadoop.hbase.ipc.RpcServer to public start() : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method public call(service BlockingService, md MethodDescriptor, param Message, cellScanner CellScanner, receiveTime long, status MonitoredRPCHandler, startTime long, timeout int) : Pair<Message,CellScanner> from class org.apache.hadoop.hbase.ipc.RpcServer to public call(service BlockingService, md MethodDescriptor, param Message, cellScanner CellScanner, receiveTime long, status MonitoredRPCHandler, startTime long, timeout int) : Pair<Message,CellScanner> from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method public setSocketSendBufSize(size int) : void from class org.apache.hadoop.hbase.ipc.RpcServer to public setSocketSendBufSize(size int) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method private doConnectionHeaderResponse(wrappedCipherMetaData byte[]) : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private doConnectionHeaderResponse(wrappedCipherMetaData byte[]) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method private doBadPreambleHandling(msg String) : int from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private doBadPreambleHandling(msg String) : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method public call(service BlockingService, md MethodDescriptor, param Message, cellScanner CellScanner, receiveTime long, status MonitoredRPCHandler) : Pair<Message,CellScanner> from class org.apache.hadoop.hbase.ipc.RpcServer to public call(service BlockingService, md MethodDescriptor, param Message, cellScanner CellScanner, receiveTime long, status MonitoredRPCHandler) : Pair<Message,CellScanner> from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method private initByteBuffToReadInto(length int) : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private initByteBuffToReadInto(length int) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method public getNumOpenConnections() : int from class org.apache.hadoop.hbase.ipc.RpcServer to public getNumOpenConnections() : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method protected channelWrite(channel GatheringByteChannel, bufferChain BufferChain) : long from class org.apache.hadoop.hbase.ipc.RpcServer to protected channelWrite(channel GatheringByteChannel, bufferChain BufferChain) : long from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method public bind(socket ServerSocket, address InetSocketAddress, backlog int) : void from class org.apache.hadoop.hbase.ipc.RpcServer to public bind(socket ServerSocket, address InetSocketAddress, backlog int) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method private process() : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private process() : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method public disconnectSince() : long from class org.apache.hadoop.hbase.ipc.RpcServer.Call to public disconnectSince() : long from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Call |
From |
To |
|
Push Down Method protected channelDataRead(channel ReadableByteChannel, buf ByteBuff) : int from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to protected channelDataRead(channel ReadableByteChannel, buf ByteBuff) : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method protected close() : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to protected close() : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method private responseConnectionHeader(chrBuilder RPCProtos.ConnectionHeaderResponse.Builder) : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private responseConnectionHeader(chrBuilder RPCProtos.ConnectionHeaderResponse.Builder) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method private processUnwrappedData(inBuf byte[]) : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private processUnwrappedData(inBuf byte[]) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method public join() : void from class org.apache.hadoop.hbase.ipc.RpcServer to public join() : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method protected decRpcCount() : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to protected decRpcCount() : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method public sendResponseIfReady() : void from class org.apache.hadoop.hbase.ipc.RpcServer.Call to public sendResponseIfReady() : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Call |
From |
To |
|
Push Down Method public Connection(channel SocketChannel, lastContact long) from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to public Connection(channel SocketChannel, lastContact long) from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Method public stop() : void from class org.apache.hadoop.hbase.ipc.RpcServer to public stop() : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Method private processOneRpc(buf ByteBuff) : void from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private processOneRpc(buf ByteBuff) : void from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute private unwrappedData : ByteBuffer from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private unwrappedData : ByteBuffer from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute private unwrappedDataLengthBuffer : ByteBuffer from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private unwrappedDataLengthBuffer : ByteBuffer from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute private listener : Listener from class org.apache.hadoop.hbase.ipc.RpcServer to private listener : Listener from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Attribute protected port : int from class org.apache.hadoop.hbase.ipc.RpcServer to protected port : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Attribute private connectionManager : ConnectionManager from class org.apache.hadoop.hbase.ipc.RpcServer to private connectionManager : ConnectionManager from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Attribute private dataLengthBuffer : ByteBuffer from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private dataLengthBuffer : ByteBuffer from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute private authFailedCall : Call from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private authFailedCall : Call from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute protected responseQueue : ConcurrentLinkedDeque<Call> from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to protected responseQueue : ConcurrentLinkedDeque<Call> from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute protected socket : Socket from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to protected socket : Socket from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute private saslCall : Call from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private saslCall : Call from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute protected address : InetSocketAddress from class org.apache.hadoop.hbase.ipc.RpcServer to protected address : InetSocketAddress from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Attribute private NIO_BUFFER_LIMIT : int from class org.apache.hadoop.hbase.ipc.RpcServer to private NIO_BUFFER_LIMIT : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Attribute private responseWriteLock : Lock from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private responseWriteLock : Lock from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute private setConnectionHeaderResponseCall : Call from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private setConnectionHeaderResponseCall : Call from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute protected responder : Responder from class org.apache.hadoop.hbase.ipc.RpcServer to protected responder : Responder from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Attribute protected responder : Responder from class org.apache.hadoop.hbase.ipc.RpcServer.Call to protected responder : Responder from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Call |
From |
To |
|
Push Down Attribute protected channel : SocketChannel from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to protected channel : SocketChannel from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute private rpcCount : LongAdder from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private rpcCount : LongAdder from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute private data : ByteBuff from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private data : ByteBuff from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute protected purgeTimeout : long from class org.apache.hadoop.hbase.ipc.RpcServer to protected purgeTimeout : long from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Attribute private lastContact : long from class org.apache.hadoop.hbase.ipc.RpcServer.Connection to private lastContact : long from class org.apache.hadoop.hbase.ipc.SimpleRpcServer.Connection |
From |
To |
|
Push Down Attribute protected socketSendBufferSize : int from class org.apache.hadoop.hbase.ipc.RpcServer to protected socketSendBufferSize : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |
|
Push Down Attribute private readThreads : int from class org.apache.hadoop.hbase.ipc.RpcServer to private readThreads : int from class org.apache.hadoop.hbase.ipc.SimpleRpcServer |
From |
To |