Skip to content

Commit 692c5a2

Browse files
resolvesCps -> cpsEnabled
1 parent deb7b49 commit 692c5a2

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

server/src/main/java/org/elasticsearch/rest/action/search/RestSearchAction.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -243,14 +243,14 @@ public static void parseSearchRequest(
243243
searchRequest.routing(request.param("routing"));
244244
searchRequest.preference(request.param("preference"));
245245
IndicesOptions indicesOptions = IndicesOptions.fromRequest(request, searchRequest.indicesOptions());
246-
if (crossProjectEnabled && searchRequest.allowsCrossProject()) {
246+
if (crossProjectEnabled) {
247247
indicesOptions = IndicesOptions.builder(indicesOptions)
248248
.crossProjectModeOptions(new IndicesOptions.CrossProjectModeOptions(true))
249249
.build();
250250
}
251251
searchRequest.indicesOptions(indicesOptions);
252252

253-
validateSearchRequest(request, searchRequest, crossProjectEnabled && searchRequest.allowsCrossProject());
253+
validateSearchRequest(request, searchRequest, crossProjectEnabled);
254254

255255
if (searchRequest.pointInTimeBuilder() != null) {
256256
preparePointInTime(searchRequest, request);
@@ -413,15 +413,15 @@ public static void validateSearchRequest(RestRequest restRequest, SearchRequest
413413
validateSearchRequest(restRequest, searchRequest, false);
414414
}
415415

416-
private static void validateSearchRequest(RestRequest restRequest, SearchRequest searchRequest, boolean resolvesCrossProject) {
416+
private static void validateSearchRequest(RestRequest restRequest, SearchRequest searchRequest, boolean crossProjectEnabled) {
417417
checkRestTotalHits(restRequest, searchRequest);
418418
checkSearchType(restRequest, searchRequest);
419419
// ensures that the rest param is consumed
420420
restRequest.paramAsBoolean(INCLUDE_NAMED_QUERIES_SCORE_PARAM, false);
421-
checkProjectRouting(searchRequest, resolvesCrossProject);
421+
checkProjectRouting(searchRequest, crossProjectEnabled);
422422
}
423423

424-
private static void checkProjectRouting(SearchRequest searchRequest, boolean resolvesCrossProject) {
424+
private static void checkProjectRouting(SearchRequest searchRequest, boolean crossProjectEnabled) {
425425
/*
426426
* There are 2 ways of specifying project_routing:
427427
* - as a query parameter: /_search?project_routing=..., and,
@@ -437,7 +437,7 @@ private static void checkProjectRouting(SearchRequest searchRequest, boolean res
437437
String projectRoutingInBody = searchRequest.source().projectRouting();
438438
// If it's null, either the query parameter is also null or it isn't. Either way, we're fine with it.
439439
if (projectRoutingInBody != null) {
440-
if (resolvesCrossProject == false) {
440+
if (crossProjectEnabled == false) {
441441
throw new IllegalArgumentException("project_routing is allowed only when CPS is enabled and the endpoint supports CPS");
442442
}
443443

x-pack/plugin/async-search/src/main/java/org/elasticsearch/xpack/search/RestSubmitAsyncSearchAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ protected RestChannelConsumer prepareRequest(RestRequest request, NodeClient cli
6969
SubmitAsyncSearchRequest submit = new SubmitAsyncSearchRequest();
7070

7171
boolean crossProjectEnabled = crossProjectModeDecider.crossProjectEnabled();
72-
if (crossProjectEnabled && submit.getSearchRequest().allowsCrossProject()) {
72+
if (crossProjectEnabled) {
7373
submit.getSearchRequest().setProjectRouting(request.param("project_routing"));
7474
}
7575

0 commit comments

Comments
 (0)