Modifier and Type	Class and Description
private abstract class	SelectableChannelEndPoint.RunnableCloseable

Modifier and Type

Class and Description

private abstract class

SelectableChannelEndPoint.RunnableCloseable

Modifier and Type	Field and Description
private final SelectableChannel	_channel
private int	_currentInterestOps
private int	_desiredInterestOps
private SelectionKey	_key
private final AutoLock	_lock
private final Runnable	_runCompleteWrite
private final Runnable	_runCompleteWriteFillable
private final Runnable	_runFillable
private final ManagedSelector	_selector
private final ManagedSelector.SelectorUpdate	_updateKeyAction
private boolean	_updatePending
private static final Logger	LOG Hides org.eclipse.jetty.io.AbstractEndPoint.LOG.

Modifier and Type

Field and Description

private final SelectableChannel

private int

private int

private SelectionKey

private final AutoLock

_lock

private final Runnable

_runCompleteWrite

private final Runnable

_runCompleteWriteFillable

private final Runnable

_runFillable

private final ManagedSelector

_selector

private final ManagedSelector.SelectorUpdate

_updateKeyAction

private boolean

_updatePending

private static final Logger

LOG

Hides org.eclipse.jetty.io.AbstractEndPoint.LOG.

Access	Constructor and Description
public	SelectableChannelEndPoint(Scheduler scheduler, SelectableChannel channel, ManagedSelector selector, SelectionKey selectionKey)

Access

Constructor and Description

public

SelectableChannelEndPoint(Scheduler scheduler, SelectableChannel channel, ManagedSelector selector, SelectionKey selectionKey)

Modifier and Type	Method and Description
private void	changeInterests(int operation)
public void	doClose() Overrides org.eclipse.jetty.io.AbstractEndPoint.doClose.
public SelectableChannel	getChannel()
public SocketAddress	getLocalSocketAddress() Overrides default org.eclipse.jetty.io.EndPoint.getLocalSocketAddress. Implements abstract org.eclipse.jetty.io.AbstractEndPoint.getLocalSocketAddress.
public Object	getTransport() Implements org.eclipse.jetty.io.EndPoint.getTransport.
public boolean	isOpen() Overrides org.eclipse.jetty.io.AbstractEndPoint.isOpen. Implements org.eclipse.jetty.io.EndPoint.isOpen. This abstract method should be called to check if idle timeouts should still be checked.
protected void	needsFillInterest() Implements abstract org.eclipse.jetty.io.AbstractEndPoint.needsFillInterest.
public void	onClose(Throwable The reason for the close, or null if a normal close. cause) Overrides org.eclipse.jetty.io.AbstractEndPoint.onClose. Implements org.eclipse.jetty.io.EndPoint.onClose. Callback method invoked when this `EndPoint` is closed.
protected void	onIncompleteFlush() Implements abstract org.eclipse.jetty.io.AbstractEndPoint.onIncompleteFlush.
public Runnable	onSelected() Implements org.eclipse.jetty.io.ManagedSelector.Selectable.onSelected. Callback method invoked when a read or write events has been detected by the `ManagedSelector` for this endpoint.
public void	replaceKey(SelectionKey the new SelectionKey newKey) Implements org.eclipse.jetty.io.ManagedSelector.Selectable.replaceKey. Callback method invoked when the SelectionKey is replaced because the channel has been moved to a new selector.
public String	toEndPointString() Overrides org.eclipse.jetty.io.AbstractEndPoint.toEndPointString.
public void	updateKey() Implements org.eclipse.jetty.io.ManagedSelector.Selectable.updateKey. Callback method invoked when all the keys selected by the `ManagedSelector` for this endpoint have been processed.
private void	updateKeyAction(Selector selector)

Modifier and Type

Method and Description

private void

changeInterests(int operation)

public void

doClose()

Overrides org.eclipse.jetty.io.AbstractEndPoint.doClose.

public SelectableChannel

getChannel()

public SocketAddress

getLocalSocketAddress()

Overrides default org.eclipse.jetty.io.EndPoint.getLocalSocketAddress.

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.getLocalSocketAddress.

public Object

getTransport()

Implements org.eclipse.jetty.io.EndPoint.getTransport.

public boolean

isOpen()

Overrides org.eclipse.jetty.io.AbstractEndPoint.isOpen.

