APISonar


org.apache.ignite.internal.GridKernalContext.io

> org > apache > ignite > internal > GridKernalContext > io
org APIs apache APIs ignite APIs internal APIs GridKernalContext APIs io APIs

Example 1
ClientMetadataRequestFuture(
            GridKernalContext ctx,
            int typeId,
            Map<Integer, ClientMetadataRequestFuture> syncMap
    ) {
        ioMgr = ctx.io();
        discoMgr = ctx.discovery();
        aliveSrvNodes = new LinkedList<>(discoMgr.aliveServerNodes());

        this.typeId = typeId;
        this.syncMap = syncMap;

        if (log == null)
            log = U.logger(ctx, logRef, ClientMetadataRequestFuture.class);
    }
Example 2
protected volatile GridKernalContext ctx;

    @Override public void onKernalStop() {
        connMgr.onKernalStop();

        ctx.io().removeMessageListener(GridTopic.TOPIC_QUERY, qryLsnr);
        ctx.event().removeLocalEventListener(discoLsnr);
    }
Example 3
public DataStreamProcessor(GridKernalContext ctx) {
        super(ctx);

        if (!ctx.clientNode()) {
            ctx.io().addMessageListener(TOPIC_DATASTREAM, new GridMessageListener() {
                @Override public void onMessage(UUID nodeId, Object msg, byte plc) {
                    assert msg instanceof DataStreamerRequest;

                    processRequest(nodeId, (DataStreamerRequest)msg);
                }
            });
        }

        marsh = ctx.config().getMarshaller();
    }
Example 4
private final GridKernalContext ctx;

    void sendUndeployRequest(String rsrcName, Collection<ClusterNode> rmtNodes) throws IgniteCheckedException {
        assert !rmtNodes.contains(ctx.discovery().localNode());

        Message req = new GridDeploymentRequest(null, null, rsrcName, true);

        if (!rmtNodes.isEmpty()) {
            ctx.io().sendToGridTopic(
                rmtNodes,
                TOPIC_CLASSLOAD,
                req,
                GridIoPolicy.P2P_POOL);
        }
    }
Example 5
private final GridKernalContext ctx;

    void stop() {
        if (log.isDebugEnabled())
            log.debug("Stopping deployment communication.");

        busyLock.block();

        ctx.io().removeMessageListener(TOPIC_CLASSLOAD, peerLsnr);
    }
Example 6
private GridKernalContext ctx;

    private void sendNextPage(ClusterNode node, GridQueryNextPageResponse msg) {
        try {
            if (msg != null) {
                if (node.isLocal())
                    h2.reduceQueryExecutor().onNextPage(node, msg);
                else
                    ctx.io().sendToGridTopic(node, GridTopic.TOPIC_QUERY, msg, QUERY_POOL);
            }
        }
        catch (IgniteCheckedException e) {
            U.error(log, "Failed to send message.", e);

            throw new IgniteException(e);
        }
    }