Java SocketStatus类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.apache.tomcat.util.net.SocketStatus类的典型用法代码示例。如果您正苦于以下问题：Java SocketStatus类的具体用法？Java SocketStatus怎么用？Java SocketStatus使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

SocketStatus类属于org.apache.tomcat.util.net包，在下文中一共展示了SocketStatus类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: event

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Process pipelined HTTP requests using the specified input and output
 * streams.
 *
 * @throws IOException error during an I/O operation
 */
@Override
public SocketState event(SocketStatus status)
    throws IOException {

    RequestInfo rp = request.getRequestProcessor();

    try {
        rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE);
        if (!getAdapter().event(request, response, status)) {
            setErrorState(ErrorState.CLOSE_NOW, null);
        }
    } catch (InterruptedIOException e) {
        setErrorState(ErrorState.CLOSE_NOW, e);
    } catch (Throwable t) {
        ExceptionUtils.handleThrowable(t);
        // 500 - Internal Server Error
        response.setStatus(500);
        setErrorState(ErrorState.CLOSE_NOW, t);
        getAdapter().log(request, response, 0);
        log.error(sm.getString("http11processor.request.process"), t);
    }

    rp.setStage(org.apache.coyote.Constants.STAGE_ENDED);

    if (getErrorState().isError() || status==SocketStatus.STOP) {
        return SocketState.CLOSED;
    } else if (!comet) {
        inputBuffer.nextRequest();
        outputBuffer.nextRequest();
        return SocketState.OPEN;
    } else {
        return SocketState.LONG;
    }
}

开发者ID:sunmingshuai，项目名称:apache-tomcat-7.0.73-with-comment，代码行数:41，代码来源:Http11AprProcessor.java

示例2: setErrorState

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Update the current error state to the new error state if the new error
 * state is more severe than the current error state.
 */
protected void setErrorState(ErrorState errorState, Throwable t) {
    boolean blockIo = this.errorState.isIoAllowed() && !errorState.isIoAllowed();
    this.errorState = this.errorState.getMostSevere(errorState);
    if (blockIo && !ContainerThreadMarker.isContainerThread() && isAsync()) {
        // The error occurred on a non-container thread during async
        // processing which means not all of the necessary clean-up will
        // have been completed. Dispatch to a container thread to do the
        // clean-up. Need to do it this way to ensure that all the necessary
        // clean-up is performed.
        if (response.getStatus() < 400) {
            response.setStatus(500);
        }
        getLog().info(sm.getString("abstractProcessor.nonContainerThreadError"), t);
        // Set the request attribute so that the async onError() event is
        // fired when the error event is processed
        request.setAttribute(RequestDispatcher.ERROR_EXCEPTION, t);
        getEndpoint().processSocketAsync(socketWrapper, SocketStatus.ERROR);
    }
}

开发者ID:liaokailin，项目名称:tomcat7，代码行数:24，代码来源:AbstractProcessor.java

示例3: event

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Process pipelined HTTP requests using the specified input and output
 * streams.
 *
 * @throws IOException
 *             error during an I/O operation
 */
@Override
public SocketState event(SocketStatus status) throws IOException {

	RequestInfo rp = request.getRequestProcessor();

	try {
		rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE);
		if (!getAdapter().event(request, response, status)) {
			setErrorState(ErrorState.CLOSE_NOW, null);
		}
	} catch (InterruptedIOException e) {
		setErrorState(ErrorState.CLOSE_NOW, e);
	} catch (Throwable t) {
		ExceptionUtils.handleThrowable(t);
		// 500 - Internal Server Error
		response.setStatus(500);
		setErrorState(ErrorState.CLOSE_NOW, t);
		getAdapter().log(request, response, 0);
		log.error(sm.getString("http11processor.request.process"), t);
	}

	rp.setStage(org.apache.coyote.Constants.STAGE_ENDED);

	if (getErrorState().isError() || status == SocketStatus.STOP) {
		return SocketState.CLOSED;
	} else if (!comet) {
		inputBuffer.nextRequest();
		outputBuffer.nextRequest();
		return SocketState.OPEN;
	} else {
		return SocketState.LONG;
	}
}

开发者ID:how2j，项目名称:lazycat，代码行数:41，代码来源:Http11AprProcessor.java

示例4: setErrorState

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Update the current error state to the new error state if the new error
 * state is more severe than the current error state.
 */
