diff options
author | Trumeet <yuuta@yuuta.moe> | 2021-04-02 14:11:41 -0700 |
---|---|---|
committer | Trumeet <yuuta@yuuta.moe> | 2021-04-02 14:11:41 -0700 |
commit | 74e4489d4736d714e22cf5c3893f1b12243a5a45 (patch) | |
tree | 8fea6e52cdb603e146756f11a66c5fa15848c975 | |
parent | e5e38927755c355d6cb318cb9d0ecef0efc6491e (diff) | |
download | dn42peering-74e4489d4736d714e22cf5c3893f1b12243a5a45.tar dn42peering-74e4489d4736d714e22cf5c3893f1b12243a5a45.tar.gz dn42peering-74e4489d4736d714e22cf5c3893f1b12243a5a45.tar.bz2 dn42peering-74e4489d4736d714e22cf5c3893f1b12243a5a45.zip |
feat(central): add logging to ProvisionRemoteServiceImpl
There are no clients that handle the result of provisioning. If there is no logging, it would be hard to debug.
-rw-r--r-- | central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java | 7 |
1 files changed, 7 insertions, 0 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 3e432bd..a70385b 100644 --- a/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java +++ b/central/src/main/java/moe/yuuta/dn42peering/provision/ProvisionRemoteServiceImpl.java @@ -5,6 +5,8 @@ import io.vertx.core.AsyncResult; import io.vertx.core.Future; import io.vertx.core.Handler; import io.vertx.core.Vertx; +import io.vertx.core.impl.logging.Logger; +import io.vertx.core.impl.logging.LoggerFactory; import io.vertx.grpc.VertxChannelBuilder; import moe.yuuta.dn42peering.agent.proto.NodeConfig; import moe.yuuta.dn42peering.agent.proto.VertxAgentGrpc; @@ -18,6 +20,8 @@ import javax.annotation.Nonnull; import java.util.List; class ProvisionRemoteServiceImpl implements IProvisionRemoteService { + private final Logger logger = LoggerFactory.getLogger(getClass().getSimpleName()); + private final Vertx vertx; private final INodeService nodeService; private final IPeerService peerService; @@ -38,6 +42,7 @@ class ProvisionRemoteServiceImpl implements IProvisionRemoteService { @Override public IProvisionRemoteService deploy(long nodeId, @Nonnull Handler<AsyncResult<Void>> handler) { + logger.info("Deploying to " + nodeId); vertx.sharedData().getLockWithTimeout("deploy_" + nodeId, 30 * 1000) .<Void>compose(lock -> { return Future.<moe.yuuta.dn42peering.node.Node>future(f -> nodeService.getNode((int)nodeId, f)) @@ -83,6 +88,8 @@ class ProvisionRemoteServiceImpl implements IProvisionRemoteService { return Future.succeededFuture(); }); }) + .onFailure(err -> logger.error("Cannot deploy to " + nodeId, err)) + .onSuccess(res -> logger.info("Deploy to " + nodeId + " succeed.")) .onComplete(handler); return this; } |