| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
| H A D | ListenerThread.java | 92 UpdateMsg updateMsg = null;
97 while (!shutdown.get() && ((updateMsg = repDomain.receive()) != null))
99 if (repDomain.processUpdate(updateMsg, shutdown))
101 repDomain.processUpdateDoneSynchronous(updateMsg);
105 if (updateMsg == null)
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
| H A D | ListenerThread.java | 92 UpdateMsg updateMsg = null;
97 while (!shutdown.get() && ((updateMsg = repDomain.receive()) != null))
99 if (repDomain.processUpdate(updateMsg, shutdown))
101 repDomain.processUpdateDoneSynchronous(updateMsg);
105 if (updateMsg == null)
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
| H A D | ListenerThread.java | 92 UpdateMsg updateMsg = null;
97 while (!shutdown.get() && ((updateMsg = repDomain.receive()) != null))
99 if (repDomain.processUpdate(updateMsg, shutdown))
101 repDomain.processUpdateDoneSynchronous(updateMsg);
105 if (updateMsg == null)
|
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ReplicaCursorTest.java | 67 final UpdateMsg updateMsg = new FakeUpdateMsg(timestamp++);
68 delegateCursor = new SequentialDBCursor(updateMsg);
73 assertThat(cursor.getRecord()).isSameAs(updateMsg);
97 final UpdateMsg updateMsg = new FakeUpdateMsg(timestamp++);
98 delegateCursor = new SequentialDBCursor(updateMsg);
104 assertThat(cursor.getRecord()).isSameAs(updateMsg);
118 final UpdateMsg updateMsg = new FakeUpdateMsg(timestamp++);
119 delegateCursor = new SequentialDBCursor(updateMsg);
124 assertThat(cursor.getRecord()).isSameAs(updateMsg);
|
| /forgerock/opendj2/src/server/org/opends/server/replication/server/ |
| H A D | ServerWriter.java | 109 final UpdateMsg updateMsg = replicationServerDomain.take(this.handler);
110 if (updateMsg == null)
117 else if (!isUpdateMsgFiltered(updateMsg))
120 session.publish(updateMsg);
121 if (updateMsg instanceof ReplicaOfflineMsg)
157 private boolean isUpdateMsgFiltered(UpdateMsg updateMsg) argument
176 updateMsg.getCSN().toString(),
187 updateMsg.getCSN().toString(),
205 updateMsg.getCSN().toString(),
|
| H A D | ServerReader.java | 116 final UpdateMsg updateMsg = (UpdateMsg) msg;
117 if (!isUpdateMsgFiltered(updateMsg))
119 handler.put(updateMsg);
253 private boolean isUpdateMsgFiltered(UpdateMsg updateMsg) argument
275 updateMsg.getCSN().toString(),
286 updateMsg.getCSN().toString(),
304 updateMsg.getCSN().toString(),
|
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ReplicaCursorTest.java | 67 final UpdateMsg updateMsg = new FakeUpdateMsg(timestamp++);
68 delegateCursor = new SequentialDBCursor(updateMsg);
73 assertThat(cursor.getRecord()).isSameAs(updateMsg);
97 final UpdateMsg updateMsg = new FakeUpdateMsg(timestamp++);
98 delegateCursor = new SequentialDBCursor(updateMsg);
104 assertThat(cursor.getRecord()).isSameAs(updateMsg);
118 final UpdateMsg updateMsg = new FakeUpdateMsg(timestamp++);
119 delegateCursor = new SequentialDBCursor(updateMsg);
124 assertThat(cursor.getRecord()).isSameAs(updateMsg);
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
| H A D | ServerWriter.java | 109 final UpdateMsg updateMsg = replicationServerDomain.take(this.handler);
110 if (updateMsg == null)
117 else if (!isUpdateMsgFiltered(updateMsg))
120 session.publish(updateMsg);
121 if (updateMsg instanceof ReplicaOfflineMsg)
157 private boolean isUpdateMsgFiltered(UpdateMsg updateMsg) argument
176 updateMsg.getCSN().toString(),
187 updateMsg.getCSN().toString(),
205 updateMsg.getCSN().toString(),
|
| H A D | ServerReader.java | 116 final UpdateMsg updateMsg = (UpdateMsg) msg;
117 if (!isUpdateMsgFiltered(updateMsg))
119 handler.put(updateMsg);
253 private boolean isUpdateMsgFiltered(UpdateMsg updateMsg) argument
275 updateMsg.getCSN().toString(),
286 updateMsg.getCSN().toString(),
304 updateMsg.getCSN().toString(),
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
| H A D | ServerWriter.java | 104 final UpdateMsg updateMsg = this.handler.take();
105 if (updateMsg == null)
112 else if (!isUpdateMsgFiltered(updateMsg))
115 session.publish(updateMsg);
116 if (updateMsg instanceof ReplicaOfflineMsg)
152 private boolean isUpdateMsgFiltered(UpdateMsg updateMsg) argument
170 updateMsg.getCSN(), handler.getBaseDN(), handler.getServerId(),
179 updateMsg.getCSN(), handler.getBaseDN(), handler.getServerId(),
196 updateMsg.getCSN(), handler.getBaseDN(), handler.getServerId(),
|
| H A D | ServerReader.java | 110 final UpdateMsg updateMsg = (UpdateMsg) msg;
111 if (!isUpdateMsgFiltered(updateMsg))
113 handler.put(updateMsg);
254 private boolean isUpdateMsgFiltered(UpdateMsg updateMsg) argument
275 handler.getReplicationServerId(), updateMsg.getCSN(),
284 handler.getReplicationServerId(), updateMsg.getCSN(),
301 handler.getReplicationServerId(), updateMsg.getCSN(),
|
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/ |
| H A D | ReplicaCursorTest.java | 68 final UpdateMsg updateMsg = new FakeUpdateMsg(timestamp++);
69 delegateCursor = new SequentialDBCursor(updateMsg);
74 assertThat(cursor.getRecord()).isSameAs(updateMsg);
98 final UpdateMsg updateMsg = new FakeUpdateMsg(timestamp++);
99 delegateCursor = new SequentialDBCursor(updateMsg);
105 assertThat(cursor.getRecord()).isSameAs(updateMsg);
119 final UpdateMsg updateMsg = new FakeUpdateMsg(timestamp++);
120 delegateCursor = new SequentialDBCursor(updateMsg);
125 assertThat(cursor.getRecord()).isSameAs(updateMsg);
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
| H A D | ECLUpdateMsg.java | 42 private final LDAPUpdateMsg updateMsg; field in class:ECLUpdateMsg
65 this.updateMsg = update;
117 this.updateMsg = (LDAPUpdateMsg)rmsg;
162 return updateMsg;
172 " updateMsg: " + updateMsg +
189 byte[] byteUpdateMsg = updateMsg.getBytes(protocolVersion);
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
| H A D | ECLUpdateMsg.java | 42 private final LDAPUpdateMsg updateMsg; field in class:ECLUpdateMsg
65 this.updateMsg = update;
117 this.updateMsg = (LDAPUpdateMsg)rmsg;
162 return updateMsg;
172 " updateMsg: " + updateMsg +
189 byte[] byteUpdateMsg = updateMsg.getBytes(protocolVersion);
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
| H A D | ECLUpdateMsg.java | 42 private final LDAPUpdateMsg updateMsg; field in class:ECLUpdateMsg
65 this.updateMsg = update;
117 this.updateMsg = (LDAPUpdateMsg)rmsg;
162 return updateMsg;
172 " updateMsg: " + updateMsg +
189 byte[] byteUpdateMsg = updateMsg.getBytes(protocolVersion);
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplayThread.java | 104 LDAPUpdateMsg updateMsg = updateToreplay.getUpdateMessage();
106 domain.replay(updateMsg, shutdown);
|
| H A D | PendingChanges.java | 215 LDAPUpdateMsg updateMsg = firstChange.getMsg();
218 domain.publish(updateMsg);
222 domain.getServerState().update(updateMsg.getChangeNumber());
|
| /forgerock/opendj2/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplayThread.java | 103 LDAPUpdateMsg updateMsg = updateToreplay.getUpdateMessage();
105 domain.replay(updateMsg, shutdown);
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplayThread.java | 104 LDAPUpdateMsg updateMsg = updateToreplay.getUpdateMessage();
106 domain.replay(updateMsg, shutdown);
|
| H A D | PendingChanges.java | 215 LDAPUpdateMsg updateMsg = firstChange.getMsg();
218 domain.publish(updateMsg);
222 domain.getServerState().update(updateMsg.getChangeNumber());
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplayThread.java | 104 LDAPUpdateMsg updateMsg = updateToreplay.getUpdateMessage();
106 domain.replay(updateMsg, shutdown);
|
| H A D | PendingChanges.java | 215 LDAPUpdateMsg updateMsg = firstChange.getMsg();
218 domain.publish(updateMsg);
222 domain.getServerState().update(updateMsg.getChangeNumber());
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplayThread.java | 103 LDAPUpdateMsg updateMsg = updateToreplay.getUpdateMessage();
105 domain.replay(updateMsg, shutdown);
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/ |
| H A D | ReplayThread.java | 97 LDAPUpdateMsg updateMsg = updateToreplay.getUpdateMessage();
99 domain.replay(updateMsg, shutdown);
|
| /forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ReplicaCursor.java | 145 final ReplicaOfflineMsg offlineMsg, final UpdateMsg updateMsg)
148 && updateMsg != null
149 && offlineMsg.getCSN().isOlderThanOrEqualTo(updateMsg.getCSN());
144 isReplicaOfflineMsgOutdated( final ReplicaOfflineMsg offlineMsg, final UpdateMsg updateMsg) argument
|