| Index: java/io/netty/internal/tcnative/Library.java
|
| diff --git a/java/io/netty/internal/tcnative/Library.java b/java/io/netty/internal/tcnative/Library.java
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..1d90cdd86b7c2a9e3e879cc69ce394316baca76c
|
| --- /dev/null
|
| +++ b/java/io/netty/internal/tcnative/Library.java
|
| @@ -0,0 +1,140 @@
|
| +/*
|
| + * Copyright 2016 The Netty Project
|
| + *
|
| + * The Netty Project 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.
|
| + */
|
| +/*
|
| + * 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 io.netty.internal.tcnative;
|
| +
|
| +import java.io.File;
|
| +
|
| +public final class Library {
|
| +
|
| + /* Default library names */
|
| + private static final String [] NAMES = {"netty-tcnative", "libnetty-tcnative", "netty-tcnative-1", "libnetty-tcnative-1"};
|
| + /*
|
| + * A handle to the unique Library singleton instance.
|
| + */
|
| + private static Library _instance = null;
|
| +
|
| + private Library() throws Exception {
|
| + boolean loaded = false;
|
| + String path = System.getProperty("java.library.path");
|
| + String [] paths = path.split(File.pathSeparator);
|
| + StringBuilder err = new StringBuilder();
|
| + for (int i = 0; i < NAMES.length; i++) {
|
| + try {
|
| + System.loadLibrary(NAMES[i]);
|
| + loaded = true;
|
| + } catch (ThreadDeath t) {
|
| + throw t;
|
| + } catch (VirtualMachineError t) {
|
| + throw t;
|
| + } catch (Throwable t) {
|
| + String name = System.mapLibraryName(NAMES[i]);
|
| + for (int j = 0; j < paths.length; j++) {
|
| + File fd = new File(paths[j] , name);
|
| + if (fd.exists()) {
|
| + // File exists but failed to load
|
| + throw new RuntimeException(t);
|
| + }
|
| + }
|
| + if (i > 0) {
|
| + err.append(", ");
|
| + }
|
| + err.append(t.getMessage());
|
| + }
|
| + if (loaded) {
|
| + break;
|
| + }
|
| + }
|
| + if (!loaded) {
|
| + throw new UnsatisfiedLinkError(err.toString());
|
| + }
|
| + }
|
| +
|
| + private Library(String libraryName)
|
| + {
|
| + if (!"provided".equals(libraryName)) {
|
| + System.loadLibrary(libraryName);
|
| + }
|
| + }
|
| +
|
| + /* create global TCN's APR pool
|
| + * This has to be the first call to TCN library.
|
| + */
|
| + private static native boolean initialize0();
|
| +
|
| + /* Internal function for loading APR Features */
|
| + private static native boolean has(int what);
|
| + /* Internal function for loading APR Features */
|
| + private static native int version(int what);
|
| +
|
| + /* APR_VERSION_STRING */
|
| + private static native String aprVersionString();
|
| +
|
| + /**
|
| + * Calls {@link #initialize(String, String)} with {@code "provided"} and {@code null}.
|
| + *
|
| + * @return {@code true} if initialization was successful
|
| + * @throws Exception if an error happens during initialization
|
| + */
|
| + public static boolean initialize() throws Exception {
|
| + return initialize("provided", null);
|
| + }
|
| +
|
| + /**
|
| + * Setup native library. This is the first method that must be called!
|
| + *
|
| + * @param libraryName the name of the library to load
|
| + * @param engine Support for external a Crypto Device ("engine"), usually
|
| + * @return {@code true} if initialization was successful
|
| + * @throws Exception if an error happens during initialization
|
| + */
|
| + public static boolean initialize(String libraryName, String engine) throws Exception {
|
| + if (_instance == null) {
|
| + if (libraryName == null)
|
| + _instance = new Library();
|
| + else
|
| + _instance = new Library(libraryName);
|
| + int aprMajor = version(0x11);
|
| +
|
| + if (aprMajor < 1) {
|
| + throw new UnsatisfiedLinkError("Unsupported APR Version (" +
|
| + aprVersionString() + ")");
|
| + }
|
| +
|
| + boolean aprHasThreads = has(2);
|
| + if (!aprHasThreads) {
|
| + throw new UnsatisfiedLinkError("Missing APR_HAS_THREADS");
|
| + }
|
| + }
|
| + return initialize0() && SSL.initialize(engine) == 0;
|
| + }
|
| +}
|
|
|