chat.dim.mtp

Interface Pool

All Known Implementing Classes:

MemPool

public interface Pool

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

Method Summary

Modifier and Type	Method and Description
boolean	appendArrival(Arrival task) Append an arrival task into the pool after received something
boolean	appendDeparture(Departure task) Append a departure task into the pool after sent.
boolean	deleteDeparture(Package response, java.net.SocketAddress destination, java.net.SocketAddress source) Delete the departure task with 'trans_id' in the response.
java.util.List<Assemble>	discardFragments() Remove all expired fragments that belong to the incomplete messages, which had waited a long time but still some fragments missed.
int	getCountOfArrivals() Check how many arrivals waiting in the pool
Package	insertFragment(Package fragment, java.net.SocketAddress source, java.net.SocketAddress destination) Add a fragment package into the pool for MessageFragment received.
Departure	shiftExpiredDeparture() Gat one departure task from the pool for sending.
Arrival	shiftFirstArrival() Get one arrival task from the pool for processing

Method Detail

shiftExpiredDeparture

Departure shiftExpiredDeparture()

Gat one departure task from the pool for sending.

Returns:

any expiring departure task (removed from pool)

appendDeparture

boolean appendDeparture(Departure task)

Append a departure task into the pool after sent. This should be removed after its response received; if timeout, send it again and check it's retries counter, when it's still greater than 0, put it back to the pool for resending.

Parameters:

task - - depature task

Returns:

false on failed

deleteDeparture

boolean deleteDeparture(Package response,
                        java.net.SocketAddress destination,
                        java.net.SocketAddress source)

Delete the departure task with 'trans_id' in the response. If it's a message fragment, check the page offset too.

Parameters:

response - - respond package

destination - - remote IP and port

source - - local IP and port

Returns:

false on task not found/not finished yet

getCountOfArrivals

int getCountOfArrivals()

Check how many arrivals waiting in the pool

Returns:

arrivals count

shiftFirstArrival

Arrival shiftFirstArrival()

Get one arrival task from the pool for processing

Returns:

the first arrival task (removed from pool)

appendArrival

boolean appendArrival(Arrival task)

Append an arrival task into the pool after received something

Parameters:

task - - arrival task

Returns:

false on failed

insertFragment

Package insertFragment(Package fragment,
                       java.net.SocketAddress source,
                       java.net.SocketAddress destination)

Add a fragment package into the pool for MessageFragment received. This will just wait until all fragments with the same 'trans_id' received. When all fragments received, they will be sorted and combined to the original message, and then return the message's data; if there are still some fragments missed, return None.

Parameters:

fragment - - message fragment

source - - remote IP and port

destination - - local IP and port

Returns:

original message package when all fragments received

discardFragments

java.util.List<Assemble> discardFragments()

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

Returns:

assembling tasks