Searched refs:rpc_options (Results 1 – 9 of 9) sorted by relevance
105 ::grpc::ChannelArguments GetChannelArguments(const RPCOptions* rpc_options) { in GetChannelArguments() argument112 if (rpc_options != nullptr) { in GetChannelArguments()113 if (rpc_options->compression_algorithm() == "deflate") { in GetChannelArguments()116 rpc_options->compression_level()); in GetChannelArguments()118 << rpc_options->compression_algorithm() in GetChannelArguments()119 << "' level=" << rpc_options->compression_level(); in GetChannelArguments()120 } else if (rpc_options->compression_algorithm() == "gzip") { in GetChannelArguments()123 rpc_options->compression_level()); in GetChannelArguments()125 << rpc_options->compression_algorithm() in GetChannelArguments()126 << "' level=" << rpc_options->compression_level(); in GetChannelArguments()[all …]
90 ::grpc::ChannelArguments GetChannelArguments(const RPCOptions* rpc_options);97 const RPCOptions* rpc_options,
52 if (!options.config.rpc_options().use_rpc_for_inprocess_master()) { in Create()59 &options.config.rpc_options(), &master_channel)); in Create()
1167 RPCOptions* rpc_options = options.config.mutable_rpc_options(); in TEST() local1168 rpc_options->set_compression_algorithm("deflate"); in TEST()1169 rpc_options->set_compression_level(GRPC_COMPRESS_LEVEL_HIGH); in TEST()
427 if (config.rpc_options().cache_rpc_response()) { in GrpcWorker()
82 name: "rpc_options"
54 cluster_->targets()[0], &options.config.rpc_options(), &channel_ptr)); in MasterTest()
120 return config_pb2.ConfigProto(rpc_options=config_pb2.RPCOptions(
460 RPCOptions rpc_options = 13; field