Package org.apache.sshd.common.channel

Class Window

java.lang.Object

org.apache.sshd.common.util.logging.AbstractLoggingBean

org.apache.sshd.common.channel.Window

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, ChannelHolder

public class Window
extends AbstractLoggingBean
implements Channel, ChannelHolder

A Window for a given channel. Windows are used to not overflow the client or server when sending datas. Both clients and servers have a local and remote window and won't send anymore data until the window has been expanded. When the local window is

Field Summary

Fields

Modifier and Type	Field	Description
private final AbstractChannel	channelInstance
private final AtomicBoolean	closed
private final AtomicBoolean	initialized
private final Object	lock
private long	maxSize
private long	packetSize
private long	size
static final Predicate<Window>	SPACE_AVAILABLE_PREDICATE	Default Predicate used to test if space became available
private final String	suffix

Fields inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

log

Constructor Summary

Constructors

Constructor	Description
Window(AbstractChannel channel, Object lock, boolean client, boolean local)

Method Summary

Modifier and Type	Method	Description
void	check(long maxFree)
protected void	checkInitialized(String location)
void	close()
void	consume(long len)
void	consumeAndCheck(long len)
void	expand(int window)
AbstractChannel	getChannel()
long	getMaxSize()
long	getPacketSize()
long	getSize()
void	init(long size, long packetSize, PropertyResolver resolver)
void	init(PropertyResolver resolver)
boolean	isOpen()
String	toString()
protected void	updateSize(long size)
void	waitAndConsume(long len, long maxWaitTime)	Waits for enough data to become available to consume the specified size
void	waitAndConsume(long len, Duration maxWaitTime)	Waits for enough data to become available to consume the specified size
protected void	waitForCondition(Predicate<? super Window> predicate, Duration maxWaitTime)	Waits up to a specified amount of time for a condition to be satisfied and signaled via the lock.
long	waitForSpace(long maxWaitTime)	Waits until some data becomes available or timeout expires
long	waitForSpace(Duration maxWaitTime)	Waits until some data becomes available or timeout expires

Methods inherited from class org.apache.sshd.common.util.logging.AbstractLoggingBean

debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn

Methods inherited from class java.lang.Object

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

Field Details

SPACE_AVAILABLE_PREDICATE

public static final Predicate<Window> SPACE_AVAILABLE_PREDICATE

Default Predicate used to test if space became available

closed

private final AtomicBoolean closed

initialized

private final AtomicBoolean initialized

channelInstance

private final AbstractChannel channelInstance

lock

private final Object lock

suffix

private final String suffix

size

private long size

maxSize

private long maxSize

packetSize

private long packetSize

Constructor Details

Window

public Window(AbstractChannel channel,
 Object lock,
 boolean client,
 boolean local)

Method Details

getChannel

public AbstractChannel getChannel()

Specified by:

getChannel in interface ChannelHolder

Returns:

The associated Channel instance

getSize

public long getSize()

getMaxSize

public long getMaxSize()

getPacketSize

public long getPacketSize()

init

public void init(PropertyResolver resolver)

init

public void init(long size,
 long packetSize,
 PropertyResolver resolver)

expand

public void expand(int window)

consume

public void consume(long len)

consumeAndCheck

public void consumeAndCheck(long len)
                     throws IOException

Throws:

IOException

check

public void check(long maxFree)
           throws IOException

Throws:

IOException

waitAndConsume

public void waitAndConsume(long len,
 long maxWaitTime)
                    throws InterruptedException,
WindowClosedException,
SocketTimeoutException

Waits for enough data to become available to consume the specified size

Parameters:

len - Size of data to consume

maxWaitTime - Max. time (millis) to wait for enough data to become available

Throws:

InterruptedException - If interrupted while waiting

WindowClosedException - If window closed while waiting

SocketTimeoutException - If timeout expired before enough data became available

See Also:

• waitForCondition(Predicate, Duration)
• consume(long)

waitAndConsume

public void waitAndConsume(long len,
 Duration maxWaitTime)
                    throws InterruptedException,
WindowClosedException,
SocketTimeoutException

Waits for enough data to become available to consume the specified size

Parameters:

len - Size of data to consume

maxWaitTime - Max. time to wait for enough data to become available

Throws:

InterruptedException - If interrupted while waiting

WindowClosedException - If window closed while waiting

SocketTimeoutException - If timeout expired before enough data became available

See Also:

• waitForCondition(Predicate, Duration)
• consume(long)

waitForSpace

public long waitForSpace(long maxWaitTime)
                  throws InterruptedException,
WindowClosedException,
SocketTimeoutException

Waits until some data becomes available or timeout expires

Parameters:

maxWaitTime - Max. time (millis) to wait for space to become available

Returns:

Amount of available data - always positive

Throws:

InterruptedException - If interrupted while waiting

WindowClosedException - If window closed while waiting

SocketTimeoutException - If timeout expired before space became available

See Also:

• waitForCondition(Predicate, Duration)

waitForSpace

public long waitForSpace(Duration maxWaitTime)
                  throws InterruptedException,
WindowClosedException,
SocketTimeoutException

Waits until some data becomes available or timeout expires

Parameters:

maxWaitTime - Max. time to wait for space to become available

Returns:

Amount of available data - always positive

Throws:

InterruptedException - If interrupted while waiting

WindowClosedException - If window closed while waiting

SocketTimeoutException - If timeout expired before space became available

See Also:

• waitForCondition(Predicate, Duration)

waitForCondition

protected void waitForCondition(Predicate<? super Window> predicate,
 Duration maxWaitTime)
                         throws WindowClosedException,
InterruptedException,
SocketTimeoutException

Waits up to a specified amount of time for a condition to be satisfied and signaled via the lock. Note: assumes that lock is acquired when this method is called.

Parameters:

predicate - The Predicate to check if the condition has been satisfied - the argument to the predicate is this reference

maxWaitTime - Max. time to wait for the condition to be satisfied

Throws:

WindowClosedException - If window closed while waiting

InterruptedException - If interrupted while waiting

SocketTimeoutException - If timeout expired before condition was satisfied

See Also:

• isOpen()

updateSize

protected void updateSize(long size)

checkInitialized

protected void checkInitialized(String location)

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface Closeable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object