ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [01/17] incubator-ignite git commit: #ignite-743: Add class IgniteCacheProxyLockFree.
Date Fri, 17 Apr 2015 11:01:06 GMT
Repository: incubator-ignite
Updated Branches:
  refs/heads/ignite-sprint-4 122f3ce3c -> 357a7156b


#ignite-743: Add class IgniteCacheProxyLockFree.


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

Branch: refs/heads/ignite-sprint-4
Commit: 196337aaf0ea0fb183bcd8f8ed75559b6ba4c871
Parents: 59b11b4
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Tue Apr 14 14:49:17 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Tue Apr 14 14:49:17 2015 +0300

----------------------------------------------------------------------
 .../cache/IgniteCacheProxyLockFree.java         | 24 ++++++++++++++++++++
 .../dr/IgniteDrDataStreamerCacheUpdater.java    |  2 --
 2 files changed, 24 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/196337aa/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyLockFree.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyLockFree.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyLockFree.java
new file mode 100644
index 0000000..81e1f24
--- /dev/null
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyLockFree.java
@@ -0,0 +1,24 @@
+/*
+ * 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.cache;
+
+/**
+ * Cache proxy lock free.
+ */
+public class IgniteCacheProxyLockFree {
+}

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/196337aa/modules/core/src/main/java/org/apache/ignite/internal/processors/dr/IgniteDrDataStreamerCacheUpdater.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/dr/IgniteDrDataStreamerCacheUpdater.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/dr/IgniteDrDataStreamerCacheUpdater.java
index 818b99a..c3a8989 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/dr/IgniteDrDataStreamerCacheUpdater.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/dr/IgniteDrDataStreamerCacheUpdater.java
@@ -53,8 +53,6 @@ public class IgniteDrDataStreamerCacheUpdater implements StreamReceiver<KeyCache
             if (log.isDebugEnabled())
                 log.debug("Running DR put job [nodeId=" + ctx.localNodeId() + ", cacheName="
+ cacheName + ']');
 
-            cache.context().awaitStarted();
-
             CacheObjectContext cacheObjCtx = cache.context().cacheObjectContext();
 
             for (Map.Entry<KeyCacheObject, CacheObject> entry0 : col) {


Mime
View raw message