<commit_before>// $Id: DistributedQueueConcurrencyTest.java,v 1.1 2003/10/15 16:15:09 rds13 Exp $

package org.jgroups.blocks;

import java.util.Vector;

import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;

import org.apache.log4j.Logger;
import org.jgroups.log.Trace;
import org.jgroups.util.Util;

/**
 * This class setup multiple DistributedQueue, some handles by a reader thread
 * others by a writer thread.
 * @author <NAME>
 */
public class DistributedQueueConcurrencyTest extends TestCase implements ICounter
{
    protected static int items = 0;

	final int NUM_CLIENTS = 10;
    final int NUM_ITEMS = 10;
    final int REPEAT_TEST= 5;

    static Logger logger = Logger.getLogger(DistributedQueueConcurrencyTest.class.getName());
    String props;

    public DistributedQueueConcurrencyTest(String testName)
    {
        super(testName);
    }

    public static Test suite()
    {
        return new TestSuite(DistributedQueueConcurrencyTest.class);
    }

    protected DistributedQueue queue1;
    protected DistributedQueue queue2;
    protected DistributedQueue queue3;

	protected DistributedQueue queue;
	protected DistributedQueue queuePut;

    public void setUp() throws Exception
    {

               props =
                   "UDP(mcast_recv_buf_size=80000;mcast_send_buf_size=150000;mcast_port=45566;"<commit_msg>set default to not repeat test<commit_after>// $Id: DistributedQueueConcurrencyTest.java,v 1.2 2003/10/20 14:38:57 rds13 Exp $

package org.jgroups.blocks;

import java.util.Vector;

import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;

import org.apache.log4j.Logger;
import org.jgroups.log.Trace;
import org.jgroups.util.Util;

/**
 * This class setup multiple DistributedQueue, some handles by a reader thread
 * others by a writer thread.
 * @author <NAME>
 */
public class DistributedQueueConcurrencyTest extends TestCase implements ICounter
{
    protected static int items = 0;

    final int NUM_CLIENTS = 10;
    final int NUM_ITEMS = 10;
    final int REPEAT_TEST= 1;

    static Logger logger = Logger.getLogger(DistributedQueueConcurrencyTest.class.getName());
    String props;

    public DistributedQueueConcurrencyTest(String testName)
    {
        super(testName);
    }

    public static Test suite()
    {
        return new TestSuite(DistributedQueueConcurrencyTest.class);
    }

    protected DistributedQueue queue1;
    protected DistributedQueue queue2;
    protected DistributedQueue queue3;

    protected DistributedQueue queue;
    protected DistributedQueue queuePut;

    public void setUp() throws Exception
    {

               props =
                   "UDP(mcast_recv_buf_size=80000;mcast_send_buf_size=150000;mcast_port=45566;"
{'fraction_non_alphanumeric': 0.07659269863994274, 'fraction_numerical': 0.031496062992125984, 'mean_word_length': 3.7453310696095077, 'pattern_counts': {'":': 0, '<': 5, '<?xml version=': 0, '>': 5, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3872963', 'n_tokens_mistral': 884, 'n_tokens_neox': 789, 'n_words': 214}