MirrorMirror
/
Signal-Server
mirror of https://github.com/signalapp/Signal-Server.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use a separate virtual executor instead of the one used for async jersey tasks

This commit is contained in:
Katherine 2024-08-14 09:28:16 -07:00 committed by GitHub
parent 3b405a53d0
commit 1ea9e38fea
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
service/src/main/java/org/whispersystems/textsecuregcm/WhisperServerService.java
View File

@ -574,8 +574,8 @@ public class WhisperServerService extends Application<WhisperServerConfiguration
.maxThreads(2) .maxThreads(2)
.minThreads(2) .minThreads(2)
.build(); .build();
ExecutorService keyTransparencyCallbackExecutor = new VirtualExecutorServiceProvider(name(getClass(), "keyTransparency-%d")) ExecutorService keyTransparencyCallbackExecutor = environment.lifecycle()
.getExecutorService(); .virtualExecutorService(name(getClass(), "keyTransparency-%d"));
ScheduledExecutorService subscriptionProcessorRetryExecutor = environment.lifecycle() ScheduledExecutorService subscriptionProcessorRetryExecutor = environment.lifecycle()
.scheduledExecutorService(name(getClass(), "subscriptionProcessorRetry-%d")).threads(1).build(); .scheduledExecutorService(name(getClass(), "subscriptionProcessorRetry-%d")).threads(1).build();
@ -988,7 +988,6 @@ public class WhisperServerService extends Application<WhisperServerConfiguration
final MessageMetrics messageMetrics = new MessageMetrics(); final MessageMetrics messageMetrics = new MessageMetrics();
environment.jersey().register(new BufferingInterceptor()); environment.jersey().register(new BufferingInterceptor());
environment.jersey().register(keyTransparencyCallbackExecutor);
environment.jersey().register(new VirtualExecutorServiceProvider("managed-async-virtual-thread-")); environment.jersey().register(new VirtualExecutorServiceProvider("managed-async-virtual-thread-"));
environment.jersey().register(new RequestStatisticsFilter(TrafficSource.HTTP)); environment.jersey().register(new RequestStatisticsFilter(TrafficSource.HTTP));
environment.jersey().register(MultiRecipientMessageProvider.class); environment.jersey().register(MultiRecipientMessageProvider.class);