1 /*

     2  * Copyright (c) 2008, 2013, Oracle and/or its affiliates. All rights reserved.

     3  * Copyright 2012 SAP AG. All rights reserved.

     4  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

     5  *

     6  * This code is free software; you can redistribute it and/or modify it

     7  * under the terms of the GNU General Public License version 2 only, as

     8  * published by the Free Software Foundation.  Oracle designates this

     9  * particular file as subject to the "Classpath" exception as provided

    10  * by Oracle in the LICENSE file that accompanied this code.

    11  *

    12  * This code is distributed in the hope that it will be useful, but WITHOUT

    13  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or

    14  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License

    15  * version 2 for more details (a copy is included in the LICENSE file that

    16  * accompanied this code).

    17  *

    18  * You should have received a copy of the GNU General Public License version

    19  * 2 along with this work; if not, write to the Free Software Foundation,

    20  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

    21  *

    22  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA

    23  * or visit www.oracle.com if you need additional information or have any

    24  * questions.

    25  */

    26 

    27 package sun.nio.ch;

    28 

    29 import java.nio.channels.*;

    30 import java.nio.channels.spi.AsynchronousChannelProvider;

    31 import java.util.concurrent.ExecutorService;

    32 import java.util.concurrent.ThreadFactory;

    33 import java.io.IOException;

    34 

    35 public class AixAsynchronousChannelProvider

    36     extends AsynchronousChannelProvider

    37 {

    38     private static volatile AixPollPort defaultPort;

    39 

    40     private AixPollPort defaultEventPort() throws IOException {

    41         if (defaultPort == null) {

    42             synchronized (AixAsynchronousChannelProvider.class) {

    43                 if (defaultPort == null) {

    44                     defaultPort = new AixPollPort(this, ThreadPool.getDefault()).start();

    45                 }

    46             }

    47         }

    48         return defaultPort;

    49     }

    50 

    51     public AixAsynchronousChannelProvider() {

    52     }

    53 

    54     @Override

    55     public AsynchronousChannelGroup openAsynchronousChannelGroup(int nThreads, ThreadFactory factory)

    56         throws IOException

    57     {

    58         return new AixPollPort(this, ThreadPool.create(nThreads, factory)).start();

    59     }

    60 

    61     @Override

    62     public AsynchronousChannelGroup openAsynchronousChannelGroup(ExecutorService executor, int initialSize)

    63         throws IOException

    64     {

    65         return new AixPollPort(this, ThreadPool.wrap(executor, initialSize)).start();

    66     }

    67 

    68     private Port toPort(AsynchronousChannelGroup group) throws IOException {

    69         if (group == null) {

    70             return defaultEventPort();

    71         } else {

    72             if (!(group instanceof AixPollPort))

    73                 throw new IllegalChannelGroupException();

    74             return (Port)group;

    75         }

    76     }

    77 

    78     @Override

    79     public AsynchronousServerSocketChannel openAsynchronousServerSocketChannel(AsynchronousChannelGroup group)

    80         throws IOException

    81     {

    82         return new UnixAsynchronousServerSocketChannelImpl(toPort(group));

    83     }

    84 

    85     @Override

    86     public AsynchronousSocketChannel openAsynchronousSocketChannel(AsynchronousChannelGroup group)

    87         throws IOException

    88     {

    89         return new UnixAsynchronousSocketChannelImpl(toPort(group));

    90     }

    91 }