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

verify that data that is written to the blob (in fs) is the same as expected in the blob write api call

This commit is contained in:
kimchy 2010-07-21 23:46:11 +03:00
parent 4dcf219086
commit b55fd0c0fc
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
modules/elasticsearch/src/main/java/org/elasticsearch/common/blobstore/fs/FsImmutableBlobContainer.java
View File

@ -19,6 +19,7 @@
package org.elasticsearch.common.blobstore.fs; package org.elasticsearch.common.blobstore.fs;
import org.elasticsearch.ElasticSearchIllegalStateException;
import org.elasticsearch.common.blobstore.BlobPath; import org.elasticsearch.common.blobstore.BlobPath;
import org.elasticsearch.common.blobstore.ImmutableBlobContainer; import org.elasticsearch.common.blobstore.ImmutableBlobContainer;
import org.elasticsearch.common.blobstore.support.BlobStores; import org.elasticsearch.common.blobstore.support.BlobStores;
@ -53,10 +54,16 @@ public class FsImmutableBlobContainer extends AbstractFsBlobContainer implements
} }
try { try {
try { try {
long bytesWritten = 0;
byte[] buffer = new byte[blobStore.bufferSizeInBytes()]; byte[] buffer = new byte[blobStore.bufferSizeInBytes()];
int bytesRead; int bytesRead;
while ((bytesRead = is.read(buffer)) != -1) { while ((bytesRead = is.read(buffer)) != -1) {
raf.write(buffer, 0, bytesRead); raf.write(buffer, 0, bytesRead);
bytesWritten += bytesRead;
}
if (bytesWritten != sizeInBytes) {
listener.onFailure(new ElasticSearchIllegalStateException("[" + blobName + "]: wrote [" + bytesWritten + "], expected to write [" + sizeInBytes + "]"));
return;
} }
} finally { } finally {
try { try {