That's fixed! Thanks Kiran.
Regards, Pierre-Arnaud On 31 mai 2011, at 13:25, Kiran Ayyagari wrote: > Have increased the sleep time and committed, let me know if the issue > is still there > > On Tue, May 31, 2011 at 2:18 PM, Pierre-Arnaud Marcelot <[email protected]> > wrote: >> Yeah, that's what I thought too looking quickly at the code. >> >> Tell me if I can be of any help (because I guess, you're not having it fail >> on your machine). >> >> Regards, >> Pierre-Arnaud >> >> On 31 mai 2011, at 10:30, Kiran Ayyagari wrote: >> >>> 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 >> >> > > > > -- > Kiran Ayyagari
