Revision 7179
Added by Chris Jones over 12 years ago
| src/edu/ucsb/nceas/metacat/dataone/CNodeService.java | ||
|---|---|---|
| 618 | 618 |
nodeSubject.getValue() + " and " + subject.getValue()); |
| 619 | 619 |
if ( nodeSubject.equals(subject) ) { // subject of session == target node subject
|
| 620 | 620 |
|
| 621 |
// lastly limit to COMPLETED and FAILED status updates from MNs only |
|
| 621 |
// lastly limit to COMPLETED, INVALIDATED, |
|
| 622 |
// and FAILED status updates from MNs only |
|
| 622 | 623 |
if ( status == ReplicationStatus.COMPLETED || |
| 624 |
status == ReplicationStatus.INVALIDATED || |
|
| 623 | 625 |
status == ReplicationStatus.FAILED) {
|
| 624 | 626 |
allowed = true; |
| 625 | 627 |
break; |
| ... | ... | |
| 678 | 680 |
systemMetadata.setSerialVersion(systemMetadata.getSerialVersion().add(BigInteger.ONE)); |
| 679 | 681 |
systemMetadata.setDateSysMetadataModified(Calendar.getInstance().getTime()); |
| 680 | 682 |
HazelcastService.getInstance().getSystemMetadataMap().put(systemMetadata.getIdentifier(), systemMetadata); |
| 681 |
|
|
| 683 |
|
|
| 684 |
if ( status != ReplicationStatus.QUEUED && status != ReplicationStatus.REQUESTED) {
|
|
| 685 |
|
|
| 686 |
logMetacat.trace("METRICS:\tREPLICATION:\tEND REQUEST:\tPID:\t" + pid.getValue() +
|
|
| 687 |
"\tNODE:\t" + targetNode.getValue() + |
|
| 688 |
"\tSIZE:\t" + systemMetadata.getSize().intValue()); |
|
| 689 |
|
|
| 690 |
logMetacat.trace("METRICS:\tREPLICATION:\t" + status.toString().toUpperCase() +
|
|
| 691 |
"\tPID:\t" + pid.getValue() + |
|
| 692 |
"\tNODE:\t" + targetNode.getValue() + |
|
| 693 |
"\tSIZE:\t" + systemMetadata.getSize().intValue()); |
|
| 694 |
} |
|
| 695 |
|
|
| 682 | 696 |
if ( status == ReplicationStatus.FAILED && failure != null ) {
|
| 683 | 697 |
logMetacat.warn("Replication failed for identifier " + pid.getValue() +
|
| 684 | 698 |
" on target node " + targetNode + ". The exception was: " + |
Also available in: Unified diff
Add a few logging statemnts for round trip replication metrics.