Class RpcClient

java.lang.Object

java.util.AbstractCollection<Socket>

java.util.AbstractList<Socket>

java.util.AbstractSequentialList<Socket>

java.util.LinkedList<Socket>

one.nio.pool.Pool<Socket>

one.nio.pool.SocketPool

one.nio.rpc.RpcClient

All Implemented Interfaces:

Closeable, Serializable, AutoCloseable, Cloneable, Iterable<Socket>, InvocationHandler, Collection<Socket>, Deque<Socket>, List<Socket>, Queue<Socket>, SequencedCollection<Socket>, SocketPoolMXBean

public class RpcClient
extends SocketPool
implements InvocationHandler

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
private final StackTraceElement	remoteMarkerElement
protected static final byte[][]	uidLocks

Fields inherited from class SocketPool

connectTimeout, host, port, proxy, readTimeout, sslContext, thinLto, tos

Fields inherited from class Pool

closed, createdCount, fifo, initialCount, keepEmpty, maxCount, timeout, timeouts, waitingThreads

Fields inherited from class AbstractList

modCount

Constructor Summary

Constructors

Constructor	Description
RpcClient(ConnectionString conn)

Method Summary

Modifier and Type	Method	Description
private void	addLocalStack(Throwable e, Object remoteRequest)
Object	invoke(Object request)
Object	invoke(Object request, int timeout)
Object	invoke(Object proxy, Method method, Object... args)
private Object	invokeRaw(Object request, int timeout)
protected Object	invokeServiceRequest(Object request)
protected void	provideSerializer(Serializer serializer)
protected Serializer	requestSerializer(long uid)
private void	sendRequest(Socket socket, byte[] buffer, int timeout)
private byte[]	serialize(Object request)
protected static Object	uidLockFor(long uid)

Methods inherited from class SocketPool

createObject, destroyObject, getBusyCount, getConnectTimeout, getFifo, getIdleCount, getMaxCount, getProxy, getReadTimeout, getSslContext, getTimeout, getTimeouts, getWaitingThreads, name, setConnectTimeout, setFifo, setMaxCount, setProperties, setProxy, setReadTimeout, setSslContext, setTimeout

Methods inherited from class Pool

borrowObject, close, initialize, invalidateAll, invalidateObject, isClosed, returnObject

Methods inherited from class LinkedList

add, add, addAll, addAll, addFirst, addLast, clear, clone, contains, descendingIterator, element, get, getFirst, getLast, indexOf, lastIndexOf, listIterator, offer, offerFirst, offerLast, peek, peekFirst, peekLast, poll, pollFirst, pollLast, pop, push, remove, remove, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, reversed, set, size, spliterator, toArray, toArray

Methods inherited from class AbstractSequentialList

iterator

Methods inherited from class AbstractList

equals, hashCode, listIterator, removeRange, subList

Methods inherited from class AbstractCollection

containsAll, isEmpty, removeAll, retainAll, toString

Methods inherited from class Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface Collection

parallelStream, removeIf, stream, toArray

Methods inherited from interface Deque

iterator

Methods inherited from interface Iterable

forEach

Methods inherited from interface List

containsAll, equals, hashCode, isEmpty, iterator, listIterator, removeAll, replaceAll, retainAll, sort, subList

Methods inherited from interface SocketPoolMXBean

invalidateAll, isClosed

Field Details

uidLocks

protected static final byte[][] uidLocks

remoteMarkerElement

private final StackTraceElement remoteMarkerElement

Constructor Details

RpcClient

public RpcClient(ConnectionString conn)

Method Details

invoke

public Object invoke(Object request)
              throws Exception

Throws:

Exception

invoke

public Object invoke(Object request,
 int timeout)
              throws Exception

Throws:

Exception

addLocalStack

private void addLocalStack(Throwable e,
 Object remoteRequest)

invoke

public Object invoke(Object proxy,
 Method method,
 Object... args)
              throws Exception

Specified by:

invoke in interface InvocationHandler

Throws:

Exception

uidLockFor

protected static Object uidLockFor(long uid)

provideSerializer

protected void provideSerializer(Serializer serializer)
                          throws Exception

Throws:

Exception

requestSerializer

protected Serializer requestSerializer(long uid)
                                throws Exception

Throws:

Exception

invokeServiceRequest

protected Object invokeServiceRequest(Object request)
                               throws Exception

Throws:

Exception

invokeRaw

private Object invokeRaw(Object request,
 int timeout)
                  throws Exception

Throws:

Exception

serialize

private byte[] serialize(Object request)
                  throws IOException

Throws:

IOException

sendRequest

private void sendRequest(Socket socket,
 byte[] buffer,
 int timeout)
                  throws IOException

Throws:

IOException