From df0ff176d4a79239ee3ebfe4925819d411fe2dc5 Mon Sep 17 00:00:00 2001
From: Shay Banon <kimchy@gmail.com>
Date: Sat, 22 Sep 2012 19:50:43 +0200
Subject: [PATCH] add simpler way to set the epoll bug workaround flag for
 netty

---
 .../elasticsearch/http/netty/NettyHttpServerTransport.java   | 5 +++++
 .../org/elasticsearch/transport/netty/NettyTransport.java    | 4 ++++
 2 files changed, 9 insertions(+)

diff --git a/src/main/java/org/elasticsearch/http/netty/NettyHttpServerTransport.java b/src/main/java/org/elasticsearch/http/netty/NettyHttpServerTransport.java
index fc93cc863e7..0661d5311a0 100644
--- a/src/main/java/org/elasticsearch/http/netty/NettyHttpServerTransport.java
+++ b/src/main/java/org/elasticsearch/http/netty/NettyHttpServerTransport.java
@@ -112,6 +112,11 @@ public class NettyHttpServerTransport extends AbstractLifecycleComponent<HttpSer
     public NettyHttpServerTransport(Settings settings, NetworkService networkService) {
         super(settings);
         this.networkService = networkService;
+
+        if (settings.getAsBoolean("netty.epollBugWorkaround", false)) {
+            System.setProperty("org.jboss.netty.epollBugWorkaround", "true");
+        }
+
         ByteSizeValue maxContentLength = componentSettings.getAsBytesSize("max_content_length", settings.getAsBytesSize("http.max_content_length", new ByteSizeValue(100, ByteSizeUnit.MB)));
         this.maxChunkSize = componentSettings.getAsBytesSize("max_chunk_size", settings.getAsBytesSize("http.max_chunk_size", new ByteSizeValue(8, ByteSizeUnit.KB)));
         this.maxHeaderSize = componentSettings.getAsBytesSize("max_header_size", settings.getAsBytesSize("http.max_header_size", new ByteSizeValue(8, ByteSizeUnit.KB)));
diff --git a/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java b/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java
index e8e02a01b42..44b40d6eba6 100644
--- a/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java
+++ b/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java
@@ -163,6 +163,10 @@ public class NettyTransport extends AbstractLifecycleComponent<Transport> implem
         this.threadPool = threadPool;
         this.networkService = networkService;
 
+        if (settings.getAsBoolean("netty.epollBugWorkaround", false)) {
+            System.setProperty("org.jboss.netty.epollBugWorkaround", "true");
+        }
+
         this.connectMutex = new Object[500];
         for (int i = 0; i < connectMutex.length; i++) {
             connectMutex[i] = new Object();