ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From vkuliche...@apache.org
Subject [12/26] incubator-ignite git commit: # gg-9791 - Communication fixes
Date Sat, 21 Feb 2015 01:46:25 GMT
# gg-9791 - Communication fixes


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/86b233c9
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/86b233c9
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/86b233c9

Branch: refs/heads/sprint-2
Commit: 86b233c9ecf27ed88880231d983e823af5f819d1
Parents: ae9df45
Author: Valentin Kulichenko <vkulichenko@gridgain.com>
Authored: Thu Feb 19 20:42:41 2015 -0800
Committer: Valentin Kulichenko <vkulichenko@gridgain.com>
Committed: Thu Feb 19 20:42:41 2015 -0800

----------------------------------------------------------------------
 .../managers/communication/GridIoMessageFactory.java    | 12 +++++++++---
 .../plugin/extensions/communication/MessageAdapter.java |  7 +++++++
 2 files changed, 16 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/86b233c9/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
index ec74b7f..65cd774 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoMessageFactory.java
@@ -68,13 +68,19 @@ public class GridIoMessageFactory implements MessageFactory {
 
         switch (type) {
             case TcpCommunicationSpi.NODE_ID_MSG_TYPE:
-                return new TcpCommunicationSpi.NodeIdMessage();
+                msg = new TcpCommunicationSpi.NodeIdMessage();
+
+                break;
 
             case TcpCommunicationSpi.RECOVERY_LAST_ID_MSG_TYPE:
-                return new TcpCommunicationSpi.RecoveryLastReceivedMessage();
+                msg = new TcpCommunicationSpi.RecoveryLastReceivedMessage();
+
+                break;
 
             case TcpCommunicationSpi.HANDSHAKE_MSG_TYPE:
-                return new TcpCommunicationSpi.HandshakeMessage();
+                msg = new TcpCommunicationSpi.HandshakeMessage();
+
+                break;
 
             case 0:
                 msg = new GridJobCancelRequest();

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/86b233c9/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java
b/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java
index 807bda5..6f0a73a 100644
--- a/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java
+++ b/modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/MessageAdapter.java
@@ -65,6 +65,13 @@ public abstract class MessageAdapter implements Serializable {
     public abstract byte directType();
 
     /**
+     * Gets fields count.
+     *
+     * @return Fields count.
+     */
+    public abstract byte fieldsCount();
+
+    /**
      * Defines whether recovery for this message should be skipped.
      *
      * @return Whether recovery for this message should be skipped.


Mime
View raw message