diff --git a/choam/src/main/java/com/salesforce/apollo/choam/ViewContext.java b/choam/src/main/java/com/salesforce/apollo/choam/ViewContext.java index a88d3e692..feaca8bf6 100644 --- a/choam/src/main/java/com/salesforce/apollo/choam/ViewContext.java +++ b/choam/src/main/java/com/salesforce/apollo/choam/ViewContext.java @@ -244,16 +244,16 @@ public boolean validate(SignedViews sv) { Verifier v = verifierOf(sv); if (v == null) { if (log.isDebugEnabled()) { - log.warn("No verifier: {} for signed view on: {}", Digest.from(sv.getViews().getMember()), - params.member().getId()); + log.debug("No verifier: {} for signed view on: {}", Digest.from(sv.getViews().getMember()), + params.member().getId()); } return false; } var validated = v.verify(JohnHancock.from(sv.getSignature()), sv.getViews().toByteString()); if (!validated) { if (log.isTraceEnabled()) { - log.warn("Cannot validate views signed by: {} on: {}", Digest.from(sv.getViews().getMember()), - params().member().getId()); + log.trace("Cannot validate views signed by: {} on: {}", Digest.from(sv.getViews().getMember()), + params().member().getId()); } } else if (log.isTraceEnabled()) { log.trace("Validated views signed by: {} on: {}", Digest.from(sv.getViews().getMember()), diff --git a/memberships/src/main/java/com/salesforce/apollo/archipelago/LocalServer.java b/memberships/src/main/java/com/salesforce/apollo/archipelago/LocalServer.java index 1f28baf49..74403835d 100644 --- a/memberships/src/main/java/com/salesforce/apollo/archipelago/LocalServer.java +++ b/memberships/src/main/java/com/salesforce/apollo/archipelago/LocalServer.java @@ -79,9 +79,6 @@ public RouterImpl router(ServerConnectionCache.Builder cacheBuilder, Supplier
  • serverBuilder = InProcessServerBuilder.forName(name) .executor(Executors.newVirtualThreadPerTaskExecutor()) - .scheduledExecutorService( - Executors.newScheduledThreadPool(100, Thread.ofVirtual() - .factory())) .intercept(ConcurrencyLimitServerInterceptor.newBuilder( limitsBuilder.build()) .statusSupplier( @@ -105,7 +102,6 @@ private ManagedChannel connectTo(Member to) { final var name = String.format(NAME_TEMPLATE, prefix, qb64(to.getId())); final InProcessChannelBuilder builder = InProcessChannelBuilder.forName(name) .executor(executor) - .offloadExecutor(executor) .usePlaintext() .intercept(clientInterceptor); disableTrash(builder); diff --git a/memberships/src/main/java/com/salesforce/apollo/archipelago/MtlsClient.java b/memberships/src/main/java/com/salesforce/apollo/archipelago/MtlsClient.java index 2ee89f441..58db9ec8e 100644 --- a/memberships/src/main/java/com/salesforce/apollo/archipelago/MtlsClient.java +++ b/memberships/src/main/java/com/salesforce/apollo/archipelago/MtlsClient.java @@ -34,7 +34,6 @@ public MtlsClient(SocketAddress address, ClientAuth clientAuth, String alias, Cl Limiter limiter = new GrpcClientLimiterBuilder().blockOnLimit(false).build(); channel = NettyChannelBuilder.forAddress(address) .executor(executor) - .offloadExecutor(executor) .withOption(ChannelOption.TCP_NODELAY, true) .sslContext(supplier.forClient(clientAuth, alias, validator, MtlsServer.TL_SV1_3)) .intercept(new ConcurrencyLimitClientInterceptor(limiter, diff --git a/pom.xml b/pom.xml index 41c502027..c4879bd2b 100644 --- a/pom.xml +++ b/pom.xml @@ -780,7 +780,7 @@ org.apache.maven.plugins maven-surefire-plugin - 3.1.2 + 3.2.5 ${forks} true