Package org.eclipse.jetty.server

Class LocalConnector.LocalEndPoint

java.lang.Object

org.eclipse.jetty.io.IdleTimeout

org.eclipse.jetty.io.AbstractEndPoint

org.eclipse.jetty.io.ByteArrayEndPoint

org.eclipse.jetty.server.LocalConnector.LocalEndPoint

All Implemented Interfaces:

Closeable, AutoCloseable, EndPoint

Enclosing class:

LocalConnector

public class LocalConnector.LocalEndPoint
extends ByteArrayEndPoint

Local EndPoint

Field Summary

Fields

Modifier and Type	Field	Description
private final CountDownLatch	_closed
private ByteBuffer	_responseData

Constructor Summary

Constructors

Constructor	Description
LocalEndPoint()

Method Summary

Modifier and Type	Method	Description
void	doShutdownOutput()
protected void	execute(Runnable task)
String	getResponse()	Wait for a response using a parser to detect the end of message
String	getResponse(boolean head, long time, TimeUnit unit)	Wait for a response using a parser to detect the end of message
ByteBuffer	getResponseData()	Remaining output ByteBuffer after calls to getResponse() or waitForResponse(boolean, long, TimeUnit)
void	onClose()	Callback method invoked when this EndPoint is close.
ByteBuffer	waitForResponse(boolean head, long time, TimeUnit unit)	Wait for a response using a parser to detect the end of message
void	waitUntilClosed()
void	waitUntilClosedOrIdleFor(long idleFor, TimeUnit units)

Methods inherited from class org.eclipse.jetty.io.ByteArrayEndPoint

addInput, addInput, addInput, addInputAndExecute, addInputEOF, doClose, fill, flush, getLocalAddress, getOutput, getOutputString, getOutputString, getRemoteAddress, getTransport, hasMore, isGrowOutput, needsFillInterest, onIncompleteFlush, reset, setGrowOutput, setOutput, takeOutput, takeOutputString, takeOutputString, toString, waitForOutput

Methods inherited from class org.eclipse.jetty.io.AbstractEndPoint

checkFill, checkFlush, close, close, doShutdownInput, fillInterested, getConnection, getCreatedTimeStamp, getFillInterest, getWriteFlusher, isFillInterested, isInputShutdown, isOpen, isOptimizedForDirectBuffers, isOutputShutdown, onClose, onIdleExpired, onOpen, setConnection, shutdownInput, shutdownOutput, toConnectionString, toEndPointString, tryFillInterested, upgrade, write

Methods inherited from class org.eclipse.jetty.io.IdleTimeout

checkIdleTimeout, getIdleFor, getIdleTimeout, getScheduler, notIdle, setIdleTimeout

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.eclipse.jetty.io.EndPoint

getIdleTimeout, setIdleTimeout

Field Details

_closed

private final CountDownLatch _closed

_responseData

private ByteBuffer _responseData

Constructor Details

LocalEndPoint

public LocalEndPoint()

Method Details

execute

protected void execute(Runnable task)

Overrides:

execute in class ByteArrayEndPoint

onClose

public void onClose()

Description copied from interface: EndPoint

Callback method invoked when this EndPoint is close.

Specified by:

onClose in interface EndPoint

Overrides:

onClose in class AbstractEndPoint

See Also:

• EndPoint.onOpen()

doShutdownOutput

public void doShutdownOutput()

Overrides:

doShutdownOutput in class ByteArrayEndPoint

waitUntilClosed

public void waitUntilClosed()

waitUntilClosedOrIdleFor

public void waitUntilClosedOrIdleFor(long idleFor,
 TimeUnit units)

getResponseData

public ByteBuffer getResponseData()

Remaining output ByteBuffer after calls to getResponse() or waitForResponse(boolean, long, TimeUnit)

Returns:

the remaining response data buffer

getResponse

public String getResponse()
                   throws Exception

Wait for a response using a parser to detect the end of message

Returns:

Buffer containing full response or null for EOF;

Throws:

Exception - if the response cannot be parsed

getResponse

public String getResponse(boolean head,
 long time,
 TimeUnit unit)
                   throws Exception

Wait for a response using a parser to detect the end of message

Parameters:

head - whether the request is a HEAD request

time - the maximum time to wait

unit - the time unit of the timeout argument

Returns:

Buffer containing full response or null for EOF;

Throws:

Exception - if the response cannot be parsed

waitForResponse

public ByteBuffer waitForResponse(boolean head,
 long time,
 TimeUnit unit)
                           throws Exception

Wait for a response using a parser to detect the end of message

Parameters:

head - whether the request is a HEAD request

time - the maximum time to wait

unit - the time unit of the timeout argument

Returns:

Buffer containing full response or null for EOF;

Throws:

Exception - if the response cannot be parsed