<commit_before>package org.jgroups.tests;


import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.jgroups.*;
import org.jgroups.util.Util;
import org.testng.annotations.AfterMethod;
import org.testng.annotations.BeforeMethod;
import org.testng.annotations.Test;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.locks.ReentrantLock;


/**
 * Test case modelling http://jira.jboss.com/jira/browse/JGRP-659
 * @author unknown
 * @version $Id: ConcurrentMemberTest.java,v 1.2 2008/04/25 07:07:58 belaban Exp $
 */
@Test(groups="temp", sequential=true)
public class ConcurrentMemberTest extends ChannelTestBase {
    private GroupManager coordinator=null;
    private List<GroupManager> managers=null;
    private static String GROUP="ConcurrentMemberTest";

    @BeforeMethod
    void beforeEachTest() throws Exception {
        coordinator=startCoordinator();
        managers=new ArrayList<GroupManager>();
    }

    @AfterMethod
    void afterEachTest() throws Exception {
        for(GroupManager manager : managers) {
            manager.shutdown();
            manager.join(20000); // NOTE: Have seen shutdown take roughly 15 seconds, so wait 20

            if(manager.isAlive()) {
                log.info("Attempted to join manager " + manager.getName() + ", but it is still running.  Failing Test.");
                throw new IllegalStateException("Unable to properly shutdown jgroups connection.");
            }<commit_msg>added group "vladimir"<commit_after>package org.jgroups.tests;


import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.jgroups.*;
import org.jgroups.util.Util;
import org.testng.annotations.AfterMethod;
import org.testng.annotations.BeforeMethod;
import org.testng.annotations.Test;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.locks.ReentrantLock;


/**
 * Test case modelling http://jira.jboss.com/jira/browse/JGRP-659
 * @author unknown
 * @version $Id: ConcurrentMemberTest.java,v 1.3 2008/05/29 12:28:35 belaban Exp $
 */
@Test(groups="vladimir", sequential=true)
public class ConcurrentMemberTest extends ChannelTestBase {
    private GroupManager coordinator=null;
    private List<GroupManager> managers=null;
    private static String GROUP="ConcurrentMemberTest";

    @BeforeMethod
    void beforeEachTest() throws Exception {
        coordinator=startCoordinator();
        managers=new ArrayList<GroupManager>();
    }

    @AfterMethod
    void afterEachTest() throws Exception {
        for(GroupManager manager : managers) {
            manager.shutdown();
            manager.join(20000); // NOTE: Have seen shutdown take roughly 15 seconds, so wait 20

            if(manager.isAlive()) {
                log.info("Attempted to join manager " + manager.getName() + ", but it is still running.  Failing Test.");
                throw new IllegalStateException("Unable to properly shutdown jgroups connection.");
            }
{'fraction_non_alphanumeric': 0.10578512396694215, 'fraction_numerical': 0.018512396694214877, 'mean_word_length': 3.619847328244275, 'pattern_counts': {'":': 0, '<': 7, '<?xml version=': 0, '>': 7, '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': '7656546', 'n_tokens_mistral': 895, 'n_tokens_neox': 817, 'n_words': 208}