diff options
| author | Trumeet <yuuta@yuuta.moe> | 2021-04-02 14:19:47 -0700 |
|---|---|---|
| committer | Trumeet <yuuta@yuuta.moe> | 2021-04-02 14:19:47 -0700 |
| commit | e24a0d7eb64026a9b2478760f38fc4bad7eceff2 (patch) | |
| tree | acea0eb66283af0f35d92717dec508e10bff8eaa | |
| parent | 26417474f09eb042b2b8547c454f572086831b84 (diff) | |
| download | dn42peering-e24a0d7eb64026a9b2478760f38fc4bad7eceff2.tar dn42peering-e24a0d7eb64026a9b2478760f38fc4bad7eceff2.tar.gz dn42peering-e24a0d7eb64026a9b2478760f38fc4bad7eceff2.tar.bz2 dn42peering-e24a0d7eb64026a9b2478760f38fc4bad7eceff2.zip | |
fix(central): deadlock if deployment is failed
| -rw-r--r-- | central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java b/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java index a70385b..5f7e8a1 100644 --- a/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java +++ b/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java @@ -83,9 +83,8 @@ class ProvisionRemoteServiceImpl implements IProvisionRemoteService { .<Void>compose(reply -> Future.succeededFuture(null)) .onComplete(res -> channel.shutdown()); }) - .compose(_v -> { + .onComplete(_v -> { lock.release(); - return Future.succeededFuture(); }); }) .onFailure(err -> logger.error("Cannot deploy to " + nodeId, err)) |