ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From voze...@apache.org
Subject [2/3] ignite git commit: WIP.
Date Mon, 31 Aug 2015 08:21:30 GMT
WIP.


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

Branch: refs/heads/ignite-1331
Commit: ece750319e595c3f2ccff399b83641e7f1cc3a8d
Parents: 6fceac0
Author: vozerov-gridgain <vozerov@gridgain.com>
Authored: Mon Aug 31 11:10:28 2015 +0300
Committer: vozerov-gridgain <vozerov@gridgain.com>
Committed: Mon Aug 31 11:10:28 2015 +0300

----------------------------------------------------------------------
 .../ignite/internal/processors/platform/PlatformTarget.java    | 4 ++--
 .../internal/processors/platform/PlatformAbstractTarget.java   | 6 +++---
 .../internal/processors/platform/cache/PlatformCache.java      | 2 +-
 .../processors/platform/cache/PlatformCacheIterator.java       | 2 +-
 .../platform/cache/query/PlatformAbstractQueryCursor.java      | 2 +-
 .../processors/platform/cluster/PlatformClusterGroup.java      | 2 +-
 .../internal/processors/platform/events/PlatformEvents.java    | 2 +-
 .../processors/platform/services/PlatformServices.java         | 4 ++--
 .../processors/platform/transactions/PlatformTransactions.java | 2 +-
 9 files changed, 13 insertions(+), 13 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/ece75031/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformTarget.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformTarget.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformTarget.java
