| | |
| | | import org.opends.server.replication.protocol.DoneMsg; |
| | | import org.opends.server.replication.protocol.ECLUpdateMsg; |
| | | import org.opends.server.replication.protocol.Session; |
| | | import org.opends.server.replication.protocol.StartECLSessionMsg; |
| | | import org.opends.server.types.DebugLogLevel; |
| | | import org.opends.server.types.DirectoryException; |
| | | import org.opends.server.types.Entry; |
| | |
| | | |
| | | if (update == null) |
| | | { |
| | | if (session != null |
| | | && handler.getSearchPhase() != ECLServerHandler.INIT_PHASE) |
| | | if (session != null && handler.isInitPhaseDone()) |
| | | { |
| | | // session is null in pusherOnly mode |
| | | // Done is used to end phase 1 |
| | |
| | | handler.getReplicationServerId(), handler.getServerId())); |
| | | } |
| | | |
| | | if (handler.isPersistent() == StartECLSessionMsg.NON_PERSISTENT) |
| | | if (handler.isNonPersistent()) |
| | | { // publishing is normally stopped here... |
| | | break; |
| | | } |