Skip to content

Commit bad45de

Browse files
committed
fix wrong handling of empty param in thrift/memcached transport
1 parent 019c844 commit bad45de

File tree

3 files changed

+8
-4
lines changed

3 files changed

+8
-4
lines changed

plugins/transport/memcached/src/main/java/org/elasticsearch/memcached/MemcachedRestRequest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -164,8 +164,8 @@ public void setData(byte[] data) {
164164
@Override public String param(String key, String defaultValue) {
165165
String value = params.get(key);
166166
if (value == null) {
167-
return value;
167+
return defaultValue;
168168
}
169-
return defaultValue;
169+
return value;
170170
}
171171
}

plugins/transport/thrift/src/main/java/org/elasticsearch/thrift/ThriftRestRequest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -148,8 +148,8 @@ public ThriftRestRequest(org.elasticsearch.thrift.RestRequest request) {
148148
@Override public String param(String key, String defaultValue) {
149149
String value = params.get(key);
150150
if (value == null) {
151-
return value;
151+
return defaultValue;
152152
}
153-
return defaultValue;
153+
return value;
154154
}
155155
}

plugins/transport/thrift/src/test/java/org/elasticsearch/thrift/test/SimpleThriftTests.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,6 +76,10 @@ public class SimpleThriftTests {
7676
assertThat(map.get("ok").toString(), equalTo("true"));
7777
assertThat(map.get("_index").toString(), equalTo("test"));
7878
assertThat(map.get("_type").toString(), equalTo("type1"));
79+
80+
request = new RestRequest(Method.GET, "/_cluster/health");
81+
response = client.execute(request);
82+
assertThat(response.getStatus(), equalTo(Status.OK));
7983
}
8084

8185
private Map<String, Object> parseBody(RestResponse response) throws IOException {

0 commit comments

Comments
 (0)