forked from netty/netty
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Introduce a native transport for linux using epoll ET
This transport use JNI (C) to directly make use of epoll in Edge-Triggered mode for maximal performance on Linux. Beside this it also support using TCP_CORK and produce less GC then the NIO transport using JDK NIO. It only builds on linux and skip the build if linux is not used. The transport produce a jar which contains all needed .so files for 32bit and 64 bit. The user only need to include the jar as dependency as usually to make use of it and use the correct classes. This includes also some cleanup of @trustin
- Loading branch information
Norman Maurer
committed
Feb 15, 2014
1 parent
c73e1e3
commit e0299e1
Showing
27 changed files
with
3,643 additions
and
1 deletion.
There are no files selected for viewing
149 changes: 149 additions & 0 deletions
149
common/src/main/java/io/netty/util/internal/NativeLibraryLoader.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,149 @@ | ||
| /* | ||
| * Copyright 2014 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. | ||
| */ | ||
| package io.netty.util.internal; | ||
|
|
||
| import io.netty.util.internal.logging.InternalLogger; | ||
| import io.netty.util.internal.logging.InternalLoggerFactory; | ||
|
|
||
| import java.io.File; | ||
| import java.io.FileOutputStream; | ||
| import java.io.IOException; | ||
| import java.io.InputStream; | ||
| import java.io.OutputStream; | ||
| import java.net.URL; | ||
| import java.util.Locale; | ||
| import java.util.regex.Pattern; | ||
|
|
||
| /** | ||
| * Helper class to load JNI resources. | ||
| * | ||
| */ | ||
| public final class NativeLibraryLoader { | ||
|
|
||
| private static final InternalLogger logger = InternalLoggerFactory.getInstance(NativeLibraryLoader.class); | ||
|
|
||
| private static final Pattern REPLACE = Pattern.compile("\\W+"); | ||
| private static final File WORKDIR; | ||
|
|
||
| static { | ||
| String workdir = SystemPropertyUtil.get("io.netty.native.workdir"); | ||
| if (workdir != null) { | ||
| File f = new File(workdir); | ||
| if (!f.exists()) { | ||
| // ok to ignore as createTempFile will take care | ||
| //noinspection ResultOfMethodCallIgnored | ||
| f.mkdirs(); | ||
| } | ||
|
|
||
| try { | ||
| f = f.getAbsoluteFile(); | ||
| } catch (Exception ignored) { | ||
| // Good to have an absolute path, but it's OK. | ||
| } | ||
|
|
||
| WORKDIR = f; | ||
| logger.debug("-Dio.netty.netty.workdir: {}", WORKDIR); | ||
| } else { | ||
| WORKDIR = PlatformDependent.tmpdir(); | ||
| logger.debug("-Dio.netty.netty.workdir: {} (io.netty.tmpdir)", WORKDIR); | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Load the given library with the specified {@link java.lang.ClassLoader} | ||
| */ | ||
| public static void load(String name, ClassLoader loader) { | ||
| String libname = System.mapLibraryName(name); | ||
| String path = "META-INF/native/" + osIdentifier() + PlatformDependent.bitMode() + '/' + libname; | ||
|
|
||
| URL url = loader.getResource(path); | ||
| if (url == null) { | ||
| // Fall back to normal loading of JNI stuff | ||
| System.loadLibrary(name); | ||
| } else { | ||
| int index = libname.lastIndexOf('.'); | ||
| String prefix = libname.substring(0, index); | ||
| String suffix = libname.substring(index, libname.length()); | ||
| InputStream in = null; | ||
| OutputStream out = null; | ||
| File tmpFile = null; | ||
| boolean loaded = false; | ||
| try { | ||
| tmpFile = File.createTempFile(prefix, suffix, WORKDIR); | ||
| in = url.openStream(); | ||
| out = new FileOutputStream(tmpFile); | ||
|
|
||
| byte[] buffer = new byte[8192]; | ||
| int length; | ||
| while ((length = in.read(buffer)) > 0) { | ||
| out.write(buffer, 0, length); | ||
| } | ||
| out.flush(); | ||
| out.close(); | ||
| out = null; | ||
|
|
||
| System.load(tmpFile.getPath()); | ||
| loaded = true; | ||
| } catch (Exception e) { | ||
| throw (UnsatisfiedLinkError) new UnsatisfiedLinkError( | ||
| "could not load a native library: " + name).initCause(e); | ||
| } finally { | ||
| if (in != null) { | ||
| try { | ||
| in.close(); | ||
| } catch (IOException ignore) { | ||
| // ignore | ||
| } | ||
| } | ||
| if (out != null) { | ||
| try { | ||
| out.close(); | ||
| } catch (IOException ignore) { | ||
| // ignore | ||
| } | ||
| } | ||
| if (tmpFile != null) { | ||
| if (loaded) { | ||
| tmpFile.deleteOnExit(); | ||
| } else { | ||
| if (!tmpFile.delete()) { | ||
| tmpFile.deleteOnExit(); | ||
| } | ||
| } | ||
| } | ||
| } | ||
| } | ||
| } | ||
|
|
||
| private static String osIdentifier() { | ||
| String name = SystemPropertyUtil.get("os.name", "unknown").toLowerCase(Locale.US).trim(); | ||
| if (name.startsWith("win")) { | ||
| return "windows"; | ||
| } | ||
| if (name.startsWith("mac os x")) { | ||
| return "osx"; | ||
| } | ||
| if (name.startsWith("linux")) { | ||
| return "linux"; | ||
| } | ||
|
|
||
| return REPLACE.matcher(name).replaceAll("_"); | ||
| } | ||
|
|
||
| private NativeLibraryLoader() { | ||
| // Utility | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,3 @@ | ||
| # Native transport for Linux | ||
|
|
||
| See [our wiki page](http://netty.io/wiki/native-transports.html). |
Oops, something went wrong.