org.apache.tomcat.util.net

Class NioEndpoint.Sendfile

java.lang.Object

org.apache.tomcat.util.net.NioEndpoint.Sendfile

All Implemented Interfaces:

Runnable

Enclosing class:

NioEndpoint

public class NioEndpoint.Sendfile
extends Object
implements Runnable

Sendfile Created on Mar 7, 2012 at 4:04:59 PM

Author:

Nabil Benothman

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicInteger	counter
protected ConcurrentLinkedQueue<NioEndpoint.SendfileData>	fileDatas
protected ConcurrentLinkedQueue<NioEndpoint.SendfileData>	recycledFileDatas
protected int	size

Constructor Summary

Constructors

Constructor and Description
Sendfile()

Method Summary

Modifier and Type	Method and Description
boolean	add(NioEndpoint.SendfileData data) Add the sendfile data to the sendfile poller.
protected void	destroy() Destroy the SendFile
int	getSendfileCount()
NioEndpoint.SendfileData	getSendfileData() Poll the head of the recycled object list if it is not empty, else create a new one.
protected void	init() Initialize the Sendfile
protected NioEndpoint.SendfileData	poll() Retrieves and removes the head of this queue, or returns null if this queue is empty.
void	recycleSendfileData(NioEndpoint.SendfileData data)
protected void	remove(NioEndpoint.SendfileData data) Remove socket from the poller.
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

size

protected int size

fileDatas

protected ConcurrentLinkedQueue<NioEndpoint.SendfileData> fileDatas

recycledFileDatas

protected ConcurrentLinkedQueue<NioEndpoint.SendfileData> recycledFileDatas

counter

protected AtomicInteger counter

Constructor Detail

Sendfile

public Sendfile()

Method Detail

getSendfileCount

public int getSendfileCount()

Returns:

the number of send file

run

public void run()

Specified by:

run in interface Runnable

init

protected void init()

Initialize the Sendfile

destroy

protected void destroy()

Destroy the SendFile

recycleSendfileData

public void recycleSendfileData(NioEndpoint.SendfileData data)

Parameters:

data -

getSendfileData

public NioEndpoint.SendfileData getSendfileData()

Poll the head of the recycled object list if it is not empty, else create a new one.

Returns:

a SendfileData

add

public boolean add(NioEndpoint.SendfileData data)

Add the sendfile data to the sendfile poller. Note that in most cases, the initial non blocking calls to sendfile will return right away, and will be handled asynchronously inside the kernel. As a result, the poller will never be used.

Parameters:

data - containing the reference to the data which should be sent

Returns:

true if all the data has been sent right away, and false otherwise

poll

protected NioEndpoint.SendfileData poll()

Retrieves and removes the head of this queue, or returns null if this queue is empty.

Returns:

the head of this queue, or null if this queue is empty

remove

protected void remove(NioEndpoint.SendfileData data)

Remove socket from the poller.

Parameters:

data - the sendfile data which should be removed