You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by yu...@apache.org on 2014/04/09 00:14:05 UTC
[3/6] git commit: Fix concurrency issue for CASSANDRA-6818
Fix concurrency issue for CASSANDRA-6818
patch by yukim; reviewed by thobbs for CASSANDRA-7007
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/b1a30704
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/b1a30704
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/b1a30704
Branch: refs/heads/trunk
Commit: b1a307047768980b5fdfcb0cffef5acea6924362
Parents: c17dcd4
Author: Yuki Morishita <yu...@apache.org>
Authored: Tue Apr 8 17:13:09 2014 -0500
Committer: Yuki Morishita <yu...@apache.org>
Committed: Tue Apr 8 17:13:09 2014 -0500
----------------------------------------------------------------------
src/java/org/apache/cassandra/streaming/StreamTransferTask.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/b1a30704/src/java/org/apache/cassandra/streaming/StreamTransferTask.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/StreamTransferTask.java b/src/java/org/apache/cassandra/streaming/StreamTransferTask.java
index 86f4ee2..7d0cc87 100644
--- a/src/java/org/apache/cassandra/streaming/StreamTransferTask.java
+++ b/src/java/org/apache/cassandra/streaming/StreamTransferTask.java
@@ -58,7 +58,7 @@ public class StreamTransferTask extends StreamTask
*
* @param sequenceNumber sequence number of file
*/
- public void complete(int sequenceNumber)
+ public synchronized void complete(int sequenceNumber)
{
OutgoingFileMessage file = files.remove(sequenceNumber);
if (file != null)
@@ -117,7 +117,7 @@ public class StreamTransferTask extends StreamTask
* @param unit unit of given time
* @return scheduled future for timeout task
*/
- public ScheduledFuture scheduleTimeout(final int sequenceNumber, long time, TimeUnit unit)
+ public synchronized ScheduledFuture scheduleTimeout(final int sequenceNumber, long time, TimeUnit unit)
{
if (timeoutExecutor.isShutdown())
return null;