Tests were pausing the wrong thread: change TimerThread.sleep() to Thread.sleep().
| | |
| | | openReplicationSession(baseDn, brokerId, 1000, replServerPort, 1000, |
| | | false); |
| | | |
| | | TimeThread.sleep(2000); |
| | | Thread.sleep(2000); |
| | | // send a sequence of add operation |
| | | |
| | | String addDn = BASEDN_STRING; |
| | |
| | | do |
| | | { |
| | | if (count++>0) |
| | | TimeThread.sleep(100); |
| | | Thread.sleep(100); |
| | | op = connection.processSearch( |
| | | ByteStringFactory.create("cn=monitor"), |
| | | SearchScope.SINGLE_LEVEL, |
| | |
| | | * CDDL HEADER END |
| | | * |
| | | * |
| | | * Portions Copyright 2006-2007 Sun Microsystems, Inc. |
| | | * Portions Copyright 2006-2008 Sun Microsystems, Inc. |
| | | */ |
| | | |
| | | package org.opends.server.replication; |
| | |
| | | broker.publish(modMsg); |
| | | |
| | | // check that the modify has not been applied |
| | | TimeThread.sleep(2000); |
| | | Thread.sleep(2000); |
| | | found = checkEntryHasAttribute(personWithUUIDEntry.getDN(), |
| | | "telephonenumber", "02 01 03 05", 10000, false); |
| | | if (found == true) |