spiffe
/
java-spiffe
mirror of https://github.com/spiffe/java-spiffe.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add volatile to closed flags 

Signed-off-by: Max Lambrecht <maxlambrecht@gmail.com>
This commit is contained in:
Max Lambrecht 2020-06-29 12:06:33 -03:00
parent 9b428d316d
commit cabcb56134
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
java-spiffe-core/src/main/java/io/spiffe/workloadapi/JwtSource.java
View File

@ -43,7 +43,7 @@ public class JwtSource implements JwtSvidSource, BundleSource<JwtBundle>, Closea
private JwtBundleSet bundles; private JwtBundleSet bundles;
private WorkloadApiClient workloadApiClient; private WorkloadApiClient workloadApiClient;
private boolean closed; private volatile boolean closed;
// private constructor // private constructor
private JwtSource() { private JwtSource() {

2
java-spiffe-core/src/main/java/io/spiffe/workloadapi/WorkloadApiClient.java
View File

@ -66,7 +66,7 @@ public final class WorkloadApiClient implements Closeable {
private final ExecutorService executorService; private final ExecutorService executorService;
private boolean closed; private volatile boolean closed;
private WorkloadApiClient(final SpiffeWorkloadAPIStub workloadApiAsyncStub, private WorkloadApiClient(final SpiffeWorkloadAPIStub workloadApiAsyncStub,
final SpiffeWorkloadAPIBlockingStub workloadApiBlockingStub, final SpiffeWorkloadAPIBlockingStub workloadApiBlockingStub,

2
java-spiffe-core/src/main/java/io/spiffe/workloadapi/X509Source.java
View File

@ -50,7 +50,7 @@ public final class X509Source implements X509SvidSource, BundleSource<X509Bundle
private Function<List<X509Svid>, X509Svid> picker; private Function<List<X509Svid>, X509Svid> picker;
private WorkloadApiClient workloadApiClient; private WorkloadApiClient workloadApiClient;
private boolean closed; private volatile boolean closed;
// private constructor // private constructor
private X509Source() { private X509Source() {