Skip to content

Commit b8e3881

Browse files
committed
coderabbit suggestions
Signed-off-by: Anthony Leong <aj.leong623@gmail.com>
1 parent 78fafcb commit b8e3881

File tree

5 files changed

+19
-9
lines changed

5 files changed

+19
-9
lines changed

server/src/internalClusterTest/java/org/opensearch/search/msearch/MultiSearchStatsIT.java

Lines changed: 7 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
public class MultiSearchStatsIT extends OpenSearchIntegTestCase {
2727
private final SearchResponseStatusStats expectedSearchResponseStatusStats = new SearchResponseStatusStats();
2828

29-
public void testNodeIndicesStatsDocStatusStatsIndexBulk() {
29+
public void testNodeIndicesStatsSearchResponseStatusStatsMultiSearch() {
3030
createIndex("test");
3131
ensureGreen();
3232
client().prepareIndex("test").setId("1").setSource("field", "xxx").get();
@@ -70,10 +70,12 @@ private void assertSearchResponseStatusStats() {
7070
.getStatusCounterStats()
7171
.getSearchResponseStatusStats();
7272

73-
Arrays.equals(
74-
searchResponseStatusStats.getSearchResponseStatusCounter(),
75-
expectedSearchResponseStatusStats.getSearchResponseStatusCounter(),
76-
Comparator.comparingLong(LongAdder::longValue)
73+
assertTrue(
74+
Arrays.equals(
75+
searchResponseStatusStats.getSearchResponseStatusCounter(),
76+
expectedSearchResponseStatusStats.getSearchResponseStatusCounter(),
77+
Comparator.comparingLong(LongAdder::longValue)
78+
)
7779
);
7880
}
7981

server/src/main/java/org/opensearch/action/admin/indices/stats/AbstractStatusStats.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
8888
builder.field(userFailureType, errorTypeCounts.getOrDefault(userFailureType, (long) 0));
8989
builder.field(systemErrorType, errorTypeCounts.getOrDefault(systemErrorType, (long) 0));
9090

91-
return builder.endObject();
91+
return builder;
9292
}
9393

9494
@Override

server/src/main/java/org/opensearch/action/admin/indices/stats/DocStatusStats.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -77,7 +77,7 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
7777
builder.startObject(Fields.DOC_STATUS);
7878

7979
super.toXContent(builder, params);
80-
return builder;
80+
return builder.endObject();
8181
}
8282

8383
@Override

server/src/main/java/org/opensearch/action/admin/indices/stats/SearchResponseStatusStats.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,7 @@ public XContentBuilder toXContent(XContentBuilder builder, Params params) throws
7676
builder.startObject(Fields.SEARCH_RESPONSE_STATUS);
7777

7878
super.toXContent(builder, params);
79-
return builder;
79+
return builder.endObject();
8080
}
8181

8282
@Override

server/src/main/java/org/opensearch/action/admin/indices/stats/StatusCounterStats.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -76,7 +76,15 @@ public StatusCounterStats getSnapshot() {
7676
}
7777

7878
public void add(StatusCounterStats stats) {
79-
docStatusStats.add(stats.docStatusStats);
79+
if (stats == null) {
80+
return;
81+
}
82+
if (docStatusStats != null) {
83+
docStatusStats.add(stats.docStatusStats);
84+
}
85+
if (searchResponseStatusStats != null) {
86+
searchResponseStatusStats.add(stats.searchResponseStatusStats);
87+
}
8088
}
8189

8290
@Override

0 commit comments

Comments
 (0)