Representa uma conexão LSP. Mais...

Funções do Pacote
	LspConnection (short id, long sockId, SocketAddress sockAddr, LspParams params, ConnectionTriggers triggers)
	Constrói um objeto LspConnection. Mais...

	LspConnection (short id, SocketAddress sockAddr, LspParams params, ConnectionTriggers triggers)
	Constrói um objeto LspConnection. Mais...

short	getId ()

long	getSockId ()
	Número único gerado a partir de um endereço IP e uma porta. Mais...

SocketAddress	getSockAddr ()

void	incSendMissing ()
	Aumenta em um o número de mensagens na fila, mas faltam enviar. Mais...

int	getSendMissing ()
	Número de mensagens na fila, mas faltam enviar. Mais...

InternalPack	sent ()
	Obtém a última mensagem de dados enviada (aguardando ACK) Mais...

InternalPack	sent (Pack pack)
	Informa o payload da última mensagem enviada. Mais...

void	ack (short seqNum)
	Informa que o ACK do número de sequência informado foi recebido. Mais...

short	receivedSeqNum ()
	Número de sequência da última mensagem DATA recebida por essa conexão. Mais...

void	received ()
	Informa que houve uma mensagem recebida por essa conexão. Mais...

void	received (short seqNum)
	Informa o número de sequência em que uma mensagem DATA foi recebida. Mais...

boolean	isInterrupted ()

boolean	isClosed ()

void	close ()

void	close (boolean interrupt)

Funções Estáticas do Pacote
static long	uniqueSockId (SocketAddress sockAddr)
	Número único gerado a partir de um endereço IP e uma porta. Mais...

Descrição Detalhada

Representa uma conexão LSP.

Autor: Wagner Macedo

Definição na linha 12 do arquivo LspConnection.java.

Construtores & Destrutores

lsp.LspConnection.LspConnection	(	short	id,
		long	sockId,
		SocketAddress	sockAddr,
		LspParams	params,
		ConnectionTriggers	triggers
	)

package

Constrói um objeto LspConnection.

Parâmetros

id	Identificador da conexão
sockId	Número IP e porta associados à conexão
sockAddr	IP e porta vinculados à essa conexão
params	Parâmetros de temporização da conexão

Definição na linha 41 do arquivo LspConnection.java.

                                                                                                                 {
         if (sockAddr == null || params == null)
             throw new NullPointerException("Nenhum parâmetro pode ser nulo");
 
         this.id = id;
         this.sockId = sockId;
         this.sockAddr = sockAddr;
         this.triggers = triggers;
         this.closed = false;
         this.seqNum = 0;
         this.receivedTime = -1;
         this.receivedSeqNum = -1;
         this.sendMissing = new AtomicInteger(0);
 
         this.statusThread = new Thread(new StatusChecker(params));
         this.statusThread.setDaemon(true);
         this.statusThread.start();
     }

lsp.LspConnection.LspConnection	(	short	id,
		SocketAddress	sockAddr,
		LspParams	params,
		ConnectionTriggers	triggers
	)

package

Constrói um objeto LspConnection.

Parâmetros

id	Identificador da conexão
sockAddr	IP e porta vinculados à essa conexão
params	Parâmetros de temporização da conexão

Definição na linha 70 do arquivo LspConnection.java.

                                                                                                    {
         this(id, uniqueSockId(sockAddr), sockAddr, params, triggers);
     }

Este é o diagrama das funções utilizadas por esta função:

Métodos

void lsp.LspConnection.ack ( short seqNum )

package

Informa que o ACK do número de sequência informado foi recebido.

Definição na linha 143 do arquivo LspConnection.java.

                            {
         // Atualiza o momento de recebimento
         received();
 
         synchronized (lock) {
             // Marca dados como recebidos, se o número de sequência é igual ao atual
             if (this.seqNum == seqNum) {
                 this.sentMessage = null;
             }
 
             // Diminuição da quantidade de mensagens faltando entregar.
             this.sendMissing.decrementAndGet();
         }
     }

Este é o diagrama das funções utilizadas por esta função:

void lsp.LspConnection.close ( )

package

Definição na linha 195 do arquivo LspConnection.java.

                  {
         close(true);
     }

void lsp.LspConnection.close ( boolean interrupt )

package

Definição na linha 199 do arquivo LspConnection.java.

                                   {
         if (interrupt) {
             this.statusThread.interrupt();
             this.closed = true;
         } else {
             this.markClosed = true;
         }
     }

short lsp.LspConnection.getId ( )

package

Definição na linha 74 do arquivo LspConnection.java.

                   {
         return this.id;
     }

Este é o diagrama das funções que utilizam esta função:

int lsp.LspConnection.getSendMissing ( )

package

Número de mensagens na fila, mas faltam enviar.

Valor controlado externamente.

Definição na linha 115 do arquivo LspConnection.java.

                          {
         return this.sendMissing.intValue();
     }

Este é o diagrama das funções que utilizam esta função:

SocketAddress lsp.LspConnection.getSockAddr ( )

package

Definição na linha 99 do arquivo LspConnection.java.

                                 {
         return this.sockAddr;
     }

long lsp.LspConnection.getSockId ( )

package

Número único gerado a partir de um endereço IP e uma porta.

Esse atributo só é usado pelo servidor

Definição na linha 95 do arquivo LspConnection.java.

                      {
         return this.sockId;
     }

void lsp.LspConnection.incSendMissing ( )

package

Aumenta em um o número de mensagens na fila, mas faltam enviar.

Isso é controlado externamente.

Definição na linha 107 do arquivo LspConnection.java.

                           {
         this.sendMissing.incrementAndGet();
     }

boolean lsp.LspConnection.isClosed ( )

package

Definição na linha 191 do arquivo LspConnection.java.

                        {
         return this.closed || this.markClosed;
     }

Este é o diagrama das funções que utilizam esta função:

boolean lsp.LspConnection.isInterrupted ( )

package

Definição na linha 187 do arquivo LspConnection.java.

                             {
         return this.closed;
     }

Este é o diagrama das funções que utilizam esta função:

void lsp.LspConnection.received ( )

package

Informa que houve uma mensagem recebida por essa conexão.

Esse método tem como único propósito a atualização do momento de recebimento.

Definição na linha 172 do arquivo LspConnection.java.

                     {
         this.receivedTime = System.currentTimeMillis();
     }

Este é o diagrama das funções que utilizam esta função:

void lsp.LspConnection.received ( short seqNum )

package

Informa o número de sequência em que uma mensagem DATA foi recebida.

Esse método atualiza o último momento de recebimento

Definição na linha 180 do arquivo LspConnection.java.

                                 {
         // Atualiza o momento de recebimento
         received();
         // Altera o número de sequência atual
         this.receivedSeqNum = seqNum;
     }

Este é o diagrama das funções utilizadas por esta função:

short lsp.LspConnection.receivedSeqNum ( )

package

Número de sequência da última mensagem DATA recebida por essa conexão.

Esse número é gerenciado externamente através do método received(short). Se receber -1, quer dizer que não chegou nenhuma mensagem depois do pedido de conexão.

Definição na linha 164 do arquivo LspConnection.java.

                            {
         return receivedSeqNum;
     }

InternalPack lsp.LspConnection.sent ( )

package

Obtém a última mensagem de dados enviada (aguardando ACK)

Definição na linha 120 do arquivo LspConnection.java.

                         {
         return this.sentMessage;
     }

InternalPack lsp.LspConnection.sent ( Pack pack )

package

Informa o payload da última mensagem enviada.

Retorna: Pacote com um novo número de sequência ou null se já há um pacote aguardando ACK

Definição na linha 130 do arquivo LspConnection.java.

                                  {
         synchronized (lock) {
             InternalPack p = new InternalPack(this, ++seqNum, pack.getPayload());
             if (this.sentMessage == null) {
                 this.sentMessage = p;
                 return p;
             }
         }
 
         return null;
     }

Este é o diagrama das funções utilizadas por esta função:

static long lsp.LspConnection.uniqueSockId ( SocketAddress sockAddr )

staticpackage

Número único gerado a partir de um endereço IP e uma porta.

Esse método só é usado pelo servidor

Definição na linha 83 do arquivo LspConnection.java.

                                                      {
         final InetSocketAddress addr = (InetSocketAddress) sockAddr;
         final int ip = addr.getAddress().hashCode();
         final int port = addr.getPort();
         return (ip & 0xffff_ffffL) << 16 | (short) port;
     }

Este é o diagrama das funções que utilizam esta função:

A documentação para esta classe foi gerada a partir do seguinte arquivo:

src/lsp/LspConnection.java

Funções do Pacote

Funções Estáticas do Pacote

Descrição Detalhada

Construtores & Destrutores

Métodos