Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Renamed a few variables to be more explicit 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1703914 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Shalin Shekhar Mangar 2015-09-18 19:32:20 +00:00
parent 2c4d7c3e08
commit c0da2bc3b6
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
solr/core/src/java/org/apache/solr/handler/IndexFetcher.java
View File

@ -161,9 +161,9 @@ public class IndexFetcher {
private volatile boolean stop = false;
private boolean useInternal = false;
private boolean useInternalCompression = false;
private boolean useExternal = false;
private boolean useExternalCompression = false;
private final HttpClient myHttpClient;
@ -192,13 +192,13 @@ public class IndexFetcher {
this.replicationHandler = handler;
String compress = (String) initArgs.get(COMPRESSION);
useInternal = INTERNAL.equals(compress);
useExternal = EXTERNAL.equals(compress);
useInternalCompression = INTERNAL.equals(compress);
useExternalCompression = EXTERNAL.equals(compress);
String connTimeout = (String) initArgs.get(HttpClientUtil.PROP_CONNECTION_TIMEOUT);
String readTimeout = (String) initArgs.get(HttpClientUtil.PROP_SO_TIMEOUT);
String httpBasicAuthUser = (String) initArgs.get(HttpClientUtil.PROP_BASIC_AUTH_USER);
String httpBasicAuthPassword = (String) initArgs.get(HttpClientUtil.PROP_BASIC_AUTH_PASS);
myHttpClient = createHttpClient(solrCore, connTimeout, readTimeout, httpBasicAuthUser, httpBasicAuthPassword, useExternal);
myHttpClient = createHttpClient(solrCore, connTimeout, readTimeout, httpBasicAuthUser, httpBasicAuthPassword, useExternalCompression);
}
/**
@ -1503,7 +1503,7 @@ public class IndexFetcher {
params.set(CommonParams.QT, "/replication");
//add the version to download. This is used to reserve the download
params.set(solrParamOutput, fileName);
if (useInternal) {
if (useInternalCompression) {
params.set(COMPRESSION, "true");
}
//use checksum
@ -1529,7 +1529,7 @@ public class IndexFetcher {
QueryRequest req = new QueryRequest(params);
response = client.request(req);
is = (InputStream) response.get("stream");
if(useInternal) {
if(useInternalCompression) {
is = new InflaterInputStream(is);
}
return new FastInputStream(is);