Package org.jgroups.protocols

Examples of org.jgroups.protocols.FORK$ForkHeader


        this.main_channel=main_channel;
        this.fork_channel_id=fork_channel_id;

        Protocol bottom_prot=null;
        synchronized(ForkChannel.class) { // To prevent multiple concurrent FORK creations https://issues.jboss.org/browse/JGRP-1842
            FORK fork=getFORK(main_channel, position, neighbor, create_fork_if_absent);
            bottom_prot=fork.get(fork_stack_id);
            if(bottom_prot == null) // Create the fork-stack if absent
                bottom_prot=fork.createForkStack(fork_stack_id, new ForkProtocolStack(), false,
                                                 protocols == null? null : Arrays.asList(protocols));
        }
        prot_stack=getForkStack(bottom_prot);
        flush_supported=main_channel.flushSupported();
    }
View Full Code Here



    protected static FORK getFORK(Channel ch, int position, Class<? extends Protocol> neighbor,
                                  boolean create_fork_if_absent) throws Exception {
        ProtocolStack stack=ch.getProtocolStack();
        FORK fork=(FORK)stack.findProtocol(FORK.class);
        if(fork == null) {
            if(!create_fork_if_absent)
                throw new IllegalArgumentException("FORK not found in main stack");
            fork=new FORK();
            stack.insertProtocol(fork, position, neighbor);
        }
        return fork;
    }
View Full Code Here

            stack.addProtocol(relay);
            relay.init();
        }

        // Add implicit FORK to the top of the stack
        FORK fork = new FORK();
        stack.addProtocol(fork);
        fork.init();

        channel.setName(this.configuration.getEnvironment().getNodeName());

        TransportConfiguration.Topology topology = this.configuration.getTransport().getTopology();
        if (topology != null) {
View Full Code Here

            stack.addProtocol(relay);
            relay.init();
        }

        // Add implicit FORK to the top of the stack
        FORK fork = new FORK();
        stack.addProtocol(fork);
        fork.init();

        // Handle the Sasl protocol
        final SaslConfiguration saslConfig = this.configuration.getSasl();
        if (saslConfig != null) {
           final String clusterRole = saslConfig.getClusterRole();
View Full Code Here

TOP

Related Classes of org.jgroups.protocols.FORK$ForkHeader

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.