Update zookeeper

reviewable/pr4232/r6
Craig Tiller 9 years ago
parent a6bebf4b0e
commit dc0366881d
  1. 7
      src/core/client_config/resolvers/zookeeper_resolver.c

@ -96,9 +96,7 @@ static void zookeeper_maybe_finish_next_locked(grpc_exec_ctx *exec_ctx,
static void zookeeper_shutdown(grpc_exec_ctx *exec_ctx, grpc_resolver *r); static void zookeeper_shutdown(grpc_exec_ctx *exec_ctx, grpc_resolver *r);
static void zookeeper_channel_saw_error(grpc_exec_ctx *exec_ctx, static void zookeeper_channel_saw_error(grpc_exec_ctx *exec_ctx,
grpc_resolver *r, grpc_resolver *r);
struct sockaddr *failing_address,
int failing_address_len);
static void zookeeper_next(grpc_exec_ctx *exec_ctx, grpc_resolver *r, static void zookeeper_next(grpc_exec_ctx *exec_ctx, grpc_resolver *r,
grpc_client_config **target_config, grpc_client_config **target_config,
grpc_closure *on_complete); grpc_closure *on_complete);
@ -125,8 +123,7 @@ static void zookeeper_shutdown(grpc_exec_ctx *exec_ctx,
} }
static void zookeeper_channel_saw_error(grpc_exec_ctx *exec_ctx, static void zookeeper_channel_saw_error(grpc_exec_ctx *exec_ctx,
grpc_resolver *resolver, grpc_resolver *resolver) {
struct sockaddr *sa, int len) {
zookeeper_resolver *r = (zookeeper_resolver *)resolver; zookeeper_resolver *r = (zookeeper_resolver *)resolver;
gpr_mu_lock(&r->mu); gpr_mu_lock(&r->mu);
if (r->resolving == 0) { if (r->resolving == 0) {

Loading…
Cancel
Save