| // |
| // 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 com.cloud.utils.nio; |
| |
| import java.io.IOException; |
| import java.net.InetSocketAddress; |
| import java.nio.channels.ClosedChannelException; |
| import java.nio.channels.SelectionKey; |
| import java.nio.channels.ServerSocketChannel; |
| import java.nio.channels.spi.SelectorProvider; |
| import java.util.Map; |
| import java.util.WeakHashMap; |
| |
| import org.apache.cloudstack.framework.ca.CAService; |
| import org.apache.log4j.Logger; |
| |
| public class NioServer extends NioConnection { |
| private final static Logger s_logger = Logger.getLogger(NioServer.class); |
| |
| protected InetSocketAddress _localAddr; |
| private ServerSocketChannel _serverSocket; |
| |
| protected Map<String, Link> _links; |
| |
| public NioServer(final String name, final int port, final int workers, final HandlerFactory factory, final CAService caService) { |
| super(name, port, workers, factory); |
| setCAService(caService); |
| _localAddr = null; |
| _links = new WeakHashMap<String, Link>(10240); |
| } |
| |
| public int getPort() { |
| return _serverSocket.socket().getLocalPort(); |
| } |
| |
| @Override |
| protected void init() throws IOException { |
| _selector = SelectorProvider.provider().openSelector(); |
| |
| _serverSocket = ServerSocketChannel.open(); |
| _serverSocket.configureBlocking(false); |
| |
| _localAddr = new InetSocketAddress(_port); |
| _serverSocket.socket().bind(_localAddr); |
| |
| _serverSocket.register(_selector, SelectionKey.OP_ACCEPT, null); |
| |
| s_logger.info("NioServer started and listening on " + _serverSocket.socket().getLocalSocketAddress()); |
| } |
| |
| @Override |
| public void cleanUp() throws IOException { |
| super.cleanUp(); |
| if (_serverSocket != null) { |
| _serverSocket.close(); |
| } |
| s_logger.info("NioConnection stopped on " + _localAddr.toString()); |
| } |
| |
| @Override |
| protected void registerLink(final InetSocketAddress addr, final Link link) { |
| _links.put(addr.getAddress().toString(), link); |
| } |
| |
| @Override |
| protected void unregisterLink(final InetSocketAddress saddr) { |
| _links.remove(saddr.getAddress().toString()); |
| } |
| |
| /** |
| * Sends the data to the address specified. If address is not already |
| * connected, this does nothing and returns null. If address is already |
| * connected, then it returns the attached object so the caller can |
| * prepare for any responses. |
| * @param saddr |
| * @param data |
| * @return null if not sent. attach object in link if sent. |
| */ |
| public Object send(final InetSocketAddress saddr, final byte[] data) throws ClosedChannelException { |
| final Link link = _links.get(saddr.getAddress().toString()); |
| if (link == null) { |
| return null; |
| } |
| link.send(data); |
| return link.attachment(); |
| } |
| } |