grpc
/
grpc-java
mirror of https://github.com/grpc/grpc-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

core: propagate name resolution errors

This commit is contained in:
Carl Mastrangelo 2016-08-08 17:53:58 -07:00
parent ff7fb5ff52
commit 5384f9706a
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
core/src/main/java/io/grpc/internal/ManagedChannelImpl.java
View File

@ -249,9 +249,14 @@ public final class ManagedChannelImpl extends ManagedChannel implements WithLogI
class NameResolverStartTask implements Runnable { class NameResolverStartTask implements Runnable {
@Override @Override
public void run() { public void run() {
NameResolverListenerImpl listener = new NameResolverListenerImpl(balancer);
// This may trigger quite a few non-trivial work in LoadBalancer and NameResolver, // This may trigger quite a few non-trivial work in LoadBalancer and NameResolver,
// we don't want to do it in the lock. // we don't want to do it in the lock.
resolver.start(new NameResolverListenerImpl(balancer)); try {
resolver.start(listener);
} catch (Throwable t) {
listener.onError(Status.fromThrowable(t));
}
} }
} }