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; |
+ } |
+} |