Skip navigation links
A B C D E F G H I J M N O P R S T U W 

A

AbstractSelectorThread(String) - Constructor for class com.thinkaurelius.thrift.TDisruptorServer.AbstractSelectorThread
 
AcceptorThread(String, TNonblockingServerTransport) - Constructor for class com.thinkaurelius.thrift.TDisruptorServer.AcceptorThread
Set up the thread that will handle the non-blocking accepts.
allocate(int, boolean) - Static method in class com.thinkaurelius.thrift.util.mem.Buffer
 
alwaysReallocateBuffers(boolean) - Method in class com.thinkaurelius.thrift.TDisruptorServer.Args
 
Args(TNonblockingServerTransport) - Constructor for class com.thinkaurelius.thrift.TDisruptorServer.Args
 

B

beforeClose(Message) - Method in class com.thinkaurelius.thrift.TDisruptorServer
Allows derived classes to react when a connection is closed.
beforeInvoke(Message) - Method in class com.thinkaurelius.thrift.TDisruptorServer
All implementations should use this method to provide custom behaviour in pre-invoke stage.
buf - Variable in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
The byte array containing the bytes written.
Buffer - Class in com.thinkaurelius.thrift.util.mem
 
Buffer() - Constructor for class com.thinkaurelius.thrift.util.mem.Buffer
 
buffer - Variable in class com.thinkaurelius.thrift.util.mem.Buffer
 

C

cancel() - Method in class com.thinkaurelius.thrift.Message
 
changeSelectInterests() - Method in class com.thinkaurelius.thrift.Message
Give this Message a chance to change its interests.
cleanupSelectionKey(SelectionKey) - Method in class com.thinkaurelius.thrift.TDisruptorServer.AbstractSelectorThread
 
clear() - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 
close() - Method in class com.thinkaurelius.thrift.Message
Shut the connection down.
close() - Method in class com.thinkaurelius.thrift.TDisruptorServer.AbstractSelectorThread
 
close() - Method in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
Closes this transport.
close() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
com.thinkaurelius.thrift - package com.thinkaurelius.thrift
 
com.thinkaurelius.thrift.util - package com.thinkaurelius.thrift.util
 
com.thinkaurelius.thrift.util.mem - package com.thinkaurelius.thrift.util.mem
 
consumeBuffer(int) - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
count - Variable in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
The number of bytes written.

D

dispatchInvoke(Message) - Method in class com.thinkaurelius.thrift.TDisruptorServer.SelectorThread
 

E

execute() - Method in class com.thinkaurelius.thrift.Message.Invocation
 

F

FACTORY - Static variable in class com.thinkaurelius.thrift.Message.Invocation
 
Factory() - Constructor for class com.thinkaurelius.thrift.util.TBinaryProtocol.Factory
 
Factory(boolean, boolean) - Constructor for class com.thinkaurelius.thrift.util.TBinaryProtocol.Factory
 
FastMemoryOutputTransport - Class in com.thinkaurelius.thrift.util.mem
 
FastMemoryOutputTransport(int, boolean) - Constructor for class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
Constructs a new FastMemoryOutputTransport with a default size of size bytes.
free() - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 

G

get(int) - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 
getBuffer() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
getBufferPosition() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
getBytesRemainingInBuffer() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
getInputTransport() - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 
getInt(int) - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 
getMessage() - Method in class com.thinkaurelius.thrift.Message.Invocation
 
getNumberOfSelectors() - Method in class com.thinkaurelius.thrift.TDisruptorServer
 
getNumberOfSelectors() - Method in interface com.thinkaurelius.thrift.TDisruptorServerMBean
 
getProtocol(TTransport) - Method in class com.thinkaurelius.thrift.util.TBinaryProtocol.Factory
 
getRingBufferSize() - Method in class com.thinkaurelius.thrift.TDisruptorServer
 
getRingBufferSize() - Method in class com.thinkaurelius.thrift.TDisruptorServer.SelectorThread
 
getRingBufferSize() - Method in interface com.thinkaurelius.thrift.TDisruptorServerMBean
 
gracefullyShutdownInvokerPool() - Method in class com.thinkaurelius.thrift.TDisruptorServer
 

H

handleRead(Message) - Method in class com.thinkaurelius.thrift.TDisruptorServer.SelectorThread
 
handleWrite(Message) - Method in class com.thinkaurelius.thrift.TDisruptorServer.SelectorThread
 

I

inputProtocolFactory - Variable in class com.thinkaurelius.thrift.util.ThriftFactories
 
inputTransportFactory - Variable in class com.thinkaurelius.thrift.util.ThriftFactories
 
Invocation() - Constructor for class com.thinkaurelius.thrift.Message.Invocation
 
invocationExecutor(ThreadPoolExecutor) - Method in class com.thinkaurelius.thrift.TDisruptorServer.Args
Executor if set takes precedence over numWorkersPerSelector.
InvocationHandler() - Constructor for class com.thinkaurelius.thrift.TDisruptorServer.InvocationHandler
 
invoke() - Method in class com.thinkaurelius.thrift.Message
Actually invoke the method signified by this Message.
isFrameFullyRead() - Method in class com.thinkaurelius.thrift.Message
 
