Class OutboundConnectionState<C extends Connection>
java.lang.Object
com.sun.corba.ee.impl.transport.connection.OutboundConnectionState<C>
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate static enum
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate int
(package private) final ContactInfo
<C> (package private) final C
(package private) final OutboundCacheEntry
<C> (package private) int
(package private) ConcurrentQueue.Handle
<C> -
Constructor Summary
ConstructorsConstructorDescriptionOutboundConnectionState
(ContactInfo<C> cinfo, OutboundCacheEntry<C> entry, C conn) -
Method Summary
Modifier and TypeMethodDescriptionvoid
acquire()
private int
private OutboundCacheEntry
<C> void
close()
private C
private ContactInfo
<C> private void
private int
boolean
isBusy()
boolean
isIdle()
boolean
private void
int
release
(int numResponsesExpected) private void
boolean
void
setReclaimableHandle
(ConcurrentQueue.Handle<C> handle) state()
toString()
-
Field Details
-
csv
-
cinfo
-
connection
-
entry
-
busyCount
private int busyCount -
expectedResponseCount
int expectedResponseCount -
reclaimableHandle
ConcurrentQueue.Handle<C extends Connection> reclaimableHandle
-
-
Constructor Details
-
OutboundConnectionState
-
-
Method Details
-
toString
-
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
-
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
-
msg
-
display
-
release
public int release(int numResponsesExpected) -
responseReceived
public boolean responseReceived() -
close
- Throws:
IOException
-
removeFromReclaim
private void removeFromReclaim()
-