network/sasl/SaslServerBootstrap.java

0001 /*
0002  * Licensed to the Apache Software Foundation (ASF) under one or more
0003  * contributor license agreements.  See the NOTICE file distributed with
0004  * this work for additional information regarding copyright ownership.
0005  * The ASF licenses this file to You under the Apache License, Version 2.0
0006  * (the "License"); you may not use this file except in compliance with
0007  * the License.  You may obtain a copy of the License at
0008  *
0009  *    http://www.apache.org/licenses/LICENSE-2.0
0010  *
0011  * Unless required by applicable law or agreed to in writing, software
0012  * distributed under the License is distributed on an "AS IS" BASIS,
0013  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
0014  * See the License for the specific language governing permissions and
0015  * limitations under the License.
0016  */
0017
0018 package org.apache.spark.network.sasl;
0019
0020 import io.netty.channel.Channel;
0021
0022 import org.apache.spark.network.server.RpcHandler;
0023 import org.apache.spark.network.server.TransportServerBootstrap;
0024 import org.apache.spark.network.util.TransportConf;
0025
0026 /**
0027  * A bootstrap which is executed on a TransportServer's client channel once a client connects
0028  * to the server. This allows customizing the client channel to allow for things such as SASL
0029  * authentication.
0030  */
0031 public class SaslServerBootstrap implements TransportServerBootstrap {
0032
0033   private final TransportConf conf;
0034   private final SecretKeyHolder secretKeyHolder;
0035
0036   public SaslServerBootstrap(TransportConf conf, SecretKeyHolder secretKeyHolder) {
0037     this.conf = conf;
0038     this.secretKeyHolder = secretKeyHolder;
0039   }
0040
0041   /**
0042    * Wrap the given application handler in a SaslRpcHandler that will handle the initial SASL
0043    * negotiation.
0044    */
0045   public RpcHandler doBootstrap(Channel channel, RpcHandler rpcHandler) {
0046     return new SaslRpcHandler(conf, channel, rpcHandler, secretKeyHolder);
0047   }
0048
0049 }