Return-Path: X-Original-To: apmail-ignite-commits-archive@minotaur.apache.org Delivered-To: apmail-ignite-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id BB1A318654 for ; Fri, 17 Jul 2015 19:49:36 +0000 (UTC) Received: (qmail 60239 invoked by uid 500); 17 Jul 2015 19:49:36 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 60207 invoked by uid 500); 17 Jul 2015 19:49:36 -0000 Mailing-List: contact commits-help@ignite.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@ignite.incubator.apache.org Delivered-To: mailing list commits@ignite.incubator.apache.org Received: (qmail 60198 invoked by uid 99); 17 Jul 2015 19:49:36 -0000 Received: from Unknown (HELO spamd3-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 17 Jul 2015 19:49:36 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd3-us-west.apache.org (ASF Mail Server at spamd3-us-west.apache.org) with ESMTP id 2C54F185F3B for ; Fri, 17 Jul 2015 19:49:36 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd3-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.771 X-Spam-Level: * X-Spam-Status: No, score=1.771 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, T_RP_MATCHES_RCVD=-0.01, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd3-us-west.apache.org [10.40.0.10]) (amavisd-new, port 10024) with ESMTP id 3iEOROEPKSRG for ; Fri, 17 Jul 2015 19:49:34 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with SMTP id 073A54E215 for ; Fri, 17 Jul 2015 19:49:23 +0000 (UTC) Received: (qmail 59339 invoked by uid 99); 17 Jul 2015 19:49:23 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 17 Jul 2015 19:49:23 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 51972E04B3; Fri, 17 Jul 2015 19:49:23 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: vkulichenko@apache.org To: commits@ignite.incubator.apache.org Date: Fri, 17 Jul 2015 19:49:49 -0000 Message-Id: In-Reply-To: <7ee78c0e55ce40dbaf2c4b647df7c608@git.apache.org> References: <7ee78c0e55ce40dbaf2c4b647df7c608@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [28/50] [abbrv] incubator-ignite git commit: ignite-890: fixes after the review ignite-890: fixes after the review Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/5c558129 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/5c558129 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/5c558129 Branch: refs/heads/ignite-884 Commit: 5c5581290aba6d2958aa410d1f126f77facc626c Parents: b601a62 Author: Denis Magda Authored: Thu Jul 16 09:01:45 2015 +0300 Committer: Denis Magda Committed: Thu Jul 16 09:01:45 2015 +0300 ---------------------------------------------------------------------- .../org/apache/ignite/spi/IgniteSpiAdapter.java | 26 +++++++++++--------- .../org/apache/ignite/spi/IgniteSpiContext.java | 6 ++--- .../communication/tcp/TcpCommunicationSpi.java | 2 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 2 +- 4 files changed, 18 insertions(+), 18 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/5c558129/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiAdapter.java b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiAdapter.java index df043dd..9bdf495 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiAdapter.java @@ -545,19 +545,17 @@ public abstract class IgniteSpiAdapter implements IgniteSpi, IgniteSpiManagement /** * @param obj Timeout object. - * @throws IgniteSpiException Thrown in case of any error. * @see IgniteSpiContext#addTimeoutObject(IgniteSpiTimeoutObject) */ - protected void addTimeoutObject(IgniteSpiTimeoutObject obj) throws IgniteSpiException { + protected void addTimeoutObject(IgniteSpiTimeoutObject obj) { spiCtx.addTimeoutObject(obj); } /** * @param obj Timeout object. - * @throws IgniteSpiException Thrown in case of any error. * @see IgniteSpiContext#removeTimeoutObject(IgniteSpiTimeoutObject) */ - protected void removeTimeoutObject(IgniteSpiTimeoutObject obj) throws IgniteSpiException { + protected void removeTimeoutObject(IgniteSpiTimeoutObject obj) { spiCtx.removeTimeoutObject(obj); } @@ -766,19 +764,23 @@ public abstract class IgniteSpiAdapter implements IgniteSpi, IgniteSpiManagement } /** {@inheritDoc} */ - @Override public void addTimeoutObject(IgniteSpiTimeoutObject obj) throws IgniteSpiException { - if (!(ignite instanceof IgniteKernal)) - throw new IgniteSpiException("Wrong Ignite instance is set: " + ignite); + @Override public void addTimeoutObject(IgniteSpiTimeoutObject obj) { + Ignite ignite0 = ignite; - ((IgniteKernal)ignite).context().timeout().addTimeoutObject(new GridSpiTimeoutObject(obj)); + if (!(ignite0 instanceof IgniteKernal)) + throw new IgniteSpiException("Wrong Ignite instance is set: " + ignite0); + + ((IgniteKernal)ignite0).context().timeout().addTimeoutObject(new GridSpiTimeoutObject(obj)); } /** {@inheritDoc} */ - @Override public void removeTimeoutObject(IgniteSpiTimeoutObject obj) throws IgniteSpiException { - if (!(ignite instanceof IgniteKernal)) - throw new IgniteSpiException("Wrong Ignite instance is set: " + ignite); + @Override public void removeTimeoutObject(IgniteSpiTimeoutObject obj) { + Ignite ignite0 = ignite; + + if (!(ignite0 instanceof IgniteKernal)) + throw new IgniteSpiException("Wrong Ignite instance is set: " + ignite0); - ((IgniteKernal)ignite).context().timeout().removeTimeoutObject(new GridSpiTimeoutObject(obj)); + ((IgniteKernal)ignite0).context().timeout().removeTimeoutObject(new GridSpiTimeoutObject(obj)); } } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/5c558129/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiContext.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiContext.java b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiContext.java index addf63f..611702b 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiContext.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/IgniteSpiContext.java @@ -320,13 +320,11 @@ public interface IgniteSpiContext { /** * @param c Timeout object. - * @throws IgniteSpiException Thrown if any exception occurs. */ - public void addTimeoutObject(IgniteSpiTimeoutObject c) throws IgniteSpiException; + public void addTimeoutObject(IgniteSpiTimeoutObject c); /** * @param c Timeout object. - * @throws IgniteSpiException Thrown if any exception occurs. */ - public void removeTimeoutObject(IgniteSpiTimeoutObject c) throws IgniteSpiException; + public void removeTimeoutObject(IgniteSpiTimeoutObject c); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/5c558129/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java index df7d098..b79ca55 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/TcpCommunicationSpi.java @@ -2063,7 +2063,7 @@ public class TcpCommunicationSpi extends IgniteSpiAdapter client = null; } - onException("Handshake timeout (will retry with increased timeout) [timeout=" + connTimeout0 + + onException("Handshake timed out (will retry with increased timeout) [timeout=" + connTimeout0 + ", addr=" + addr + ']', e); if (log.isDebugEnabled()) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/5c558129/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java index bca2d98..6587006 100644 --- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java +++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/ServerImpl.java @@ -338,7 +338,7 @@ class ServerImpl extends TcpDiscoveryImpl { clientMsgWorkers.clear(); - utilityPool.shutdownNow(); + IgniteUtils.shutdownNow(ServerImpl.class, utilityPool, log); U.interrupt(statsPrinter); U.join(statsPrinter, log);