isFullyStreamed() - Method in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
 
isHeapBasedAllocationUsed() - Method in class com.thinkaurelius.thrift.TDisruptorServer
 
isHeapBasedAllocationUsed() - Method in interface com.thinkaurelius.thrift.TDisruptorServerMBean
 
isOpen() - Method in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
 
isOpen() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
isReadyToRead() - Method in class com.thinkaurelius.thrift.Message
 
isReadyToWrite() - Method in class com.thinkaurelius.thrift.Message
 
isStopped() - Method in class com.thinkaurelius.thrift.TDisruptorServer.AbstractSelectorThread
 
isStopped() - Method in class com.thinkaurelius.thrift.TDisruptorServer
 

J

joinSelector() - Method in class com.thinkaurelius.thrift.TDisruptorServer
 

M

maxFrameSizeInBytes(int) - Method in class com.thinkaurelius.thrift.TDisruptorServer.Args
 
maxFrameSizeInBytes - Variable in class com.thinkaurelius.thrift.util.ThriftFactories
 
MBEAN_NAME - Static variable in class com.thinkaurelius.thrift.TDisruptorServer
 
Message - Class in com.thinkaurelius.thrift
Class that implements a sort of state machine around the interaction with a client and an invoker.
Message(TNonblockingTransport, SelectionKey, ThriftFactories, boolean, boolean) - Constructor for class com.thinkaurelius.thrift.Message
 
message - Variable in class com.thinkaurelius.thrift.Message.Invocation
 
Message.Invocation - Class in com.thinkaurelius.thrift
 

N

nextSelector() - Method in class com.thinkaurelius.thrift.TDisruptorServer.RandomSelectorLoadBalancer
 
nextSelector() - Method in interface com.thinkaurelius.thrift.TDisruptorServer.SelectorLoadBalancer
 
numAcceptors(int) - Method in class com.thinkaurelius.thrift.TDisruptorServer.Args
 
numSelectors(int) - Method in class com.thinkaurelius.thrift.TDisruptorServer.Args
 
numWorkersPerSelector(int) - Method in class com.thinkaurelius.thrift.TDisruptorServer.Args
 

O

onEvent(Message.Invocation) - Method in class com.thinkaurelius.thrift.TDisruptorServer.InvocationHandler
 
open() - Method in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
 
open() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
outputProtocolFactory - Variable in class com.thinkaurelius.thrift.util.ThriftFactories
 
outputTransportFactory - Variable in class com.thinkaurelius.thrift.util.ThriftFactories
 

P

processKey(SelectionKey) - Method in class com.thinkaurelius.thrift.TDisruptorServer.AbstractSelectorThread
Process each individual key that reported ready state
processKey(SelectionKey) - Method in class com.thinkaurelius.thrift.TDisruptorServer.AcceptorThread
 
processKey(SelectionKey) - Method in class com.thinkaurelius.thrift.TDisruptorServer.SelectorThread
 
processorFactory - Variable in class com.thinkaurelius.thrift.util.ThriftFactories
 
put(int, byte) - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 

R

RandomSelectorLoadBalancer(TDisruptorServer.SelectorThread[]) - Constructor for class com.thinkaurelius.thrift.TDisruptorServer.RandomSelectorLoadBalancer
 
read() - Method in class com.thinkaurelius.thrift.Message
Give this Message a chance to read.
read(byte[], int, int) - Method in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
 
read(byte[], int, int) - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
read() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
readBinary() - Method in class com.thinkaurelius.thrift.util.TBinaryProtocol
 
readBoolean() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
readByte() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
readByte() - Method in class com.thinkaurelius.thrift.util.TBinaryProtocol
 
readBytes(int) - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
readDouble() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
readDouble() - Method in class com.thinkaurelius.thrift.util.TBinaryProtocol
 
readFrom(TNonblockingTransport) - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 
readFully(byte[]) - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
readFully(byte[], int, int) - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
readI16() - Method in class com.thinkaurelius.thrift.util.TBinaryProtocol
 
readI32() - Method in class com.thinkaurelius.thrift.util.TBinaryProtocol
 
readI64() - Method in class com.thinkaurelius.thrift.util.TBinaryProtocol
 
readInt() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
readLong() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
readShort() - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
readString() - Method in class com.thinkaurelius.thrift.util.TBinaryProtocol
 
readStringBody(int) - Method in class com.thinkaurelius.thrift.util.TBinaryProtocol
 
reallocate(int) - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 
remaining() - Method in class com.thinkaurelius.thrift.util.mem.Buffer
Buffers should only be accessed by absolute positions, this method is for convenience when buffer is passed to TTransport implementation
requestInvoke(AbstractNonblockingServer.FrameBuffer) - Method in class com.thinkaurelius.thrift.TDisruptorServer
 
responseReady() - Method in class com.thinkaurelius.thrift.Message
 
ringSizePerSelector(int) - Method in class com.thinkaurelius.thrift.TDisruptorServer.Args
 
run() - Method in class com.thinkaurelius.thrift.TDisruptorServer.AbstractSelectorThread
 

