---

meltsufin · chingor13 · commit 46e25a293870 · 2019-05-01T13:30:12.000-07:00
yaml --- r: 32941 b: refs/heads/autosynth-kms c: aee1e2e h: refs/heads/master i: 32939: af79432
diff --git a/[refs] b/[refs]
@@ -132,7 +132,7 @@ refs/heads/autosynth-dialogflow: 73974cc32e5212aec0126472e0bc1442886fedaf
 refs/heads/autosynth-errorreporting: effe8001d110ad584187b30aafc473db0dd4a15f
 refs/heads/autosynth-firestore: e79eeb26930dfae4439424ad2fda5874eeca54c8
 refs/heads/autosynth-iot: 044be280805a59e06d09658688c9ee474a9815ad
-refs/heads/autosynth-kms: cda0b03316ae6213d51f045c940d8a634dbcbcf2
+refs/heads/autosynth-kms: aee1e2e1ee11270c0427da99a010881c5cb8949f
 refs/heads/autosynth-language: e73905aa7672afa47240e65b25c087207f4594f9
 refs/heads/autosynth-os-login: 123ba209c5769d0ee067e0ce5848bec13b42a4f4
 refs/heads/autosynth-redis: 6bedce4d7c7c6ca6a22e83ad1780e08fdc565a9e
diff --git a/branches/autosynth-kms/google-cloud-clients/google-cloud-logging/src/main/java/com/google/cloud/logging/LoggingImpl.java b/branches/autosynth-kms/google-cloud-clients/google-cloud-logging/src/main/java/com/google/cloud/logging/LoggingImpl.java
@@ -582,6 +582,8 @@ public void flush() {
 
   /* Write logs synchronously or asynchronously based on writeSynchronicity setting. */
   private void writeLogEntries(Iterable<LogEntry> logEntries, WriteOption... writeOptions) {
+    if (closed) return;
+
     switch (this.writeSynchronicity) {
       case SYNC:
         get(writeAsync(logEntries, writeOptions));
@@ -688,6 +690,7 @@ public void close() throws Exception {
       return;
     }
     closed = true;
+    flush();
     rpc.close();
   }
 

Original file line number	Diff line number	Diff line change
`@@ -582,6 +582,8 @@ public void flush() {`
`582`	`582`
`583`	`583`	`/* Write logs synchronously or asynchronously based on writeSynchronicity setting. */`
`584`	`584`	`private void writeLogEntries(Iterable<LogEntry> logEntries, WriteOption... writeOptions) {`
	`585`	`+ if (closed) return;`
	`586`	`+`
`585`	`587`	`switch (this.writeSynchronicity) {`
`586`	`588`	`case SYNC:`
`587`	`589`	`get(writeAsync(logEntries, writeOptions));`
`@@ -688,6 +690,7 @@ public void close() throws Exception {`
`688`	`690`	`return;`
`689`	`691`	`}`
`690`	`692`	`closed = true;`
	`693`	`+ flush();`
`691`	`694`	`rpc.close();`
`692`	`695`	`}`
`693`	`696`