Package com.sun.corba.ee.impl.transport.connection

Class OutboundConnectionState<C extends Connection>

java.lang.Object

com.sun.corba.ee.impl.transport.connection.OutboundConnectionState<C>

@ManagedData
public class OutboundConnectionState<C extends Connection>
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	OutboundConnectionState.ConnectionStateValue

Field Summary

Fields

Modifier and Type	Field	Description
private int	busyCount
(package private) ContactInfo<C>	cinfo
(package private) C	connection
private OutboundConnectionState.ConnectionStateValue	csv
(package private) OutboundCacheEntry<C>	entry
(package private) int	expectedResponseCount
(package private) ConcurrentQueue.Handle<C>	reclaimableHandle

Constructor Summary

Constructors

Constructor	Description
OutboundConnectionState(ContactInfo<C> cinfo, OutboundCacheEntry<C> entry, C conn)

Method Summary

Modifier and Type	Method	Description
void	acquire()
private int	busyCount()
private OutboundCacheEntry<C>	cacheEntry()
void	close()
private C	connection()
private ContactInfo<C>	contactInfo()
private void	display(java.lang.String m, java.lang.Object value)
private int	expectedResponseCount()
boolean	isBusy()
boolean	isIdle()
boolean	isReclaimable()
private void	msg(java.lang.String m)
int	release(int numResponsesExpected)
private void	removeFromReclaim()
boolean	responseReceived()
void	setReclaimableHandle(ConcurrentQueue.Handle<C> handle)
private OutboundConnectionState.ConnectionStateValue	state()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

csv

private OutboundConnectionState.ConnectionStateValue csv

cinfo

final ContactInfo<C extends Connection> cinfo

connection

final C extends Connection connection

entry

final OutboundCacheEntry<C extends Connection> entry

busyCount

private int busyCount

expectedResponseCount

int expectedResponseCount

reclaimableHandle

ConcurrentQueue.Handle<C extends Connection> reclaimableHandle

Constructor Detail

OutboundConnectionState

public OutboundConnectionState(ContactInfo<C> cinfo,
                               OutboundCacheEntry<C> entry,
                               C conn)

Method Detail

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

state

@ManagedAttribute
@Description("The current state of this connection")
private OutboundConnectionState.ConnectionStateValue state()

contactInfo

@ManagedAttribute
@Description("The contactInfo used to create this connection")
private ContactInfo<C> contactInfo()

connection

@ManagedAttribute
@Description("The underlying connection for this ConnectionState")
private C connection()

cacheEntry

@ManagedAttribute
private OutboundCacheEntry<C> cacheEntry()

busyCount

@ManagedAttribute
private int busyCount()

expectedResponseCount

@ManagedAttribute
private int expectedResponseCount()

isReclaimable

@ManagedAttribute
public boolean isReclaimable()

isBusy

public boolean isBusy()

isIdle

public boolean isIdle()

acquire

public void acquire()

setReclaimableHandle

public void setReclaimableHandle(ConcurrentQueue.Handle<C> handle)

msg

@InfoMethod
private void msg(java.lang.String m)

display

@InfoMethod
private void display(java.lang.String m,
                     java.lang.Object value)

release

public int release(int numResponsesExpected)

responseReceived

public boolean responseReceived()

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

removeFromReclaim

private void removeFromReclaim()