A B C D E F G H I J M N O P R S T U V Z

A

appendArrival(Arrival) - Method in class chat.dim.mtp.MemPool

appendArrival(Arrival) - Method in interface chat.dim.mtp.Pool

Append an arrival task into the pool after received something

appendDeparture(Departure) - Method in class chat.dim.mtp.MemPool

appendDeparture(Departure) - Method in interface chat.dim.mtp.Pool

Append a departure task into the pool after sent.

Arrival - Class in chat.dim.mtp.task

Data package received (waiting process)

Arrival(Data, SocketAddress, SocketAddress) - Constructor for class chat.dim.mtp.task.Arrival

Assemble - Class in chat.dim.mtp.task

Message fragments received (waiting assemble)

Assemble(Package, SocketAddress, SocketAddress) - Constructor for class chat.dim.mtp.task.Assemble

B

body - Variable in class chat.dim.mtp.protocol.Package

bodyLength - Variable in class chat.dim.mtp.protocol.Header

C

chat.dim.mtp - package chat.dim.mtp

chat.dim.mtp.protocol - package chat.dim.mtp.protocol

chat.dim.mtp.task - package chat.dim.mtp.task

checkFragment(Package, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.PeerHandler

Check message fragment from the source address, if too many incomplete tasks from the same address, return False to reject it to avoid 'DDoS' attack.

close() - Method in class chat.dim.mtp.Peer

Command - Static variable in class chat.dim.mtp.protocol.DataType

CommandRespond - Static variable in class chat.dim.mtp.protocol.DataType

create(DataType, TransactionID, int, int, int) - Static method in class chat.dim.mtp.protocol.Header

create(DataType, TransactionID, int, int) - Static method in class chat.dim.mtp.protocol.Header

create(DataType, int, int) - Static method in class chat.dim.mtp.protocol.Header

create(DataType, TransactionID) - Static method in class chat.dim.mtp.protocol.Header

create(DataType) - Static method in class chat.dim.mtp.protocol.Header

create(DataType, TransactionID, int) - Static method in class chat.dim.mtp.protocol.Header

create(DataType, int) - Static method in class chat.dim.mtp.protocol.Header

create(DataType, TransactionID, int, int, int, Data) - Static method in class chat.dim.mtp.protocol.Package

create(DataType, TransactionID, int, int, Data) - Static method in class chat.dim.mtp.protocol.Package

create(DataType, int, int, Data) - Static method in class chat.dim.mtp.protocol.Package

create(DataType, TransactionID, Data) - Static method in class chat.dim.mtp.protocol.Package

create(DataType, Data) - Static method in class chat.dim.mtp.protocol.Package

create(DataType, TransactionID, int, Data) - Static method in class chat.dim.mtp.protocol.Package

create(DataType, int, Data) - Static method in class chat.dim.mtp.protocol.Package

D

DataType - Class in chat.dim.mtp.protocol

DataType(byte, String) - Constructor for class chat.dim.mtp.protocol.DataType

DataType(int, String) - Constructor for class chat.dim.mtp.protocol.DataType

deleteDeparture(Package, SocketAddress, SocketAddress) - Method in class chat.dim.mtp.MemPool

deleteDeparture(Package, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.Pool

Delete the departure task with 'trans_id' in the response.

Departure - Class in chat.dim.mtp.task

Package(s) to sent out (waiting response)

Departure(List<Package>, SocketAddress, SocketAddress) - Constructor for class chat.dim.mtp.task.Departure

destination - Variable in class chat.dim.mtp.task.Arrival

destination - Variable in class chat.dim.mtp.task.Assemble

destination - Variable in class chat.dim.mtp.task.Departure

discardFragments() - Method in class chat.dim.mtp.MemPool

Remove all expired fragments

discardFragments() - Method in interface chat.dim.mtp.Pool

Remove all expired fragments that belong to the incomplete messages, which had waited a long time but still some fragments missed.

E

equals(Object) - Method in class chat.dim.mtp.protocol.DataType

equals(int) - Method in class chat.dim.mtp.protocol.DataType

EXPIRES - Static variable in class chat.dim.mtp.MemPool

1.

F

fragments - Variable in class chat.dim.mtp.task.Assemble

G

generate() - Static method in class chat.dim.mtp.protocol.TransactionID

getCountOfArrivals() - Method in class chat.dim.mtp.MemPool

getCountOfArrivals() - Method in interface chat.dim.mtp.Pool

Check how many arrivals waiting in the pool

getDelegate() - Method in class chat.dim.mtp.Peer

getHandler() - Method in class chat.dim.mtp.Peer

getInstance(byte) - Static method in class chat.dim.mtp.protocol.DataType

getInstance(int) - Static method in class chat.dim.mtp.protocol.DataType

getLastTime() - Method in class chat.dim.mtp.task.Assemble

getLastTime() - Method in class chat.dim.mtp.task.Departure

H

hashCode() - Method in class chat.dim.mtp.protocol.DataType

head - Variable in class chat.dim.mtp.protocol.Package

Header - Class in chat.dim.mtp.protocol

Header(Header) - Constructor for class chat.dim.mtp.protocol.Header

Header(Data, DataType, TransactionID, int, int, int) - Constructor for class chat.dim.mtp.protocol.Header

Create package header

Header(Data, DataType, TransactionID, int) - Constructor for class chat.dim.mtp.protocol.Header

Header(Data, DataType, TransactionID) - Constructor for class chat.dim.mtp.protocol.Header

I

insert(Package, SocketAddress, SocketAddress) - Method in class chat.dim.mtp.task.Assemble

insertFragment(Package, SocketAddress, SocketAddress) - Method in class chat.dim.mtp.MemPool

insertFragment(Package, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.Pool

Add a fragment package into the pool for MessageFragment received.

isCompleted() - Method in class chat.dim.mtp.task.Assemble

J

join(List<Package>) - Static method in class chat.dim.mtp.protocol.Package

Join sorted packages' body data together

M

MAGIC_CODE - Static variable in class chat.dim.mtp.protocol.Header

MAX_BODY_LENGTH - Static variable in class chat.dim.mtp.protocol.Header

MAX_PAGES - Static variable in class chat.dim.mtp.protocol.Header

maxRetries - Variable in class chat.dim.mtp.task.Departure

MemPool - Class in chat.dim.mtp

MemPool() - Constructor for class chat.dim.mtp.MemPool

Message - Static variable in class chat.dim.mtp.protocol.DataType

MessageFragment - Static variable in class chat.dim.mtp.protocol.DataType

MessageRespond - Static variable in class chat.dim.mtp.protocol.DataType

N

name - Variable in class chat.dim.mtp.protocol.DataType

O

offset - Variable in class chat.dim.mtp.protocol.Header

onReceivedCommand(Data, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.PeerHandler

Received command data from source address.

onReceivedError(Data, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.PeerHandler

Received error data from source address.

onReceivedMessage(Data, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.PeerHandler

Received command data from source address.

onSendCommandSuccess(TransactionID, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.PeerHandler

Callback for send command success

onSendCommandTimeout(TransactionID, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.PeerHandler

Callback for send command failed

onSendMessageSuccess(TransactionID, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.PeerHandler

Callback for send message success

onSendMessageTimeout(TransactionID, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.PeerHandler

Callback for send message failed

OPTIMAL_BODY_LENGTH - Static variable in class chat.dim.mtp.protocol.Package

P

Package - Class in chat.dim.mtp.protocol

Package(Data, Header, Data) - Constructor for class chat.dim.mtp.protocol.Package

Package(Header, Data) - Constructor for class chat.dim.mtp.protocol.Package

Package(Header) - Constructor for class chat.dim.mtp.protocol.Package

packages - Variable in class chat.dim.mtp.task.Departure

pages - Variable in class chat.dim.mtp.protocol.Header

pages - Variable in class chat.dim.mtp.task.Assemble

parse(Data) - Static method in class chat.dim.mtp.protocol.Header

parse(Data) - Static method in class chat.dim.mtp.protocol.Package

parse(Data) - Static method in class chat.dim.mtp.protocol.TransactionID

payload - Variable in class chat.dim.mtp.task.Arrival

Peer - Class in chat.dim.mtp

Peer(Pool) - Constructor for class chat.dim.mtp.Peer

Peer() - Constructor for class chat.dim.mtp.Peer

PeerDelegate - Interface in chat.dim.mtp

PeerHandler - Interface in chat.dim.mtp

pool - Variable in class chat.dim.mtp.Peer

Pool - Interface in chat.dim.mtp

Task Pool ~~~~~~~~~ Cache for departure, arrival tasks and message fragments

R

recycleFragments(List<Package>, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.PeerHandler

Recycle incomplete message fragments from source address.

run() - Method in class chat.dim.mtp.Peer

S

sendCommand(Package, SocketAddress, SocketAddress) - Method in class chat.dim.mtp.Peer

sendData(Data, SocketAddress, SocketAddress) - Method in interface chat.dim.mtp.PeerDelegate

Send data to destination address

sendMessage(Package, SocketAddress, SocketAddress) - Method in class chat.dim.mtp.Peer

setDelegate(PeerDelegate) - Method in class chat.dim.mtp.Peer

setHandler(PeerHandler) - Method in class chat.dim.mtp.Peer

shiftExpiredDeparture() - Method in class chat.dim.mtp.MemPool

shiftExpiredDeparture() - Method in interface chat.dim.mtp.Pool

Gat one departure task from the pool for sending.

shiftFirstArrival() - Method in class chat.dim.mtp.MemPool

shiftFirstArrival() - Method in interface chat.dim.mtp.Pool

Get one arrival task from the pool for processing

sn - Variable in class chat.dim.mtp.protocol.Header

sn - Variable in class chat.dim.mtp.task.Assemble

sn - Variable in class chat.dim.mtp.task.Departure

sort(List<Package>) - Static method in class chat.dim.mtp.protocol.Package

source - Variable in class chat.dim.mtp.task.Arrival

source - Variable in class chat.dim.mtp.task.Assemble

source - Variable in class chat.dim.mtp.task.Departure

split() - Method in class chat.dim.mtp.protocol.Package

Split large message package

start() - Method in class chat.dim.mtp.Peer

T

toString() - Method in class chat.dim.mtp.protocol.DataType

TransactionID - Class in chat.dim.mtp.protocol

TransactionID(Data) - Constructor for class chat.dim.mtp.protocol.TransactionID

type - Variable in class chat.dim.mtp.protocol.Header

type - Variable in class chat.dim.mtp.task.Departure

U

updateLastTime() - Method in class chat.dim.mtp.task.Assemble

updateLastTime() - Method in class chat.dim.mtp.task.Departure

V

value - Variable in class chat.dim.mtp.protocol.DataType

Z

ZERO - Static variable in class chat.dim.mtp.protocol.TransactionID

A B C D E F G H I J M N O P R S T U V Z