[jgroups-users] ReplicatedHashMap and ForkChannel

Questions/problems related to using JGroups <[email protected]> Tue, 18 Oct 2016 14:19:21 -0400

Newsgroups	gmane.comp.java.javagroups.general
Message-ID	<[email protected]>

As I read the code, there is no way for a ReplacedHashMap to work on a ForkChannel.  Is this right?  Or at least you can't have the STATE_TRANSFER on the fork.  The ForkChannel.getState(...) just calls the main_channel method.  Even if the STATE_TRANSFER is on the main channel, my replicatedHashMap.start() is timing out even though I have very little data.

Has anyone gotten this to work?  I've attached my stack.  My ReplacedHashMap is built with the following code which attaches to the main stack:

   ForkChannel forkChannel = new ForkChannel(jchannel, forkName, channelName, new STATE_TRANSFER());
   forkChannel.connect(jchannel.getClusterName());
   ReplicatedHashMap<K, V> map = new ReplicatedHashMap<>(forkChannel);
   map.start(10000);

Thanks much in advance,
gray

------------------------------------------------------------------------------
Check out the vibrant tech community on one of the world's most 
engaging tech sites, SlashDot.org! http://sdm.link/slashdot

_______________________________________________
javagroups-users mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/javagroups-users

jgroups_udp.xml (application/xml, 2.6 KB)

<!-- This config file is used by the JgroupsChannel java class to load in a number of different network protocols that allow 
	us to talk amongst servers. This is designed to work in EC2 but can also work locallhy. This stack uses UDP unicasting for 
	network. It is both authenticated and encrypted. NOTE: The FRAG2 fragment size needs to be <= 32k for EC2. -->
<config xmlns="urn:org:jgroups" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:org:jgroups http://www.jgroups.org/schema/jgroups.xsd">

	<!-- port wired in by JgroupsChannel -->
	<UDP ip_mcast="false" tos="8" ucast_recv_buf_size="2M" ucast_send_buf_size="2M" max_bundle_size="30K"
		max_bundle_timeout="30" enable_diagnostics="false" thread_naming_pattern="cl" thread_pool.min_threads="2"
		thread_pool.queue_enabled="true" thread_pool.queue_max_size="100" thread_pool.rejection_policy="discard"
		thread_pool.max_threads="8" thread_pool.keep_alive_time="5000" />
	<!-- our ping implementation which uses AWS lookup to find the prospective hosts -->
	<org.achievementnetwork.core.net.EC2_PING />
	<MERGE3 min_interval="5000" max_interval="30000" />
	<!-- failure detection and verification -->
	<FD_ALL />
	<VERIFY_SUSPECT timeout="1500" />
	<BARRIER />
	<!-- coordinator is the key-server that manages the encryption on the channel -->
	<ASYM_ENCRYPT encrypt_entire_message="true" sym_keylength="128" sym_algorithm="AES/ECB/PKCS5Padding"
		asym_keylength="512" asym_algorithm="RSA" />
	<!-- must be above the encrypt -->
	<pbcast.NAKACK2 xmit_interval="500" xmit_table_num_rows="100" xmit_table_msgs_per_row="2000"
		xmit_table_max_compaction_time="30000" max_msg_batch_size="500" use_mcast_xmit="false" discard_delivered_msgs="true" />
	<UNICAST3 xmit_interval="500" xmit_table_num_rows="100" xmit_table_msgs_per_row="2000"
		xmit_table_max_compaction_time="60000" conn_expiry_timeout="0" max_msg_batch_size="500" />
	<pbcast.STABLE desired_avg_gossip="50000" max_bytes="1m" />
	<!-- AUTH required by ASYM_ENCRYPT, must be below GMS, auth-value is replaced by JgroupsChannel at runtime -->
	<AUTH auth_class="org.jgroups.auth.MD5Token" auth_value="REPLACED" token_hash="MD5" />
	<pbcast.GMS print_local_addr="false" join_timeout="2000" view_bundling="true" />
	<!-- flow control for both unicast and multicast -->
	<UFC max_credits="1m" min_threshold="0.4" />
	<MFC max_credits="1m" min_threshold="0.4" />
	<!-- needs to be <= than 32k because of ec2 limitations, must also be less than the UDP max_bundle_size -->
	<FRAG2 frag_size="28k" />
	<!-- not sure if this is needed here or on the FORKs -->
	<pbcast.STATE_TRANSFER />
	<FORK />

</config>