---

spkrka · sduskis · commit 7d5574acceec · 2019-03-19T07:16:52.000-04:00
yaml --- r: 18521 b: refs/heads/autosynth-compute c: 03ba9c9 h: refs/heads/master i: 18519: ba1cf5b
diff --git a/[refs] b/[refs]
@@ -112,7 +112,7 @@ refs/tags/v0.64.0: 456e8fbd129deced3ca025f239a2d8a82bde1d0a
 refs/tags/v0.65.0: 10939381ffe0b8da32db4fe3087c86e3aa7f3e55
 refs/tags/v0.66.0: ed6a3f57cbdaa20339a1995f7d7d53b172a5b8ef
 refs/tags/v0.67.0: 30b56f02092efc6f3c3667650ea8b8825003e0b7
-refs/heads/autosynth-compute: 0a6fc39ab502f112b3cbdd671d8c79189c51bcdf
+refs/heads/autosynth-compute: 03ba9c91cab9113f30bfc43d185fc87d1b515303
 refs/heads/autosynth-container: f6384095f50b31bfc8208542a49181e158d3681c
 refs/heads/autosynth-monitoring: e67db7395a868e5f6ecc3476eb4a91c47abd4234
 refs/heads/autosynth-pubsub: fd363d13793a853214eb8193c922b28c54e7a6b3
diff --git a/branches/autosynth-compute/google-cloud-clients/google-cloud-logging/src/main/java/com/google/cloud/logging/LoggingImpl.java b/branches/autosynth-compute/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-compute/google-cloud-clients/google-cloud-logging/src/test/java/com/google/cloud/logging/LoggingImplTest.java b/branches/autosynth-compute/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`