---

spkrka · sduskis · commit 7b50b8addaa7 · 2019-03-19T07:16:52.000-04:00
yaml --- r: 24677 b: refs/heads/autosynth-scheduler c: 03ba9c9 h: refs/heads/master i: 24675: e73fc68
diff --git a/[refs] b/[refs]
@@ -136,7 +136,7 @@ refs/heads/autosynth-kms: 6b65b0f34c12d141031c7288cdc01e550212d0f6
 refs/heads/autosynth-language: e73905aa7672afa47240e65b25c087207f4594f9
 refs/heads/autosynth-os-login: 123ba209c5769d0ee067e0ce5848bec13b42a4f4
 refs/heads/autosynth-redis: 6bedce4d7c7c6ca6a22e83ad1780e08fdc565a9e
-refs/heads/autosynth-scheduler: 0a6fc39ab502f112b3cbdd671d8c79189c51bcdf
+refs/heads/autosynth-scheduler: 03ba9c91cab9113f30bfc43d185fc87d1b515303
 refs/heads/autosynth-spanner: a249d9564d8c27ab4439abc6562d7f3b9b7f655d
 refs/heads/autosynth-speech: 75d6c62a9d07d3a3642980502a25d07fbde0f232
 refs/heads/autosynth-tasks: 5d6a4f686ffef2080506d3b613fc7563a8bba1cb
diff --git a/branches/autosynth-scheduler/google-cloud-clients/google-cloud-logging/src/main/java/com/google/cloud/logging/LoggingImpl.java b/branches/autosynth-scheduler/google-cloud-clients/google-cloud-logging/src/main/java/com/google/cloud/logging/LoggingImpl.java
@@ -37,6 +37,7 @@
 import com.google.cloud.MonitoredResourceDescriptor;
 import com.google.cloud.PageImpl;
 import com.google.cloud.logging.spi.v2.LoggingRpc;
+import com.google.common.annotations.VisibleForTesting;
 import com.google.common.base.Function;
 import com.google.common.base.Throwables;
 import com.google.common.collect.ImmutableList;
@@ -595,6 +596,9 @@ private void writeLogEntries(Iterable<LogEntry> logEntries, WriteOption... write
       case ASYNC:
       default:
         final ApiFuture<Void> writeFuture = writeAsync(logEntries, writeOptions);
+        synchronized (writeLock) {
+          pendingWrites.add(writeFuture);
+        }
         ApiFutures.addCallback(
             writeFuture,
             new ApiFutureCallback<Void>() {
@@ -619,9 +623,6 @@ public void onFailure(Throwable t) {
                 }
               }
             });
-        synchronized (writeLock) {
-          pendingWrites.add(writeFuture);
-        }
         break;
     }
   }
@@ -707,4 +708,11 @@ public void close() throws Exception {
     }
     return optionMap;
   }
+
+  @VisibleForTesting
+  int getNumPendingWrites() {
+    synchronized (writeLock) {
+      return pendingWrites.size();
+    }
+  }
 }
diff --git a/branches/autosynth-scheduler/google-cloud-clients/google-cloud-logging/src/test/java/com/google/cloud/logging/LoggingImplTest.java b/branches/autosynth-scheduler/google-cloud-clients/google-cloud-logging/src/test/java/com/google/cloud/logging/LoggingImplTest.java
@@ -1186,6 +1186,7 @@ public void testWriteLogEntries() {
     EasyMock.replay(rpcFactoryMock, loggingRpcMock);
     logging = options.getService();
     logging.write(ImmutableList.of(LOG_ENTRY1, LOG_ENTRY2));
+    assertEquals(0, ((LoggingImpl) logging).getNumPendingWrites());
   }
 
   @Test

Original file line number	Diff line number	Diff line change
`@@ -37,6 +37,7 @@`
`37`	`37`	`import com.google.cloud.MonitoredResourceDescriptor;`
`38`	`38`	`import com.google.cloud.PageImpl;`
`39`	`39`	`import com.google.cloud.logging.spi.v2.LoggingRpc;`
	`40`	`+import com.google.common.annotations.VisibleForTesting;`
`40`	`41`	`import com.google.common.base.Function;`
`41`	`42`	`import com.google.common.base.Throwables;`
`42`	`43`	`import com.google.common.collect.ImmutableList;`
`@@ -595,6 +596,9 @@ private void writeLogEntries(Iterable<LogEntry> logEntries, WriteOption... write`
`595`	`596`	`case ASYNC:`
`596`	`597`	`default:`
`597`	`598`	`final ApiFuture<Void> writeFuture = writeAsync(logEntries, writeOptions);`
	`599`	`+ synchronized (writeLock) {`
	`600`	`+ pendingWrites.add(writeFuture);`
	`601`	`+ }`
`598`	`602`	`ApiFutures.addCallback(`
`599`	`603`	`writeFuture,`
`600`	`604`	`new ApiFutureCallback<Void>() {`
`@@ -619,9 +623,6 @@ public void onFailure(Throwable t) {`
`619`	`623`	`}`
`620`	`624`	`}`
`621`	`625`	`});`
`622`		`- synchronized (writeLock) {`
`623`		`- pendingWrites.add(writeFuture);`
`624`		`- }`
`625`	`626`	`break;`
`626`	`627`	`}`
`627`	`628`	`}`
`@@ -707,4 +708,11 @@ public void close() throws Exception {`
`707`	`708`	`}`
`708`	`709`	`return optionMap;`
`709`	`710`	`}`
	`711`	`+`
	`712`	`+ @VisibleForTesting`
	`713`	`+ int getNumPendingWrites() {`
	`714`	`+ synchronized (writeLock) {`
	`715`	`+ return pendingWrites.size();`
	`716`	`+ }`
	`717`	`+ }`
`710`	`718`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1186,6 +1186,7 @@ public void testWriteLogEntries() {`
`1186`	`1186`	`EasyMock.replay(rpcFactoryMock, loggingRpcMock);`
`1187`	`1187`	`logging = options.getService();`
`1188`	`1188`	`logging.write(ImmutableList.of(LOG_ENTRY1, LOG_ENTRY2));`
	`1189`	`+ assertEquals(0, ((LoggingImpl) logging).getNumPendingWrites());`
`1189`	`1190`	`}`
`1190`	`1191`
`1191`	`1192`	`@Test`