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());
}