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 A294B1863A for ; Fri, 8 May 2015 09:15:59 +0000 (UTC) Received: (qmail 18962 invoked by uid 500); 8 May 2015 09:15:59 -0000 Delivered-To: apmail-ignite-commits-archive@ignite.apache.org Received: (qmail 18931 invoked by uid 500); 8 May 2015 09:15:59 -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 18922 invoked by uid 99); 8 May 2015 09:15:59 -0000 Received: from Unknown (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 08 May 2015 09:15:59 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id 1416F1A23DA for ; Fri, 8 May 2015 09:15:59 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 1.791 X-Spam-Level: * X-Spam-Status: No, score=1.791 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, 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 (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id kRWuqilgTxoH for ; Fri, 8 May 2015 09:15:47 +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 F3E9D47610 for ; Fri, 8 May 2015 09:13:02 +0000 (UTC) Received: (qmail 9244 invoked by uid 99); 8 May 2015 09:13:02 -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, 08 May 2015 09:13:02 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 12521E4455; Fri, 8 May 2015 09:13:02 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sboikov@apache.org To: commits@ignite.incubator.apache.org Date: Fri, 08 May 2015 09:13:22 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [22/50] incubator-ignite git commit: ignite-646 ignite-646 Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b0374bca Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b0374bca Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b0374bca Branch: refs/heads/ignite-286 Commit: b0374bca8929687f6398076c795b68673fa244ca Parents: b45679c Author: avinogradov Authored: Wed Apr 29 15:25:22 2015 +0300 Committer: avinogradov Committed: Wed Apr 29 15:25:22 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/GridCacheIoManager.java | 13 +++++++ .../dht/preloader/GridDhtForceKeysResponse.java | 36 ++++++++++++++++---- 2 files changed, 42 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b0374bca/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java index 14d6f7c..a6cbc37 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheIoManager.java @@ -302,6 +302,13 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter { } } + /** + * Sends response on failed message. + * @param nodeId node id. + * @param res response. + * @param cctx shared context. + * @param plc grid io policy. + */ private void sendResponseOnFailedMessage(UUID nodeId, GridCacheMessage res, GridCacheSharedContext cctx, GridIoPolicy plc) { try { @@ -313,6 +320,12 @@ public class GridCacheIoManager extends GridCacheSharedManagerAdapter { } } + /** + * Processes failed messages. + * @param nodeId niode id. + * @param msg message. + * @throws IgniteCheckedException + */ private void processFailedMessage(UUID nodeId, GridCacheMessage msg) throws IgniteCheckedException { GridCacheContext ctx = cctx.cacheContext(msg.cacheId()); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b0374bca/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java index 5c6e24f..41ce0be 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtForceKeysResponse.java @@ -43,8 +43,12 @@ public class GridDhtForceKeysResponse extends GridCacheMessage implements GridCa private IgniteUuid miniId; /** Error. */ + @GridDirectTransient private volatile IgniteCheckedException err; + /** Serialized error. */ + private byte[] errBytes; + /** Missed (not found) keys. */ @GridToStringInclude @GridDirectCollection(KeyCacheObject.class) @@ -160,6 +164,8 @@ public class GridDhtForceKeysResponse extends GridCacheMessage implements GridCa for (GridCacheEntryInfo info : infos) info.marshal(cctx); } + + errBytes = ctx.marshaller().marshal(err); } /** {@inheritDoc} */ @@ -175,6 +181,8 @@ public class GridDhtForceKeysResponse extends GridCacheMessage implements GridCa for (GridCacheEntryInfo info : infos) info.unmarshal(cctx, ldr); } + + err = ctx.marshaller().unmarshal(errBytes, ldr); } /** {@inheritDoc} */ @@ -193,24 +201,30 @@ public class GridDhtForceKeysResponse extends GridCacheMessage implements GridCa switch (writer.state()) { case 3: - if (!writer.writeIgniteUuid("futId", futId)) + if (!writer.writeByteArray("errBytes", errBytes)) return false; writer.incrementState(); case 4: - if (!writer.writeCollection("infos", infos, MessageCollectionItemType.MSG)) + if (!writer.writeIgniteUuid("futId", futId)) return false; writer.incrementState(); case 5: - if (!writer.writeIgniteUuid("miniId", miniId)) + if (!writer.writeCollection("infos", infos, MessageCollectionItemType.MSG)) return false; writer.incrementState(); case 6: + if (!writer.writeIgniteUuid("miniId", miniId)) + return false; + + writer.incrementState(); + + case 7: if (!writer.writeCollection("missedKeys", missedKeys, MessageCollectionItemType.MSG)) return false; @@ -233,7 +247,7 @@ public class GridDhtForceKeysResponse extends GridCacheMessage implements GridCa switch (reader.state()) { case 3: - futId = reader.readIgniteUuid("futId"); + errBytes = reader.readByteArray("errBytes"); if (!reader.isLastRead()) return false; @@ -241,7 +255,7 @@ public class GridDhtForceKeysResponse extends GridCacheMessage implements GridCa reader.incrementState(); case 4: - infos = reader.readCollection("infos", MessageCollectionItemType.MSG); + futId = reader.readIgniteUuid("futId"); if (!reader.isLastRead()) return false; @@ -249,7 +263,7 @@ public class GridDhtForceKeysResponse extends GridCacheMessage implements GridCa reader.incrementState(); case 5: - miniId = reader.readIgniteUuid("miniId"); + infos = reader.readCollection("infos", MessageCollectionItemType.MSG); if (!reader.isLastRead()) return false; @@ -257,6 +271,14 @@ public class GridDhtForceKeysResponse extends GridCacheMessage implements GridCa reader.incrementState(); case 6: + miniId = reader.readIgniteUuid("miniId"); + + if (!reader.isLastRead()) + return false; + + reader.incrementState(); + + case 7: missedKeys = reader.readCollection("missedKeys", MessageCollectionItemType.MSG); if (!reader.isLastRead()) @@ -276,7 +298,7 @@ public class GridDhtForceKeysResponse extends GridCacheMessage implements GridCa /** {@inheritDoc} */ @Override public byte fieldsCount() { - return 7; + return 8; } /** {@inheritDoc} */