org.globus.wsrf.container
Class ServiceThread

java.lang.Object
  java.lang.Thread
      org.globus.wsrf.container.ServiceThread

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

GSIServiceThread

public class ServiceThread

extends Thread

This class is responsible for reading the request from the request queue, format it, and pass it through the Axis engine.

Field Summary

private static byte[]	ACTION_HEADER
private String	baseURL
private byte[]	buf
private static int	BUFSIZ
private boolean	chunked
private static byte[]	CHUNKED
private String	configRootPath
private static byte[]	CONNECTION_CLOSE
protected static byte[]	CONTENT_LENGTH
protected static String	CONTENT_TYPE
private static byte[]	ENCODING_HEADER
private AxisEngine	engine
private static String	FILE_NOT_FOUND
private static byte[]	FILE_NOT_FOUND_MSG
private StringBuffer	fileName
private static byte[]	GET_HEADER
private static byte[]	HEAD_HEADER
private static byte[]	HEADER_ENDER
protected static byte[]	HTML_MIME_STUFF
protected static byte[]	HTTP_10
protected static byte[]	HTTP_11
private static byte[]	HTTP_BASE_VERSION
private static int	HTTP_GET
private static int	HTTP_HEAD
private static int	HTTP_POST
protected boolean	http11
private int	httpRequest
private static org.globus.util.I18n	i18n
private NonBlockingBufferedInputStream	is
private static byte[]	ISE
protected static byte[]	JAR_MIME_STUFF
protected static byte[]	JNLP_MIME_STUFF
private static byte[]	LENGTH_HEADER
private static org.apache.commons.logging.Log	logger
protected MessageContext	msgContext
private static byte[]	OK
(package private) static PerformanceLog	performanceLogger
(package private) static PerformanceLog	performanceProcessLogger
private static byte[]	POST_HEADER
private ServiceRequestQueue	queue
private Message	responseMsg
static String	SEND_CONTENT_LENGTH
private boolean	sendContentLength
protected static byte[]	SEPARATOR
private StringBuffer	soapAction
private ServiceThreadPool	threadPool
private static byte[]	toLower
private static byte[]	TRANSFER_ENCODING_CHUNKED
protected static byte[]	UNAUTH
private String	webRootPath
private boolean	webStartEnabled
protected static byte[]	XML_MIME_STUFF

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

ServiceThread(ServiceRequestQueue queue, ServiceThreadPool pool, AxisEngine engine)

Method Summary

private byte[]	createHeaderReply(byte[] code, byte[] contentType, long length)
protected byte[]	doFault(Exception e, MessageContext msgContext, String filepart)
protected void	doGet(AxisEngine engine, MessageContext msgContext, OutputStream out, String filePart, boolean returnContent)
protected void	doGetSub(AxisEngine engine, MessageContext msgContext, OutputStream out, String filePart, boolean returnContent)
protected void	doPost(AxisEngine engine, MessageContext msgContext)
protected void	doWSDL(AxisEngine engine, MessageContext msgContext, OutputStream out, String filePart)
static String	getConfigRootPath(AxisEngine engine)
private static String	getHost(AxisEngine engine)
protected String	getProtocol()
static String	getWebRootPath(AxisEngine engine)
private void	handleOutOfMemoryError()
boolean	matches(byte[] buf, byte[] target) does tolower[buf] match the target byte array, up to the target's length?
boolean	matches(byte[] buf, int bufIdx, byte[] target) Case-insensitive match of a target byte [] to a source byte [], starting from a particular offset into the source.
private int	parseHeaders(InputStream is, StringBuffer soapAction, StringBuffer fileName) Read all mime headers, returning the value of Content-Length and SOAPAction.
private void	parseRequest(StringBuffer fileName, byte[] buf, int n, int offset)
protected void	process(ServiceRequest request)
private void	putInt(OutputStream out, int value) output an integer into the output stream
private int	readLine(InputStream is, byte[] b, int off, int len) Read a single line from the input stream
private void	reset()
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static org.apache.commons.logging.Log logger

i18n

private static org.globus.util.I18n i18n

queue

private ServiceRequestQueue queue

threadPool

private ServiceThreadPool threadPool

engine

private AxisEngine engine

msgContext

protected MessageContext msgContext

is

private NonBlockingBufferedInputStream is

responseMsg

private Message responseMsg

soapAction

private StringBuffer soapAction

fileName

private StringBuffer fileName

httpRequest

private int httpRequest

sendContentLength

private boolean sendContentLength

http11

protected boolean http11

chunked

private boolean chunked

performanceLogger

static PerformanceLog performanceLogger

performanceProcessLogger

static PerformanceLog performanceProcessLogger

SEND_CONTENT_LENGTH

public static final String SEND_CONTENT_LENGTH

See Also:

Constant Field Values

HTTP_10

protected static final byte[] HTTP_10

HTTP_11

protected static final byte[] HTTP_11

OK

private static final byte[] OK

UNAUTH

protected static final byte[] UNAUTH

ISE

private static final byte[] ISE

FILE_NOT_FOUND