Implements org.eclipse.jetty.io.EndPoint.isOpen.

This abstract method should be called to check if idle timeouts should still be checked.

protected void

needsFillInterest()

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.needsFillInterest.

public void

onClose(Throwable

The reason for the close, or null if a normal close.

cause)

Overrides org.eclipse.jetty.io.AbstractEndPoint.onClose.

Implements org.eclipse.jetty.io.EndPoint.onClose.

Callback method invoked when this EndPoint is closed.

protected void

onIncompleteFlush()

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.onIncompleteFlush.

public Runnable

onSelected()

Implements org.eclipse.jetty.io.ManagedSelector.Selectable.onSelected.

Callback method invoked when a read or write events has been detected by the ManagedSelector for this endpoint.

public void

replaceKey(SelectionKey

the new SelectionKey

newKey)

Implements org.eclipse.jetty.io.ManagedSelector.Selectable.replaceKey.

Callback method invoked when the SelectionKey is replaced because the channel has been moved to a new selector.

public String

toEndPointString()

Overrides org.eclipse.jetty.io.AbstractEndPoint.toEndPointString.

public void

updateKey()

Implements org.eclipse.jetty.io.ManagedSelector.Selectable.updateKey.

Callback method invoked when all the keys selected by the ManagedSelector for this endpoint have been processed.

private void

updateKeyAction(Selector selector)

Field Detail

_channel	back to summary
private final SelectableChannel _channel

_channel

back to summary

private final SelectableChannel _channel

_currentInterestOps	back to summary
private int _currentInterestOps

_currentInterestOps

back to summary

private int _currentInterestOps

_desiredInterestOps	back to summary
private int _desiredInterestOps

_desiredInterestOps

back to summary

private int _desiredInterestOps

_key	back to summary
private SelectionKey _key

_key

back to summary

private SelectionKey _key

_lock	back to summary
private final AutoLock _lock

_lock

back to summary

private final AutoLock _lock

_runCompleteWrite	back to summary
private final Runnable _runCompleteWrite

_runCompleteWrite

back to summary

private final Runnable _runCompleteWrite

_runCompleteWriteFillable	back to summary
private final Runnable _runCompleteWriteFillable

_runCompleteWriteFillable

back to summary

private final Runnable _runCompleteWriteFillable

_runFillable	back to summary
private final Runnable _runFillable

_runFillable

back to summary

private final Runnable _runFillable

_selector	back to summary
private final ManagedSelector _selector

_selector

back to summary

private final ManagedSelector _selector

_updateKeyAction	back to summary
private final ManagedSelector.SelectorUpdate _updateKeyAction

_updateKeyAction

back to summary

private final ManagedSelector.SelectorUpdate _updateKeyAction

_updatePending	back to summary
private boolean _updatePending

_updatePending

back to summary

private boolean _updatePending

LOG	back to summary
private static final Logger LOG Hides org.eclipse.jetty.io.AbstractEndPoint.LOG.

LOG

back to summary

private static final Logger LOG

Hides org.eclipse.jetty.io.AbstractEndPoint.LOG.

SelectableChannelEndPoint	back to summary
public SelectableChannelEndPoint(Scheduler scheduler, SelectableChannel channel, ManagedSelector selector, SelectionKey selectionKey)

SelectableChannelEndPoint

back to summary

public SelectableChannelEndPoint(Scheduler scheduler, SelectableChannel channel, ManagedSelector selector, SelectionKey selectionKey)

Method Detail

changeInterests	back to summary
private void changeInterests(int operation)

doClose	back to summary
public void doClose() Overrides org.eclipse.jetty.io.AbstractEndPoint.doClose. Annotations @Override

doClose

back to summary

public void doClose()

Overrides org.eclipse.jetty.io.AbstractEndPoint.doClose.

Annotations

@Override

getChannel	back to summary
public SelectableChannel getChannel()

getLocalSocketAddress back to summary

getLocalSocketAddress	back to summary
public SocketAddress getLocalSocketAddress() Overrides default org.eclipse.jetty.io.EndPoint.getLocalSocketAddress. Implements abstract org.eclipse.jetty.io.AbstractEndPoint.getLocalSocketAddress. Returns:SocketAddress Doc from org.eclipse.jetty.io.EndPoint.getLocalSocketAddress. the local SocketAddress to which this `EndPoint` is bound or `null` if this `EndPoint` is not bound to a Socket address. Annotations @Override