S

selector - Variable in class com.thinkaurelius.thrift.TDisruptorServer.AbstractSelectorThread
 
selectorIterationComplete() - Method in class com.thinkaurelius.thrift.TDisruptorServer.AbstractSelectorThread
Called after each selector event loop completion, useful for booking (e.g.
selectorIterationComplete() - Method in class com.thinkaurelius.thrift.TDisruptorServer.AcceptorThread
 
selectorIterationComplete() - Method in class com.thinkaurelius.thrift.TDisruptorServer.SelectorThread
 
SelectorThread(String, int, ThreadPoolExecutor, int, boolean) - Constructor for class com.thinkaurelius.thrift.TDisruptorServer.SelectorThread
Set up the thread that will handle the non-blocking reads, and writes.
setBuffer(ByteBuffer) - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 
setBuffer(ByteBuffer, ByteOrder) - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 
setMessage(Message) - Method in class com.thinkaurelius.thrift.Message.Invocation
 
shutdown() - Method in class com.thinkaurelius.thrift.TDisruptorServer.SelectorThread
 
size() - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 
size() - Method in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
Returns the total number of bytes written to this transport so far.
startThreads() - Method in class com.thinkaurelius.thrift.TDisruptorServer
 
stop() - Method in class com.thinkaurelius.thrift.TDisruptorServer
 
streamPos - Variable in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
 
streamTo(TNonblockingTransport) - Method in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
Start writing accumulated content to the given transport or continue from the previous stop point (this method is stateful).
subscribe(TNonblockingTransport) - Method in class com.thinkaurelius.thrift.TDisruptorServer.SelectorThread
 

T

TBinaryProtocol - Class in com.thinkaurelius.thrift.util
Thrift original TBinaryProtocol implementation relies on the fact that all TTransport instances are byte array backed, so for all it's operations they can just use that array, requesting it using TTransport.getBuffer().
TBinaryProtocol(TMemoryInputTransport) - Constructor for class com.thinkaurelius.thrift.util.TBinaryProtocol
 
TBinaryProtocol(TMemoryInputTransport, boolean, boolean) - Constructor for class com.thinkaurelius.thrift.util.TBinaryProtocol
 
TBinaryProtocol.Factory - Class in com.thinkaurelius.thrift.util
 
TDisruptorServer - Class in com.thinkaurelius.thrift
 
TDisruptorServer(TDisruptorServer.Args) - Constructor for class com.thinkaurelius.thrift.TDisruptorServer
 
TDisruptorServer.AbstractSelectorThread - Class in com.thinkaurelius.thrift
 
TDisruptorServer.AcceptorThread - Class in com.thinkaurelius.thrift
 
TDisruptorServer.Args - Class in com.thinkaurelius.thrift
 
TDisruptorServer.InvocationHandler - Class in com.thinkaurelius.thrift
 
TDisruptorServer.RandomSelectorLoadBalancer - Class in com.thinkaurelius.thrift
 
TDisruptorServer.SelectorLoadBalancer - Interface in com.thinkaurelius.thrift
 
TDisruptorServer.SelectorThread - Class in com.thinkaurelius.thrift
 
TDisruptorServerMBean - Interface in com.thinkaurelius.thrift
 
thriftFactories - Variable in class com.thinkaurelius.thrift.Message
 
ThriftFactories - Class in com.thinkaurelius.thrift.util
 
ThriftFactories(TTransportFactory, TTransportFactory, TProtocolFactory, TProtocolFactory, TProcessorFactory, int) - Constructor for class com.thinkaurelius.thrift.util.ThriftFactories
 
TMemoryInputTransport - Class in com.thinkaurelius.thrift.util.mem
 
TMemoryInputTransport(ByteBuffer) - Constructor for class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
toString() - Method in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
Returns the contents of this ByteArrayOutputStream as a string.
transport - Variable in class com.thinkaurelius.thrift.Message
 

U

useHeapBasedAllocation(boolean) - Method in class com.thinkaurelius.thrift.TDisruptorServer.Args
 
useHeapBasedAllocation(boolean) - Method in class com.thinkaurelius.thrift.TDisruptorServer
 
useHeapBasedAllocation(boolean) - Method in interface com.thinkaurelius.thrift.TDisruptorServerMBean
 

W

waitForShutdown() - Method in class com.thinkaurelius.thrift.TDisruptorServer
 
wakeupSelector() - Method in class com.thinkaurelius.thrift.TDisruptorServer.AbstractSelectorThread
 
write() - Method in class com.thinkaurelius.thrift.Message
Give this Message a chance to write its output to the final client.
write(byte[], int, int) - Method in class com.thinkaurelius.thrift.util.mem.FastMemoryOutputTransport
Writes count bytes from the byte buffer buffer starting at offset index to this stream.
write(byte[], int, int) - Method in class com.thinkaurelius.thrift.util.mem.TMemoryInputTransport
 
writeTo(TNonblockingTransport, int, int) - Method in class com.thinkaurelius.thrift.util.mem.Buffer
 
A B C D E F G H I J M N O P R S T U W 
Skip navigation links

Copyright © 2013–2017. All rights reserved.