index e8b5b66..5326a83 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformTarget.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/platform/PlatformTarget.java
@@ -46,13 +46,13 @@ public interface PlatformTarget {
     public Object inStreamOutObject(int type, long memPtr) throws Exception;
 
     /**
-     * Synchronous OUT operation.
+     * Operation returning result to memory stream.
      *
      * @param type Operation type.
      * @param memPtr Memory pointer.
      * @throws Exception In case of failure.
      */
-    public void outOp(int type, long memPtr) throws Exception;
+    public void outStream(int type, long memPtr) throws Exception;
 
     /**
      * Operation accepting one memory stream and returning result to another memory stream.

http://git-wip-us.apache.org/repos/asf/ignite/blob/ece75031/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/PlatformAbstractTarget.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/PlatformAbstractTarget.java
b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/PlatformAbstractTarget.java
index 23add19..1868e96 100644
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/PlatformAbstractTarget.java
+++ b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/PlatformAbstractTarget.java
@@ -85,13 +85,13 @@ public abstract class PlatformAbstractTarget implements PlatformTarget
{
     }
 
     /** {@inheritDoc} */
-    @Override public void outOp(int type, long memPtr) throws Exception {
+    @Override public void outStream(int type, long memPtr) throws Exception {
         try (PlatformMemory mem = platformCtx.memory().get(memPtr)) {
             PlatformOutputStream out = mem.output();
 
             PortableRawWriterEx writer = platformCtx.writer(out);
 
-            processOutOp(type, writer);
+            processOutStream(type, writer);
 
             out.synchronize();
         }
@@ -247,7 +247,7 @@ public abstract class PlatformAbstractTarget implements PlatformTarget
{
      * @param writer Portable writer.
      * @throws IgniteCheckedException In case of exception.
      */
-    protected void processOutOp(int type, PortableRawWriterEx writer) throws IgniteCheckedException
{
+    protected void processOutStream(int type, PortableRawWriterEx writer) throws IgniteCheckedException
{
         throwUnsupported(type);
     }
 

http://git-wip-us.apache.org/repos/asf/ignite/blob/ece75031/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
index ec8f3e3..f6e5241 100644
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
+++ b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCache.java
@@ -428,7 +428,7 @@ public class PlatformCache extends PlatformAbstractTarget {
     }
 
     /** {@inheritDoc} */
-    @Override protected void processOutOp(int type, PortableRawWriterEx w) throws IgniteCheckedException
{
+    @Override protected void processOutStream(int type, PortableRawWriterEx w) throws IgniteCheckedException
{
         switch (type) {
             case OP_GET_NAME:
                 w.writeObject(cache.getName());

http://git-wip-us.apache.org/repos/asf/ignite/blob/ece75031/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheIterator.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheIterator.java
b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheIterator.java
index 45e777d..4facac9 100644
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheIterator.java
+++ b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/PlatformCacheIterator.java
@@ -47,7 +47,7 @@ public class PlatformCacheIterator extends PlatformAbstractTarget {
     }
 
     /** {@inheritDoc} */
-    @Override protected void processOutOp(int type, PortableRawWriterEx writer) throws IgniteCheckedException
{
+    @Override protected void processOutStream(int type, PortableRawWriterEx writer) throws
IgniteCheckedException {
         switch (type) {
             case OP_NEXT:
                 if (iter.hasNext()) {

http://git-wip-us.apache.org/repos/asf/ignite/blob/ece75031/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformAbstractQueryCursor.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformAbstractQueryCursor.java
b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformAbstractQueryCursor.java
index c01da0e..9307d8c 100644
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformAbstractQueryCursor.java
+++ b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cache/query/PlatformAbstractQueryCursor.java
@@ -62,7 +62,7 @@ public abstract class PlatformAbstractQueryCursor<T> extends PlatformAbstractTar
     }
 
     /** {@inheritDoc} */
-    @Override protected void processOutOp(int type, final PortableRawWriterEx writer) throws
IgniteCheckedException {
+    @Override protected void processOutStream(int type, final PortableRawWriterEx writer)
throws IgniteCheckedException {
         switch (type) {
             case OP_GET_BATCH: {
                 assert iter != null : "iterator() has not been called";

http://git-wip-us.apache.org/repos/asf/ignite/blob/ece75031/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterGroup.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterGroup.java
b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterGroup.java
index 6cb5421..dcbf8ce 100644
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterGroup.java
+++ b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/cluster/PlatformClusterGroup.java
@@ -90,7 +90,7 @@ public class PlatformClusterGroup extends PlatformAbstractTarget {
 
     /** {@inheritDoc} */
     @SuppressWarnings("deprecation")
-    @Override protected void processOutOp(int type, PortableRawWriterEx writer) throws IgniteCheckedException
{
+    @Override protected void processOutStream(int type, PortableRawWriterEx writer) throws
IgniteCheckedException {
         switch (type) {
             case OP_METRICS:
                 platformCtx.writeClusterMetrics(writer, prj.metrics());

http://git-wip-us.apache.org/repos/asf/ignite/blob/ece75031/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java
b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java
index 741b270..72bb45b 100644
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java
+++ b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/events/PlatformEvents.java
@@ -247,7 +247,7 @@ public class PlatformEvents extends PlatformAbstractTarget {
     }
 
     /** {@inheritDoc} */
-    @Override protected void processOutOp(int type, PortableRawWriterEx writer) throws IgniteCheckedException
{
+    @Override protected void processOutStream(int type, PortableRawWriterEx writer) throws
IgniteCheckedException {
         switch (type) {
             case OP_GET_ENABLED_EVENTS:
                 writeEventTypes(events.enabledEvents(), writer);

http://git-wip-us.apache.org/repos/asf/ignite/blob/ece75031/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformServices.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformServices.java
b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformServices.java
index 9c5b51e..14b0fd1 100644
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformServices.java
+++ b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/services/PlatformServices.java
@@ -213,7 +213,7 @@ public class PlatformServices extends PlatformAbstractTarget {
     }
 
     /** {@inheritDoc} */
-    @Override protected void processOutOp(int type, PortableRawWriterEx writer) throws IgniteCheckedException
{
+    @Override protected void processOutStream(int type, PortableRawWriterEx writer) throws
IgniteCheckedException {
         switch (type) {
             case OP_DESCRIPTORS: {
                 Collection<ServiceDescriptor> descs = services.serviceDescriptors();
@@ -242,7 +242,7 @@ public class PlatformServices extends PlatformAbstractTarget {
             }
         }
 
-        super.processOutOp(type, writer);
+        super.processOutStream(type, writer);
     }
 
     /** <inheritDoc /> */

http://git-wip-us.apache.org/repos/asf/ignite/blob/ece75031/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/transactions/PlatformTransactions.java
----------------------------------------------------------------------
diff --git a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/transactions/PlatformTransactions.java
b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/transactions/PlatformTransactions.java
index aedc380..4da5392 100644
--- a/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/transactions/PlatformTransactions.java
+++ b/modules/platform/src/main/java/org/apache/ignite/internal/processors/platform/transactions/PlatformTransactions.java
@@ -227,7 +227,7 @@ public class PlatformTransactions extends PlatformAbstractTarget {
     }
 
     /** {@inheritDoc} */
-    @Override protected void processOutOp(int type, PortableRawWriterEx writer) throws IgniteCheckedException
{
+    @Override protected void processOutStream(int type, PortableRawWriterEx writer) throws
IgniteCheckedException {
         switch (type) {
             case OP_CACHE_CONFIG_PARAMETERS:
                 TransactionConfiguration txCfg = platformCtx.kernalContext().config().getTransactionConfiguration();


Mime
View raw message