public SocketAddress getLocalSocketAddress()

Overrides default org.eclipse.jetty.io.EndPoint.getLocalSocketAddress.

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.getLocalSocketAddress.

Returns:SocketAddress

Doc from org.eclipse.jetty.io.EndPoint.getLocalSocketAddress.

the local SocketAddress to which this EndPoint is bound or null if this EndPoint is not bound to a Socket address.

Annotations

@Override

getTransport	back to summary
public Object getTransport() Implements org.eclipse.jetty.io.EndPoint.getTransport. Returns:Object Doc from org.eclipse.jetty.io.EndPoint.getTransport. The underlying transport object (socket, channel, etc.) Annotations @Override

getTransport

back to summary

public Object getTransport()

Implements org.eclipse.jetty.io.EndPoint.getTransport.

Returns:Object

Doc from org.eclipse.jetty.io.EndPoint.getTransport.

The underlying transport object (socket, channel, etc.)

Annotations

@Override

isOpen	back to summary
public boolean isOpen() Overrides org.eclipse.jetty.io.AbstractEndPoint.isOpen. Implements org.eclipse.jetty.io.EndPoint.isOpen. Doc from org.eclipse.jetty.io.IdleTimeout.isOpen. This abstract method should be called to check if idle timeouts should still be checked. Returns:boolean Doc from org.eclipse.jetty.io.EndPoint.isOpen. whether this EndPoint is open Annotations @Override

isOpen

back to summary

public boolean isOpen()

Overrides org.eclipse.jetty.io.AbstractEndPoint.isOpen.

Implements org.eclipse.jetty.io.EndPoint.isOpen.

Doc from org.eclipse.jetty.io.IdleTimeout.isOpen.

This abstract method should be called to check if idle timeouts should still be checked.

Returns:boolean

Doc from org.eclipse.jetty.io.EndPoint.isOpen.

whether this EndPoint is open

Annotations

@Override

needsFillInterest	back to summary
protected void needsFillInterest() Implements abstract org.eclipse.jetty.io.AbstractEndPoint.needsFillInterest. Annotations @Override

needsFillInterest

back to summary

protected void needsFillInterest()

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.needsFillInterest.

Annotations

@Override

onClose back to summary

onClose	back to summary
public void onClose(Throwable cause) Overrides org.eclipse.jetty.io.AbstractEndPoint.onClose. Implements org.eclipse.jetty.io.EndPoint.onClose. Doc from org.eclipse.jetty.io.EndPoint.onClose. Callback method invoked when this `EndPoint` is closed. Parameters cause:Throwable The reason for the close, or null if a normal close. Annotations @Override

public void onClose(Throwable cause)

Overrides org.eclipse.jetty.io.AbstractEndPoint.onClose.

Implements org.eclipse.jetty.io.EndPoint.onClose.

Doc from org.eclipse.jetty.io.EndPoint.onClose.

Callback method invoked when this EndPoint is closed.

Parameters

cause:Throwable: The reason for the close, or null if a normal close.

Annotations

@Override

onIncompleteFlush	back to summary
protected void onIncompleteFlush() Implements abstract org.eclipse.jetty.io.AbstractEndPoint.onIncompleteFlush. Annotations @Override

onIncompleteFlush

back to summary

protected void onIncompleteFlush()

Implements abstract org.eclipse.jetty.io.AbstractEndPoint.onIncompleteFlush.

Annotations

@Override

onSelected back to summary

onSelected	back to summary
public Runnable onSelected() Implements org.eclipse.jetty.io.ManagedSelector.Selectable.onSelected. Doc from org.eclipse.jetty.io.ManagedSelector.Selectable.onSelected. Callback method invoked when a read or write events has been detected by the `ManagedSelector` for this endpoint. Returns:Runnable a job that may block or null Annotations @Override

public Runnable onSelected()

Implements org.eclipse.jetty.io.ManagedSelector.Selectable.onSelected.

Doc from org.eclipse.jetty.io.ManagedSelector.Selectable.onSelected.

Callback method invoked when a read or write events has been detected by the ManagedSelector for this endpoint.

