|
Tomcat example source code file (MemoryProtocolHandler.java)
The Tomcat MemoryProtocolHandler.java source code/* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.apache.coyote.memory; import java.io.IOException; import java.util.Iterator; import org.apache.tomcat.util.buf.ByteChunk; import org.apache.coyote.Adapter; import org.apache.coyote.InputBuffer; import org.apache.coyote.OutputBuffer; import org.apache.coyote.ProtocolHandler; import org.apache.coyote.Request; import org.apache.coyote.Response; /** * Abstract the protocol implementation, including threading, etc. * Processor is single threaded and specific to stream-based protocols, * will not fit Jk protocols like JNI. * * @author Remy Maucherat */ public class MemoryProtocolHandler implements ProtocolHandler { // ------------------------------------------------------------- Properties /** * Pass config info. */ public void setAttribute(String name, Object value) { } public Object getAttribute(String name) { return null; } public Iterator getAttributeNames() { return null ; } /** * Associated adapter. */ protected Adapter adapter = null; /** * The adapter, used to call the connector. */ public void setAdapter(Adapter adapter) { this.adapter = adapter; } public Adapter getAdapter() { return (adapter); } // ------------------------------------------------ ProtocolHandler Methods /** * Init the protocol. */ public void init() throws Exception { } /** * Start the protocol. */ public void start() throws Exception { } public void pause() throws Exception { } public void resume() throws Exception { } public void destroy() throws Exception { } // --------------------------------------------------------- Public Methods /** * Process specified request. */ public void process(Request request, ByteChunk input, Response response, ByteChunk output) throws Exception { InputBuffer inputBuffer = new ByteChunkInputBuffer(input); OutputBuffer outputBuffer = new ByteChunkOutputBuffer(output); request.setInputBuffer(inputBuffer); response.setOutputBuffer(outputBuffer); adapter.service(request, response); } // --------------------------------------------- ByteChunkInputBuffer Class protected class ByteChunkInputBuffer implements InputBuffer { protected ByteChunk input = null; public ByteChunkInputBuffer(ByteChunk input) { this.input = input; } public int doRead(ByteChunk chunk, Request request) throws IOException { return input.substract(chunk); } } // -------------------------------------------- ByteChunkOuptutBuffer Class protected class ByteChunkOutputBuffer implements OutputBuffer { protected ByteChunk output = null; public ByteChunkOutputBuffer(ByteChunk output) { this.output = output; } public int doWrite(ByteChunk chunk, Response response) throws IOException { output.append(chunk); return chunk.getLength(); } } } Other Tomcat examples (source code examples)Here is a short list of links related to this Tomcat MemoryProtocolHandler.java source code file: |
... this post is sponsored by my books ... | |
#1 New Release! |
FP Best Seller |
Copyright 1998-2021 Alvin Alexander, alvinalexander.com
All Rights Reserved.
A percentage of advertising revenue from
pages under the /java/jwarehouse
URI on this website is
paid back to open source projects.