protected void setErrorState(ErrorState errorState, Throwable t) {
	boolean blockIo = this.errorState.isIoAllowed() && !errorState.isIoAllowed();
	this.errorState = this.errorState.getMostSevere(errorState);
	if (response.getStatus() < 400) {
		response.setStatus(500);
	}
	if (t != null) {
		request.setAttribute(RequestDispatcher.ERROR_EXCEPTION, t);
	}
	if (blockIo && !ContainerThreadMarker.isContainerThread() && isAsync()) {
		// The error occurred on a non-container thread during async
		// processing which means not all of the necessary clean-up will
		// have been completed. Dispatch to a container thread to do the
		// clean-up. Need to do it this way to ensure that all the necessary
		// clean-up is performed.
		getLog().info(sm.getString("abstractProcessor.nonContainerThreadError"), t);
		getEndpoint().processSocketAsync(socketWrapper, SocketStatus.ERROR);
	}
}

开发者ID:how2j，项目名称:lazycat，代码行数:24，代码来源:AbstractProcessor.java

示例5: actionInternal

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
protected void actionInternal(ActionCode actionCode, Object param) {

    if (actionCode == ActionCode.ASYNC_COMPLETE) {
        if (asyncStateMachine.asyncComplete()) {
            ((AprEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }

    } else if (actionCode == ActionCode.ASYNC_SETTIMEOUT) {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        socketWrapper.setTimeout(timeout);

    } else if (actionCode == ActionCode.ASYNC_DISPATCH) {
        if (asyncStateMachine.asyncDispatch()) {
            ((AprEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }
    }
}

开发者ID:deathspeeder，项目名称:class-guard，代码行数:28，代码来源:AjpAprProcessor.java

示例6: actionInternal

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
protected void actionInternal(ActionCode actionCode, Object param) {

    if (actionCode == ActionCode.ASYNC_COMPLETE) {
        if (asyncStateMachine.asyncComplete()) {
            ((NioEndpoint)endpoint).processSocket(this.socketWrapper.getSocket(),
                    SocketStatus.OPEN_READ, false);
        }

    } else if (actionCode == ActionCode.ASYNC_SETTIMEOUT) {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        final KeyAttachment ka =
                (KeyAttachment)socketWrapper.getSocket().getAttachment(false);
        ka.setTimeout(timeout);

    } else if (actionCode == ActionCode.ASYNC_DISPATCH) {
        if (asyncStateMachine.asyncDispatch()) {
            ((NioEndpoint)endpoint).processSocket(this.socketWrapper.getSocket(),
                    SocketStatus.OPEN_READ, true);
        }
    }
}

开发者ID:deathspeeder，项目名称:class-guard，代码行数:30，代码来源:AjpNioProcessor.java

示例7: actionInternal

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
protected void actionInternal(ActionCode actionCode, Object param) {

    if (actionCode == ActionCode.ASYNC_COMPLETE) {
        if (asyncStateMachine.asyncComplete()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }

    } else if (actionCode == ActionCode.ASYNC_SETTIMEOUT) {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        // if we are not piggy backing on a worker thread, set the timeout
        socketWrapper.setTimeout(timeout);

    } else if (actionCode == ActionCode.ASYNC_DISPATCH) {
        if (asyncStateMachine.asyncDispatch()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }
    }
}

开发者ID:deathspeeder，项目名称:class-guard，代码行数:29，代码来源:AjpProcessor.java

示例8: asyncDispatch

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
@Override
public SocketState asyncDispatch(SocketStatus status) {

    RequestInfo rp = request.getRequestProcessor();
    try {
        rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE);
        error = !adapter.asyncDispatch(request, response, status);
        resetTimeouts();
    } catch (InterruptedIOException e) {
        error = true;
    } catch (Throwable t) {
        ExceptionUtils.handleThrowable(t);
        getLog().error(sm.getString("http11processor.request.process"), t);
        error = true;
    } finally {
        if (error) {
            // 500 - Internal Server Error
            response.setStatus(500);
            adapter.log(request, response, 0);
        }
    }

    rp.setStage(org.apache.coyote.Constants.STAGE_ENDED);

    if (isAsync()) {
        if (error) {
            request.updateCounters();
            return SocketState.CLOSED;
        } else {
            return SocketState.LONG;
        }
    } else {
        request.updateCounters();
        if (error) {
            return SocketState.CLOSED;
        } else {
            return SocketState.OPEN;
        }
    }
}

开发者ID:deathspeeder，项目名称:class-guard，代码行数:41，代码来源:AbstractAjpProcessor.java

示例9: asyncDispatch

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
@Override
public SocketState asyncDispatch(SocketStatus status) {

    RequestInfo rp = request.getRequestProcessor();
    try {
        rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE);
        error = !adapter.asyncDispatch(request, response, status);
        resetTimeouts();
    } catch (InterruptedIOException e) {
        error = true;
    } catch (Throwable t) {
        ExceptionUtils.handleThrowable(t);
        getLog().error(sm.getString("http11processor.request.process"), t);
        error = true;
    } finally {
        if (error) {
            // 500 - Internal Server Error
            response.setStatus(500);
            adapter.log(request, response, 0);
        }
    }

    rp.setStage(org.apache.coyote.Constants.STAGE_ENDED);

    if (error) {
        return SocketState.CLOSED;
    } else if (isAsync()) {
        return SocketState.LONG;
    } else {
        if (!keepAlive) {
            return SocketState.CLOSED;
        } else {
            getInputBuffer().nextRequest();
            getOutputBuffer().nextRequest();
            return SocketState.OPEN;
        }
    }
}

开发者ID:deathspeeder，项目名称:class-guard，代码行数:39，代码来源:AbstractHttp11Processor.java

示例10: event

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Process pipelined HTTP requests using the specified input and output
 * streams.
 *
 * @throws IOException error during an I/O operation
 */
@Override
public SocketState event(SocketStatus status)
    throws IOException {

    RequestInfo rp = request.getRequestProcessor();

    try {
        rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE);
        error = !adapter.event(request, response, status);
    } catch (InterruptedIOException e) {
        error = true;
    } catch (Throwable t) {
        ExceptionUtils.handleThrowable(t);
        log.error(sm.getString("http11processor.request.process"), t);
        // 500 - Internal Server Error
        response.setStatus(500);
        adapter.log(request, response, 0);
        error = true;
    }

    rp.setStage(org.apache.coyote.Constants.STAGE_ENDED);

    if (error || status==SocketStatus.STOP) {
        return SocketState.CLOSED;
    } else if (!comet) {
        inputBuffer.nextRequest();
        outputBuffer.nextRequest();
        return SocketState.OPEN;
    } else {
        return SocketState.LONG;
    }
}

开发者ID:deathspeeder，项目名称:class-guard，代码行数:39，代码来源:Http11AprProcessor.java

示例11: asyncDispatch

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
@Override
public SocketState asyncDispatch(SocketStatus status) {

    RequestInfo rp = request.getRequestProcessor();
    try {
        rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE);
        if (!getAdapter().asyncDispatch(request, response, status)) {
            setErrorState(ErrorState.CLOSE_NOW, null);
        }
        resetTimeouts();
    } catch (InterruptedIOException e) {
        setErrorState(ErrorState.CLOSE_NOW, e);
    } catch (Throwable t) {
        ExceptionUtils.handleThrowable(t);
        setErrorState(ErrorState.CLOSE_NOW, t);
        getLog().error(sm.getString("http11processor.request.process"), t);
    } finally {
        if (getErrorState().isError()) {
            // 500 - Internal Server Error
            response.setStatus(500);
            adapter.log(request, response, 0);
        }
    }

    rp.setStage(org.apache.coyote.Constants.STAGE_ENDED);

    if (getErrorState().isError()) {
        return SocketState.CLOSED;
    } else if (isAsync()) {
        return SocketState.LONG;
    } else {
        if (!keepAlive) {
            return SocketState.CLOSED;
        } else {
            getInputBuffer().nextRequest();
            getOutputBuffer().nextRequest();
            return SocketState.OPEN;
        }
    }
}

