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

initial chunk of work on refactoring the gateway, syntatic gateway files names, commit points that include translog information

This commit is contained in:
kimchy 2010-08-23 15:42:03 +03:00
parent b49d331c86
commit 939d583550
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
modules/elasticsearch/src/main/java/org/elasticsearch/index/gateway/blobstore/BlobStoreIndexShardGateway.java
View File

@ -398,7 +398,7 @@ public abstract class BlobStoreIndexShardGateway extends AbstractIndexShardCompo
FastByteArrayOutputStream bos = new FastByteArrayOutputStream(); FastByteArrayOutputStream bos = new FastByteArrayOutputStream();
boolean ignore = false; boolean ignore = false;
@Override public void onPartial(byte[] data, int offset, int size) throws IOException { @Override public synchronized void onPartial(byte[] data, int offset, int size) throws IOException {
if (ignore) { if (ignore) {
return; return;
} }
@ -449,6 +449,9 @@ public abstract class BlobStoreIndexShardGateway extends AbstractIndexShardCompo
} }
@Override public synchronized void onCompleted() { @Override public synchronized void onCompleted() {
if (ignore) {
return;
}
if (!transIt.hasNext()) { if (!transIt.hasNext()) {
latch.countDown(); latch.countDown();
return; return;