Package io.antmedia.servlet

Class ChunkedTransferServlet

java.lang.Object

jakarta.servlet.GenericServlet

jakarta.servlet.http.HttpServlet

io.antmedia.servlet.ChunkedTransferServlet

All Implemented Interfaces:

jakarta.servlet.Servlet, jakarta.servlet.ServletConfig, Serializable

public class ChunkedTransferServlet
extends jakarta.servlet.http.HttpServlet

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ChunkedTransferServlet.ChunkListener
static class	ChunkedTransferServlet.StatusListener

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.slf4j.Logger	logger
static final String	STREAMS
static final String	WEBAPPS

Fields inherited from class jakarta.servlet.http.HttpServlet

LEGACY_DO_HEAD

Constructor Summary

Constructors

Constructor	Description
ChunkedTransferServlet()

Method Summary

Modifier and Type	Method	Description
private void	deleteFreeDir(jakarta.servlet.http.HttpServletRequest req, String applicationName, File streamsDir)
void	deleteRequest(jakarta.servlet.http.HttpServletRequest req, jakarta.servlet.http.HttpServletResponse resp)
protected void	doDelete(jakarta.servlet.http.HttpServletRequest req, jakarta.servlet.http.HttpServletResponse resp)
protected void	doGet(jakarta.servlet.http.HttpServletRequest req, jakarta.servlet.http.HttpServletResponse resp)
protected void	doPost(jakarta.servlet.http.HttpServletRequest req, jakarta.servlet.http.HttpServletResponse resp)
protected void	doPut(jakarta.servlet.http.HttpServletRequest req, jakarta.servlet.http.HttpServletResponse resp)
void	handleGetRequest(jakarta.servlet.http.HttpServletRequest req, jakarta.servlet.http.HttpServletResponse resp)
void	handleIncomingStream(jakarta.servlet.http.HttpServletRequest req, jakarta.servlet.http.HttpServletResponse resp)
static void	logHeaders(jakarta.servlet.http.HttpServletResponse resp)
private void	mkdirIfRequired(jakarta.servlet.http.HttpServletRequest req, String applicationName)
void	readInputStream(File finalFile, File tmpFile, IChunkedCacheManager cacheManager, IParser atomparser, jakarta.servlet.AsyncContext asyncContext, InputStream inputStream, ChunkedTransferServlet.StatusListener statusListener)
void	writeChunks(File file, IChunkedCacheManager cacheManager, jakarta.servlet.AsyncContext asyncContext, ChunkedTransferServlet.ChunkListener chunkListener, String mimeType)
private void	writeInternalError(jakarta.servlet.http.HttpServletResponse resp, int status, String message)
void	writeOutputStream(File file, jakarta.servlet.AsyncContext asyncContext, String mimeType)

Methods inherited from class jakarta.servlet.http.HttpServlet

doHead, doOptions, doTrace, getLastModified, init, service, service

Methods inherited from class jakarta.servlet.GenericServlet

destroy, getInitParameter, getInitParameterNames, getServletConfig, getServletContext, getServletInfo, getServletName, init, log, log

Methods inherited from class java.lang.Object

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

Field Details

STREAMS

public static final String STREAMS

See Also:

• Constant Field Values

WEBAPPS

public static final String WEBAPPS

See Also:

• Constant Field Values

logger

protected static org.slf4j.Logger logger

Constructor Details

ChunkedTransferServlet

public ChunkedTransferServlet()

Method Details

doPut

protected void doPut(jakarta.servlet.http.HttpServletRequest req,
 jakarta.servlet.http.HttpServletResponse resp)
              throws jakarta.servlet.ServletException,
IOException

Overrides:

doPut in class jakarta.servlet.http.HttpServlet

Throws:

jakarta.servlet.ServletException

IOException

doPost

protected void doPost(jakarta.servlet.http.HttpServletRequest req,
 jakarta.servlet.http.HttpServletResponse resp)
               throws jakarta.servlet.ServletException,
IOException

Overrides:

doPost in class jakarta.servlet.http.HttpServlet

Throws:

jakarta.servlet.ServletException

IOException

handleIncomingStream

public void handleIncomingStream(jakarta.servlet.http.HttpServletRequest req,
 jakarta.servlet.http.HttpServletResponse resp)

mkdirIfRequired

private void mkdirIfRequired(jakarta.servlet.http.HttpServletRequest req,
 String applicationName)

readInputStream

public void readInputStream(File finalFile,
 File tmpFile,
 IChunkedCacheManager cacheManager,
 IParser atomparser,
 jakarta.servlet.AsyncContext asyncContext,
 InputStream inputStream,
 ChunkedTransferServlet.StatusListener statusListener)

deleteRequest

public void deleteRequest(jakarta.servlet.http.HttpServletRequest req,
 jakarta.servlet.http.HttpServletResponse resp)

doDelete

protected void doDelete(jakarta.servlet.http.HttpServletRequest req,
 jakarta.servlet.http.HttpServletResponse resp)
                 throws jakarta.servlet.ServletException,
IOException

Overrides:

doDelete in class jakarta.servlet.http.HttpServlet

Throws:

jakarta.servlet.ServletException

IOException

deleteFreeDir

private void deleteFreeDir(jakarta.servlet.http.HttpServletRequest req,
 String applicationName,
 File streamsDir)
                    throws IOException

Throws:

IOException

writeOutputStream

public void writeOutputStream(File file,
 jakarta.servlet.AsyncContext asyncContext,
 String mimeType)

logHeaders

public static void logHeaders(jakarta.servlet.http.HttpServletResponse resp)

doGet

protected void doGet(jakarta.servlet.http.HttpServletRequest req,
 jakarta.servlet.http.HttpServletResponse resp)
              throws jakarta.servlet.ServletException,
IOException

Overrides:

doGet in class jakarta.servlet.http.HttpServlet

Throws:

jakarta.servlet.ServletException

IOException

handleGetRequest

public void handleGetRequest(jakarta.servlet.http.HttpServletRequest req,
 jakarta.servlet.http.HttpServletResponse resp)

writeChunks

public void writeChunks(File file,
 IChunkedCacheManager cacheManager,
 jakarta.servlet.AsyncContext asyncContext,
 ChunkedTransferServlet.ChunkListener chunkListener,
 String mimeType)

writeInternalError

private void writeInternalError(jakarta.servlet.http.HttpServletResponse resp,
 int status,
 String message)