---

meltsufin · chingor13 · commit 49f976a1179e · 2019-05-01T13:30:12.000-07:00
yaml --- r: 33667 b: refs/heads/autosynth-redis c: aee1e2e h: refs/heads/master i: 33665: e520e18 33663: ce3d408
diff --git a/[refs] b/[refs]
@@ -135,7 +135,7 @@ refs/heads/autosynth-iot: 044be280805a59e06d09658688c9ee474a9815ad
 refs/heads/autosynth-kms: d31449d6621a50fb16a4bef4f30f0f3051d27d7c
 refs/heads/autosynth-language: 6130869312f99a1e7d3aa0485759172a23333cc5
 refs/heads/autosynth-os-login: 49028d40ac477fca5f948cc5a3ce7422729fdb67
-refs/heads/autosynth-redis: cda0b03316ae6213d51f045c940d8a634dbcbcf2
+refs/heads/autosynth-redis: aee1e2e1ee11270c0427da99a010881c5cb8949f
 refs/heads/autosynth-scheduler: 57f9fdb1e7de30c85f4ec7198931a07f50603e55
 refs/heads/autosynth-spanner: de02ca32edea133b68b51052e325359a3704b5d2
 refs/heads/autosynth-speech: 64692f6db11364f663921be02c08072b966b6e7b
diff --git a/branches/autosynth-redis/google-cloud-clients/google-cloud-logging/src/main/java/com/google/cloud/logging/LoggingImpl.java b/branches/autosynth-redis/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`