Author: cdouglas
Date: Tue Oct 28 01:40:42 2008
New Revision: 708480
URL: http://svn.apache.org/viewvc?rev=708480&view=rev
Log:
HADOOP-4525. Fix ipc.server.ipcnodelay originally missed in in HADOOP-2232.
Contributed by Clint Morgan.
Modified:
hadoop/core/branches/branch-0.19/CHANGES.txt
hadoop/core/branches/branch-0.19/src/core/org/apache/hadoop/ipc/Server.java
Modified: hadoop/core/branches/branch-0.19/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.19/CHANGES.txt?rev=708480&r1=708479&r2=708480&view=diff
==============================================================================
--- hadoop/core/branches/branch-0.19/CHANGES.txt (original)
+++ hadoop/core/branches/branch-0.19/CHANGES.txt Tue Oct 28 01:40:42 2008
@@ -960,6 +960,9 @@
and can be used with other Serialization frameworks. (Chris Wensel via
acmurthy)
+ HADOOP-4525. Fix ipc.server.ipcnodelay originally missed in in HADOOP-2232.
+ (cdouglas via Clint Morgan)
+
Release 0.18.2 - Unreleased
BUG FIXES
Modified:
hadoop/core/branches/branch-0.19/src/core/org/apache/hadoop/ipc/Server.java
URL:
http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.19/src/core/org/apache/hadoop/ipc/Server.java?rev=708480&r1=708479&r2=708480&view=diff
==============================================================================
--- hadoop/core/branches/branch-0.19/src/core/org/apache/hadoop/ipc/Server.java
(original)
+++ hadoop/core/branches/branch-0.19/src/core/org/apache/hadoop/ipc/Server.java
Tue Oct 28 01:40:42 2008
@@ -136,7 +136,7 @@
private int maxQueueSize;
private int socketSendBufferSize;
- private boolean tcpNoDelay; // if T then disable Nagle's Algorithm
+ private final boolean tcpNoDelay; // if T then disable Nagle's Algorithm
volatile private boolean running = true; // true while server runs
private BlockingQueue<Call> callQueue; // queued calls
@@ -955,6 +955,7 @@
this.port = listener.getAddress().getPort();
this.rpcMetrics = new RpcMetrics(serverName,
Integer.toString(this.port), this);
+ this.tcpNoDelay = conf.getBoolean("ipc.server.tcpnodelay", false);
// Create the responder here
