JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
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
Overview
Package
Class
Use
Tree
Deprecated
Index
Help
Prev
Next
Frames
No Frames
All Classes
Copyright © 2013–2017. All rights reserved.