APISonar


org.apache.ignite.internal.processors.cache.GridCacheContext.time

> org > apache > ignite > internal > processors > cache > GridCacheContext > time
org APIs apache APIs ignite APIs internal APIs processors APIs cache APIs GridCacheContext APIs time APIs

Example 1
protected GridCacheContext<K, V> cctx;

    @Override public boolean onDone(Collection<R> res, Throwable err) {
        cctx.time().removeTimeoutObject(this);

        return super.onDone(res, err);
    }
Example 2
private GridCacheContext<?, ?> cctx;

    public void map() {
        if (F.isEmpty(entries)) {
            onComplete(true, false, true);

            return;
        }

        readyLocks();

        if (timeout > 0) {
            timeoutObj = new LockTimeoutObject();

            cctx.time().addTimeoutObject(timeoutObj);
        }
    }
Example 3
private GridCacheContext<K, V> cctx;

    private void onComplete(boolean success) {
        if (!success)
            undoLocks();

        if (onDone(success, err)) {
            if (log.isDebugEnabled())
                log.debug("Completing future: " + this);

            cache.onFutureDone(this);

            if (timeoutObj != null)
                cctx.time().removeTimeoutObject(timeoutObj);
        }
    }