//
// ========================================================================
// Copyright (c) 1995-2020 Mort Bay Consulting Pty Ltd and others.
//
// This program and the accompanying materials are made available under
// the terms of the Eclipse Public License 2.0 which is available at
// https://www.eclipse.org/legal/epl-2.0
//
// This Source Code may also be made available under the following
// Secondary Licenses when the conditions for such availability set
// forth in the Eclipse Public License, v. 2.0 are satisfied:
// the Apache License v2.0 which is available at
// https://www.apache.org/licenses/LICENSE-2.0
//
// SPDX-License-Identifier: EPL-2.0 OR Apache-2.0
// ========================================================================
//

package org.eclipse.jetty.server;

import java.util.Objects;

import org.eclipse.jetty.http.HttpVersion;
import org.eclipse.jetty.io.Connection;
import org.eclipse.jetty.io.EndPoint;
import org.eclipse.jetty.util.annotation.Name;

A Connection Factory for HTTP Connections.

Accepts connections either directly or via SSL and/or ALPN chained connection factories. The accepted HttpConnections are configured by a HttpConfiguration instance that is either created by default or passed in to the constructor.

/** * A Connection Factory for HTTP Connections. * <p>Accepts connections either directly or via SSL and/or ALPN chained connection factories. The accepted * {@link HttpConnection}s are configured by a {@link HttpConfiguration} instance that is either created by * default or passed in to the constructor. */
public class HttpConnectionFactory extends AbstractConnectionFactory implements HttpConfiguration.ConnectionFactory { private final HttpConfiguration _config; private boolean _recordHttpComplianceViolations; private boolean _useInputDirectByteBuffers; private boolean _useOutputDirectByteBuffers; public HttpConnectionFactory() { this(new HttpConfiguration()); } public HttpConnectionFactory(@Name("config") HttpConfiguration config) { super(HttpVersion.HTTP_1_1.asString()); _config = Objects.requireNonNull(config); addBean(_config); setUseInputDirectByteBuffers(_config.isUseInputDirectByteBuffers()); setUseOutputDirectByteBuffers(_config.isUseOutputDirectByteBuffers()); } @Override public HttpConfiguration getHttpConfiguration() { return _config; } public boolean isRecordHttpComplianceViolations() { return _recordHttpComplianceViolations; } public void setRecordHttpComplianceViolations(boolean recordHttpComplianceViolations) { this._recordHttpComplianceViolations = recordHttpComplianceViolations; } public boolean isUseInputDirectByteBuffers() { return _useInputDirectByteBuffers; } public void setUseInputDirectByteBuffers(boolean useInputDirectByteBuffers) { _useInputDirectByteBuffers = useInputDirectByteBuffers; } public boolean isUseOutputDirectByteBuffers() { return _useOutputDirectByteBuffers; } public void setUseOutputDirectByteBuffers(boolean useOutputDirectByteBuffers) { _useOutputDirectByteBuffers = useOutputDirectByteBuffers; } @Override public Connection newConnection(Connector connector, EndPoint endPoint) { HttpConnection connection = new HttpConnection(_config, connector, endPoint, isRecordHttpComplianceViolations()); connection.setUseInputDirectByteBuffers(isUseInputDirectByteBuffers()); connection.setUseOutputDirectByteBuffers(isUseOutputDirectByteBuffers()); return configure(connection, connector, endPoint); } }