---

meltsufin · chingor13 · commit 4c2c5657ee8a · 2019-05-01T13:30:12.000-07:00
yaml --- r: 28703 b: refs/heads/autosynth-dlp c: aee1e2e h: refs/heads/master i: 28701: 889b1b7 28699: fa3ee17 28695: 921be2a 28687: cf6e9d7 28671: 0ab66f1
diff --git a/[refs] b/[refs]
@@ -103,7 +103,7 @@ refs/tags/v0.60.0: 4cd518d0612329f8a8e53484eef4cd1651e32855
 refs/tags/v0.61.0: e4b526656bb1bf5eefd0ee578b7405147821225e
 refs/tags/v0.62.0: bbede7385d48ba08f487bdd29ec10668ace96396
 refs/heads/0.60.0-alpha: 10939381ffe0b8da32db4fe3087c86e3aa7f3e55
-refs/heads/autosynth-dlp: cda0b03316ae6213d51f045c940d8a634dbcbcf2
+refs/heads/autosynth-dlp: aee1e2e1ee11270c0427da99a010881c5cb8949f
 refs/heads/autosynth-logging: eca54b98c8cf82050bbdfc5c19139673dff9e5b8
 refs/heads/dupes: 3478c5d81fd242d0e985656645a679420a2060c2
 refs/tags/v0.63.0: 94f19b71d40f46b36120e7b9d78a1a3d41bfcbd6
diff --git a/branches/autosynth-dlp/google-cloud-clients/google-cloud-logging/src/main/java/com/google/cloud/logging/LoggingImpl.java b/branches/autosynth-dlp/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`