Bump async_grpc (#1380)

Specify timeouts where RetryStrategy is used.
master
gaschler 2018-08-10 09:30:54 +02:00 committed by GitHub
parent 8d0457d1d8
commit 3877f97b23
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 7 additions and 6 deletions

View File

@ -228,9 +228,9 @@ def cartographer_repositories():
_maybe(native.http_archive,
name = "com_github_googlecartographer_async_grpc",
strip_prefix = "async_grpc-ed8e3b31bdd46a74f0c47b4c53a47e0c0f21141b",
strip_prefix = "async_grpc-771af45374af7f7bfc3b622ed7efbe29a4aba403",
urls = [
"https://github.com/googlecartographer/async_grpc/archive/ed8e3b31bdd46a74f0c47b4c53a47e0c0f21141b.tar.gz",
"https://github.com/googlecartographer/async_grpc/archive/771af45374af7f7bfc3b622ed7efbe29a4aba403.tar.gz",
],
)
_maybe(native.http_archive,

View File

@ -66,8 +66,9 @@ int MapBuilderStub::AddTrajectoryBuilder(
*request.add_expected_sensor_ids() = cloud::ToProto(sensor_id);
}
async_grpc::Client<handlers::AddTrajectorySignature> client(
client_channel_, async_grpc::CreateLimitedBackoffStrategy(
common::FromMilliseconds(100), 2.f, 5));
client_channel_, common::FromSeconds(10),
async_grpc::CreateLimitedBackoffStrategy(common::FromMilliseconds(100),
2.f, 5));
CHECK(client.Write(request));
// Construct trajectory builder stub.

View File

@ -205,7 +205,7 @@ void LocalTrajectoryUploader::ProcessSendQueue() {
if (batch_request.sensor_data_size() == batch_size_) {
async_grpc::Client<handlers::AddSensorDataBatchSignature> client(
client_channel_,
client_channel_, common::FromSeconds(10),
async_grpc::CreateUnlimitedConstantDelayStrategy(
common::FromSeconds(1), kUnrecoverableStatusCodes));
if (client.Write(batch_request)) {

View File

@ -19,7 +19,7 @@ set -o verbose
git clone https://github.com/googlecartographer/async_grpc
cd async_grpc
git checkout ed8e3b31bdd46a74f0c47b4c53a47e0c0f21141b
git checkout 771af45374af7f7bfc3b622ed7efbe29a4aba403
mkdir build
cd build
cmake -G Ninja \