Revision 6599
Added by Chris Jones over 12 years ago
| src/edu/ucsb/nceas/metacat/dataone/MNodeService.java | ||
|---|---|---|
| 125 | 125 |
* MNReplication.replicate() |
| 126 | 126 |
* |
| 127 | 127 |
*/ |
| 128 |
public class MNodeService extends D1NodeService implements MNAuthorization, MNCore, MNRead, MNReplication, MNStorage {
|
|
| 128 |
public class MNodeService extends D1NodeService |
|
| 129 |
implements MNAuthorization, MNCore, MNRead, MNReplication, MNStorage {
|
|
| 129 | 130 |
|
| 130 | 131 |
/* the logger instance */ |
| 131 | 132 |
private Logger logMetacat = null; |
| ... | ... | |
| 417 | 418 |
// TODO: switch credentials for the server retrieval? |
| 418 | 419 |
MNode mn = D1Client.getMN(sourceNode); |
| 419 | 420 |
CNode cn = D1Client.getCN(); |
| 420 |
|
|
| 421 |
long serialVersion = sysmeta.getSerialVersion().longValue(); |
|
| 421 | 422 |
InputStream object = null; |
| 422 | 423 |
|
| 423 | 424 |
try {
|
| ... | ... | |
| 452 | 453 |
|
| 453 | 454 |
try {
|
| 454 | 455 |
// call the CN as the MN to set the replication status |
| 455 |
cn.setReplicationStatus(null, pid, sourceNode, ReplicationStatus.COMPLETED); |
|
| 456 |
cn.setReplicationStatus(null, pid, sourceNode, ReplicationStatus.COMPLETED, serialVersion);
|
|
| 456 | 457 |
|
| 457 | 458 |
} catch (InvalidToken e) {
|
| 458 | 459 |
// TODO Auto-generated catch block |
| ... | ... | |
| 974 | 975 |
|
| 975 | 976 |
} |
| 976 | 977 |
|
| 978 |
/** |
|
| 979 |
* A method to notifiy the Member Node that the authoritative copy of |
|
| 980 |
* system metadata on the Coordinating Nodes has changed. |
|
| 981 |
* |
|
| 982 |
* @param session Session information that contains the identity of the |
|
| 983 |
* calling user as retrieved from the X.509 certificate |
|
| 984 |
* which must be traceable to the CILogon service. |
|
| 985 |
* @param serialVersion The serialVersion of the system metadata |
|
| 986 |
* @param dateSysMetaLastModified The time stamp for when the system metadata was changed |
|
| 987 |
* @throws NotImplemented |
|
| 988 |
* @throws ServiceFailure |
|
| 989 |
* @throws NotAuthorized |
|
| 990 |
* @throws InvalidRequest |
|
| 991 |
* @throws InvalidToken |
|
| 992 |
*/ |
|
| 993 |
public void systemMetadataChanged(Session session, Identifier pid, |
|
| 994 |
long serialVersion, Date dateSysMetaLastModified) |
|
| 995 |
throws NotImplemented, ServiceFailure, NotAuthorized, InvalidRequest, |
|
| 996 |
InvalidToken {
|
|
| 997 |
|
|
| 998 |
} |
|
| 999 |
|
|
| 977 | 1000 |
} |
Also available in: Unified diff
Include the serialVersion in the call to CN.setReplicationStatus() after replicating data.