ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject incubator-ignite git commit: # sprint-6 fixed file name
Date Wed, 28 Jan 2015 12:56:30 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-6 6e3b88d5d -> 6759af1ec


# sprint-6 fixed file name


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

Branch: refs/heads/ignite-6
Commit: 6759af1ecfcd390b35859e596f9527611ec56d6f
Parents: 6e3b88d
Author: sboikov <sboikov@gridgain.com>
Authored: Wed Jan 28 15:56:02 2015 +0300
Committer: sboikov <sboikov@gridgain.com>
Committed: Wed Jan 28 15:56:02 2015 +0300

----------------------------------------------------------------------
 .../DataStructuresCommandHandler.java           | 108 +++++++++++++++++++
 .../DatastructuresCommandHandler.java           | 108 -------------------
 .../rest/request/DataStructuresRequest.java     |  74 +++++++++++++
 .../rest/request/DatastructuresRequest.java     |  74 -------------
 4 files changed, 182 insertions(+), 182 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6759af1e/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/datastructures/DataStructuresCommandHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/datastructures/DataStructuresCommandHandler.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/datastructures/DataStructuresCommandHandler.java
new file mode 100644
index 0000000..b4cb672
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/datastructures/DataStructuresCommandHandler.java
@@ -0,0 +1,108 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.processors.rest.handlers.datastructures;
+
+import org.apache.ignite.*;
+import org.apache.ignite.internal.*;
+import org.apache.ignite.internal.processors.rest.*;
+import org.apache.ignite.internal.processors.rest.handlers.*;
+import org.apache.ignite.internal.processors.rest.request.*;
+import org.apache.ignite.internal.util.future.*;
+import org.apache.ignite.internal.util.typedef.*;
+import org.apache.ignite.internal.util.typedef.internal.*;
+import org.apache.ignite.lang.*;
+
+import java.util.*;
+import java.util.concurrent.*;
+
+import static org.apache.ignite.internal.processors.rest.GridRestCommand.*;
+
+/**
+ *
+ */
+public class DataStructuresCommandHandler extends GridRestCommandHandlerAdapter {
+    /** Supported commands. */
+    private static final Collection<GridRestCommand> SUPPORTED_COMMANDS = U.sealList(
+        CACHE_INCREMENT,
+        CACHE_DECREMENT
+    );
+    /**
+     * @param ctx Context.
+     */
+    public DataStructuresCommandHandler(GridKernalContext ctx) {
+        super(ctx);
+    }
+
+    /** {@inheritDoc} */
+    @Override public Collection<GridRestCommand> supportedCommands() {
+        return SUPPORTED_COMMANDS;
+    }
+
+    /** {@inheritDoc} */
+    @Override public IgniteFuture<GridRestResponse> handleAsync(GridRestRequest req)
{
+        assert SUPPORTED_COMMANDS.contains(req.command()) : req.command();
+
+        return incrementOrDecrement((DataStructuresRequest)req).chain(new CX1<IgniteFuture<?>,
GridRestResponse>() {
+            @Override public GridRestResponse applyx(IgniteFuture<?> fut) throws IgniteCheckedException
{
+                GridRestResponse res = new GridRestResponse();
+
+                res.setResponse(fut.get());
+
+                return res;
+            }
+        });
+    }
+    /**
+     * Handles increment and decrement commands.
+     *
+     * @param req Request.
+     * @return Future of operation result.
+     */
+    private IgniteFuture<?> incrementOrDecrement(final DataStructuresRequest req) {
+        assert req != null;
+        assert req.command() == CACHE_INCREMENT || req.command() == CACHE_DECREMENT : req.command();
+
+        if (req.key() == null) {
+            IgniteCheckedException err =
+                new IgniteCheckedException(GridRestCommandHandlerAdapter.missingParameter("key"));
+
+            return new GridFinishedFuture(ctx, err);
+        }
+        else if (req.delta() == null) {
+            IgniteCheckedException err =
+                new IgniteCheckedException(GridRestCommandHandlerAdapter.missingParameter("delta"));
+
+            return new GridFinishedFuture(ctx, err);
+        }
+
+        return ctx.closure().callLocalSafe(new Callable<Object>() {
+            @Override public Object call() throws Exception {
+                Long init = req.initial();
+                Long delta = req.delta();
+
+                boolean decr = req.command() == CACHE_DECREMENT;
+
+                String key = (String)req.key();
+
+                IgniteAtomicLong l = ctx.grid().atomicLong(key, init != null ? init : 0,
true);
+
+                return l.addAndGet(decr ? -delta : delta);
+            }
+        }, false);
+    }
+}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6759af1e/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/datastructures/DatastructuresCommandHandler.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/datastructures/DatastructuresCommandHandler.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/datastructures/DatastructuresCommandHandler.java
deleted file mode 100644
index b4cb672..0000000
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/handlers/datastructures/DatastructuresCommandHandler.java
+++ /dev/null
@@ -1,108 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.rest.handlers.datastructures;
-
-import org.apache.ignite.*;
-import org.apache.ignite.internal.*;
-import org.apache.ignite.internal.processors.rest.*;
-import org.apache.ignite.internal.processors.rest.handlers.*;
-import org.apache.ignite.internal.processors.rest.request.*;
-import org.apache.ignite.internal.util.future.*;
-import org.apache.ignite.internal.util.typedef.*;
-import org.apache.ignite.internal.util.typedef.internal.*;
-import org.apache.ignite.lang.*;
-
-import java.util.*;
-import java.util.concurrent.*;
-
-import static org.apache.ignite.internal.processors.rest.GridRestCommand.*;
-
-/**
- *
- */
-public class DataStructuresCommandHandler extends GridRestCommandHandlerAdapter {
-    /** Supported commands. */
-    private static final Collection<GridRestCommand> SUPPORTED_COMMANDS = U.sealList(
-        CACHE_INCREMENT,
-        CACHE_DECREMENT
-    );
-    /**
-     * @param ctx Context.
-     */
-    public DataStructuresCommandHandler(GridKernalContext ctx) {
-        super(ctx);
-    }
-
-    /** {@inheritDoc} */
-    @Override public Collection<GridRestCommand> supportedCommands() {
-        return SUPPORTED_COMMANDS;
-    }
-
-    /** {@inheritDoc} */
-    @Override public IgniteFuture<GridRestResponse> handleAsync(GridRestRequest req)
{
-        assert SUPPORTED_COMMANDS.contains(req.command()) : req.command();
-
-        return incrementOrDecrement((DataStructuresRequest)req).chain(new CX1<IgniteFuture<?>,
GridRestResponse>() {
-            @Override public GridRestResponse applyx(IgniteFuture<?> fut) throws IgniteCheckedException
{
-                GridRestResponse res = new GridRestResponse();
-
-                res.setResponse(fut.get());
-
-                return res;
-            }
-        });
-    }
-    /**
-     * Handles increment and decrement commands.
-     *
-     * @param req Request.
-     * @return Future of operation result.
-     */
-    private IgniteFuture<?> incrementOrDecrement(final DataStructuresRequest req) {
-        assert req != null;
-        assert req.command() == CACHE_INCREMENT || req.command() == CACHE_DECREMENT : req.command();
-
-        if (req.key() == null) {
-            IgniteCheckedException err =
-                new IgniteCheckedException(GridRestCommandHandlerAdapter.missingParameter("key"));
-
-            return new GridFinishedFuture(ctx, err);
-        }
-        else if (req.delta() == null) {
-            IgniteCheckedException err =
-                new IgniteCheckedException(GridRestCommandHandlerAdapter.missingParameter("delta"));
-
-            return new GridFinishedFuture(ctx, err);
-        }
-
-        return ctx.closure().callLocalSafe(new Callable<Object>() {
-            @Override public Object call() throws Exception {
-                Long init = req.initial();
-                Long delta = req.delta();
-
-                boolean decr = req.command() == CACHE_DECREMENT;
-
-                String key = (String)req.key();
-
-                IgniteAtomicLong l = ctx.grid().atomicLong(key, init != null ? init : 0,
true);
-
-                return l.addAndGet(decr ? -delta : delta);
-            }
-        }, false);
-    }
-}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6759af1e/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/request/DataStructuresRequest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/request/DataStructuresRequest.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/request/DataStructuresRequest.java
new file mode 100644
index 0000000..13f03cd
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/request/DataStructuresRequest.java
@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.ignite.internal.processors.rest.request;
+
+/**
+ *
+ */
+public class DataStructuresRequest extends GridRestRequest {
+    /** Value to add/subtract. */
+    private Long delta;
+
+    /** Initial value for increment and decrement commands. */
+    private Long init;
+
+    /** Key. */
+    private Object key;
+
+    /**
+     * @return Key.
+     */
+    public Object key() {
+        return key;
+    }
+
+    /**
+     * @param key Key.
+     */
+    public void key(Object key) {
+        this.key = key;
+    }
+
+    /**
+     * @return Delta for increment and decrement commands.
+     */
+    public Long delta() {
+        return delta;
+    }
+
+    /**
+     * @param delta Delta for increment and decrement commands.
+     */
+    public void delta(Long delta) {
+        this.delta = delta;
+    }
+
+    /**
+     * @return Initial value for increment and decrement commands.
+     */
+    public Long initial() {
+        return init;
+    }
+
+    /**
+     * @param init Initial value for increment and decrement commands.
+     */
+    public void initial(Long init) {
+        this.init = init;
+    }
+}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/6759af1e/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/request/DatastructuresRequest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/request/DatastructuresRequest.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/request/DatastructuresRequest.java
deleted file mode 100644
index 13f03cd..0000000
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/rest/request/DatastructuresRequest.java
+++ /dev/null
@@ -1,74 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.ignite.internal.processors.rest.request;
-
-/**
- *
- */
-public class DataStructuresRequest extends GridRestRequest {
-    /** Value to add/subtract. */
-    private Long delta;
-
-    /** Initial value for increment and decrement commands. */
-    private Long init;
-
-    /** Key. */
-    private Object key;
-
-    /**
-     * @return Key.
-     */
-    public Object key() {
-        return key;
-    }
-
-    /**
-     * @param key Key.
-     */
-    public void key(Object key) {
-        this.key = key;
-    }
-
-    /**
-     * @return Delta for increment and decrement commands.
-     */
-    public Long delta() {
-        return delta;
-    }
-
-    /**
-     * @param delta Delta for increment and decrement commands.
-     */
-    public void delta(Long delta) {
-        this.delta = delta;
-    }
-
-    /**
-     * @return Initial value for increment and decrement commands.
-     */
-    public Long initial() {
-        return init;
-    }
-
-    /**
-     * @param init Initial value for increment and decrement commands.
-     */
-    public void initial(Long init) {
-        this.init = init;
-    }
-}


Mime
View raw message