开发者ID:sdw2330976，项目名称:apache-tomcat-7.0.57，代码行数:41，代码来源:AbstractHttp11Processor.java

示例12: longPoll

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
@SuppressWarnings("deprecation") // Inbound/Outbound based upgrade
@Override
protected void longPoll(SocketWrapper<Long> socket,
        Processor<Long> processor) {

    if (processor.isAsync()) {
        // Async
        socket.setAsync(true);
    } else if (processor.isComet()) {
        // Comet
        if (proto.endpoint.isRunning()) {
            socket.setComet(true);
            ((AprEndpoint) proto.endpoint).getPoller().add(
                    socket.getSocket().longValue(),
                    proto.endpoint.getSoTimeout(), true, false);
        } else {
            // Process a STOP directly
            ((AprEndpoint) proto.endpoint).processSocket(
                    socket.getSocket().longValue(),
                    SocketStatus.STOP);
        }
    } else if (processor.isUpgrade()) {
        // Upgraded
        Poller p = ((AprEndpoint) proto.endpoint).getPoller();
        if (p == null) {
            // Connector has been stopped
            release(socket, processor, true, false);
        } else {
            p.add(socket.getSocket().longValue(), -1, true, false);
        }
    } else {
        // Tomcat 7 proprietary upgrade
        ((AprEndpoint) proto.endpoint).getPoller().add(
                socket.getSocket().longValue(),
                processor.getUpgradeInbound().getReadTimeout(),
                true, false);
    }
}

