Skip to content

Commit d90d91f

Browse files
committed
Merge remote-tracking branch 'origin/master' into ss-firestore-emulator-settings
2 parents 9d499c1 + 59db590 commit d90d91f

File tree

3 files changed

+8
-2
lines changed

3 files changed

+8
-2
lines changed

firebase-installations/src/main/java/com/google/firebase/installations/FirebaseInstallations.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -139,7 +139,6 @@ public Thread newThread(Runnable r) {
139139
TimeUnit.SECONDS,
140140
new LinkedBlockingQueue<>(),
141141
THREAD_FACTORY);
142-
preConditionChecks();
143142
}
144143

145144
/**
@@ -217,6 +216,7 @@ String getName() {
217216
@NonNull
218217
@Override
219218
public Task<String> getId() {
219+
preConditionChecks();
220220
return Tasks.forResult(doGetId());
221221
}
222222

@@ -231,6 +231,7 @@ public Task<String> getId() {
231231
@NonNull
232232
@Override
233233
public Task<InstallationTokenResult> getToken(boolean forceRefresh) {
234+
preConditionChecks();
234235
Task<InstallationTokenResult> task = addGetAuthTokenListener();
235236
backgroundExecutor.execute(() -> doGetAuthToken(forceRefresh));
236237
return task;

transport/transport-backend-cct/src/main/java/com/google/android/datatransport/cct/CctTransportBackend.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -48,9 +48,11 @@
4848
import java.io.InputStreamReader;
4949
import java.io.OutputStream;
5050
import java.io.OutputStreamWriter;
51+
import java.net.ConnectException;
5152
import java.net.HttpURLConnection;
5253
import java.net.MalformedURLException;
5354
import java.net.URL;
55+
import java.net.UnknownHostException;
5456
import java.nio.charset.Charset;
5557
import java.util.ArrayList;
5658
import java.util.Calendar;
@@ -268,6 +270,9 @@ private HttpResponse doSend(HttpRequest request) throws IOException {
268270
// JsonWriter often writes one character at a time.
269271
dataEncoder.encode(
270272
request.requestBody, new BufferedWriter(new OutputStreamWriter(outputStream)));
273+
} catch (ConnectException | UnknownHostException e) {
274+
Logging.e(LOG_TAG, "Couldn't open connection, returning with 500", e);
275+
return new HttpResponse(500, null, 0);
271276
} catch (EncodingException | IOException e) {
272277
Logging.e(LOG_TAG, "Couldn't encode request, returning with 400", e);
273278
return new HttpResponse(400, null, 0);

transport/transport-runtime/src/main/java/com/google/android/datatransport/runtime/scheduling/persistence/SQLiteEventStore.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -54,7 +54,7 @@ public class SQLiteEventStore implements EventStore, SynchronizationGuard {
5454

5555
private static final String LOG_TAG = "SQLiteEventStore";
5656

57-
static final int MAX_RETRIES = 10;
57+
static final int MAX_RETRIES = 16;
5858

5959
private static final int LOCK_RETRY_BACK_OFF_MILLIS = 50;
6060
private static final Encoding PROTOBUF_ENCODING = Encoding.of("proto");

0 commit comments

Comments
 (0)