honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

update the current recvoerd files size in peer recovery

This commit is contained in:
kimchy 2010-08-16 09:11:51 +03:00
parent a012e0f1bd
commit 92aa91d7b2
2 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/recovery/OnGoingRecovery.java
View File

@ -24,6 +24,7 @@ import org.elasticsearch.common.util.concurrent.ConcurrentCollections;
import java.util.List; import java.util.List;
import java.util.concurrent.ConcurrentMap; import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.atomic.AtomicLong;
/** /**
* @author kimchy (shay.banon) * @author kimchy (shay.banon)
@ -48,4 +49,5 @@ public class OnGoingRecovery {
volatile Stage stage = Stage.INIT; volatile Stage stage = Stage.INIT;
volatile long currentTranslogOperations = 0; volatile long currentTranslogOperations = 0;
AtomicLong currentFilesSize = new AtomicLong();
} }

1
modules/elasticsearch/src/main/java/org/elasticsearch/index/shard/recovery/RecoveryTarget.java
View File

@ -395,6 +395,7 @@ public class RecoveryTarget extends AbstractComponent {
synchronized (indexOutput) { synchronized (indexOutput) {
try { try {
indexOutput.writeBytes(request.content(), request.contentLength()); indexOutput.writeBytes(request.content(), request.contentLength());
onGoingRecovery.currentFilesSize.addAndGet(request.contentLength());
if (indexOutput.getFilePointer() == request.length()) { if (indexOutput.getFilePointer() == request.length()) {
// we are done // we are done
indexOutput.close(); indexOutput.close();