Returns:Runnable

a job that may block or null

Annotations

@Override

replaceKey	back to summary
public void replaceKey(SelectionKey newKey) Implements org.eclipse.jetty.io.ManagedSelector.Selectable.replaceKey. Doc from org.eclipse.jetty.io.ManagedSelector.Selectable.replaceKey. Callback method invoked when the SelectionKey is replaced because the channel has been moved to a new selector. Parameters newKey:SelectionKey the new SelectionKey Annotations @Override

replaceKey

back to summary

public void replaceKey(SelectionKey newKey)

Implements org.eclipse.jetty.io.ManagedSelector.Selectable.replaceKey.

Doc from org.eclipse.jetty.io.ManagedSelector.Selectable.replaceKey.

Callback method invoked when the SelectionKey is replaced because the channel has been moved to a new selector.

Parameters

newKey:SelectionKey: the new SelectionKey

Annotations

@Override

toEndPointString	back to summary
public String toEndPointString() Overrides org.eclipse.jetty.io.AbstractEndPoint.toEndPointString. Annotations @Override

toEndPointString

back to summary

public String toEndPointString()

Overrides org.eclipse.jetty.io.AbstractEndPoint.toEndPointString.

Annotations

@Override

updateKey back to summary

updateKey	back to summary
public void updateKey() Implements org.eclipse.jetty.io.ManagedSelector.Selectable.updateKey. Doc from org.eclipse.jetty.io.ManagedSelector.Selectable.updateKey. Callback method invoked when all the keys selected by the `ManagedSelector` for this endpoint have been processed. Annotations @Override

public void updateKey()

Implements org.eclipse.jetty.io.ManagedSelector.Selectable.updateKey.

Doc from org.eclipse.jetty.io.ManagedSelector.Selectable.updateKey.

Callback method invoked when all the keys selected by the ManagedSelector for this endpoint have been processed.

Annotations

@Override

updateKeyAction	back to summary
private void updateKeyAction(Selector selector)

org.eclipse.jetty.io back to summary

private abstract Class SelectableChannelEndPoint.RunnableCloseable

Class Inheritance

extends Object
implements Task, Closeable

java.lang.Object
org.eclipse.jetty.io.SelectableChannelEndPoint.RunnableCloseable

All Implemented Interfaces

java.io.Closeable, java.lang.AutoCloseable, org.eclipse.jetty.util.thread.Invocable.Task, java.lang.Runnable, org.eclipse.jetty.util.thread.Invocable

Field Summary

Modifier and Type	Field and Description
pack-priv final String	_operation

Constructor Summary

Access	Constructor and Description
private	RunnableCloseable(String operation)

Method Summary

Modifier and Type	Method and Description
public void	close() Implements java.io.Closeable.close. Closes this stream and releases any system resources associated with it.
public String	toString() Overrides java.lang.Object.toString. Returns a string representation of the object.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll wait wait wait

Field Detail

_operation	back to summary
pack-priv final String _operation

Constructor Detail

RunnableCloseable	back to summary
private RunnableCloseable(String operation)

Method Detail

close back to summary

close	back to summary
public void close() Implements java.io.Closeable.close. Doc from java.io.Closeable.close. Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect. As noted in `AutoCloseable#close()`, cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the `Closeable` as closed, prior to throwing the `IOException`. Annotations @Override

public void close()

Implements java.io.Closeable.close.

Doc from java.io.Closeable.close.

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

As noted in AutoCloseable#close(), cases where the close may fail require careful attention. It is strongly advised to relinquish the underlying resources and to internally mark the Closeable as closed, prior to throwing the IOException.

Annotations

@Override

toString back to summary

toString	back to summary
public String toString() Overrides java.lang.Object.toString. Doc from java.lang.Object.toString. Returns a string representation of the object. Satisfying this method's contract implies a non-`null` result must be returned. Returns:String a string representation of the object Annotations @Override

public String toString()

Overrides java.lang.Object.toString.

Doc from java.lang.Object.toString.

Returns a string representation of the object. Satisfying this method's contract implies a non-null result must be returned.

Returns:String

a string representation of the object

Annotations

@Override

public abstract Class SelectableChannelEndPoint

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private abstract Class SelectableChannelEndPoint.RunnableCloseable

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail