Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: INNER | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

com.newstep.solid.netio.rtt

Class RttAccessPoint.ListeningServer

All Implemented Interfaces:
ConnectionListener

class RttAccessPoint.ListeningServer

RttAccessPoint delegates listening on the specific RttEndpoint to ListeningServer

Implements:

ConnectionListener

Links:

Kernel Association Association Link

to Class RttAccessPoint

Associates type:

association

Client cardinality:

Client navigability:

NOT NAVIGABLE

Client visibility:

private

Supplier cardinality:

Supplier navigability:

NAVIGABLE

Supplier visibility:

package

Kernel Association Association Link

to Class RttEndpoint

Associates type:

association

Client cardinality:

Client navigability:

NOT NAVIGABLE

Client visibility:

private

Supplier cardinality:

Supplier navigability:

NAVIGABLE

Supplier visibility:

package

Kernel Association Association Link

to Interface ConnectionListener

Associates type:

association

Client cardinality:

Client navigability:

NOT NAVIGABLE

Client visibility:

private

Supplier cardinality:

Supplier navigability:

NAVIGABLE

Supplier visibility:

package

Implementation Implementation Link

to Interface ConnectionListener

RttAccessPoint delegates listening on the specific RttEndpoint to ListeningServer

Field Summary
RttAccessPoint	accessPoint
ConnectionListener	connectionListener
int	counter
RttEndpoint	localEndpoint
TimerTask	retryListeningPrimary
TimerTask	retryListeningSecondary
ReentrantLock	retryLock

Constructor Summary
protected void	ListeningServer(RttEndpoint endpoint, ConnectionListener listener, Integer count)

Method Summary
private void	accept(RttServerChannel channel)
protected synchronized void	decrementConnectCounter()
protected synchronized void	incrementConnectCounter()
protected void	listen()
public void	newConnection(CommChannel channel)
protected void	register(RttServerChannel channel)
protected void	reWire(RttServerChannel channel)
protected void	stop()

Field Detail

accessPoint

RttAccessPoint accessPoint

Multiplicity:

connectionListener

ConnectionListener connectionListener

Multiplicity:

counter

int counter

Multiplicity:

localEndpoint

RttEndpoint localEndpoint

Multiplicity:

retryListeningPrimary

TimerTask retryListeningPrimary

Multiplicity:

retryListeningSecondary

TimerTask retryListeningSecondary

Multiplicity:

retryLock

ReentrantLock retryLock

Multiplicity:

Constructor Detail

ListeningServer

protected void ListeningServer (RttEndpoint endpoint, ConnectionListener listener, Integer count)

Stereotype:

create

Method Detail

private void accept (RttServerChannel channel)

Accepts new RTT connection, or rejects it if there is already connection with the same
host id

Parameters:

channel

decrementConnectCounter

protected synchronized void decrementConnectCounter ()

Decrements the allowed connections counter and stops listening when no more connections
are allowed. Does nothing if the number of allowed connectins is unlimited.

Synchronized.

incrementConnectCounter

protected synchronized void incrementConnectCounter ()

Increments the allowed connections counter. Does nothing if the number of allowed
connectins is unlimited.

Synchronized.

listen

protected void listen ()

Starts listening for connections on both tcp channels

newConnection

public void newConnection (CommChannel channel)

Gets notified when a tcp channel connects

Parameters: