Remove unnecessary changes as start and resolve etc are already calle…

…d from sync context.
kannanjgithub · Nov 5, 2024 · d882a00 · d882a00
1 parent 75719be
commit d882a00
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 12 deletions.
diff --git a/core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java b/core/src/main/java/io/grpc/internal/ManagedChannelImplBuilder.java
@@ -878,14 +878,13 @@ public String getServiceAuthority() {
 
         @Override
         public void start(Listener2 listener) {
-          args.getSynchronizationContext().execute(() ->
-              listener.onResult2(
-                  ResolutionResult.newBuilder()
-                      .setAddressesOrError(
-                          StatusOr.fromValue(
-                              Collections.singletonList(new EquivalentAddressGroup(address))))
-                      .setAttributes(Attributes.EMPTY)
-                      .build()));
+          listener.onResult2(
+              ResolutionResult.newBuilder()
+                  .setAddressesOrError(
+                      StatusOr.fromValue(
+                          Collections.singletonList(new EquivalentAddressGroup(address))))
+                  .setAttributes(Attributes.EMPTY)
+                  .build());
         }
 
         @Override

diff --git a/netty/src/main/java/io/grpc/netty/UdsNameResolver.java b/netty/src/main/java/io/grpc/netty/UdsNameResolver.java
@@ -30,12 +30,10 @@
 final class UdsNameResolver extends NameResolver {
   private NameResolver.Listener2 listener;
   private final String authority;
-  private final Args args;
 
   UdsNameResolver(String authority, String targetPath, Args args) {
     checkArgument(authority == null, "non-null authority not supported");
     this.authority = targetPath;
-    this.args = args;
   }
 
   @Override
@@ -60,8 +58,7 @@ private void resolve() {
     List<EquivalentAddressGroup> servers = new ArrayList<>(1);
     servers.add(new EquivalentAddressGroup(new DomainSocketAddress(authority)));
     resolutionResultBuilder.setAddressesOrError(StatusOr.fromValue(servers));
-    args.getSynchronizationContext().execute(() ->
-        listener.onResult2(resolutionResultBuilder.build()));
+    listener.onResult2(resolutionResultBuilder.build());
   }
 
   @Override