RpcServer.Responder (Apache HBase 1.2.12 API)

java.lang.Object
- java.lang.Thread
- - org.apache.hadoop.hbase.ipc.RpcServer.Responder

All Implemented Interfaces:

Runnable

Enclosing class:

RpcServer
```
protected class RpcServer.Responder
extends Thread
```

Nested Class Summary
- Nested classes/interfaces inherited from class java.lang.Thread
  Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields
Modifier and Type Field and Description

private Selector writeSelector

private Set<RpcServer.Connection> writingCons
- Fields inherited from class java.lang.Thread
  MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Fields
Modifier and Type	Field and Description
`private Selector`	`writeSelector`
`private Set<RpcServer.Connection>`	`writingCons`

Constructor Summary

Constructors
Constructor and Description

RpcServer.Responder()

Constructors
Constructor and Description
`RpcServer.Responder()`

Method Summary

Methods
Modifier and Type	Method and Description
`private void`	`doAsyncWrite(SelectionKey key)`
`(package private) void`	`doRespond(RpcServer.Call call)`
`private void`	`doRunLoop()`
`private boolean`	`processAllResponses(RpcServer.Connection connection)` Process all the responses for this connection
`private boolean`	`processResponse(RpcServer.Call call)` Process the response for this call.
`private long`	`purge(long lastPurgeTime)` If there were some calls that have not been sent out for a long time, we close the connection.
`void`	`registerForWrite(RpcServer.Connection c)` Add a connection to the list that want to write,
`private void`	`registerWrites()` Take the list of the connections that want to write, and register them in the selector.
`void`	`run()`

Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

- Field Detail
  - writeSelector
```
private final Selector writeSelector
```
  - writingCons
```
private final Set<RpcServer.Connection> writingCons
```
- Constructor Detail
  - RpcServer.Responder
```
RpcServer.Responder()
              throws IOException
```
    Throws:
    
    IOException
- Method Detail
  - run
```
public void run()
```
    Specified by:
    
    run in interface Runnable
    
    Overrides:
    
    run in class Thread
  - registerWrites
```
private void registerWrites()
```
    Take the list of the connections that want to write, and register them in the selector.
  - registerForWrite
```
public void registerForWrite(RpcServer.Connection c)
```
    Add a connection to the list that want to write,
  - doRunLoop
```
private void doRunLoop()
```
  - purge
```
private long purge(long lastPurgeTime)
```
    If there were some calls that have not been sent out for a long time, we close the connection.
    
    Returns:
    the time of the purge.
  - doAsyncWrite
```
private void doAsyncWrite(SelectionKey key)
                   throws IOException
```
    Throws:
    
    IOException
  - processResponse
```
private boolean processResponse(RpcServer.Call call)
                         throws IOException
```
    Process the response for this call. You need to have the lock on RpcServer.Connection.responseWriteLock
    
    Parameters:
    call - the call
    
    Returns:
    true if we proceed the call fully, false otherwise.
    
    Throws:
    
    IOException
  - processAllResponses
```
private boolean processAllResponses(RpcServer.Connection connection)
                             throws IOException
```
    Process all the responses for this connection
    
    Returns:
    true if all the calls were processed or that someone else is doing it. false if there * is still some work to do. In this case, we expect the caller to delay us.
    
    Throws:
    
    IOException
  - doRespond
```
void doRespond(RpcServer.Call call)
         throws IOException
```
    Throws:
    
    IOException

Class RpcServer.Responder

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Field Summary

Fields inherited from class java.lang.Thread

Constructor Summary

Method Summary

Methods inherited from class java.lang.Thread

Methods inherited from class java.lang.Object

Field Detail

writeSelector

writingCons

Constructor Detail

RpcServer.Responder

Method Detail

run

registerWrites

registerForWrite

doRunLoop

purge

doAsyncWrite

processResponse

processAllResponses

doRespond