开发者ID:sdw2330976，项目名称:apache-tomcat-7.0.57，代码行数:39，代码来源:Http11AprProtocol.java

示例13: setErrorState

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Update the current error state to the new error state if the new error
 * state is more severe than the current error state.
 */
protected void setErrorState(ErrorState errorState, Throwable t) {
    boolean blockIo = this.errorState.isIoAllowed() && !errorState.isIoAllowed();
    this.errorState = this.errorState.getMostSevere(errorState);
    if (blockIo && !ContainerThreadMarker.isContainerThread()) {
        // The error occurred on a non-container thread which means not all
        // of the necessary clean-up will have been completed. Dispatch to
        // a container thread to do the clean-up. Need to do it this way to
        // ensure that all the necessary clean-up is performed.
        if (response.getStatus() < 400) {
            response.setStatus(500);
        }
        getLog().info(sm.getString("abstractProcessor.nonContainerThreadError"), t);
        getEndpoint().processSocketAsync(socketWrapper, SocketStatus.CLOSE_NOW);
    }
}

开发者ID:sdw2330976，项目名称:apache-tomcat-7.0.57，代码行数:20，代码来源:AbstractProcessor.java

示例14: actionInternal

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
protected void actionInternal(ActionCode actionCode, Object param) {

    if (actionCode == ActionCode.ASYNC_COMPLETE) {
        if (asyncStateMachine.asyncComplete()) {
            ((AprEndpoint)endpoint).processSocketAsync(this.socket,
                    SocketStatus.OPEN);
        }
    } else if (actionCode == ActionCode.ASYNC_SETTIMEOUT) {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        socket.setTimeout(timeout);
    } else if (actionCode == ActionCode.ASYNC_DISPATCH) {
        if (asyncStateMachine.asyncDispatch()) {
            ((AprEndpoint)endpoint).processSocketAsync(this.socket,
                    SocketStatus.OPEN);
        }
    }
}

开发者ID:WhiteBearSolutions，项目名称:WBSAirback，代码行数:26，代码来源:AjpAprProcessor.java

示例15: actionInternal

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
protected void actionInternal(ActionCode actionCode, Object param) {

    if (actionCode == ActionCode.ASYNC_COMPLETE) {
        if (asyncStateMachine.asyncComplete()) {
            ((NioEndpoint)endpoint).processSocket(this.socket,
                    SocketStatus.OPEN, false);
        }
    } else if (actionCode == ActionCode.ASYNC_SETTIMEOUT) {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        final KeyAttachment ka = (KeyAttachment)socket.getAttachment(false);
        if (keepAliveTimeout > 0) {
            ka.setTimeout(timeout);
        }
    } else if (actionCode == ActionCode.ASYNC_DISPATCH) {
        if (asyncStateMachine.asyncDispatch()) {
            ((NioEndpoint)endpoint).processSocket(this.socket,
                    SocketStatus.OPEN, true);
        }
    }
}

开发者ID:WhiteBearSolutions，项目名称:WBSAirback，代码行数:29，代码来源:AjpNioProcessor.java

示例16: actionInternal

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
protected void actionInternal(ActionCode actionCode, Object param) {

    if (actionCode == ActionCode.ASYNC_COMPLETE) {
        if (asyncStateMachine.asyncComplete()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socket,
                    SocketStatus.OPEN);
        }
    } else if (actionCode == ActionCode.ASYNC_SETTIMEOUT) {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        // if we are not piggy backing on a worker thread, set the timeout
        socket.setTimeout(timeout);
    } else if (actionCode == ActionCode.ASYNC_DISPATCH) {
        if (asyncStateMachine.asyncDispatch()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socket,
                    SocketStatus.OPEN);
        }
    }
}

开发者ID:WhiteBearSolutions，项目名称:WBSAirback，代码行数:27，代码来源:AjpProcessor.java

