---

meltsufin · chingor13 · commit 881c1a7aeb75 · 2019-05-01T13:30:12.000-07:00
yaml --- r: 28245 b: refs/heads/autosynth-spanner c: aee1e2e h: refs/heads/master i: 28243: 57d5b42
diff --git a/[refs] b/[refs]
@@ -137,7 +137,7 @@ refs/heads/autosynth-language: e73905aa7672afa47240e65b25c087207f4594f9
 refs/heads/autosynth-os-login: 123ba209c5769d0ee067e0ce5848bec13b42a4f4
 refs/heads/autosynth-redis: 6bedce4d7c7c6ca6a22e83ad1780e08fdc565a9e
 refs/heads/autosynth-scheduler: 57f9fdb1e7de30c85f4ec7198931a07f50603e55
-refs/heads/autosynth-spanner: cda0b03316ae6213d51f045c940d8a634dbcbcf2
+refs/heads/autosynth-spanner: aee1e2e1ee11270c0427da99a010881c5cb8949f
 refs/heads/autosynth-speech: 64692f6db11364f663921be02c08072b966b6e7b
 refs/heads/autosynth-tasks: eb03eeab747e925175890db923945384d89b273a
 refs/heads/autosynth-texttospeech: 2c442fe0b7f089fbab266edfe4dd83c532e82dd0
diff --git a/branches/autosynth-spanner/google-cloud-clients/google-cloud-logging/src/main/java/com/google/cloud/logging/LoggingImpl.java b/branches/autosynth-spanner/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`