X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fnet%2Fpterodactylus%2Fjsite%2Fcore%2FCoreImpl.java;h=07c634557ba81c68352e65f5d3b58fdf36422c49;hb=f58c676a286a7cd8d37c3f510e787144a9bff5ad;hp=682199e0cbf6689d805080d3ff1f3860507f46c5;hpb=9585222dac6894e3faaca5c411922011b0e0ea33;p=jSite2.git diff --git a/src/net/pterodactylus/jsite/core/CoreImpl.java b/src/net/pterodactylus/jsite/core/CoreImpl.java index 682199e..07c6345 100644 --- a/src/net/pterodactylus/jsite/core/CoreImpl.java +++ b/src/net/pterodactylus/jsite/core/CoreImpl.java @@ -237,6 +237,20 @@ public class CoreImpl implements Core, NodeListener, RequestListener { } /** + * Notifies all listeners that a connection to a node has failed. + * + * @param node + * The node that could not be connected + * @param cause + * The cause of the failure + */ + private void fireNodeConnectionFailed(Node node, Throwable cause) { + for (CoreListener coreListener: coreListeners) { + coreListener.nodeConnectionFailed(node, cause); + } + } + + /** * Notifies all listeners that the given node was disconnected. * * @param node @@ -403,9 +417,8 @@ public class CoreImpl implements Core, NodeListener, RequestListener { /** * {@inheritDoc} */ - public void addNode(Node node) throws UnknownHostException { - nodeManager.addNode(node); - fireNodeAdded(node); + public boolean addNode(Node node) throws UnknownHostException { + return nodeManager.addNode(node); } /** @@ -413,7 +426,6 @@ public class CoreImpl implements Core, NodeListener, RequestListener { */ public void removeNode(Node node) { nodeManager.removeNode(node); - fireNodeRemoved(node); } /** @@ -479,6 +491,13 @@ public class CoreImpl implements Core, NodeListener, RequestListener { /** * {@inheritDoc} */ + public void nodeConnectionFailed(Node node, Throwable cause) { + fireNodeConnectionFailed(node, cause); + } + + /** + * {@inheritDoc} + */ public void nodeDisconnected(Node node, Throwable throwable) { fireNodeDisconnected(node, throwable); } @@ -500,6 +519,6 @@ public class CoreImpl implements Core, NodeListener, RequestListener { * boolean) */ public void requestProgressed(Node node, Request request, int totalBlocks, int requiredBlocks, int successfulBlocks, int failedBlocks, int fatallyFailedBlocks, boolean finalizedTotal) { - fireRequestProgressed(node, request, totalBlocks, requiredBlocks, successfulBlocks, failedBlocks, fatallyFailedBlocks, finalizedTotal); - } + fireRequestProgressed(node, request, totalBlocks, requiredBlocks, successfulBlocks, failedBlocks, fatallyFailedBlocks, finalizedTotal); + } }