Skip to content

Commit

Permalink
Fixed deployment test.
Browse files Browse the repository at this point in the history
  • Loading branch information
agoncharuk committed Nov 23, 2015
1 parent 3ca58d7 commit eeb9142
Show file tree
Hide file tree
Showing 4 changed files with 17 additions and 4 deletions.
Expand Up @@ -238,7 +238,7 @@ else if (o instanceof CacheObject) {
CacheObject co = (CacheObject)o;

if (!keepPortable || co.isPlatformType())
return unwrapPortable(co.value(this, true), keepPortable, cpy);
return unwrapPortable(co.value(this, cpy), keepPortable, cpy);
}

return o;
Expand Down
Expand Up @@ -179,8 +179,12 @@ public void onEnter() {
/**
* @param ignore {@code True} to ignore.
*/
public void ignoreOwnership(boolean ignore) {
public boolean ignoreOwnership(boolean ignore) {
boolean old = ignoreOwnership.get();

ignoreOwnership.set(ignore);

return old;
}

/**
Expand Down
Expand Up @@ -1049,6 +1049,6 @@ public boolean onResponse() {

/** {@inheritDoc} */
@Override public String toString() {
return S.toString(GridDhtAtomicUpdateRequest.class, this);
return S.toString(GridDhtAtomicUpdateRequest.class, this, "super", super.toString());
}
}
Expand Up @@ -217,7 +217,16 @@ public CacheObjectBinaryProcessorImpl(GridKernalContext ctx) {
/** {@inheritDoc} */
@SuppressWarnings("unchecked")
@Override public void onUtilityCacheStarted() throws IgniteCheckedException {
metaDataCache = (IgniteCacheProxy)ctx.cache().jcache(CU.UTILITY_CACHE_NAME).withNoRetries();
IgniteCacheProxy<Object, Object> proxy = ctx.cache().jcache(CU.UTILITY_CACHE_NAME);

boolean old = proxy.context().deploy().ignoreOwnership(true);

try {
metaDataCache = (IgniteCacheProxy)proxy.withNoRetries();
}
finally {
proxy.context().deploy().ignoreOwnership(old);
}

if (clientNode) {
assert !metaDataCache.context().affinityNode();
Expand Down

0 comments on commit eeb9142

Please sign in to comment.