directory-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pierre-Arnaud Marcelot ...@marcelot.net>
Subject Re: svn commit: r1129134 - /directory/apacheds/trunk/server-integ/src/test/java/org/apache/directory/server/replication/ClientServerReplicationIT.java
Date Tue, 31 May 2011 08:00:47 GMT
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, kayyagari@apache.org 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();
>     }
> }
> 
> 


Mime
View raw message