You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@avro.apache.org by cu...@apache.org on 2010/01/07 00:26:31 UTC

svn commit: r896714 - in /hadoop/avro/trunk: CHANGES.txt src/java/org/apache/avro/ipc/SocketServer.java src/java/org/apache/avro/ipc/SocketTransceiver.java

Author: cutting
Date: Wed Jan  6 23:26:30 2010
New Revision: 896714

URL: http://svn.apache.org/viewvc?rev=896714&view=rev
Log:
AVRO-291.  Set NODELAY in Java's SocketTransceiver.  Contributed by Eric Evans.

Modified:
    hadoop/avro/trunk/CHANGES.txt
    hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketServer.java
    hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketTransceiver.java

Modified: hadoop/avro/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/CHANGES.txt?rev=896714&r1=896713&r2=896714&view=diff
==============================================================================
--- hadoop/avro/trunk/CHANGES.txt (original)
+++ hadoop/avro/trunk/CHANGES.txt Wed Jan  6 23:26:30 2010
@@ -174,6 +174,9 @@
 
     AVRO-172. More efficient schema processing (massie)
 
+    AVRO-291. Set NODELAY in Java's SocketTransceiver.
+    (Eric Evans via cutting)
+
   BUG FIXES
  
     AVRO-176. Safeguard against bad istreams before reading. (sbanacho)

Modified: hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketServer.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketServer.java?rev=896714&r1=896713&r2=896714&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketServer.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketServer.java Wed Jan  6 23:26:30 2010
@@ -75,7 +75,7 @@
 
   private class Connection extends SocketTransceiver implements Runnable {
 
-    public Connection(SocketChannel channel) {
+    public Connection(SocketChannel channel) throws IOException {
       super(channel);
 
       Thread thread = new Thread(group, this);

Modified: hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketTransceiver.java
URL: http://svn.apache.org/viewvc/hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketTransceiver.java?rev=896714&r1=896713&r2=896714&view=diff
==============================================================================
--- hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketTransceiver.java (original)
+++ hadoop/avro/trunk/src/java/org/apache/avro/ipc/SocketTransceiver.java Wed Jan  6 23:26:30 2010
@@ -40,8 +40,9 @@
     this(SocketChannel.open(address));
   }
 
-  public SocketTransceiver(SocketChannel channel) {
+  public SocketTransceiver(SocketChannel channel) throws IOException {
     this.channel = channel;
+    this.channel.socket().setTcpNoDelay(true);
     LOG.info("open to "+getRemoteName());
   }