APISonar


org.apache.ignite.Ignite.log

> org > apache > ignite > Ignite > log
org APIs apache APIs ignite APIs Ignite APIs log APIs

Example 1
@Override public void start(PluginContext ctx) {
        final Ignite ignite = ctx.grid();

        log = ignite.log();
        managedBuffers = setupDirect((IgniteEx)ignite);
    }
Example 2
public AsyncNativeProcessRunner(Ignite ignite, ExecutorService executor) {
        this.log = ignite.log().getLogger(AsyncNativeProcessRunner.class);
        this.executor = executor;
    }
Example 3
@Override protected boolean handle(Ignite ignite, FailureContext failureCtx) {
        new Thread(
            new Runnable() {
                @Override public void run() {
                    U.error(ignite.log(), "Restarting JVM on Ignite failure: [failureCtx=" + failureCtx + ']');

                    G.restart(true);
                }
            },
            "node-restarter"
        ).start();

        return true;
    }
Example 4
IgniteGeneralDataRegion(RegionFactory factory, String name,
        Ignite ignite, HibernateCacheProxy cache) {
        super(factory, name, ignite, cache);

        log = ignite.log().getLogger(getClass());
    }
Example 5
public TensorFlowUserScriptRunner(Ignite ignite, ExecutorService executor, TensorFlowJobArchive jobArchive,
        TensorFlowClusterSpec clusterSpec, Consumer<String> out, Consumer<String> err) {
        super(ignite, executor);

        this.log = ignite.log().getLogger(TensorFlowUserScriptRunner.class);

        this.jobArchive = jobArchive;
        this.clusterSpec = clusterSpec;
        this.out = out;
        this.err = err;
    }
Example 6
private void removeRetriesSimple(Ignite ignite, boolean putCntr) {
        for (int i = 0; i < RETRIES; i++) {
            if (DEBUG)
                ignite.log().info("***");

            if (cntrRmvd.get() % LOG_FREQ == 0 || DEBUG)
                ignite.log().info("*** Iteration #" + i + " ***");

            if (DEBUG)
                ignite.log().info("***");

            onRemoveItemSimple(putCntr, ignite, i);
        }
    }
Example 7
@Override protected boolean handle(Ignite ignite, FailureContext failureCtx) {
        if (this.failureCtx == null) {
            this.failureCtx = failureCtx;

            if (latch != null)
                latch.countDown();

            ignite.log().warning("Handled ignite failure: " + failureCtx);
        }

        return invalidate;
    }
Example 8
protected HibernateAccessStrategyAdapter(
        Ignite ignite,
        HibernateCacheProxy cache,
        HibernateExceptionConverter eConverter) {
        this.cache = cache;
        this.ignite = ignite;
        this.eConverter = eConverter;

        log = ignite.log().getLogger(getClass());
    }
Example 9
public ClusterPortManager(Ignite ignite, String poolName, int from, int cnt) {
        assert ignite != null : "Ignite instance should not be null";
        assert poolName != null : "Pool name should not be null";
        assert cnt >= 0 : "Count should not be negative";
        assert from >= 0 && cnt + from <= 0xFFFF : "Port range should be between 0 and 65535";

        this.ignite = ignite;
        this.log = ignite.log().getLogger(ClusterPortManager.class);

        this.portMgrCacheName = String.format("PORT_MANAGER_%s_CACHE", poolName);
        this.from = from;
        this.cnt = cnt;
        this.cache = getOrCreateCache();
    }