Skip to content

Commit

Permalink
Merge branch 'opensearch-project:main' into perf_16934_1
Browse files Browse the repository at this point in the history
  • Loading branch information
expani authored Feb 11, 2025
2 parents 21d5903 + d0a65d3 commit 368383f
Show file tree
Hide file tree
Showing 84 changed files with 164 additions and 197 deletions.
102 changes: 2 additions & 100 deletions CHANGELOG.md

Large diffs are not rendered by default.

2 changes: 1 addition & 1 deletion gradle/libs.versions.toml
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ grpc = "1.68.2"
# when updating the JNA version, also update the version in buildSrc/build.gradle
jna = "5.13.0"

netty = "4.1.117.Final"
netty = "4.1.118.Final"
joda = "2.12.7"
roaringbitmap = "1.3.0"

Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
7022990af1e0d449f9d5322035899745e19735c5

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
4bb0f9899146484fa89f7b9bc27389d5b8e2ecde

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
7022990af1e0d449f9d5322035899745e19735c5

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
307f665c08ce57333121de4f460479fc0c3c94d4

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
eda08a71294afe78c779b85fd696bc13491507a8

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
e3c35c0685ec9e84c4f84b79feea7c9d185a08d3

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
4bb0f9899146484fa89f7b9bc27389d5b8e2ecde

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
30ebb05b6b0fb071dbfcf713017c4a767a97bb9b

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
28c378c19c1779eca1104b400452627f3ebc4aea

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
5a27232e5d08218722d94ca14f0b1b4576e7711c

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
9da25a94e6a0edac90da0bc7894e5a54efcb866b
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.util.concurrent.Future;

import static org.opensearch.common.util.concurrent.OpenSearchExecutors.privilegedDaemonThreadFactory;
import static org.opensearch.common.util.concurrent.OpenSearchExecutors.daemonThreadFactory;

/**
* Creates and returns {@link io.netty.channel.EventLoopGroup} instances. It will return a shared group for
Expand Down Expand Up @@ -91,7 +91,7 @@ public synchronized SharedGroup getHttpGroup() {
if (dedicatedHttpGroup == null) {
NioEventLoopGroup eventLoopGroup = new NioEventLoopGroup(
httpWorkerCount,
privilegedDaemonThreadFactory(settings, HttpServerTransport.HTTP_SERVER_WORKER_THREAD_NAME_PREFIX)
daemonThreadFactory(settings, HttpServerTransport.HTTP_SERVER_WORKER_THREAD_NAME_PREFIX)
);
dedicatedHttpGroup = new SharedGroup(new RefCountedGroup(eventLoopGroup));
}
Expand All @@ -103,7 +103,7 @@ private SharedGroup getGenericGroup() {
if (genericGroup == null) {
EventLoopGroup eventLoopGroup = new NioEventLoopGroup(
workerCount,
privilegedDaemonThreadFactory(settings, TcpTransport.TRANSPORT_WORKER_THREAD_NAME_PREFIX)
daemonThreadFactory(settings, TcpTransport.TRANSPORT_WORKER_THREAD_NAME_PREFIX)
);
this.genericGroup = new RefCountedGroup(eventLoopGroup);
} else {
Expand Down

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
0e04bf6679ab5e1bedae12047c4e049887476993

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
e3c35c0685ec9e84c4f84b79feea7c9d185a08d3

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
488a67579f062bba2d2d20ce46f9bb28a68b0875

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
28d6c41b72df614e09440ae0bed53a43fbcfbe27

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
ff5bfb643ccc5a809c4c21b10167b8d214ceaeeb

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
9da25a94e6a0edac90da0bc7894e5a54efcb866b

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
00b5462c05eeb5a0321fded73c28b5fc7833878f

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
7022990af1e0d449f9d5322035899745e19735c5

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
307f665c08ce57333121de4f460479fc0c3c94d4

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
eda08a71294afe78c779b85fd696bc13491507a8

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
e3c35c0685ec9e84c4f84b79feea7c9d185a08d3

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
4bb0f9899146484fa89f7b9bc27389d5b8e2ecde

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
30ebb05b6b0fb071dbfcf713017c4a767a97bb9b

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
28c378c19c1779eca1104b400452627f3ebc4aea

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
5a27232e5d08218722d94ca14f0b1b4576e7711c

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
376ce95507066f0e755d97c1c8bcd6c33f657617

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
9da25a94e6a0edac90da0bc7894e5a54efcb866b

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
7022990af1e0d449f9d5322035899745e19735c5

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
307f665c08ce57333121de4f460479fc0c3c94d4

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
0e04bf6679ab5e1bedae12047c4e049887476993

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
eda08a71294afe78c779b85fd696bc13491507a8

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
e3c35c0685ec9e84c4f84b79feea7c9d185a08d3

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
4bb0f9899146484fa89f7b9bc27389d5b8e2ecde

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
30ebb05b6b0fb071dbfcf713017c4a767a97bb9b

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
28c378c19c1779eca1104b400452627f3ebc4aea

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
ff5bfb643ccc5a809c4c21b10167b8d214ceaeeb

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
5a27232e5d08218722d94ca14f0b1b4576e7711c

This file was deleted.

Original file line number Diff line number Diff line change
@@ -0,0 +1 @@
9da25a94e6a0edac90da0bc7894e5a54efcb866b
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.util.concurrent.Future;

import static org.opensearch.common.util.concurrent.OpenSearchExecutors.privilegedDaemonThreadFactory;
import static org.opensearch.common.util.concurrent.OpenSearchExecutors.daemonThreadFactory;

/**
* Creates and returns {@link io.netty.channel.EventLoopGroup} instances. It will return a shared group for
Expand Down Expand Up @@ -89,7 +89,7 @@ public synchronized SharedGroup getHttpGroup() {
if (dedicatedHttpGroup == null) {
NioEventLoopGroup eventLoopGroup = new NioEventLoopGroup(
httpWorkerCount,
privilegedDaemonThreadFactory(settings, HttpServerTransport.HTTP_SERVER_WORKER_THREAD_NAME_PREFIX)
daemonThreadFactory(settings, HttpServerTransport.HTTP_SERVER_WORKER_THREAD_NAME_PREFIX)
);
dedicatedHttpGroup = new SharedGroup(new RefCountedGroup(eventLoopGroup));
}
Expand All @@ -101,7 +101,7 @@ private SharedGroup getGenericGroup() {
if (genericGroup == null) {
EventLoopGroup eventLoopGroup = new NioEventLoopGroup(
workerCount,
privilegedDaemonThreadFactory(settings, TcpTransport.TRANSPORT_WORKER_THREAD_NAME_PREFIX)
daemonThreadFactory(settings, TcpTransport.TRANSPORT_WORKER_THREAD_NAME_PREFIX)
);
this.genericGroup = new RefCountedGroup(eventLoopGroup);
} else {
Expand Down
Loading

0 comments on commit 368383f

Please sign in to comment.