private static final String FILE_NOT_FOUND

See Also:

Constant Field Values

FILE_NOT_FOUND_MSG

private static final byte[] FILE_NOT_FOUND_MSG

XML_MIME_STUFF

protected static final byte[] XML_MIME_STUFF

HTML_MIME_STUFF

protected static final byte[] HTML_MIME_STUFF

JNLP_MIME_STUFF

protected static final byte[] JNLP_MIME_STUFF

JAR_MIME_STUFF

protected static final byte[] JAR_MIME_STUFF

CONTENT_TYPE

protected static final String CONTENT_TYPE

See Also:

Constant Field Values

CONTENT_LENGTH

protected static final byte[] CONTENT_LENGTH

CONNECTION_CLOSE

private static final byte[] CONNECTION_CLOSE

TRANSFER_ENCODING_CHUNKED

private static final byte[] TRANSFER_ENCODING_CHUNKED

SEPARATOR

protected static final byte[] SEPARATOR

toLower

private static final byte[] toLower

LENGTH_HEADER

private static final byte[] LENGTH_HEADER

ACTION_HEADER

private static final byte[] ACTION_HEADER

GET_HEADER

private static final byte[] GET_HEADER

HEAD_HEADER

private static final byte[] HEAD_HEADER

POST_HEADER

private static final byte[] POST_HEADER

HEADER_ENDER

private static final byte[] HEADER_ENDER

ENCODING_HEADER

private static final byte[] ENCODING_HEADER

CHUNKED

private static final byte[] CHUNKED

HTTP_BASE_VERSION

private static final byte[] HTTP_BASE_VERSION

HTTP_GET

private static final int HTTP_GET

See Also:

Constant Field Values

HTTP_HEAD

private static final int HTTP_HEAD

See Also:

Constant Field Values

HTTP_POST

private static final int HTTP_POST

See Also:

Constant Field Values

BUFSIZ

private static final int BUFSIZ

See Also:

Constant Field Values

buf

private byte[] buf

webRootPath

private String webRootPath

webStartEnabled

private boolean webStartEnabled

configRootPath

private String configRootPath

baseURL

private String baseURL

Constructor Detail

ServiceThread

public ServiceThread(ServiceRequestQueue queue,
                     ServiceThreadPool pool,
                     AxisEngine engine)

Method Detail

getHost

private static String getHost(AxisEngine engine)
                       throws IOException

Throws:

IOException

getWebRootPath

public static String getWebRootPath(AxisEngine engine)
                             throws IOException

Throws:

IOException

getConfigRootPath

public static String getConfigRootPath(AxisEngine engine)

reset

private void reset()

handleOutOfMemoryError

private void handleOutOfMemoryError()

run

public void run()

getProtocol

protected String getProtocol()

process

protected void process(ServiceRequest request)

createHeaderReply

private byte[] createHeaderReply(byte[] code,
                                 byte[] contentType,
                                 long length)
                          throws IOException

Throws:

IOException

doWSDL

protected void doWSDL(AxisEngine engine,
                      MessageContext msgContext,
                      OutputStream out,
                      String filePart)
               throws IOException

Throws:

IOException

doGet

protected void doGet(AxisEngine engine,
                     MessageContext msgContext,
                     OutputStream out,
                     String filePart,
                     boolean returnContent)

doGetSub

protected void doGetSub(AxisEngine engine,
                        MessageContext msgContext,
                        OutputStream out,
                        String filePart,
                        boolean returnContent)
                 throws IOException

Throws:

IOException

doPost

protected void doPost(AxisEngine engine,
                      MessageContext msgContext)
               throws AxisFault

Throws:

AxisFault

doFault

protected byte[] doFault(Exception e,
                         MessageContext msgContext,
                         String filepart)

readLine

private int readLine(InputStream is,
                     byte[] b,
                     int off,
                     int len)
              throws IOException

Read a single line from the input stream

Parameters:

is - inputstream to read from

b - byte array to read into

off - starting offset into the byte array

len - maximum number of bytes to read

Throws:

IOException

parseRequest

private void parseRequest(StringBuffer fileName,
                          byte[] buf,
                          int n,
                          int offset)
                   throws IOException

Throws:

IOException

parseHeaders

private int parseHeaders(InputStream is,
                         StringBuffer soapAction,
                         StringBuffer fileName)
                  throws IOException

Read all mime headers, returning the value of Content-Length and SOAPAction.

Parameters:

is - InputStream to read from

soapAction - StringBuffer to return the soapAction into

Returns:

Content-Length

Throws:

IOException

matches

public boolean matches(byte[] buf,
                       byte[] target)

does tolower[buf] match the target byte array, up to the target's length?

matches

public boolean matches(byte[] buf,
                       int bufIdx,
                       byte[] target)

Case-insensitive match of a target byte [] to a source byte [], starting from a particular offset into the source.

putInt

private void putInt(OutputStream out,
                    int value)
             throws IOException

output an integer into the output stream

Parameters:

out - OutputStream to be written to

value - Integer value to be written.

Throws:

IOException