chat.dim.mtp

Class MemPool

java.lang.Object

chat.dim.mtp.MemPool

All Implemented Interfaces:

Pool

public class MemPool
extends java.lang.Object
implements Pool

Field Summary

Fields

Modifier and Type	Field and Description
static long	EXPIRES 1.

Constructor Summary

Constructors

Constructor and Description
MemPool()

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
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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

EXPIRES

public static long EXPIRES

1. Departure task should be expired after 2 minutes when receive no response. 2. Assembling task should be expired after 2 minutes when receive nothing.

Constructor Detail

MemPool

public MemPool()

Method Detail

shiftExpiredDeparture

public Departure shiftExpiredDeparture()

Description copied from interface: Pool

Gat one departure task from the pool for sending.

Specified by:

shiftExpiredDeparture in interface Pool

Returns:

any expiring departure task (removed from pool)

appendDeparture

public boolean appendDeparture(Departure task)

Description copied from interface: Pool

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.

Specified by:

appendDeparture in interface Pool

Parameters:

task - - depature task

Returns:

false on failed

deleteDeparture

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

Description copied from interface: Pool

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

Specified by:

deleteDeparture in interface Pool

Parameters:

response - - respond package

destination - - remote IP and port

source - - local IP and port

Returns:

false on task not found/not finished yet

getCountOfArrivals

public int getCountOfArrivals()

Description copied from interface: Pool

Check how many arrivals waiting in the pool

Specified by:

getCountOfArrivals in interface Pool

Returns:

arrivals count

shiftFirstArrival

public Arrival shiftFirstArrival()

Description copied from interface: Pool

Get one arrival task from the pool for processing

Specified by:

shiftFirstArrival in interface Pool

Returns:

the first arrival task (removed from pool)

appendArrival

public boolean appendArrival(Arrival task)

Description copied from interface: Pool

Append an arrival task into the pool after received something

Specified by:

appendArrival in interface Pool

Parameters:

task - - arrival task

Returns:

false on failed

insertFragment

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

Description copied from interface: Pool

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.

Specified by:

insertFragment in interface Pool

Parameters:

fragment - - message fragment

source - - remote IP and port

destination - - local IP and port

Returns:

original message package when all fragments received

discardFragments

public java.util.List<Assemble> discardFragments()

Remove all expired fragments

Specified by:

discardFragments in interface Pool

Returns:

assembling tasks