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
All Methods Instance Methods Concrete Methods 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()
-
-
-
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 classjava.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()
-
-