示例17: asyncDispatch

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
@Override
public SocketState asyncDispatch(SocketStatus status) {

    RequestInfo rp = request.getRequestProcessor();
    try {
        rp.setStage(org.apache.coyote.Constants.STAGE_SERVICE);
        error = !adapter.asyncDispatch(request, response, status);
    } catch (InterruptedIOException e) {
        error = true;
    } catch (Throwable t) {
        ExceptionUtils.handleThrowable(t);
        getLog().error(sm.getString("http11processor.request.process"), t);
        error = true;
    } finally {
        if (error) {
            // 500 - Internal Server Error
            response.setStatus(500);
            adapter.log(request, response, 0);
        }
    }

    rp.setStage(org.apache.coyote.Constants.STAGE_ENDED);

    if (isAsync()) {
        if (error) {
            request.updateCounters();
            return SocketState.CLOSED;
        } else {
            return SocketState.LONG;
        }
    } else {
        request.updateCounters();
        if (error) {
            return SocketState.CLOSED;
        } else {
            return SocketState.OPEN;
        }
    }
}

开发者ID:WhiteBearSolutions，项目名称:WBSAirback，代码行数:40，代码来源:AbstractAjpProcessor.java

示例18: action

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
@SuppressWarnings("incomplete-switch") // Other cases are handled by action()
protected void actionInternal(ActionCode actionCode, Object param) {

    switch (actionCode) {
    case ASYNC_COMPLETE: {
        if (asyncStateMachine.asyncComplete()) {
            ((AprEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }
        break;
    }
    case ASYNC_SETTIMEOUT: {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        socketWrapper.setTimeout(timeout);
        break;
    }
    case ASYNC_DISPATCH: {
        if (asyncStateMachine.asyncDispatch()) {
            ((AprEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }
        break;
    }
    }
}

开发者ID:liaokailin，项目名称:tomcat7，代码行数:34，代码来源:AjpAprProcessor.java

示例19: action

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
@SuppressWarnings("incomplete-switch") // Other cases are handled by action()
protected void actionInternal(ActionCode actionCode, Object param) {

    switch (actionCode) {
    case ASYNC_COMPLETE: {
        if (asyncStateMachine.asyncComplete()) {
            ((NioEndpoint)endpoint).processSocket(this.socketWrapper.getSocket(),
                    SocketStatus.OPEN_READ, false);
        }
        break;
    }
    case ASYNC_SETTIMEOUT: {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        final KeyAttachment ka =
                (KeyAttachment)socketWrapper.getSocket().getAttachment();
        ka.setTimeout(timeout);
        break;
    }
    case ASYNC_DISPATCH: {
        if (asyncStateMachine.asyncDispatch()) {
            ((NioEndpoint)endpoint).processSocket(this.socketWrapper.getSocket(),
                    SocketStatus.OPEN_READ, true);
        }
        break;
    }
    }
}

开发者ID:liaokailin，项目名称:tomcat7，代码行数:36，代码来源:AjpNioProcessor.java

示例20: action

import org.apache.tomcat.util.net.SocketStatus; //导入依赖的package包/类
/**
 * Send an action to the connector.
 *
 * @param actionCode Type of the action
 * @param param Action parameter
 */
@Override
@SuppressWarnings("incomplete-switch") // Other cases are handled by action()
protected void actionInternal(ActionCode actionCode, Object param) {

    switch (actionCode) {
    case ASYNC_COMPLETE: {
        if (asyncStateMachine.asyncComplete()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }
        break;
    }
    case ASYNC_SETTIMEOUT: {
        if (param == null) return;
        long timeout = ((Long)param).longValue();
        // if we are not piggy backing on a worker thread, set the timeout
        socketWrapper.setTimeout(timeout);
        break;
    }
    case ASYNC_DISPATCH: {
        if (asyncStateMachine.asyncDispatch()) {
            ((JIoEndpoint)endpoint).processSocketAsync(this.socketWrapper,
                    SocketStatus.OPEN_READ);
        }
        break;
    }
    }
}

开发者ID:liaokailin，项目名称:tomcat7，代码行数:35，代码来源:AjpProcessor.java

注：本文中的org.apache.tomcat.util.net.SocketStatus类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java EdgePair类代码示例发布时间：2022-05-23

Java AbstractShallowCallback类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：17987|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9573|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8130|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8513|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8417|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9313|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8380|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7813|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8368|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7363|2022-11-06

客服电话

电子邮件

Java SocketStatus类代码示例

示例1: event

示例2: setErrorState

示例3: event

示例4: setErrorState

示例5: actionInternal

示例6: actionInternal

示例7: actionInternal

示例8: asyncDispatch

示例9: asyncDispatch

示例10: event

示例11: asyncDispatch

示例12: longPoll

示例13: setErrorState

示例14: actionInternal

示例15: actionInternal

示例16: actionInternal

示例17: asyncDispatch

示例18: action

示例19: action

示例20: action

请发表评论

全部评论

上一篇：

下一篇：

微信小程序虚拟列表（长列表）

librespeed/speedtest: Self-hosted Speedt

CVE-2022-36415

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053