weblogic.socket

Class ServerThrottle

java.lang.Object

weblogic.socket.ServerThrottle

public final class ServerThrottle
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	ServerThrottle.ServerThrottleMaker

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	enabled
private static weblogic.security.acl.internal.AuthenticatedSubject	kernelId
private weblogic.utils.concurrent.Semaphore	lock
private int	maxOpenSockets

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ServerThrottle()

Method Summary

Modifier and Type	Method and Description
void	acquireSocketPermit() First attempt to acquire a permit without blocking.
void	changeMaxOpenSockets(int maxvalue)
void	decrementOpenSocketCount()
static ServerThrottle	getServerThrottle()
boolean	isEnabled()
boolean	tryAcquirePermit() tries to acquire a permit and returns the result without blocking.

Methods inherited from class java.lang.Object

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

Field Detail

kernelId

private static final weblogic.security.acl.internal.AuthenticatedSubject kernelId

lock

private final weblogic.utils.concurrent.Semaphore lock

enabled

private volatile boolean enabled

maxOpenSockets

private volatile int maxOpenSockets

Constructor Detail

ServerThrottle

private ServerThrottle()

Method Detail

getServerThrottle

public static ServerThrottle getServerThrottle()

changeMaxOpenSockets

public void changeMaxOpenSockets(int maxvalue)

isEnabled

public boolean isEnabled()

tryAcquirePermit

public boolean tryAcquirePermit()

tries to acquire a permit and returns the result without blocking. Caller is expected to take appropriate action based on the results.

Returns:

true when the permit was acquired

acquireSocketPermit

public void acquireSocketPermit()

First attempt to acquire a permit without blocking. If unable to get a permit, log the MaxOpenSockets has been reached and block until the permit is acquired. Also set the health state to warn. Once the lock permit is acquired log the fact that we are accepting connections again and set the health state to OK.

decrementOpenSocketCount

public void decrementOpenSocketCount()