Yeah, Emmanuel had the same issue yesterday, looks like a timing issue, will fix it
On Tue, May 31, 2011 at 1:30 PM, Pierre-Arnaud Marcelot <[email protected]> wrote: > Hi Kiran, > > Looks like this test does not pass here (tested this under two different > machines). > > Here's the output: >> Tests in error: >> >> testRebootConsumer(org.apache.directory.server.replication.ClientServerReplicationIT): >> Attempt to lookup non-existant entry: cn=user5,dc=example,dc=com >> >> Tests run: 303, Failures: 0, Errors: 1, Skipped: 5 > > > Regards, > Pierre-Arnaud > > On 30 mai 2011, at 13:59, [email protected] wrote: > >> Author: kayyagari >> Date: Mon May 30 11:59:34 2011 >> New Revision: 1129134 >> >> URL: http://svn.apache.org/viewvc?rev=1129134&view=rev >> Log: >> o added a test to check the replication of data to the client when the >> client goes offline and reboots after some activity on the master server >> >> Modified: >> >> directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java >> >> Modified: >> directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java >> URL: >> http://svn.apache.org/viewvc/directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java?rev=1129134&r1=1129133&r2=1129134&view=diff >> ============================================================================== >> --- >> directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java >> (original) >> +++ >> directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java >> Mon May 30 11:59:34 2011 >> @@ -67,11 +67,11 @@ public class ClientServerReplicationIT >> >> private static LdapServer consumerServer; >> >> - private SchemaManager schemaManager; >> + private static SchemaManager schemaManager; >> >> - private CoreSession providerSession; >> + private static CoreSession providerSession; >> >> - private CoreSession consumerSession; >> + private static CoreSession consumerSession; >> >> private static AtomicInteger entryCount = new AtomicInteger(); >> >> @@ -93,15 +93,6 @@ public class ClientServerReplicationIT >> } >> >> >> - @Before >> - public void accessFields() >> - { >> - schemaManager = >> providerServer.getDirectoryService().getSchemaManager(); >> - providerSession = >> providerServer.getDirectoryService().getAdminSession(); >> - consumerSession = >> consumerServer.getDirectoryService().getAdminSession(); >> - } >> - >> - >> @Test >> public void testInjectContextEntry() throws Exception >> { >> @@ -202,6 +193,32 @@ public class ClientServerReplicationIT >> } >> >> >> + @Test >> + public void testRebootConsumer() throws Exception >> + { >> + Entry provUser = createEntry(); >> + >> + providerSession.add( provUser ); >> + >> + waitAndCompareEntries( provUser.getDn() ); >> + >> + consumerServer.stop(); >> + >> + Dn deletedUserDn = provUser.getDn(); >> + providerSession.delete( deletedUserDn ); >> + >> + provUser = createEntry(); >> + Dn addedUserDn = provUser.getDn(); >> + providerSession.add( provUser ); >> + >> + startConsumer(); >> + >> + Thread.sleep( 2000 ); >> + assertFalse( consumerSession.exists( deletedUserDn ) ); >> + waitAndCompareEntries( addedUserDn ); >> + } >> + >> + >> private void waitAndCompareEntries( Dn dn ) throws Exception >> { >> // sleep for 2 sec (twice the refresh interval), just to let the >> first refresh request succeed >> @@ -263,6 +280,8 @@ public class ClientServerReplicationIT >> try >> { >> providerServer.start(); >> + schemaManager = >> providerServer.getDirectoryService().getSchemaManager(); >> + providerSession = >> providerServer.getDirectoryService().getAdminSession(); >> } >> catch( Exception e ) >> { >> @@ -274,6 +293,7 @@ public class ClientServerReplicationIT >> Thread t = new Thread( r ); >> t.setDaemon( true ); >> t.start(); >> + t.join(); >> } >> >> >> @@ -325,6 +345,7 @@ public class ClientServerReplicationIT >> try >> { >> consumerServer.start(); >> + >> DirectoryService ds = >> consumerServer.getDirectoryService(); >> >> Dn configDn = new Dn( ds.getSchemaManager(), >> "ads-replProviderId=localhost,ou=system" ); >> @@ -347,7 +368,8 @@ public class ClientServerReplicationIT >> provConfigEntry.add( "ads-replUserDn", >> config.getReplUserDn() ); >> provConfigEntry.add( "ads-replUserPassword", >> config.getReplUserPassword() ); >> >> - ds.getAdminSession().add( provConfigEntry ); >> + consumerSession = >> consumerServer.getDirectoryService().getAdminSession(); >> + consumerSession.add( provConfigEntry ); >> } >> catch( Exception e ) >> { >> @@ -359,5 +381,6 @@ public class ClientServerReplicationIT >> Thread t = new Thread( r ); >> t.setDaemon( true ); >> t.start(); >> + t.join(); >> } >> } >> >> > > -- Kiran Ayyagari
