| | |
| | | * |
| | | * Copyright 2006-2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2013-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC |
| | | */ |
| | | package org.opends.server.replication; |
| | | |
| | |
| | | import org.opends.server.protocols.internal.InternalClientConnection; |
| | | import org.opends.server.replication.protocol.AddMsg; |
| | | import org.opends.server.replication.protocol.ReplicationMsg; |
| | | import org.opends.server.replication.protocol.UpdateMsg; |
| | | import org.opends.server.replication.service.ReplicationBroker; |
| | | import org.opends.server.types.Entry; |
| | | import org.opends.server.types.InitializationException; |
| | |
| | | |
| | | |
| | | /** Stress test from LDAP server to client using the ReplicationBroker API. */ |
| | | @Test(enabled=false, groups="slow") |
| | | @Test |
| | | public void fromServertoBroker() throws Exception |
| | | { |
| | | logger.error(LocalizableMessage.raw("Starting replication StressTest : fromServertoBroker")); |
| | |
| | | { |
| | | break; |
| | | } |
| | | if (msg instanceof UpdateMsg) |
| | | { |
| | | // Acknowledge the flow control window, otherwise the replication |
| | | // server stops sending after windowSize messages. |
| | | broker.updateWindowAfterReplay(); |
| | | } |
| | | count ++; |
| | | } |
| | | } catch (Exception e) |