You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@zookeeper.apache.org by ma...@apache.org on 2010/02/19 03:42:39 UTC
svn commit: r911678 - in /hadoop/zookeeper/trunk: CHANGES.txt
src/contrib/bookkeeper/src/java/org/apache/bookkeeper/streaming/LedgerInputStream.java
Author: mahadev
Date: Fri Feb 19 02:42:39 2010
New Revision: 911678
URL: http://svn.apache.org/viewvc?rev=911678&view=rev
Log:
ZOOKEEPER-668. Close method in LedgerInputStream doesn't do anything (flavio via mahadev)
Modified:
hadoop/zookeeper/trunk/CHANGES.txt
hadoop/zookeeper/trunk/src/contrib/bookkeeper/src/java/org/apache/bookkeeper/streaming/LedgerInputStream.java
Modified: hadoop/zookeeper/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/zookeeper/trunk/CHANGES.txt?rev=911678&r1=911677&r2=911678&view=diff
==============================================================================
--- hadoop/zookeeper/trunk/CHANGES.txt (original)
+++ hadoop/zookeeper/trunk/CHANGES.txt Fri Feb 19 02:42:39 2010
@@ -223,6 +223,9 @@
ZOOKEEPER-672. typo nits across documentation (Kay Kay via mahadev)
+ ZOOKEEPER-668. Close method in LedgerInputStream doesn't do anything (flavio
+ via mahadev)
+
IMPROVEMENTS:
ZOOKEEPER-473. cleanup junit tests to eliminate false positives due to
"socket reuse" and failure to close client (phunt via mahadev)
Modified: hadoop/zookeeper/trunk/src/contrib/bookkeeper/src/java/org/apache/bookkeeper/streaming/LedgerInputStream.java
URL: http://svn.apache.org/viewvc/hadoop/zookeeper/trunk/src/contrib/bookkeeper/src/java/org/apache/bookkeeper/streaming/LedgerInputStream.java?rev=911678&r1=911677&r2=911678&view=diff
==============================================================================
--- hadoop/zookeeper/trunk/src/contrib/bookkeeper/src/java/org/apache/bookkeeper/streaming/LedgerInputStream.java (original)
+++ hadoop/zookeeper/trunk/src/contrib/bookkeeper/src/java/org/apache/bookkeeper/streaming/LedgerInputStream.java Fri Feb 19 02:42:39 2010
@@ -74,6 +74,11 @@
ledgerSeq = lh.readEntries(0, lastEntry);
}
+ /**
+ * Method close currently doesn't do anything. The application
+ * is supposed to open and close the ledger handle backing up
+ * a stream ({@link LedgerHandle}).
+ */
@Override
public void close() {
// do nothing